群发

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/controller/content/QwMessageController.java

@@ -21,7 +21,9 @@ import com.gic.haoban.app.customer.dto.CustomerDTO;
 import com.gic.haoban.app.customer.dto.MemberInfoListParamsDTO;
 import com.gic.haoban.app.customer.service.api.service.DistributeApiService;
 import com.gic.haoban.common.utils.EntityUtil;
+import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
 import com.gic.haoban.manage.api.service.StaffApiService;
+import com.gic.haoban.manage.api.service.StaffClerkRelationApiService;
 import com.gic.haoban.manage.web.controller.WebBaseController;
 import com.gic.haoban.manage.web.qo.CustomerQO;
 import com.gic.haoban.manage.web.utils.ClerkUtils;
@@ -35,6 +37,8 @@ public class QwMessageController extends WebBaseController {
     private StaffApiService staffApiService;
     @Autowired
     private ClerkService clerkService;
+    @Autowired
+    private StaffClerkRelationApiService staffClerkRelationApiService ;
 
     /**
      *  群发-分享
@@ -64,8 +68,12 @@ public class QwMessageController extends WebBaseController {
         List<String> staffIdList = new ArrayList<>();
         if (clerk.getClerkType() == 1) {
             staffIdList = staffApiService.listBindStaffId(storeId);
+            logger.info("店长,成员数={}",staffIdList);
         } else if(clerk.getClerkType()==0) {
-            staffIdList.add(clerkId);
+            StaffClerkRelationDTO dto = this.staffClerkRelationApiService.getOneByClerkId(clerkId) ;
+            if(null != dto) {
+                staffIdList.add(dto.getStaffId());
+            }
         }
         if(CollectionUtils.isEmpty(staffIdList)) {
             return RestResponse.failure("-1","无成员数据");