| | |
| | | //@Transactional(rollbackFor = Throwable.class) |
| | | @Scheduled(cron = "${erp.refreshtime}") |
| | | public void InHedTBScheduler() { |
| | | //log.info("InHedTBScheduler开始了"); |
| | | //log.info("InHedTBScheduler开始了" |
| | | // 7); |
| | | if (!erpEnabled) return; |
| | | String sqlInHed = "select * from erp_InHedTB where LKName='中扬二期'"; |
| | | List<InHedTB> inHeds = erpSqlServer.select(sqlInHed, InHedTB.class); |
| | |
| | | HashMap<String, Object> hedAndDet = new HashMap<>(); |
| | | hedAndDet.put("hed", inHed); |
| | | hedAndDet.put("det", inDetTBS); |
| | | if (inDetTBS == null || inDetTBS.isEmpty()) { |
| | | continue; |
| | | } |
| | | try { |
| | | inMS.createInOrder(inHed, inDetTBS); |
| | | log.info("入库单据成功,{}", inHed); |
| | | move(hedAndDet); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | log.info(e.getMessage()); |
| | | //e.printStackTrace(); |
| | | String sql = "UPDATE erp_InHedTB SET Temp3 = 'fault' WHERE BillNo = '" + inHed.getBillNo() + "'"; |
| | | erpSqlServer.update(sql); |
| | | erpSqlServer.update(sql); |
| | | } |
| | | } |
| | | } |