Merge remote-tracking branch 'origin/main'

ship-module-trade/ship-module-trade-biz/src/main/java/com/yc/ship/module/trade/service/notify/NotifyServiceImpl.java

@@ -1,5 +1,6 @@
 package com.yc.ship.module.trade.service.notify;
 
+import com.yc.ship.framework.tenant.core.util.TenantUtils;
 import com.yc.ship.module.system.api.notify.NotifyMessageSendApi;
 import com.yc.ship.module.system.api.notify.dto.NotifySendSingleToUserReqDTO;
 import com.yc.ship.module.trade.controller.admin.notify.vo.NotifyInsuranceReqVO;
@@ -28,44 +29,46 @@ public class NotifyServiceImpl implements NotifyService {
     private NotifyMessageSendApi notifyMessageSendApi;
     @Override
     public Boolean notifyInsurance(NotifyInsuranceReqVO reqVO) {
-        String status = reqVO.getStatus();
-        String externalPolicyNumber = reqVO.getExternalPolicyNumber();
-        String policyNo = reqVO.getPolicyNo();
-        String downloadUrl = reqVO.getDownloadUrl();
-        String msg = reqVO.getMsg();
+        TenantUtils.execute(1L, () -> {
+            String status = reqVO.getStatus();
+            String externalPolicyNumber = reqVO.getExternalPolicyNumber();
+            String policyNo = reqVO.getPolicyNo();
+            String downloadUrl = reqVO.getDownloadUrl();
+            String msg = reqVO.getMsg();
 //        String successDate = reqVO.getSuccessDate();
-        Long id = Long.valueOf(externalPolicyNumber);
-        String service = reqVO.getService();
-        InsuranceDO insuranceDO = insuranceMapper.selectById(id);
-        if("SUCCESS".equals(status)) {
-            insuranceDO.setPolicyNo(policyNo);
-            insuranceDO.setElectronicPolicy(downloadUrl);
-            if("applyTeam".equals(service)) {
-                insuranceDO.setInsuranceStatus(InsuranceStatusEnum.SUCCESS.getValue());
-            }else if ("cancelTeam".equals(service)) {
-                insuranceDO.setInsuranceStatus(InsuranceStatusEnum.CANCELLED.getValue());
-            }
+            Long id = Long.valueOf(externalPolicyNumber);
+            String service = reqVO.getService();
+            InsuranceDO insuranceDO = insuranceMapper.selectById(id);
+            if("SUCCESS".equals(status)) {
+                insuranceDO.setPolicyNo(policyNo);
+                insuranceDO.setElectronicPolicy(downloadUrl);
+                if("applyTeam".equals(service)) {
+                    insuranceDO.setInsuranceStatus(InsuranceStatusEnum.SUCCESS.getValue());
+                }else if ("cancelTeam".equals(service)) {
+                    insuranceDO.setInsuranceStatus(InsuranceStatusEnum.CANCELLED.getValue());
+                }
 //            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
 //            insuranceDO.setInsuranceEffectDate(LocalDateTime.parse(successDate,formatter));
 
-        }else if ("FAIL".equals(status)) {
-            insuranceDO.setInsuranceStatus(InsuranceStatusEnum.FAIL.getValue());
-            // 发送站内信
-            TradeOrderDO orderDO = tradeOrderRepositoryService.getById(insuranceDO.getOrderId());
-            String insuranceNo = insuranceDO.getInsuranceNo();
+            }else if ("FAIL".equals(status)) {
+                insuranceDO.setInsuranceStatus(InsuranceStatusEnum.FAIL.getValue());
+                // 发送站内信
+                TradeOrderDO orderDO = tradeOrderRepositoryService.getById(insuranceDO.getOrderId());
+                String insuranceNo = insuranceDO.getInsuranceNo();
 
-            Map<String,Object> templateData = new HashMap<>();
-            templateData.put("orderNo",insuranceNo);
-            templateData.put("msg",msg);
-            NotifySendSingleToUserReqDTO reqDTO = new NotifySendSingleToUserReqDTO();
-            reqDTO.setUserId(Long.parseLong(orderDO.getCreator()));
-            reqDTO.setTemplateParams(templateData);
-            reqDTO.setTemplateCode("send_insurance_fail");
-            notifyMessageSendApi.sendSingleMessageToMember(reqDTO);
-            insuranceDO.setResMsg(msg);
-        }
-        insuranceMapper.updateById(insuranceDO);
-        tradeOrderRepositoryService.updateOrderInsureStatus(insuranceDO.getOrderId(),insuranceDO.getInsuranceStatus());
+                Map<String,Object> templateData = new HashMap<>();
+                templateData.put("orderNo",insuranceNo);
+                templateData.put("msg",msg);
+                NotifySendSingleToUserReqDTO reqDTO = new NotifySendSingleToUserReqDTO();
+                reqDTO.setUserId(Long.parseLong(orderDO.getCreator()));
+                reqDTO.setTemplateParams(templateData);
+                reqDTO.setTemplateCode("send_insurance_fail");
+                notifyMessageSendApi.sendSingleMessageToMember(reqDTO);
+                insuranceDO.setResMsg(msg);
+            }
+            insuranceMapper.updateById(insuranceDO);
+            tradeOrderRepositoryService.updateOrderInsureStatus(insuranceDO.getOrderId(),insuranceDO.getInsuranceStatus());
+        });
         return true;
     }
 }