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