添加绑定销售校验

fs-service/src/main/java/com/fs/activity/service/AccActivityService.java

@@ -73,4 +73,6 @@ public interface AccActivityService extends IService<AccActivity> {
     R updateActivityShow(Long activityId, long userId);
 
     R imMsg(AccTeam accWork);
+
+    R checkBindCompanyUser(Long leaderId);
 }

fs-service/src/main/java/com/fs/activity/service/impl/AccActivityServiceImpl.java

@@ -7,6 +7,8 @@ import com.fs.activity.domain.AccWork;
 import com.fs.activity.service.AccActivityService;
 import com.fs.activity.mapper.AccActivityMapper;
 import com.fs.common.core.domain.R;
+import com.fs.course.domain.FsUserCompanyUser;
+import com.fs.course.mapper.FsUserCompanyUserMapper;
 import com.fs.gtPush.service.uniPush2Service;
 import com.fs.his.enums.PushLogDesTypeEnum;
 import com.fs.im.service.OpenIMService;
@@ -36,6 +38,9 @@ public class AccActivityServiceImpl extends ServiceImpl<AccActivityMapper, AccAc
     @Autowired
     private OpenIMService openIMService;
 
+    @Autowired
+    private FsUserCompanyUserMapper fsUserCompanyUserMapper;
+
     @Autowired
     private RedisTemplate redisTemplate;
 
@@ -215,6 +220,27 @@ public class AccActivityServiceImpl extends ServiceImpl<AccActivityMapper, AccAc
         return null;
     }
 
+    /**
+     * @Description: 检查用户是否已经绑定销售
+     * @Param:
+     * @Return:
+     * @Author xgb
+     * @Date 2026/3/12 14:16
+     */
+
+    @Override
+    public R checkBindCompanyUser(Long userId) {
+
+        FsUserCompanyUser companyUser = new FsUserCompanyUser();
+        companyUser.setUserId(userId);
+        companyUser.setStatus(1);
+        List<FsUserCompanyUser> users=fsUserCompanyUserMapper.selectFsUserCompanyUserList(companyUser);
+        if(users== null || users.isEmpty()){
+            return R.error("请先添加销售app好友");
+        }
+        return R.ok();
+    }
+
 
 }
 

fs-service/src/main/java/com/fs/activity/service/impl/AccTeamServiceImpl.java

@@ -67,12 +67,18 @@ public class AccTeamServiceImpl extends ServiceImpl<AccTeamMapper, AccTeam>
     @Transactional
     public R signUpLeader(AccTeam accTeam) {
 
-
+        // 1.检查活动状态
         R r=accActivityService.checkActivitySignUpStatus(accTeam.getActivityId());
         if(!r.get("code").equals(200)){
             return r;
         }
 
+        // 2.检查是否绑定销售
+        r=accActivityService.checkBindCompanyUser(accTeam.getLeaderId());
+        if(!r.get("code").equals(200)){
+            return r;
+        }
+
         accTeam.setTeamCode(CodeGenerator.generateTeamCode(accTeam.getActivityId()));
         accTeam.setMemberCount(1);
         if(baseMapper.insert(accTeam)<=0){
@@ -114,6 +120,12 @@ public class AccTeamServiceImpl extends ServiceImpl<AccTeamMapper, AccTeam>
             return r;
         }
 
+        // 2.检查是否绑定销售
+        r=accActivityService.checkBindCompanyUser(accTeam.getUserId());
+        if(!r.get("code").equals(200)){
+            return r;
+        }
+
         // 获取领队信息 更具队伍码
         AccTeam team=baseMapper.selectOne(new LambdaQueryWrapper<AccTeam>()
                 .eq(AccTeam::getTeamCode, accTeam.getTeamCode()));