zhaoxianglong
1 year ago
1 changed files with 230 additions and 0 deletions
@ -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(); |
||||
|
} |
||||
|
} |
||||
Loading…
Reference in new issue