加成员新增同步群

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

@@ -10,9 +10,11 @@ import com.gic.commons.util.UniqueIdUtils;
 import com.gic.content.api.service.ContentProducerApiService;
 import com.gic.haoban.app.customer.service.api.service.InnerApiService;
 import com.gic.haoban.common.utils.StringUtil;
+import com.gic.haoban.manage.api.dto.CommonMQDTO;
 import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
 import com.gic.haoban.manage.api.dto.StaffDTO;
 import com.gic.haoban.manage.api.enums.ChannelCodeEnum;
+import com.gic.haoban.manage.api.service.HaobanCommonMQApiService;
 import com.gic.haoban.manage.api.service.StaffClerkRelationApiService;
 import com.gic.haoban.manage.api.service.hm.HmQrcodeApiService;
 import com.gic.haoban.manage.service.config.Config;
@@ -78,6 +80,8 @@ public class StaffServiceImpl implements StaffService {
     private StaffClerkRelationApiService staffClerkRelationApiService ;
     @Autowired
     private StaffDepartmentRelatedService staffDepartmentRelatedService ;
+    @Autowired
+    private HaobanCommonMQApiService haobanCommonMQApiService ;
 
     @Override
     public TabHaobanStaff selectById(String id) {
@@ -113,6 +117,12 @@ public class StaffServiceImpl implements StaffService {
             return staff.getStaffId() ;
         }
         mapper.insertSelective(tab);
+        CommonMQDTO mq = new CommonMQDTO() ;
+        mq.setType(11) ;
+        Map<String,String> map = new HashMap<>() ;
+        map.put("staffId",tab.getStaffId()) ;
+        mq.setParams(map);
+        this.haobanCommonMQApiService.putCommonDelayMessage(mq, 10);
         RedisUtil.unlock(lockKey);
         return tab.getStaffId();
     }

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

@@ -12,6 +12,7 @@ import com.gic.commons.util.StringUtil;
 import com.gic.haoban.manage.api.dto.MemberUnionidWechatAccountQDTO;
 import com.gic.haoban.manage.api.service.ExternalClerkRelatedApiService;
 import com.gic.haoban.manage.service.service.chat.GroupChatPlanService;
+import com.gic.haoban.manage.service.service.chat.GroupChatService;
 import com.gic.haoban.manage.service.service.moment.QwMomentPlanAttendService;
 import com.gic.haoban.manage.service.service.moment.QwMomentPlanService;
 import com.gic.haoban.manage.service.service.role.HaobanMenuService;
@@ -65,6 +66,8 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
     private QwMomentPlanService qwMomentPlanService ;
     @Autowired
     private QwMomentPlanAttendService qwMomentPlanAttendService;
+    @Autowired
+    private GroupChatService groupChatService ;
 
     @Override
     public void putCommonMessage(CommonMQDTO dto) {
@@ -178,6 +181,10 @@ public class HaobanCommonMQApiServiceImpl implements HaobanCommonMQApiService {
             Long planId10 = Long.valueOf(map.get("planId")) ;
             this.qwMomentPlanService.getQwData(planId10);
             break;
+        case 11 :
+            String staffId11 = map.get("staffId") ;
+            this.groupChatService.initStaffGroupChat(staffId11);
+            break;
         default:
             break;
         }