瀏覽代碼

feat:缺失数据中间表更新优化,每次清表更新

chenjianhua 21 小時之前
父節點
當前提交
83a571085f

+ 3 - 1
service-base/src/main/java/com/simuwang/base/mapper/daq/DeletionTypeStatisticsMapper.java

@@ -1,4 +1,4 @@
-package com.simuwang.base.mapper;
+package com.simuwang.base.mapper.daq;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.simuwang.base.pojo.dos.DeletionTypeStatisticsDO;
@@ -8,4 +8,6 @@ import org.apache.ibatis.annotations.Param;
 @Mapper
 public interface DeletionTypeStatisticsMapper extends BaseMapper<DeletionTypeStatisticsDO> {
     DeletionTypeStatisticsDO getDeletionTypeStatistics(@Param("fundId") String fundId, @Param("deletionType")Integer deletionType,@Param("channelId")Integer channelId);
+
+    void truncateTable();
 }

+ 1 - 0
service-manage/src/main/java/com/simuwang/manage/service/impl/DeletionServiceImpl.java

@@ -227,6 +227,7 @@ public class DeletionServiceImpl implements DeletionService {
 
     @Override
     public void computeDeletionTypeNum(List<FundDeletionTypeDO> fundDeletionTypeList) {
+        deletionTypeStatisticsMapper.truncateTable();
         for (FundDeletionTypeDO fundDeletionType : fundDeletionTypeList) {
             String fundId = fundDeletionType.getFundId();
             Integer deletionType = fundDeletionType.getDeletionType();