HQPODataUploadTask.java 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. package com.uas.eis.task;
  2. import com.uas.eis.dao.BaseDao;
  3. import com.uas.eis.sdk.entity.ApiResult;
  4. import com.uas.eis.service.ERPService;
  5. import com.uas.eis.service.HQService;
  6. import org.slf4j.Logger;
  7. import org.slf4j.LoggerFactory;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.scheduling.annotation.EnableAsync;
  10. import org.springframework.scheduling.annotation.EnableScheduling;
  11. import org.springframework.scheduling.annotation.Scheduled;
  12. import org.springframework.stereotype.Component;
  13. @Component
  14. @EnableAsync
  15. @EnableScheduling
  16. public class HQPODataUploadTask {
  17. private final Logger logger = LoggerFactory.getLogger(this.getClass());
  18. @Autowired
  19. private BaseDao baseDao;
  20. @Autowired
  21. private HQService hqService;
  22. @Scheduled(cron = "0 0 0 * * ?")
  23. public void uploadHQPOPlan() {
  24. logger.info("uploadHQPOPlan-begin");
  25. String master = "N_HUASL_SZ";
  26. Integer vpId = baseDao.queryForObject("select max(vp_id) vp_id from "+master+".vendPurExecplan where vp_statuscode='AUDITED' and nvl(vp_remark,' ') not like '%测试%'",Integer.class);
  27. if(vpId!=null && vpId > 0){
  28. String emCode="TASK";
  29. String caller = "";
  30. ApiResult<String> apiResult = hqService.syncHQPOPlan(master,vpId,emCode,caller);
  31. System.out.println(apiResult.toString());
  32. }
  33. logger.info("uploadHQPOPlan-End:master {} id {}",master,vpId);
  34. }
  35. }