用户余额日志删除数据同步

kxs-transfer/src/main/java/com/kxs/transfer/api/controller/DtsController.java

@@ -159,7 +159,7 @@ public class DtsController {
             //盟主表
             if ("Leaders".equals(dmlData.getTableName())) {
                 kxsLeaderService.changeData(dmlData);
-            }
+             }
             //盟主金额变动记录表
             if ("LeaderReserveRecord".equals(dmlData.getTableName())) {
                 kxsLeaderAmountLogService.changeData(dmlData);

kxs-transfer/src/main/java/com/kxs/transfer/api/service/user/impl/KxsUserAmountLogServiceImpl.java

@@ -17,6 +17,7 @@ import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
@@ -47,10 +48,20 @@ public class KxsUserAmountLogServiceImpl extends ServiceImpl<KxsUserAmountLogMap
         KxsUserAmountLog userAmountLog = new KxsUserAmountLog();
         userAmountLog.setId(id);
 
+        String tradeMonth;
+        if(fieldDataMap.get("CreateDate") != null){
+            LocalDateTime createTime = LocalDateTimeUtil.parse(fieldDataMap.get("CreateDate").toString(), DatePattern.NORM_DATETIME_PATTERN);
+            tradeMonth = LocalDateTimeUtil.format(createTime, DatePattern.SIMPLE_MONTH_PATTERN);
+        }else{
+            tradeMonth = MonthTableNameHandler.getThisMoth();
+        }
+        //每个请求线程维护一个month数据，避免多线程数据冲突
+        MonthTableNameHandler.setData(tradeMonth);
+
+
         //操作类型
         OperationType operation = dmlData.getOperation();
         if (operation.equals(OperationType.DELETE)) {
-            MonthTableNameHandler.setData(MonthTableNameHandler.getThisMoth());
             // 删除数据
             baseMapper.deleteById(id);
             //删除线程，避免线程污染
@@ -102,8 +113,6 @@ public class KxsUserAmountLogServiceImpl extends ServiceImpl<KxsUserAmountLogMap
                     break;
             }
         }
-        //分表月份
-        MonthTableNameHandler.setData(MonthTableNameHandler.getThisMoth());
         if (operation.equals(OperationType.UPDATE)) {
             // 更新数据
             baseMapper.updateById(userAmountLog);