在data-gateway-eg-kat服务模块中增加查询db数据库文件数据查询逻辑，查询设备配置数据

data-gateway/data-gateway-eg-kat/pom.xml

@@ -51,16 +51,18 @@
             <artifactId>spring-boot-configuration-processor</artifactId>
             <optional>true</optional>
         </dependency>
-<!--        <dependency>-->
-<!--            <groupId>org.springframework.boot</groupId>-->
-<!--            <artifactId>spring-boot-starter-test</artifactId>-->
-<!--            <scope>test</scope>-->
-<!--        </dependency>-->
-        <!-- Pagehelper -->
-<!--        <dependency>-->
-<!--            <groupId>com.github.pagehelper</groupId>-->
-<!--            <artifactId>pagehelper-spring-boot-starter</artifactId>-->
-<!--        </dependency>-->
+        <!-- sqlite3驱动包 -->
+        <dependency>
+            <groupId>org.xerial</groupId>
+            <artifactId>sqlite-jdbc</artifactId>
+            <version>3.42.0.1</version>
+        </dependency>
+        <!--mybatis-plus插件-->
+        <dependency>
+            <groupId>com.baomidou</groupId>
+            <artifactId>mybatis-plus-boot-starter</artifactId>
+            <version>3.5.5</version>
+        </dependency>
 
     </dependencies>
 

data-gateway/data-gateway-eg-kat/src/main/java/com/usky/gateway/domain/GatewayDeviceConfig.java

@@ -0,0 +1,20 @@
+package com.usky.gateway.domain;
+
+import lombok.Data;
+
+@Data
+public class GatewayDeviceConfig {
+
+    private String productCode;
+
+    private String deviceId;
+
+    private String ip;
+    private String port;
+
+    private String param1;
+    private String param2;
+    private String param3;
+    private String param4;
+    private String param5;
+}

data-gateway/data-gateway-eg-kat/src/main/java/com/usky/gateway/mapper/GatewayDeviceConfigMapper.java

@@ -0,0 +1,18 @@
+package com.usky.gateway.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.usky.gateway.domain.GatewayDeviceConfig;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+/**
+ * <p>
+ * 用户信息表 Mapper 接口
+ * </p>
+ *
+ * @since 2022-04-21
+ */
+@Repository
+@Mapper
+public interface GatewayDeviceConfigMapper extends BaseMapper<GatewayDeviceConfig> {}  // 结合mybatis plus
+

data-gateway/data-gateway-eg-kat/src/main/java/com/usky/gateway/service/mqtt/control/control.java

@@ -2,6 +2,10 @@ package com.usky.gateway.service.mqtt.control;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.usky.gateway.domain.GatewayDeviceConfig;
+import com.usky.gateway.mapper.GatewayDeviceConfigMapper;
 import com.usky.gateway.service.config.mqtt.MqttOutConfig;
 import com.usky.gateway.service.config.udp.UdpBaseConfig;
 import com.usky.gateway.service.mqtt.MqttStrategy;
@@ -13,6 +17,7 @@ import lombok.Data;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Service;
 
