磅单审核列表

performance-api/src/main/java/com/clx/performance/enums/OrderChildEnum.java

@@ -119,6 +119,18 @@ public enum OrderChildEnum {
 
     );
 
+    // 运单数据同步一部状态
+    public static final List<Integer> SYNC_STATUS_lIST = Arrays.asList(
+            Status.CREATED.getCode(),
+            Status.GO_TO_SEND.getCode(),
+            Status.ARRIVE_SEND.getCode(),
+            Status.LOAD.getCode(),
+            Status.GO_TO_RECEIVE.getCode(),
+            Status.ARRIVE_RECEIVE.getCode(),
+            Status.UNLOAD.getCode()
+
+    );
+
 
     public static ConcurrentHashMap<Integer, String> map = new ConcurrentHashMap();
     static {

performance-web/src/main/java/com/clx/performance/config/RabbitBeanConfig.java

@@ -91,12 +91,5 @@ public class RabbitBeanConfig {
         return BindingBuilder.bind(orderOnDeadQueue()).to(orderOnDeadExchange()).with(RabbitKeyConstants.ORDER_ON_ROUTE_KEY);
     }
 
-/*    *//**
-     * 运单同步队列
-     *//*
-    @Bean
-    public Queue orderChildQueue() {
-        return new Queue(RabbitKeyConstants.CLX_PERFORMANCE_ORDER_CHILD_QUEUE, true);
-    }*/
 
 }

performance-web/src/main/java/com/clx/performance/listener/OrderChildDtsListener.java

-/*
 package com.clx.performance.listener;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.clx.performance.constant.RabbitKeyConstants;
 import com.clx.performance.data.OrderChildData;
+import com.clx.performance.enums.OrderChildEnum;
 import com.msl.common.utils.DtsMapConvertUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.*;
 import org.springframework.stereotype.Component;
 
+import java.util.Objects;
+
 @Slf4j
 @Component
 public class OrderChildDtsListener  {
@@ -26,14 +28,27 @@ public class OrderChildDtsListener  {
 
             JSONObject beforeMap = object.getJSONObject("beforeMap");
             JSONObject afterMap = object.getJSONObject("afterMap");
+
             OrderChildData before = DtsMapConvertUtil.convert(beforeMap, new OrderChildData());
-            OrderChildData entity = DtsMapConvertUtil.convert(afterMap, new OrderChildData());
+            OrderChildData after = DtsMapConvertUtil.convert(afterMap, new OrderChildData());
+
+            if(Objects.isNull(before) && Objects.nonNull(after)){
+                //同步after数据
+                System.out.println("新增:"+after);
+            }else if(Objects.nonNull(before) && Objects.nonNull(after)){
+                if(OrderChildEnum.SYNC_STATUS_lIST.contains(after.getStatus()) && !Objects.equals(before.getStatus(),after.getStatus())){
+                    //同步after数据
+                    System.out.println("修改:"+after);
+                }
+            }else if(Objects.nonNull(before) && Objects.isNull(after)){
+                //数据删除
+                System.out.println("删除:"+before);
+            }
 
 
         } catch (Exception e) {
-            log.info("DTS消息同步失败, database:order_service, error:{}", e.getMessage());
+            log.info("DTS消息同步失败, database:clx_performance.order_child, error:{}", e.getMessage());
         }
     }
 
 }
-*/

performance-web/src/main/java/com/clx/performance/sqlProvider/OrderChildSqlProvider.java

@@ -86,7 +86,7 @@ public class OrderChildSqlProvider {
                     "date_format(load_time, '%Y-%m-%d %H:%i:%s') as loadTime," +
                     "date_format(unload_time, '%Y-%m-%d %H:%i:%s') as unloadTime ");
             FROM("order_child ");
-            WHERE("pound_status >0");
+            WHERE("pound_status >=0");
             if (StringUtils.isNotBlank(param.getBeginTime())) {WHERE("pay_time >= #{param.beginTime}");}
             if (StringUtils.isNotBlank(param.getEndTime())) {WHERE("pay_time <= #{param.endTime}");}