XA/mqtt-car
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码优化

Browse Source
This commit is contained in:
zc
2025-12-19 10:03:36 +08:00
parent cb619195fd
commit 88ba83a5b3
2 changed files with 23 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java
View File

@@ -27,6 +27,7 @@ import org.springframework.transaction.annotation.Transactional;
import org.tio.utils.hutool.StrUtil; import org.tio.utils.hutool.StrUtil;
import java.nio.charset.StandardCharsets; import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@@ -57,7 +58,8 @@ public class CarMessageListener {
private static String key = "1234567898765432"; private static String key = "1234567898765432";
private String jinjiangUrl = "http://127.0.0.1:6609/"; // private String jinjiangUrl = "http://127.0.0.1:6609/";
private String jinjiangUrl = "http://192.168.155.42:6609/";
/** /**
* 心跳 * 心跳
@@ -119,6 +121,7 @@ public class CarMessageListener {
JSONObject alarmInfoPlate = payload.getJSONObject("AlarmInfoPlate"); JSONObject alarmInfoPlate = payload.getJSONObject("AlarmInfoPlate");
JSONObject result = alarmInfoPlate.getJSONObject("result"); JSONObject result = alarmInfoPlate.getJSONObject("result");
JSONObject plateResult = result.getJSONObject("PlateResult"); JSONObject plateResult = result.getJSONObject("PlateResult");
log.info("临时日志：{}", JSON.toJSONString(plateResult));
JSONObject carBrand = plateResult.getJSONObject("car_brand"); JSONObject carBrand = plateResult.getJSONObject("car_brand");
String license = plateResult.getString("license"); String license = plateResult.getString("license");
String colorType = plateResult.getString("colorType"); String colorType = plateResult.getString("colorType");
@@ -150,7 +153,8 @@ public class CarMessageListener {
if (null != imgRsp && imgRsp.getInteger("code") == 200) { if (null != imgRsp && imgRsp.getInteger("code") == 200) {
record.setUrl(imgRsp.getJSONObject("data").getString("url")); record.setUrl(imgRsp.getJSONObject("data").getString("url"));
} }
record.setPassTime(DateUtil.date(plateResult.getLong("start_time"))); // record.setPassTime(DateUtil.date(plateResult.getLong("start_time")));
record.setPassTime(new Date());
record.setSn(sn); record.setSn(sn);
record.setUniqueNo(id); record.setUniqueNo(id);
record.setTriggerType(plateResult.getString("triggerType")); record.setTriggerType(plateResult.getString("triggerType"));
@@ -222,7 +226,8 @@ public class CarMessageListener {
if (null != imgRsp && imgRsp.getInteger("code") == 200) { if (null != imgRsp && imgRsp.getInteger("code") == 200) {
record.setUrl(imgRsp.getJSONObject("data").getString("url")); record.setUrl(imgRsp.getJSONObject("data").getString("url"));
} }
record.setPassTime(DateUtil.date(plateResult.getLong("start_time"))); // record.setPassTime(DateUtil.date(plateResult.getLong("start_time")));
record.setPassTime(new Date());
record.setSn(sn); record.setSn(sn);
record.setUniqueNo(id); record.setUniqueNo(id);
record.setTriggerType(plateResult.getString("triggerType")); record.setTriggerType(plateResult.getString("triggerType"));

19
example/mqtt-car/src/main/resources/application-prod.yml
View File

@@ -1,17 +1,28 @@
spring: spring:
datasource: datasource:
driver-class-name: com.mysql.cj.jdbc.Driver driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/jl_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
#xa #xa
# url: jdbc:mysql://127.0.0.1:3306/xa_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
# username: root
# password: Xahg2024. # password: Xahg2024.
#jl #jl
# url: jdbc:mysql://127.0.0.1:3306/jl_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
# username: root
# password: JL202509jj # password: JL202509jj
#td #td
password: td@JJ2024 # url: jdbc:mysql://127.0.0.1:3306/td_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
# username: root
# password: td@JJ2024
#zr
url: jdbc:mysql://192.168.155.42:3306/zr_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
username: root
password: zr202407.J
data: data:
redis: redis:
host: 127.0.0.1 #zr
host: 192.168.155.42
#xa、jl、td
# host: 127.0.0.1
port: 6379 port: 6379
password: password:
database: 1 database: 1