Merge remote-tracking branch 'origin/master'

liuhaonan

2021-12-17 d2bf8caa38cc592cf5516bf64da27ad1ec8ea308

Merge remote-tracking branch 'origin/master'

 dao/src/main/java/com/sandu/ximon/dao/domain/AirData.java

@@ -1,39 +1,141 @@
package com.sandu.ximon.dao.domain;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import lombok.Data;

import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;

/**
 * 
 * @TableName air_data
 */
@TableName(value ="air_data")
@Data
public class AirData implements Serializable {
    /**
     * 
     */
    @TableId(type = IdType.AUTO)
    private Long id;

    //所属灯杆
    private String belongTo;
    //接入时间
    /**
     * è®¾å¤‡mac
     */
    private String deviceMac;

    /**
     * è®¾å¤‡åž‹å·
     */
    private String deviceType;

    /**
     * æ¨¡å—预热状态标志
     */
    private String moduleWarmUpStatusFlag;

    /**
     * æ¸©åº¦å€¼
     */
    private Double temperature;

    /**
     * æ¹¿åº¦å€¼
     */
    private Double humidity;

    /**
     * é£Žé€Ÿ
     */
    private Double windSpeed;

    /**
     * é£Žå‘
     */
    private Double windDirection;

    /**
     * å¤§æ°”压
     */
    private Integer pressure;

    /**
     * å…‰å¼º
     */
    private Integer lightIntensity;

    /**
     * å™ªéŸ³
     */
    private Integer noise;

    /**
     * PM2.5
     */
    private Integer pm25;

    /**
     *  PM10
     */
    private Integer pm10;

    /**
     * æ€»æ‚¬æµ®é¢—粒物（TSP）
     */
    private Integer tsp;

    /**
     * SO2二氧化硫相对值
     */
    private Integer so2;

    /**
     * ç”²é†›ç›¸å¯¹å€¼
     */
    private Integer ech2o;

    /**
     * NO2二氧化氮
     */
    private Integer no2;

    /**
     * TVOC
     */
    private Integer tvoc;

    /**
     * CO一氧化碳
     */
    private Integer co;

    /**
     * äºŒæ°§åŒ–碳
     */
    private Integer co2;

    /**
     * O3臭氧
     */
    private Integer o3;

    /**
     * F氟化物
     */
    private Integer fluoride;

    /**
     * 
     */
    private LocalDateTime createTime;
    //温度
    private String temperature;
    //湿度
    private String humidity;
    //PM2.5
    private String PM25;
    //亮度
    private int brightness;
    //PM10
    private String PM10;
    //甲醛
    private String formaldehyde;
    //二氧化碳CO2
    private String CO2;
    //室内有机气态物质
    private int tVoc;
    //风速
    private String windSpeed;
    //上报时间

    /**
     * 
     */
    private LocalDateTime updateTime;
}

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

 dao/src/main/java/com/sandu/ximon/dao/domain/LightTask.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,76 @@
package com.sandu.ximon.dao.domain;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;

/**
 * è·¯ç¯ä»»åŠ¡è¡¨
 * @TableName light_task
 */
@TableName(value ="light_task")
@Data
public class LightTask implements Serializable {
    /**
     * 
     */
    @TableId(type = IdType.AUTO)
    private Long taskId;

    /**
     * å®¢æˆ·id
     */
    private Long clientId;

    /**
     * ä»»åŠ¡åç§°
     */
    private String taskName;

    /**
     * 1暂停、0启用
     */
    private Integer pause;

    /**
     * æ˜ŸæœŸå‡ ï¼Œä½è¿ç®—保存，1代表星期一，2星期二，4星期三，8星期四，16星期五，32星期六，64星期日
     */
    private Integer week;

    /**
     * å¼€ç¯å‘½ä»¤
     */
    private String openOrder;

    /**
     * å…³é—­ç¯å‘½ä»¤
     */
    private String closeOrder;

    /**
     * ç¯æŽ§å‘½ä»¤
     */
    private String controlOrder;

    /**
     * åˆ›å»ºç”¨æˆ·
     */
    private String createUser;

    /**
     * åˆ›å»ºæ—¶é—´
     */
    private LocalDateTime createTime;

    /**
     * 
     */
    private LocalDateTime updateTime;

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

 dao/src/main/java/com/sandu/ximon/dao/domain/LightTaskPoleRelation.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,46 @@
package com.sandu.ximon.dao.domain;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;

/**
 * è·¯ç¯ä»»åŠ¡å’Œç¯æ†å…³ç³»è¡¨
 * @TableName light_task_pole_relation
 */
@TableName(value ="light_task_pole_relation")
@Data
public class LightTaskPoleRelation implements Serializable {
    /**
     * 
     */
    @TableId(type = IdType.AUTO)
    private Long id;

    /**
     * ä»»åŠ¡id
     */
    private Long taskId;

    /**
     * ç¯æ†id
     */
    private Long poleId;

    /**
     * åˆ›å»ºæ—¶é—´
     */
    private LocalDateTime createTime;

    /**
     * 
     */
    private LocalDateTime updateTime;

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

 dao/src/main/java/com/sandu/ximon/dao/domain/LightTaskQuartz.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package com.sandu.ximon.dao.domain;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;

/**
 * è·¯ç¯ä»»åŠ¡å®šæ—¶å™¨è¡¨
 * @TableName light_task_quartz
 */
@TableName(value ="light_task_quartz")
@Data
public class LightTaskQuartz implements Serializable {
    /**
     * 
     */
    @TableId(type = IdType.AUTO)
    private Long id;

    /**
     * ä»»åŠ¡id
     */
    private Long taskId;

    /**
     * å®šæ—¶å™¨åç§°
     */
    private String quartzName;

    /**
     * å®šæ—¶å™¨cron
     */
    private String cronExpression;

    /**
     * 1暂停、0启用
     */
    private Integer pause;

    /**
     * å®šæ—¶å™¨å‘½ä»¤å¸§
     */
    private String framePayload;

    /**
     * åˆ›å»ºæ—¶é—´
     */
    private LocalDateTime createTime;

    /**
     * 
     */
    private LocalDateTime updateTime;

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

 dao/src/main/java/com/sandu/ximon/dao/domain/LightTaskQuartzLog.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,66 @@
package com.sandu.ximon.dao.domain;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;

/**
 * è·¯ç¯ä»»åŠ¡å®šæ—¶å™¨æ‰§è¡Œæ—¥å¿—表
 * @TableName light_task_quartz_log
 */
@TableName(value ="light_task_quartz_log")
@Data
public class LightTaskQuartzLog implements Serializable {
    /**
     * 
     */
    @TableId(type = IdType.AUTO)
    private Long id;

    /**
     * ä»»åŠ¡id
     */
    private Long taskId;

    /**
     * å®šæ—¶å™¨id
     */
    private Long quartzId;

    /**
     * ä»»åŠ¡åç§°
     */
    private String taskName;

    /**
     * å®šæ—¶å™¨cron
     */
    private String cronExpression;

    /**
     * å¸§è´Ÿè·
     */
    private String framePayload;

    /**
     * è¯·æ±‚时间
     */
    private Long time;

    /**
     * é”™è¯¯æ—¥å¿—
     */
    private String exceptionDetail;

    /**
     * åˆ›å»ºæ—¶é—´
     */
    private LocalDateTime createTime;

    @TableField(exist = false)
    private static final long serialVersionUID = 1L;
}

 dao/src/main/java/com/sandu/ximon/dao/enums/WeekEnums.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,52 @@
package com.sandu.ximon.dao.enums;

/**
 * æ˜ŸæœŸæžšä¸¾ç±»
 *
 * @author chenjiantian
 */
public enum WeekEnums {

    /**
     * TUESDAY
     */
    MONDAY(1),
    /**
     * TUESDAY
     */
    TUESDAY(2),
    /**
     * WEDNESDAY
     */
    WEDNESDAY(4),
    /**
     * THURSDAY
     */
    THURSDAY(8),
    /**
     * FRIDAY
     */
    FRIDAY(16),
    /**
     * SATURDAY
     */
    SATURDAY(32),
    /**
     * SUNDAY
     */
    SUNDAY(64),
    ;

    private final Integer code;

    WeekEnums(Integer code) {
        this.code = code;
    }


    public Integer getCode() {
        return code;
    }


}

 dao/src/main/java/com/sandu/ximon/dao/mapper/AirDataMapper.java

@@ -1,10 +1,21 @@
package com.sandu.ximon.dao.mapper;

import com.sandu.common.domain.BaseMapper;
import com.sandu.ximon.dao.domain.AirData;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.sandu.ximon.dao.domain.Monitor;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

/**
 * @Entity com.sandu.ximon.dao.domain.AirData
 */
@Mapper
public interface AirDataMapper extends BaseMapper<AirData> {
    List<String> listAirEquipmentMAC();

}





 dao/src/main/java/com/sandu/ximon/dao/mapper/LightTaskMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.sandu.ximon.dao.mapper;

import com.sandu.ximon.dao.domain.LightTask;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Entity com.sandu.ximon.dao.domain.LightTask
 */
@Mapper
public interface LightTaskMapper extends BaseMapper<LightTask> {

}





