增加一个居民信息导入的postProcessor

epmet-user/epmet-user-server/src/main/java/com/epmet/processor/ResiImportDyzxhPostProcessor.java

@@ -0,0 +1,13 @@
+package com.epmet.processor;
+
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+@Component
+public class ResiImportDyzxhPostProcessor extends ResiImportPostProcessor{
+    @Override
+    public void consume(Map<String, String> resiInfoMap) {
+        System.out.println(resiInfoMap);
+    }
+}

epmet-user/epmet-user-server/src/main/java/com/epmet/processor/ResiImportPostProcessor.java

@@ -0,0 +1,21 @@
+package com.epmet.processor;
+
+import java.util.Map;
+
+/**
+ * @Description 居民信息导入之后的处理方法
+ * @Author wangxianzhang
+ * @Time 2023/5/17 1:33 PM
+ */
+public abstract class ResiImportPostProcessor {
+
+    /**
+     * @Description: 居民信息导入之后的消费方法
+     * @param resiInfoMap: 居民信息map
+     * @Return void
+     * @Author: wangxianzhang
+     * @Date: 2023/5/17 1:33 PM
+     */
+    public abstract void consume(Map<String, String> resiInfoMap);
+
+}

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java

@@ -46,6 +46,7 @@ import com.epmet.enums.IcResiUserTableEnum;
 import com.epmet.excel.handler.IcResiImportDynamicExcelListener;
 import com.epmet.excel.handler.IcResiVirtualSheetImportListener;
 import com.epmet.feign.*;
+import com.epmet.processor.ResiImportPostProcessor;
 import com.epmet.resi.partymember.feign.ResiPartyMemberOpenFeignClient;
 import com.epmet.send.SendMqMsgUtil;
 import com.epmet.service.IcResiUserImportService;
@@ -170,6 +171,8 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
     private IcPartyMemberDao icPartyMemberDao;
     @Autowired
     private EpmetMessageOpenFeignClient epmetMessageOpenFeignClient;
+    @Autowired
+    private List<ResiImportPostProcessor> resiImportPostProcessors;
 
     /**
      * 子表中不需要的列。因为主表中需要身份证号，网格等信息，但子表中不需要这些列必填，只要有身份证号即可，因此字表判断的时候需要排除这些列
@@ -584,6 +587,9 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
                     categoryData = null;
                 }
 
+                // 居民信息导入后置处理器回调
+                resiImportPostProcessors.forEach(p -> p.consume(columnAndValues));
+
             } catch (Exception e) {
                 String errorMsg;
 
@@ -1040,7 +1046,9 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
                         superOptions = new HashMap<>();
                         superOptions.put(superColumnValue, options);
                         itemIdAndOptionsCache.put(currentItemId, superOptions);
-
+                        if (options == null) {
+                            System.out.println(options);
+                        }
                         String colValue = options.get(cellContent);
                         columnWrapper.setColValue(colValue);
                     }