alarm_daily统计任务，创建alarm年月分表任务，alarm相关接口更新

jinpengyong

2020-05-19 c49d3947b165e0868d48a4c969e55093b8d05705

 src/main/java/com/moral/task/RabbitMQInsertTask.java

@@ -32,7 +32,7 @@
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;

//@Component
@Component
public class RabbitMQInsertTask {
    private static transient Logger logger = LoggerFactory.getLogger(RabbitMQInsertTask.class);

@@ -61,11 +61,24 @@
    @Qualifier("organization_data")
    private TopicExchange organization_data;

    //@XxlJob("RabbitMQRealtimeMinutely")
    @XxlJob("RabbitMQRealtimeMinutely")
    public ReturnT insertRabbitMQRealtimeMinutely(String params) {
        LocalDateTime time = LocalDateTime.now();
        int year = time.getYear();
        int month = time.getMonthValue();
        int day = time.getDayOfMonth();
        int hour = time.getHour();
        int minute = time.getMinute();
        if (day == 1) {
            if (hour == 0 && minute == 0) {
                if (month == 1) {
                    month = 12;
                    year = year - 1;
                } else {
                    month = month - 1;
                }
            }
        }
        String monthStr = month < 10 ? ("0" + month) : month + "";
        String yearAndMonth = year + monthStr;
        Map organizationIdMap = JSON.parseObject(params);
@@ -122,11 +135,24 @@
        return returnT;
    }

    //@XxlJob("RabbitMQRealtimeEveryFiveMinutes")
    @XxlJob("RabbitMQRealtimeEveryFiveMinutes")
    public ReturnT insertRabbitMQRealtimeEveryFiveMinutes(String params) {
        LocalDateTime time = LocalDateTime.now();
        int year = time.getYear();
        int month = time.getMonthValue();
        int day = time.getDayOfMonth();
        int hour = time.getHour();
        int minute = time.getMinute();
        if (day == 1) {
            if (hour == 0 && minute == 0) {
                if (month == 1) {
                    month = 12;
                    year = year - 1;
                } else {
                    month = month - 1;
                }
            }
        }
        String monthStr = month < 10 ? ("0" + month) : month + "";
        String yearAndMonth = year + monthStr;
        Map organizationIdMap = JSON.parseObject(params);
@@ -183,11 +209,24 @@
        return returnT;
    }

    //@XxlJob("RabbitMQMinutely")
    @XxlJob("RabbitMQMinutely")
    public ReturnT insertRabbitMQMinutely(String params) {
        LocalDateTime time = LocalDateTime.now();
        int year = time.getYear();
        int month = time.getMonthValue();
        int day = time.getDayOfMonth();
        int hour = time.getHour();
        int minute = time.getMinute();
        if (day == 1) {
            if (hour == 0 && minute == 0) {
                if (month == 1) {
                    month = 12;
                    year = year - 1;
                } else {
                    month = month - 1;
                }
            }
        }
        String monthStr = month < 10 ? ("0" + month) : month + "";
        String yearAndMonth = year + monthStr;
        Map organizationIdMap = JSON.parseObject(params);
@@ -245,7 +284,7 @@
        return returnT;
    }

    //@XxlJob("RabbitMQHourly")
    @XxlJob("RabbitMQHourly")
    public ReturnT insertRabbitMQHourly(String params) {
        LocalDateTime time = LocalDateTime.now();
        Map organizationIdMap = JSON.parseObject(params);
@@ -302,7 +341,7 @@
        return returnT;
    }

    //@XxlJob("RabbitMQDaily")
    @XxlJob("RabbitMQDaily")
    public ReturnT insertRabbitMQDaily(String params) {
        LocalDateTime time = LocalDateTime.now();
        Map organizationIdMap = JSON.parseObject(params);
@@ -358,4 +397,7 @@
        ReturnT returnT = new ReturnT(500, "RabbitMQ天数据存入失败");
        return returnT;
    }

}