完善test的配置

yangys

2025-04-10 5367cf982379f91f81a9b8328f07714dbbf3045c

完善test的配置

 collect/src/main/java/com/qianwen/mdc/collect/handler/AlarmDataHandler.java

@@ -2,6 +2,7 @@

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;

import org.slf4j.Logger;
@@ -14,6 +15,8 @@
import com.qianwen.mdc.collect.dto.PackedTelemetryData;
import com.qianwen.mdc.collect.entity.iotdb.Alarm;
import com.qianwen.mdc.collect.service.AlarmService;

import cn.hutool.core.util.ObjectUtil;

@Component
public class AlarmDataHandler implements TelemetryDataHandler {
@@ -31,6 +34,9 @@
    }
    
    List<Alarm> parseAlarm(PackedTelemetryData data){
        if(ObjectUtil.isEmpty(data.getValue())) {
            return Collections.emptyList();
        }
        List<Alarm> alarmList = new ArrayList<>();
        //828d json数组格式[{"alarmNo":"8084"}]
        JSONArray alarmArr = JSONArray.parseArray(data.getValue());

 collect/src/main/resources/application-test.yml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,59 @@
spring:
  redis:
    database: 5 #5
    host: 120.46.212.231
    port: 6379
    password: root
    timeout: 3000
  thymeleaf:
    cache: false

#MQTT-服务端地址

mqtt:
  host: tcp://broker.emqx.io:1883
  #username=admin #MQTT-服务端用户名
  #password=public #MQTT-服务端密码
  cleansession: false #MQTT-是否清理session
  #MQTT-当前客户端的唯一标识
  clientid: mqtt_publish
  default_topic: TEST #当前客户端的默认主题(大多数时候没什么用)
  #连接超时时间
  timeout: 3000
  #心跳时间
  keepalive: 10
  connectionTimeout: 3000 #连接超时时间
  dataReceiveTopic: forward/testxx #从iot平台接收mqtt采集数据的topic forward/test
  # mysql
datasource:
  type: mysql
  url: jdbc:mysql://120.46.212.231:3306/smartman?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true
  port: 3306
  username: qwmdc
  password: Kknd_1234
  driver-class-name: com.mysql.cj.jdbc.Driver
#iotdb ä»¥åŠå…¶jdbc一起配置
iotdb:
  driver: org.apache.iotdb.jdbc.IoTDBDriver
  host: 120.46.212.231 #120.46.212.231 localhost 116.63.148.72
  port: 6667
  maxSize: 100
  username: root
  password: root

xxl:
  job:
    admin:
      ### xxl-job admin address list, such as "http://address" or "http://address01,http://address02"
      addresses: http://127.0.0.1:8080/xxl-job-admin
      ### xxl-job executor address
    executor:
      appname: qwmdc-collect
      ip: 
      port: 8802
      ### xxl-job log path
      logpath: /qwlogs/xxl-job/jobhandler
      ### xxl-job log remain days
      logretentiondays: 7
    ### xxl-job, access token
    accessToken:

 collect/src/main/resources/logback.xml

@@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration debug="false">
    <!--定义日志文件的存储地址 å‹¿åœ¨ LogBack çš„配置中使用相对路径-->
    <property name="LOG_HOME" value="/var/log" />
    <property name="LOG_HOME" value="/var/collect/logs" />
    <!-- æŽ§åˆ¶å°è¾“出 -->
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
    <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">