|  |  |  | 
|---|
|  |  |  | 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())); | 
|---|
|  |  |  | 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()); | 
|---|
|  |  |  | 
|---|
|  |  |  | //                    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 失败!(半成品调拨单任务)" ); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | // 更新源库位 | 
|---|