WmScorePackageSettleNoteHandler补充ignoreDeptId

canal-console/src/main/java/com/retdata/canal/handler/WmScorePackageSettleNoteHandler.java

@@ -30,11 +30,21 @@ public class WmScorePackageSettleNoteHandler extends AbstractCanalDbHandler {
             List<CanalEntry.Column> columns = rowData.getBeforeColumnsList();
 
             String valId = "";
+            boolean ignoreDeptId = false;
             for (CanalEntry.Column column : columns) {
                 if (column.getName().equals("id")) {
                     valId = column.getValue();
+                } else if (column.getName().equals("settle_dept_id")) {
+                    if (ignoreDeptId(dataSourceEnum, column.getValue(), column)) {
+                        ignoreDeptId = true;
+                    }
                 }
             }
+
+            if (ignoreDeptId) {
+                return;
+            }
+
             LambdaQueryWrapper<WmScorePackageSettleNote> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper
                     .eq(WmScorePackageSettleNote::getId, valId)
@@ -46,12 +56,21 @@ public class WmScorePackageSettleNoteHandler extends AbstractCanalDbHandler {
             String jsonStr = columnsToJson(afterColumns);
 
             String valId = "";
+            boolean ignoreDeptId = false;
             for (CanalEntry.Column column : afterColumns) {
                 if (column.getName().equals("id")) {
                     valId = column.getValue();
-                    break;
+                } else if (column.getName().equals("settle_dept_id")) {
+                    if (ignoreDeptId(dataSourceEnum, column.getValue(), column)) {
+                        ignoreDeptId = true;
+                    }
                 }
             }
+
+            if (ignoreDeptId) {
+                return;
+            }
+
             LambdaQueryWrapper<WmScorePackageSettleNote> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper.eq(WmScorePackageSettleNote::getId, valId)
                     .eq(WmScorePackageSettleNote::getDbSourceId, valSource);