| | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.baomidou.mybatisplus.mapper.EntityWrapper; |
|---|
| | | import com.core.common.Cools; |
|---|
| | | import com.core.common.R; |
|---|
| | | import com.core.exception.CoolException; |
|---|
| | | import com.zy.api.controller.params.ReceviceTaskParams; |
|---|
| | |
|---|
| | | if (params.getNotifyType().equals("task")) { |
|---|
| | | //任务 |
|---|
| | | if (params.getMsgType().equals("task_complete")) { |
|---|
| | | mast.setWrkSts(4L); |
|---|
| | | if (!Objects.isNull(mast.getWrkCode())) { |
|---|
| | | if (mast.getOveMk().equals("N") && !Cools.isEmpty(mast.getIsSuplus())) { |
|---|
| | | throw new CoolException("任务未上报重量，无法完结任务！！"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (mast.getIoType() == 1) { |
|---|
| | | mast.setWrkSts(4L); |
|---|
| | | } else if (mast.getIoType() == 101) { |
|---|
| | | mast.setWrkSts(14L); |
|---|
| | | } |
|---|
| | | if (!wrkMastService.updateById(mast)) { |
|---|
| | | throw new CoolException("任务状态修改失败！！"); |
|---|
| | | } |
|---|
| | | } else if (params.getMsgType().equals("task_cancel")) { |
|---|
| | | |
|---|
| | | //todo 取消任务 |
|---|
| | | } |
|---|
| | | } else if (params.getNotifyType().equals("weight")) { |
|---|
| | | //称重 |
|---|
| | | if (mast.getWrkSts() == 2) { |
|---|
| | | if (mast.getIoType() == 10) { |
|---|
| | | //空板入库任务档 |
|---|
| | | LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no", mast.getSourceLocNo())); |
|---|
| | | LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>() |
|---|
| | | .eq("barcode", mast.getBarcode()) |
|---|
| | | .eq("loc_no", mast.getSourceLocNo())); |
|---|
| | | if (Objects.isNull(locDetl)) { |
|---|
| | | throw new CoolException("明细数据不存在！！"); |
|---|
| | | } |
|---|
| | |
|---|
| | | WrkDetl wrkDetl = new WrkDetl(); |
|---|
| | | BeanUtils.copyProperties(locDetl, wrkDetl); |
|---|
| | | wrkDetl.setWrkNo(mast.getWrkNo()); |
|---|
| | | wrkDetl.setStockQty(locDetl.getAnfme()); |
|---|
| | | wrkDetl.setIoTime(new Date()); |
|---|
| | | wrkDetl.setWeight(params.getWeight()); |
|---|
| | | //余料长度 |
|---|
| | | wrkDetl.setRealQty(val * matnr.getVolume()); |
|---|
| | | wrkDetl.setAnfme(val * matnr.getVolume()); |
|---|
| | | mast.setIoType(1); |
|---|
| | | mast.setIsSuplus(1); |
|---|
| | | mast.setOveMk("Y"); |
|---|
| | | if (!wrkMastService.updateById(mast)) { |
|---|
| | | throw new CoolException("主档状态修改失败"); |
|---|
| | | throw new CoolException("任务档修改失败！！"); |
|---|
| | | } |
|---|
| | | if (!wrkDetlService.insert(wrkDetl)) { |
|---|
| | | throw new CoolException("明细保存失败！！"); |
|---|
| | | // 更新原出库单 |
|---|
| | | int indexOf = mast.getWrkCode().indexOf("-1"); |
|---|
| | | if (indexOf != -1) { |
|---|
| | | String wrkNo = mast.getWrkCode().substring(0, indexOf); |
|---|
| | | WrkMast orgWrk = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", wrkNo)); |
|---|
| | | if (Objects.isNull(orgWrk)) { |
|---|
| | | throw new CoolException("数据错误，主任务档不存在或已删除！！"); |
|---|
| | | } |
|---|
| | | orgWrk.setOveMk("Y"); |
|---|
| | | if (!wrkMastService.updateById(orgWrk)) { |
|---|
| | | throw new CoolException("任务档修改失败！！"); |
|---|
| | | } |
|---|
| | | //称重后，计算出真实长度 |
|---|
| | | Double realQty = val * matnr.getVolume(); |
|---|
| | | //库存减去称重长度 |
|---|
| | | Double v = Math.round((wrkDetl.getStockQty() - realQty) * 10000) / 10000.0; |
|---|
| | | //原出为数量与真实数量互换，保持一致性 |
|---|
| | | wrkDetl.setAnfme(v); |
|---|
| | | wrkDetl.setWeight(params.getWeight()); |
|---|
| | | if (!wrkDetlService.insert(wrkDetl)) { |
|---|
| | | throw new CoolException("明细保存失败！！"); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | throw new CoolException("任务号截取失败，请检查主任务档任档wrkCode字段"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | |
|---|
| | | throw new CoolException("物料基础信息不存在！！"); |
|---|
| | | } |
|---|
| | | Double val = Math.round((params.getWeight() - matnr.getSafeQty()) * 10000) / 10000.0; |
|---|
| | | //称重后，计算出真实长度 |
|---|
| | | Double realQty = val * matnr.getVolume(); |
|---|
| | | // if (val.compareTo(0.0) > 0) { |
|---|
| | | // //余料长度 |
|---|
| | | // wrkDetl.setRealQty(realQty); |
|---|
| | | // } else { |
|---|
| | | // //空板 |
|---|
| | | // wrkDetl.setRealQty(0.0); |
|---|
| | | // } |
|---|
| | | wrkDetl.setAnfme(realQty); |
|---|
| | | wrkDetl.setWeight(params.getWeight()); |
|---|
| | | if (!wrkDetlService.update(wrkDetl, new EntityWrapper<WrkDetl>().eq("wrk_no", mast.getWrkNo()).eq("matnr", wrkDetl.getMatnr()).eq("barcode", wrkDetl.getBarcode()))) { |
|---|
| | | throw new CoolException("任务档明细修改失败！！"); |
|---|
| | | } |
|---|
| | | mast.setOveMk("Y"); |
|---|
| | | if (!wrkMastService.updateById(mast)) { |
|---|
| | | throw new CoolException("任务档修改失败！！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 更新原出库单 |
|---|
| | | int indexOf = mast.getWrkCode().indexOf("-1"); |
|---|
| | | if (indexOf != -1) { |
|---|
| | |
|---|
| | | if (Objects.isNull(orgWrk)) { |
|---|
| | | throw new CoolException("数据错误，主任务档不存在或已删除！！"); |
|---|
| | | } |
|---|
| | | orgWrk.setOveMk("Y"); |
|---|
| | | if (!wrkMastService.updateById(orgWrk)) { |
|---|
| | | throw new CoolException("任务档修改失败！！"); |
|---|
| | | } |
|---|
| | | WrkDetl detl = wrkDetlService.selectOne(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkNo)); |
|---|
| | | if (Objects.isNull(detl)) { |
|---|
| | | throw new CoolException("子任务档明细不存在！！"); |
|---|
| | | } |
|---|
| | | //库存减去称重长度 |
|---|
| | | Double v = Math.round((wrkDetl.getStockQty() - realQty) * 10000) / 10000.0; |
|---|
| | | detl.setRealQty(v); |
|---|
| | | //原出为数量与真实数量互换，保持一致性 |
|---|
| | | detl.setAnfme(v); |
|---|
| | | detl.setWeight(params.getWeight()); |
|---|
| | | if (!wrkDetlService.update(detl, new EntityWrapper<WrkDetl>().eq("wrk_no", wrkNo).eq("matnr", detl.getMatnr()).eq("barcode", detl.getBarcode()))) { |
|---|
| | | throw new CoolException("原任务档明细修改失败！！"); |
|---|