 dao/src/main/java/com/sandu/ximon/dao/mapper/LightTaskPoleRelationMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.sandu.ximon.dao.mapper;

import com.sandu.ximon.dao.domain.LightTaskPoleRelation;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Entity com.sandu.ximon.dao.domain.LightTaskPoleRelation
 */
@Mapper
public interface LightTaskPoleRelationMapper extends BaseMapper<LightTaskPoleRelation> {

}





 dao/src/main/java/com/sandu/ximon/dao/mapper/LightTaskQuartzLogMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.sandu.ximon.dao.mapper;

import com.sandu.ximon.dao.domain.LightTaskQuartzLog;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Entity com.sandu.ximon.dao.domain.LightTaskQuartzLog
 */
@Mapper
public interface LightTaskQuartzLogMapper extends BaseMapper<LightTaskQuartzLog> {

}





 dao/src/main/java/com/sandu/ximon/dao/mapper/LightTaskQuartzMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.sandu.ximon.dao.mapper;

import com.sandu.ximon.dao.domain.LightTaskQuartz;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;

/**
 * @Entity com.sandu.ximon.dao.domain.LightTaskQuartz
 */
@Mapper
public interface LightTaskQuartzMapper extends BaseMapper<LightTaskQuartz> {

}





 dao/src/main/resources/mapper/AirDataMapper.xml

@@ -6,18 +6,36 @@

    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.AirData">
        <id property="id" column="id" jdbcType="BIGINT"/>
        <result property="belongTo" column="belong_to" jdbcType="VARCHAR"/>
        <result property="deviceMac" column="device_mac" jdbcType="VARCHAR"/>
        <result property="deviceType" column="device_type" jdbcType="VARCHAR"/>
        <result property="moduleWarmUpStatusFlag" column="module_warm_up_status_flag" jdbcType="VARCHAR"/>
        <result property="temperature" column="temperature" jdbcType="DOUBLE"/>
        <result property="humidity" column="humidity" jdbcType="DOUBLE"/>
        <result property="windSpeed" column="wind_speed" jdbcType="DOUBLE"/>
        <result property="windDirection" column="wind_direction" jdbcType="DOUBLE"/>
        <result property="pressure" column="pressure" jdbcType="INTEGER"/>
        <result property="lightIntensity" column="light_intensity" jdbcType="INTEGER"/>
        <result property="noise" column="noise" jdbcType="INTEGER"/>
        <result property="pm25" column="pm25" jdbcType="INTEGER"/>
        <result property="pm10" column="pm10" jdbcType="INTEGER"/>
        <result property="tsp" column="tsp" jdbcType="INTEGER"/>
        <result property="so2" column="so2" jdbcType="INTEGER"/>
        <result property="ech2o" column="ech2o" jdbcType="INTEGER"/>
        <result property="no2" column="no2" jdbcType="INTEGER"/>
        <result property="tvoc" column="tvoc" jdbcType="INTEGER"/>
        <result property="co" column="co" jdbcType="INTEGER"/>
        <result property="co2" column="co2" jdbcType="INTEGER"/>
        <result property="o3" column="o3" jdbcType="INTEGER"/>
        <result property="fluoride" column="fluoride" jdbcType="INTEGER"/>
        <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
        <result property="temperature" column="temperature" jdbcType="VARCHAR"/>
        <result property="humidity" column="humidity" jdbcType="VARCHAR"/>
        <result property="PM25" column="p_m25" jdbcType="VARCHAR"/>
        <result property="brightness" column="brightness" jdbcType="INTEGER"/>
        <result property="PM10" column="p_m10" jdbcType="VARCHAR"/>
        <result property="formaldehyde" column="formaldehyde" jdbcType="VARCHAR"/>
        <result property="CO2" column="c_o2" jdbcType="VARCHAR"/>
        <result property="tVoc" column="t_voc" jdbcType="INTEGER"/>
        <result property="windSpeed" column="wind_speed" jdbcType="VARCHAR"/>
        <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
    </resultMap>

    <select id="listAirEquipmentMAC" resultType="java.lang.String">
            SELECT DISTINCT
            device_mac
            FROM
             air_data
    </select>

</mapper>

 dao/src/main/resources/mapper/LightTaskMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sandu.ximon.dao.mapper.LightTaskMapper">

    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.LightTask">
            <id property="taskId" column="task_id" jdbcType="BIGINT"/>
            <result property="clientId" column="client_id" jdbcType="BIGINT"/>
            <result property="taskName" column="task_name" jdbcType="VARCHAR"/>
            <result property="pause" column="pause" jdbcType="TINYINT"/>
            <result property="week" column="week" jdbcType="TINYINT"/>
            <result property="openOrder" column="open_order" jdbcType="VARCHAR"/>
            <result property="closeOrder" column="close_order" jdbcType="VARCHAR"/>
            <result property="controlOrder" column="control_order" jdbcType="VARCHAR"/>
            <result property="createUser" column="create_user" jdbcType="VARCHAR"/>
            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
    </resultMap>

    <sql id="Base_Column_List">
        task_id,client_id,task_name,
        pause,week,open_order,
        close_order,control_order,create_user,
        create_time,update_time
    </sql>
</mapper>

 dao/src/main/resources/mapper/LightTaskPoleRelationMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sandu.ximon.dao.mapper.LightTaskPoleRelationMapper">

    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.LightTaskPoleRelation">
            <id property="id" column="id" jdbcType="BIGINT"/>
            <result property="taskId" column="task_id" jdbcType="BIGINT"/>
            <result property="poleId" column="pole_id" jdbcType="BIGINT"/>
            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
    </resultMap>

    <sql id="Base_Column_List">
        id,task_id,pole_id,
        create_time,update_time
    </sql>
</mapper>

 dao/src/main/resources/mapper/LightTaskQuartzLogMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sandu.ximon.dao.mapper.LightTaskQuartzLogMapper">

    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.LightTaskQuartzLog">
            <id property="id" column="id" jdbcType="BIGINT"/>
            <result property="taskId" column="task_id" jdbcType="BIGINT"/>
            <result property="quartzId" column="quartz_id" jdbcType="BIGINT"/>
            <result property="taskName" column="task_name" jdbcType="VARCHAR"/>
            <result property="cronExpression" column="cron_expression" jdbcType="VARCHAR"/>
            <result property="framePayload" column="frame_payload" jdbcType="VARCHAR"/>
            <result property="time" column="time" jdbcType="BIGINT"/>
            <result property="exceptionDetail" column="exception_detail" jdbcType="VARCHAR"/>
            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
    </resultMap>

    <sql id="Base_Column_List">
        id,task_id,quartz_id,
        task_name,cron_expression,frame_payload,
        time,exception_detail,create_time
    </sql>
</mapper>

 dao/src/main/resources/mapper/LightTaskQuartzMapper.xml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.sandu.ximon.dao.mapper.LightTaskQuartzMapper">

    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.LightTaskQuartz">
            <id property="id" column="id" jdbcType="BIGINT"/>
            <result property="taskId" column="task_id" jdbcType="BIGINT"/>
            <result property="quartzName" column="quartz_name" jdbcType="VARCHAR"/>
            <result property="cronExpression" column="cron_expression" jdbcType="VARCHAR"/>
            <result property="pause" column="pause" jdbcType="TINYINT"/>
            <result property="framePayload" column="frame_payload" jdbcType="VARCHAR"/>
            <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
            <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
    </resultMap>

    <sql id="Base_Column_List">
        id,task_id,quartz_name,
        cron_expression,pause,frame_payload,
        create_time,update_time
    </sql>
</mapper>

 sandu-common/src/main/java/com/sandu/common/enums/ResponseStatusEnums.java

@@ -2,33 +2,35 @@

/**
 * @author yadong.zhang (yadong.zhang0415(a)gmail.com)
 * @website https://www.zhyd.me
 * @version 1.0
 * @website https://www.zhyd.me
 * @date 2018/4/16 16:26
 * @since 1.0
 */
public enum ResponseStatusEnums {
    /** æ“ä½œæˆåŠŸ*/
    /**
     * æ“ä½œæˆåŠŸ
     */
    SUCCESS(20000, "success"),
    FAIL(40000, "fail"),

    BAD_CREDENTIALS(40001, "用户名或密码不正确"),
    DISABLE_ACCOUNT(40002, "该账号已被禁止使用"),
    /** token ç›¸å…³ */
    TOKEN_INVALID(40011, "token失效"),
    /**
     * token ç›¸å…³
     */
    TOKEN_INVALID(40011, "token无效"),
    TOKEN_EXPIRED(40012, "token过期"),
    TOKEN_NONE(40013, "token为空"),
    SINGLE_LOGIN(40014, "该账号在其他设备登录,请重新登录"),
    TENANT_NONE(40015, "租户id为空"),
    TENANT_ERROR(40016, "租户值出错"),
    TENANT_EXPIRED(40017, "租户会员已过期"),

    FORBIDDEN(40030, "没有相关权限"),

    WECHAT_LOGIN_UNREGISTERED(40041, "该三方账号未注册，请到注册界面"),
    WECHAT_LOGIN_SET_PASSWORD(40042, "手机为首次登录，请设置登录密码"),

