From 1c8794398da91bf43e568c207dfb513b441395a1 Mon Sep 17 00:00:00 2001
From: Yen <yen1130@qq.com>
Date: Tue, 5 Dec 2023 23:36:18 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4=E9=9D=9E=E5=AE=A1=E6=89=B9?=
 =?UTF-8?q?=E5=92=8C=E9=80=9A=E8=BF=87=E7=8A=B6=E6=80=81=E7=9A=84bir?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/BirActivityCenterGoodsMapper.java  |  2 +
 .../BirActivityCenterGoodsServiceImpl.java    | 46 +++++++++++--------
 .../bir/BirActivityCenterGoodsMapper.xml      |  6 +++
 3 files changed, 36 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java b/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java
index 19dbec5d..2b90332c 100644
--- a/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java
+++ b/src/main/java/com/qs/serve/modules/bir/mapper/BirActivityCenterGoodsMapper.java
@@ -17,6 +17,8 @@ import java.util.List;
  */
 public interface BirActivityCenterGoodsMapper extends BaseMapper<BirActivityCenterGoods> {
 
+    List<BirActivityCenterGoods> selectErrorBir();
+
     /**
      * 查询出异动的记录
      * @param startDate
diff --git a/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java b/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java
index 410921df..78ef61b1 100644
--- a/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java
+++ b/src/main/java/com/qs/serve/modules/bir/service/impl/BirActivityCenterGoodsServiceImpl.java
@@ -84,7 +84,13 @@ public class BirActivityCenterGoodsServiceImpl extends ServiceImpl<BirActivityCe
         LocalDate endDate = LocalDate.of(year,month,lastDayNum2);
         //加载所有异动的数据
         List<TbsActivityCenterGoods> activityCenterGoodsAllList = this.baseMapper.selectChangeCenterGoods(startDate,endDate,null);
-//        List<TbsActivityCenterGoods> activityCenterGoodsAllList = this.baseMapper.selectChangeCenterGoods(null,null,15840L);
+
+        //异常状态的费用申请，导致的Bir
+        List<BirActivityCenterGoods> removeErrorBirList = this.baseMapper.selectErrorBir();
+        List<Long> errorActIds = removeErrorBirList.stream().map(BirActivityCenterGoods::getActivityId).distinct().collect(Collectors.toList());
+        this.buildRemoveRecode(errorActIds);
+
+
         if(activityCenterGoodsAllList.size()<1){
             return;
         }
@@ -93,23 +99,7 @@ public class BirActivityCenterGoodsServiceImpl extends ServiceImpl<BirActivityCe
         // 删除历史数据
         List<Long> activityIds = activityCenterGoodsAllList.stream().filter(a->a.getId()!=null)
                 .map(TbsActivityCenterGoods::getActivityId).collect(Collectors.toList());
-        LambdaQueryWrapper<BirActivityCenterGoods> birBaseActivityLqw = new LambdaQueryWrapper<>();
-        birBaseActivityLqw.in(BirActivityCenterGoods::getActivityId,activityIds);
-
-        List<BirActivityCenterGoods> removeBirList = this.list(birBaseActivityLqw);
-        if(removeBirList.size()>0){
-            List<BirRemoveId> removeIds = removeBirList.stream().map(a-> {
-                BirRemoveId birRemoveId = new BirRemoveId();
-                birRemoveId.setDeleteTime(LocalDateTime.now());
-                birRemoveId.setId(a.getId());
-                return birRemoveId;
-            }).collect(Collectors.toList());
-
-            removeIds.forEach(a->{
-                birRemoveIdMapper.insert(a);
-            });
-        }
-        this.remove(birBaseActivityLqw);
+        this.buildRemoveRecode(activityIds);
 
         List<BirActivityCenterGoods> noExist = this.baseMapper.selectNoExistCenterGoods();
         if(noExist.size()>0){
@@ -212,6 +202,26 @@ public class BirActivityCenterGoodsServiceImpl extends ServiceImpl<BirActivityCe
 
     }
 
+    private void buildRemoveRecode(List<Long> activityIds) {
+        LambdaQueryWrapper<BirActivityCenterGoods> birBaseActivityLqw = new LambdaQueryWrapper<>();
+        birBaseActivityLqw.in(BirActivityCenterGoods::getActivityId, activityIds);
+
+        List<BirActivityCenterGoods> removeBirList = this.list(birBaseActivityLqw);
+        if(removeBirList.size()>0){
+            List<BirRemoveId> removeIds = removeBirList.stream().map(a-> {
+                BirRemoveId birRemoveId = new BirRemoveId();
+                birRemoveId.setDeleteTime(LocalDateTime.now());
+                birRemoveId.setId(a.getId());
+                return birRemoveId;
+            }).collect(Collectors.toList());
+
+            removeIds.forEach(a->{
+                birRemoveIdMapper.insert(a);
+            });
+        }
+        this.remove(birBaseActivityLqw);
+    }
+
     /**
      * 创建底表对象
      * @param costCenterList
diff --git a/src/main/resources/mapper/bir/BirActivityCenterGoodsMapper.xml b/src/main/resources/mapper/bir/BirActivityCenterGoodsMapper.xml
index 563b5acc..46d54bda 100644
--- a/src/main/resources/mapper/bir/BirActivityCenterGoodsMapper.xml
+++ b/src/main/resources/mapper/bir/BirActivityCenterGoodsMapper.xml
@@ -175,5 +175,11 @@
           and key_num &gt;=#{query.startYearMonth}
         group by key_num
     </select>
+
+    <select id="selectErrorBir" resultType="com.qs.serve.modules.bir.entity.BirActivityCenterGoods">
+        select bir_activity_center_goods.* from bir_activity_center_goods left join tbs_cost_apply
+            on tbs_cost_apply.id = bir_activity_center_goods.cost_apply_id
+        where charge_state not in (2,3)
+    </select>
 </mapper>