最新版本

wang-hao-jie

2022-05-03 b8086d8c8bf084ed20488a005f957e29ee3cbc8e

 xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java

@@ -15,6 +15,8 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;


@Component
public class MQTT {
@@ -96,17 +98,27 @@
                                    JSONObject jsonObject1 = JSONUtil.parseObj(s1);
                                    String data = jsonObject1.get("data").toString();
                                    JSONObject jsonObject2 = JSONUtil.parseObj(data);
                                    //System.out.println(jsonObject2.get("alarmId"));//报警id
                                    //System.out.println(jsonObject2.get("vehicleIndexCode"));//车辆code
                                    //System.out.println(jsonObject2.get("eventType"));//报警类型
                                    //未系安全带：132376
                                    //抽烟：132375
                                    //接打电话：132374
                                    //疲劳驾驶：132371
                                    String eventType = jsonObject2.get("eventType").toString();
                                    String vehicleIndexCode = jsonObject2.get("vehicleIndexCode").toString();
                                    String alarmId = jsonObject2.get("alarmId").toString();
                                    String alarmTime = jsonObject2.get("alarmTime").toString();

                                    QueryWrapper<Car> wrapper = new QueryWrapper<Car>();
                                    wrapper.eq("code",vehicleIndexCode);
                                    Car car = iCarService.getOne(wrapper);
                                    if(car==null){
                                        return;
                                    }

                                    String format = alarmTime.substring(0,17);
                                    QueryWrapper<Alarm> awrapper = new QueryWrapper<>();
                                    awrapper.between("create_time",format+"00",format+"59");
                                    awrapper.eq("car_no",car.getCarNo());
                                    awrapper.eq("type",1);
                                    List<Alarm> list = iAlarmService.list(awrapper);
                                    if(list.size()>0){
                                        return;
                                    }

                                    Alarm alarm = new Alarm();
                                    if(eventType.equals("132371")){
@@ -125,13 +137,6 @@
                                        alarm.setType(7);
                                        alarm.setValue("超速");
                                    }else{
                                        return;
                                    }

                                    QueryWrapper<Car> wrapper = new QueryWrapper<Car>();
                                    wrapper.eq("code",vehicleIndexCode);
                                    Car car = iCarService.getOne(wrapper);
                                    if(car==null){
                                        return;
                                    }