|
@@ -1,8 +1,11 @@
|
|
|
package com.zfire.jiasm.syncdata.base;
|
|
|
|
|
|
+import com.zfire.jiasm.syncdata.constant.DictTypeEnum;
|
|
|
import com.zfire.jiasm.syncdata.constant.RedisConstant;
|
|
|
import com.zfire.jiasm.syncdata.plus.entity.Belongcompany;
|
|
|
import com.zfire.jiasm.syncdata.plus.entity.Brand;
|
|
|
+import com.zfire.jiasm.syncdata.plus.entity.OrderBase;
|
|
|
+import com.zfire.jiasm.syncdata.plus.entity.SysDict;
|
|
|
import com.zfire.jiasm.syncdata.plus.service.*;
|
|
|
import com.zfire.jiasm.syncdata.utils.RedisUtil;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
@@ -31,9 +34,29 @@ public class BaseService {
|
|
|
BrandService brandService;
|
|
|
@Resource
|
|
|
RedisUtil redis;
|
|
|
+ @Resource
|
|
|
+ SysDictService sysDictService;
|
|
|
+
|
|
|
|
|
|
+ // 提取消息渠道ID 消息渠道名称
|
|
|
+ public String getxxqd(String xxqd){
|
|
|
+ String phone = "电话";
|
|
|
+ String dictcode = "";
|
|
|
+ if (redis.hasKey(RedisConstant.XXQD_CODE + phone)) {
|
|
|
+ dictcode = (String) redis.get(RedisConstant.XXQD_CODE + phone);
|
|
|
+ } else {
|
|
|
+ SysDict sysDict = sysDictService.lambdaQuery().
|
|
|
+ eq(SysDict::getDictType, DictTypeEnum.DICT_TYPE_XXQD_CHANNEL.getCode())
|
|
|
+ .eq(SysDict::getDictValue,xxqd).last("limit 1").one();
|
|
|
+ if (sysDict != null){
|
|
|
+ dictcode = sysDict.getDictCode();
|
|
|
|
|
|
+ redis.set(RedisConstant.XXQD_CODE + phone, dictcode,RedisConstant.BRAND_CODE_TIME_LENGTH);
|
|
|
+ }
|
|
|
+ }
|
|
|
|
|
|
+ return dictcode;
|
|
|
+ }
|
|
|
|
|
|
public Brand getBrand() {
|
|
|
Brand brand = new Brand();
|