同步历史货单

performance-web/src/main/java/com/clx/performance/dao/OrderGoodsDao.java

@@ -52,4 +52,7 @@ public interface OrderGoodsDao extends BaseDao<OrderGoodsMapper, OrderGoods, Int
     Optional<List<OrderGoods>> getOrderGoodsList();
 
     List<OrderGoods> getSendAddressSelect(GoodsOrderMapParam param);
+
+    List<OrderGoods> listIntegralOrderGoodsSync();
+
 }

performance-web/src/main/java/com/clx/performance/dao/impl/OrderGoodsDaoImpl.java

@@ -135,5 +135,14 @@ public class OrderGoodsDaoImpl extends BaseDaoImpl<OrderGoodsMapper, OrderGoods,
         ));
     }
 
+    @Override
+    public List<OrderGoods> listIntegralOrderGoodsSync() {
+        return list(lQrWrapper()
+                .eq(OrderGoods::getOrderGoodsStatus, OrderGoodsStatusEnum.Status.PAYING.getCode())
+                .eq(OrderGoods::getOrderGoodsStatus, OrderGoodsStatusEnum.Status.GO_TO_SEND.getCode())
+                .eq(OrderGoods::getOrderGoodsStatus, OrderGoodsStatusEnum.Status.SUCCESS.getCode())
+        );
+    }
+
 
 }

performance-web/src/main/java/com/clx/performance/job/IntegralJob.java

 package com.clx.performance.job;
 
 import com.clx.performance.dao.IntegralTruckDao;
+import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.model.IntegralTruck;
+import com.clx.performance.model.OrderGoods;
 import com.clx.performance.service.IntegralJobHandlerService;
 import com.clx.performance.utils.JobHandlerService;
 import com.clx.performance.utils.LocalDateTimeUtils;
@@ -19,6 +21,7 @@ import java.util.List;
 public class IntegralJob {
 
     private final IntegralTruckDao integralTruckDao;
+    private final OrderGoodsDao orderGoodsDao;
     private final JobHandlerService jobHandlerService;
 
     private final IntegralJobHandlerService integralJobHandlerService;
@@ -72,4 +75,19 @@ public class IntegralJob {
         });
     }
 
+    /**
+     * 历史货单同步 (初始化1次)
+     */
+    @XxlJob("syncHistoryOrderGoods")
+    public void syncHistoryOrderGoods() {
+        jobHandlerService.handler("司机积分-历史货单同步", ()->{
+            List<OrderGoods> list = orderGoodsDao.listIntegralOrderGoodsSync();
+            log.info("司机积分，历史货单数量:{}", list.size());
+
+            list.forEach(integralJobHandlerService::syncHistoryOrderGoods);
+
+        });
+
+    }
+
 }

performance-web/src/main/java/com/clx/performance/service/IntegralJobHandlerService.java

 package com.clx.performance.service;
 
 import com.clx.performance.model.IntegralTruck;
+import com.clx.performance.model.OrderGoods;
 
 public interface IntegralJobHandlerService {
 
@@ -11,4 +12,6 @@ public interface IntegralJobHandlerService {
 
     void truckProtectionCancel(IntegralTruck truck);
 
+    void syncHistoryOrderGoods(OrderGoods orderGoods);
+
 }

performance-web/src/main/java/com/clx/performance/service/impl/IntegralJobHandlerServiceImpl.java

 package com.clx.performance.service.impl;
 
 import com.clx.performance.model.IntegralTruck;
+import com.clx.performance.model.OrderGoods;
 import com.clx.performance.service.IntegralJobHandlerService;
 import com.clx.performance.service.IntegralMqService;
 import com.clx.performance.utils.LocalDateTimeUtils;
@@ -54,4 +55,11 @@ public class IntegralJobHandlerServiceImpl implements IntegralJobHandlerService
         integralMqService.truckProtectionCancel(LocalDateTimeUtils.getWeekStart(), truck.getTruckNo());
     }
 
+    @Override
+    public void syncHistoryOrderGoods(OrderGoods orderGoods) {
+        integralMqService.orderGoodsAdd(orderGoods.getOrderGoodsNo(),
+                orderGoods.getSendAddressId(), orderGoods.getSendAddressShorter(),
+                orderGoods.getReceiveAddressId(), orderGoods.getReceiveAddressShorter());
+    }
+
 }