| | |
| | | import com.ruoyi.common.core.web.page.PageInfo; |
| | | import com.ruoyi.other.api.feignClient.RoleSiteClient; |
| | | import com.ruoyi.other.api.feignClient.UserSiteClient; |
| | | import com.ruoyi.system.api.domain.SysRole; |
| | | import com.ruoyi.system.api.domain.SysUser; |
| | | import com.ruoyi.system.api.feignClient.SysRoleClient; |
| | | import com.ruoyi.system.api.feignClient.SysUserClient; |
| | | import com.ruoyi.system.api.feignClient.SysUserRoleClient; |
| | | import com.ruoyi.system.api.model.GetSysRoleByIds; |
| | | import com.ruoyi.system.api.model.SysUserRoleVo; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | |
| | | */ |
| | | @Service |
| | | public class PartnerServiceImpl extends ServiceImpl<PartnerMapper, Partner> implements IPartnerService { |
| | | |
| | | @Resource |
| | | private SysRoleClient sysRoleClient; |
| | | |
| | | @Resource |
| | | private SysUserClient sysUserClient; |
| | |
| | | public PageInfo<PartnerListDTO> getPartnerList(GetPartnerList partnerList) { |
| | | PageInfo<PartnerListDTO> pageInfo = new PageInfo(partnerList.getPageCurr(), partnerList.getPageSize()); |
| | | List<PartnerListDTO> list = this.baseMapper.getPartnerList(pageInfo, partnerList); |
| | | List<Integer> roleIds = list.stream().map(PartnerListDTO::getRoleId).collect(Collectors.toList()); |
| | | GetSysRoleByIds ids = new GetSysRoleByIds(); |
| | | ids.setIds(roleIds); |
| | | //获取相关的角色id |
| | | R<List<SysRole>> r = sysRoleClient.getSysRoleByIds(ids); |
| | | if(r.getCode() != 200){ |
| | | throw new RuntimeException(r.getMsg()); |
| | | } |
| | | List<SysRole> data = r.getData(); |
| | | for (PartnerListDTO partnerListDTO : list) { |
| | | Integer roleId = partnerListDTO.getRoleId(); |
| | | if(null == roleId){ |
| | | continue; |
| | | } |
| | | SysRole sysRole = data.stream().filter(s -> roleId.compareTo(s.getRoleId().intValue()) == 0).findFirst().get(); |
| | | if(null != sysRole){ |
| | | partnerListDTO.setRoleName(sysRole.getRoleName()); |
| | | } |
| | | } |
| | | pageInfo.setRecords(list); |
| | | return pageInfo; |
| | | } |
| | |
| | | if(ajaxResult.isError()){ |
| | | return ajaxResult; |
| | | } |
| | | assignDefaultRole(partner); |
| | | Partner one = this.getOne(new LambdaQueryWrapper<Partner>() |
| | | .eq(Partner::getCode, partner.getCode()) |
| | | .eq(Partner::getDelFlag, 0) |
| | |
| | | if(StringUtils.isEmpty(partner.getName())){ |
| | | return AjaxResult.error("合作商名称不能为空"); |
| | | } |
| | | if(null == partner.getRoleId()){ |
| | | return AjaxResult.error("合作商角色不能为空"); |
| | | if(null == partner.getPartnerType()){ |
| | | return AjaxResult.error("合作商类型不能为空"); |
| | | } |
| | | if(StringUtils.isEmpty(partner.getPhoneOne())){ |
| | | return AjaxResult.error("合作商电话1不能为空"); |
| | |
| | | */ |
| | | @Override |
| | | public Partner getPartner(Integer id) { |
| | | Partner partner = this.getById(id); |
| | | if(null == partner){ |
| | | return partner; |
| | | } |
| | | GetSysRoleByIds ids = new GetSysRoleByIds(); |
| | | ids.setIds(Arrays.asList(partner.getRoleId())); |
| | | //获取相关的角色id |
| | | R<List<SysRole>> r = sysRoleClient.getSysRoleByIds(ids); |
| | | if(r.getCode() != 200){ |
| | | throw new RuntimeException(r.getMsg()); |
| | | } |
| | | List<SysRole> data = r.getData(); |
| | | if(data.size() > 0){ |
| | | partner.setRoleName(data.get(0).getRoleName()); |
| | | } |
| | | return partner; |
| | | return this.getById(id); |
| | | } |
| | | |
| | | |
| | |
| | | if(ajaxResult.isError()){ |
| | | return ajaxResult; |
| | | } |
| | | assignDefaultRole(partner); |
| | | Partner one = this.getOne(new LambdaQueryWrapper<Partner>() |
| | | .eq(Partner::getCode, partner.getCode()) |
| | | .eq(Partner::getDelFlag, 0) |
| | |
| | | } |
| | | Partner oldPartner = this.getById(partner.getId()); |
| | | SysUser user = sysUserClient.queryUserByUserName(oldPartner.getAccount()).getData(); |
| | | if(StringUtils.isEmpty(partner.getPassword())){ |
| | | partner.setPassword(oldPartner.getPassword()); |
| | | } |
| | | //修改登录账户 |
| | | if(null == user){ |
| | | user = new SysUser(); |
| | |
| | | user.setUserName(partner.getAccount()); |
| | | user.setNickName(partner.getName()); |
| | | user.setAvatar(partner.getLogoUrl()); |
| | | user.setPassword(partner.getPassword()); |
| | | if(StringUtils.isNotEmpty(partner.getPassword())){ |
| | | user.setPassword(partner.getPassword()); |
| | | user.setPassWordUpdate(new Date()); |
| | | } |
| | | user.setRoleId(partner.getRoleId().longValue()); |
| | | user.setPassWordUpdate(new Date()); |
| | | R r = sysUserClient.updateSysUser(user); |
| | | if(200 != r.getCode()){ |
| | | throw new RuntimeException(r.getMsg()); |
| | |
| | | } |
| | | |
| | | |
| | | private void assignDefaultRole(Partner partner) { |
| | | String roleName = partnerTypeRoleName(partner.getPartnerType()); |
| | | Integer roleId = this.baseMapper.getDefaultPartnerRoleId(roleName); |
| | | if (roleId == null) { |
| | | throw new RuntimeException("系统内置角色【" + roleName + "】不存在,请先配置角色"); |
| | | } |
| | | partner.setRoleId(roleId); |
| | | } |
| | | |
| | | private String partnerTypeRoleName(Integer partnerType) { |
| | | if (Integer.valueOf(2).equals(partnerType)) { |
| | | return "场地方"; |
| | | } |
| | | if (Integer.valueOf(3).equals(partnerType)) { |
| | | return "服务商"; |
| | | } |
| | | return "合作商"; |
| | | } |
| | | /** |
| | | * 删除合作商 |
| | | * @param ids 合作商id |