Просмотр исходного кода

fix: 接收保险通知消息,修改订单保险购买状态

luofeiyun 1 неделя назад
Родитель
Сommit
02e15f48a2

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

@@ -6,6 +6,7 @@ import com.yc.ship.module.trade.controller.admin.notify.vo.NotifyInsuranceReqVO;
 import com.yc.ship.module.trade.dal.dataobject.insurance.InsuranceDO;
 import com.yc.ship.module.trade.dal.dataobject.insurance.InsuranceDO;
 import com.yc.ship.module.trade.dal.mysql.insurance.InsuranceMapper;
 import com.yc.ship.module.trade.dal.mysql.insurance.InsuranceMapper;
 import com.yc.ship.module.trade.enums.InsuranceStatusEnum;
 import com.yc.ship.module.trade.enums.InsuranceStatusEnum;
+import com.yc.ship.module.trade.service.order.TradeOrderRepositoryService;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
 import javax.annotation.Resource;
 import javax.annotation.Resource;
@@ -20,6 +21,8 @@ public class NotifyServiceImpl implements NotifyService {
 
 
     @Resource
     @Resource
     private InsuranceMapper insuranceMapper;
     private InsuranceMapper insuranceMapper;
+    @Resource
+    private TradeOrderRepositoryService tradeOrderRepositoryService;
     @Override
     @Override
     public Boolean notifyInsurance(NotifyInsuranceReqVO reqVO) {
     public Boolean notifyInsurance(NotifyInsuranceReqVO reqVO) {
         String status = reqVO.getStatus();
         String status = reqVO.getStatus();
@@ -40,10 +43,12 @@ public class NotifyServiceImpl implements NotifyService {
             }
             }
 //            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
 //            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
 //            insuranceDO.setInsuranceEffectDate(LocalDateTime.parse(successDate,formatter));
 //            insuranceDO.setInsuranceEffectDate(LocalDateTime.parse(successDate,formatter));
-            insuranceMapper.updateById(insuranceDO);
+
         }else if ("FAIL".equals(status)) {
         }else if ("FAIL".equals(status)) {
             insuranceDO.setInsuranceStatus(InsuranceStatusEnum.FAIL.getValue());
             insuranceDO.setInsuranceStatus(InsuranceStatusEnum.FAIL.getValue());
         }
         }
+        insuranceMapper.updateById(insuranceDO);
+        tradeOrderRepositoryService.updateOrderInsureStatus(insuranceDO.getOrderId(),insuranceDO.getInsuranceStatus());
         return true;
         return true;
     }
     }
 }
 }