| | |
| | | |
| | | @Transactional(rollbackFor = Throwable.class) |
| | | @Scheduled(cron = "${erp.refreshtime}") |
| | | public void InCancelScheduler() { |
| | | public void OutCancelScheduler() { |
| | | //log.info("InCancelScheduler开始了"); |
| | | if (!erpEnabled) return; |
| | | String sqlInCancelTB = "select * from erp_OutCancelTB where LKName='中扬二期'"; |
| | | String sqlInCancelTB = "select * from erp_OutCancelTB"; |
| | | List<OutCancelTB> ins = erpSqlServer.select(sqlInCancelTB, OutCancelTB.class); |
| | | for (OutCancelTB in : ins) { |
| | | com.zy.third.lk.entity.InCancelTB lkCancel = inMS.tryCancel(in.getBillNo()); |
| | | com.zy.third.lk.entity.OutCancelTB lkCancel = inMS.tryCancelOut(in.getBillNo()); |
| | | if (lkCancel != null) { |
| | | HashMap<String, String> condition = new HashMap<>(); |
| | | condition.put("BillNo", "'" + in.getBillNo() + "'"); |
| | | int delete = erpSqlServer.delete(InCancelTB.class, condition); |
| | | int delete = erpSqlServer.delete(com.zy.third.erp.entity.OutCancelTB.class, condition); |
| | | if (delete > 0) { |
| | | log.info("将入库取消通知单删除成功,{}", lkCancel.getBillNo()); |
| | | log.info("将出库取消通知单删除成功,{}", lkCancel.getBillNo()); |
| | | } else { |
| | | log.error("将入库取消通知单删除失败,{}", lkCancel.getBillNo()); |
| | | log.error("将出库取消通知单删除失败,{}", lkCancel.getBillNo()); |
| | | } |
| | | HashMap<String, Object> content = new HashMap<>(); |
| | | content.put("BillNo", "'" + lkCancel.getBillNo() + "'"); |
| | | content.put("opFlag", lkCancel.getOpFlag()); |
| | | int insert = erpSqlServer.insert(com.zy.third.lk.entity.InCancelTB.class, content); |
| | | // content.put("opFlag", lkCancel.getOpFlag()); |
| | | int insert = erpSqlServer.insert(com.zy.third.lk.entity.OutCancelTB.class, content); |
| | | if (insert > 0) { |
| | | log.info("将入库取消通知单写入成功,{}", lkCancel.getBillNo()); |
| | | log.info("将出库取消通知单写入成功,{}", lkCancel.getBillNo()); |
| | | } else { |
| | | log.error("将入库取消通知单写入失败,{}", lkCancel.getBillNo()); |
| | | log.error("将出库取消通知单写入失败,{}", lkCancel.getBillNo()); |
| | | } |
| | | } else { |
| | | log.error("将入库取消通知单写入失败"); |
| | | log.error("将出库取消通知单写入失败"); |
| | | } |
| | | } |
| | | } |