Sfoglia il codice sorgente

修改 创建工单并发的 bug

suntianwu 3 anni fa
parent
commit
d5c34c0b85

+ 2 - 2
src/main/java/com/care/mqtt/service/MqttMsgService.java

@@ -219,7 +219,7 @@ public class MqttMsgService {
                             this.bigScreenService.pushRtEventFlag(order.getStationId().toString(), order.getId().toString(), "orderAdd");
                             this.bigScreenService.pushRtEventFlag(order.getStationId().toString(), order.getId().toString(), "orderAdd");
                             this.bigScreenService.pushRtEventFlag(order.getStationId().toString(), order.getId().toString(), "bigscreenRefresh");
                             this.bigScreenService.pushRtEventFlag(order.getStationId().toString(), order.getId().toString(), "bigscreenRefresh");
                         } else { //取消 不处理工单
                         } else { //取消 不处理工单
-                            careMqttMsg.setStatus(MqttMsgStatusEnum.HANDLED.getValue());
+                            careMqttMsg.setStatus(MqttMsgStatusEnum.CANCEL.getValue());
                             this.careMqttMsgService.save(careMqttMsg);
                             this.careMqttMsgService.save(careMqttMsg);
                         }
                         }
 
 
@@ -232,7 +232,7 @@ public class MqttMsgService {
                             //进行调度处理
                             //进行调度处理
                             mqttMsgRedisService.addRedis(careMqttMsg, date.getTime() + careMqttMsg.getDelayTime() * 60 * 1000);
                             mqttMsgRedisService.addRedis(careMqttMsg, date.getTime() + careMqttMsg.getDelayTime() * 60 * 1000);
                         } else { //取消: 更新mqtt消息为已取消,等待执行的调度到时会取消执行
                         } else { //取消: 更新mqtt消息为已取消,等待执行的调度到时会取消执行
-                            careMqttMsg.setStatus(MqttMsgStatusEnum.HANDLED.getValue());
+                            careMqttMsg.setStatus(MqttMsgStatusEnum.CANCEL.getValue());
                             this.careMqttMsgService.save(careMqttMsg);
                             this.careMqttMsgService.save(careMqttMsg);
 
 
                             //更新mqtt消息为已取消
                             //更新mqtt消息为已取消