package com.zy.ints.task; import com.zy.asrs.task.core.ReturnT; import com.zy.ints.entity.WaitMatchk; import com.zy.ints.service.WaitMatchkService; import com.zy.ints.task.handler.WaitMatchkLogHandler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.util.List; /** * 盘点通知档转历史档 * Created by TQS on 2021/9/2 */ @Component public class WaitMatchkLogScheduler { private static final Logger log = LoggerFactory.getLogger(WaitMatchkLogScheduler.class); @Autowired private WaitMatchkLogHandler waitMatchkLogHandler; @Autowired private WaitMatchkService waitMatchkService; /** * ERP接口是否启用 */ @Value("${erp.enabled}") private Boolean erpEnabled; @Scheduled(cron = "0/5 * * * * ? ") private void execute(){ if(!erpEnabled) return; List waitMatchks = waitMatchkService.selectWaitMatchkBySts(); for (WaitMatchk waitMatchk : waitMatchks) { ReturnT result = waitMatchkLogHandler.start(waitMatchk); if (!result.isSuccess()) { log.error("盘点通知档[billNo={},locNo={},matNo={}]历史档处理失败", waitMatchk.getBillNo(),waitMatchk.getLocNo(),waitMatchk.getMatNo()); } } } }