From 78a59eda850857e1bfeb48541f0c64d442877a4d Mon Sep 17 00:00:00 2001 From: lty <876263681@qq.com> Date: 星期二, 08 四月 2025 11:17:10 +0800 Subject: [PATCH] #实现pda简单入库出库操作 --- src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java | 411 +++++++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 360 insertions(+), 51 deletions(-) diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java index c644d71..a5fcd61 100644 --- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java @@ -1,40 +1,73 @@ package com.zy.asrs.service.impl; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.BaseRes; import com.core.common.Cools; +import com.core.common.DateUtils; +import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; -import com.zy.asrs.entity.MatCode; -import com.zy.asrs.entity.Order; -import com.zy.asrs.entity.OrderDetl; -import com.zy.asrs.entity.WaitPakin; +import com.zy.asrs.entity.*; import com.zy.asrs.entity.param.CombParam; +import com.zy.asrs.entity.param.MobileAdjustParam; +import com.zy.asrs.entity.param.OpenOrderPakinParam; import com.zy.asrs.service.*; -import com.zy.asrs.utils.VersionUtils; +import com.zy.asrs.task.core.ReturnT; +import com.zy.asrs.task.handler.WorkLogHandler; +import com.zy.asrs.utils.MatUtils; +import com.zy.common.constant.MesConstant; +import com.zy.common.entity.Parameter; import com.zy.common.model.DetlDto; +import com.zy.common.model.MesCombParam; +import com.zy.common.service.CommonService; +import com.zy.common.utils.HttpHandler; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.Date; +import java.util.Iterator; import java.util.List; /** * 绉诲姩绔湇鍔℃牳蹇冪被 * Created by vincent on 2020/6/28 */ +@Slf4j @Service public class MobileServiceImpl implements MobileService { @Autowired - private MatCodeService matCodeService; + private MatService matService; @Autowired private WaitPakinService waitPakinService; @Autowired private OrderService orderService; @Autowired private OrderDetlService orderDetlService; + @Autowired + private BasDevpService basDevpService; + @Autowired + private WrkMastService wrkMastService; + @Autowired + private WrkDetlService wrkDetlService; + @Autowired + private PackService packService; + @Autowired + private OpenService openService; + @Autowired + private SnowflakeIdWorker snowflakeIdWorker; + @Autowired + private ApiLogService apiLogService; + @Autowired + private WorkLogHandler workLogHandler; + @Autowired + private CommonService commonService; + @Autowired + private LocMastService locMastService; @Override @Transactional @@ -45,45 +78,23 @@ // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁 if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>(). eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) { - throw new CoolException("鏉$爜鏁版嵁宸插瓨鍦�"); + throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱"); } + + // todo: 涓嶄笅绾块噸鏂板叆搴� + WrkMast wrkMast18 = wrkMastService.selectByBarcode(param.getBarcode()); + if (wrkMast18 != null && wrkMast18.getWrkSts() == 18) { + ReturnT<String> start = workLogHandler.start(wrkMast18); + if (!start.isSuccess()) { + log.error("宸ヤ綔妗workNo={}]鍘嗗彶妗e鐞嗗け璐�", wrkMast18.getWrkNo()); + } + } + Date now = new Date(); // 鏃犲崟缁勬墭 if (Cools.isEmpty(param.getOrderNo())) { - // 鐢熸垚鍏ュ簱閫氱煡妗� - List<DetlDto> detlDtos = new ArrayList<>(); - param.getCombMats().forEach(elem -> { - DetlDto detlDto = new DetlDto(elem.getMatNo(), elem.getBatch(), elem.getCount()); - if (DetlDto.has(detlDtos, detlDto)) { - DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch()); - assert one != null; - one.setAnfme(one.getAnfme() + detlDto.getAnfme()); - } else { - detlDtos.add(detlDto); - } - }); - - for (DetlDto detlDto : detlDtos) { - MatCode matCode = matCodeService.selectById(detlDto.getMatnr()); - if (Cools.isEmpty(matCode)) { - throw new CoolException("鐗╂枡鏁版嵁閿欒"); - } - WaitPakin waitPakin = new WaitPakin(); - waitPakin.setZpallet(param.getBarcode()); // 鎵樼洏鐮� - waitPakin.setIoStatus("N"); // 鍏ュ嚭鐘舵�� - waitPakin.setAnfme(detlDto.getAnfme()); // 鏁伴噺 - waitPakin.setStatus("Y"); // 鐘舵�� - waitPakin.setAppeUser(userId); - waitPakin.setAppeTime(now); - waitPakin.setModiUser(userId); - waitPakin.setModiTime(now); - VersionUtils.setWaitPakIn(waitPakin, matCode); - if (!waitPakinService.insert(waitPakin)) { - throw new CoolException("淇濆瓨鏁版嵁澶辫触"); - } - } // 鍏宠仈缁勬墭 } else { Order order = orderService.selectByNo(param.getOrderNo()); @@ -95,16 +106,16 @@ param.getCombMats().forEach(elem -> { // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙 - OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), elem.getMatNo(), elem.getBatch()); - if (elem.getCount() > orderDetl.getEnableQty()) { + OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), elem.getMatnr(), elem.getBatch()); + if (elem.getAnfme() > orderDetl.getEnableQty()) { throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�"); } // 淇敼璁㈠崟鏄庣粏鏁伴噺 - if (!orderDetlService.increase(order.getId(), elem.getMatNo(), elem.getBatch(), elem.getCount())) { + if (!orderDetlService.increase(order.getId(), elem.getMatnr(), elem.getBatch(), elem.getAnfme())) { throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触"); } - DetlDto detlDto = new DetlDto(elem.getMatNo(), elem.getBatch(), elem.getCount()); + DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme()); if (DetlDto.has(detlDtos, detlDto)) { DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch()); assert one != null; @@ -113,14 +124,306 @@ detlDtos.add(detlDto); } }); + + orderService.updateSettle(order.getId(), 2L, userId); + } + + LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O")); + if (Cools.isEmpty(locMast1)) { + throw new CoolException("鏈壘鍒版纭殑搴撲綅淇℃伅"); + } + + int workNo = commonService.getWorkNo(0); + + // 鐢熸垚宸ヤ綔妗� + WrkMast wrkMast = new WrkMast(); + wrkMast.setWrkNo(workNo); + wrkMast.setIoTime(new Date()); + wrkMast.setWrkSts(9L); // 宸ヤ綔鐘舵�侊細鐢熸垚鍏ュ簱ID + wrkMast.setIoType(1); // 鍏ュ嚭搴撶姸鎬侊細1.鍏ュ簱 + Double ioPri = wrkMastService.getIoPri(1, locMast1.getLocNo()); + wrkMast.setIoPri(ioPri); // 浼樺厛绾� + wrkMast.setCrnNo(locMast1.getCrnNo()); + wrkMast.setOutMost(locMastService.isOutMost(locMast1.getLocNo(), true)?1:0);; + wrkMast.setSourceStaNo(null); + wrkMast.setStaNo(null); + wrkMast.setLocNo(locMast1.getLocNo()); + wrkMast.setBarcode(param.getBarcode()); // 鎵樼洏鐮� + wrkMast.setFullPlt("Y"); // 婊℃澘锛歒 + wrkMast.setPicking("N"); // 鎷f枡 + wrkMast.setExitMk("N"); // 閫�鍑� + wrkMast.setEmptyMk("N"); // 绌烘澘 + wrkMast.setLinkMis("Y"); + wrkMast.setCtnType(null); // 瀹瑰櫒绫诲瀷 + // 鎿嶄綔浜哄憳鏁版嵁 + wrkMast.setAppeTime(now); + wrkMast.setModiTime(now); + boolean res = wrkMastService.insert(wrkMast); + if (!res) { + throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐�"); + } + + + for (CombParam.CombMat paramMat : param.getCombMats() ) + { + Mat mat = matService.selectByMatnr(paramMat.getMatnr()); + if (Cools.isEmpty(mat)) { + throw new CoolException(paramMat.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�"); + } + + // 鐢熸垚宸ヤ綔妗f槑缁� + WrkDetl wrkDetl = new WrkDetl(); + wrkDetl.sync(mat); + wrkDetl.setAnfme(paramMat.getAnfme()); + wrkDetl.setZpallet(param.getBarcode()); +// wrkDetl.setAnfme(1.0D); + wrkDetl.setWrkNo(wrkMast.getWrkNo()); + wrkDetl.setIoTime(wrkMast.getIoTime()); + wrkDetl.setAppeTime(now); + wrkDetl.setModiTime(now); + if (!wrkDetlService.insert(wrkDetl)) { + throw new CoolException("淇濆瓨宸ヤ綔鏄庣粏澶辫触"); + } + } + +// // 鏇存柊鍏ュ簱閫氱煡妗� ioStatus ===>> Y +// Wrapper<WaitPakin> wrapper = new EntityWrapper<WaitPakin>() +// .eq("zpallet", barcode); +// WaitPakin setParam = new WaitPakin(); +// setParam.setIoStatus("Y"); +// setParam.setModiTime(now); +// if (!waitPakinService.update(setParam, wrapper)) { +// throw new CoolException("鏇存柊閫氱煡妗eけ璐�"); +// } + + + // 鏇存柊鐩爣搴撲綅鐘舵�� + + if (locMast1.getLocSts().equals("O")){ + locMast1.setLocSts("S"); // S.鍏ュ簱棰勭害 + locMast1.setModiTime(now); + if (!locMastService.updateById(locMast1)){ + throw new CoolException("鏀瑰彉搴撲綅鐘舵�佸け璐�"); + } + } else { + throw new CoolException(locMast1.getLocNo()+"鐩爣搴撲綅宸茶鍗犵敤"); + } + + + + } + + @Override + @Transactional + public void adjust(MobileAdjustParam param, Long userId) { + BasDevp basDevp = basDevpService.selectById(param.getStaNo()); + if (null == basDevp || basDevp.getWrkNo() == null) { + throw new CoolException(param.getStaNo() + "鐩樼偣绔欐棤鏁�"); + } + if (!param.getWrkNo().equals(basDevp.getWrkNo())) { + throw new CoolException(param.getStaNo() + "鐩樼偣绔欐洿鏂帮紝璇烽噸鏂版绱�"); + } + WrkMast wrkMast = wrkMastService.selectById(param.getWrkNo()); + if (wrkMast.getWrkSts() < 10) { + throw new CoolException("鐩樼偣鏃犳晥锛屼换鍔″凡鐩樼偣鍐嶅叆搴�"); + } + Date now = new Date(); + List<WrkDetl> wrkDetls = wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()); + + List<WrkDetl> list = param.getWrkDetls(); + + // 淇敼鏁伴噺 + Iterator<WrkDetl> iterator = wrkDetls.iterator(); + while (iterator.hasNext()) { + WrkDetl wrkDetl = iterator.next(); + Iterator<WrkDetl> iterator1 = list.iterator(); + while (iterator1.hasNext()) { + WrkDetl wrkDetl1 = iterator1.next(); + if (wrkDetl1.getAnfme() == 0) { + iterator1.remove(); + } + if (wrkDetl.getMatnr().equals(wrkDetl1.getMatnr()) && Cools.eq(wrkDetl.getBatch(), wrkDetl1.getBatch())) { + if (!wrkDetl.getAnfme().equals(wrkDetl1.getAnfme())) { + // todo 鐩樼偣璁板綍銆佷繚瀛樿皟鏁磋褰� + // 淇敼鏄庣粏 + if (!wrkDetlService.updateAnfme(wrkDetl1.getAnfme(), wrkMast.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) { + throw new CoolException(wrkMast.getWrkNo() + "鐩樼偣浠诲姟锛�" + wrkDetl.getMatnr() + "鍟嗗搧锛�" + wrkDetl.getBatch() + "搴忓垪鐮佷慨鏀规暟閲忓け璐�"); + } + } + iterator.remove(); + iterator1.remove(); + } + } + } + + // 鍒犻櫎鏄庣粏 + for (WrkDetl wrkDetl : wrkDetls) { + // todo 鐩樼偣璁板綍銆佷繚瀛樿皟鏁磋褰� + if (!wrkDetlService.updateAnfme(-1.0D, wrkMast.getWrkNo(), wrkDetl.getMatnr(), wrkDetl.getBatch())) { + throw new CoolException("鍒犻櫎" + wrkMast.getWrkNo() + "鐩樼偣浠诲姟锛�" + wrkDetl.getMatnr() + "鍟嗗搧锛�" + wrkDetl.getBatch() + "搴忓垪鐮佷换鍔℃槑缁嗗け璐�"); + } + } + + // 娣诲姞鏄庣粏 + for (WrkDetl wrkDetl : list) { + if (wrkDetl.getAnfme() == 0.0D) { continue; } + // todo 鐩樼偣璁板綍銆佷繚瀛樿皟鏁磋褰� + String orderNo = wrkDetl.getOrderNo(); + Mat mat = matService.selectByMatnr(wrkDetl.getMatnr()); + wrkDetl.sync(mat); + wrkDetl.setOrderNo(orderNo); + wrkDetl.setModiTime(now); + wrkDetl.setModiUser(userId); + wrkDetl.setAppeTime(now); + wrkDetl.setAppeUser(userId); + if (!wrkDetlService.insert(wrkDetl)) { + throw new CoolException("娣诲姞" + wrkMast.getWrkNo() + "鐩樼偣浠诲姟锛�" + wrkDetl.getMatnr() + "鍟嗗搧锛�" + wrkDetl.getBatch() + "搴忓垪鐮佷换鍔℃槑缁嗗け璐�"); + } + } + + // 淇敼鐩樼偣浠诲姟涓绘。鐘舵�� + wrkMast.setFullPlt(wrkDetlService.selectByWrkNo(wrkMast.getWrkNo()).size() != 0?"Y":"N"); + wrkMast.setModiTime(now); + wrkMast.setModiUser(userId); + if (!wrkMastService.updateById(wrkMast)) { + throw new CoolException("淇敼鐩樼偣浠诲姟涓绘。澶辫触"); + } + + } + + @Override + @Transactional + public void packComb(CombParam param, Long userId) { + if (Cools.isEmpty(param.getBarcode(), param.getCombMats())) { + throw new CoolException(BaseRes.PARAM); + } + // 鍒ゆ柇鏄惁鏈夌浉鍚屾潯鐮佺殑鏁版嵁 + if (waitPakinService.selectCount(new EntityWrapper<WaitPakin>(). + eq("zpallet", param.getBarcode()).eq("io_status", "N")) > 0) { + throw new CoolException(param.getBarcode() + "鏁版嵁姝e湪杩涜鍏ュ簱"); + } + Date now = new Date(); + + boolean packDown = Parameter.get().getPackDown().equals("true"); + + // 鏃犲崟缁勬墭 + if (Cools.isEmpty(param.getOrderNo())) { + + // 鐢熸垚鍏ュ簱閫氱煡妗� + List<DetlDto> detlDtos = new ArrayList<>(); + param.getCombMats().forEach(elem -> { + // 鎵撳寘涓婄嚎鏁版嵁鏍¢獙 + if (packDown) { + Pack pack = packService.selectByBarcode(elem.getMatnr()); + if (pack == null) { + throw new CoolException(elem.getMatnr() + "鏉$爜鍐椾綑锛岃妫�鏌ワ紒"); + } + if (pack.getSettle() != 1) { + throw new CoolException(elem.getMatnr() + "鏉$爜宸蹭笅绾匡紝璇锋鏌ワ紒"); + } + } + Mat analyse = MatUtils.analyseMat(elem.getMatnr()); + // 鏉$爜銆佺墿鏂欎唬鐮併�佸簭鍒楀彿銆佹暟閲� + DetlDto detlDto = new DetlDto(elem.getMatnr(), analyse.getMatnr(), analyse.getBarcode(), elem.getAnfme()); +// DetlDto detlDto = new DetlDto(elem.getMatnr(), elem.getBatch(), elem.getAnfme()); + if (DetlDto.has(detlDtos, detlDto)) { + DetlDto one = DetlDto.find(detlDtos, detlDto.getMatnr(), detlDto.getBatch()); + assert one != null; + one.setAnfme(one.getAnfme() + detlDto.getAnfme()); + } else { + detlDtos.add(detlDto); + } + }); + + if (packDown) { + MesCombParam mesCombParam = new MesCombParam(); + mesCombParam.setZpallet(param.getBarcode()); + mesCombParam.setPakinTime(DateUtils.convert(now)); + mesCombParam.setLgort("5008"); + mesCombParam.setPlantCode("5000"); + mesCombParam.setFromCode("5012-20"); + mesCombParam.setStationCode("JJQ-PFZPDB-XX"); + for (DetlDto detlDto : detlDtos) { + mesCombParam.getList().add(new MesCombParam.Detl(detlDto.getOrderNo(), detlDto.getAnfme())); + } + String response = ""; + boolean success = false; + try { + response = new HttpHandler.Builder() + .setUri(MesConstant.URL) + .setPath(MesConstant.PACK_DOWN_URL) + .setJson(JSON.toJSONString(mesCombParam)) + .build() + .doPost(); + JSONObject jsonObject = JSON.parseObject(response); + if (jsonObject.getInteger("code").equals(200)) { + success = true; + } else if (jsonObject.getInteger("code").equals(500)) { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); + throw new CoolException(jsonObject.getString("msg")); + } else { + log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PACK_DOWN_URL, JSON.toJSONString(mesCombParam), response); + throw new CoolException("涓婃姤mes绯荤粺澶辫触"); + } + } catch (Exception e) { + log.error("fail", e); + throw new CoolException(e.getMessage()); + } finally { + try { + // 淇濆瓨鎺ュ彛鏃ュ織 + apiLogService.save( + "鎵撳寘涓嬬嚎甯墭涓婃姤", + MesConstant.URL + MesConstant.PACK_DOWN_URL, + null, + "127.0.0.1", + JSON.toJSONString(mesCombParam), + response, + success + ); + } catch (Exception e) { log.error("", e); } + } + + } + + // 鐢熸垚鍏ュ簱鍗曟嵁 + String orderNo = "PACK" + snowflakeIdWorker.nextId(); + OpenOrderPakinParam openParam = new OpenOrderPakinParam(); + openParam.setOrderNo(orderNo); + openParam.setOrderTime(DateUtils.convert(now)); + openParam.setOrderType("鎵撳寘鍏ュ簱鍗�"); + openParam.setOrderDetails(detlDtos); + openService.pakinOrderCreate(openParam); + Order order = orderService.selectByNo(orderNo); + if (null == order) { + throw new CoolException("鐢熸垚鍗曟嵁澶辫触"); + } + if (!orderService.updateSettle(order.getId(), 2L, userId)) { + throw new CoolException("淇敼鍗曟嵁鐘舵�佸け璐�"); + } + + // 鐢熸垚鍏ュ簱閫氱煡妗� for (DetlDto detlDto : detlDtos) { - MatCode matCode = matCodeService.selectById(detlDto.getMatnr()); - if (Cools.isEmpty(matCode)) { - throw new CoolException("鐗╂枡鏁版嵁閿欒"); + + // 淇敼浣滀笟鏁伴噺 ---------------------------------------- + // 璁㈠崟鏄庣粏鏁伴噺鏍¢獙 + OrderDetl orderDetl = orderDetlService.selectItem(order.getId(), detlDto.getMatnr(), detlDto.getBatch()); + if (detlDto.getAnfme() > orderDetl.getEnableQty()) { + throw new CoolException(orderDetl.getMatnr() + "鍏ュ簱鏁伴噺涓嶅悎娉�"); + } + // 淇敼璁㈠崟鏄庣粏鏁伴噺 + if (!orderDetlService.increase(order.getId(), detlDto.getMatnr(), detlDto.getBatch(), detlDto.getAnfme())) { + throw new CoolException("淇敼鍗曟嵁鏄庣粏鏁伴噺澶辫触"); + } + + // 淇濆瓨鍏ュ簱閫氱煡妗� + Mat mat = matService.selectByMatnr(detlDto.getMatnr()); + if (Cools.isEmpty(mat)) { + throw new CoolException(detlDto.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�"); } WaitPakin waitPakin = new WaitPakin(); - waitPakin.setOrderNo(order.getOrderNo()); // 鍗曟嵁缂栧彿 - waitPakin.setBatch(detlDto.getBatch()); // 鎵瑰彿 + waitPakin.sync(mat); + waitPakin.setOrderNo(orderNo); + waitPakin.setBatch(detlDto.getBatch()); waitPakin.setZpallet(param.getBarcode()); // 鎵樼洏鐮� waitPakin.setIoStatus("N"); // 鍏ュ嚭鐘舵�� waitPakin.setAnfme(detlDto.getAnfme()); // 鏁伴噺 @@ -129,14 +432,20 @@ waitPakin.setAppeTime(now); waitPakin.setModiUser(userId); waitPakin.setModiTime(now); - VersionUtils.setWaitPakIn(waitPakin, matCode); if (!waitPakinService.insert(waitPakin)) { - throw new CoolException("淇濆瓨鏁版嵁澶辫触"); + throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�"); + } + // 淇敼鎵撳寘鏁版嵁鐘舵�� + Pack pack = packService.selectByBarcode(detlDto.getOrderNo()); + pack.setSettle(2L); + pack.setUpdateTime(now); + pack.setUpdateBy(userId); + if (!packService.updateById(pack)) { + throw new CoolException("淇敼鎵撳寘鏁版嵁寮傚父"); } } } - } } -- Gitblit v1.9.1