package com.zy.ints.task.scheduler; import com.zy.asrs.service.ApiLogService; import com.zy.ints.entity.ErpDetTb; 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.Date; import java.util.List; /** * erp任务控制器 * Created by vincent on 2020/11/27 */ @Slf4j @Component public class ErpLkScheduler { /** * ERP接口是否启用 */ @Value("${erp.enabled}") private Boolean erpEnabled; @Value("${erp.useName.ip}") private String ip; @Autowired private ApiLogService apiLogService; @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){ Date date = new Date(); log.error(date + ": 表名:bas_erp_lk :" + e); } } public void callApiLogSave(ErpLk erpLk, String tableName, String response, Boolean bool) { apiLogService.save("ERP与lk库存数据比对", tableName, "null", ip, "品号:" + erpLk.getPrdNo() + "、货品特征:" + erpLk.getPrdMark() + "、数量:" + erpLk.getQty() + "、状态:" + erpLk.getStatus(), response, bool); } }