fix:补充提交

swb

2024-07-05 f577294fad6b5636a22ce872b3b762ae40fd7799

 screen-job/src/main/java/com/moral/api/task/HistoryTableInsertTask.java

@@ -7,10 +7,16 @@
import com.moral.api.service.HistoryFiveMinutelyService;
import com.moral.api.service.HistoryHourlyService;
import com.moral.api.service.HistoryMonthlyService;
import com.moral.api.service.HistorySecondCruiserService;
import com.moral.api.service.HistoryWeeklyService;
import com.moral.api.service.ManageCoordinateDetailService;
import com.moral.api.service.impl.HistorySecondCruiserServiceImpl;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;

import javax.xml.crypto.Data;
import java.util.Date;

@Component
public class HistoryTableInsertTask {
@@ -30,6 +36,14 @@
    @Autowired
    private HistoryMonthlyService historyMonthlyService;


    @Autowired
    private ManageCoordinateDetailService manageCoordinateDetailService;


    @Autowired
    private HistorySecondCruiserService historySecondCruiserService;

    //5分钟数据统计
    @XxlJob("insertHistoryFiveMinutely")
    public ReturnT insertHistoryFiveMinutely() {
@@ -46,7 +60,8 @@
    @XxlJob("insertHistoryDaily")
    public ReturnT insertHistoryDaily() {
        try {
            historyDailyService.insertHistoryDaily();
            Date now = new Date();
            historyDailyService.insertHistoryDaily(null);
        } catch (Exception e) {
            XxlJobHelper.log(e.getMessage());
            return ReturnT.FAIL;
@@ -101,4 +116,75 @@
        }
        return ReturnT.SUCCESS;
    }

    @XxlJob("dateToChangShu")
    public ReturnT dateToChangShu(){
        try {
            historyHourlyService.dateToChangShu(null);
        } catch (Exception e) {
            e.printStackTrace();
            return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
        }
        return ReturnT.SUCCESS;
    }

    //海城小时数据统计
    @XxlJob("dateInsertHistoryHourlyAvg")
    public ReturnT dateInsertHistoryHourlyAvg(){
        try {
            historyHourlyService.dateInsertHistoryHourlyAvg();
        } catch (Exception e) {
            e.printStackTrace();
            return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
        }
        return ReturnT.SUCCESS;
    }


    //疾控中心小时数据统计
    @XxlJob("dateInsertHistoryHourlyJKAvg")
    public ReturnT dateInsertHistoryHourlyJKAvg(){
        try {
            historyHourlyService.dateInsertHistoryHourlyJKAvg(null,null);
        } catch (Exception e) {
            e.printStackTrace();
            return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
        }
        return ReturnT.SUCCESS;
    }


    /**
     * 路段信息录入
     * @return
     */
    @XxlJob("manageCoordinateDetail")
    public ReturnT manageCoordinateDetail(){
        try {
            manageCoordinateDetailService.insertCoordinateDetail(null,null);
        } catch (Exception e) {
            XxlJobHelper.log(e.getMessage());
            return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
        }
        return ReturnT.SUCCESS;

    }


    /**
     * 走航车路段排名
     * @return
     */
    @XxlJob("secondCruiserSort")
    public ReturnT secondCruiserSort(){
        try {
            historySecondCruiserService.sort(null,null);
        } catch (Exception e) {
            XxlJobHelper.log(e.getMessage());
            return new ReturnT(ReturnT.FAIL_CODE, e.getMessage());
        }
        return ReturnT.SUCCESS;

    }

}