|  |  |  | 
|---|
|  |  |  | package com.zy.ints.task.scheduler; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.baomidou.mybatisplus.mapper.EntityWrapper; | 
|---|
|  |  |  | import com.core.common.Cools; | 
|---|
|  |  |  | import com.core.common.DateUtils; | 
|---|
|  |  |  | import com.core.common.SnowflakeIdWorker; | 
|---|
|  |  |  | import com.zy.asrs.entity.DocType; | 
|---|
|  |  |  | import com.zy.asrs.entity.Mat; | 
|---|
|  |  |  | import com.zy.asrs.entity.Order; | 
|---|
|  |  |  | import com.zy.asrs.entity.OrderDetl; | 
|---|
|  |  |  | import com.zy.asrs.entity.*; | 
|---|
|  |  |  | import com.zy.asrs.service.*; | 
|---|
|  |  |  | import com.zy.ints.entity.ErpDetTb; | 
|---|
|  |  |  | import com.zy.ints.entity.ErpDetTbBak; | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | Order order1 = orderService.selectByNo(erpDetTb.getBillNo()); | 
|---|
|  |  |  | if (!Cools.isEmpty(order1)) { | 
|---|
|  |  |  | OrderDetl orderDetl = orderDetlService.selectItem(order1.getId(), erpDetTb.getBillNo(), erpDetTb.getPrdMark()); | 
|---|
|  |  |  | //                                OrderDetl orderDetl = orderDetlService.selectItem(order1.getId(), erpDetTb.getBillNo(), erpDetTb.getPrdMark()); | 
|---|
|  |  |  | OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no",erpDetTb.getBillNo()).eq("matnr",erpDetTb.getPrdNo())); | 
|---|
|  |  |  | if (Cools.isEmpty(orderDetl)) { | 
|---|
|  |  |  | orderDetl = new OrderDetl(); | 
|---|
|  |  |  | orderDetl.setOrderId(order1.getId()); | 
|---|
|  |  |  | 
|---|
|  |  |  | orderDetl.setBatch(erpDetTb.getPrdMark()); | 
|---|
|  |  |  | orderDetl.setSpecs(mat.getSpecs()); | 
|---|
|  |  |  | orderDetl.setUnit(mat.getUnit()); | 
|---|
|  |  |  | orderDetl.setOrigin(erpDetTb.getItm().toString()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | orderDetl.setStatus(1); | 
|---|
|  |  |  | orderDetl.setCreateBy(9999L); | 
|---|
|  |  |  | 
|---|
|  |  |  | callApiLogSave(erpDetTb, "ERP_DETTB", "ERP下发订单接收失败!!", false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else if (!erpDetTb.getItm().toString().equals(orderDetl.getOrigin())){ | 
|---|
|  |  |  | orderDetl.setAnfme(orderDetl.getAnfme()+erpDetTb.getQty()); | 
|---|
|  |  |  | EntityWrapper<OrderDetl> wrapper = new EntityWrapper<>(); | 
|---|
|  |  |  | wrapper.eq("id", orderDetl.getId()); | 
|---|
|  |  |  | if (orderDetlService.update(orderDetl,wrapper)) { | 
|---|
|  |  |  | erpSqlServer.update(sqlUpDateErpDetTbOne + "'" + erpDetTb.getPrdNo() + "'"); | 
|---|
|  |  |  | callApiLogSave(erpDetTb, "ERP_DETTB", "接收ERP下发订单接收成功!!", true); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | if (Cools.isEmpty(erpDetTb.getTemp2())){ | 
|---|
|  |  |  | erpSqlServer.update(sqlUpDateErpDetTbTwo + ",temp2='更新订单明细档失败!!!'" + "where 1=1 " | 
|---|
|  |  |  | +" and PRD_NO=" + "'" + erpDetTb.getPrdNo() + "'" | 
|---|
|  |  |  | +" and ITM=" + "'" + erpDetTb.getItm() + "'" | 
|---|
|  |  |  | +" and BIL_NO=" + "'" + erpDetTb.getBillNo() + "'"); | 
|---|
|  |  |  | callApiLogSave(erpDetTb, "ERP_DETTB", "ERP下发订单接收失败!!", false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | if (Cools.isEmpty(erpDetTb.getTemp3())){ | 
|---|
|  |  |  | erpSqlServer.update(sqlUpDateErpDetTbTwo + ",temp3='更新订单明细档失败!!!订单明细已存在!!'" + "where 1=1 " | 
|---|
|  |  |  | +" and PRD_NO=" + "'" + erpDetTb.getPrdNo() + "'" | 
|---|
|  |  |  | +" and ITM=" + "'" + erpDetTb.getItm() + "'" | 
|---|
|  |  |  | +" and BIL_NO=" + "'" + erpDetTb.getBillNo() + "'"); | 
|---|
|  |  |  | callApiLogSave(erpDetTb, "ERP_DETTB", "ERP下发订单接收失败!!", false); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|