解决重复调用影像

order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java

@@ -465,6 +465,7 @@ public class PushInvoiceServiceImpl implements PushInvoiceService {
 //            this.openTextUploadFile(fpTsMqData,shList);
 
             //多个地址循环推送
+            boolean flag = true;
             for (PushInfo pushInfo : pushInfoList) {
 
                 if (StringUtils.isBlank(pushInfo.getPushUrl())) {
@@ -482,17 +483,21 @@ public class PushInvoiceServiceImpl implements PushInvoiceService {
                     failPush(null,JsonUtils.getInstance().toJsonString(fpTsMqData),error,error,pushInfo,fpTsMqData.getPushType());
                     break;
                 }
-                try {
-                    //推送影像系统
-                    sendImageSys(content,fpTsMqData.getPushType(),pushInfo, null);
-                } catch (Exception e) {
-                    String error=String.format("影像推送出现异常%s,推送类型%s",e,fpTsMqData.getPushType());
-                    log.error(error);
-                    PushInfo pushInfo1 = new PushInfo();
-                    pushInfo1.setId(pushInfo.getId());
-                    pushInfo1.setByzd1("YXXT");
-                    failPush(null,content,error,e.getMessage(),pushInfo1,fpTsMqData.getPushType());
-                    e.printStackTrace();
+                if(flag){
+                    try {
+                        //推送影像系统
+                        sendImageSys(content,fpTsMqData.getPushType(),pushInfo, null);
+                        flag = false;
+                    } catch (Exception e) {
+                        flag = false;
+                        String error=String.format("影像推送出现异常%s,推送类型%s",e,fpTsMqData.getPushType());
+                        log.error(error);
+                        PushInfo pushInfo1 = new PushInfo();
+                        pushInfo1.setId(pushInfo.getId());
+                        pushInfo1.setByzd1("YXXT");
+                        failPush(null,content,error,e.getMessage(),pushInfo1,fpTsMqData.getPushType());
+                        e.printStackTrace();
+                    }
                 }
                 OrderProcessInfo orderProcessInfo = null;
                 Map<String, String> requestMap = commonDisposeService.getRequestParameter(pushInfo.getNsrsbh(), pushInfo.getZipCode(), pushInfo.getEncryptCode(), content, pushInfo.getPushUrl(), pushInfo.getInterfaceType(), pushInfo.getVersionIdent());