From 04fb99466803facb0790f71c4f1322ef4825875b Mon Sep 17 00:00:00 2001
From: chenhc <2369838784@qq.com>
Date: Thu, 23 Jan 2025 11:52:52 +0800
Subject: [PATCH] =?UTF-8?q?fix:=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../inout/IoSplitFifoInvController.java       |  4 +-
 .../api/dao/inout/IoSplitFifoInvMapper.java   |  1 +
 .../service/inout/IoSplitFifoInvService.java  | 30 ++++++-
 .../mapper/inout/IoSplitFifoInvMapper.xml     | 89 ++++++++++++++++++-
 4 files changed, 120 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/glxp/api/controller/inout/IoSplitFifoInvController.java b/src/main/java/com/glxp/api/controller/inout/IoSplitFifoInvController.java
index 1289e5b8e..1632fe084 100644
--- a/src/main/java/com/glxp/api/controller/inout/IoSplitFifoInvController.java
+++ b/src/main/java/com/glxp/api/controller/inout/IoSplitFifoInvController.java
@@ -80,7 +80,7 @@ public class IoSplitFifoInvController extends BaseController {
         }
 
 
-        List<IoSplitInvResponse> splitCodeEntities = splitFifoInvService.filterList(ioSplitFifoInvRequest);
+        List<IoSplitInvResponse> splitCodeEntities = splitFifoInvService.filterKcyjList(ioSplitFifoInvRequest);
         for (IoSplitInvResponse ioSplitCodeResponse : splitCodeEntities) {
             if (StrUtil.isEmpty(ioSplitCodeResponse.getGgxh())) {
                 ioSplitCodeResponse.setGgxh(ioSplitCodeResponse.getBzgg());
@@ -136,7 +136,7 @@ public class IoSplitFifoInvController extends BaseController {
         // 模拟数据库获取数据
         ioSplitFifoInvRequest.setPage(null);
         ioSplitFifoInvRequest.setLimit(null);
-        List<IoSplitInvResponse> list = splitFifoInvService.filterList(ioSplitFifoInvRequest);
+        List<IoSplitInvResponse> list = splitFifoInvService.filterKcyjList(ioSplitFifoInvRequest);
         List<IoSplitInvViewResponse> splitCodeEntities = BeanUtil.copyToList(list, IoSplitInvViewResponse.class);
 
         response.setCharacterEncoding(StandardCharsets.UTF_8.name());
diff --git a/src/main/java/com/glxp/api/dao/inout/IoSplitFifoInvMapper.java b/src/main/java/com/glxp/api/dao/inout/IoSplitFifoInvMapper.java
index a63d66b76..d973710b9 100644
--- a/src/main/java/com/glxp/api/dao/inout/IoSplitFifoInvMapper.java
+++ b/src/main/java/com/glxp/api/dao/inout/IoSplitFifoInvMapper.java
@@ -11,4 +11,5 @@ import java.util.List;
 @Mapper
 public interface IoSplitFifoInvMapper extends BaseMapper<IoSplitFifoInv> {
     List<IoSplitInvResponse> filterList(IoSplitFifoInvRequest ioSplitFifoInvRequest);
+    List<IoSplitInvResponse> filterKcyjList(IoSplitFifoInvRequest ioSplitFifoInvRequest);
 }
diff --git a/src/main/java/com/glxp/api/service/inout/IoSplitFifoInvService.java b/src/main/java/com/glxp/api/service/inout/IoSplitFifoInvService.java
index 9e5ac8d3a..becc34af7 100644
--- a/src/main/java/com/glxp/api/service/inout/IoSplitFifoInvService.java
+++ b/src/main/java/com/glxp/api/service/inout/IoSplitFifoInvService.java
@@ -299,7 +299,35 @@ public class IoSplitFifoInvService extends ServiceImpl<IoSplitFifoInvMapper, IoS
             ioSplitInvResponses.forEach(t -> {
                 if (IntUtil.value(t.getQueueEnableRemind())) {
                     int count = t.getReCount() - t.getQueueRemindCount();
-                    if (count >= 0) {
+                    if (count > 0) {
+                        t.setRemindState(1);
+                    } else {
+                        t.setRemindState(2);
+                    }
+                } else {
+                    t.setRemindState(1);
+                }
+            });
+            return ioSplitInvResponses;
+        } else {
+            return Collections.emptyList();
+        }
+    }
+
+    public List<IoSplitInvResponse> filterKcyjList(IoSplitFifoInvRequest ioSplitFifoInvRequest) {
+        if (ioSplitFifoInvRequest == null) {
+            return Collections.emptyList();
+        }
+        if (ioSplitFifoInvRequest.getPage() != null) {
+            int offset = (ioSplitFifoInvRequest.getPage() - 1) * ioSplitFifoInvRequest.getLimit();
+            PageHelper.offsetPage(offset, ioSplitFifoInvRequest.getLimit());
+        }
+        List<IoSplitInvResponse> ioSplitInvResponses = this.baseMapper.filterKcyjList(ioSplitFifoInvRequest);
+        if (CollUtil.isNotEmpty(ioSplitInvResponses)) {
+            ioSplitInvResponses.forEach(t -> {
+                if (t.getQueueEnableRemind()) {
+                    int count = t.getReCount() - t.getQueueRemindCount();
+                    if (count > 0) {
                         t.setRemindState(1);
                     } else {
                         t.setRemindState(2);
diff --git a/src/main/resources/mybatis/mapper/inout/IoSplitFifoInvMapper.xml b/src/main/resources/mybatis/mapper/inout/IoSplitFifoInvMapper.xml
index c3359d123..48d50043c 100644
--- a/src/main/resources/mybatis/mapper/inout/IoSplitFifoInvMapper.xml
+++ b/src/main/resources/mybatis/mapper/inout/IoSplitFifoInvMapper.xml
@@ -27,7 +27,94 @@
     expireDate, supId, inCount, outCount, createTime, updateTime, remark
   </sql>
 
+
   <select id="filterList" parameterType="com.glxp.api.req.inout.IoSplitFifoInvRequest" resultType="com.glxp.api.res.inout.IoSplitInvResponse">
+    select isfi.*,
+           bp.cpmctymc,
+           bp.ggxh,
+           bp.bzgg,
+           bu.useLevelUnit,
+           bp.ylqxzcrbarmc,
+           bp.nameCode,
+           bp.manufactory,
+           bp.measname,
+           bp.zczbhhzbapzbh,
+           bp.ybbm,
+           bp.zxxsdycpbs,
+           bc.name  supName,
+           sw.workPlaceName,
+           swd.busName,
+           swd.monopoly
+    from io_split_fifo_inv isfi
+           LEFT JOIN basic_udirel bu ON bu.id = isfi.relId
+           LEFT JOIN basic_products bp ON bu.uuid = bp.uuid
+           left join basic_corp bc on bc.erpId = isfi.supId
+           left join sys_workplace sw on sw.workplaceId = isfi.workPlaceCode
+           left join sys_workplace_document swd on swd.documentTypeCode = isfi.busType
+      <where>
+          <if test="relId != null">
+              AND isfi.relId = #{relId}
+          </if>
+          <if test="nameCode != '' and nameCode != null">
+              AND bp.nameCode = #{nameCode}
+          </if>
+          <if test="zczbhhzbapzbh != '' and zczbhhzbapzbh != null">
+              AND bp.zczbhhzbapzbh like concat('%', #{zczbhhzbapzbh}, '%')
+          </if>
+          <if test="ylqxzcrbarmc != '' and ylqxzcrbarmc != null">
+              AND (
+              bp.ylqxzcrbarmc like concat('%', #{ylqxzcrbarmc}, '%')
+              or bp.manufactory like concat('%', #{ylqxzcrbarmc}, '%'))
+          </if>
+          <if test="batchNo != '' and batchNo != null">
+              AND isfi.batchNo = #{batchNo}
+          </if>
+          <if test="invCode != null">
+              AND isfi.invCode = #{invCode}
+          </if>
+          <if test="supId != null">
+              AND isfi.supId = #{supId}
+          </if>
+          <if test="fifoSplit != null">
+              AND isfi.fifoSplit = #{fifoSplit}
+          </if>
+          <if test="productType != null">
+              AND isfi.productType = #{productType}
+          </if>
+          <if test="workPlaceCode != null">
+              AND isfi.workPlaceCode = #{workPlaceCode}
+          </if>
+          <if test="busType != null and busType != ''">
+              AND isfi.busType = #{busType}
+          </if>
+          <if test="cpmctymc != null and cpmctymc != ''">
+              AND bp.cpmctymc like concat('%', #{cpmctymc}, '%')
+          </if>
+          <if test="keyWords != null and keyWords != ''">
+              AND (
+              isfi.workPlaceCode like concat('%', #{keyWords}, '%')
+              or bp.nameCode like concat('%', #{keyWords}, '%')
+              or isfi.batchNo like concat('%', #{keyWords}, '%')
+              or bp.cpmctymc like concat('%', #{keyWords}, '%')
+              or bp.ggxh like concat('%', #{keyWords}, '%')
+              or bp.bzgg like concat('%', #{keyWords}, '%')
+              or bp.nameCode like concat('%', #{keyWords}, '%')
+              or bp.zczbhhzbapzbh like concat('%', #{keyWords}, '%')
+              or bp.ylqxzcrbarmc like concat('%', #{keyWords}, '%')
+              or bp.manufactory like concat('%',#{keyWords},'%')
+              or bc.name like concat('%',#{keyWords},'%')
+              or swd.busName like concat('%',#{keyWords},'%')
+              )
+          </if>
+          <if test="remind != null and remind == 'yj' ">
+             AND not exists(select 1 from io_split_fifo_inv t where t.enableRemind = 0 and (t.reCount - t.invRemindCount) <![CDATA[ >= ]]>  0 and t.id = isfi.id )
+          </if>
+      </where>
+      GROUP  BY id
+  </select>
+
+
+  <select id="filterKcyjList" parameterType="com.glxp.api.req.inout.IoSplitFifoInvRequest" resultType="com.glxp.api.res.inout.IoSplitInvResponse">
     select isfi.*,
            bp.cpmctymc,
            CASE   WHEN bp.ggxh IS NULL THEN bp.bzgg  ELSE bp.ggxh END AS ggxh,
@@ -51,7 +138,7 @@
            swf.freightRow,
            (ifnull(swq.maxDrugCount,0) - ifnull(isfi.reCount,0)) as suggestOutCount
         from
-        (select relId,sum(reCount) as reCount,sum(availableCount) as availableCount,supId,workPlaceQueueCode,workPlaceCode,busType from io_split_fifo_inv
+        (select relId,sum(reCodeCount) as reCount,sum(availableCount) as availableCount,supId,workPlaceQueueCode,workPlaceCode,busType from io_split_fifo_inv
         group by relId,supId,workPlaceQueueCode,workPlaceCode,busType
         ) as isfi
            LEFT JOIN basic_udirel bu ON bu.id = isfi.relId