From 2ba81296daf787d2e1e90e6f7242098ef55276c8 Mon Sep 17 00:00:00 2001
From: super_liu <396572590@qq.com>
Date: Mon, 26 Jul 2021 09:51:12 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=A0=87=E5=87=86=E5=BA=93MQ?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/SarStandardsInfoServiceImpl.java     | 70 ++++++++++---------
 1 file changed, 37 insertions(+), 33 deletions(-)

diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java
index c3e1a681..0af77f7f 100644
--- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java
+++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java
@@ -6,6 +6,7 @@ import com.adc.da.att.vo.AttFileVo;
 import com.adc.da.common.*;
 import com.adc.da.http.ResponseMessage;
 import com.adc.da.http.Result;
+import com.adc.da.mq.service.CreateStandMQService;
 import com.adc.da.person.dao.PersonCollectEODao;
 import com.adc.da.person.dao.PersonShareEODao;
 import com.adc.da.person.entity.PersonMsgEO;
@@ -171,6 +172,9 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl<SarStandardsInfoDao
     @Autowired
     private ITsResourceService iTsResourceService;
 
+    @Autowired
+    private CreateStandMQService createStandMQService;
+
 
     /***
      * @Description: 分页查询
@@ -996,39 +1000,39 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl<SarStandardsInfoDao
 //        replaseStandState(sarStandardsInfoEO);
         // 记录修改日志
         saveUpdateLog(sarStandardsInfoEO, beforeSarStandardsInfo);
-//        if(elasflag) {
-//            createStandMQService.sendStandMQ(sarStandardsInfoEO,"update");
-//            List<String> bhs = new ArrayList<>(Arrays.asList(String.valueOf(map.get("DTBJH")).split(",")));
-//            for (String bh :bhs) {
-//                SarStandardsInfoEOPage page = new SarStandardsInfoEOPage();
-//                int countStand = 10000;
-//                int countSuccess = 0;
-//                page.setValidFlag("0");
-//                page.setPageSize(countStand);
-//                page.setMenuId("nomenu");
-//                page.setStandType("ALL");
-//                page.setStandNumber(bh);
-//                List<SarStandardsInfo> rowsStand = dao.selectStandardsInfoBynumber(page);
-//                for (SarStandardsInfo sarStandardsInfo : rowsStand) {
-//                    List<SarStandardsInfo> sarStandardsInfoEOS = new ArrayList<>();
-//                    sarStandardsInfoEOS.add(sarStandardsInfo);
-//                    attrInfo(sarStandardsInfoEOS);
-//                    if (sarStandardsInfoEOS.size()>0) {
-//                        sarStandardsInfo = sarStandardsInfoEOS.get(0);
-//                        countSuccess++;
-//                        if (sarStandardsInfo.getAttrInfoMap() != null) {
-//                            if (sarStandardsInfo.getAttrInfoMap().containsKey("BDTBZBH")){
-//                                String bdtbh = String.valueOf(sarStandardsInfo.getAttrInfoMap().get("BDTBZBH"));
-//                                sarStandardsInfo.getAttrInfoMap().put("BDTBH", bdtbh);
-//                                sarStandardsInfo.setSarStandAttrEOStr(com.alibaba.fastjson.JSONObject.toJSONString(sarStandardsInfo.getAttrInfoMap()));
-//                            }
-//
-//                        }
-//                        createStandMQService.sendStandMQ(sarStandardsInfo, "update");
-//                    }
-//                }
-//            }
-//        }
+        if(elasflag) {
+            createStandMQService.sendStandMQ(sarStandardsInfoEO,"update");
+            List<String> bhs = new ArrayList<>(Arrays.asList(String.valueOf(map.get("DTBJH")).split(",")));
+            for (String bh :bhs) {
+                SarStandardsInfoEOPage page = new SarStandardsInfoEOPage();
+                int countStand = 10000;
+                int countSuccess = 0;
+                page.setValidFlag("0");
+                page.setPageSize(countStand);
+                page.setMenuId("nomenu");
+                page.setStandType("ALL");
+                page.setStandNumber(bh);
+                List<SarStandardsInfo> rowsStand = dao.selectStandardsInfoBynumber(page);
+                for (SarStandardsInfo sarStandardsInfo : rowsStand) {
+                    List<SarStandardsInfo> sarStandardsInfoEOS = new ArrayList<>();
+                    sarStandardsInfoEOS.add(sarStandardsInfo);
+                    attrInfo(sarStandardsInfoEOS);
+                    if (sarStandardsInfoEOS.size()>0) {
+                        sarStandardsInfo = sarStandardsInfoEOS.get(0);
+                        countSuccess++;
+                        if (sarStandardsInfo.getAttrInfoMap() != null) {
+                            if (sarStandardsInfo.getAttrInfoMap().containsKey("BDTBZBH")){
+                                String bdtbh = String.valueOf(sarStandardsInfo.getAttrInfoMap().get("BDTBZBH"));
+                                sarStandardsInfo.getAttrInfoMap().put("BDTBH", bdtbh);
+                                sarStandardsInfo.setSarStandAttrEOStr(com.alibaba.fastjson.JSONObject.toJSONString(sarStandardsInfo.getAttrInfoMap()));
+                            }
+
+                        }
+                        createStandMQService.sendStandMQ(sarStandardsInfo, "update");
+                    }
+                }
+            }
+        }
         return result;
     }