water-iot/smart-city-job/src/main/java/com/zcxk/job/service/jobhandler/WaterMeterReadJob.java

package com.zcxk.job.service.jobhandler;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.xxl.job.core.log.XxlJobLogger;
import com.xxl.job.core.util.ShardingUtil;
import com.zcxk.job.service.MeterReadRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class WaterMeterReadJob {

    @Autowired
    MeterReadRecordService meterReadRecordService;

    /**
     * 每天生成第二天的抄表记录
     * @param param
     * @return
     * @throws Exception
     */
    @XxlJob("waterMeterReadJobHandler")
    public ReturnT<String> waterMeterReadJobHandler(String param) throws Exception {

        // 分片参数
        ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
        XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());

        // 业务逻辑
        for (int i = 0; i < shardingVO.getTotal(); i++) {
            if (i == shardingVO.getIndex()) {
                XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
                meterReadRecordService.createMeterReadRecord(param,shardingVO.getIndex(),shardingVO.getTotal());
            } else {
                XxlJobLogger.log("第 {} 片, 忽略", i);
            }
        }

        return ReturnT.SUCCESS;
    }

    /**
     * 补齐昨天未抄的最近有效数据
     * @param param
     * @return
     * @throws Exception
     */
    @XxlJob("waterMeterUnReadReplenishJobHandler")
    public ReturnT<String> waterMeterUnReadReplenishJobHandler(String param) throws Exception {

        meterReadRecordService.waterMeterUnReadReplenishJobHandler(param);

        return ReturnT.SUCCESS;
    }
}