traf-prcs-server/src/main/java/com/its/traf/controller/its/TrafPrcsHHController.java

package com.its.traf.controller.its;

import com.its.app.utils.TimeUtils;
import com.its.traf.define.ITS;
import com.its.traf.global.AppRepository;
import com.its.traf.global.TrafJobType;
import com.its.traf.process.DbmsData;
import com.its.traf.process.DbmsDataProcess;
import com.its.traf.process.DbmsDataType;
import com.its.traf.service.its.TbHldyInfrService;
import com.its.traf.vo.statistics.voStatistics;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;

import java.util.Date;

@Slf4j
@Controller
@RequiredArgsConstructor
public class TrafPrcsHHController implements AbstractTrafPrcsController {

    private final TbHldyInfrService hldyInfrService;
    private final DbmsDataProcess dbmsDataProcess;

    private String statTime;
    private String fromTime;
    private String toTime;

    @Override
    public void initialize() {
        String currTime = TimeUtils.getCurrentTimeString();
        this.statTime = TimeUtils.getTime(TimeUtils.TYPE_PRCS_HOUR);
        this.fromTime = this.statTime;
        this.toTime = TimeUtils.getToTime(this.fromTime, TimeUtils.TYPE_PRCS_HOUR);

        String funcName = String.format("%45s", "TrafPrcsHHController.initialize");
        log.info("[SCHEDULING] {}: .HOUR, {}, {}, {}, {}", funcName, currTime, this.statTime, this.fromTime, this.toTime);
    }

    @Override
    public void run() {
        /**
         * 기타 통계 정보 생성
         */
        initialize();

        Date statDt = TimeUtils.stringToDate(this.statTime);
        String weekCd = ITS.getDayWeekCd(ITS.getDayWeek(statDt));

        voStatistics voStat = new voStatistics();
        voStat.setSTAT_DT(this.statTime);
        voStat.setSTAT_FROM(this.fromTime);
        voStat.setSTAT_TO(this.toTime);
        voStat.setDAY_TYPE_CD(weekCd);

        AppRepository.getInstance().startJob(TrafJobType.STAT_LINK_HH);
        this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_LINK_STAT_HH_CREATE, false, voStat, 1));

        AppRepository.getInstance().startJob(TrafJobType.STAT_IFSC_HH);
        this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_IFSC_STAT_HH_CREATE, false, voStat, 1));

        AppRepository.getInstance().startJob(TrafJobType.STAT_ROAD_HH);
        this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_ROAD_STAT_HH_CREATE, false, voStat, 1));
    }
}