feiyu02
2024-08-15 196bb14112448857a885e32dc4149e308e00b01a
src/main/kotlin/cn/flightfeather/supervision/bgtask/TaskController.kt
ÎļþÃû´Ó src/main/kotlin/cn/flightfeather/supervision/timingtask/TaskController.kt ÐÞ¸Ä
@@ -1,6 +1,7 @@
package cn.flightfeather.supervision.timingtask
package cn.flightfeather.supervision.bgtask
import org.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Value
import org.springframework.stereotype.Component
import java.time.LocalDateTime
import java.time.LocalTime
@@ -14,7 +15,18 @@
 */
@Component
class TaskController(
    fetchVOC: TaskFetchVOC, pushFume: TaskPushFume, ledgerCopy: TaskLedgerCopy
    fetchVOC: TaskFetchVOC,
    pushFume: TaskPushFume,
    ledgerCopy: TaskLedgerCopy,
    ledgerRemind: TaskLedgerRemind,
    taskJinAnLampEnterBaseInfo: TaskJinAnLampEnterBaseInfo,
    taskJinAnLampDeviceData: TaskJinAnLampDeviceData,
    taskJinAnConstructionSiteInfo: TaskJinAnConstructionSiteInfo,
    taskJinAnHourlyDustData: TaskJinAnHourlyDustData,
    taskAutoLedger:TaskAutoLedger,
    // æ ¹æ®app不同,切换不同的定时任务
    @Value("\${systemIsApp}")
    systemIsApp: Boolean,
) {
    companion object {
@@ -33,11 +45,19 @@
        LOGGER.info("添加定时任务")
        timeTask.clear()
        //飞羽环境,获取voc数据、推送油烟数据
//        timeTask.add(fetchVOC)
//        timeTask.add(pushFume)
        //微信小程序(中小企业守法自助),台账复制、定时任务推送等
        timeTask.add(ledgerCopy)
        if (systemIsApp) {
            timeTask.add(fetchVOC)
            timeTask.add(pushFume)
        } else {
            //微信小程序(中小企业守法自助),台账复制、定时任务推送等
//        timeTask.add(ledgerCopy)
            timeTask.add(ledgerRemind)
            timeTask.add(taskJinAnLampEnterBaseInfo)
//        timeTask.add(taskJinAnLampDeviceData)
            timeTask.add(taskJinAnConstructionSiteInfo)
//            timeTask.add(taskJinAnHourlyDustData)
            timeTask.add(taskAutoLedger)
        }
        LOGGER.info("添加定时任务完成,任务总计${timeTask.size}个")
    }