feat(综合搜索)：增量更新

amos-boot-system-tzs/amos-boot-module-common/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/refresh/listener/DataRefreshListener.java

@@ -68,11 +68,7 @@ public class DataRefreshListener {
         TzsDataRefreshMessage message = new TzsDataRefreshMessage();
         try {
             // 1.记录 message
-            message.setDataId(event.getDataId());
-            message.setDataType(event.getDataType());
-            message.setOperation(event.getOperation().name());
-            message.setStatus(Constants.REFRESH_STATUS_DEALING); // 流程中
-            tzsDataRefreshMessageService.save(message);
+            createMsg(event, message);
             // 2.调用更新处理
             dataRefreshService.ifPresent(service -> service.doDispatch(message));
         } catch (Exception e) {
@@ -81,4 +77,12 @@ public class DataRefreshListener {
             tzsDataRefreshMessageService.saveOrUpdate(message);
         }
     }
+
+    private void createMsg(DataRefreshEvent event, TzsDataRefreshMessage message) {
+        message.setDataId(event.getDataId());
+        message.setDataType(event.getDataType());
+        message.setOperation(event.getOperation().name());
+        message.setStatus(Constants.REFRESH_STATUS_DEALING); // 流程中
+        tzsDataRefreshMessageService.save(message);
+    }
 }