From 84759c579add1daea7b3dca92dcadf17c9318ec9 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期四, 12 十二月 2024 13:28:34 +0800
Subject: [PATCH] 库存上下限预警

---
 src/main/java/com/zy/asrs/controller/LocDetlController.java |  156 ++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 133 insertions(+), 23 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/LocDetlController.java b/src/main/java/com/zy/asrs/controller/LocDetlController.java
index a83bb8f..04d4bb5 100644
--- a/src/main/java/com/zy/asrs/controller/LocDetlController.java
+++ b/src/main/java/com/zy/asrs/controller/LocDetlController.java
@@ -14,6 +14,7 @@
 import com.core.common.R;
 import com.zy.asrs.entity.LocDetl;
 import com.zy.asrs.entity.Mat;
+import com.zy.asrs.entity.param.AbnormalLocDetlParam;
 import com.zy.asrs.mapper.LocDetlMapper;
 import com.zy.asrs.service.LocDetlService;
 import com.zy.asrs.service.MatService;
@@ -31,6 +32,7 @@
 
     @Autowired
     private LocDetlService locDetlService;
+
     @Autowired
     private LocDetlMapper locDetlMapper;
     @Autowired
@@ -42,6 +44,77 @@
             return R.error();
         }
         return R.ok();
+    }
+
+    @RequestMapping(value = "/locDetl/groupLocList/auth")
+    @ManagerAuth
+    public R groupLocList(@RequestParam(defaultValue = "1") Integer curr,
+                          @RequestParam(defaultValue = "10") Integer limit,
+                          @RequestParam(required = false) String orderByField,
+                          @RequestParam(required = false) String orderByType,
+                          @RequestParam(required = false) String condition,
+                          @RequestParam Map<String, Object> param) {
+
+//        List<LocDetl> result = new ArrayList<>();
+        List<AbnormalLocDetlParam> result = new ArrayList<>();
+//        excludeTrash(param);
+        param.put("curr", curr);
+        param.put("limit", limit);
+        Page<LocDetl> groupLocDetl = locDetlService.getStockStatis2(toPage(1, 10000, param, LocDetl.class));
+//        List<LocDetl> groupLocDetl = locDetlService.selectGroupPage(param, curr, limit);
+        for (LocDetl locDetl : groupLocDetl.getRecords()) {
+            AbnormalLocDetlParam abnormalLocDetlParam = new AbnormalLocDetlParam();
+            Mat mat = matService.selectOne(new EntityWrapper<Mat>()
+                    .eq("matnr", locDetl.getMatnr()));
+            if (Cools.isEmpty(mat)) {
+                continue;
+            }
+
+
+            if (!Cools.isEmpty(mat.getStoreMax()) || !Cools.isEmpty(mat.getStoreMin())) {
+                abnormalLocDetlParam.setStoreMax(mat.getStoreMax());
+                abnormalLocDetlParam.setStoreMaxDate(mat.getStoreMaxDate());
+                abnormalLocDetlParam.setStoreMin(mat.getStoreMin());
+                abnormalLocDetlParam.setAnfme(locDetl.getAnfme());
+                abnormalLocDetlParam.setMaktx(mat.getMaktx());
+                abnormalLocDetlParam.setMatnr(mat.getMatnr());
+                abnormalLocDetlParam.setSpecs(mat.getSpecs());
+                abnormalLocDetlParam.setBatch(locDetl.getBatch());
+
+//                SimpleDateFormat simple = new SimpleDateFormat("yyyyMMdd");
+//                Date maxDate = simple.parse(locDetl.getBatch());
+//                long time = maxDate.getTime();
+//                Date now = new Date();
+//                long time1 = now.getTime();
+//                abnormalLocDetlParam.setNowTime((int) ((time1 - time) / (1000 * 60 * 60 * 24)));
+
+                if (!Cools.isEmpty(mat.getStoreMax()) && locDetl.getAnfme() > mat.getStoreMax()) {
+                    result.add(abnormalLocDetlParam);
+                } else if (!Cools.isEmpty(mat.getStoreMin()) && locDetl.getAnfme() < mat.getStoreMin()) {
+                    result.add(abnormalLocDetlParam);
+                }
+            }
+        }
+
+        Page<AbnormalLocDetlParam> locDetlPage = new Page<>();
+        locDetlPage.setRecords(paging(result, curr, limit));
+        locDetlPage.setTotal(result.size());
+        locDetlPage.setCurrent(curr);
+        locDetlPage.setSize(limit);
+        return R.ok(locDetlPage);
+    }
+
+    private List<AbnormalLocDetlParam> paging(List<AbnormalLocDetlParam> result, Integer curr, Integer limit) {
+        List<AbnormalLocDetlParam> pageRecord = new ArrayList<AbnormalLocDetlParam>();
+        int minIndex = (curr - 1) * limit;
+        int maxIndex = (curr * limit) - 1;
+        if (result.size() < maxIndex) {
+            maxIndex = result.size();
+        }
+        for (int i = minIndex; i < maxIndex; i++) {
+            pageRecord.add(result.get(i));
+        }
+        return pageRecord;
     }
 
     @RequestMapping(value = "/locDetl/{id}/auth")
@@ -80,10 +153,14 @@
                 param.remove("modi_time");
             }
         }
