From e8f0b3422d307c686b3a81269f9e9e4fb34a846e Mon Sep 17 00:00:00 2001
From: wjli <591616088@qq.com>
Date: 星期五, 12 四月 2024 10:49:46 +0800
Subject: [PATCH] 指纹登陆返回客户端加密信息
---
xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java | 41 ++++++++++++++++++++++++++---------------
1 files changed, 26 insertions(+), 15 deletions(-)
diff --git a/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java b/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java
index 3738147..aab6372 100644
--- a/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java
+++ b/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java
@@ -6,6 +6,7 @@
import cn.exrick.xboot.your.service.IAlarmService;
import cn.exrick.xboot.your.service.ICarService;
import cn.exrick.xboot.your.service.IEventLogService;
+import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
@@ -14,6 +15,9 @@
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
@Component
@@ -58,9 +62,9 @@
// 璁剧疆鍥炶皟鍑芥暟
client.setCallback(new MqttCallback() {
public void connectionLost(Throwable cause) {
- System.out.println("connectionLost");
+ //System.out.println("connectionLost");
String topicInfo = haiKangPost.getTopicInfo();
- System.out.println("閲嶈繛-璁㈤槄淇℃伅锛�"+topicInfo);
+ //System.out.println("閲嶈繛-璁㈤槄淇℃伅锛�"+topicInfo);
JSONObject jsonObject = JSONUtil.parseObj(topicInfo);
if(jsonObject.get("data")!=null){
String data = jsonObject.get("data").toString();
@@ -73,7 +77,7 @@
}
public void deliveryComplete(IMqttDeliveryToken token) {
- System.out.println("deliveryComplete---------"+ token.isComplete());
+ //System.out.println("deliveryComplete---------"+ token.isComplete());
}
@@ -96,17 +100,17 @@
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;
+ }
Alarm alarm = new Alarm();
if(eventType.equals("132371")){
@@ -122,16 +126,23 @@
alarm.setType(4);
alarm.setValue("鎶界儫");
}else if(eventType.equals("132405")){
- alarm.setType(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){
+ Date date1 = new Date();
+ long time = date1.getTime()-2*60*1000;
+ Date date = new Date(time);
+ String format1 = DateUtil.format(date,"yyyy-MM-dd HH:mm:ss");
+ String format2 = DateUtil.format(date1,"yyyy-MM-dd HH:mm:ss");
+ QueryWrapper<Alarm> awrapper = new QueryWrapper<>();
+ awrapper.between("create_time",format1,format2);
+ awrapper.eq("car_no",car.getCarNo());
+ awrapper.eq("type",alarm.getType());
+ List<Alarm> list = iAlarmService.list(awrapper);
+ if(list.size()>0){
return;
}
--
Gitblit v1.9.1