From c511bd724b1a34411b8e28116bbc5baf9353a03d Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: 星期六, 22 七月 2023 09:56:40 +0800
Subject: [PATCH] 三一车辆sdk引入提交
---
ard-work/pom.xml | 52 ++++++++
ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java | 2
ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java | 5
ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java | 27 ++++
ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml | 3
ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java | 6 +
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java | 123 ++++++++++++++++++++
ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImpl.java | 109 ++++++++++++++++++
8 files changed, 326 insertions(+), 1 deletions(-)
diff --git a/ard-work/pom.xml b/ard-work/pom.xml
index 2e3a240..eec47b0 100644
--- a/ard-work/pom.xml
+++ b/ard-work/pom.xml
@@ -123,7 +123,57 @@
<artifactId>fastjson2</artifactId>
<version>2.0.36</version>
</dependency>
-
+ <!--涓変竴杞﹁締渚濊禆-->
+ <dependency>
+ <groupId>commons-codec</groupId>
+ <artifactId>commons-codec</artifactId>
+ <version>1.14</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-collections4</artifactId>
+ <version>4.4</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-lang3</artifactId>
+ <version>3.9</version>
+ </dependency>
+ <dependency>
+ <groupId>commons-logging</groupId>
+ <artifactId>commons-logging</artifactId>
+ <version>1.2</version>
+ </dependency>
+ <dependency>
+ <groupId>com.alibaba</groupId>
+ <artifactId>fastjson</artifactId>
+ <version>1.2.35</version>
+ </dependency>
+ <dependency>
+ <groupId>com.sy</groupId>
+ <artifactId>gps-push-client</artifactId>
+ <version>1.0.0</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-api</artifactId>
+ <version>2.12.1</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-core</artifactId>
+ <version>2.12.1</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.logging.log4j</groupId>
+ <artifactId>log4j-jcl</artifactId>
+ <version>2.11.2</version>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-all</artifactId>
+ <version>4.1.63.Final</version>
+ </dependency>
</dependencies>
<build>
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 2eb89b7..27d8afc 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
@@ -4,6 +4,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import javax.annotation.PostConstruct;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@@ -12,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.PushClientImplPosition;
import com.ruoyi.sy.service.IArdSyUserService;
import com.ruoyi.sy.service.SysParaService;
import com.ruoyi.system.domain.SysConfig;
@@ -60,6 +62,31 @@
@Autowired
private IArdSyUserService iArdSyUserService;
+ private ArdSyCarController ardSyCarController;
+
+ @PostConstruct
+ public void init(){
+ ardSyCarController = this;
+ ardSyCarController.sysConfigService = this.sysConfigService;
+ ardSyCarController.iArdSyUserService = this.iArdSyUserService;
+
+ SysConfig config = new SysConfig();
+ config.setConfigKey("syCarPT");
+ List<SysConfig> sysConfigResult = sysConfigService.selectConfigList(config);
+ String syURL = "";
+ if(sysConfigResult.size() == 0){
+ return;
+ }else{
+ syURL = sysConfigResult.get(0).getConfigValue();
+ }
+ String ip = syURL.split(":")[1].replace("//", "");
+ List<ArdSyUser> ardSyUserList = iArdSyUserService.selectSyUser();
+ //杞﹁締瀹炴椂浣嶇疆绾跨▼
+ PushClientImplPosition pushClientImplPosition = new PushClientImplPosition(ip,ardSyUserList.get(0).getUserId(),ardSyUserList.get(0).getPassword());
+ Thread pushClientImplPositionThread = new Thread(pushClientImplPosition);
+ pushClientImplPositionThread.start();
+ }
+
/**
* 鏌ヨ涓変竴杞﹁締鍒楄〃
*/
diff --git a/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImpl.java b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImpl.java
new file mode 100644
index 0000000..ba6bc30
--- /dev/null
+++ b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImpl.java
@@ -0,0 +1,109 @@
+/**
+ * <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 java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+
+import com.alibaba.fastjson2.JSON;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+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;
+/**
+ * <p>Description: </p>
+ * <p>Copyright: Copyright (c) 2020</p>
+ * <p>Company: www.31gps.net</p>
+ * @author chencq
+ * @version 1.0
+ */
+public class PushClientImpl extends PushClient{
+ private static final Log log = LogFactory.getLog(PushClientImpl.class);
+
+ @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)));
+ /**
+ *
+ * 璇峰姞鍏ヤ笁鏂归泦鎴愭柟鐨勪笟鍔￠�昏緫
+ *
+ */
+ }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 static void main(String[] args) {
+ try {
+ PushClientImpl client = new PushClientImpl();
+ client.setLog(true);//鏄惁鎵撳嵃鏄庢枃
+ //client.setLogBytes(true);//鏄惁鎵撳嵃缃戠粶瀛楄妭娴�
+ //client.setHost("106.14.186.44");//鏈嶅姟鍣↖P
+ client.setHost("116.182.15.14");//鏈嶅姟鍣↖P
+ client.setPort(10100);//鏈嶅姟鍣ㄧ鍙�
+ //client.setUserName("ys_admin");//绯荤粺鐢ㄦ埛鍚�
+ //client.setPwd("123456");//绯荤粺鐢ㄦ埛瀵嗙爜
+ //client.setUserName("admin_dqard");//绯荤粺鐢ㄦ埛鍚�
+ //client.setUserName("dqard");//绯荤粺鐢ㄦ埛鍚�
+ //client.setPwd("123456");//绯荤粺鐢ㄦ埛瀵嗙爜
+ client.setUserName("admin");//绯荤粺鐢ㄦ埛鍚�
+ client.setPwd("654321");//绯荤粺鐢ㄦ埛瀵嗙爜
+ //client.setSubMsgIds("0200|0300");//璁㈤槄鐨勫姩鎬佹秷鎭紝澶氫釜鍔ㄦ�佹秷鎭娇鐢▅杈熷垎锛屽綋鍓嶇ず渚嬫槸璁㈤槄 瀹氫綅娑堟伅(0x0200)鍜屾姤璀︽秷鎭�(0x0300)
+ client.setSubMsgIds("0200");//璁㈤槄鐨勫姩鎬佹秷鎭紝澶氫釜鍔ㄦ�佹秷鎭娇鐢▅杈熷垎锛屽綋鍓嶇ず渚嬫槸璁㈤槄 瀹氫綅娑堟伅(0x0200)鍜屾姤璀︽秷鎭�(0x0300)
+ client.setDesc("娴嬭瘯瀹㈡埛绔�");//瀹㈡埛绔殑鎻忚堪锛�
+ client.start();
+ while(true) {
+ Thread.sleep(1000);
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+}
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
new file mode 100644
index 0000000..00765d5
--- /dev/null
+++ b/ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java
@@ -0,0 +1,123 @@
+/**
+ * <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 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 PushClientImplPosition extends PushClient implements Runnable {
+
+ private static final Log log = LogFactory.getLog(PushClientImplPosition.class);
+
+ private String ip;
+
+ private String userId;
+
+ private String password;
+
+ public PushClientImplPosition(String ip, String userId, String password) {
+ this.ip = ip;
+ this.userId = userId;
+ this.password = password;
+ }
+
+ public PushClientImplPosition() {
+
+ }
+
+ @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)));
+ /**
+ *
+ * 璇峰姞鍏ヤ笁鏂归泦鎴愭柟鐨勪笟鍔￠�昏緫
+ *
+ */
+ }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(true);//鏄惁鎵撳嵃鏄庢枃
+ client.setHost(this.ip);//鏈嶅姟鍣↖P
+ client.setPort(10100);//鏈嶅姟鍣ㄧ鍙�
+ client.setUserName(this.userId);//绯荤粺鐢ㄦ埛鍚�
+ client.setPwd(this.password);//绯荤粺鐢ㄦ埛瀵嗙爜
+ client.setSubMsgIds("0200");//璁㈤槄鐨勫姩鎬佹秷鎭紝澶氫釜鍔ㄦ�佹秷鎭娇鐢▅杈熷垎锛屽綋鍓嶇ず渚嬫槸璁㈤槄 瀹氫綅娑堟伅(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/mapper/ArdSyUserMapper.java b/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java
index 79b167b..bf59b58 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/mapper/ArdSyUserMapper.java
@@ -81,4 +81,6 @@
Map<String,Object> selectArdSyUserByUsersId(Integer usersId);
ArdSyUser userById(String id);
+
+ public List<ArdSyUser> selectSyUser();
}
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java b/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java
index cdb48ea..7dc55ef 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/IArdSyUserService.java
@@ -77,4 +77,9 @@
Map<String,Object> selectArdSyUserByUsersId(Integer usersId);
ArdSyUser userById(String id);
+
+ /**
+ * 鏌ヨ鏈寕鎺ヤ笁涓�杞﹁締璐﹀彿瀵嗙爜
+ */
+ public List<ArdSyUser> selectSyUser();
}
diff --git a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java
index de6ae1b..0a97740 100644
--- a/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyUserServiceImpl.java
@@ -126,4 +126,10 @@
public ArdSyUser userById(String id) {
return ardSyUserMapper.userById(id);
}
+
+ @Override
+ public List<ArdSyUser> selectSyUser() {
+ List<ArdSyUser> result = ardSyUserMapper.selectSyUser();
+ return result;
+ }
}
diff --git a/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml b/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml
index 7918055..d33f4d4 100644
--- a/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml
+++ b/ard-work/src/main/resources/mapper/sy/ArdSyUserMapper.xml
@@ -137,4 +137,7 @@
<include refid="selectArdSyUserVo"/>
where sys_user_id = #{id}
</select>
+ <select id="selectSyUser" resultMap="ArdSyUserResult">
+ select distinct asu.user_id,asu.password from ard_sy_user asu
+ </select>
</mapper>
\ No newline at end of file
--
Gitblit v1.9.3