@@ -24,11 +29,11 @@ import java.util.Map;
 @Configuration
 @Data
 public class control implements MqttStrategy {
-    @Value("${udp.deviceIp}")
-    private String deviceIp;
-
-    @Value("${udp.sendingPort}")
-    private Integer sendingPort;
+//    @Value("${udp.deviceIp}")
+//    private String deviceIp;
+//
+//    @Value("${udp.sendingPort}")
+//    private Integer sendingPort;
 
     @Autowired
     private UdpUtil udpUtil;
@@ -37,42 +42,62 @@ public class control implements MqttStrategy {
     @Resource
     private MqttOutConfig.MqttGateway mqttGateway;
 
+    @Autowired
+    private GatewayDeviceConfigMapper gatewayDeviceConfigMapper;
+
     //处理下发命令消息，下发命令控制设备
     public String disposeMessage(MqttBaseVO mqttBaseVO) {
-//        Map map_data = JsonUtils.fromJson(mqttBaseVO.getData().toString(), Map.class);
+        String[] topics = mqttBaseVO.getTopic().split("/");
+        String productCode = topics[1];
         JSONObject obj_data = JSONObject.parseObject(mqttBaseVO.getData().toString());
         Integer commandId = Integer.parseInt(obj_data.get("id").toString());
         Object params = JSONObject.toJSONString(obj_data.get("params"));
         JSONObject params_data = JSON.parseObject(params.toString());
-        Integer deviceId = Integer.parseInt(params_data.getString("device_id"));
+        String deviceId = params_data.getString("deviceId");
+        String commandCode = params_data.getString("commandCode");
+        String commandValue = params_data.getString("commandValue");
 
         //开门   17 40 00 00 E0 F4 4D 0D 01 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00
-        byte[] deviceByte = byteUtil.toLH(deviceId);
-        byte[] requestBytes = new byte[] { 0x17, 0x40, 0x00, 0x00, deviceByte[0], deviceByte[1], deviceByte[2], deviceByte[3], 0x01, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 };
-        byteUtil.printBytes(requestBytes);
-        String responseData = udpUtil.sendUDPRequest(this.getDeviceIp(), this.getSendingPort(), requestBytes);
-
-        //推送下发命令响应mqtt
-        JSONObject jsonObject = new JSONObject();
-        byte[] responseByte = responseData.getBytes(Charset.forName("ISO-8859-1"));  //"US-ASCII"
-        byteUtil.printBytes(responseByte);
-
-        if(responseByte[8] == 0x01){
-            jsonObject.put("result","success");
-
-        }else{
-            JSONObject obj1 = new JSONObject();
-            obj1.put("code",-1);
-            obj1.put("message","open failed");
-            jsonObject.put("error",obj1);
-
+        if(commandCode.equals("door_onoff")){
+            //通过查询db文件获取对应udpIp udpPort 目标设备id 门号
+            LambdaQueryWrapper<GatewayDeviceConfig> queryWrapper = Wrappers.lambdaQuery();
+            queryWrapper.select(GatewayDeviceConfig::getIp,GatewayDeviceConfig::getPort,GatewayDeviceConfig::getParam1,GatewayDeviceConfig::getParam2)
+                    .eq(GatewayDeviceConfig::getProductCode,productCode)
+                    .eq(GatewayDeviceConfig::getDeviceId,deviceId);
+            GatewayDeviceConfig one = gatewayDeviceConfigMapper.selectOne(queryWrapper);
+            if(one != null){
+                String devId = one.getParam1();
+                byte[] deviceByte = byteUtil.toLH(Integer.parseInt(devId));
+                int doorNum = Integer.parseInt(one.getParam2());
+                byte bDoorNum = (byte)doorNum;
+                byte[] requestBytes = new byte[] { 0x17, 0x40, 0x00, 0x00, deviceByte[0], deviceByte[1], deviceByte[2], deviceByte[3], bDoorNum, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00 };
+                byteUtil.printBytes(requestBytes);
+                String responseData = udpUtil.sendUDPRequest(one.getIp(), Integer.parseInt(one.getPort()), requestBytes);
+
+                //推送下发命令响应mqtt
+                JSONObject jsonObject = new JSONObject();
+                byte[] responseByte = responseData.getBytes(Charset.forName("ISO-8859-1"));  //"US-ASCII"
+                byteUtil.printBytes(responseByte);
+
+                if(responseByte[8] == 0x01){
+                    jsonObject.put("result","success");
+
+                }else{
+                    JSONObject obj1 = new JSONObject();
+                    obj1.put("code",-1);
+                    obj1.put("message","open failed");
+                    jsonObject.put("error",obj1);
+
+                }
+
+                jsonObject.put("timeStamp",System.currentTimeMillis());
+                jsonObject.put("id",commandId);
+
+                String res_topic = mqttBaseVO.getTopic().replace("control","controlResponse");
+                mqttGateway.sendToMqtt(res_topic,jsonObject.toJSONString());
+            }
         }
 
-        jsonObject.put("timeStamp",System.currentTimeMillis());
-        jsonObject.put("id",commandId);
-
-        String res_topic = mqttBaseVO.getTopic().replace("control","controlResponse");
-        mqttGateway.sendToMqtt(res_topic,jsonObject.toJSONString());
 
         return null;
     }

data-gateway/data-gateway-eg-kat/src/main/resources/application.yml

@@ -31,6 +31,12 @@ spring:
     multipart:
       max-file-size: 10MB
       max-request-size: 15MB
+  datasource:
+    name: sqlite3
+    url: jdbc:sqlite::resource:db/yt_gateway.db
+    driver-class-name: org.sqlite.JDBC
+    username:
+    password:
 
 temp:
   basedir: C:/Users/pc/Desktop/
@@ -47,6 +53,6 @@ mqtt:
   url: tcp://47.98.201.73:1883
   username: usky
 # 和嵌入式udp通信的发送端口和监听端口地址
-udp:
-  deviceIp: 192.168.123.44
-  sendingPort: 60000
+#udp:
+#  deviceIp: 192.168.123.44
+#  sendingPort: 60000