From 50f2f8945f1ab86c931fee6cf9d9bd88a122ae6e Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期六, 07 六月 2025 17:14:47 +0800
Subject: [PATCH] #单据出库
---
rsf-server/src/main/java/com/vincent/rsf/server/api/controller/mcp/McpController.java | 94 +++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 94 insertions(+), 0 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/mcp/McpController.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/mcp/McpController.java
new file mode 100644
index 0000000..8940c25
--- /dev/null
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/controller/mcp/McpController.java
@@ -0,0 +1,94 @@
+package com.vincent.rsf.server.api.controller.mcp;
+
+import com.alibaba.fastjson.JSONArray;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.vincent.rsf.framework.common.Cools;
+import com.vincent.rsf.framework.common.R;
+import com.vincent.rsf.server.common.constant.Constants;
+import com.vincent.rsf.server.common.domain.BaseParam;
+import com.vincent.rsf.server.common.domain.PageParam;
+import com.vincent.rsf.server.common.utils.FieldsUtils;
+import com.vincent.rsf.server.manager.controller.params.LocToTaskParams;
+import com.vincent.rsf.server.manager.entity.DeviceSite;
+import com.vincent.rsf.server.manager.entity.LocItem;
+import com.vincent.rsf.server.manager.enums.LocStsType;
+import com.vincent.rsf.server.manager.service.DeviceSiteService;
+import com.vincent.rsf.server.manager.service.LocItemService;
+import com.vincent.rsf.server.system.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+@RestController
+@RequestMapping("/mcp")
+@Api(tags = "mcp鎺ュ彛")
+public class McpController extends BaseController {
+
+ @Autowired
+ private LocItemService locItemService;
+ @Autowired
+ private DeviceSiteService deviceSiteService;
+
+
+ @PostMapping("/locItem/useF/list")
+ public R locUseOPage(@RequestBody Map<String, Object> map) {
+ QueryWrapper<LocItem> locItemQueryWrapper = new QueryWrapper<>();
+ if (null != map.get("matnr") && !Cools.isEmpty(map.get("matnr"))){
+ locItemQueryWrapper.eq("matnr_code", map.get("matnr"));
+ }else {
+ return R.error("鐗╂枡缂栫爜涓虹┖");
+ }
+ String applySql = String.format(
+ "EXISTS (SELECT 1 FROM man_loc ml " +
+ "WHERE ml.use_status = '%s'" +
+ "AND ml.id = man_loc_item.loc_id " +
+ ")",
+ LocStsType.LOC_STS_TYPE_F.type
+ );
+ locItemQueryWrapper.apply(applySql);
+ List<LocItem> locItems = locItemService.list(locItemQueryWrapper);
+ for (LocItem locItem : locItems) {
+ if (!Objects.isNull(locItem.getFieldsIndex())) {
+ Map<String, String> fields = FieldsUtils.getFields(locItem.getFieldsIndex());
+ locItem.setExtendFields(fields);
+ }
+ }
+ return R.ok().add(locItems);
+ }
+
+
+ @PostMapping("/selectStaList/list")
+ public R selectStaList(@RequestBody Map<String, Object> map) {
+ List<String> longs = null;
+ if (map.get("type") != null) {
+ longs = JSONArray.parseArray(map.get("type").toString(), String.class);
+ map.entrySet().removeIf(next -> next.getKey().equals("type"));
+ }
+ List<DeviceSite> list = deviceSiteService.list(new LambdaQueryWrapper<DeviceSite>().in(DeviceSite::getType, longs));
+ return R.ok().add(list);
+ }
+
+ @ApiOperation("鐢熸垚搴撳瓨鍑哄簱浠诲姟")
+ @PostMapping("/generate/task")
+ public R generateTask(@RequestBody LocToTaskParams param) {
+ if (Objects.isNull(param)) {
+ return R.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
+ }
+ param.setType(Constants.TASK_TYPE_OUT_STOCK);
+
+ return locItemService.generateTask(param, getLoginUserId());
+ }
+
+
+
+}
--
Gitblit v1.9.1