refact(3库刷新) ：优化

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

@@ -25,10 +25,11 @@ public class DataRefreshDispatcher implements IDataRefreshDispatch {
     @Async
     public void doDispatch(List<IDataRefreshHandler> dataRefreshHandlers, List<TzsDataRefreshMessage> messages) {
         int total = dataRefreshHandlers.size();
-        dataRefreshHandlers.forEach(dataRefreshHandler -> {
         messages.parallelStream().forEach(message -> {
             try {
                 message.setDistributions(total);
+                dataRefreshHandlers.forEach(dataRefreshHandler -> {
+                    try {
                         dataRefreshHandler.doRefresh(message);
                         markRefreshSuccess(message, dataRefreshHandler);
                     } catch (Exception e) {
@@ -36,6 +37,10 @@ public class DataRefreshDispatcher implements IDataRefreshDispatch {
                         markRefreshFailure(message, dataRefreshHandler, e);
                     }
                 });
+                doUpdateMessage(message);
+            } catch (Exception e) {
+                log.error("3库数据刷新,写入数据库失败,消息:{}", message, e);
+            }
         });
     }
 
@@ -46,17 +51,15 @@ public class DataRefreshDispatcher implements IDataRefreshDispatch {
 
     private void markRefreshSuccess(TzsDataRefreshMessage message, IDataRefreshHandler dataRefreshHandler) {
         message.setSuccessDistributionHandler(message.getSuccessDistributionHandler() == null ? dataRefreshHandler.getClass().getSimpleName() : message.getSuccessDistributionHandler() + ";" + dataRefreshHandler.getClass().getSimpleName());
-        updateMessageStatus(message);
     }
 
     private void markRefreshFailure(TzsDataRefreshMessage message, IDataRefreshHandler dataRefreshHandler, Exception e) {
         message.setErrorMsg(buildErrorMsg(dataRefreshHandler, message, e));
         message.setFailedDistributions(message.getFailedDistributions() == null ? 1 : message.getFailedDistributions() + 1);
-        updateMessageStatus(message);
     }
 
 
-    private void updateMessageStatus(TzsDataRefreshMessage message) {
+    private void doUpdateMessage(TzsDataRefreshMessage message) {
         message.setRecDate(new Date());
         refreshMessageService.saveOrUpdate(message);
     }