-        return R.ok(locDetlService.getStockOut(toPage(curr, limit, param, LocDetl.class)));
+        Page<LocDetl> stockOut = locDetlService.getStockOut(toPage(curr, limit, param, LocDetl.class));
+        if (stockOut.getRecords().size()==0){
+            stockOut = locDetlService.getStockOut(toPage(1, limit, param, LocDetl.class));
+        }
+        return R.ok(stockOut);
     }
 
-    @RequestMapping(value = "/locDetl/list/auth")
+    @RequestMapping(value = "/locDetl/list/auth")// /locDetl/list/auth 鎺ュ彛闂
     @ManagerAuth
     public R list(@RequestParam(defaultValue = "1")Integer curr,
                   @RequestParam(defaultValue = "10")Integer limit,
@@ -91,30 +168,29 @@
                   @RequestParam(required = false)String orderByType,
                   @RequestParam(required = false)String condition,
                   @RequestParam Map<String, Object> param){
-
-        String row = "";
+//        String row = "";
         EntityWrapper<LocDetl> wrapper = new EntityWrapper<>();
-        if (param.get("row") != null) {
-            String chooseRow = (String) param.get("row");
-            if (chooseRow.length() == 1) {
-                row = "0" + chooseRow;
-                param.remove("row");
-            }else {
-                row = chooseRow;
-                param.remove("row");
-            }
-        }
+//        if (param.get("row") != null) {
+//            String chooseRow = (String) param.get("row");
+//            if (chooseRow.length() == 1) {
+//                row = "0" + chooseRow;
+//                param.remove("row");
+//            }else {
+//                row = chooseRow;
+//                param.remove("row");
+//            }
+//        }
         excludeTrash(param);
         convert(param, wrapper);
         allLike(LocDetl.class, param.keySet(), wrapper, condition);
         if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
-        if (!row.equals("")){
-            wrapper.and()
-                    .where("loc_no like '" +row +"%'");
-        }
-
+//        if (!row.equals("")){
+//            wrapper.and()
+//                    .where("loc_no like '" +row +"%'");
+//        }
         return R.ok(locDetlService.selectPage(new Page<>(curr, limit), wrapper));
     }
+
 
     private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper){
         for (Map.Entry<String, Object> entry : map.entrySet()){
@@ -181,18 +257,52 @@
             if (chooseRow.length() == 1) {
                 row = "0" + chooseRow;
                 map.remove("row");
-            }else {
+            } else {
                 row = chooseRow;
                 map.remove("row");
             }
         }
         convert(map, wrapper);
-        if (!row.equals("")){
+        if (!row.equals("")) {
             wrapper.and()
-                    .where("loc_no like '" +row +"%'");
+                    .where("loc_no like '" + row + "%'");
         }
         List<LocDetl> list = locDetlService.selectList(wrapper);
-        return R.ok(exportSupport(list, fields));
+        List<AbnormalLocDetlParam> result = new ArrayList<>();
+
+        Page<LocDetl> groupLocDetl = locDetlService.getStockStatis2(toPage(1, 10000, param, LocDetl.class));
+        for (LocDetl locDetl : groupLocDetl.getRecords()) {
+            AbnormalLocDetlParam abnormalLocDetlParam = new AbnormalLocDetlParam();
+            Mat mat = matService.selectOne(new EntityWrapper<Mat>()
+                    .eq("matnr", locDetl.getMatnr()));
+            if (Cools.isEmpty(mat)) {
+                continue;
+            }
+            if (!Cools.isEmpty(mat                                                                          .getStoreMax()) || !Cools.isEmpty(mat.getStoreMin())) {
+                abnormalLocDetlParam.setStoreMax(mat.getStoreMax());
+                abnormalLocDetlParam.setStoreMaxDate(mat.getStoreMaxDate());
+                abnormalLocDetlParam.setStoreMin(mat.getStoreMin());
+                abnormalLocDetlParam.setAnfme(locDetl.getAnfme());
+                abnormalLocDetlParam.setMaktx(mat.getMaktx());
+                abnormalLocDetlParam.setMatnr(mat.getMatnr());
+                abnormalLocDetlParam.setSpecs(mat.getSpecs());
+                abnormalLocDetlParam.setBatch(locDetl.getBatch());
+
+//                SimpleDateFormat simple = new SimpleDateFormat("yyyyMMdd");
+//                Date maxDate = simple.parse(locDetl.getBatch());
+//                long time = maxDate.getTime();
+//                Date now = new Date();
+//                long time1 = now.getTime();
+//                abnormalLocDetlParam.setNowTime((int) ((time1 - time) / (1000 * 60 * 60 * 24)));
+
+                if (!Cools.isEmpty(mat.getStoreMax()) && locDetl.getAnfme() > mat.getStoreMax()) {
+                    result.add(abnormalLocDetlParam);
+                } else if (!Cools.isEmpty(mat.getStoreMin()) && locDetl.getAnfme() < mat.getStoreMin()) {
+                    result.add(abnormalLocDetlParam);
+                }
+            }
+        }
+        return R.ok(exportSupport(result, fields));
     }
 
     @RequestMapping(value = "/locDetlQuery/auth")

--
Gitblit v1.9.1