    /** æœåŠ¡å™¨å¼‚常 */
    /**
     * æœåŠ¡å™¨å¼‚常
     */
    SERVER_ERROR(50000, "api接口出错"),
    ;


 sandu-common/src/main/java/com/sandu/common/quartz/ExecutionJob.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.sandu.common.quartz;

import org.quartz.JobExecutionContext;
import org.springframework.scheduling.quartz.QuartzJobBean;

/**
 * @author chenjiantian
 * @date 2021/12/15 10:28
 */
public class ExecutionJob extends QuartzJobBean {

    @Override
    protected void executeInternal(JobExecutionContext context) {
        System.out.println("执行任务");
        System.out.println(Thread.currentThread().toString());
    }
}

 sandu-common/src/main/java/com/sandu/common/quartz/config/QuartzConfig.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,59 @@
package com.sandu.common.quartz.config;

import com.sandu.common.quartz.service.QuartzService;
import org.quartz.Scheduler;
import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.AdaptableJobFactory;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Component;

/**
 * @author chenjiantian
 * @date 2021/12/15 10:48
 */
@Configuration
@ConditionalOnClass(QuartzService.class)
public class QuartzConfig {

    /**
     * è§£å†³Job中注入Spring Bean为null的问题
     */
    @Component("quartzJobFactory")
    public static class QuartzJobFactory extends AdaptableJobFactory {

        private final AutowireCapableBeanFactory capableBeanFactory;

        public QuartzJobFactory(AutowireCapableBeanFactory capableBeanFactory) {
            this.capableBeanFactory = capableBeanFactory;
        }

        @Override
        protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {

            //调用父类的方法
            Object jobInstance = super.createJobInstance(bundle);
            capableBeanFactory.autowireBean(jobInstance);
            return jobInstance;
        }
    }

    /**
     * æ³¨å…¥scheduler到spring
     * @param quartzJobFactory /
     * @return Scheduler
     * @throws Exception /
     */
    @Bean(name = "scheduler")
    public Scheduler scheduler(QuartzJobFactory quartzJobFactory) throws Exception {
        SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
        factoryBean.setJobFactory(quartzJobFactory);
        factoryBean.afterPropertiesSet();
        Scheduler scheduler = factoryBean.getScheduler();
        scheduler.start();
        return scheduler;
    }
}

 sandu-common/src/main/java/com/sandu/common/quartz/service/QuartzService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,68 @@
package com.sandu.common.quartz.service;

import org.springframework.scheduling.quartz.QuartzJobBean;

import java.util.Map;

/**
 * @author chenjiantian
 * @date 2021/12/15 10:36
 */
public interface QuartzService {

    /**
     * å¢žåŠ ä¸€ä¸ªä»»åŠ¡job
     *
     * @param jobClass å®žçŽ°çš„任务类
     * @param jobId    ä»»åŠ¡å”¯ä¸€id
     * @param cron     cron表达式
     * @param jobData  å‚æ•°
     */
    void addJob(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData);

    /**
     * ä¿®æ”¹ä¸€ä¸ªä»»åŠ¡job
     *
     * @param jobClass å®žçŽ°çš„任务类
     * @param jobId    ä»»åŠ¡å”¯ä¸€id
     * @param cron     cron表达式
     * @param jobData  å‚æ•°
     */
    void updateJobCron(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData);

    /**
     * åˆ é™¤ä¸€ä¸ªä»»åŠ¡job
     *
     * @param jobClass å®žçŽ°çš„任务类
     * @param jobId    å®šæ—¶ä»»åŠ¡id
     */
    void deleteJob(Class<? extends QuartzJobBean> jobClass, Long jobId);

    /**
     * æš‚停一个任务job
     *
     * @param jobClass å®žçŽ°çš„任务类
     * @param jobId    å®šæ—¶ä»»åŠ¡id
     */
    void pauseJob(Class<? extends QuartzJobBean> jobClass, Long jobId);

    /**
     * æ¢å¤ä¸€ä¸ªä»»åŠ¡job
     *
     * @param jobClass å®žçŽ°çš„任务类
     * @param jobId    ä»»åŠ¡å”¯ä¸€id
     * @param cron     cron表达式
     * @param jobData  å‚æ•°
     */
    void resumeJob(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData);

    /**
     * ç«‹å³æ‰§è¡Œä¸€ä¸ªä»»åŠ¡job
     *
     * @param jobClass å®žçŽ°çš„任务类
     * @param jobId    ä»»åŠ¡å”¯ä¸€id
     * @param cron     cron表达式
     * @param jobData  å‚æ•°
     */
    void runJobNow(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData);
}

 sandu-common/src/main/java/com/sandu/common/quartz/service/QuartzServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,130 @@
package com.sandu.common.quartz.service;

import com.sandu.common.execption.BusinessException;
import lombok.extern.slf4j.Slf4j;
import org.quartz.*;
import org.quartz.impl.triggers.CronTriggerImpl;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;
import java.util.Map;

/**
 * @author chenjiantian
 * @date 2021/12/15 10:39
 * quartz job管理类
 */
@Slf4j
@Service
@ConditionalOnProperty(prefix = "sandu.quartz", name = "enable", havingValue = "true")
public class QuartzServiceImpl implements QuartzService {

    @Resource(name = "scheduler")
    private Scheduler scheduler;

    @Override
    public void addJob(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData) {
        try {
            String simpleName = jobClass.getSimpleName();
            JobDetail jobDetail = JobBuilder.newJob(jobClass)
                    .withIdentity(simpleName + jobId)
                    .build();
            CronTrigger cronTrigger = TriggerBuilder.newTrigger()
                    .withIdentity(simpleName + jobId)
                    .startNow()
                    .withSchedule(CronScheduleBuilder.cronSchedule(cron))
                    .build();
            cronTrigger.getJobDataMap().putAll(jobData);
            ((CronTriggerImpl) cronTrigger).setStartTime(new Date());
            scheduler.scheduleJob(jobDetail, cronTrigger);

            log.info("添加定时器{}", simpleName + jobId);
        } catch (SchedulerException e) {
            log.error("创建定时任务失败", e);
            throw new BusinessException("创建定时任务失败");
        }
    }

    @Override
    public void updateJobCron(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData) {
        try {
            TriggerKey triggerKey = TriggerKey.triggerKey(jobClass.getSimpleName() + jobId);
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            if (trigger == null) {
                addJob(jobClass, jobId, cron, jobData);
                trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            }
            CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron);
            trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
            trigger.getJobDataMap().putAll(jobData);

            scheduler.rescheduleJob(triggerKey, trigger);
        } catch (SchedulerException e) {
            log.error("更新定时任务失败", e);
            throw new BusinessException("更新定时任务失败");
        }
    }

    @Override
    public void deleteJob(Class<? extends QuartzJobBean> jobClass, Long jobId) {
        try {
            JobKey jobKey = JobKey.jobKey(jobClass.getSimpleName() + jobId);
            scheduler.pauseJob(jobKey);
            scheduler.deleteJob(jobKey);
            log.info("删除定时器{}", jobClass.getSimpleName() + jobId);
        } catch (SchedulerException e) {
            log.error("删除定时任务失败", e);
            throw new BusinessException("删除定时任务失败");
        }
    }

    @Override
    public void pauseJob(Class<? extends QuartzJobBean> jobClass, Long jobId) {
        try {
            JobKey jobKey = JobKey.jobKey(jobClass.getSimpleName() + jobId);
            scheduler.pauseJob(jobKey);
        } catch (Exception e) {
            log.error("定时任务暂停失败", e);
            throw new BusinessException("定时任务暂停失败");
        }
    }

    @Override
    public void resumeJob(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData) {
        try {
            TriggerKey triggerKey = TriggerKey.triggerKey(jobClass.getSimpleName() + jobId);
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            // å¦‚果不存在则创建一个定时任务
            if (trigger == null) {
                addJob(jobClass, jobId, cron, jobData);
            }
            JobKey jobKey = JobKey.jobKey(jobClass.getSimpleName() + jobId);
            scheduler.resumeJob(jobKey);
        } catch (Exception e) {
            log.error("恢复定时任务失败", e);
            throw new BusinessException("恢复定时任务失败");
        }
    }

    @Override
    public void runJobNow(Class<? extends QuartzJobBean> jobClass, Long jobId, String cron, Map<String, Object> jobData) {
        try {
            TriggerKey triggerKey = TriggerKey.triggerKey(jobClass.getSimpleName() + jobId);
            CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
            // å¦‚果不存在则创建一个定时任务
            if (trigger == null) {
                addJob(jobClass, jobId, cron, jobData);
            }
            JobDataMap dataMap = new JobDataMap();
            dataMap.putAll(jobData);
            JobKey jobKey = JobKey.jobKey(jobClass.getSimpleName() + jobId);
            scheduler.triggerJob(jobKey, dataMap);
        } catch (Exception e) {
            log.error("定时任务执行失败", e);
            throw new BusinessException("定时任务执行失败");
        }
    }
}

 sandu-common/src/main/java/com/sandu/common/security/JwtAuthenticationEntryPoint.java

@@ -37,7 +37,7 @@
        SecurityProperties properties = SpringContextHolder.getBean(SecurityProperties.class);

