修改恢复吨数的代码

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

@@ -28,7 +28,6 @@ import com.msl.common.base.Optional;
 import com.msl.common.exception.ServiceSystemException;
 import com.msl.common.result.Result;
 import com.msl.common.utils.DateUtils;
-import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -297,7 +296,7 @@ public class OrderCancelComponent implements InitializingBean {
             rollbackOrderWeightParam.setOwnResidueCarryWeight(BigDecimal.ZERO);
             rollbackOrderWeightParam.setPlatformResidueCarryWeight(BigDecimal.ZERO);
         } else {
-            if (orderGoods.getVehicleUsage().equals(VehicleUsageEnum.Status.OWN.getCode())) {
+            if (Objects.equals(orderGoods.getVehicleUsage(),VehicleUsageEnum.Status.OWN.getCode())) {
                 if(isSub && weight.compareTo(orderInfo.getOwnResidueCarryWeight()) > 0 ){
                     log.warn("货单用车需求: {},订单号：{},货单号：{},自有剩余吨数:{},需要扣减吨数:{},不足扣减",
                             TruckDemandEnum.TruckType.PLATFORM_ANY_CAR.getMsg(),orderNo,orderGoods.getOrderGoodsNo(),

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

@@ -45,13 +45,13 @@ public class OrderGoodsDtsListener {
             OrderGoods after = DtsMapConvertUtil.convert(dataTransportDTO.getAfterMap(), new OrderGoods());
             if(Objects.equals(DtsOperationTypeEnum.INSERT.getCode(),dataTransportDTO.getOperationType().getCode())){
                 //同步after数据
-                log.info("新增:{}",after);
+                log.info("新增:{}",JSON.toJSONString(after));
             }else if(Objects.equals(DtsOperationTypeEnum.UPDATE.getCode(),dataTransportDTO.getOperationType().getCode())){
-                log.info("修改:{}",after);
+                log.info("修改:{}",JSON.toJSONString(after));
                 backFillOrderWeight(after);
             }else if(Objects.equals(DtsOperationTypeEnum.DELETE.getCode(),dataTransportDTO.getOperationType().getCode())){
                 //数据删除
-                log.info("删除:{}",before);
+                log.info("删除:{}",JSON.toJSONString(before));
             }
         } catch (Exception e) {
             log.info("DTS消息同步失败, database:clx_performance.order_goods, error:{}", e.getMessage());