线路预警

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

@@ -14,6 +14,14 @@ import java.util.List;
 @Repository
 public class LineWarnOrderGoodsDaoImpl extends BaseDaoImpl<LineWarnOrderGoodsMapper, LineWarnOrderGoods, Integer> implements LineWarnOrderGoodsDao {
 
+    @Override
+    public boolean updateWarnStatus(LineWarnOrderGoods item) {
+        return update(lUdWrapper()
+                .eq(LineWarnOrderGoods::getId, item.getId())
+                .set(LineWarnOrderGoods::getWarnStatus, item.getWarnStatus())
+        );
+    }
+
     @Override
     public Optional<LineWarnOrderGoods> getByOrderGoodsNo(String orderGoodsNo) {
         return Optional.of(orderGoodsNo)

performance-web/src/main/java/com/clx/performance/dao/linewarn/LineWarnOrderGoodsDao.java

@@ -9,6 +9,8 @@ import java.util.List;
 
 public interface LineWarnOrderGoodsDao extends BaseDao<LineWarnOrderGoodsMapper, LineWarnOrderGoods, Integer> {
 
+    boolean updateWarnStatus(LineWarnOrderGoods item);
+
     Optional<LineWarnOrderGoods> getByOrderGoodsNo(String orderGoodsNo);
 
     List<LineWarnOrderGoods> ListOrderGoodsNoOfWarn();

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

@@ -14,7 +14,9 @@ import com.clx.performance.dao.linewarn.LineWarnInfoDao;
 import com.clx.performance.dao.linewarn.LineWarnOrderGoodsDao;
 import com.clx.performance.dao.vehiclewarn.VehicleWarnUserDao;
 import com.clx.performance.dto.linewarn.LineWarnCommonInfoDTO;
+import com.clx.performance.enums.OrderGoodsStatusEnum;
 import com.clx.performance.enums.ResultEnum;
+import com.clx.performance.enums.linewarn.LineWarnOrderGoodsEnum;
 import com.clx.performance.extranal.user.OrderService;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.model.linewarn.LineWarnInfo;
@@ -30,11 +32,13 @@ import com.clx.performance.utils.gd.GdUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 
 @Slf4j
 @Service
@@ -80,6 +84,7 @@ public class LineWarnMqHandlerServiceImpl implements LineWarnMqHandlerService {
     private ClxMessageOpenapiFeign clxMessageOpenapiFeign;
 
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void orderGoodsAdd(LineWarnOrderGoodsAddMqParam mq) {
         OrderGoods orderGoods = orderGoodsDao
@@ -100,6 +105,7 @@ public class LineWarnMqHandlerServiceImpl implements LineWarnMqHandlerService {
         lineWarnOrderGoodsDao.saveEntity(lineWarnOrderGoods);
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void lineWarn(LineWarnLineWarnMqParam mq) {
         LineWarnOrderGoods lineWarnOrderGoods = lineWarnOrderGoodsDao
@@ -170,6 +176,14 @@ public class LineWarnMqHandlerServiceImpl implements LineWarnMqHandlerService {
             log.info("线路异常，msg:{}", e.getMessage());
         }
 
+        if (Objects.equals(orderGoods.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.CANCEL.getCode())
+                || Objects.equals(orderGoods.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.SUCCESS.getCode())
+                || Objects.equals(orderGoods.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.COMPLETED.getCode())
+        ){
+            lineWarnOrderGoods.setWarnStatus(LineWarnOrderGoodsEnum.WarnStatus.DISABLE.getCode());
+            lineWarnOrderGoodsDao.updateWarnStatus(lineWarnOrderGoods);
+        }
+
     }
 
     @Override
@@ -256,6 +270,7 @@ public class LineWarnMqHandlerServiceImpl implements LineWarnMqHandlerService {
 
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void orderChildWarn(LineWarnOrderChildWarnMqParam mq) {
         LineWarnOrderGoods lineWarnOrderGoods = lineWarnOrderGoodsDao