配置

Merge branch 'refs/heads/dev_zc' into td_h5
2026-06-19 15:11:15 +08:00 · 2026-05-12 15:15:55 +08:00 · 2026-05-12 14:05:15 +08:00 · 2026-05-12 10:49:59 +08:00 · 2026-05-11 12:30:25 +08:00 · 2026-05-09 10:33:36 +08:00
21 changed files with 429 additions and 186 deletions
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/controller/ServerController.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/controller/ServerController.java
@@ -3,10 +3,7 @@ package org.dromara.mica.mqtt.server.controller;
 import com.alibaba.fastjson2.JSONObject;
 import org.dromara.mica.mqtt.server.service.impl.ServerService;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;

@RequestMapping("/mqtt/server")
@RestController
@@ -52,4 +49,55 @@ public class ServerController {
 		return service.set_time(body);
 	}

+	//手动触发抬杆
+	@PostMapping("/gpio_out")
+	public boolean gpio_out(@RequestBody JSONObject js) {
+		String sn = js.getString("sn");
+		Integer io = js.getInteger("io");
+		Integer value = js.getInteger("value");
+		return service.gpio_out(sn, io, value);
+	}
+
+	@PostMapping("/set_io_lock_status")
+	public JSONObject lock(@RequestBody JSONObject js) {
+		String sn = js.getString("sn");
+		Integer status = js.getInteger("status");
+		Integer ioout = js.getInteger("ioout");
+		boolean publish = service.set_io_lock_status(sn, status,ioout);
+		JSONObject jsonObject = new JSONObject();
+		if (publish) {
+			jsonObject.put("code", 200);
+		} else {
+			jsonObject.put("code", 500);
+		}
+		return jsonObject;
+	}
+
+	//开闸
+	@PostMapping("/set_io_lock_open")
+	public JSONObject lockOpen(@RequestBody JSONObject js) {
+		String sn = js.getString("sn");
+		boolean publish = service.lockOpen(sn);
+		JSONObject jsonObject = new JSONObject();
+		if (publish) {
+			jsonObject.put("code", 200);
+		} else {
+			jsonObject.put("code", 500);
+		}
+		return jsonObject;
+	}
+
+	//关闸
+	@PostMapping("/set_io_lock_close")
+	public JSONObject lockClose(@RequestBody JSONObject js) {
+		String sn = js.getString("sn");
+		boolean publish = service.lockClose(sn);
+		JSONObject jsonObject = new JSONObject();
+		if (publish) {
+			jsonObject.put("code", 200);
+		} else {
+			jsonObject.put("code", 500);
+		}
+		return jsonObject;
+	}
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarParkItem.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarParkItem.java
@@ -47,4 +47,14 @@ public class CarParkItem implements Serializable {
 	 */
 	private String area;

+	/**
+	 * 车位数量
+	 */
+	private Integer carsNum;
+
+	/**
+	 * 满车位自动锁杆：0：不锁，1：锁
+	 */
+	private Integer autoLock;
+
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarPassGather.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarPassGather.java
@@ -24,7 +24,7 @@ public class CarPassGather implements Serializable {
 	/**
 	 * id
 	 */
-	@TableId(type = IdType.AUTO)
+	@TableId(type = IdType.AUTO )
 	private Long id;

 	/**
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarPassRecord.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarPassRecord.java
@@ -5,8 +5,6 @@ import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;
-import org.apache.commons.lang3.builder.ToStringBuilder;
-import org.apache.commons.lang3.builder.ToStringStyle;

 import java.io.Serial;
 import java.io.Serializable;
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/IoLockEquipment.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/IoLockEquipment.java
@@ -10,8 +10,8 @@ import java.io.Serial;
 import java.io.Serializable;

@Data
-@TableName("sys_equipment")
-public class Equipment implements Serializable {
+@TableName("sys_io_lock_equipment")
+public class IoLockEquipment implements Serializable {

 	@Serial
 	private static final long serialVersionUID = 1L;
@@ -21,9 +21,6 @@ public class Equipment implements Serializable {
 	@TableId(type = IdType.AUTO)
 	private Long id;

-	/** 所属产品Id */
-	private Long productId;
-
 	/** 设备名称 */
 	private String name;

@@ -36,15 +33,6 @@ public class Equipment implements Serializable {
 	/** 设备密码 */
 	private String password;

-	/** 设备区域 */
-	private Long spaceId;
-
-	/** 设备位置 */
-	private Long pointId;
-
-	/** 对接状态(0未对接 1对接成功) */
-	private Long state;
-
 	/** 设备状态(0在线 1离线) */
 	private String flag;

--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java
@@ -21,6 +21,7 @@ import org.dromara.mica.mqtt.server.service.ICarParkItemService;
 import org.dromara.mica.mqtt.server.service.ICarParkRecordService;
 import org.dromara.mica.mqtt.server.service.ICarPassGatherService;
 import org.dromara.mica.mqtt.server.service.ICarPassRecordService;
+import org.dromara.mica.mqtt.server.service.impl.ServerService;
 import org.dromara.mica.mqtt.server.utils.AESUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -30,6 +31,7 @@ import org.tio.utils.hutool.StrUtil;
 import java.nio.charset.StandardCharsets;
 import java.util.Date;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;

@@ -45,24 +47,21 @@ public class CarMessageListener {
 	@Autowired
 	RedisService redisService;

-	@Autowired
-	ICarParkRecordService carParkRecordService;
+//	@Autowired
+//	ICarParkRecordService carParkRecordService;
+//
+//	@Autowired
+//	ICarPassRecordService carPassRecordService;
+//
+//	@Autowired
+//	ICarParkItemService carParkItemService;
+//
+//	@Autowired
+//	ICarPassGatherService carPassGatherService;

-	@Autowired
-	ICarPassRecordService carPassRecordService;
+//	private static String key = "1234567898765432";

-	@Autowired
-	ICarParkItemService carParkItemService;
-
-	@Autowired
-	ICarPassGatherService carPassGatherService;
-
-	private static String key = "1234567898765432";
-
-	//xa、jl、td、xj
-	private String jinjiangUrl = "http://127.0.0.1:6609/";
-	//zr
-//	private String jinjiangUrl = "http://192.168.155.42:6609/";
+//	private String jinjiangUrl = "http://127.0.0.1:6609/";

 	/**
 	 * 心跳
@@ -75,7 +74,7 @@ public class CarMessageListener {
 		String sn = topicVars.get("sn");
 		log.info("接收到来自客户端 [{}] 的心跳消息 -> Topic: {}", sn, topic);

-        // 更新客户端的最后心跳
+		// 更新客户端的最后心跳
 		redisService.setCacheObject(CacheConstants.EQUIPMENT_HEARTBEAT + sn, FlagEnums.ONLINE.getCode(), CacheConstants.OFFLINE_THRESHOLD, TimeUnit.MILLISECONDS);
 	}

@@ -85,7 +84,7 @@ public class CarMessageListener {
 	 * @param topic
 	 * @param message
 	 */
-	@MqttServerFunction("device/${sn}/message/down/white_list_operator/reply")
+	/*@MqttServerFunction("device/${sn}/message/down/white_list_operator/reply")
 	@Transactional(rollbackFor = Exception.class)
 	public void white_list_operator_reply(String topic, byte[] message) {
 		log.info("接收到车牌下发消息 -> Topic: {}, message: {}", topic, new String(message));
@@ -105,7 +104,7 @@ public class CarMessageListener {
 			carParkRecord.setSync("1");
 		}
 		carParkRecordService.updateByClientId(carParkRecord);
-	}
+	}*/

 	/**
 	 * 车牌入场出场识别监听
@@ -117,74 +116,98 @@ public class CarMessageListener {
 	public void ivs_result(String topic, Map<String, String> topicVars, byte[] message) throws Exception {
 		String sn = topicVars.get("sn");
 		log.info("接收到车辆识别消息 -> Topic: {}", topic);
-		CarParkItem carParkItem = carParkItemService.selectBySn(sn);
-
-		String data = new String(message, StandardCharsets.UTF_8);
-		JSONObject jsonObject = JSONObject.parseObject(data);
-		JSONObject payload = jsonObject.getJSONObject("payload");
-		String id = jsonObject.getString("id");
-		JSONObject alarmInfoPlate = payload.getJSONObject("AlarmInfoPlate");
-		JSONObject result = alarmInfoPlate.getJSONObject("result");
-		JSONObject plateResult = result.getJSONObject("PlateResult");
-		JSONObject carBrand = plateResult.getJSONObject("car_brand");
-		String license = plateResult.getString("license");
-		String colorType = plateResult.getString("colorType");
-		String str = "";
-		if ("5".equals(colorType)) {
-			str = AESUtil.decrptyAES_ECB(license, key).substring(0, 20);
-		} else {
-			str = AESUtil.decrptyAES_ECB(license, key).substring(0, 18);
-		}
-
-		license = AESUtil.UTF8decode(str);
-		log.info("解密前车牌：{}，解谜后的车牌:{}", plateResult.getString("license"), license);
-
-		//保存通行记录
-		CarPassRecord record = new CarPassRecord();
-		record.setCarColor(plateResult.getString("carColor"));
-		record.setColorType(colorType);
-		record.setDirection(plateResult.getString("direction"));
-		record.setLicense(license);
-		record.setDataType("0");
-		Map<String, Object> paramMap = new HashMap<>();
-		paramMap.put("url", plateResult.getString("full_image_content"));
-		String repose = HttpUtil.createPost(jinjiangUrl + "file/uploadMinioCarBase64")
-			.body(JSON.toJSONString(paramMap))
-			.execute()
-			.body();
-		log.info("imgRsp:{}", repose);
-		JSONObject imgRsp = JSONObject.parseObject(repose);
-		if (null != imgRsp && imgRsp.getInteger("code") == 200) {
-			record.setUrl(imgRsp.getJSONObject("data").getString("url"));
-		}
-		if (plateResult.containsKey("start_time")) {
-			log.info("拿到了时间：{}", plateResult.getLong("start_time"));
-			record.setPassTime(DateUtil.date(plateResult.getLong("start_time")));
-		} else {
-			log.info("没有拿到时间，默认当前时间");
-			record.setPassTime(DateUtil.date(new Date()));
-		}
-		record.setSn(sn);
-		record.setUniqueNo(id);
-		record.setParkId(carParkItem.getParkId());
-		record.setTriggerType(plateResult.getString("triggerType"));
-		record.setType(carBrand.getString("type"));
-		carPassRecordService.save(record);
-
-		//保存/删除在场数据
-		boolean isExist = carPassGatherService.exists(new QueryWrapper<CarPassGather>().eq("license", license));
-		//入场新增数据
-		if (StrUtil.equals(carParkItem.getWay(), "0") && !isExist) {
-			CarPassGather carPassGather = new CarPassGather();
-			carPassGather.setLicense(license);
-			carPassGather.setParkId(carParkItem.getParkId());
-			carPassGather.setArea(carParkItem.getArea());
-			carPassGather.setJoinTime(record.getPassTime());
-			carPassGather.setSn(sn);
-			carPassGatherService.save(carPassGather);
-		} else if (StrUtil.equals(carParkItem.getWay(), "1") && isExist) {//出场删除数据
-			carPassGatherService.deleteByLicense(license);
-		}
+//
+//		//如果开启了锁杆，且车位满了
+//		CarParkItem carParkItem = carParkItemService.selectBySn(sn);
+//		long count = carPassGatherService.count(new QueryWrapper<CarPassGather>().eq("park_id", carParkItem.getParkId()));
+//		if (StrUtil.equals(carParkItem.getWay(), "0") //入场
+//			&& carParkItem.getAutoLock() == 1 //开启了锁杆
+//			&& count >= carParkItem.getCarsNum()) { //车位满了
+//			log.info("车位满了，不记录入场数据");
+//			return;
+//		}
+//
+//		String data = new String(message, StandardCharsets.UTF_8);
+//		JSONObject jsonObject = JSONObject.parseObject(data);
+//		JSONObject payload = jsonObject.getJSONObject("payload");
+//		String id = jsonObject.getString("id");
+//		JSONObject alarmInfoPlate = payload.getJSONObject("AlarmInfoPlate");
+//		JSONObject result = alarmInfoPlate.getJSONObject("result");
+//		JSONObject plateResult = result.getJSONObject("PlateResult");
+//		JSONObject carBrand = plateResult.getJSONObject("car_brand");
+//		String license = plateResult.getString("license");
+//		String colorType = plateResult.getString("colorType");
+//		String str = "";
+//		if ("5".equals(colorType)) {
+//			str = AESUtil.decrptyAES_ECB(license, key).substring(0, 20);
+//		} else {
+//			str = AESUtil.decrptyAES_ECB(license, key).substring(0, 18);
+//		}
+//
+//		license = AESUtil.UTF8decode(str);
+//		log.info("解密前车牌：{}，解谜后的车牌:{}", plateResult.getString("license"), license);
+//
+//		//保存通行记录
+//		CarPassRecord record = new CarPassRecord();
+//		record.setCarColor(plateResult.getString("carColor"));
+//		record.setColorType(colorType);
+//		record.setDirection(plateResult.getString("direction"));
+//		record.setLicense(license);
+//		record.setDataType("0");
+//		Map<String, Object> paramMap = new HashMap<>();
+//		paramMap.put("url", plateResult.getString("full_image_content"));
+//		String repose = HttpUtil.createPost(jinjiangUrl + "file/uploadMinioCarBase64")
+//			.body(JSON.toJSONString(paramMap))
+//			.execute()
+//			.body();
+//		log.info("imgRsp:{}", repose);
+//		JSONObject imgRsp = JSONObject.parseObject(repose);
+//		if (null != imgRsp && imgRsp.getInteger("code") == 200) {
+//			record.setUrl(imgRsp.getJSONObject("data").getString("url"));
+//		}
+//		if (plateResult.containsKey("start_time")) {
+//			log.info("拿到了时间：{}", plateResult.getLong("start_time"));
+//			record.setPassTime(DateUtil.date(plateResult.getLong("start_time")));
+//		} else {
+//			log.info("没有拿到时间，默认当前时间");
+//			record.setPassTime(DateUtil.date(new Date()));
+//		}
+//		record.setSn(sn);
+//		record.setUniqueNo(id);
+//		record.setParkId(carParkItem.getParkId());
+//		record.setTriggerType(plateResult.getString("triggerType"));
+//		record.setType(carBrand.getString("type"));
+//		carPassRecordService.save(record);
+//
+//		//保存/删除在场数据
+//		boolean isExist = carPassGatherService.exists(new QueryWrapper<CarPassGather>().eq("license", license).eq("park_id", carParkItem.getParkId()));
+//		//入场新增数据
+//		if (StrUtil.equals(carParkItem.getWay(), "0") && !isExist) {
+//			CarPassGather carPassGather = new CarPassGather();
+//			carPassGather.setLicense(license);
+//			carPassGather.setParkId(carParkItem.getParkId());
+//			carPassGather.setArea(carParkItem.getArea());
+//			carPassGather.setJoinTime(record.getPassTime());
+//			carPassGather.setSn(sn);
+//			carPassGatherService.save(carPassGather);
+//
+//			//最后一辆车进场
+//			if (carParkItem.getAutoLock() == 1 && (count + 1) >= carParkItem.getCarsNum()) {
+//				List<String> snList = carParkItemService.selectSnByParkId(carParkItem.getParkId());
+//				for (String s : snList) {
+//					service.locked(s, 2, 0);
+//				}
+//			}
+//		} else if (StrUtil.equals(carParkItem.getWay(), "1") && isExist) {//出场删除数据
+//			carPassGatherService.deleteByLicense(license);
+//			//出去一辆车，有空位
+//			if (carParkItem.getAutoLock() == 1 && count == carParkItem.getCarsNum()) {
+//				List<String> snList = carParkItemService.selectSnByParkId(carParkItem.getParkId());
+//				for (String s : snList) {
+//					service.locked(s, 0, 0);
+//				}
+//			}
+//		}
 	}

 	/**
@@ -193,7 +216,7 @@ public class CarMessageListener {
 	 * @param topic
 	 * @param message
 	 */
-	@MqttServerFunction("device/${sn}/message/up/ivs_result_offline")
+	/*@MqttServerFunction("device/${sn}/message/up/ivs_result_offline")
 	public void ivs_result_offline(String topic, Map<String, String> topicVars, byte[] message) throws Exception {
 		String sn = topicVars.get("sn");
 		log.info("接收到车辆离线识别消息 -> Topic: {}", topic);
@@ -248,7 +271,7 @@ public class CarMessageListener {
 		record.setTriggerType(plateResult.getString("triggerType"));
 		record.setType(carBrand.getString("type"));
 		carPassRecordService.save(record);
-	}
+	}*/

 	/**
 	 * IO输出事件监听
@@ -274,9 +297,36 @@ public class CarMessageListener {
 	public void set_io_lock_status(String topic, byte[] message) {
 		log.info("IO锁定事件监听消息 -> Topic: {}, message: {}", topic, new String(message));
 		String data = new String(message, StandardCharsets.UTF_8);
-		log.info("IO锁定事件监听：{}", data);
+		JSONObject jsonObject = JSONObject.parseObject(data);
 	}

+	/**
+	 * 发布获取IO锁定状态监听
+	 *
+	 * @param topic
+	 * @param message
+	 */
+	@MqttServerFunction("device/${sn}/message/down/get_io_lock_status/reply")
+	public void get_io_lock_status(String topic, byte[] message) {
+		log.info("发布获取IO锁定状态监听消息 -> Topic: {}, message: {}", topic, new String(message));
+		String data = new String(message, StandardCharsets.UTF_8);
+		JSONObject jsonObject = JSONObject.parseObject(data);
+	}
+
+	/**
+	 * 发布获取IO状态监听
+	 *
+	 * @param topic
+	 * @param message
+	 */
+	@MqttServerFunction("device/${sn}/message/down/get_io_status/reply")
+	public void get_io_status(String topic, byte[] message) {
+		log.info("发布获取IO状态监听消息 -> Topic: {}, message: {}", topic, new String(message));
+		String data = new String(message, StandardCharsets.UTF_8);
+		JSONObject jsonObject = JSONObject.parseObject(data);
+	}
+
+
 	/**
 	 * 订阅离线数据数量
 	 *
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java
@@ -16,13 +16,10 @@

 package org.dromara.mica.mqtt.server.listener;

-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import lombok.extern.slf4j.Slf4j;
 import org.dromara.mica.mqtt.core.server.event.IMqttConnectStatusListener;
 import org.dromara.mica.mqtt.server.constant.CacheConstants;
-import org.dromara.mica.mqtt.server.entity.Equipment;
 import org.dromara.mica.mqtt.server.enums.FlagEnums;
-import org.dromara.mica.mqtt.server.mapper.EquipmentMapper;
 import org.dromara.mica.mqtt.server.redis.RedisService;
 import org.dromara.mica.mqtt.server.service.IEquipmentService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -30,8 +27,6 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.tio.core.ChannelContext;

-import java.util.concurrent.TimeUnit;
-
 /**
 * mqtt 连接状态
 *
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/mapper/CarParkItemMapper.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/mapper/CarParkItemMapper.java
@@ -12,6 +12,9 @@ import java.util.List;
@Mapper
 public interface CarParkItemMapper extends BaseMapper<CarParkItem> {

-	@Select("SELECT p.id,p.park_id parkId,p.way,p.equipment_id equipmentId,p.area  FROM car_park_item p left join sys_equipment e on p.equipment_id = e.id where e.sequence = #{sn} and e.product_id = 4 limit 1")
+	@Select("SELECT p.id,p.park_id parkId,k.auto_lock autoLock,k.cars_num carsNum,p.way,p.equipment_id equipmentId,p.area  FROM car_park_item p left join sys_equipment e on p.equipment_id = e.id LEFT JOIN car_park k on p.park_id = k.id where e.sequence = #{sn} and e.product_id = 4 limit 1")
 	CarParkItem selectBySn(@Param("sn") String sn);
+
+	@Select("SELECT e.sequence FROM car_park_item p left join sys_equipment e on p.equipment_id = e.id where p.park_id = #{parkId} and p.way = 0 and e.product_id = 4")
+	List<String> selectSnByParkId(@Param("parkId") String parkId);
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/mapper/EquipmentMapper.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/mapper/EquipmentMapper.java
@@ -2,10 +2,9 @@ package org.dromara.mica.mqtt.server.mapper;

 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
-import org.dromara.mica.mqtt.server.entity.CarInfo;
-import org.dromara.mica.mqtt.server.entity.Equipment;
+import org.dromara.mica.mqtt.server.entity.IoLockEquipment;

@Mapper
-public interface EquipmentMapper extends BaseMapper<Equipment> {
+public interface EquipmentMapper extends BaseMapper<IoLockEquipment> {

 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/pojo/DeviceIOLockRequestPO.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/pojo/DeviceIOLockRequestPO.java
@@ -0,0 +1,45 @@
+package org.dromara.mica.mqtt.server.pojo;
+
+import com.alibaba.fastjson2.JSONObject;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Data;
+
+@Data
+public class DeviceIOLockRequestPO {
+	/**
+	 * 消息ID，用于关联具体消息
+	 */
+	@JsonProperty("id")
+	private String id;
+
+	/**
+	 * 设备序列号
+	 */
+	@JsonProperty("sn")
+	private String sn;
+
+	/**
+	 * 消息名称
+	 */
+	@JsonProperty("name")
+	private String name;
+
+	/**
+	 * 消息版本，目前都填1.0
+	 */
+	@JsonProperty("version")
+	private String version = "1.0";
+
+	/**
+	 * 时间戳
+	 */
+	@JsonProperty("timestamp")
+	private long timestamp = System.currentTimeMillis() / 1000;
+
+	/**
+	 * 消息负载
+	 */
+	@JsonProperty("payload")
+	private JSONObject payload;
+
+}
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/pojo/OpenFloodgatePO.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/pojo/OpenFloodgatePO.java
@@ -0,0 +1,39 @@
+package org.dromara.mica.mqtt.server.pojo;
+
+
+import lombok.Data;
+import com.alibaba.fastjson2.JSONObject;
+
+@Data
+public class OpenFloodgatePO {
+	/**
+	 * 消息ID，用于关联具体消息
+	 */
+	private String id;
+
+	/**
+	 * 设备序列号
+	 */
+	private String sn;
+
+	/**
+	 * 消息名称（固定为gpio_out）
+	 */
+	private String name;
+
+	/**
+	 * 消息版本（目前都填1.0）
+	 */
+	private String version = "1.0";
+
+	/**
+	 * 时间戳
+	 */
+	private Long timestamp = System.currentTimeMillis() / 1000;
+
+	/**
+	 * 消息负载
+	 */
+	private JSONObject payload;
+
+}
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/ICarParkItemService.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/ICarParkItemService.java
@@ -3,7 +3,11 @@ package org.dromara.mica.mqtt.server.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import org.dromara.mica.mqtt.server.entity.CarParkItem;

+import java.util.List;
+
 public interface ICarParkItemService extends IService<CarParkItem> {

 	CarParkItem selectBySn(String sn);
+
+	List<String> selectSnByParkId(String parkId);
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/IEquipmentService.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/IEquipmentService.java
@@ -1,15 +1,15 @@
 package org.dromara.mica.mqtt.server.service;

 import com.baomidou.mybatisplus.extension.service.IService;
-import org.dromara.mica.mqtt.server.entity.Equipment;
+import org.dromara.mica.mqtt.server.entity.IoLockEquipment;

 import java.util.List;

-public interface IEquipmentService extends IService<Equipment> {
+public interface IEquipmentService extends IService<IoLockEquipment> {

-	Equipment selectEquipmentBySn(String sn);
+	IoLockEquipment selectEquipmentBySn(String sn);

-	List<Equipment> selectAllSnFlag();
+	List<IoLockEquipment> selectAllSnFlag();

 	void updateFlag(String sn, String flag);
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/impl/CarParkItemServiceImpl.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/impl/CarParkItemServiceImpl.java
@@ -1,6 +1,5 @@
 package org.dromara.mica.mqtt.server.service.impl;

-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.dromara.mica.mqtt.server.entity.CarParkItem;
 import org.dromara.mica.mqtt.server.mapper.CarParkItemMapper;
@@ -8,6 +7,8 @@ import org.dromara.mica.mqtt.server.service.ICarParkItemService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

+import java.util.List;
+
@Service
 public class CarParkItemServiceImpl extends ServiceImpl<CarParkItemMapper, CarParkItem> implements ICarParkItemService {

@@ -18,4 +19,9 @@ public class CarParkItemServiceImpl extends ServiceImpl<CarParkItemMapper, CarPa
 	public CarParkItem selectBySn(String sn) {
 		return carParkItemMapper.selectBySn(sn);
 	}
+
+	@Override
+	public List<String> selectSnByParkId(String parkId) {
+		return carParkItemMapper.selectSnByParkId(parkId);
+	}
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/impl/EquipmentServiceImpl.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/impl/EquipmentServiceImpl.java
@@ -2,7 +2,7 @@ package org.dromara.mica.mqtt.server.service.impl;

 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import org.dromara.mica.mqtt.server.entity.Equipment;
+import org.dromara.mica.mqtt.server.entity.IoLockEquipment;
 import org.dromara.mica.mqtt.server.mapper.EquipmentMapper;
 import org.dromara.mica.mqtt.server.service.IEquipmentService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -11,25 +11,25 @@ import org.springframework.stereotype.Service;
 import java.util.List;

@Service
-public class EquipmentServiceImpl extends ServiceImpl<EquipmentMapper, Equipment> implements IEquipmentService {
+public class EquipmentServiceImpl extends ServiceImpl<EquipmentMapper, IoLockEquipment> implements IEquipmentService {

 	@Autowired
 	EquipmentMapper equipmentMapper;

 	@Override
-	public Equipment selectEquipmentBySn(String sn) {
-		return equipmentMapper.selectOne(new QueryWrapper<Equipment>().eq("sequence", sn).eq("product_id", 4L).last("limit 1"));
+	public IoLockEquipment selectEquipmentBySn(String sn) {
+		return equipmentMapper.selectOne(new QueryWrapper<IoLockEquipment>().eq("sequence", sn).last("limit 1"));
 	}

 	@Override
-	public List<Equipment> selectAllSnFlag() {
-		return equipmentMapper.selectList(new QueryWrapper<Equipment>().eq("product_id", 4L).select("sequence", "flag"));
+	public List<IoLockEquipment> selectAllSnFlag() {
+		return equipmentMapper.selectList(new QueryWrapper<IoLockEquipment>().select("sequence", "flag"));
 	}

 	@Override
 	public void updateFlag(String sn, String flag) {
-		Equipment equipment = new Equipment();
+		IoLockEquipment equipment = new IoLockEquipment();
 		equipment.setFlag(flag);
-		equipmentMapper.update(equipment, new QueryWrapper<Equipment>().eq("sequence", sn).eq("product_id", 4L));
+		equipmentMapper.update(equipment, new QueryWrapper<IoLockEquipment>().eq("sequence", sn));
 	}
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/impl/ServerService.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/service/impl/ServerService.java
@@ -1,12 +1,18 @@
 package org.dromara.mica.mqtt.server.service.impl;

+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
 import lombok.extern.slf4j.Slf4j;
+import org.dromara.mica.mqtt.server.pojo.DeviceIOLockRequestPO;
+import org.dromara.mica.mqtt.server.pojo.OpenFloodgatePO;
+import org.dromara.mica.mqtt.server.utils.UuidUtil;
 import org.dromara.mica.mqtt.spring.server.MqttServerTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

 import java.nio.charset.StandardCharsets;
+import java.time.LocalDateTime;
+import java.time.ZoneId;

 /**
 * @author wsq
@@ -55,4 +61,81 @@ public class ServerService {
 		log.info("发布离线数据数量body:{},result:{}", body, result);
 		return result;
 	}
+
+	public boolean gpio_out(String sn, Integer io, Integer value) {
+		String operUrl = "device/%s/message/down/gpio_out";
+		String topic = String.format(operUrl, sn);
+		OpenFloodgatePO openFloodgatePO = new OpenFloodgatePO();
+		String uuid = "open_" + UuidUtil.getUuid();
+		openFloodgatePO.setId(uuid);
+		openFloodgatePO.setSn(sn);
+		openFloodgatePO.setName("gpio_out");
+		openFloodgatePO.setTimestamp(System.currentTimeMillis() / 1000);
+		openFloodgatePO.setPayload(this.buildGpioOut(io, value));
+		boolean result = server.publish(sn,topic, JSON.toJSONString(openFloodgatePO).getBytes(StandardCharsets.UTF_8));
+		log.info("gpio_out设备编码:{},result:{},请求体{}", sn,result,openFloodgatePO);
+		return result;
+	}
+
+
+	private JSONObject buildGpioOut(Integer io, Integer value) {
+		JSONObject body = new JSONObject();
+		body.put("delay", 500);
+		body.put("io", io);
+		body.put("value", value);
+		JSONObject payload = new JSONObject();
+		payload.put("type", "gpio_out");
+		payload.put("body", body);
+		return payload;
+	}
+
+	public boolean set_io_lock_status(String sn, Integer status, Integer ioout) {
+		String operUrl = "device/%s/message/down/set_io_lock_status";
+		String topic = String.format(operUrl, sn);
+		DeviceIOLockRequestPO deviceIOLockRequestPO = new DeviceIOLockRequestPO();
+		String uuid = "locked_" + UuidUtil.getUuid();
+		deviceIOLockRequestPO.setId(uuid);
+		deviceIOLockRequestPO.setSn(sn);
+		deviceIOLockRequestPO.setName("set_io_lock_status");
+		deviceIOLockRequestPO.setPayload(this.buildPayloadLocked(status, ioout));
+		return server.publish(sn,topic, JSON.toJSONString(deviceIOLockRequestPO).getBytes(StandardCharsets.UTF_8));
+	}
+
+	private JSONObject buildPayloadLocked(Integer status, Integer ioout) {
+		JSONObject payload = new JSONObject();
+		payload.put("type", "set_io_lock_status");
+		JSONObject body = new JSONObject();
+		//io口，摄像头接线口
+		body.put("ioout", ioout);
+		//0解锁 1高电平锁定（保持常抬） 2低电平锁定（保持常关）
+		body.put("status", status);
+		payload.put("body", body);
+		return payload;
+	}
+
+	public boolean lockOpen(String sn) {
+		String operUrl = "device/%s/message/down/gpio_out";
+		String topic = String.format(operUrl, sn);
+		OpenFloodgatePO openFloodgatePO = new OpenFloodgatePO();
+		String uuid = "open_" + UuidUtil.getUuid();
+		openFloodgatePO.setId(uuid);
+		openFloodgatePO.setSn(sn);
+		openFloodgatePO.setName("gpio_out");
+		openFloodgatePO.setTimestamp(System.currentTimeMillis() / 1000);
+		openFloodgatePO.setPayload(this.buildGpioOut(0, 2));
+		return server.publish(sn,topic, JSON.toJSONString(openFloodgatePO).getBytes(StandardCharsets.UTF_8));
+	}
+
+	public boolean lockClose(String sn) {
+		String operUrl = "device/%s/message/down/gpio_out";
+		String topic = String.format(operUrl, sn);
+		OpenFloodgatePO openFloodgatePO = new OpenFloodgatePO();
+		String uuid = "open_" + UuidUtil.getUuid();
+		openFloodgatePO.setId(uuid);
+		openFloodgatePO.setSn(sn);
+		openFloodgatePO.setName("gpio_out");
+		openFloodgatePO.setTimestamp(System.currentTimeMillis() / 1000);
+		openFloodgatePO.setPayload(this.buildGpioOut(1, 2));
+		return server.publish(sn,topic, JSON.toJSONString(openFloodgatePO).getBytes(StandardCharsets.UTF_8));
+	}
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/HeartbeatOnLineTask.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/HeartbeatOnLineTask.java
@@ -1,11 +1,9 @@
 package org.dromara.mica.mqtt.server.task;

-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import lombok.extern.slf4j.Slf4j;
 import org.dromara.mica.mqtt.server.constant.CacheConstants;
-import org.dromara.mica.mqtt.server.entity.Equipment;
+import org.dromara.mica.mqtt.server.entity.IoLockEquipment;
 import org.dromara.mica.mqtt.server.enums.FlagEnums;
-import org.dromara.mica.mqtt.server.mapper.EquipmentMapper;
 import org.dromara.mica.mqtt.server.redis.RedisService;
 import org.dromara.mica.mqtt.server.service.IEquipmentService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -30,32 +28,28 @@ public class HeartbeatOnLineTask {

 	@Scheduled(fixedRate = 15 * 1000)
 	public void run() {
-		// 添加异常捕获，防止单个任务异常导致定时任务线程阻塞
-		try {
-			log.info("===========心跳检测=============");
-			//查询车辆摄像头的编码和在线状态
-			List<Equipment> equipment = equipmentService.selectAllSnFlag();
+		log.info("===========心跳检测=============");
+		//查询车辆摄像头的编码和在线状态
+		List<IoLockEquipment> equipment = equipmentService.selectAllSnFlag();

-			for (Equipment equip : equipment) {
-				//缓存中有该设备心跳key
-				if (redisService.hasKey(CacheConstants.EQUIPMENT_HEARTBEAT + equip.getSequence())) {
-					String flag = redisService.getCacheObject(CacheConstants.EQUIPMENT_HEARTBEAT + equip.getSequence());
-					//有心跳，但是和数据库设备在线状态不一致
-					if (!StrUtil.equals(flag, equip.getFlag())) {
-						log.info("设备：{}，flag:{}", equip.getSequence(), flag);
-						equipmentService.updateFlag(equip.getSequence(), flag);
-					}
-				} else {
-					//没有心跳上传，且设备在线,将设备置为离线
-					if (StrUtil.equals(FlagEnums.ONLINE.getCode(), equip.getFlag())) {
-						log.info("设备：{}，无心跳离线", equip.getSequence());
-						equipmentService.updateFlag(equip.getSequence(), FlagEnums.OFFLINE.getCode());
-					}
+		for (IoLockEquipment equip : equipment) {
+			//缓存中有该设备心跳key
+			if (redisService.hasKey(CacheConstants.EQUIPMENT_HEARTBEAT + equip.getSequence())) {
+				String flag = redisService.getCacheObject(CacheConstants.EQUIPMENT_HEARTBEAT + equip.getSequence());
+				//有心跳，但是和数据库设备在线状态不一致
+				if (!StrUtil.equals(flag, equip.getFlag())) {
+					log.info("设备：{}，flag:{}", equip.getSequence(), flag);
+					equipmentService.updateFlag(equip.getSequence(), flag);
+				}
+			} else {
+				//没有心跳上传，且设备在线,将设备置为离线
+				if (StrUtil.equals(FlagEnums.ONLINE.getCode(), equip.getFlag())) {
+					log.info("设备：{}，无心跳离线", equip.getSequence());
+					equipmentService.updateFlag(equip.getSequence(), FlagEnums.OFFLINE.getCode());
 				}
 			}
-		} catch (Exception e) {
-			// 捕获所有异常并记录日志，确保定时任务能继续执行
-			log.error("HeartbeatOnLineTask 定时任务执行异常", e);
+
 		}
+
 	}
 }
--- a/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java
+++ b/example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/PlatePublishTask.java
@@ -48,7 +48,7 @@ public class PlatePublishTask {
 	/**
 	 * 定时查询数据库需要下发的车辆进行下发
 	 */
-	@Scheduled(fixedDelay = 8 * 1000)
+//	@Scheduled(fixedDelay = 8 * 1000)
 	public void run() {
 		// 添加异常捕获，防止单个任务异常导致定时任务线程阻塞
 		try {
--- a/example/mqtt-car/src/main/resources/application-dev.yml
+++ b/example/mqtt-car/src/main/resources/application-dev.yml
@@ -1,7 +1,7 @@
 spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://127.0.0.1:3306/xa_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
+    url: jdbc:mysql://127.0.0.1:3306/td_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
    username: root
    password: root
    # Druid 连接池配置
--- a/example/mqtt-car/src/main/resources/application-prod.yml
+++ b/example/mqtt-car/src/main/resources/application-prod.yml
@@ -1,26 +1,10 @@
 spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
-    #xa
-#    url: jdbc:mysql://127.0.0.1:3306/xa_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
-#    username: root
-#    password: Xahg2024.
-    #jl
-#    url: jdbc:mysql://127.0.0.1:3306/jl_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
-#    username: root
-#    password: JL202509jj
    #td
-#    url: jdbc:mysql://127.0.0.1:3306/td_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
-#    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&connectTimeout=5000&socketTimeout=30000
-#    username: root
-#    password: zr202407.J
-    #xj
-    url: jdbc:mysql://127.0.0.1:3306/xj_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
+    url: jdbc:mysql://192.168.251.16:3306/td_cloud?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&connectTimeout=5000&socketTimeout=30000
    username: root
-    password: XjJN2024!
+    password: td@JJ2024
    # Druid 连接池配置
    druid:
      max-active: 20
@@ -35,13 +19,10 @@ spring:
      min-evictable-idle-time-millis: 300000
  data:
    redis:
-      #zr
-#      host: 192.168.155.42
-      #xa、jl、td、xj
-      host: 127.0.0.1
+      host: 192.168.251.16
      port: 6379
      password:
-      database: 1
+      database: 2
      # Redis 超时配置，防止连接阻塞
      timeout: 5000ms
      lettuce:
--- a/example/mqtt-car/src/main/resources/application.yml
+++ b/example/mqtt-car/src/main/resources/application.yml
@@ -6,8 +6,8 @@ spring:
    name: mica-mqtt-server
  # 环境 dev|test|prod
  profiles:
-    active: dev
-#    active: prod
+#    active: dev
+    active: prod
  messages:
    encoding: UTF-8
    basename: i18n/messages
Author	SHA1	Message	Date
zc	d43acc31d9	配置	2026-06-19 15:11:15 +08:00
zc	58b76371c5	配置	2026-05-12 15:15:55 +08:00
zc	e9a698c728	Merge branch 'refs/heads/dev_zc' into td_h5 # Conflicts: # example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/entity/CarPassGather.java # example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/listener/CarMessageListener.java # example/mqtt-car/src/main/java/org/dromara/mica/mqtt/server/task/HeartbeatOnLineTask.java # example/mqtt-car/src/main/resources/application-dev.yml # example/mqtt-car/src/main/resources/application-prod.yml	2026-05-12 14:05:15 +08:00
zc	2248060905	h5提交	2026-05-12 10:49:59 +08:00
zc	17eb0c69ff	配置	2026-05-11 12:30:25 +08:00
zc	985ec252c6	开关闸控制	2026-05-09 10:33:36 +08:00
zc	7871c2ac70	满车位锁杆	2026-04-30 14:49:53 +08:00