From 893fe161e39d8f912fe2f2b0d3cb89b16c9fc420 Mon Sep 17 00:00:00 2001 From: pjb <123456> Date: 星期三, 25 九月 2024 14:21:26 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/PlaController.java | 112 ++++++++++++++++++++++++++++--------------------------- 1 files changed, 57 insertions(+), 55 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/PlaController.java b/src/main/java/com/zy/asrs/controller/PlaController.java index dc23bfc..5688b5d 100644 --- a/src/main/java/com/zy/asrs/controller/PlaController.java +++ b/src/main/java/com/zy/asrs/controller/PlaController.java @@ -11,6 +11,7 @@ import com.core.common.R; import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; +import com.microsoft.sqlserver.jdbc.SQLServerException; import com.zy.asrs.entity.*; import com.zy.asrs.entity.param.GlobleParameter; import com.zy.asrs.entity.result.KeyValueVo; @@ -57,15 +58,15 @@ @RequestMapping(value = "/pla/list/auth") @ManagerAuth - public R list(@RequestParam(defaultValue = "1")Integer curr, - @RequestParam(defaultValue = "10")Integer limit, - @RequestParam(required = false)String condition, - @RequestParam Map<String, Object> param){ + public R list(@RequestParam(defaultValue = "1") Integer curr, + @RequestParam(defaultValue = "10") Integer limit, + @RequestParam(required = false) String condition, + @RequestParam Map<String, Object> param) { excludeTrash(param); EntityWrapper<Pla> wrapper = new EntityWrapper<>(); - if(!Cools.isEmpty(param.get("brand"))){ - wrapper.eq("brand",param.get("brand")); + if (!Cools.isEmpty(param.get("brand"))) { + wrapper.eq("brand", param.get("brand")); param.remove("brand"); } // 娌℃湁閫夋嫨鐨勬椂鍊欓粯璁や笉鏄剧ず宸插嚭搴撶殑鐗╂枡 @@ -73,14 +74,14 @@ wrapper.ne("status", "鍏ㄩ儴鍑哄簱"); } - if (!Cools.isEmpty(param.get("batch")) && param.get("batch").toString().contains(",")){ + if (!Cools.isEmpty(param.get("batch")) && param.get("batch").toString().contains(",")) { String[] batchs = param.get("batch").toString().split(","); - wrapper.in("batch",batchs); + wrapper.in("batch", batchs); param.remove("batch"); } convert(param, wrapper); - wrapper.orderBy("batch",true).orderBy("package_no" ,true); + wrapper.orderBy("batch", true).orderBy("package_no", true); allLike(Pla.class, param.keySet(), wrapper, condition); return R.ok(plaService.selectPage(new Page<>(curr, limit), wrapper)); } @@ -105,7 +106,7 @@ plaService.updateById(pla); PlaLog plaLog = new PlaLog(); - BeanUtils.copyProperties(plaSave,plaLog); + BeanUtils.copyProperties(plaSave, plaLog); plaLog.setId(null); plaLog.setCreateTime(new Date()); plaLog.setModifyUser(getUser().getUsername()); @@ -120,7 +121,7 @@ public R delete(@RequestBody List<Pla> plas) { System.out.println(plas.toString()); plas.forEach(pla -> { - if(!pla.getStatus().equals(GlobleParameter.PLA_STATUS_00) && !pla.getStatus().equals(GlobleParameter.PLA_STATUS_0) && !pla.getStatus().equals(GlobleParameter.PLA_STATUS_1)){ + if (!pla.getStatus().equals(GlobleParameter.PLA_STATUS_00) && !pla.getStatus().equals(GlobleParameter.PLA_STATUS_0) && !pla.getStatus().equals(GlobleParameter.PLA_STATUS_1)) { throw new CoolException("宸插叆搴撶殑鏁版嵁鏃犳硶琚垹闄�"); } Pla plaSave = plaService.selectById(pla.getId()); @@ -128,7 +129,7 @@ plaService.deleteById(pla.getId()); PlaLog plaLog = new PlaLog(); - BeanUtils.copyProperties(plaSave,plaLog); + BeanUtils.copyProperties(plaSave, plaLog); plaLog.setId(null); plaLog.setCreateTime(new Date()); plaLog.setModifyUser(getUser().getUsername()); @@ -156,20 +157,20 @@ Order order = orderService.selectByNo(orderNo); OrderDetl orderDetl = orderDetlService.selectByOrderNoAndMaktx(orderNo, maktx); - for (Pla pla : plas){ + for (Pla pla : plas) { - if(pla.getStockFreeze() == 0){ + if (pla.getStockFreeze() == 0) { // throw new CoolException("搴撳瓨宸茶鍐荤粨锛岃閲嶆柊閫夋嫨搴撳瓨"); System.out.println(pla.getStockFreezeBy() + "," + getUser().getUsername()); - if(!Cools.eq(pla.getStockFreezeBy(),getUser().getUsername())){ + if (!Cools.eq(pla.getStockFreezeBy(), getUser().getUsername())) { throw new CoolException("璇ュ簱瀛樺凡琚叾浠栫敤鎴峰喕缁擄紝璇烽噸鏂伴�夋嫨"); } } allOrderWeight += pla.getOrderWeight(); - if(pla.getWeightAnfme() - pla.getQtyAnfme() - pla.getOrderWeight() < 0){ - throw new CoolException("鎵瑰彿:" + pla.getBatch() +"锛屽寘鍙�:" + pla.getPackageNo() +" 鍓╀綑鍙嚭搴撻噸閲忎笉瓒筹紝璇疯皟鏁村嚭搴撻噸閲�"); + if (pla.getWeightAnfme() - pla.getQtyAnfme() - pla.getOrderWeight() < 0) { + throw new CoolException("鎵瑰彿:" + pla.getBatch() + "锛屽寘鍙�:" + pla.getPackageNo() + " 鍓╀綑鍙嚭搴撻噸閲忎笉瓒筹紝璇疯皟鏁村嚭搴撻噸閲�"); } pla.setQtyAnfme(pla.getQtyAnfme() + pla.getOrderWeight()); pla.setHandlerBy(getUser().getUsername()); @@ -178,7 +179,7 @@ pla.setPakoutTime(pla.getPakoutTime().split("\\(")[0]); //鐢熸垚姝ゆ浣滀笟淇℃伅 PlaQty plaQty = new PlaQty(); - BeanUtils.copyProperties(pla,plaQty); + BeanUtils.copyProperties(pla, plaQty); plaQty.setCreateTime(new Date()); plaQty.setId(null); plaQty.setTransfer(order.getDocType$()); @@ -186,16 +187,17 @@ plaService.updateById(pla); plaQtyService.insert(plaQty); //鐢熸垚鎷h揣鍗� - addPakOUT(plaQty,getUserId()); + addPakOUT(plaQty, getUserId()); - }; + } + ; //淇敼鍗曟嵁淇℃伅 - if(orderDetl.getAnfme()-orderDetl.getWorkQty()-allOrderWeight < 0){ + if (orderDetl.getAnfme() - orderDetl.getWorkQty() - allOrderWeight < 0) { throw new CoolException("璇ヨ鍗曞嚭搴撴暟閲忓ぇ浜庤鍗曞緟鍑烘暟閲忥紝璇烽噸鏂伴�夋嫨鍑哄簱鏁伴噺"); } - if(order.getStatus() < 2){ - orderService.updateSettle(order.getId(),2L,getUserId()); + if (order.getStatus() < 2) { + orderService.updateSettle(order.getId(), 2L, getUserId()); } orderDetl.setWorkQty(orderDetl.getWorkQty() + allOrderWeight); @@ -208,14 +210,14 @@ @RequestMapping(value = "/pla/returned/auth") @ManagerAuth public R returned(@RequestBody List<PlaQty> plaQties) { - plaService.returned(plaQties,getUser()); + plaService.returned(plaQties, getUser()); return R.ok(); } @RequestMapping(value = "/pla/viladate/auth") @ManagerAuth public R viladate(@RequestBody List<Pla> plas) { - plaService.viladate(plas,getUser()); + plaService.viladate(plas, getUser()); return R.ok(); } @@ -228,8 +230,8 @@ pla.setModifyTime(new Date()); pla.setWeightAnfme(0.0); plaService.updateById(pla); - SaasUtils.insertLog(1,pla.getLocNo(),pla.getBrand(),anfme,getUser().getUsername(), - null,pla.getBatch(),pla.getPackageNo(),pla.getOwner(),pla.getWorkshop(),null); + SaasUtils.insertLog(1, pla.getLocNo(), pla.getBrand(), anfme, getUser().getUsername(), + null, pla.getBatch(), pla.getPackageNo(), pla.getOwner(), pla.getWorkshop(), null); }); return R.ok(); @@ -238,12 +240,12 @@ @RequestMapping(value = "/pla/updateStockFreeze") @Transactional @ManagerAuth(memo = "搴撲綅鍐荤粨") - public R updateStockFreeze(@RequestBody List<Pla> plas){ - if (Cools.isEmpty(plas)){ + public R updateStockFreeze(@RequestBody List<Pla> plas) { + if (Cools.isEmpty(plas)) { return R.error("鏃犳暟鎹�"); } - for (Pla pla : plas){ - if (pla.getStockFreeze() == 0){ + for (Pla pla : plas) { + if (pla.getStockFreeze() == 0) { continue; // throw new CoolException("搴撳瓨宸茶鍐荤粨锛�"); } @@ -258,16 +260,16 @@ @RequestMapping(value = "/pla/updateStockDisFreeze") @ManagerAuth(memo = "搴撲綅瑙e喕") - public R updateStockDisFreeze(@RequestBody List<Pla> plas){ - if (Cools.isEmpty(plas)){ + public R updateStockDisFreeze(@RequestBody List<Pla> plas) { + if (Cools.isEmpty(plas)) { return R.error("鏃犳暟鎹�"); } - for (Pla pla : plas){ - if (pla.getStockFreeze() == 1){ + for (Pla pla : plas) { + if (pla.getStockFreeze() == 1) { continue; // throw new CoolException("搴撲綅鏈喕缁擄紝鏃犻渶瑙e喕"); } - if(!Cools.eq(pla.getStockFreezeBy(),getUser().getUsername())){ + if (!Cools.eq(pla.getStockFreezeBy(), getUser().getUsername())) { throw new CoolException("鏃犳硶瑙e喕鍏朵粬鐢ㄦ埛鍐荤粨鐨勫簱浣�"); } pla.setStockFreeze(1); @@ -287,7 +289,7 @@ wrapper.like("maktx", condition); Page<Mat> page = matService.selectPage(new Page<>(0, 10), wrapper); List<Map<String, Object>> result = new ArrayList<>(); - for (Mat mat : page.getRecords()){ + for (Mat mat : page.getRecords()) { Map<String, Object> map = new HashMap<>(); map.put("id", mat.getMaktx()); map.put("value", mat.getMaktx()); @@ -298,8 +300,8 @@ @RequestMapping(value = "/pla/statis/auth") @ManagerAuth - public R statis(@RequestParam(defaultValue = "1")Integer curr, - @RequestParam(defaultValue = "10")Integer limit, + public R statis(@RequestParam(defaultValue = "1") Integer curr, + @RequestParam(defaultValue = "10") Integer limit, @RequestParam Map<String, Object> param) { Page<Pla> stockStatis = plaService.getStockStatisAll(toPage(curr, limit, param, Pla.class)); @@ -331,24 +333,24 @@ PlaExcelListener listener = new PlaExcelListener(getUserId()); try { EasyExcel.read(file.getInputStream(), PlaExcel.class, listener).sheet().doRead(); - }catch (Exception e){ + } catch (Exception e) { e.printStackTrace(); int index = listener.getIndex() - 1; throw new CoolException("瀵煎叆鐨勬暟鎹牸寮忛敊璇紝鍘熷洜锛�" + e.getMessage() + "锛岀" + index + "锛屾暟鎹牸寮忎笉瀵�"); } log.info("瀵煎叆淇敼淇℃伅杈撳嚭锛�" + listener.getRecordLog()); - return R.ok("鎴愬姛鍚屾"+listener.getTotal()+"鏉la鐗╂枡鏁版嵁"); + return R.ok("鎴愬姛鍚屾" + listener.getTotal() + "鏉la鐗╂枡鏁版嵁"); } // 鎵撳嵃 @RequestMapping(value = "/pla/print/auth") @ManagerAuth(memo = "pla缂栫爜鎵撳嵃") public R matCodePrint(@RequestBody List<Pla> plas) { - if(Cools.isEmpty(plas)) { + if (Cools.isEmpty(plas)) { return R.parse(CodeRes.EMPTY); } List<Pla> res = new ArrayList<>(); - for (Pla pla : plas){ + for (Pla pla : plas) { res.add(pla); } return R.ok().add(res); @@ -363,7 +365,7 @@ Wrapper<Pla> wrapper = new EntityWrapper<Pla>().setSqlSelect("batch") .andNew().like("batch", condition) .groupBy("batch") - .orderBy("batch",false); + .orderBy("batch", false); List<Pla> plas = plaService.selectPage(new Page<Pla>(1, 30), wrapper).getRecords(); List<KeyValueVo> valueVos = new ArrayList<>(); for (Pla pla : plas) { @@ -375,17 +377,17 @@ return R.ok().add(valueVos); } - private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper){ - for (Map.Entry<String, Object> entry : map.entrySet()){ + private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper) { + for (Map.Entry<String, Object> entry : map.entrySet()) { String val = String.valueOf(entry.getValue()); - if (val.contains(RANGE_TIME_LINK)){ + if (val.contains(RANGE_TIME_LINK)) { String[] dates = val.split(RANGE_TIME_LINK); wrapper.ge(entry.getKey(), DateUtils.convert(dates[0])); wrapper.le(entry.getKey(), DateUtils.convert(dates[1])); - }else if (entry.getKey().contains("Min")){ - wrapper.ge(entry.getKey().substring(0,entry.getKey().length()-3),val); - }else if (entry.getKey().contains("Max")){ - wrapper.le(entry.getKey().substring(0,entry.getKey().length()-3),val); + } else if (entry.getKey().contains("Min")) { + wrapper.ge(entry.getKey().substring(0, entry.getKey().length() - 3), val); + } else if (entry.getKey().contains("Max")) { + wrapper.le(entry.getKey().substring(0, entry.getKey().length() - 3), val); } else { wrapper.like(entry.getKey(), val); } @@ -393,10 +395,10 @@ } @Synchronized - private R addPakOUT(PlaQty plaQty,Long userId){ - ManPakOut manPakOut=new ManPakOut(); - manPakOut.setWrkNo(plaQty.getOrderNo()+"-"+String.valueOf(snowflakeIdWorker.nextId())); - manPakOut.setWrkSts((long)1); + private R addPakOUT(PlaQty plaQty, Long userId) { + ManPakOut manPakOut = new ManPakOut(); + manPakOut.setWrkNo(plaQty.getOrderNo() + "-" + String.valueOf(snowflakeIdWorker.nextId())); + manPakOut.setWrkSts((long) 1); manPakOut.setAnfme(plaQty.getOrderWeight()); manPakOut.setMaktx(plaQty.getBrand()); manPakOut.setLocNo(plaQty.getLocNo()); -- Gitblit v1.9.1