处理BUG,增加日志

performance-web/src/main/java/com/clx/performance/component/OrderGoodsStatusLazyComponent.java

@@ -34,7 +34,7 @@ import java.util.Set;
 public class OrderGoodsStatusLazyComponent implements InitializingBean {
 
     @Autowired
-    private RedisTemplate<String,String> redisTemplate;
+    private RedisTemplate<String, String> redisTemplate;
 
     @Autowired
     private OrderGoodsDao orderGoodsDao;
@@ -88,6 +88,13 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
                     redisTemplate.opsForZSet().remove(RedisConstants.ORDER_GOODS_STATUS_LAZY, orderGoodsId.getValue());
                     log.info("当前货单编号未查询出订单数据，执行删除redis ORDER_GOODS_STATUS_LAZY id: {}", orderGoodsId.getValue());
                     continue;
+                } else {
+                    log.info("当前货单编号已经查出数据{}", orderGoodsNo);
+                }
+                if (OrderGoodsStatusEnum.Status.SUCCESS.getCode().equals(orderGoods.getOrderGoodsStatus())) {
+                    log.info("当前货单状态判断为已完成");
+                } else {
+                    log.info("当前货单状态判断不是已完成：货单状态为{}", orderGoods.getOrderGoodsStatus());
                 }
 
                 if (OrderGoodsStatusEnum.Status.SUCCESS.getCode().equals(orderGoods.getOrderGoodsStatus())) {
@@ -95,6 +102,8 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
                     //如果当前货单已完成，则判断之前所有货单是否等于订单总吨数，等于则更新订单为已完成
                     List<OrderGoods> list = orderGoodsDao.getOrderGoodsListByOrderNoAndLastArriveSendTime(orderGoods.getOrderNo(), nowDateTime);
                     BigDecimal childSum = list.stream().map(OrderGoods::getExtractWeight).reduce(BigDecimal.ZERO, BigDecimal::add);
+                    log.info("算出所有货单总量:{}, 订单总吨数：{}", childSum, orderInfoFeign.getTransportWeight());
+
                     if (childSum.compareTo(new BigDecimal(orderInfoFeign.getTransportWeight())) == 0) {
                         log.info("已完成的货单已经等于订单的拉运吨数，提前更新订单状态 已完成");
                         //已完成的货单已经等于订单的拉运吨数，提前更新订单状态 已完成
@@ -102,6 +111,9 @@ public class OrderGoodsStatusLazyComponent implements InitializingBean {
                         updateOrderInfoParam.setOrderId(orderInfoFeign.getId());
                         updateOrderInfoParam.setOrderStatus(OrderEnum.Status.SUCCESS.getCode());
                         orderFeign.updateOrderInfo(updateOrderInfoParam);
+                    } else {
+                        log.info("判断吨数不一致：childSum{}, transportWeight {}", childSum, new BigDecimal(orderInfoFeign.getTransportWeight()));
+
                     }
                 } else {
                     log.info("当前货单状态为已完结");

performance-web/src/test/java/com/clx/performance/JobTest.java

@@ -5,7 +5,9 @@ import com.clx.order.param.feign.UpdateOrderInfoResidueWeightParam;
 import com.clx.performance.component.OrderGoodsStatusLazyComponent;
 import com.clx.performance.constant.RabbitKeyConstants;
 import com.clx.performance.constant.RedisConstants;
+import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.mapper.OrderGoodsMapper;
+import com.clx.performance.model.OrderGoods;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.amqp.core.Message;
@@ -19,6 +21,7 @@ import org.springframework.test.context.junit4.SpringRunner;
 
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
+import java.util.List;
 import java.util.Set;
 
 @SpringBootTest
@@ -37,11 +40,15 @@ public class JobTest {
     @Autowired
     private OrderGoodsStatusLazyComponent orderGoodsStatusLazyComponent;
 
+    @Autowired
+    private OrderGoodsDao orderGoodsDao;
     @Test
     public void test1() {
-        orderGoodsStatusLazyComponent.consuming();
+        List<OrderGoods> list = orderGoodsDao.getOrderGoodsListByOrderNoAndLastArriveSendTime("PT2023092700023", LocalDateTime.now());
+        BigDecimal childSum = list.stream().map(OrderGoods::getExtractWeight).reduce(BigDecimal.ZERO, BigDecimal::add);
         System.out.println();
 
+
 //                UpdateOrderInfoResidueWeightParam param = new UpdateOrderInfoResidueWeightParam();
 //        param.setOrderId(150);
 //        param.setUpdateType("1");