meter-reading-system-v2/src/main/java/com/zcxk/meterreadingsystemv2/controller/TestController.java

package com.zcxk.meterreadingsystemv2.controller;

import com.zcxk.meterreadingsystemv2.common.AjaxMessage;
import com.zcxk.meterreadingsystemv2.common.ResultStatus;
import com.zcxk.meterreadingsystemv2.repository.MongoMeterReadRecord;
import com.zcxk.meterreadingsystemv2.repository.MeterReadRecordRepository;
import com.zcxk.meterreadingsystemv2.scheduled.MeterReadingScheduleTask;
import com.zcxk.meterreadingsystemv2.service.MeterReadService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@ResponseBody
@RequestMapping("/test")
@Api(tags = "测试")
public class TestController {

    @Autowired
    private MeterReadService meterReadService;
    @Autowired
    private MeterReadingScheduleTask meterReadingScheduleTask;
    @Autowired
    private MeterReadRecordRepository meterReadRecordRepository;

    /*@GetMapping("test")
    @ApiOperation(value = "测试")
    public AjaxMessage test(
            @ApiParam(value = "名称", required = false) @RequestParam(required = false) String name
    ) {
        meterReadService.test(name);
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("switchDb")
    @ApiOperation(value = "切换数据库")
    public AjaxMessage switchDb(
            @ApiParam(value = "名称", required = false) @RequestParam(required = false) String name
    ) {
        meterReadService.switchDb(name);
        return new AjaxMessage<>(ResultStatus.OK);
    }*/

    @GetMapping("test")
    @ApiOperation(value = "测试")
    public AjaxMessage testGetUser(
    ) {
        //meterReadService.testGetUser();
        //meterReadService.test(null);
        meterReadService.testQ(null);
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("test2")
    @ApiOperation(value = "测试2")
    public AjaxMessage testGetUser2(
    ) {
        //meterReadService.testGetUser();
        //meterReadService.test(null);
        meterReadService.testQ2(null);
        return new AjaxMessage<>(ResultStatus.OK);
    }


    @GetMapping("xpTasks")
    @ApiOperation(value = "执行新蒲新区(遵义新区供水)定时任务")
    public AjaxMessage xpTasks(
    ) {
        meterReadingScheduleTask.xpTasksV2();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("xingpingTasks")
    @ApiOperation(value = "执行兴平定时任务")
    public AjaxMessage xingpingTasks(
    ) {
        meterReadingScheduleTask.xingpingTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("lbTasks")
    @ApiOperation(value = "执行萝北定时任务")
    public AjaxMessage lbTasks(
    ) {

        meterReadingScheduleTask.lbTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    /*@GetMapping("suibinTasks")
    @ApiOperation(value = "执行绥滨定时任务")
    public AjaxMessage suibinTasks(
    ) {
        meterReadingScheduleTask.suibinTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }*/

    @GetMapping("suiyangTasks")
    @ApiOperation(value = "执行绥阳定时任务")
    public AjaxMessage suiyangTasks(
    ) {
        meterReadingScheduleTask.suiyangTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("tongjiangTasks")
    @ApiOperation(value = "执行同江定时任务")
    public AjaxMessage tongjiangTasks(
    ) {
        meterReadingScheduleTask.tongjiangTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("huichuanTasks")
    @ApiOperation(value = "执行汇川定时任务")
    public AjaxMessage huichuanTasks(
    ) {
        meterReadingScheduleTask.huichuanTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("balikunTasks")
    @ApiOperation(value = "执行巴里坤定时任务")
    public AjaxMessage balikunTasks(
    ) {
        meterReadingScheduleTask.balikunTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("jingyangTasks")
    @ApiOperation(value = "执行泾阳定时任务")
    public AjaxMessage jingyangTasks(
    ) {
        meterReadingScheduleTask.jingyangTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("jlTasks")
    @ApiOperation(value = "执行监利定时任务")
    public AjaxMessage jlTasks(
    ) {
        meterReadingScheduleTask.jlTasks();
        return new AjaxMessage<>(ResultStatus.OK);
    }

    @GetMapping("testMongo")
    @ApiOperation(value = "测试mongo")
    public AjaxMessage testMongo(
    ) {
        MongoMeterReadRecord mongoMeterReadRecord = meterReadRecordRepository.findByDeviceIdAndReadDate(801556644956864512L,20210125);
        return new AjaxMessage<>(ResultStatus.OK, mongoMeterReadRecord);
    }
}