| | |
| | | import com.zy.asrs.entity.*; |
| | | import com.zy.asrs.entity.param.*; |
| | | import com.zy.asrs.service.*; |
| | | import com.zy.asrs.service.impl.OrderServiceImpl; |
| | | import com.zy.common.web.BaseController; |
| | | import io.swagger.models.auth.In; |
| | | import lombok.Synchronized; |
| | |
| | | private SnowflakeIdWorker snowflakeIdWorker; |
| | | @Autowired |
| | | private FlowLogService flowLogService; |
| | | @Autowired |
| | | private OrderServiceImpl orderService; |
| | | |
| | | |
| | | /* |
| | |
| | | List<HashMap<String,String>> dbList = (List<HashMap<String, String>>) params.get("dbList"); |
| | | params.get("dbList"); |
| | | Object mT = params.get("moveType"); |
| | | String orderNo = params.get("orderNo").toString(); |
| | | String moveType = ""; |
| | | Integer ioType = 0; |
| | | if (mT.equals("unAuto")) { |
| | |
| | | wrkDetl.setWrkNo(wrkMast.getWrkNo()); |
| | | wrkDetl.sync(agvLocDetl); |
| | | wrkDetl.setSuppCode(agvLocDetl.getSuppCode()); |
| | | wrkDetl.setModel(orderNo); |
| | | wrkDetl.setIoTime(now); |
| | | wrkDetl.setAppeUser(getUserId()); |
| | | wrkDetl.setAppeTime(now); |
| | |
| | | if (!agvWrkDetlService.insert(wrkDetl)) { |
| | | throw new CoolException("保存工作明细失败"); |
| | | } |
| | | |
| | | // 更新订单 |
| | | OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("source",33).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode())); |
| | | // FlowLog flowLog = new FlowLog(); |
| | | OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no",orderNo).eq("source",33).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode())); |
| | | // 判断订单是否超量 |
| | | if (orderDetl.getQty() >= orderDetl.getAnfme()) { |
| | | throw new CoolException("调拨单:" + orderNo + "的<" + agvLocDetl.getMatnr() + ">已完成调拨数量,请检查!"); |
| | | } |
| | | // FlowLog flowLog = new FlowLog(); |
| | | // flowLog.setFid(String.valueOf(flowId)); |
| | | // flowLog.setSpare2(wrkMast.getWrkNo().toString()); |
| | | // flowLog.setLocNo(wrkMast.getSourceLocNo()); |
| | |
| | | // throw new CoolException("同步半成品调拨单流水记录失败"); |
| | | // } |
| | | orderDetl.setQty(orderDetl.getQty() + agvLocDetl.getAnfme()); |
| | | if (!orderDetlService.update(orderDetl,new EntityWrapper<OrderDetl>().eq("source",33).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()))){ |
| | | throw new CoolException("修改订单明细失败,请联系管理员"+agvLocDetl.getOrderNo()+agvLocDetl.getMatnr()); |
| | | if (!orderDetlService.update(orderDetl,new EntityWrapper<OrderDetl>().eq("order_no",orderNo).eq("source",33).eq("matnr", agvLocDetl.getMatnr()).eq("three_code",agvLocDetl.getThreeCode()))){ |
| | | throw new CoolException("订单号:{"+orderNo+"}更新订单明细失败! 异常物料:"+agvLocDetl.getMatnr()+"(半成品调拨单任务)" ); |
| | | } |
| | | // 更新订单状态 |
| | | Order order = orderService.selectByNo(orderDetl.getOrderNo()); |
| | | Long settle = order.getSettle(); |
| | | if (settle == 1L) { |
| | | if (!orderService.updateSettle(order.getId(),2L,getUserId())) { |
| | | throw new CoolException("订单号:{"+order.getOrderNo()+"}更新订单状态:1-->2 失败!(半成品调拨单任务)" ); |
| | | } |
| | | } |
| | | } |
| | | // 更新源库位 |