From 0009bb19c1146623ebff97f6615a266974c0b538 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期日, 03 十一月 2024 18:24:10 +0800
Subject: [PATCH] 根据不同上级角色，显示不同库信息
---
src/main/java/com/zy/asrs/controller/WrkDetlLogController.java | 90 ++++++++++-------
src/main/java/com/zy/asrs/controller/WrkDetlController.java | 3
src/main/java/com/zy/asrs/controller/LocMastController.java | 5
src/main/java/com/zy/asrs/controller/LocDetlController.java | 19 ++-
src/main/java/com/zy/system/entity/Role.java | 9 +
src/main/java/com/zy/system/entity/User.java | 8 +
src/main/java/com/zy/common/utils/RoleUtils.java | 122 ++++++++++++++++++++++++
src/main/java/com/zy/asrs/controller/WrkMastLogController.java | 3
src/main/java/com/zy/asrs/controller/WorkController.java | 12 ++
src/main/java/com/zy/asrs/controller/WrkMastController.java | 3
10 files changed, 227 insertions(+), 47 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/LocDetlController.java b/src/main/java/com/zy/asrs/controller/LocDetlController.java
index 7d72cb0..c180e32 100644
--- a/src/main/java/com/zy/asrs/controller/LocDetlController.java
+++ b/src/main/java/com/zy/asrs/controller/LocDetlController.java
@@ -13,12 +13,11 @@
import com.core.common.DateUtils;
import com.core.common.R;
import com.zy.asrs.entity.LocDetl;
-import com.zy.asrs.entity.ManLocDetl;
import com.zy.asrs.entity.Mat;
import com.zy.asrs.mapper.LocDetlMapper;
import com.zy.asrs.service.LocDetlService;
-import com.zy.asrs.service.ManLocDetlService;
import com.zy.asrs.service.MatService;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -83,11 +82,17 @@
param.remove("modi_time");
}
}
- 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));
+ param.remove("curr");
+ param.remove("limit");
+ EntityWrapper<LocDetl> wrapper = new EntityWrapper<>();
+ convert(param, wrapper);
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByLocNo(getUserId(),wrapper);
+ Page<LocDetl> locDetlPage = locDetlService.selectPage(new Page<>(curr, limit), wrapper);
+ if (locDetlPage.getRecords().size()==0){
+ locDetlPage = locDetlService.selectPage(new Page<>(1, limit), wrapper);
}
- return R.ok(stockOut);
+ return R.ok(locDetlPage);
}
@RequestMapping(value = "/stock/out/crn/list/auth")
@@ -140,6 +145,8 @@
excludeTrash(param);
convert(param, wrapper);
allLike(LocDetl.class, param.keySet(), wrapper, condition);
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByLocNo(getUserId(),wrapper);
if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
// if (!row.equals("")){
// wrapper.and()
diff --git a/src/main/java/com/zy/asrs/controller/LocMastController.java b/src/main/java/com/zy/asrs/controller/LocMastController.java
index 1b3ad84..37db305 100644
--- a/src/main/java/com/zy/asrs/controller/LocMastController.java
+++ b/src/main/java/com/zy/asrs/controller/LocMastController.java
@@ -17,12 +17,11 @@
import com.zy.asrs.service.BasWhsService;
import com.zy.asrs.service.LocDetlService;
import com.zy.asrs.service.LocMastService;
-import com.zy.asrs.utils.Utils;
import com.zy.common.entity.Parameter;
import com.zy.common.model.Shelves;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import java.util.*;
@@ -67,6 +66,8 @@
excludeTrash(param);
EntityWrapper<LocMast> wrapper = new EntityWrapper<>();
convert(param, wrapper);
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByCrn(getUserId(),wrapper);
if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
return R.ok(locMastService.selectPage(new Page<>(curr, limit), wrapper));
}
diff --git a/src/main/java/com/zy/asrs/controller/WorkController.java b/src/main/java/com/zy/asrs/controller/WorkController.java
index 1050097..cd2a71f 100644
--- a/src/main/java/com/zy/asrs/controller/WorkController.java
+++ b/src/main/java/com/zy/asrs/controller/WorkController.java
@@ -4,7 +4,6 @@
import com.core.annotations.ManagerAuth;
import com.core.common.Cools;
import com.core.common.R;
-import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.StaDesc;
import com.zy.asrs.entity.WaitPakin;
import com.zy.asrs.entity.param.EmptyPlateOutParam;
@@ -15,6 +14,7 @@
import com.zy.asrs.service.StaDescService;
import com.zy.asrs.service.WorkService;
import com.zy.common.model.StartupDto;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody;
@@ -26,6 +26,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.stream.Collectors;
/**
* 宸ヤ綔娴佹帴鍙ｆ帶鍒跺櫒
@@ -143,7 +144,14 @@
@RequestMapping("/available/empty/take/site")
@ManagerAuth()
public R availableEmptyTakeSite(){
- return R.ok().add(basDevpService.getAvailableEmptyOutSite());
+ EntityWrapper<StaDesc> wrapper = new EntityWrapper<>();
+ wrapper.eq("type_no",110);
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByCrn(getUserId(),wrapper);
+ List<StaDesc> staDescs = staDescService.selectList(wrapper);
+ List<Integer> collect = staDescs.stream().map(StaDesc::getStnNo).distinct().collect(Collectors.toList());
+ return R.ok().add(collect);
+// return R.ok().add(basDevpService.getAvailableEmptyOutSite());
}
@RequestMapping("/full/store/put/start")
diff --git a/src/main/java/com/zy/asrs/controller/WrkDetlController.java b/src/main/java/com/zy/asrs/controller/WrkDetlController.java
index 3baba43..d4b7c72 100644
--- a/src/main/java/com/zy/asrs/controller/WrkDetlController.java
+++ b/src/main/java/com/zy/asrs/controller/WrkDetlController.java
@@ -12,6 +12,7 @@
import com.core.common.R;
import com.zy.asrs.entity.WrkDetl;
import com.zy.asrs.service.WrkDetlService;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -50,6 +51,8 @@
} else {
wrapper.orderBy("appe_time", false);
}
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByBarcode(getUserId(),wrapper);
return R.ok(wrkDetlService.selectPage(new Page<>(curr, limit), wrapper));
}
diff --git a/src/main/java/com/zy/asrs/controller/WrkDetlLogController.java b/src/main/java/com/zy/asrs/controller/WrkDetlLogController.java
index dd97c89..33270f9 100644
--- a/src/main/java/com/zy/asrs/controller/WrkDetlLogController.java
+++ b/src/main/java/com/zy/asrs/controller/WrkDetlLogController.java
@@ -12,11 +12,15 @@
import com.core.common.R;
import com.zy.asrs.entity.WrkDetlLog;
import com.zy.asrs.service.WrkDetlLogService;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
@RestController
public class WrkDetlLogController extends BaseController {
@@ -77,43 +81,55 @@
@RequestParam(required = false) String condition,
@RequestParam Map<String, Object> param) {
try {
- Integer wrkNo = null;
- String orderNo = null;
- String matnr = null;
- String specs = null;
- String zpallet = null;
- String batch = null;
- Double anfme = null;
- Date modiTimeStart = null, modiTimeEnd = null;
- for (Map.Entry<String, Object> entry : param.entrySet()) {
- String val = String.valueOf(entry.getValue());
- if (Cools.isEmpty(val)) {
- continue;
- }
- if (val.contains(RANGE_TIME_LINK)) {
- String[] dates = val.split(RANGE_TIME_LINK);
- modiTimeStart = DateUtils.convert(dates[0]);
- modiTimeEnd = DateUtils.convert(dates[1]);
- } else if (entry.getKey().equals("wrk_no")) {
- wrkNo = Integer.parseInt(val);
- } else if (entry.getKey().equals("order_no")) {
- orderNo = val;
- } else if (entry.getKey().equals("specs")) {
- specs = val;
- } else if (entry.getKey().equals("zpallet")) {
- zpallet = val;
- } else if (entry.getKey().equals("batch")) {
- batch = val;
- } else if (entry.getKey().equals("anfme")) {
- anfme = Double.parseDouble(val);
- }else if (entry.getKey().equals("matnr")) {
- matnr = val;
- }
+ excludeTrash(param);
+ EntityWrapper<WrkDetlLog> wrapper = new EntityWrapper<>();
+ convert(param, wrapper);
+ allLike(WrkDetlLog.class, param.keySet(), wrapper, condition);
+ if (!Cools.isEmpty(orderByField)){
+ wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));
+ } else {
+ wrapper.orderBy("appe_time", false);
}
- List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectWrkDetlLogs(wrkNo, orderNo,matnr,specs,zpallet,batch,anfme, modiTimeStart, modiTimeEnd, curr, limit);
- Page<WrkDetlLog> page1 = new Page<WrkDetlLog>(curr, limit).setRecords(wrkDetlLogs);
- page1.setTotal(wrkDetlLogService.selectWrkDetlLogsTotal(wrkNo, orderNo,matnr,specs,zpallet,batch,anfme, modiTimeStart, modiTimeEnd));
- return R.ok(page1);
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByBarcode(getUserId(),wrapper);
+ return R.ok(wrkDetlLogService.selectPage(new Page<>(curr, limit), wrapper));
+// Integer wrkNo = null;
+// String orderNo = null;
+// String matnr = null;
+// String specs = null;
+// String zpallet = null;
+// String batch = null;
+// Double anfme = null;
+// Date modiTimeStart = null, modiTimeEnd = null;
+// for (Map.Entry<String, Object> entry : param.entrySet()) {
+// String val = String.valueOf(entry.getValue());
+// if (Cools.isEmpty(val)) {
+// continue;
+// }
+// if (val.contains(RANGE_TIME_LINK)) {
+// String[] dates = val.split(RANGE_TIME_LINK);
+// modiTimeStart = DateUtils.convert(dates[0]);
+// modiTimeEnd = DateUtils.convert(dates[1]);
+// } else if (entry.getKey().equals("wrk_no")) {
+// wrkNo = Integer.parseInt(val);
+// } else if (entry.getKey().equals("order_no")) {
+// orderNo = val;
+// } else if (entry.getKey().equals("specs")) {
+// specs = val;
+// } else if (entry.getKey().equals("zpallet")) {
+// zpallet = val;
+// } else if (entry.getKey().equals("batch")) {
+// batch = val;
+// } else if (entry.getKey().equals("anfme")) {
+// anfme = Double.parseDouble(val);
+// }else if (entry.getKey().equals("matnr")) {
+// matnr = val;
+// }
+// }
+// List<WrkDetlLog> wrkDetlLogs = wrkDetlLogService.selectWrkDetlLogs(wrkNo, orderNo,matnr,specs,zpallet,batch,anfme, modiTimeStart, modiTimeEnd, curr, limit);
+// Page<WrkDetlLog> page1 = new Page<WrkDetlLog>(curr, limit).setRecords(wrkDetlLogs);
+// page1.setTotal(wrkDetlLogService.selectWrkDetlLogsTotal(wrkNo, orderNo,matnr,specs,zpallet,batch,anfme, modiTimeStart, modiTimeEnd));
+// return R.ok(page1);
} catch (Exception e) {
return R.error("寮傚父" + e);
}
diff --git a/src/main/java/com/zy/asrs/controller/WrkMastController.java b/src/main/java/com/zy/asrs/controller/WrkMastController.java
index 3a6a9c5..314ebf6 100644
--- a/src/main/java/com/zy/asrs/controller/WrkMastController.java
+++ b/src/main/java/com/zy/asrs/controller/WrkMastController.java
@@ -12,6 +12,7 @@
import com.core.common.R;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.WrkMastService;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -50,6 +51,8 @@
}else {
wrapper.orderBy("io_time", false);
}
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByCrn(getUserId(),wrapper);
return R.ok(wrkMastService.selectPage(new Page<>(curr, limit), wrapper));
}
diff --git a/src/main/java/com/zy/asrs/controller/WrkMastLogController.java b/src/main/java/com/zy/asrs/controller/WrkMastLogController.java
index 7e0bec4..9a41f8e 100644
--- a/src/main/java/com/zy/asrs/controller/WrkMastLogController.java
+++ b/src/main/java/com/zy/asrs/controller/WrkMastLogController.java
@@ -12,6 +12,7 @@
import com.core.common.R;
import com.zy.asrs.entity.WrkMastLog;
import com.zy.asrs.service.WrkMastLogService;
+import com.zy.common.utils.RoleUtils;
import com.zy.common.web.BaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@@ -53,6 +54,8 @@
}else {
wrapper.orderBy("modi_time", false);
}
+ // 涓嶅悓缁ф壙瑙掕壊鏄剧ず涓嶅悓搴撲俊鎭�
+ RoleUtils.addRoleWrapperByCrn(getUserId(),wrapper);
return R.ok(wrkMastLogService.selectPage(new Page<>(curr, limit), wrapper));
}
diff --git a/src/main/java/com/zy/common/utils/RoleUtils.java b/src/main/java/com/zy/common/utils/RoleUtils.java
new file mode 100644
index 0000000..c9bcf3d
--- /dev/null
+++ b/src/main/java/com/zy/common/utils/RoleUtils.java
@@ -0,0 +1,122 @@
+package com.zy.common.utils;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
+import com.core.common.SpringUtils;
+import com.zy.system.entity.User;
+import com.zy.system.service.UserService;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author pang.jiabao
+ * @description 鏍规嵁瑙掕壊鍖哄垎涓嶅悓搴撴樉绀轰笉鍚屽簱瀛�
+ * @createDate 2024/11/3 14:11
+ */
+@Component
+public class RoleUtils {
+
+ /**
+ * 浠ヨ鑹茬户鎵胯鑹叉樉绀哄嚭鎸囧畾搴撲俊鎭寜鍫嗗灈鏈洪檺鍒�
+ */
+ public static <T> void addRoleWrapperByCrn(Long userId, EntityWrapper<T> wrapper) {
+ // super璐﹀彿
+ if (userId == 9527) {
+ return;
+ }
+
+ UserService userService = SpringUtils.getBean(UserService.class);
+ User user = userService.selectById(userId);
+ String roleName = user.getRoleName();
+
+ // 绠＄悊鍛樿鑹�
+ if (Cools.isEmpty(roleName)) {
+ wrapper.eq("1", 0);
+ } else if (roleName.equals("绠＄悊鍛�")) {
+ return;
+ }
+
+ // 鍏朵粬瑙掕壊鐪嬬户鎵胯鑹�
+ String roleLeaderCode = user.getRoleLeaderCode();
+ if (Cools.isEmpty(roleLeaderCode)) {
+ wrapper.eq("1", 0);
+ } else if (roleLeaderCode.equals("stacker_hangar")) { // 鍫嗗灈鏈哄簱
+ wrapper.le("crn_no", 4); // 闄愬埗1~4鍙峰爢鍨涙満
+ } else if (roleLeaderCode.equals("four_directional_library")) { // 鍥涘悜搴�
+ wrapper.eq("crn_no", 7); // 闄愬埗7鍙峰爢鍨涙満
+ } else if (roleLeaderCode.equals("ctu_library")) { // ctu搴�
+ wrapper.in("crn_no", 8, 9); //闄愬埗8锛�9鍙峰爢鍨涙満
+ }
+
+ }
+
+ /**
+ * 浠ヨ鑹茬户鎵胯鑹叉樉绀哄嚭鎸囧畾搴撲俊鎭寜搴撲綅闄愬埗
+ */
+ public static <T> void addRoleWrapperByLocNo(Long userId, EntityWrapper<T> wrapper) {
+ // super璐﹀彿
+ if (userId == 9527) {
+ return;
+ }
+
+ UserService userService = SpringUtils.getBean(UserService.class);
+ User user = userService.selectById(userId);
+ String roleName = user.getRoleName();
+
+ // 绠＄悊鍛樿鑹�
+ if (Cools.isEmpty(roleName)) {
+ wrapper.eq("1", 0);
+ return;
+ } else if (roleName.equals("绠＄悊鍛�")) {
+ return;
+ }
+
+ // 鍏朵粬瑙掕壊鐪嬬户鎵胯鑹�
+ String roleLeaderCode = user.getRoleLeaderCode();
+ if (Cools.isEmpty(roleLeaderCode)) {
+ wrapper.eq("1", 0);
+ } else if (roleLeaderCode.equals("stacker_hangar")) { // 鍫嗗灈鏈哄簱
+ wrapper.addFilter("LEFT(loc_no,2)<=16"); // 闄愬埗1~16鎺�
+ } else if (roleLeaderCode.equals("four_directional_library")) { // 鍥涘悜搴�
+ wrapper.addFilter("LEFT(loc_no,2)>=17 and LEFT(loc_no,2)<=37"); // 闄愬埗17~37鎺�
+ } else if (roleLeaderCode.equals("ctu_library")) { // ctu搴�
+ wrapper.addFilter("LEFT(loc_no,2)>=38"); //闄愬埗38~53鎺�
+ }
+ }
+
+
+ /**
+ * 浠ヨ鑹茬户鎵胯鑹叉樉绀哄嚭鎸囧畾搴撲俊鎭寜鎵樼洏鐮侀檺鍒�
+ */
+ public static <T> void addRoleWrapperByBarcode(Long userId, EntityWrapper<T> wrapper) {
+ // super璐﹀彿
+ if (userId == 9527) {
+ return;
+ }
+
+ UserService userService = SpringUtils.getBean(UserService.class);
+ User user = userService.selectById(userId);
+ String roleName = user.getRoleName();
+
+ // 绠＄悊鍛樿鑹�
+ if (Cools.isEmpty(roleName)) {
+ wrapper.eq("1", 0);
+ return;
+ } else if (roleName.equals("绠＄悊鍛�")) {
+ return;
+ }
+
+ // 鍏朵粬瑙掕壊鐪嬬户鎵胯鑹�
+ String roleLeaderCode = user.getRoleLeaderCode();
+ if (Cools.isEmpty(roleLeaderCode)) {
+ wrapper.eq("1", 0);
+ } else if (roleLeaderCode.equals("stacker_hangar")) { // 鍫嗗灈鏈哄簱
+ // TODO 鍫嗗灈鏈哄紑澶存湭纭
+// wrapper.addFilter("LEFT(zpallet,3) =''"); // 闄愬埗
+ } else if (roleLeaderCode.equals("four_directional_library")) { // 鍥涘悜搴�
+ wrapper.addFilter("LEFT(zpallet,3) ='SXK'"); // 闄愬埗SXK
+ } else if (roleLeaderCode.equals("ctu_library")) { // ctu搴�
+ wrapper.addFilter("LEFT(zpallet,3) ='CTU'"); //闄愬埗CTU
+ }
+ }
+
+}
diff --git a/src/main/java/com/zy/system/entity/Role.java b/src/main/java/com/zy/system/entity/Role.java
index 7f31512..86214e0 100644
--- a/src/main/java/com/zy/system/entity/Role.java
+++ b/src/main/java/com/zy/system/entity/Role.java
@@ -99,6 +99,15 @@
return null;
}
+ public String getLeaderCode(){
+ RoleService service = SpringUtils.getBean(RoleService.class);
+ Role role = service.selectById(this.leader);
+ if (!Cools.isEmpty(role)){
+ return String.valueOf(role.getCode());
+ }
+ return null;
+ }
+
public void setLeader(Long leader) {
this.leader = leader;
}
diff --git a/src/main/java/com/zy/system/entity/User.java b/src/main/java/com/zy/system/entity/User.java
index 98d856f..f8251bb 100644
--- a/src/main/java/com/zy/system/entity/User.java
+++ b/src/main/java/com/zy/system/entity/User.java
@@ -215,6 +215,14 @@
}
return null;
}
+ public String getRoleLeaderCode(){
+ RoleService service = SpringUtils.getBean(RoleService.class);
+ Role role = service.selectById(this.roleId);
+ if (!Cools.isEmpty(role)){
+ return role.getLeaderCode();
+ }
+ return null;
+ }
public void setRoleId(Long roleId) {
this.roleId = roleId;
--
Gitblit v1.9.1