From 5074e86c3be3a5dee506ce131a28b82bd0ed6207 Mon Sep 17 00:00:00 2001
From: zhaoxianglong <you@example.com>
Date: Thu, 1 Feb 2024 09:04:09 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E9=9D=9E=E6=9C=BA=E9=A2=84?=
=?UTF-8?q?=E8=AD=A6=E4=BA=8B=E4=BB=B6=E4=B8=8A=E6=8A=A5=E8=AE=A2=E9=98=85?=
=?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=8F=8A=E4=BA=8B=E4=BB=B6=E4=B8=8A=E6=8A=A5?=
=?UTF-8?q?=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../NonAutomaticWarningController.java | 230 ++++++++++++++++++
1 file changed, 230 insertions(+)
create mode 100644 zc-business/src/main/java/com/zc/business/controller/NonAutomaticWarningController.java
diff --git a/zc-business/src/main/java/com/zc/business/controller/NonAutomaticWarningController.java b/zc-business/src/main/java/com/zc/business/controller/NonAutomaticWarningController.java
new file mode 100644
index 00000000..51297fd1
--- /dev/null
+++ b/zc-business/src/main/java/com/zc/business/controller/NonAutomaticWarningController.java
@@ -0,0 +1,230 @@
+package com.zc.business.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.hikvision.artemis.sdk.ArtemisHttpUtil;
+import com.hikvision.artemis.sdk.config.ArtemisConfig;
+import com.ruoyi.common.core.controller.BaseController;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.utils.uuid.IdUtils;
+import com.zc.business.domain.DcWarning;
+import com.zc.business.service.IDcWarningService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.eclipse.paho.client.mqttv3.*;
+import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.*;
+
+
+/**
+ * License
+ *
+ * @author Athena-xiepufeng
+ */
+@Api(tags = "非机预警接口")
+@RestController
+@RequestMapping("/nonAutomaticWarning")
+public class NonAutomaticWarningController extends BaseController {
+
+ private static final String APPKEY = "22825659";
+
+ private static final String APPSECRET = "7Qcq3fr1gaYws6QhyDqt";
+
+ private static final String URI = "/artemis/api/common/v1/event/getTopicInfo";
+
+ private static final String IP = "10.0.81.28";
+
+ @Resource
+ private IDcWarningService dcWarningService;
+
+ /*
+ * 调用功能
+ * */
+ @ApiOperation("事件订阅")
+ @PostMapping(value = "/eventSubscription")
+ public AjaxResult eventSubscription() throws Exception {
+
+ ArtemisConfig config = new ArtemisConfig();
+ config.setHost(IP); // 代理API网关nginx服务器ip端口
+ config.setAppKey(APPKEY); // 秘钥appkey
+ config.setAppSecret(APPSECRET);// 秘钥appSecret
+ final String getCamsApi = URI;
+ Map<String, Object> paramMap = new HashMap<String, Object>();// post请求Form表单参数
+ ArrayList<Long> longs = new ArrayList<>();
+ longs.add(6274879489L);
+ longs.add(6274883585L);
+ longs.add(7768236033L);
+ longs.add(7835340801L);
+ paramMap.put("eventTypes", longs);
+ String body = JSON.toJSON(paramMap).toString();
+ Map<String, String> path = new HashMap<String, String>(2) {
+ {
+ put("https://", getCamsApi);
+ }
+ };
+ String jsonString = ArtemisHttpUtil.doPostStringArtemis(config, path, body, null, null, "application/json");
+
+ JSONObject jsonObject = JSONObject.parseObject(jsonString);
+ String code = jsonObject.getString("code");
+ if (Objects.equals(code, "0")) {
+ JSONObject jsonResult = jsonObject.getJSONObject("data");
+ String host = jsonResult.getString("host");
+ String clientId = jsonResult.getString("clientId");
+ String userName = jsonResult.getString("userName");
+ String password = jsonResult.getString("password");
+ JSONObject topicName = jsonResult.getJSONObject("topicName");
+ try {
+ // host为主机名，test为clientid即连接MQTT的客户端ID，一般以客户端唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
+ MqttClient client = new MqttClient(host, clientId, new MemoryPersistence());
+ // MQTT的连接设置
+ MqttConnectOptions options = new MqttConnectOptions();
+ // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接
+ options.setCleanSession(true);
+ // 设置连接的用户名
+ options.setUserName(userName);
+ // 设置连接的密码
+ options.setPassword(password.toCharArray());
+ // 设置超时时间 单位为秒
+ options.setConnectionTimeout(10);
+ // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制
+ options.setKeepAliveInterval(20);
+ // 设置回调函数
+ client.setCallback(new MqttCallback() {
+
+ public void connectionLost(Throwable cause) {
+ System.out.println("connectionLost");
+ }
+
+ public void messageArrived(String topic, MqttMessage message) {
+ System.out.println("======监听到来自[" + topic + "]的消息======");
+ String jsonObjString = new String(message.getPayload());
+ JSONObject eventJsonObject = JSONObject.parseObject(jsonObjString);
+ JSONObject params = eventJsonObject.getJSONObject("params");
+ if (params == null) {
+ return;
+ }
+ JSONArray events = params.getJSONArray("events");
+ events.forEach(item -> {
+ JSONObject event = JSONObject.parseObject(String.valueOf(item));
+ JSONObject data = event.getJSONObject("data");
+ String crossingIndexCode = event.getString("crossingIndexCode");
+ Date happenTime = event.getDate("happenTime");
+ String srcName = event.getString("srcName").split("收费站")[1];
+ String illegalTrafficEvent = data.getString("illegalTrafficEvent");
+ String directionName = data.getString("directionName");
+ String crossingName = data.getString("crossingName");
+ String targetPicUrl = data.getString("targetPicUrl");
+
+ DcWarning dcWarning = new DcWarning();
+ dcWarning.setOtherConfig(jsonObjString);
+ switch (illegalTrafficEvent) {
+ case "congestion"://拥堵
+ dcWarning.setWarningType(1);
+ break;
+ //case "laneChange"://变道
+ // dcWarning.setWarningType();
+ // break;
+ //case "vehicleexist"://机占非
+ // dcWarning.setWarningType();
+ // break;
+ //case "roadBlock"://路障
+ // dcWarning.setWarningType();
+ // break;
+ //case "construction"://施工
+ // dcWarning.setWarningType();
+ // break;
+ case "llegalParking"://停车
+ dcWarning.setWarningType(4);
+ break;
+ //case "crossLane"://压线
+ // dcWarning.setWarningType();
+ // break;
+ //case "turnRound"://掉头
+ // dcWarning.setWarningType();
+ // break;
+ case "wrongDirection"://逆行
+ dcWarning.setWarningType(5);
+ break;
+ case "pedestrian"://行人
+ dcWarning.setWarningType(2);
+ break;
+ case "abandonedObject"://抛洒物
+ dcWarning.setWarningType(7);
+ break;
+ default://其他
+ dcWarning.setWarningType(10);
+ }
+ if (Objects.equals(directionName, "上行")) {
+ dcWarning.setDirection("1");
+ } else if (Objects.equals(directionName, "中")) {
+ dcWarning.setDirection("2");
+ } else if (Objects.equals(directionName, "下行")) {
+ dcWarning.setDirection("3");
+ }
+ dcWarning.setWarningTime(happenTime);
+ dcWarning.setCreateTime(new Date());
+ if (crossingName.startsWith("大学城")) {
+ dcWarning.setStakeMark("k59+289");
+ } else if (crossingName.startsWith("长清")) {
+ dcWarning.setStakeMark("k72+847");
+ } else if (crossingName.startsWith("孝里")) {
+ dcWarning.setStakeMark("k86+499");
+ } else if (crossingName.startsWith("平阴北")) {
+ dcWarning.setStakeMark("k99+750");
+ } else if (crossingName.startsWith("平阴南")) {
+ dcWarning.setStakeMark("k126+223");
+ } else if (crossingName.startsWith("平阴")) {
+ dcWarning.setStakeMark("k105+904");
+ } else if (crossingName.startsWith("东平")) {
+ dcWarning.setStakeMark("k145+933");
+ } else if (crossingName.startsWith("梁山东")) {
+ dcWarning.setStakeMark("k173+950");
+ } else if (crossingName.startsWith("梁山")) {
+ dcWarning.setStakeMark("k179+396");
+ } else if (crossingName.startsWith("嘉祥")) {
+ dcWarning.setStakeMark("k190+495");
+ }
+ dcWarning.setWarningTitle(crossingName+srcName);
+ //设置事件Id UUID无下划线格式32
+ String uuid = IdUtils.fastSimpleUUID();
+ dcWarning.setId(uuid);
+ dcWarning.setWarningSource(6);
+ dcWarning.setWarningState(1);
+ dcWarningService.insertDcWarning(dcWarning);
+ });
+ System.out.println("message content:" + jsonObjString);
+ System.out.println("============");
+ }
+
+ public void deliveryComplete(IMqttDeliveryToken token) {
+ System.out.println("deliveryComplete---------" + token.isComplete());
+ }
+
+ });
+
+ // 建立连接
+ System.out.println("连接到 broker: " + host);
+ client.connect(options);
+
+ System.out.println("连接成功.");
+ //订阅消息
+ //client.subscribe(topicName.getString("6274883585"), 1);
+ //System.out.println("开始监听" + topicName.getString("6274883585"));
+ client.subscribe(topicName.getString("6274879489"), 1);
+ System.out.println("开始监听" + topicName.getString("6274879489"));
+ client.subscribe(topicName.getString("7768236033"), 1);
+ System.out.println("开始监听" + topicName.getString("7768236033"));
+ client.subscribe(topicName.getString("7835340801"), 1);
+ System.out.println("开始监听" + topicName.getString("7835340801"));
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return AjaxResult.success();
+ }
+ return AjaxResult.error();
+ }
+}