update

xufenglei

2020-03-26 ac4de7623b87a6826d3078f35cf3da13a43af3cf

 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,7 +61,7 @@
    @Qualifier("organization_data")
    private TopicExchange organization_data;

    //@XxlJob("RabbitMQRealtimeMinutely")
    @XxlJob("RabbitMQRealtimeMinutely")
    public ReturnT insertRabbitMQRealtimeMinutely(String params) {
        LocalDateTime time = LocalDateTime.now();
        int year = time.getYear();
@@ -122,7 +122,7 @@
        return returnT;
    }

    //@XxlJob("RabbitMQRealtimeEveryFiveMinutes")
    @XxlJob("RabbitMQRealtimeEveryFiveMinutes")
    public ReturnT insertRabbitMQRealtimeEveryFiveMinutes(String params) {
        LocalDateTime time = LocalDateTime.now();
        int year = time.getYear();
@@ -183,7 +183,7 @@
        return returnT;
    }

    //@XxlJob("RabbitMQMinutely")
    @XxlJob("RabbitMQMinutely")
    public ReturnT insertRabbitMQMinutely(String params) {
        LocalDateTime time = LocalDateTime.now();
        int year = time.getYear();
@@ -245,7 +245,7 @@
        return returnT;
    }

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

    //@XxlJob("RabbitMQDaily")
    @XxlJob("RabbitMQDaily")
    public ReturnT insertRabbitMQDaily(String params) {
        LocalDateTime time = LocalDateTime.now();
        Map organizationIdMap = JSON.parseObject(params);