package com.zy.ints.task.scheduler; import com.zy.ints.entity.ErpLk; import com.zy.ints.erp.ErpSqlServer; import lombok.extern.slf4j.Slf4j; 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; /** * erp任务控制器 * Created by vincent on 2020/11/27 */ @Slf4j @Component public class ErpLkScheduler { /** * ERP接口是否启用 */ @Value("${erp.enabled}") private Boolean erpEnabled; @Autowired private ErpSqlServer erpSqlServer; /** * ERP与lk库存数据比对 */ @Scheduled(cron = "${erp.refreshtime}") public void proofread() { if (!erpEnabled) return; String sqlSelectErpLk = "select prd_no as prdNo,prd_mark as prdMark,qty,wh,status,temp1,temp2,temp3 from bas_erp_lk where 1=1"; String sqlUpDateErpLkOne = "update bas_erp_lk set status=1 where prd_no="; String sqlUpDateErpLkTwo = "update bas_erp_lk set status=2 where prd_no="; try { List erpLks = erpSqlServer.select(sqlSelectErpLk, ErpLk.class); if (erpLks.size() > 0){ for (ErpLk erpLk:erpLks){ Integer status = erpLk.getStatus(); if (status == 0){ }else if (status == 1){ }else if (status == 2){ }else { } } } }catch (Exception e){ } } }