        if (!StringUtils.hasText(token)) {
            writeResponse(response, ResponseUtil.error(ResponseStatusEnums.TOKEN_NONE.getCode(), ResponseStatusEnums.TOKEN_NONE.getMessage()));
            writeResponse(response, ResponseUtil.error(ResponseStatusEnums.TOKEN_INVALID.getCode(), ResponseStatusEnums.TOKEN_INVALID.getMessage()));
            return;
        }


 sandu-common/src/main/resources/application.yml

@@ -6,3 +6,4 @@
    active: dev
#    active: "@profileActive@"



 ximon-admin/src/main/java/com/sandu/ximon/admin/config/JobRunner.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package com.sandu.ximon.admin.config;

import com.sandu.ximon.admin.service.LightTaskQuartzService;
import com.sandu.ximon.dao.domain.LightTaskQuartz;
import lombok.AllArgsConstructor;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * @author chenjiantian
 * @date 2021/12/16 11:55
 */
@AllArgsConstructor
@Component
public class JobRunner implements ApplicationRunner {

    private final LightTaskQuartzService lightTaskQuartzService;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        System.out.println("--------------------注入路灯定时任务---------------------");
        List<LightTaskQuartz> list = lightTaskQuartzService.list();
        lightTaskQuartzService.runLightTaskQuartz(list);
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/constant/Constants.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,11 @@
package com.sandu.ximon.admin.constant;

/**
 * @author chenjiantian
 * @date 2021/12/16 11:42
 */
public class Constants {

    // ç¯å®šæ—¶å‘½ä»¤é•¿åº¦
    public final static int LIGHT_TIMER_ORDER_LENGTH = 8;
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/AdminController.java

@@ -48,7 +48,7 @@
@Slf4j
@RestController
@AllArgsConstructor
@RequestMapping("v1/admin")
@RequestMapping("/v1/admin")
public class AdminController {

    private final SecurityProperties properties;

 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/AirDataController.java

@@ -25,13 +25,12 @@
    }

