积分管理

src/main/java/com/poteviohealth/cgp/integration/service/impl/IntegralDetailServiceImpl.java

@@ -3,6 +3,7 @@ package com.poteviohealth.cgp.integration.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.poteviohealth.cgp.common.filter.MiniJwtVO;
 import com.poteviohealth.cgp.common.filter.TokenContext;
 import com.poteviohealth.cgp.common.integrated.customer.model.CustomerIntegration;
 import com.poteviohealth.cgp.common.model.CommonPage;
@@ -18,6 +19,8 @@ import com.poteviohealth.cgp.integration.service.IIntegralDetailService;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.beans.factory.config.YamlPropertiesFactoryBean;
 import org.springframework.core.io.ClassPathResource;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -108,6 +111,7 @@ public class IntegralDetailServiceImpl extends BaseServiceImpl<IntegralDetailMap
 
         List<IntegralDetail> list = IntegralConverter.INSTANCE.model2FeginDTO(customerIntegration);
         for (IntegralDetail detail : list) {
+            createOperator(detail.getOperatorId());
             detail.setIntegralDetailId(CgpTool.generateKey());
         }
         return VaultsResponse.success(super.saveBatch(list));
@@ -128,4 +132,11 @@ public class IntegralDetailServiceImpl extends BaseServiceImpl<IntegralDetailMap
         return super.commonPage(page, orderQueryWrapper);
     }
 
+    private void createOperator(Integer operatorId){
+        MiniJwtVO jwtVO = new MiniJwtVO();
+        jwtVO.setOperatorId(operatorId);
+        UsernamePasswordAuthenticationToken authentication = new UsernamePasswordAuthenticationToken(jwtVO, null, null);
+        SecurityContextHolder.getContext().setAuthentication(authentication);
+    }
+
 }