快递100监听问题处理

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

@@ -5,12 +5,14 @@ import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.dynamic.datasource.annotation.DSTransactional;
+import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.fjhx.common.constant.SourceConstant;
 import com.fjhx.common.utils.Assert;
 import com.fjhx.item.entity.product.po.ProductInfo;
 import com.fjhx.item.service.product.ProductInfoService;
+import com.fjhx.kd100.util.KD100Util;
 import com.fjhx.purchase.entity.arrival.po.ArrivalDetail;
 import com.fjhx.purchase.entity.arrival.vo.ArrivalDetailVo;
 import com.fjhx.purchase.entity.purchase.po.Purchase;
@@ -188,6 +190,13 @@ public class DeliverGoodsServiceImpl extends ServiceImpl<DeliverGoodsMapper, Del
         logisticsInfos.setLogisticsCompanyCode(deliverGoodsDto.getLogisticsCompanyCode());
         logisticsInfos.setIsKd100(0);
         logisticsInfos.setPurchaseId(purchase.getId());
+
+        //发起快递100订阅
+        DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+        Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 1, LogisticsInfos.class).getState();
+        DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setLogisticsStatus(state);
+
         logisticsInfosService.save(logisticsInfos);
 
         List<DeliverGoodsDetails> deliverGoodsDetailsList = deliverGoodsDto.getDeliverGoodsDetailsList();

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

@@ -339,6 +339,13 @@ public class JdBackServiceImpl extends ServiceImpl<JdBackMapper, JdBack> impleme
             logisticsInfo.setInStockStatus(10);
             logisticsInfo.setLogisticsCompanyCode("jingdongkuaiyun");//物流公司编码
             logisticsInfo.setWarehouseId(warehouseId);
+
+            //发起快递100订阅
+            DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+            Integer state = KD100Util.monitor(logisticsInfo.getLogisticsCompanyCode(), logisticsInfo.getCode(), logisticsInfo.getId(), 4, LogisticsInfos.class).getState();
+            DynamicDataSourceContextHolder.poll();
+            logisticsInfo.setLogisticsStatus(state);
+
             logisticsInfoList.add(logisticsInfo);
         }
         logisticsInfosService.saveBatch(logisticsInfoList);

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

@@ -15,6 +15,7 @@ import com.fjhx.item.service.product.ProductInfoService;
 import com.fjhx.item.util.excel.util.ExcelUtil;
 import com.fjhx.kd100.entity.company.po.CompanyInfo;
 import com.fjhx.kd100.service.company.CompanyInfoService;
+import com.fjhx.kd100.util.KD100Util;
 import com.fjhx.victoriatourist.entity.abnormal.po.AbnormalInfo;
 import com.fjhx.victoriatourist.entity.jd.bo.JdOrderExcelImportBo;
 import com.fjhx.victoriatourist.entity.jd.dto.JdOrderDto;
@@ -400,6 +401,13 @@ public class JdOrderServiceImpl extends ServiceImpl<JdOrderMapper, JdOrder> impl
         logisticsInfos.setWarehouseId(jdOrderDto.getOutWarehouseId());
         logisticsInfos.setReservationCode(jdOrderDto.getReservationCode());
         logisticsInfos.setIsKd100(0);
+
+        //发起快递100订阅
+        DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+        Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 2, LogisticsInfos.class).getState();
+        DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setLogisticsStatus(state);
+
         logisticsInfosService.save(logisticsInfos);
 
         List<LogisticsDetails> logisticsDetailsList = new ArrayList<>();

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

@@ -14,6 +14,7 @@ import com.fjhx.customer.service.customer.CustomerService;
 import com.fjhx.item.service.product.ProductInfoService;
 import com.fjhx.kd100.entity.company.po.CompanyInfo;
 import com.fjhx.kd100.service.company.CompanyInfoService;
+import com.fjhx.kd100.util.KD100Util;
 import com.fjhx.victoriatourist.entity.logistics.po.LogisticsDetails;
 import com.fjhx.victoriatourist.entity.logistics.po.LogisticsInfos;
 import com.fjhx.victoriatourist.entity.logistics.vo.LogisticsInfosVo;
@@ -260,6 +261,14 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
         logisticsInfos.setCode(stockWaitDetailsDto.getLogisticsCode());
         logisticsInfos.setWarehouseId(stockWaitDetailsDto.getWarehouseId());
         logisticsInfos.setIsKd100(0);
+
+
+        //发起快递100订阅
+        DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+        Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 3, LogisticsInfos.class).getState();
+        DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setLogisticsStatus(state);
+
         logisticsInfosService.save(logisticsInfos);
 
         LogisticsDetails logisticsDetails = new LogisticsDetails();
@@ -286,6 +295,13 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
         logisticsInfos.setWarehouseId(stockWaitDto.getWarehouseId());
         logisticsInfos.setIsKd100(0);
         logisticsInfos.setStockWaitId(stockWait.getId());
+
+        //发起快递100订阅
+        DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+        Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 3, LogisticsInfos.class).getState();
+        DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setLogisticsStatus(state);
+
         logisticsInfosService.save(logisticsInfos);
 
         List<StockWaitDetails> stockWaitDetailsList = stockWaitDto.getStockWaitDetailsList();

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

@@ -11,6 +11,7 @@ import com.fjhx.common.constant.SourceConstant;
 import com.fjhx.common.utils.Assert;
 import com.fjhx.kd100.entity.company.po.CompanyInfo;
 import com.fjhx.kd100.service.company.CompanyInfoService;
+import com.fjhx.kd100.util.KD100Util;
 import com.fjhx.purchase.entity.purchase.po.Purchase;
 import com.fjhx.purchase.service.purchase.PurchaseService;
 import com.fjhx.victoriatourist.entity.logistics.po.LogisticsDetails;
@@ -214,6 +215,13 @@ public class PurchaseBackServiceImpl extends ServiceImpl<PurchaseBackMapper, Pur
         logisticsInfos.setProvinceId(stockWaitDto.getProvinceId());//市id
         logisticsInfos.setAddress(stockWaitDto.getAddress());
 
+
+        //发起快递100订阅
+        DynamicDataSourceContextHolder.push(SourceConstant.KD100);
+        Integer state = KD100Util.monitor(logisticsInfos.getLogisticsCompanyCode(), logisticsInfos.getCode(), logisticsInfos.getId(), 5, LogisticsInfos.class).getState();
+        DynamicDataSourceContextHolder.poll();
+        logisticsInfos.setLogisticsStatus(state);
+
         logisticsInfosService.save(logisticsInfos);
 
         List<StockWaitDetails> stockWaitDetailsList = stockWaitDto.getStockWaitDetailsList();