交易额同步数据过滤删除

kxs-transfer/src/main/java/com/kxs/transfer/api/service/stat/KxsUserTradeAfterService.java

@@ -1,5 +1,6 @@
 package com.kxs.transfer.api.service.stat;
 
+import com.aliyun.dts.subscribe.clients.record.OperationType;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.kxs.common.mybatis.handler.MonthTableNameHandler;
@@ -30,8 +31,10 @@ public class KxsUserTradeAfterService extends ServiceImpl<KxsUserTradeAfterMappe
         Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
         //修改的字段
         List<String> changeFieldList = dmlData.getChangeFieldList();
-        //操作的主键
-        int id = Integer.parseInt(dmlData.getId());
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            return;
+        }
 
         KxsUserTradeAfter userTrade = new KxsUserTradeAfter();
 
@@ -128,8 +131,10 @@ public class KxsUserTradeAfterService extends ServiceImpl<KxsUserTradeAfterMappe
         Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
         //修改的字段
         List<String> changeFieldList = dmlData.getChangeFieldList();
-        //操作的主键
-        int id = Integer.parseInt(dmlData.getId());
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            return;
+        }
 
         KxsUserTradeAfter userTrade = new KxsUserTradeAfter();
 

kxs-transfer/src/main/java/com/kxs/transfer/api/service/stat/KxsUserTradeBeforeService.java

@@ -1,5 +1,6 @@
 package com.kxs.transfer.api.service.stat;
 
+import com.aliyun.dts.subscribe.clients.record.OperationType;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.kxs.common.mybatis.handler.MonthTableNameHandler;
@@ -29,9 +30,10 @@ public class KxsUserTradeBeforeService extends ServiceImpl<KxsUserTradeBeforeMap
         Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
         //修改的字段
         List<String> changeFieldList = dmlData.getChangeFieldList();
-        //操作的主键
-        int id = Integer.parseInt(dmlData.getId());
-
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            return;
+        }
         KxsUserTradeBefore userTrade = new KxsUserTradeBefore();
 
         String tradeMonth;
@@ -127,8 +129,10 @@ public class KxsUserTradeBeforeService extends ServiceImpl<KxsUserTradeBeforeMap
         Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
         //修改的字段
         List<String> changeFieldList = dmlData.getChangeFieldList();
-        //操作的主键
-        int id = Integer.parseInt(dmlData.getId());
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            return;
+        }
 
         KxsUserTradeBefore userTrade = new KxsUserTradeBefore();
 

kxs-transfer/src/main/java/com/kxs/transfer/api/service/stat/KxsUserTradeService.java

@@ -30,8 +30,11 @@ public class KxsUserTradeService extends ServiceImpl<KxsUserTradeMapper, KxsUser
         Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
         //修改的字段
         List<String> changeFieldList = dmlData.getChangeFieldList();
-        //操作的主键
-        int id = Integer.parseInt(dmlData.getId());
+
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            return;
+        }
 
         KxsUserTrade userTrade = new KxsUserTrade();
 
@@ -128,8 +131,10 @@ public class KxsUserTradeService extends ServiceImpl<KxsUserTradeMapper, KxsUser
         Map<String, FieldData> fieldDataMap = dmlData.getFieldDataMap();
         //修改的字段
         List<String> changeFieldList = dmlData.getChangeFieldList();
-        //操作的主键
-        int id = Integer.parseInt(dmlData.getId());
+        OperationType operation = dmlData.getOperation();
+        if(operation.equals(OperationType.DELETE)){
+            return;
+        }
 
         KxsUserTrade userTrade = new KxsUserTrade();