导购任务-通知

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/MemberUnionidRelatedApiServiceImpl.java

@@ -867,6 +867,19 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
      * 欧泊莱定制需求
      */
     private void addDelFriendEvent(String unionId, String clerkId, String wxEnterpriseId, String enterpriseId, String memberId, String storeId, Integer changeType) {
+        GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+        if(changeType==1) {
+            log.info("加好友通知={}",memberId);
+            JSONObject json  = new JSONObject() ;
+            json.put("enterpriseId",enterpriseId) ;
+            json.put("clerkId",clerkId) ;
+            json.put("memberId",memberId) ;
+            try {
+                clientInstance.sendMessage("qywxAddFriendEvent", json.toJSONString());
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+        }
         String addDelFriendEvent = config.getAddDelFriendEvent();
         if (!addDelFriendEvent.contains(wxEnterpriseId)) {
             log.info("非定制，无需广播通知");
@@ -886,7 +899,6 @@ public class MemberUnionidRelatedApiServiceImpl implements MemberUnionidRelatedA
             log.info("会员不存在:{}", memberId);
             return;
         }
-        GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
         try {
             JSONObject msgBody = new JSONObject();
             msgBody.put("cardNo", member.getCardNum());