经销商邀请

mp-admin/src/main/java/com/qs/mp/web/controller/api/channel/ChannelInviteController.java

@@ -2,6 +2,7 @@ package com.qs.mp.web.controller.api.channel;
 
 import cn.jsms.api.ValidSMSResult;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.qs.mp.channel.domain.Channel;
 import com.qs.mp.channel.domain.param.ChannelInviteParam;
 import com.qs.mp.channel.service.IChannelService;
@@ -82,7 +83,10 @@ public class ChannelInviteController extends BaseApiController {
 		if (res == null || !res.getIsValid()) {
 			return error("短信验证码错误");
 		}
-
+		int cnt = channelService.count(new LambdaQueryWrapper<Channel>().eq(Channel::getMobile, param.getMobile()));
+		if (cnt > 0) {
+			return error("手机号已存在");
+		}
 		// 创建经销商
 		Channel channel = new Channel();
 		channel.setChannelNo(parent.getChannelNo() + ".");

mp-service/src/main/java/com/qs/mp/channel/service/impl/ChannelServiceImpl.java

@@ -2,6 +2,7 @@ package com.qs.mp.channel.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.qs.mp.channel.domain.Channel;
 import com.qs.mp.channel.domain.vo.ChannelOperDataVO;
 import com.qs.mp.channel.domain.vo.ChannelVO;
@@ -18,8 +19,6 @@ import com.qs.mp.system.domain.SysUser;
 import com.qs.mp.system.service.ISysRoleService;
 import com.qs.mp.system.service.ISysUserService;
 import com.qs.mp.utils.SecurityUtils;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-
 import java.util.List;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -34,130 +33,136 @@ import org.springframework.transaction.annotation.Transactional;
  * @since 2022-03-02
  */
 @Service
-public class ChannelServiceImpl extends ServiceImpl<ChannelMapper, Channel> implements IChannelService {
-
-	@Autowired
-	private IChannelService channelService;
-
-	@Autowired
-	private IChannelUserRelService channelUserRelService;
-
-	@Autowired
-	private IChannelCommissionService channelCommissionService;
-
-    @Autowired
-    private ISysUserService userService;
-
-    @Autowired
-    private ISysRoleService roleService;
-
-	@Override
-	@Transactional
-	public void saveChannel(Channel channel, ChannelRoleEnum channelRole){
-		boolean res = channelService.save(channel);
-		if(res && null != channel.getChannelId()) {
-			channel.setChannelNo(channel.getChannelNo()+channel.getChannelId());
-		    // 获取默认的角色
-		    SysRole sysRole = roleService.selectDefaultRoleByType(
-						channelRole == ChannelRoleEnum.CHANNEL ? RoleTypeEnum.CHANNEL_ROLE.getValue() : RoleTypeEnum.SALESITE_ROLE.getValue());
-		    if (null == sysRole || null == sysRole.getRoleId()) {
-		      throw new ServiceException(
-		          "未设置默认角色，请联系管理员");
-		    }
-			// 生成用户
-			SysUser sysUser = new SysUser();
-			sysUser.setUserName(channel.getMobile());
-		    sysUser.setPhonenumber(channel.getMobile());
-		    sysUser.setNickName(channel.getMobile());
+public class ChannelServiceImpl extends ServiceImpl<ChannelMapper, Channel> implements
+    IChannelService {
+
+  @Autowired
+  private IChannelService channelService;
+
+  @Autowired
+  private IChannelUserRelService channelUserRelService;
+
+  @Autowired
+  private IChannelCommissionService channelCommissionService;
+
+  @Autowired
+  private ISysUserService userService;
+
+  @Autowired
+  private ISysRoleService roleService;
+
+  @Override
+  @Transactional
+  public void saveChannel(Channel channel, ChannelRoleEnum channelRole) {
+    boolean res = channelService.save(channel);
+    if (res && null != channel.getChannelId()) {
+      channel.setChannelNo(channel.getChannelNo() + channel.getChannelId());
+			SysUser sysUser = userService.selectUserByUserName(channel.getMobile());
+			if (null == sysUser) {
+				// 生成用户
+				sysUser = new SysUser();
+				sysUser.setUserName(channel.getMobile());
+				sysUser.setPhonenumber(channel.getMobile());
+				sysUser.setNickName(channel.getMobile());
 //		    sysUser.setDeptId(SecurityUtils.getDeptId());
 //			sysUser.setCreateBy(SecurityUtils.getUsername());
-			Long[] roleIds = new Long[1];
-			roleIds[0] = sysRole.getRoleId();
-		    sysUser.setRoleIds(roleIds);
-			int userNum = userService.insertUser(sysUser);
-		    if (userNum == 0 || null == sysUser.getUserId()) {
-		        throw new ServiceException("账号创建失败，请联系管理员");
-		    }
-		    channel.setUserId(sysUser.getUserId());
-		    boolean ures = channelService.updateById(channel);
-		    if(!ures) {
-		    	throw new ServiceException("请联系管理员");
-		    }
-		    // 4.发送账号创建成功短信
-			JSMSUtils.sendChannelActNotify(channel.getMobile());
-		}else {
-			throw new ServiceException("请联系管理员");
-		}
-	}
-
-
-	@Override
-	@Transactional
-	public void updateChannel(Channel channel, boolean mobileChange) {
-	    // 4.更新入库
-		 boolean editRes = channelService.updateById(channel);
-		 if(editRes && mobileChange
-				 && null != channel.getUserId()) {
-			 SysUser sysUser = new SysUser();
-			 sysUser.setUserId(channel.getUserId());
-			 sysUser.setUserName(channel.getMobile());
-			 sysUser.setPhonenumber(channel.getMobile());
-			 sysUser.setNickName(channel.getName());
-			 sysUser.setDeptId(SecurityUtils.getDeptId());
-			 int userNum = userService.updateUser(sysUser);
-			 if (userNum == 0 || null == sysUser.getUserId()) {
-		       throw new ServiceException("更新失败，请联系管理员");
-		     }
-			 // 发送账号更新成功短信
-		 }
-	}
-
-	@Override
-	public List<ChannelVO> selectChannelVoList(Wrapper<Channel> queryWrapper) {
-		return getBaseMapper().selectChannelVoList(queryWrapper);
-	}
-
-	@Override
-	public Channel getChannelByUserId(Long userId) {
-		return getBaseMapper().selectOne(new LambdaQueryWrapper<Channel>().eq(Channel::getUserId, userId));
-	}
-
-	@Override
-	public int getChannelSiteCnt(String channelNo) {
-		return getBaseMapper().getChannelSiteCnt(channelNo);
-	}
-
-	@Override
-	public ChannelVO getChannelVoById(Long channelId) {
-		return getBaseMapper().getChannelVoById(channelId);
-	}
-
-	@Override
-	public ChannelOperDataVO getChannelOperData(String channelNo, int days) {
-		ChannelOperDataVO channelOperData = new ChannelOperDataVO();
-		// 查询销售金额
-		channelOperData.setSaleAmt(channelCommissionService.getChannelSaleAmtCnt(channelNo, days));
-		// 查询佣金金额
-		channelOperData.setCommAmt(channelCommissionService.getChannelCommAmtCnt(channelNo, days));
-		// 查询新增用户数
-		int newUserCnt = channelUserRelService.getChannelNewUserCnt(channelNo, days);
-		channelOperData.setNewUserCnt(newUserCnt);
-		return channelOperData;
-	}
-
-
-	@Override
-	public ChannelOperDataVO getChannelTotalOperData(String channelNo) {
-		ChannelOperDataVO channelOperData = new ChannelOperDataVO();
-		// 查询销售金额
-		channelOperData.setSaleAmt(channelCommissionService.getChannelTotalSaleAmtCnt(channelNo));
-		// 查询佣金金额
-		channelOperData.setCommAmt(channelCommissionService.getChannelTotalCommAmtCnt(channelNo));
-		// 查询新增用户数
-		// int newUserCnt = channelUserRelService.getChannelNewUserCnt(channelNo, days);
-		// channelOperData.setNewUserCnt(newUserCnt);
-		return channelOperData;
-	}
+				// 获取默认的角色
+				SysRole sysRole = roleService.selectDefaultRoleByType(
+						channelRole == ChannelRoleEnum.CHANNEL ? RoleTypeEnum.CHANNEL_ROLE.getValue()
+								: RoleTypeEnum.SALESITE_ROLE.getValue());
+				if (null == sysRole || null == sysRole.getRoleId()) {
+					throw new ServiceException(
+							"未设置默认角色，请联系管理员");
+				}
+				Long[] roleIds = new Long[1];
+				roleIds[0] = sysRole.getRoleId();
+				sysUser.setRoleIds(roleIds);
+				int userNum = userService.insertUser(sysUser);
+				if (userNum == 0 || null == sysUser.getUserId()) {
+					throw new ServiceException("账号创建失败，请联系管理员");
+				}
+			}
+      channel.setUserId(sysUser.getUserId());
+      boolean ures = channelService.updateById(channel);
+      if (!ures) {
+        throw new ServiceException("请联系管理员");
+      }
+      // 4.发送账号创建成功短信
+      JSMSUtils.sendChannelActNotify(channel.getMobile());
+    } else {
+      throw new ServiceException("请联系管理员");
+    }
+  }
+
+
+  @Override
+  @Transactional
+  public void updateChannel(Channel channel, boolean mobileChange) {
+    // 4.更新入库
+    boolean editRes = channelService.updateById(channel);
+    if (editRes && mobileChange
+        && null != channel.getUserId()) {
+      SysUser sysUser = new SysUser();
+      sysUser.setUserId(channel.getUserId());
+      sysUser.setUserName(channel.getMobile());
+      sysUser.setPhonenumber(channel.getMobile());
+      sysUser.setNickName(channel.getName());
+      sysUser.setDeptId(SecurityUtils.getDeptId());
+      int userNum = userService.updateUser(sysUser);
+      if (userNum == 0 || null == sysUser.getUserId()) {
+        throw new ServiceException("更新失败，请联系管理员");
+      }
+      // 发送账号更新成功短信
+    }
+  }
+
+  @Override
+  public List<ChannelVO> selectChannelVoList(Wrapper<Channel> queryWrapper) {
+    return getBaseMapper().selectChannelVoList(queryWrapper);
+  }
+
+  @Override
+  public Channel getChannelByUserId(Long userId) {
+    return getBaseMapper().selectOne(
+        new LambdaQueryWrapper<Channel>().eq(Channel::getUserId, userId));
+  }
+
+  @Override
+  public int getChannelSiteCnt(String channelNo) {
+    return getBaseMapper().getChannelSiteCnt(channelNo);
+  }
+
+  @Override
+  public ChannelVO getChannelVoById(Long channelId) {
+    return getBaseMapper().getChannelVoById(channelId);
+  }
+
+  @Override
+  public ChannelOperDataVO getChannelOperData(String channelNo, int days) {
+    ChannelOperDataVO channelOperData = new ChannelOperDataVO();
+    // 查询销售金额
+    channelOperData.setSaleAmt(channelCommissionService.getChannelSaleAmtCnt(channelNo, days));
+    // 查询佣金金额
+    channelOperData.setCommAmt(channelCommissionService.getChannelCommAmtCnt(channelNo, days));
+    // 查询新增用户数
+    int newUserCnt = channelUserRelService.getChannelNewUserCnt(channelNo, days);
+    channelOperData.setNewUserCnt(newUserCnt);
+    return channelOperData;
+  }
+
+
+  @Override
+  public ChannelOperDataVO getChannelTotalOperData(String channelNo) {
+    ChannelOperDataVO channelOperData = new ChannelOperDataVO();
+    // 查询销售金额
+    channelOperData.setSaleAmt(channelCommissionService.getChannelTotalSaleAmtCnt(channelNo));
+    // 查询佣金金额
+    channelOperData.setCommAmt(channelCommissionService.getChannelTotalCommAmtCnt(channelNo));
+    // 查询新增用户数
+    // int newUserCnt = channelUserRelService.getChannelNewUserCnt(channelNo, days);
+    // channelOperData.setNewUserCnt(newUserCnt);
+    return channelOperData;
+  }
 
 
 }