push

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/CommissionServiceImpl.java

@@ -2,6 +2,7 @@ package com.yd.csf.service.service.impl;
 
 
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.yd.auth.core.dto.AuthUserDto;
 import com.yd.auth.core.dto.AuthUserDto;
 import com.yd.auth.core.utils.SecurityUtil;
 import com.yd.auth.core.utils.SecurityUtil;
@@ -10,11 +11,13 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yd.base.feign.client.exchangerate.ApiExchangeRateFeignClient;
 import com.yd.base.feign.client.exchangerate.ApiExchangeRateFeignClient;
+import com.yd.common.constant.RedisConstants;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.ResultCode;
 import com.yd.common.enums.ResultCode;
 import com.yd.common.exception.BusinessException;
 import com.yd.common.exception.BusinessException;
 import com.yd.common.result.Result;
 import com.yd.common.result.Result;
 import com.yd.common.utils.RandomStringGenerator;
 import com.yd.common.utils.RandomStringGenerator;
+import com.yd.common.utils.RedisUtil;
 import com.yd.csf.service.component.CommissionAsyncService;
 import com.yd.csf.service.component.CommissionAsyncService;
 import com.yd.csf.service.component.ReceivableService;
 import com.yd.csf.service.component.ReceivableService;
 import com.yd.csf.service.dto.*;
 import com.yd.csf.service.dto.*;
@@ -28,6 +31,7 @@ import com.yd.csf.service.vo.CommissionStatisticsVO;
 import com.yd.csf.service.vo.CommissionVO;
 import com.yd.csf.service.vo.CommissionVO;
 import com.yd.insurance.base.feign.client.insurancereconciliationcompany.ApiInsuranceReconciliationCompanyFeignClient;
 import com.yd.insurance.base.feign.client.insurancereconciliationcompany.ApiInsuranceReconciliationCompanyFeignClient;
 import com.yd.insurance.base.feign.request.insurancereconciliationcompany.ApiInsuranceReconciliationCompanyPageRequest;
 import com.yd.insurance.base.feign.request.insurancereconciliationcompany.ApiInsuranceReconciliationCompanyPageRequest;
+import com.yd.user.feign.response.sysdict.GetDictItemListByDictTypeResponse;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.collections4.MapUtils;
@@ -83,6 +87,8 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
     private ApiExchangeRateFeignClient apiExchangeRateFeignClient;
     private ApiExchangeRateFeignClient apiExchangeRateFeignClient;
     @Resource
     @Resource
     private ApiInsuranceReconciliationCompanyFeignClient apiInsuranceReconciliationCompanyFeignClient;
     private ApiInsuranceReconciliationCompanyFeignClient apiInsuranceReconciliationCompanyFeignClient;
+    @Resource
+    private RedisUtil redisUtil;
 
 
 
 
     @Override
     @Override
@@ -813,6 +819,15 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
     @Override
     @Override
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     public List<Commission> addCommissionBatch(List<CommissionAddRequest> customerAddRequestList) {
     public List<Commission> addCommissionBatch(List<CommissionAddRequest> customerAddRequestList) {
+        //查询redis缓存的字典列表信息
+        List<GetDictItemListByDictTypeResponse> dictTypeResponses = redisUtil.getCacheObject(RedisConstants.DICT_LIST);
+        log.info("addCommissionBatch========查询redis缓存的字典列表信息======,{}", JSON.toJSONString(dictTypeResponses));
+        if (!CollectionUtils.isNotEmpty(dictTypeResponses)) {
+            String label = GetDictItemListByDictTypeResponse.getItemLabel(dictTypeResponses,
+                    "csf_commission_type","销售佣金");
+            log.info("GetDictItemListByDictTypeResponse.getItemLabel=============,{}",label);
+        }
+
         if (CollectionUtils.isEmpty(customerAddRequestList)) {
         if (CollectionUtils.isEmpty(customerAddRequestList)) {
             throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "入账数据不能为空");
             throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "入账数据不能为空");
         }
         }