快递100监听问题处理

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/controller/logistics/LogisticsInfosController.java

@@ -2,8 +2,10 @@ package com.fjhx.victoriatourist.controller.logistics;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.fjhx.kd100.util.KD100Result;
+import com.fjhx.kd100.util.KD100Util;
 import com.fjhx.victoriatourist.entity.logistics.dto.LogisticsInfosDto;
 import com.fjhx.victoriatourist.entity.logistics.dto.LogisticsInfosSelectDto;
+import com.fjhx.victoriatourist.entity.logistics.po.LogisticsInfos;
 import com.fjhx.victoriatourist.entity.logistics.vo.LogisticsInfosVo;
 import com.fjhx.victoriatourist.service.logistics.LogisticsInfosService;
 import com.ruoyi.common.core.domain.BaseSelectDto;
@@ -103,4 +105,15 @@ public class LogisticsInfosController {
         return logisticsInfosService.getDepts();
     }
 
+    @PostMapping("/test")
+    public void test(@RequestBody List<LogisticsInfosDto> dtos){
+        for (LogisticsInfosDto dto : dtos) {
+            KD100Util.monitor(dto.getLogisticsCompanyCode(),dto.getCode(),dto.getBusinessId(),dto.getBusinessType(), LogisticsInfos.class);
+            try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+        }
+    }
 }

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/deliver/impl/DeliverGoodsServiceImpl.java

@@ -197,6 +197,7 @@ public class DeliverGoodsServiceImpl extends ServiceImpl<DeliverGoodsMapper, Del
         DynamicDataSourceContextHolder.push(SourceConstant.KD100);
         Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 1, LogisticsInfos.class).getState();
         DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setIsKd100(1);
         logisticsInfos.setLogisticsStatus(state);
 
         logisticsInfosService.save(logisticsInfos);

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/jd/impl/JdBackServiceImpl.java

@@ -148,6 +148,7 @@ public class JdBackServiceImpl extends ServiceImpl<JdBackMapper, JdBack> impleme
         Integer state = KD100Util.monitor(jdBackDto.getLogisticsCompanyCode(), jdBackDto.getLogisticsCode(), jdBackDto.getId(), 4, LogisticsInfos.class).getState();
         DynamicDataSourceContextHolder.poll();
         logisticsInfos.setLogisticsStatus(state);
+        logisticsInfos.setIsKd100(1);
         logisticsInfosService.updateById(logisticsInfos);
 
         /**
@@ -345,6 +346,7 @@ public class JdBackServiceImpl extends ServiceImpl<JdBackMapper, JdBack> impleme
             DynamicDataSourceContextHolder.push(SourceConstant.KD100);
             Integer state = KD100Util.monitor(logisticsInfo.getLogisticsCompanyCode(), logisticsInfo.getCode(), logisticsInfo.getId(), 4, LogisticsInfos.class).getState();
             DynamicDataSourceContextHolder.poll();
+            logisticsInfo.setIsKd100(1);
             logisticsInfo.setLogisticsStatus(state);
 
             logisticsInfoList.add(logisticsInfo);

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/jd/impl/JdOrderServiceImpl.java

@@ -407,6 +407,7 @@ public class JdOrderServiceImpl extends ServiceImpl<JdOrderMapper, JdOrder> impl
         DynamicDataSourceContextHolder.push(SourceConstant.KD100);
         Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 2, LogisticsInfos.class).getState();
         DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setIsKd100(1);
         logisticsInfos.setLogisticsStatus(state);
 
         logisticsInfosService.save(logisticsInfos);

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/logistics/impl/LogisticsInfosServiceImpl.java

@@ -142,6 +142,7 @@ public class LogisticsInfosServiceImpl extends ServiceImpl<LogisticsInfosMapper,
             DynamicDataSourceContextHolder.push(SourceConstant.KD100);
             Integer state = KD100Util.monitor(logisticsInfosDto.getLogisticsCompanyCode(), logisticsInfosDto.getCode(), logisticsInfosId, 1, LogisticsInfos.class).getState();
             logisticsInfosDto.setLogisticsStatus(state);
+            logisticsInfosDto.setIsKd100(1);
             DynamicDataSourceContextHolder.poll();
         }
         this.save(logisticsInfosDto);
@@ -169,6 +170,15 @@ public class LogisticsInfosServiceImpl extends ServiceImpl<LogisticsInfosMapper,
 
     @Override
     public void edit(LogisticsInfosDto logisticsInfosDto) {
+        if (logisticsInfosDto.getIsKd100() == 1) {
+            //发起快递100订阅
+            DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+            Integer state = KD100Util.monitor(logisticsInfosDto.getLogisticsCompanyCode(), logisticsInfosDto.getCode(), logisticsInfosDto.getId(), logisticsInfosDto.getBusinessType(), LogisticsInfos.class).getState();
+            logisticsInfosDto.setLogisticsStatus(state);
+            logisticsInfosDto.setIsKd100(1);
+            DynamicDataSourceContextHolder.poll();
+        }
+
         this.updateById(logisticsInfosDto);
     }
 

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/order/impl/OrderInfoServiceImpl.java

@@ -270,6 +270,7 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
         Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 3, LogisticsInfos.class).getState();
         DynamicDataSourceContextHolder.poll();
         logisticsInfos.setLogisticsStatus(state);
+        logisticsInfos.setIsKd100(1);
 
         logisticsInfosService.save(logisticsInfos);
 
@@ -304,6 +305,7 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
         Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 3, LogisticsInfos.class).getState();
         DynamicDataSourceContextHolder.poll();
         logisticsInfos.setLogisticsStatus(state);
+        logisticsInfos.setIsKd100(1);
 
         logisticsInfosService.save(logisticsInfos);
 

hx-victoriatourist/src/main/java/com/fjhx/victoriatourist/service/purchase/impl/PurchaseBackServiceImpl.java

@@ -223,6 +223,7 @@ public class PurchaseBackServiceImpl extends ServiceImpl<PurchaseBackMapper, Pur
         Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 5, LogisticsInfos.class).getState();
         DynamicDataSourceContextHolder.poll();
         logisticsInfos.setLogisticsStatus(state);
+        logisticsInfos.setIsKd100(1);
 
         logisticsInfosService.save(logisticsInfos);