    /**
     * æ¨¡ç³ŠæŸ¥è¯¢
     *
     * æŸ¥è¯¢å¤§æ°”设备MAC地址
     * @return
     */
    @GetMapping("/listAirDataByKeyword/{keyword}")
    public ResponseVO<Object> listAirDataByKeyword(@PathVariable String keyword) {
        List<AirData> list = airDataService.listAirDataByKeyword(keyword);
    @GetMapping("/listAirEquipmentMAC")
    public ResponseVO<Object> listAirEquipmentMAC() {
        List<String> list = airDataService.listAirEquipmentMAC();
        return ResponseUtil.successPage(list);
    }


 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/LightController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,39 @@
package com.sandu.ximon.admin.controller;

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.domain.ResponseVO;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.util.ResponseUtil;
import com.sandu.ximon.admin.dto.LightDataDto;
import com.sandu.ximon.admin.service.LightReportDataService;
import com.sandu.ximon.dao.domain.Pole;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * è·¯ç¯ç›¸å…³æŽ§åˆ¶ç±»
 *
 * @author chenjiantian
 */
@RestController
@AllArgsConstructor
@RequestMapping("/v1/light")
public class LightController {

    private final LightReportDataService lightReportDataService;


    @GetMapping("/list")
    public ResponseVO<Object> listLight(BaseConditionVO conditionVO, @RequestParam(required = false) String keyword) {
        List<LightDataDto> list = lightReportDataService.listLight(conditionVO.getPageNo(),conditionVO.getPageSize(),keyword);
        return ResponseUtil.success(list);
    }

}

 ximon-admin/src/main/java/com/sandu/ximon/admin/controller/LightTaskController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
package com.sandu.ximon.admin.controller;

import com.sandu.common.domain.ResponseVO;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.util.ResponseUtil;
import com.sandu.ximon.admin.param.LightTaskDelParam;
import com.sandu.ximon.admin.param.LightTaskParam;
import com.sandu.ximon.admin.service.LightTaskService;
import com.sandu.ximon.dao.domain.LightTask;
import lombok.AllArgsConstructor;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import java.util.List;

/**
 * è·¯ç¯ä»»åŠ¡ç›¸å…³æŽ§åˆ¶ç±»
 *
 * @author chenjiantian
 */
@RestController
@AllArgsConstructor
@RequestMapping("/v1/light/task")
public class LightTaskController {

    private final LightTaskService lightTaskService;


    @PostMapping("/add")
    public ResponseVO<Object> addLightTask(@RequestBody @Validated LightTaskParam param) {
        boolean result = lightTaskService.addLightTask(param);
        if (result) {
            return ResponseUtil.success("新增成功");
        } else {
            return ResponseUtil.fail("新增失败");
        }
    }

    @GetMapping("/list")
    public ResponseVO<Object> listLightTask(BaseConditionVO conditionVO, @RequestParam(required = false) String keyword) {
        List<LightTask> taskList = lightTaskService.listLightTask(conditionVO.getPageNo(), conditionVO.getPageSize(), keyword);
        return ResponseUtil.successPage(taskList);
    }

    @PostMapping("/del")
    public ResponseVO<Object> delLightTask(@RequestBody @Validated LightTaskDelParam param) {
        boolean result = lightTaskService.delLightTask(param.getTaskIdList());
        if (result) {
            return ResponseUtil.success("删除成功");
        } else {
            return ResponseUtil.fail("删除失败");
        }
    }

    @PostMapping("/update/{taskId}")
    public ResponseVO<Object> updateLightTask(@PathVariable Long taskId, @RequestBody @Validated LightTaskParam param) {
        boolean result = lightTaskService.updateLightTask(taskId,param);
        if (result) {
            return ResponseUtil.success("编辑成功");
        } else {
            return ResponseUtil.fail("编辑失败");
        }
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/dto/LightDataDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,11 @@
package com.sandu.ximon.admin.dto;

import lombok.Data;

/**
 * @author chenjiantian
 * @date 2021/12/14 14:36
 */
@Data
public class LightDataDto {
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/dto/SingleLightOrderDto.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.sandu.ximon.admin.dto;

import lombok.Data;

/**
 * @author chenjiantian
 * @date 2021/12/15 18:07
 * å•ä¸ªè·¯ç¯ä»»åŠ¡å‘½ä»¤çš„内容
 */
@Data
public class SingleLightOrderDto {

    private int hour;
    private int minute;
    /**
     * 0-100
     */
    private int brightness;
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/AmqpMessageListener.java

@@ -1,6 +1,7 @@
package com.sandu.ximon.admin.manager.iot.amqp;

import com.alibaba.fastjson.JSON;
import com.sandu.ximon.admin.manager.iot.amqp.processor.AirDataProcessor;
import com.sandu.ximon.admin.manager.iot.amqp.processor.LightDataProcessor;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.*;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
@@ -93,13 +94,14 @@
        log.info(frame.toString());
        if (frame.getOrderType().equals(A5OrderEnum.RESPONSE_LIGHT_DATA.getCode())) {
            // å•ç¯æ•°æ®ä¸ŠæŠ¥å¤„理
            LightDataProcessor.getInstance().process(productKey,deviceName,frame);
            LightDataProcessor.getInstance().process(productKey, deviceName, frame);
        } else if (frame.getOrderType().equals(A5OrderEnum.RESPONSE_C3_DATA.getCode())) {
            // C3充电桩上报处理
            c3ChargingReportAnalysis(productKey, deviceName, frame);
        } else if (frame.getOrderType().equals(A5OrderEnum.RESPONSE_ATMOSPHERE_DATA.getCode())) {
            // å¤§æ°”数据指令上报
            atmosphereAnalysis(productKey, deviceName, frame);
            AirDataProcessor.getInstance().process(productKey, deviceName, frame);
//            atmosphereAnalysis(productKey, deviceName, frame);
        }
    }


 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/processor/AirDataProcessor.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,44 @@
package com.sandu.ximon.admin.manager.iot.amqp.processor;

import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5AtmosphereHeartbeatReportInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.CommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5AtmosphereReportEnum;
import com.sandu.ximon.admin.service.AirDataService;
import lombok.extern.slf4j.Slf4j;

/**
 * @author ZZQ
 * @date 2021/12/14
 * å¤§æ°”数据上报处理
 */
@Slf4j
public class AirDataProcessor implements IMessageProcessor {

    private AirDataProcessor() {
    }

    public static AirDataProcessor getInstance() {
        return AirDataProcessor.AirDataProcessorHolder.INSTANCE;
    }

    private static class AirDataProcessorHolder {

        private static final AirDataProcessor INSTANCE = new AirDataProcessor();
    }

    @Override
    public void process(String productKey, String deviceName, CommonFrame frame) {
        String functionCode = frame.getPayload().substring(2, 4);
        if (A5AtmosphereReportEnum.HeartBeat_Data.getCode().equals(functionCode)) {
            log.info("心跳相应");
            A5AtmosphereHeartbeatReportInnerFrame heartbeatReportInnerFrame = new A5AtmosphereHeartbeatReportInnerFrame().transformFrame(frame.getPayload());
            log.info(heartbeatReportInnerFrame.toString());

            SpringContextHolder.getBean(AirDataService.class).saveReportData(deviceName, heartbeatReportInnerFrame.getHeartBeatDataPackage());

//            SpringContextHolder.getBean(LightService.class).saveLight(deviceName,heartbeatReportInnerFrame.getHeartBeatDataPackage());

        }
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/frame/inner/request/A5LightTimerReqInnerFrame.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,41 @@
package com.sandu.ximon.admin.manager.iot.frame.inner.request;

import cn.hutool.core.util.HexUtil;
import com.sandu.ximon.admin.dto.SingleLightOrderDto;
import com.sandu.ximon.admin.manager.iot.frame.inner.IRequestInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5LightDataEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.MQTTConnectTypeEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.util.CRC32Utils;
import com.sandu.ximon.admin.manager.iot.rrpc.util.SupplementUtils;

/**
 * @author chenjiantian
 * @date 2021/12/6 14:46
 * A5->01->23
 * å®šæ—¶æŽ§ç¯
 * 0x00：关灯
 * å…¶å®ƒï¼šå¼€ç¯&亮度值"
 */
public class A5LightTimerReqInnerFrame implements IRequestInnerFrame {

    private final String payload;
    private final String functionCode = A5LightDataEnum.LightTimer.getCode();
    private final String payloadLength;

    /**
     * @param framePayload å¤šä¸ªè·¯ç¯å®šæ—¶æŒ‡ä»¤ï¼Œ
     */
    public A5LightTimerReqInnerFrame(String framePayload) {
        String destinationAddress = "FFFF";
        payload = destinationAddress + framePayload;
        this.payloadLength = SupplementUtils.suppleZero(Integer.toHexString((payload.length() / 2)).toUpperCase(), 4);
    }

    @Override
    public String getEncodeFrame() {
        String frame = functionCode + payloadLength + payload;
        return MQTTConnectTypeEnum.SYNCHRONIZATION.getCode() + frame.toUpperCase() + CRC32Utils.getCRC32(frame.toUpperCase());
    }


}

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/frame/inner/response/A5LightTimerRespInnerFrame.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
package com.sandu.ximon.admin.manager.iot.frame.inner.response;

import cn.hutool.core.util.StrUtil;
import com.sandu.ximon.admin.manager.iot.frame.inner.BaseResponseInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.util.CRC32Utils;
import lombok.Data;
import lombok.ToString;

/**
 * @author chenjiantian
 * @date 2021/12/6 14:46
 * A5-81-23灯定时任务 åº”ç­”
 */
@Data
@ToString(callSuper = true)
public class A5LightTimerRespInnerFrame extends BaseResponseInnerFrame<A5LightTimerRespInnerFrame> {

    /**
     * ç›®æ ‡åœ°å€ 2
     */
    private String destinationAddress;
    /**
     * å“åº”状态 1
     */
    private String responseStatus;

    @Override
    public A5LightTimerRespInnerFrame transformFrame(String hex) {
        if (StrUtil.isBlank(hex)) {
            return null;
        }
        // MQTT通信方式(1)
        setConnectType(hex.substring(0, 2));
        //  åŠŸèƒ½ç (1)
        setFunctionCode(hex.substring(2, 4));
        //  è´Ÿè·é•¿åº¦(2)
        setPayloadLength(hex.substring(4, 8));

        setDestinationAddress(hex.substring(8, 12));

        setResponseStatus(hex.substring(12, 14));
        setCrc32(hex.substring(14, 22));
        //  æ ¡éªŒCRC32
        String frame = getFunctionCode() + getPayloadLength() + getDestinationAddress() + getResponseStatus();
        this.setValidate(CRC32Utils.validateFrame(frame, getCrc32()));
        return this;
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/rrpc/enums/A5LightDataEnum.java

@@ -14,6 +14,8 @@
    //  å…‰æ„ŸæŽ§åˆ¶
    LightSensorControl("04"),

    //设置定时控灯参数
    LightTimer("23"),
    // æ¸…除单灯累计数据
    LightReset("25");


 ximon-admin/src/main/java/com/sandu/ximon/admin/param/LightTaskDelParam.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
package com.sandu.ximon.admin.param;

import lombok.Data;
import org.hibernate.validator.constraints.Length;

import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;

/**
 * @author chenjiantian
 * è·¯ç¯ä»»åŠ¡
 */
@Data
public class LightTaskDelParam {

    @NotEmpty(message = "任务id不能为空")
    private List<Long> taskIdList;

}

 ximon-admin/src/main/java/com/sandu/ximon/admin/param/LightTaskParam.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,49 @@
package com.sandu.ximon.admin.param;

import lombok.Data;
import org.hibernate.validator.constraints.Length;

import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;

/**
 * @author chenjiantian
 * è·¯ç¯ä»»åŠ¡
 */
@Data
public class LightTaskParam {

    public static final int REQUEST_ORDER_LENGTH = 7;
    /**
     * ä»»åŠ¡åç§°
     */
    @NotEmpty(message = "任务名称不能为空")
    private String taskName;

    /**
     * æ˜ŸæœŸå‡ ï¼Œä½è¿ç®—保存，1代表星期一，2星期二，4星期三，8星期四，16星期五，32星期六，64星期日
     */
    @NotNull(message = "星期不能为空")
    private Integer week;


    /**
     * å¼€ç¯å‘½ä»¤
     */
    @Length(min = REQUEST_ORDER_LENGTH, max = REQUEST_ORDER_LENGTH, message = "开灯命令长度错误")
    private String openOrder;

    /**
     * å…³é—­ç¯å‘½ä»¤
     */
    @Length(min = REQUEST_ORDER_LENGTH, max = REQUEST_ORDER_LENGTH, message = "关灯命令长度错误")
    private String closeOrder;
    /**
     * ç¯æŽ§å‘½ä»¤
     */
    private String controlOrder;

    private List<Long> poleIdList;

}

 ximon-admin/src/main/java/com/sandu/ximon/admin/quartz/LightTimerJob.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,69 @@
package com.sandu.ximon.admin.quartz;

import cn.hutool.core.collection.CollectionUtil;
import com.sandu.common.util.SpringContextHolder;
import com.sandu.common.util.ThrowableUtil;
import com.sandu.ximon.admin.service.*;
import com.sandu.ximon.dao.domain.LightTaskQuartz;
import com.sandu.ximon.dao.domain.LightTaskQuartzLog;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;

import java.util.List;

/**
 * @author chenjiantian
 * @date 2021/12/15 10:28
 * è®¾ç½®å®šæ—¶æŽ§ç¯çš„定时任务
 */
public class LightTimerJob extends QuartzJobBean {

    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println("执行任务" + Thread.currentThread().toString());
        long quartzId = context.getMergedJobDataMap().getLong("quartzId");
        String taskName = context.getMergedJobDataMap().getString("taskName");
        long taskId = context.getMergedJobDataMap().getLong("taskId");
        String cron = context.getMergedJobDataMap().getString("cron");

        LightTaskQuartzLog log = new LightTaskQuartzLog();
        log.setCronExpression(cron);
        log.setTaskId(taskId);
        log.setTaskName(taskName);
        log.setQuartzId(quartzId);

        PoleService poleService = SpringContextHolder.getBean(PoleService.class);
        LightTaskPoleRelationService lightTaskPoleRelationService = SpringContextHolder.getBean(LightTaskPoleRelationService.class);
        LightTaskQuartzService lightTaskQuartzService = SpringContextHolder.getBean(LightTaskQuartzService.class);
        LightTaskService lightTaskService = SpringContextHolder.getBean(LightTaskService.class);
        LightTaskQuartzLogService lightTaskQuartzLogService = SpringContextHolder.getBean(LightTaskQuartzLogService.class);

        long startTime = System.currentTimeMillis();
        try {
            // ä»»åŠ¡ç»‘定的灯杆
            List<Long> poleIdList = lightTaskPoleRelationService.listPoleIdByTaskId(taskId);
            // ç¯æ†çš„设备码
            List<String> deviceCodeList = poleService.listDeviceCodeByIds(poleIdList);

            if (CollectionUtil.isNotEmpty(deviceCodeList)) {
                LightTaskQuartz lightTaskQuartz = lightTaskQuartzService.getById(quartzId);
                if (lightTaskQuartz != null) {
                    for (String deviceCode : deviceCodeList) {
                        // å®šæ—¶ç»™æ¯ä¸ªè®¾å¤‡å—发送灯控请求
                        lightTaskService.sendTimeRRpc(lightTaskQuartz.getFramePayload(), deviceCode);
                    }
                    log.setFramePayload(lightTaskQuartz.getFramePayload());
                }
            }
            long times = System.currentTimeMillis() - startTime;
            log.setTime(times);
        } catch (Exception e) {
            log.setExceptionDetail(ThrowableUtil.getStackTrace(e));
            long times = System.currentTimeMillis() - startTime;
            log.setTime(times);
        } finally {
            lightTaskQuartzLogService.save(log);
        }
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/AirDataService.java

@@ -4,10 +4,11 @@
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5AtmosphereHeartbeatReportInnerFrame;
import com.sandu.ximon.dao.domain.AirData;
import com.sandu.ximon.dao.domain.Monitor;
import com.sandu.ximon.dao.mapper.AirDataMapper;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import java.util.List;
@@ -15,6 +16,21 @@
@Service
@AllArgsConstructor
public class AirDataService extends BaseServiceImpl<AirDataMapper, AirData> {
    private final AirDataMapper airDataMapper;

    /**
     * ä¿å­˜ä¸ŠæŠ¥å¤§æ°”心跳数据
     *
     * @return æ˜¯å¦æˆåŠŸ
     */
    public boolean saveReportData(String deviceName, A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage heartBeatDataPackage) {

        AirData airData = new AirData();
        BeanUtils.copyProperties(heartBeatDataPackage, airData);
        airData.setDeviceMac(deviceName);

        return save(airData);
    }

    /**
     * æŸ¥è¯¢å…¨éƒ¨å¤§æ°”设备
@@ -27,16 +43,10 @@
    }

    /**
     * æ¨¡ç³ŠæŸ¥è¯¢
     * æŸ¥è¯¢å¤§æ°”设备MAC地址
     */
    public List<AirData> listAirDataByKeyword(String keyword) {

        LambdaQueryWrapper<AirData> wrapper = Wrappers.lambdaQuery(AirData.class);
        if(keyword != null){
            wrapper.like(AirData::getBelongTo,keyword);
        }
        List<AirData> airDataList = list(wrapper);
        return airDataList;
    public List<String> listAirEquipmentMAC() {
        return airDataMapper.listAirEquipmentMAC();
    }

}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightReportDataService.java

@@ -1,11 +1,15 @@
package com.sandu.ximon.admin.service;

import com.github.pagehelper.PageHelper;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.dto.LightDataDto;
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5LightHeartbeatReportInnerFrame;
import com.sandu.ximon.dao.domain.LightReportData;
import com.sandu.ximon.dao.mapper.LightReportDataMapper;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author chenjiantian
@@ -28,4 +32,14 @@

        return save(lightReportData);
    }

    /**
     * èŽ·å–路灯列表
     * @return è¿”回组合数据dto
     */
    public List<LightDataDto> listLight(int pageNo, int pageSize, String keyword) {
        PageHelper.startPage(pageNo,pageSize);

        return null;
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskPoleRelationService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,51 @@
package com.sandu.ximon.admin.service;

import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.dao.domain.LightTaskPoleRelation;
import com.sandu.ximon.dao.mapper.LightTaskPoleRelationMapper;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @author chenjiantian
 * @date 2021/12/16 14:15
 */
@Service
public class LightTaskPoleRelationService extends BaseServiceImpl<LightTaskPoleRelationMapper, LightTaskPoleRelation> {

    /**
     * æ‰¹é‡ä¿å­˜ä»»åŠ¡å’Œç¯æ†çš„关系
     *
     * @param taskId     ä»»åŠ¡id
     * @param poleIdList ç¯æ†id
     * @return è¿”回是否成功
     */
    public boolean updateLightTaskPoleRelation(Long taskId, List<Long> poleIdList) {
        remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getTaskId, taskId));
        if (CollectionUtil.isEmpty(poleIdList)) {
            return true;
        }
        List<LightTaskPoleRelation> batchSave = new ArrayList<>();
        for (Long poleId : poleIdList) {
            LightTaskPoleRelation lightTaskPoleRelation = new LightTaskPoleRelation();
            lightTaskPoleRelation.setPoleId(poleId);
            lightTaskPoleRelation.setTaskId(taskId);
            batchSave.add(lightTaskPoleRelation);
        }

        return saveBatch(batchSave);
    }

    public List<Long> listPoleIdByTaskId(Long taskId) {
        if (taskId == null) {
            return null;
        }
        return list(Wrappers.lambdaQuery(LightTaskPoleRelation.class).eq(LightTaskPoleRelation::getTaskId, taskId).select(LightTaskPoleRelation::getPoleId))
                .stream().map(LightTaskPoleRelation::getPoleId).collect(Collectors.toList());
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskQuartzLogService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,14 @@
package com.sandu.ximon.admin.service;

import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.dao.domain.LightTaskQuartzLog;
import com.sandu.ximon.dao.mapper.LightTaskQuartzLogMapper;
import org.springframework.stereotype.Service;

/**
 * @author chenjiantian
 * @date 2021/12/16 15:12
 */
@Service
public class LightTaskQuartzLogService extends BaseServiceImpl<LightTaskQuartzLogMapper,LightTaskQuartzLog> {
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskQuartzService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,169 @@
package com.sandu.ximon.admin.service;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ArrayUtil;
import cn.hutool.core.util.HexUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.quartz.ExecutionJob;
import com.sandu.common.quartz.service.QuartzService;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.constant.Constants;
import com.sandu.ximon.admin.dto.SingleLightOrderDto;
import com.sandu.ximon.admin.manager.iot.rrpc.util.SupplementUtils;
import com.sandu.ximon.admin.param.LightTaskParam;
import com.sandu.ximon.admin.quartz.LightTimerJob;
import com.sandu.ximon.admin.utils.TaskOrderUtil;
import com.sandu.ximon.dao.domain.LightTask;
import com.sandu.ximon.dao.domain.LightTaskQuartz;
import com.sandu.ximon.dao.mapper.LightTaskQuartzMapper;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * @author chenjiantian
 * @date 2021/12/15 17:46
 */
@Service
@AllArgsConstructor
public class LightTaskQuartzService extends BaseServiceImpl<LightTaskQuartzMapper, LightTaskQuartz> {

    @Resource
    private QuartzService quartzService;

    /**
     * æ·»åŠ å®šæ—¶å™¨ä»»åŠ¡
     *
     * @param lightTask è·¯ç¯ä»»åŠ¡å®žä½“类，一个路灯任务有多个定时器任务
     */
    public List<LightTaskQuartz> addLightTaskQuartz(LightTask lightTask) {
        List<LightTaskQuartz> list = buildLightTaskQuartzList(lightTask);

        boolean saveBatch = saveBatch(list);
        if (!saveBatch) {
            throw new BusinessException("保存定时任务失败");
        }

        runLightTaskQuartz(list);

        return list;
    }

    /**
     * æ ¹æ®è·¯ç¯ä»»åŠ¡ä¿¡æ¯ç”Ÿæˆè·¯ç¯å®šæ—¶å™¨åˆ—表
     * @param lightTask è·¯ç¯ä»»åŠ¡ä¿¡æ¯
     * @return è·¯ç¯å®šæ—¶å™¨åˆ—表
     */
    private List<LightTaskQuartz> buildLightTaskQuartzList(LightTask lightTask) {
        List<LightTaskQuartz> list = new ArrayList<>();

        // æ·»åŠ å¼€ç¯å®šæ—¶å™¨
        SingleLightOrderDto openLightOrder = TaskOrderUtil.parseLightOrder(lightTask.getOpenOrder());
        SingleLightOrderDto closeLightOrder = TaskOrderUtil.parseLightOrder(lightTask.getCloseOrder());
        String[] controlOrderArray = StrUtil.split(lightTask.getControlOrder(), LightTaskParam.REQUEST_ORDER_LENGTH);
        Integer[] weekArrays = TaskOrderUtil.parseLightWeek(lightTask.getWeek());
        if (openLightOrder == null || closeLightOrder == null) {
            throw new BusinessException("解析单灯命令失败");
        }
        if (ArrayUtil.isEmpty(weekArrays)) {
            throw new BusinessException("请设置星期");
        }

        StringBuilder sb = new StringBuilder();
        String weekHex = SupplementUtils.suppleZero(HexUtil.toHex(lightTask.getWeek()), 2);

        // æ‹¼æŽ¥å¼€ç¯å‘½ä»¤
        sb.append(weekHex);
        sb.append(SupplementUtils.suppleZero(HexUtil.toHex(openLightOrder.getHour()), 2));
        sb.append(SupplementUtils.suppleZero(HexUtil.toHex(openLightOrder.getMinute()), 2));
        sb.append(SupplementUtils.suppleZero(HexUtil.toHex(openLightOrder.getBrightness()), 2));

        // æ‹¼æŽ¥å…³ç¯å‘½ä»¤
        sb.append(weekHex);
        sb.append(SupplementUtils.suppleZero(HexUtil.toHex(closeLightOrder.getHour()), 2));
        sb.append(SupplementUtils.suppleZero(HexUtil.toHex(closeLightOrder.getMinute()), 2));
        sb.append(SupplementUtils.suppleZero(HexUtil.toHex(closeLightOrder.getBrightness()), 2));

        // æ–°å¢žå¼€ç¯å®šæ—¶å™¨
        LightTaskQuartz openLightTaskQuartz = new LightTaskQuartz();
        openLightTaskQuartz.setTaskId(lightTask.getTaskId());
        openLightTaskQuartz.setCronExpression(TaskOrderUtil.getHourAndMinuteOnGivenDaysOfWeek(openLightOrder.getHour(), openLightOrder.getMinute(), weekArrays));
        openLightTaskQuartz.setQuartzName(lightTask.getTaskName());
        list.add(openLightTaskQuartz);

        // æ–°å¢žå…³ç¯ç¯å®šæ—¶å™¨
        LightTaskQuartz closeLightTaskQuartz = new LightTaskQuartz();
        closeLightTaskQuartz.setTaskId(lightTask.getTaskId());
        closeLightTaskQuartz.setCronExpression(TaskOrderUtil.getHourAndMinuteOnGivenDaysOfWeek(closeLightOrder.getHour(), closeLightOrder.getMinute(), weekArrays));
        closeLightTaskQuartz.setQuartzName(lightTask.getTaskName());
        list.add(closeLightTaskQuartz);

        // æ‹¼æŽ¥äº®åº¦æŽ§ç¯å‘½ä»¤
        for (String controlOrderStr : controlOrderArray) {
            SingleLightOrderDto controlLightOrder = TaskOrderUtil.parseLightOrder(controlOrderStr);
            if (controlLightOrder != null) {
                sb.append(weekHex);
                sb.append(SupplementUtils.suppleZero(HexUtil.toHex(controlLightOrder.getHour()), 2));
                sb.append(SupplementUtils.suppleZero(HexUtil.toHex(controlLightOrder.getMinute()), 2));
                sb.append(SupplementUtils.suppleZero(HexUtil.toHex(controlLightOrder.getBrightness()), 2));

                LightTaskQuartz controlLightTaskQuartz = new LightTaskQuartz();
                controlLightTaskQuartz.setTaskId(lightTask.getTaskId());
                controlLightTaskQuartz.setCronExpression(TaskOrderUtil.getHourAndMinuteOnGivenDaysOfWeek(controlLightOrder.getHour(), controlLightOrder.getMinute(), weekArrays));
                controlLightTaskQuartz.setQuartzName(lightTask.getTaskName());
                list.add(controlLightTaskQuartz);
            }
        }

        String lightOrder = sb.toString();

        for (LightTaskQuartz lightTaskQuartz : list) {
            lightTaskQuartz.setFramePayload(lightOrder);
        }
        return list;
    }

    /**
     * æ‰§è¡Œå®šæ—¶å™¨ä»»åŠ¡
     * @param list å®šæ—¶å™¨åˆ—表
     */
    public void runLightTaskQuartz(List<LightTaskQuartz> list){
        for (LightTaskQuartz taskQuartz : list) {
            Map<String, Object> build = MapUtil.<String, Object>builder()
                    .put("taskId", taskQuartz.getTaskId())
                    .put("taskName", taskQuartz.getQuartzName())
                    .put("quartzId", taskQuartz.getId())
                    .put("cron", taskQuartz.getCronExpression()).build();
            quartzService.addJob(LightTimerJob.class, taskQuartz.getId(), taskQuartz.getCronExpression(), build);
        }
    }

    public List<LightTaskQuartz> updateLightTaskQuartz(LightTask lightTask) {

        Long taskId = lightTask.getTaskId();
        // åˆ é™¤æ—§ä»»åŠ¡
        removeLightTaskQuartz(CollectionUtil.toList(taskId));

        List<LightTaskQuartz> list = addLightTaskQuartz(lightTask);

        return list;
    }

    public boolean removeLightTaskQuartz(List<Long> taskIdList) {
        List<Long> delTaskQuartzIdList = list(Wrappers.lambdaQuery(LightTaskQuartz.class).in(LightTaskQuartz::getTaskId, taskIdList).select(LightTaskQuartz::getId))
                .stream().map(LightTaskQuartz::getId).collect(Collectors.toList());
        for (Long delTaskQuartzId : delTaskQuartzIdList) {
            quartzService.deleteJob(LightTimerJob.class,delTaskQuartzId);
        }

        return removeByIds(delTaskQuartzIdList);
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/LightTaskService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,193 @@
package com.sandu.ximon.admin.service;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.manager.iot.frame.FrameBuilder;
import com.sandu.ximon.admin.manager.iot.frame.IRequestFrame;
import com.sandu.ximon.admin.manager.iot.frame.inner.request.A5LightTimerReqInnerFrame;
import com.sandu.ximon.admin.manager.iot.frame.inner.response.A5LightTimerRespInnerFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.dto.WrapResponseCommonFrame;
import com.sandu.ximon.admin.manager.iot.rrpc.enums.A5OrderEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
import com.sandu.ximon.admin.param.LightTaskParam;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.dao.domain.LightTask;
import com.sandu.ximon.dao.domain.LightTaskPoleRelation;
import com.sandu.ximon.dao.domain.LightTaskQuartz;
import com.sandu.ximon.dao.mapper.LightTaskMapper;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.time.LocalDateTime;
import java.util.List;

/**
 * @author chenjiantian
 * @date 2021/12/15 16:33
 * è·¯ç¯ä»»åŠ¡æ“ä½œ
 */
@Service
@AllArgsConstructor
public class LightTaskService extends BaseServiceImpl<LightTaskMapper, LightTask> {


    private final LightTaskQuartzService lightTaskQuartzService;
    private final PoleService poleService;
    private final LightTaskPoleRelationService lightTaskPoleRelationService;

    /**
     * æ–°å¢žè·¯ç¯ä»»åŠ¡
     */
    @Transactional(rollbackFor = Exception.class)
    public boolean addLightTask(LightTaskParam param) {
        if (StrUtil.length(param.getControlOrder()) % LightTaskParam.REQUEST_ORDER_LENGTH != 0) {
            throw new BusinessException("灯控命令格式不正确");
        }
        LightTask lightTask = new LightTask();
        lightTask.setClientId(SecurityUtils.getClientId());
        lightTask.setTaskName(param.getTaskName());
        lightTask.setWeek(param.getWeek());
        lightTask.setCloseOrder(param.getCloseOrder());
        lightTask.setOpenOrder(param.getOpenOrder());
        lightTask.setControlOrder(param.getControlOrder());
        lightTask.setCreateUser(SecurityUtils.getUsername());
        if (!save(lightTask)) {
            throw new BusinessException("保存路灯任务失败");
        }
        List<LightTaskQuartz> list = lightTaskQuartzService.addLightTaskQuartz(lightTask);
        if (CollectionUtil.isEmpty(list)) {
            throw new BusinessException("添加定时任务失败");
        }
        // æ·»åŠ ç»‘定灯杆
        if (!lightTaskPoleRelationService.updateLightTaskPoleRelation(lightTask.getTaskId(), param.getPoleIdList())) {
            throw new BusinessException("绑定灯杆失败");
        }

        List<Long> poleIdList = param.getPoleIdList();
        if (CollectionUtil.isNotEmpty(poleIdList)) {
            List<String> deviceCodeList = poleService.listDeviceCodeByIds(poleIdList);
            if (CollectionUtil.isEmpty(deviceCodeList)) {
                throw new BusinessException("找不到灯杆mac，无法发送定时任务");
            }
            // èŽ·å–定时灯控命令
            String framePayload = list.get(0).getFramePayload();

            // rrpc å‘生定时命令
            for (String deviceCode : deviceCodeList) {
                sendTimeRRpc(framePayload, deviceCode);
            }
        }
        return true;
    }

    /**
     * å‘送灯控请求
     *
     * @param framePayload ç¯æŽ§å‚æ•°
     * @param deviceCode   è®¾å¤‡å—
     * @return è¿”回帧
     */
    public A5LightTimerRespInnerFrame sendTimeRRpc(String framePayload, String deviceCode) {
        IRequestFrame requestFrame = FrameBuilder.builderA5().innerFrame(new A5LightTimerReqInnerFrame(framePayload))
                .orderType(A5OrderEnum.REQUEST_LIGHT_DATA.getCode()).build();
        WrapResponseCommonFrame<A5LightTimerRespInnerFrame> responseCommonFrame = MainBoardInvokeSyncService.getInstance()
                .sendRRPC(deviceCode, requestFrame, A5LightTimerRespInnerFrame.class);
        System.out.println("发送结果");
        A5LightTimerRespInnerFrame responseInnerFrame = responseCommonFrame.getResponseInnerFrame();
        System.out.println(responseInnerFrame.getResponseStatus());
        return responseInnerFrame;
    }

    public List<LightTask> listLightTask(int pageNo, int pageSize, String keyword) {
        LambdaQueryWrapper<LightTask> wrapper = Wrappers.lambdaQuery(LightTask.class);
        if (StrUtil.isNotBlank(keyword)) {
            wrapper.like(LightTask::getTaskName, keyword);
        }
        Long clientId = SecurityUtils.getClientId();
        if (clientId != null) {
            wrapper.eq(LightTask::getClientId, clientId);
        }

        PageHelper.startPage(pageNo, pageSize);
        return list(wrapper);
    }

    @Transactional(rollbackFor = Exception.class)
    public boolean updateLightTask(Long taskId, LightTaskParam param) {
        if (StrUtil.length(param.getControlOrder()) % LightTaskParam.REQUEST_ORDER_LENGTH != 0) {
            throw new BusinessException("灯控命令格式不正确");
        }
        LightTask lightTask = getById(taskId);
        if (lightTask == null) {
            throw new BusinessException("找不到路灯任务");
        }

        lightTask.setTaskName(param.getTaskName());
        lightTask.setWeek(param.getWeek());
        lightTask.setControlOrder(param.getControlOrder());
        lightTask.setOpenOrder(param.getOpenOrder());
        lightTask.setCloseOrder(param.getCloseOrder());
        lightTask.setUpdateTime(LocalDateTime.now());

        if (!updateById(lightTask)) {
            throw new BusinessException("编辑任务失败");
        }

        List<LightTaskQuartz> list = lightTaskQuartzService.updateLightTaskQuartz(lightTask);
        if (CollectionUtil.isEmpty(list)) {
            throw new BusinessException("编辑定时任务失败");
        }

        // æ·»åŠ ç»‘定灯杆
        if (!lightTaskPoleRelationService.updateLightTaskPoleRelation(lightTask.getTaskId(), param.getPoleIdList())) {
            throw new BusinessException("绑定灯杆失败");
        }
        List<Long> poleIdList = param.getPoleIdList();
        if (CollectionUtil.isNotEmpty(poleIdList)) {
            List<String> deviceCodeList = poleService.listDeviceCodeByIds(poleIdList);
            if (CollectionUtil.isEmpty(deviceCodeList)) {
                throw new BusinessException("找不到灯杆mac，无法发送定时任务");
            }
            // èŽ·å–定时灯控命令
            String framePayload = list.get(0).getFramePayload();

            // rrpc å‘生定时命令
            for (String deviceCode : deviceCodeList) {
                sendTimeRRpc(framePayload, deviceCode);
            }
        }

        return true;
    }

    @Transactional(rollbackFor = Exception.class)
    public boolean delLightTask(List<Long> taskIdList) {
        List<LightTask> lightTaskList = listByIds(taskIdList);
        if (CollectionUtil.isEmpty(lightTaskList)) {
            throw new BusinessException("找不到任务信息");
        }

        // åˆ é™¤ä»»åŠ¡
        if (!removeByIds(taskIdList)) {
            throw new BusinessException("删除任务失败");
        }

        // åˆ é™¤ç»‘定灯杆
        if (!lightTaskPoleRelationService.remove(Wrappers.lambdaQuery(LightTaskPoleRelation.class).in(LightTaskPoleRelation::getTaskId, taskIdList))) {
            throw new BusinessException("删除绑定灯杆失败");
        }

        // åˆ é™¤å®šæ—¶å™¨
        if (!lightTaskQuartzService.removeLightTaskQuartz(taskIdList)) {
            throw new BusinessException("删除定时器失败");
        }

        return true;
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/PoleService.java

@@ -1,5 +1,7 @@
package com.sandu.ximon.admin.service;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.StrUtil;
import com.aliyuncs.iot.model.v20180120.BatchGetDeviceStateResponse;
import com.aliyuncs.iot.model.v20180120.QueryDeviceDetailResponse;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -35,6 +37,7 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * ç¯æ†ç›¸å…³
@@ -82,7 +85,7 @@
    /**
     * ç”Ÿæˆç¯æ†ç¼–号
     */
    private Long generatePoleCode() {
    public Long generatePoleCode() {
        StringBuilder sb = new StringBuilder();
        String date = new SimpleDateFormat("yyMMdd").format(new Date());
        sb.append(date);
@@ -277,4 +280,12 @@
        }
        return setMac;
    }

    public List<String> listDeviceCodeByIds(List<Long> poleIdList) {
        if(CollectionUtil.isEmpty(poleIdList)){
            return null;
        }
        return list(Wrappers.lambdaQuery(Pole.class).in(Pole::getId, poleIdList).select(Pole::getDeviceCode))
                .stream().map(Pole::getDeviceCode).filter(StrUtil::isNotEmpty).collect(Collectors.toList());
    }
}

 ximon-admin/src/main/java/com/sandu/ximon/admin/utils/TaskOrderUtil.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,77 @@
package com.sandu.ximon.admin.utils;

import cn.hutool.core.util.ArrayUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import com.sandu.ximon.admin.constant.Constants;
import com.sandu.ximon.admin.dto.SingleLightOrderDto;
import com.sandu.ximon.dao.enums.WeekEnums;
import org.quartz.DateBuilder;

import java.util.ArrayList;
import java.util.List;

/**
 * @author chenjiantian
 * @date 2021/12/15 18:06
 * ä»»åŠ¡å‘½ä»¤å·¥å…·ç±»
 */
public class TaskOrderUtil {

    public static SingleLightOrderDto parseLightOrder(String lightOrder) {
        if (StrUtil.length(lightOrder) != 7) {
            return null;
        }
        SingleLightOrderDto singleLightOrderDto = new SingleLightOrderDto();
        singleLightOrderDto.setHour(NumberUtil.parseInt(lightOrder.substring(0, 2)));
        singleLightOrderDto.setMinute(NumberUtil.parseInt(lightOrder.substring(2, 4)));
        singleLightOrderDto.setBrightness(NumberUtil.parseInt(lightOrder.substring(4, 7)));
        return singleLightOrderDto;
    }

    public static Integer[] parseLightWeek(Integer week) {
        if (week == null) {
            return null;
        }
        List<Integer> list = new ArrayList<>();
        if((WeekEnums.SUNDAY.getCode() & week) > 0){
            list.add(DateBuilder.SUNDAY);
        }
        if((WeekEnums.MONDAY.getCode() & week) > 0){
            list.add(DateBuilder.MONDAY);
        }
        if((WeekEnums.TUESDAY.getCode() & week) > 0){
            list.add(DateBuilder.TUESDAY);
        }
        if((WeekEnums.WEDNESDAY.getCode() & week) > 0){
            list.add(DateBuilder.WEDNESDAY);
        }
        if((WeekEnums.THURSDAY.getCode() & week) > 0){
            list.add(DateBuilder.THURSDAY);
        }
        if((WeekEnums.FRIDAY.getCode() & week) > 0){
            list.add(DateBuilder.FRIDAY);
        }
        if((WeekEnums.SATURDAY.getCode() & week) > 0){
            list.add(DateBuilder.SATURDAY);
        }
        return list.toArray(new Integer[0]);
    }

    /**
     * æ ¹æ®ç»™å®šçš„时分周生成cron
     * @param hour æ—¶
     * @param minute åˆ†
     * @param daysOfWeek 1表示的是星期日，7表示的星期六
     * @return cron
     */
    public static String getHourAndMinuteOnGivenDaysOfWeek(int hour, int minute, Integer... daysOfWeek) {
        StringBuilder cronExpression = new StringBuilder(String.format("0 %d %d ? * %d", minute, hour,
                daysOfWeek[0]));

        for (int i = 1; i < daysOfWeek.length; i++) {
            cronExpression.append(",").append(daysOfWeek[i]);
        }
        return cronExpression.toString();
    }
}

 ximon-admin/src/main/resources/application-dev.yml

@@ -33,5 +33,7 @@
    storage: local
  common:
    urlPrefix: http://localhost:8080/file/
  quartz:
    enable: true



 ximon-admin/src/test/java/com/sandu/ximon/admin/AdminApplicationTests.java

@@ -1,6 +1,10 @@
package com.sandu.ximon.admin;

import cn.hutool.crypto.SecureUtil;
import com.sandu.ximon.admin.service.PoleService;
import org.junit.jupiter.api.Test;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.security.crypto.password.PasswordEncoder;
@@ -8,12 +12,28 @@
@SpringBootTest
class AdminApplicationTests {

    @Autowired
    private PasswordEncoder passwordEncoder;
    @Test
    void contextLoads() {
        System.out.println(passwordEncoder.encode("666666"));
    }
    @Autowired
    private PasswordEncoder passwordEncoder;
    @Autowired
    private PoleService poleService;

    @Test
    void contextLoads() {
        //ae8b5aa26a3ae31612eec1d1f6ffbce9
        String encode = SecureUtil.md5("66666");
        String encode2 = passwordEncoder.encode(encode);
        System.out.println(encode);
        System.out.println(encode2);
    }

    @Test
    void poleService() {
        System.out.println(poleService.generatePoleCode());
    }

    public static void main(String[] args) {


    }

}

 ximon-admin/src/test/java/com/sandu/ximon/admin/QuartzTests.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,35 @@
package com.sandu.ximon.admin;

import cn.hutool.core.collection.ListUtil;
import com.sandu.common.quartz.service.QuartzServiceImpl;
import com.sandu.ximon.admin.param.LightTaskParam;
import com.sandu.ximon.admin.service.LightTaskService;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import javax.annotation.Resource;

@SpringBootTest
@Slf4j
class QuartzTests {

    @Resource
    private QuartzServiceImpl quartzService;
    @Resource
    private LightTaskService lightTaskService;

    @Test
    void addLightTask() {
        LightTaskParam lightTaskParam = new LightTaskParam();
        lightTaskParam.setTaskName("日常任务");
        lightTaskParam.setPoleIdList(ListUtil.toList(1L));
        lightTaskParam.setWeek(126);
        lightTaskParam.setOpenOrder("1630100");
        lightTaskParam.setCloseOrder("0600000");
        lightTaskParam.setControlOrder("00000500300020");
        System.out.println(lightTaskService.addLightTask(lightTaskParam));
    }


}