现场问题处理

amos-boot-module/amos-boot-module-biz/amos-boot-module-patrol-biz/src/main/java/com/yeejoin/amos/patrol/business/controller/PlanTaskController.java

@@ -66,7 +66,7 @@ public class PlanTaskController extends AbstractBaseController {
     @Autowired
     private IRouteService routeService;
 
-    @Value("${params.isPush:false}")
+    @Value("${is.zxj:false}")
     private Boolean isZxj;
 
 
@@ -350,11 +350,11 @@ public class PlanTaskController extends AbstractBaseController {
      *
      * @return
      */
-    @Scheduled(cron = "${jobs.cron}")
+//    @Scheduled(cron = "${jobs.cron}")
     @ApiOperation(value = "定时执行任务表生成(<font color='blue'>release</font>)", notes = "定时执行任务表生成")
     @RequestMapping(value = "/queryOmission", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
     public CommonResponse pushCarData() {
-        if (Boolean.TRUE.equals(!isZxj)) {
+//        if (Boolean.TRUE.equals(!isZxj)) {
             try {
                 RequestAttributes reqs = RequestContextHolder.getRequestAttributes();
                 RequestContextHolder.setRequestAttributes(reqs, true);
@@ -365,8 +365,8 @@ public class PlanTaskController extends AbstractBaseController {
                 log.error(e.getMessage(), e);
                 return CommonResponseUtil.failure();
             }
-        }
-        return CommonResponseUtil.success();
+//        }
+//        return CommonResponseUtil.success();
     }
 
     /**

amos-boot-module/amos-boot-module-biz/amos-boot-module-patrol-biz/src/main/java/com/yeejoin/amos/patrol/mqtt/PatrolMqttListener.java

@@ -25,18 +25,18 @@ public class PatrolMqttListener extends EmqxListener {
 
     @Override
     public void processMessage(String topic, MqttMessage message) {
-        if(log.isInfoEnabled()){
-            log.info("收到消息主题：{},消息内容：{}",topic, message.toString());
-        }
-        try {
-            Map<String, Object> msg = JSON.parseObject(message.toString());
-            if (pointClassifyTopic.equals(topic)) {
-                iPointService.syncPointClassify(msg);
-            }
-            log.info("巡检对象同步完成");
-        } catch (Exception e) {
-            log.info("巡检对象同步失败:{}", e.getMessage());
-        }
+//        if(log.isInfoEnabled()){
+//            log.info("收到消息主题：{},消息内容：{}",topic, message.toString());
+//        }
+//        try {
+//            Map<String, Object> msg = JSON.parseObject(message.toString());
+//            if (pointClassifyTopic.equals(topic)) {
+//                iPointService.syncPointClassify(msg);
+//            }
+//            log.info("巡检对象同步完成");
+//        } catch (Exception e) {
+//            log.info("巡检对象同步失败:{}", e.getMessage());
+//        }
     }
 
 }