提交

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/FireFightingSystemServiceImpl.java

@@ -1158,9 +1158,9 @@ public class FireFightingSystemServiceImpl extends ServiceImpl<FireFightingSyste
             }
 
         }
-        if (!ObjectUtils.isEmpty(data)) {
-            mqttSendGateway.sendToMqtt(String.format("%s%s", "INTEGRATE_TOPIC/", systemCode), JSON.toJSONString(data));
-        }
+//        if (!ObjectUtils.isEmpty(data)) {
+//            mqttSendGateway.sendToMqtt(String.format("%s%s", "INTEGRATE_TOPIC/", systemCode), JSON.toJSONString(data));
+//        }
         return Collections.emptyMap();
     }
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/JxiopCarIotListerServiceImpl.java

@@ -200,9 +200,9 @@ public class JxiopCarIotListerServiceImpl {
                     maxSpeed = car.getMaxSpeed();
                 }
                 car.setExtra2(power.toString());
-                logger.info("----------------更新车辆电池电量信息成功----------------");
+                //logger.info("----------------更新车辆电池电量信息成功----------------");
                 carMapper.updateById(car);
-                logger.info("车牌号：：" + car.getCarNum() + "最大车速：" + maxSpeed + "当前车速::" + speed);
+                //logger.info("车牌号：：" + car.getCarNum() + "最大车速：" + maxSpeed + "当前车速::" + speed);
                 if ((speed - maxSpeed) > 0) {
                     List<CarSpeedWarningRecord> list = wlCarSpeedWaringRecordMapper.selectList(new QueryWrapper<CarSpeedWarningRecord>().eq("car_num", car.getCarNum()).
                             between("waring_date", DateUtil.offsetMinute(new Date(), -10), new Date()));
@@ -235,12 +235,12 @@ public class JxiopCarIotListerServiceImpl {
                         logger.info("-----------更新车辆超速告警成功--------");
                     }
                 }
-                logger.info("-----------推送车辆位置消息到到地图成功--------");
-                try {
-                    emqkeeper.getMqttClient().publish("car/location", sendArr.toJSONString().getBytes(), 0, false);
-                } catch (MqttException e) {
-                    e.printStackTrace();
-                }
+              //  logger.info("-----------推送车辆位置消息到到地图成功--------");
+//                try {
+//                    emqkeeper.getMqttClient().publish("car/location", sendArr.toJSONString().getBytes(), 0, false);
+//                } catch (MqttException e) {
+//                    e.printStackTrace();
+//                }
             }
         }
     }

amos-boot-module/amos-boot-module-biz/amos-boot-module-equip-biz/src/main/java/com/yeejoin/equipmanage/service/impl/WlCarMileageServiceImpl.java

@@ -411,8 +411,12 @@ public class WlCarMileageServiceImpl extends ServiceImpl<WlCarMileageMapper, WlC
     public void endCarMileageTask() {
         List<WlCarMileage> list = wlCarMileageMapper.selectList(new QueryWrapper<WlCarMileage>().isNull("end_time").isNotNull("start_time"));
         list.forEach(item -> {
+            log.info("1获取code:{}", item.getIotCode());
+            log.info("2获取值:{}", redisTemplate.opsForValue().get(item.getIotCode()));
+            log.info("3获取结果:{}", ObjectUtils.isEmpty(redisTemplate.opsForValue().get(item.getIotCode())));
             if (ObjectUtils.isEmpty(redisTemplate.opsForValue().get(item.getIotCode()))) {
                 if (!ObjectUtils.isEmpty(item.getIotCode()) && item.getIotCode().length() > 8) {
+                    log.info("4处理结束坐标轨迹iocCode:{}", item.getIotCode());
                     // 查询车辆上报信息
                     Date date = new Date();
                     ResponseModel<List<Object>> result = iotFeign.getLiveData(item.getIotCode().substring(0, 8), item.getIotCode().substring(8),