From 7005c13237516d5dd965afb1b3c5aa734a01a661 Mon Sep 17 00:00:00 2001
From: wang-hao-jie <1550036656@qq.com>
Date: 星期三, 23 三月 2022 17:27:59 +0800
Subject: [PATCH] 最新版本
---
xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/util/MQTT.java | 43 ++++++++++++++++++++++++++++++++++++-------
1 files changed, 36 insertions(+), 7 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 390c107..09a0001 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
@@ -2,8 +2,10 @@
import cn.exrick.xboot.your.entity.Alarm;
import cn.exrick.xboot.your.entity.Car;
+import cn.exrick.xboot.your.entity.EventLog;
import cn.exrick.xboot.your.service.IAlarmService;
import cn.exrick.xboot.your.service.ICarService;
+import cn.exrick.xboot.your.service.IEventLogService;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
@@ -13,12 +15,17 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+
@Component
public class MQTT {
@Autowired
private IAlarmService iAlarmService;
@Autowired
private ICarService iCarService;
+ @Autowired
+ private HaiKangPost haiKangPost;
+ @Autowired
+ private IEventLogService iEventLogService;
public static void main(String[] args) {
MQTT mqtt = new MQTT();
@@ -26,7 +33,8 @@
}
public void event(String clientid,String userName,String passWord){
- String HOST = "tcp://111.63.178.115:1883";
+ String HOST = "tcp://10.10.101.1:1883";
+ //String HOST = "tcp://111.63.178.115:1883";
String TOPIC = "artemis/event_msa_alarm/5201154049/admin";
int qos = 1;
// String clientid = "28156526";
@@ -50,11 +58,22 @@
// 璁剧疆鍥炶皟鍑芥暟
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);
+ JSONObject jsonObject = JSONUtil.parseObj(topicInfo);
+ if(jsonObject.get("data")!=null){
+ String data = jsonObject.get("data").toString();
+ JSONObject jsonObject2 = JSONUtil.parseObj(data);
+ String clientId = jsonObject2.get("clientId").toString();
+ String userName = jsonObject2.get("userName").toString();
+ String password = jsonObject2.get("password").toString();
+ event(clientId,userName,password);
+ }
}
public void deliveryComplete(IMqttDeliveryToken token) {
- System.out.println("deliveryComplete---------"+ token.isComplete());
+ //System.out.println("deliveryComplete---------"+ token.isComplete());
}
@@ -77,9 +96,9 @@
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"));//鎶ヨ绫诲瀷
+ //System.out.println(jsonObject2.get("alarmId"));//鎶ヨid
+ //System.out.println(jsonObject2.get("vehicleIndexCode"));//杞﹁締code
+ //System.out.println(jsonObject2.get("eventType"));//鎶ヨ绫诲瀷
//鏈郴瀹夊叏甯︼細132376
//鎶界儫锛�132375
//鎺ユ墦鐢佃瘽锛�132374
@@ -87,6 +106,7 @@
String eventType = jsonObject2.get("eventType").toString();
String vehicleIndexCode = jsonObject2.get("vehicleIndexCode").toString();
String alarmId = jsonObject2.get("alarmId").toString();
+ String alarmTime = jsonObject2.get("alarmTime").toString();
Alarm alarm = new Alarm();
if(eventType.equals("132371")){
@@ -101,6 +121,9 @@
}else if(eventType.equals("132375")){
alarm.setType(4);
alarm.setValue("鎶界儫");
+ }else if(eventType.equals("132405")){
+ alarm.setType(7);
+ alarm.setValue("瓒呴��");
}else{
return;
}
@@ -117,8 +140,14 @@
alarm.setCarNo(car.getCarNo());
alarm.setCarUserId(car.getUserId());
alarm.setFollowUserId(car.getFollowUserId());
-
+ alarm.setAlarmTime(alarmTime);
iAlarmService.saveOrUpdate(alarm);
+
+ EventLog eventLog = new EventLog();
+ eventLog.setType(alarm.getType());
+ eventLog.setRefId(alarmId);
+ eventLog.setCarNo(car.getCarNo());
+ iEventLogService.saveOrUpdate(eventLog);
}
}
}
--
Gitblit v1.9.1