13 changed files with 573 additions and 71 deletions
@ -0,0 +1,236 @@ |
|||
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.PostMapping; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
import javax.annotation.Resource; |
|||
import java.util.ArrayList; |
|||
import java.util.Date; |
|||
import java.util.HashMap; |
|||
import java.util.Map; |
|||
import java.util.Objects; |
|||
|
|||
|
|||
/** |
|||
* 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(99); |
|||
} |
|||
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(); |
|||
} |
|||
} |
|||
@ -0,0 +1,120 @@ |
|||
package com.zc.business.domain; |
|||
|
|||
import com.fasterxml.jackson.annotation.JsonFormat; |
|||
import com.ruoyi.common.annotation.Excel; |
|||
import com.ruoyi.common.core.domain.BaseEntity; |
|||
import io.swagger.annotations.ApiModelProperty; |
|||
import org.apache.commons.lang3.builder.ToStringBuilder; |
|||
import org.apache.commons.lang3.builder.ToStringStyle; |
|||
|
|||
import java.util.Date; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* @author 王思祥 |
|||
* @ClassName DcShiftsList |
|||
*/ |
|||
|
|||
public class DcShiftsList { |
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** */ |
|||
private Long id; |
|||
|
|||
/** 当值人员ID */ |
|||
@ApiModelProperty(value = "当值人员ID", required = true) |
|||
@Excel(name = "当值人员ID") |
|||
private Long employeesId; |
|||
|
|||
|
|||
|
|||
@Excel(name = "姓名") |
|||
private String name; |
|||
@Excel(name = "所属路管驻点名称") |
|||
private String organizationName; |
|||
@ApiModelProperty("排班 1-白班 2-夜班") |
|||
@Excel(name = "排班 1-白班 2-夜班") |
|||
private String scheduling; |
|||
@ApiModelProperty("驻点id") |
|||
@Excel(name = "驻点id") |
|||
private String station; |
|||
@Excel(name = "手机号") |
|||
private String contactNumber; |
|||
|
|||
|
|||
public String getContactNumber() { |
|||
return contactNumber; |
|||
} |
|||
|
|||
public void setContactNumber(String contactNumber) { |
|||
this.contactNumber = contactNumber; |
|||
} |
|||
|
|||
public String getScheduling() { |
|||
return scheduling; |
|||
} |
|||
|
|||
public String getStation() { |
|||
return station; |
|||
} |
|||
|
|||
public void setStation(String station) { |
|||
this.station = station; |
|||
} |
|||
|
|||
public void setScheduling(String scheduling) { |
|||
this.scheduling = scheduling; |
|||
} |
|||
|
|||
|
|||
|
|||
public String getOrganizationName() { |
|||
return organizationName; |
|||
} |
|||
|
|||
public void setOrganizationName(String organizationName) { |
|||
this.organizationName = organizationName; |
|||
} |
|||
|
|||
public String getName() { |
|||
return name; |
|||
} |
|||
|
|||
public void setName(String name) { |
|||
this.name = name; |
|||
} |
|||
|
|||
|
|||
|
|||
public void setId(Long id) |
|||
{ |
|||
this.id = id; |
|||
} |
|||
|
|||
public Long getId() |
|||
{ |
|||
return id; |
|||
} |
|||
|
|||
public void setEmployeesId(Long employeesId) |
|||
{ |
|||
this.employeesId = employeesId; |
|||
} |
|||
|
|||
public Long getEmployeesId() |
|||
{ |
|||
return employeesId; |
|||
} |
|||
|
|||
|
|||
|
|||
|
|||
|
|||
@Override |
|||
public String toString() { |
|||
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE) |
|||
.append("id", getId()) |
|||
.append("employeesId", getEmployeesId()) |
|||
.toString(); |
|||
} |
|||
} |
|||
Loading…
Reference in new issue