From dfd793f14e51c48c3322f1b36f543179043bd45d Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期日, 22 十月 2023 18:25:27 +0800
Subject: [PATCH] 更新仓内抓拍
---
igds-core/src/main/java/com/ld/igds/common/manager/CommonManager.java | 102 +++++++++++++++++++++++++--------------------------
1 files changed, 50 insertions(+), 52 deletions(-)
diff --git a/igds-core/src/main/java/com/ld/igds/common/manager/CommonManager.java b/igds-core/src/main/java/com/ld/igds/common/manager/CommonManager.java
index e82212f..68dee3b 100644
--- a/igds-core/src/main/java/com/ld/igds/common/manager/CommonManager.java
+++ b/igds-core/src/main/java/com/ld/igds/common/manager/CommonManager.java
@@ -11,9 +11,9 @@
import com.ld.igds.data.BaseParam;
import com.ld.igds.data.Page;
import com.ld.igds.data.PageResponse;
+import com.ld.igds.data.SimpleDepot;
import com.ld.igds.grain.dto.GrainData;
import com.ld.igds.grain.service.CoreGrainService;
-import com.ld.igds.inout.dto.InoutParam;
import com.ld.igds.models.*;
import com.ld.igds.sys.service.DicTriggerService;
import com.ld.igds.sys.service.SysDeptService;
@@ -25,13 +25,16 @@
import com.ld.igds.warn.data.WarnParam;
import com.ld.igds.warn.service.CoreWarnService;
import com.ld.igds.weather.CoreWeatherService;
+
import lombok.extern.slf4j.Slf4j;
+
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
+
import java.util.*;
import java.util.stream.Collectors;
@@ -62,26 +65,48 @@
private CoreWarnService coreWarnService;
@Resource
private RedisUtil redisUtil;
+
/**
- * 鑾峰彇鍏ュ簱鐨勪笅鎷夋
+ * 鑾峰彇鍏ュ簱浣滀笟涓紝浠撳簱涓嬫媺妗嗭紝鍊艰幏鍙栫姸鎬�=闈炴弧浠撶殑绮簱
*
* @return
*/
- public List<Depot> listInDepot() {
- List<Depot> list = listDepot(true);
- return list;
+ public List<SimpleDepot> getCacheDeptIn(String companyId, String deptId) {
+
+ List<SimpleDepot> result = new ArrayList<>();
+ List<Depot> list = coreCommonService.getCacheDepotList(companyId, deptId);
+
+ for (Depot depot : list) {
+ if (DepotStatus.STATUS_3.getCode().equals(depot.getDepotStatus())) continue;
+ if (DepotStatus.STATUS_31.getCode().equals(depot.getDepotStatus())) continue;
+ if (DepotStatus.STATUS_32.getCode().equals(depot.getDepotStatus())) continue;
+ if (DepotStatus.STATUS_33.getCode().equals(depot.getDepotStatus())) continue;
+ if (DepotStatus.STATUS_34.getCode().equals(depot.getDepotStatus())) continue;
+
+ result.add(new SimpleDepot(depot));
+ }
+
+ return result;
}
/**
- * 鑾峰彇鍑哄簱鐨勪笅鎷夋
+ * 鑾峰彇鍑哄簱涓嬫媺妗嗗垪琛紝鑷姩灞忚斀绌轰粨
*
* @return
*/
- public List<Depot> listOutDepot() {
- List<Depot> list = listDepot(true);
+ public List<SimpleDepot> getCacheDeptOut(String companyId, String deptId) {
+ List<SimpleDepot> result = new ArrayList<>();
+ List<Depot> list = coreCommonService.getCacheDepotList(companyId, deptId);
- return list;
+ for (Depot depot : list) {
+ if (DepotStatus.STATUS_1.getCode().equals(depot.getDepotStatus())) continue;
+ if (DepotStatus.STATUS_2.getCode().equals(depot.getDepotStatus())) continue;
+
+ result.add(new SimpleDepot(depot));
+ }
+
+ return result;
}
/**
@@ -117,38 +142,12 @@
/**
* 鏌ヨ閮ㄩ棬涓嬪睘鎵�鏈変粨搴撳垪琛�
*
- * @param isDelOther
+ * @param companyId
* @param deptId
* @return
*/
- public List<Depot> listDepotByDeptId(boolean isDelOther, String deptId) {
- String companyId = ContextUtil.getCompanyId();
-
- if (StringUtils.isEmpty(deptId)) {
- return null;
- }
-
- List<Depot> list = coreCommonService.getCacheDepotList(companyId);
- if (null == list || list.isEmpty()) {
- return list;
- }
-
- List<Depot> listDepot = new ArrayList<>();
- for (Depot depot : list) {
- if (depot.getDeptId().contains(deptId)) {
- listDepot.add(depot);
- }
- }
-
- // 鍒犻櫎闈炰粨搴撳垪琛�
- if (isDelOther) {
- return listDepot
- .stream()
- .filter(item -> !item.getDepotType().equals(
- DepotType.TYPE_99.getCode())).collect(Collectors.toList());
- }
-
- return listDepot;
+ public List<Depot> listDepotByDeptId(String companyId, String deptId) {
+ return coreCommonService.getCacheDepotList(companyId, deptId);
}
/**
@@ -485,18 +484,6 @@
return new PageResponse<>(RespCodeEnum.CODE_0000, data);
}
- public PageResponse<Page<DicFoodOrigin>> pageFoodLocation(InoutParam param) {
-
- Page<DicFoodOrigin> result = coreDicService.pageFoodLocation(param);
-
- if (null == result.getRecords() || result.getRecords().isEmpty()) {
- return new PageResponse<>(RespCodeEnum.CODE_2000.getCode(),
- "鑾峰彇鍒版暟鎹俊鎭负绌�");
- }
- return new PageResponse<Page<DicFoodOrigin>>(RespCodeEnum.CODE_0000,
- result);
- }
-
public DepotConf getDepotConf(String companyId, String depotId) {
return coreCommonService.getCacheDepotConf(companyId, depotId);
@@ -575,8 +562,9 @@
log.debug("----------------鏍规嵁鐢ㄦ埛IP鑾峰彇閫夋嫨-鍦扮----{}", userIp);
String key = "INOUT:WEIGHT:" + userIp;
-
- return (String) redisUtil.get(key);
+ String sort = (String)redisUtil.get(key);
+ if(StringUtils.isEmpty(sort))sort="1";
+ return sort;
}
/**
@@ -621,5 +609,15 @@
return (String) redisUtil.get(key);
}
+ public Page<DicArea> pageDicArea(BaseParam param) {
+
+ Page<DicArea> page = new Page<>(param.getPage(), param.getLimit());
+
+ List<DicArea> list = coreDicService.listDicArea(page, param);
+ page.setRecords(list);
+
+ return page;
+ }
+
}
--
Gitblit v1.9.3