From 3bf231d89a3012da9fe8447f321a82e13c426d7f Mon Sep 17 00:00:00 2001
From: skyouc <creaycat@gmail.com>
Date: 星期一, 19 一月 2026 08:46:03 +0800
Subject: [PATCH] 库存查询接口修改
---
src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java | 25 +++++++++++++++----------
1 files changed, 15 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java b/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java
index f10fdb8..14eb485 100644
--- a/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java
+++ b/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java
@@ -47,6 +47,7 @@
import java.math.BigDecimal;
import java.util.*;
+import java.util.stream.Collectors;
@Slf4j
@Service("kopenApiServiceImpl")
@@ -557,18 +558,22 @@
* @return com.core.common.R
*/
@Override
- public XSR getStockInfo(PageRequestParams params) {
+ public XSR getStockInfo(List<PageRequestParams> params) {
+ if (Objects.isNull(params) || params.isEmpty()) {
+ throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
+ }
+
+ Set<String> collect = params.stream().map(PageRequestParams::getPro_id).collect(Collectors.toSet());
+
+ Set<String> komccodes = params.stream().map(PageRequestParams::getPro_komcode).collect(Collectors.toSet());
+
EntityWrapper<LocDetl> wrapper = new EntityWrapper<>();
- if (!Objects.isNull(params.getPro_id())) {
- wrapper.eq("supp_code", params.getPro_id());
- }
- if (!Objects.isNull(params.getPro_komcode())) {
- wrapper.eq("matnr", params.getPro_komcode());
- }
+ wrapper.in(collect.isEmpty(), "pro_id", collect);
+ wrapper.in(komccodes.isEmpty(), "komccode", komccodes);
- Page<LocDetl> locDetls = locDetlService.selectPage(new Page<>(params.getCurr(), params.getLimit()), wrapper);
+ List<LocDetl> detls = locDetlService.selectList(wrapper);
- return XSR.ok(locDetls.getRecords());
+ return XSR.ok(detls);
}
/**
@@ -726,7 +731,7 @@
.setJson(JSONObject.toJSONString(orderParams))
.build()
.doPost();
- if (Objects.isNull(response) || response.trim().isEmpty()) {
+ if (Objects.isNull(response) || response.trim().isEmpty()) {
return XSR.error("澶栫綉鎺ュ彛鏃犲搷搴旓紒锛�");
}
JSONObject jsonObject = JSONObject.parseObject(response);
--
Gitblit v1.9.1