From 9b88bdf9ae10df3b175802b555100410f6557d1a Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: Mon, 24 Jul 2023 10:41:49 +0800
Subject: [PATCH] 三一车辆实时报警提交
---
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplAlarm.java | 128 ++++++++++++++++++++++++++++++++++++++++++
ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml | 7 ++
ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserMapper.java | 6 ++
ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java | 6 ++
ard-work/src/main/java/com/ruoyi/sy/service/IArdSyCarService.java | 5 +
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java | 2
ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java | 10 ++
7 files changed, 161 insertions(+), 3 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java b/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
index 71d6c11..fb2a8c4 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
@@ -13,6 +13,7 @@
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.sy.domain.ArdSyUser;
+import com.ruoyi.sy.gps31.PushClientImplAlarm;
import com.ruoyi.sy.gps31.PushClientImplPosition;
import com.ruoyi.sy.service.IArdSyUserService;
import com.ruoyi.system.domain.SysConfig;
@@ -95,6 +96,11 @@
}
};
carPositionTimer.scheduleAtFixedRate(carPositionTask,date,3*1000);//启用
+
+ //车辆实时位置线程
+ PushClientImplAlarm pushClientImplAlarm = new PushClientImplAlarm(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
+ Thread pushClientImplAlarmThread = new Thread(pushClientImplAlarm);
+ pushClientImplAlarmThread.start();
}
/**
diff --git a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplAlarm.java b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplAlarm.java
new file mode 100644
index 0000000..4e20729
--- /dev/null
+++ b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplAlarm.java
@@ -0,0 +1,128 @@
+/**
+ * <p>Description: </p>
+ * <p>Copyright: Copyright (c) 2020</p>
+ * <p>Company: www.31gps.net</p>
+ * @author chencq
+ * @version 1.0
+ */
+package com.ruoyi.sy.gps31;
+
+import com.alibaba.fastjson2.JSON;
+import com.gps31.push.netty.PushClient;
+import com.gps31.push.netty.PushMsg;
+import com.gps31.push.netty.client.TcpClient;
+import com.gps31.push.util.MapUtil;
+import com.ruoyi.common.utils.spring.SpringUtils;
+import com.ruoyi.sy.service.impl.ArdSyCarServiceImpl;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * <p>Description: </p>
+ * <p>Copyright: Copyright (c) 2020</p>
+ * <p>Company: www.31gps.net</p>
+ * @author chencq
+ * @version 1.0
+ */
+public class PushClientImplAlarm extends PushClient implements Runnable {
+
+ private static final Log log = LogFactory.getLog(PushClientImplAlarm.class);
+
+ private String ip;
+
+ private String userId;
+
+ private String password;
+
+ public PushClientImplAlarm(String ip, String userId, String password) {
+ this.ip = ip;
+ this.userId = userId;
+ this.password = password;
+ }
+
+ public PushClientImplAlarm() {
+
+ }
+
+ @Override
+ public void messageReceived(TcpClient tcpClient, PushMsg pushMsg)
+ throws Exception {
+ if("8001".equals(pushMsg.getCmd())) {//登录应答
+ String rspResult = MapUtil.getStrVal(pushMsg.getJsonMap(),"rspResult","1");
+ if("0".equals(rspResult)) {//登录成功，定阅动态消息
+ Map<String,Object> map = new HashMap<String,Object>();
+ map.put("seq", "1");
+ map.put("action", "add");
+ map.put("msgIds", JSON.toJSONString(getSubCmdSet()));
+ PushMsg subMsg = getInstance("0003",map);
+ sendMsg(subMsg);
+ }
+ }else if("8002".equals(pushMsg.getCmd())){//心跳应答
+
+ }else if("8003".equals(pushMsg.getCmd())){//订阅动态消息应答
+ String rspResult = MapUtil.getStrVal(pushMsg.getJsonMap(),"rspResult","1");
+ //log.error(String.format(" 订阅应答:%s", "0".equals(rspResult)?"成功":"失败"));
+ }else if("0200".equals(pushMsg.getCmd())) {//定位信息
+ Map<String,Object> gpsMap = pushMsg.getJsonMap();
+ String carName = MapUtil.getStrVal(gpsMap, "carName","");//获取车牌号
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ System.out.println(sdf.format(new Date()));
+ //log.error(String.format(" ---->收到定位数据:%s",JSON.toJSONString(gpsMap)));
+ /**
+ *
+ * 请加入三方集成方的业务逻辑
+ *
+ */
+ }else if("0300".equals(pushMsg.getCmd())) {//报警消息
+ Map<String,Object> alarmMap = pushMsg.getJsonMap();
+ /*String carName = MapUtil.getStrVal(alarmMap, "carName","");//获取车牌号
+ log.error(String.format(" ---->收到报警数据:%s",JSON.toJSONString(alarmMap)));*/
+ String carId = (String)alarmMap.get("carId");
+ Map<String,Object> result = ((ArdSyCarServiceImpl) SpringUtils.getBean("ardSyCarServiceImpl")).getArdSyCarAndDeptByCarId(carId);//查询车辆及部门
+ if(result != null){
+ alarmMap.putAll(result);
+ }
+ Map<Integer,Object> data = new HashMap();
+ data.put(40000, alarmMap);
+ ((ArdSyCarServiceImpl) SpringUtils.getBean("ardSyCarServiceImpl")).sendArdSyCarAlarmByCarId(carId,data);//查询车辆及部门
+ }else if("0401".equals(pushMsg.getCmd())) {//透传消息
+ Map<String,Object> dataMap = pushMsg.getJsonMap();
+ String carName = MapUtil.getStrVal(dataMap, "carName","");//获取车牌号
+ //log.error(String.format(" ---->收到透传数据:%s",JSON.toJSONString(dataMap)));
+ /**
+ *
+ * 请加入三方集成方的业务逻辑
+ *
+ */
+ }
+ }
+
+ public void sendMassage() {
+ try {
+ PushClientImplPosition client = new PushClientImplPosition();
+ client.setLog(false);//是否打印明文
+ client.setHost(this.ip);//服务器IP
+ client.setPort(10100);//服务器端口
+ client.setUserName(this.userId);//系统用户名
+ client.setPwd(this.password);//系统用户密码
+ client.setSubMsgIds("0300");//订阅的动态消息，多个动态消息使用|辟分，当前示例是订阅 定位消息(0x0200)和报警消息(0x0300)
+ client.setDesc("测试客户端");//客户端的描述，
+ client.start();
+ while(true) {
+ Thread.sleep(1000);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ @Override
+ public void run() {
+ sendMassage();
+ }
+}
diff --git a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
index bb667de..aa2e1b2 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -143,7 +143,7 @@
public void sendMassage() {
try {
PushClientImplPosition client = new PushClientImplPosition();
- client.setLog(true);//是否打印明文
+ client.setLog(false);//是否打印明文
client.setHost(this.ip);//服务器IP
client.setPort(10100);//服务器端口
client.setUserName(this.userId);//系统用户名
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyCarService.java b/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyCarService.java
index ce5df91..3538608 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyCarService.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyCarService.java
@@ -92,6 +92,11 @@
* 根据部门发送车辆实时位置
*/
public void sendArdSyCarPosition();
+
+ /**
+ * 根据部门发送车辆实时报警
+ */
+ public void sendArdSyCarAlarmByCarId(String carId, Map<Integer,Object> data);
// List<ArdSyCar> getArdSyCarWithRightByCarIdList(List<String> carIdList);
Results carListById(String id);
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
index 88fd800..7dc8c9e 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java
@@ -371,11 +371,17 @@
SysUser sysUser = userMapper.selectUserById(key);
String deptId = String.valueOf(sysUser.getDeptId());
Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
- System.out.println("/////////////");
- System.out.println(PositionContainer.getDeptPositionMap());
Map<Integer,Object> data = new HashMap();
data.put(30000, map.values());
WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
}
}
+
+ @Override
+ public void sendArdSyCarAlarmByCarId(String carId, Map<Integer,Object> data) {
+ List<SysUser> result = userMapper.getSysUserByCarId(carId);
+ for(SysUser sysUser : result){
+ WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sysUser.getUserId()), JSON.toJSONString(data));
+ }
+ }
}
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserMapper.java b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserMapper.java
index bf69eff..0d0b987 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserMapper.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/mapper/SysUserMapper.java
@@ -130,4 +130,10 @@
* @return 结果
*/
public SysUser checkEmailUnique(String email);
+
+ /**
+ * 根据车辆主键查询直属及上级用户
+ *
+ */
+ public List<SysUser> getSysUserByCarId(String carId);
}
diff --git a/ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml b/ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml
index 08396d0..5f916c9 100644
--- a/ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml
+++ b/ruoyi-system/src/main/resources/mapper/system/SysUserMapper.xml
@@ -283,4 +283,11 @@
</foreach>
</delete>
+ <select id="getSysUserByCarId" parameterType="java.lang.String" resultMap="SysUserResult">
+ select * from sys_user su where su.dept_id in (
+ select cast(unnest(array_append(string_to_array(sd.ancestors,','),
+ cast(sd.dept_id as text))) as int) from ard_sy_car asy
+ inner join sys_dept sd on asy.dept_id = sd.dept_id
+ where asy.car_id = #{carId})
+ </select>
</mapper>
\ No newline at end of file
--
Gitblit v1.9.3