|
|
|
@ -352,7 +352,7 @@ public class KtsGroupServiceImpl implements KtsGroupService { |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public KtsKtGroupMember addMember(GroupDto.AddMember dto) { |
|
|
|
public void addMember(GroupDto.AddMember dto) { |
|
|
|
LoginUser loginUser = SecurityUtils.getLoginUser(); |
|
|
|
//检查添加的成员是否是当前用户所属的合作单位
|
|
|
|
Long projOrgId = ObjectUtil.isNull(dto.getProjOrgId()) ? dto.getOrgId() : dto.getProjOrgId(); |
|
|
|
@ -361,72 +361,73 @@ public class KtsGroupServiceImpl implements KtsGroupService { |
|
|
|
}else if(!projOrgId.equals(loginUser.getUser().getOrgId())){ |
|
|
|
throw new BaseException("您无法在其他合作单位下添加或修改课题组成员"); |
|
|
|
} |
|
|
|
//添加课题组成员
|
|
|
|
KtsKtGroupMember ktsKtGroupMember = BeanUtil.copyProperties(dto, KtsKtGroupMember.class); |
|
|
|
ktsKtGroupMember.setEnrollTime(dto.getEnrollmentTime()); |
|
|
|
ktsKtGroupMember.setEnrollTime(dto.getEnrollmentTime()); |
|
|
|
if(dto.getType().contains("1")){ |
|
|
|
ktsKtGroupMember.setType("1"); |
|
|
|
}else { |
|
|
|
ktsKtGroupMember.setType("2"); |
|
|
|
} |
|
|
|
//id不为空则修改
|
|
|
|
if(ObjectUtil.isNotNull(dto.getId())){ |
|
|
|
//根据手机号查询课题组成员
|
|
|
|
KtsKtGroupMemberExample ktsKtGroupMemberExample = new KtsKtGroupMemberExample(); |
|
|
|
ktsKtGroupMemberExample.createCriteria() |
|
|
|
.andMemberPhoneEqualTo(dto.getMemberPhone()) |
|
|
|
.andKtGroupIdEqualTo(dto.getKtGroupId()) |
|
|
|
.andIdNotEqualTo(dto.getId()) |
|
|
|
.andDelFlagEqualTo((byte) 0); |
|
|
|
if(ktsKtGroupMemberMapper.countByExample(ktsKtGroupMemberExample) > 0){ |
|
|
|
throw new BaseException("该手机号已存在"); |
|
|
|
} |
|
|
|
//根据手机号查询用户
|
|
|
|
SysUser sysUser = sysUserService.selectUserByPhone(dto.getMemberPhone()); |
|
|
|
if (sysUser != null && "0".equals(sysUser.getDelFlag())) { |
|
|
|
//如果用户已存在,直接关联该用户
|
|
|
|
ktsKtGroupMember.setUserId(sysUser.getUserId()); |
|
|
|
} |
|
|
|
ktsKtGroupMemberMapper.updateByPrimaryKeySelective(ktsKtGroupMember); |
|
|
|
}else { |
|
|
|
//检查课题组id,没有且课题组名称不为空,则创建课题组信息
|
|
|
|
if (dto.getKtGroupId() == null && StrUtil.isNotEmpty(dto.getKtGroupName())) { |
|
|
|
GroupDto.Add add = new GroupDto.Add(); |
|
|
|
add.setKtGroupName(dto.getKtGroupName()); |
|
|
|
add.setProjId(dto.getProjId()); |
|
|
|
add.setProjOrgId(projOrgId); |
|
|
|
add.setIntro(dto.getKtGroupIntro()); |
|
|
|
add.setName(dto.getMemberName()); |
|
|
|
add.setPhone(dto.getMemberPhone()); |
|
|
|
add.setParentKtId(dto.getParentKtId()); |
|
|
|
KtsKtGroup add1 = add(add); |
|
|
|
ktsKtGroupMember.setKtGroupId(add1.getId()); |
|
|
|
for (Long ktGroupId : dto.getKtGroupId()) { |
|
|
|
//添加课题组成员
|
|
|
|
KtsKtGroupMember ktsKtGroupMember = BeanUtil.copyProperties(dto, KtsKtGroupMember.class); |
|
|
|
ktsKtGroupMember.setEnrollTime(dto.getEnrollmentTime()); |
|
|
|
ktsKtGroupMember.setEnrollTime(dto.getEnrollmentTime()); |
|
|
|
if (dto.getType().contains("1")) { |
|
|
|
ktsKtGroupMember.setType("1"); |
|
|
|
} else { |
|
|
|
ktsKtGroupMember.setType("2"); |
|
|
|
} |
|
|
|
//id不为空则修改
|
|
|
|
if (ObjectUtil.isNotNull(dto.getId())) { |
|
|
|
//根据手机号查询课题组成员
|
|
|
|
KtsKtGroupMemberExample ktsKtGroupMemberExample = new KtsKtGroupMemberExample(); |
|
|
|
ktsKtGroupMemberExample.createCriteria() |
|
|
|
.andMemberPhoneEqualTo(dto.getMemberPhone()) |
|
|
|
.andKtGroupIdEqualTo(ktGroupId) |
|
|
|
.andIdNotEqualTo(dto.getId()) |
|
|
|
.andDelFlagEqualTo((byte) 0); |
|
|
|
if (ktsKtGroupMemberMapper.countByExample(ktsKtGroupMemberExample) > 0) { |
|
|
|
throw new BaseException("该手机号已存在"); |
|
|
|
} |
|
|
|
//根据手机号查询用户
|
|
|
|
SysUser sysUser = sysUserService.selectUserByPhone(dto.getMemberPhone()); |
|
|
|
if (sysUser != null && "0".equals(sysUser.getDelFlag())) { |
|
|
|
//如果用户已存在,直接关联该用户
|
|
|
|
ktsKtGroupMember.setUserId(sysUser.getUserId()); |
|
|
|
} |
|
|
|
ktsKtGroupMemberMapper.updateByPrimaryKeySelective(ktsKtGroupMember); |
|
|
|
} else { |
|
|
|
//检查课题组id,没有且课题组名称不为空,则创建课题组信息
|
|
|
|
if (dto.getKtGroupId() == null && StrUtil.isNotEmpty(dto.getKtGroupName())) { |
|
|
|
GroupDto.Add add = new GroupDto.Add(); |
|
|
|
add.setKtGroupName(dto.getKtGroupName()); |
|
|
|
add.setProjId(dto.getProjId()); |
|
|
|
add.setProjOrgId(projOrgId); |
|
|
|
add.setIntro(dto.getKtGroupIntro()); |
|
|
|
add.setName(dto.getMemberName()); |
|
|
|
add.setPhone(dto.getMemberPhone()); |
|
|
|
add.setParentKtId(dto.getParentKtId()); |
|
|
|
KtsKtGroup add1 = add(add); |
|
|
|
ktsKtGroupMember.setKtGroupId(add1.getId()); |
|
|
|
} |
|
|
|
|
|
|
|
//根据手机号查询课题组成员
|
|
|
|
KtsKtGroupMemberExample ktsKtGroupMemberExample = new KtsKtGroupMemberExample(); |
|
|
|
ktsKtGroupMemberExample.createCriteria().andMemberPhoneEqualTo(ktsKtGroupMember.getMemberPhone()).andKtGroupIdEqualTo(ktsKtGroupMember.getKtGroupId()).andDelFlagEqualTo((byte) 0); |
|
|
|
List<KtsKtGroupMember> ktsKtGroupMembers = ktsKtGroupMemberMapper.selectByExample(ktsKtGroupMemberExample); |
|
|
|
if (CollUtil.isNotEmpty(ktsKtGroupMembers)) { |
|
|
|
throw new BaseException("该手机号已存在"); |
|
|
|
} |
|
|
|
//根据手机号查询用户
|
|
|
|
SysUser sysUser = sysUserService.selectUserByPhone(ktsKtGroupMember.getMemberPhone()); |
|
|
|
if (sysUser != null && "0".equals(sysUser.getDelFlag())) { |
|
|
|
//如果用户已存在,直接关联该用户
|
|
|
|
ktsKtGroupMember.setUserId(sysUser.getUserId()); |
|
|
|
//根据手机号查询课题组成员
|
|
|
|
KtsKtGroupMemberExample ktsKtGroupMemberExample = new KtsKtGroupMemberExample(); |
|
|
|
ktsKtGroupMemberExample.createCriteria().andMemberPhoneEqualTo(ktsKtGroupMember.getMemberPhone()).andKtGroupIdEqualTo(ktsKtGroupMember.getKtGroupId()).andDelFlagEqualTo((byte) 0); |
|
|
|
List<KtsKtGroupMember> ktsKtGroupMembers = ktsKtGroupMemberMapper.selectByExample(ktsKtGroupMemberExample); |
|
|
|
if (CollUtil.isNotEmpty(ktsKtGroupMembers)) { |
|
|
|
throw new BaseException("该手机号已存在"); |
|
|
|
} |
|
|
|
//根据手机号查询用户
|
|
|
|
SysUser sysUser = sysUserService.selectUserByPhone(ktsKtGroupMember.getMemberPhone()); |
|
|
|
if (sysUser != null && "0".equals(sysUser.getDelFlag())) { |
|
|
|
//如果用户已存在,直接关联该用户
|
|
|
|
ktsKtGroupMember.setUserId(sysUser.getUserId()); |
|
|
|
} |
|
|
|
ktsKtGroupMember.setId(IdUtil.getSnowflakeNextId()); |
|
|
|
ktsKtGroupMember.setCreateBy(SecurityUtils.getUsername()); |
|
|
|
ktsKtGroupMember.setMemberStatus((byte) 0); |
|
|
|
ktsKtGroupMember.setAuditStatus((byte) 0); |
|
|
|
ktsKtGroupMember.setCreateTime(new Date()); |
|
|
|
ktsKtGroupMember.setProjOrgId(dto.getProjOrgId()); |
|
|
|
ktsKtGroupMember.setDelFlag((byte) 0); |
|
|
|
ktsKtGroupMemberMapper.insertSelective(ktsKtGroupMember); |
|
|
|
} |
|
|
|
ktsKtGroupMember.setId(IdUtil.getSnowflakeNextId()); |
|
|
|
ktsKtGroupMember.setCreateBy(SecurityUtils.getUsername()); |
|
|
|
ktsKtGroupMember.setMemberStatus((byte) 0); |
|
|
|
ktsKtGroupMember.setAuditStatus((byte) 0); |
|
|
|
ktsKtGroupMember.setCreateTime(new Date()); |
|
|
|
ktsKtGroupMember.setProjOrgId(dto.getProjOrgId()); |
|
|
|
ktsKtGroupMember.setDelFlag((byte) 0); |
|
|
|
ktsKtGroupMemberMapper.insertSelective(ktsKtGroupMember); |
|
|
|
} |
|
|
|
return ktsKtGroupMember; |
|
|
|
|
|
|
|
|
|
|
|
// //是否传了课题组ID,没传且课题组名称不为空,则添加课题组
|
|
|
|
@ -713,15 +714,17 @@ public class KtsGroupServiceImpl implements KtsGroupService { |
|
|
|
continue; |
|
|
|
} |
|
|
|
if (memberResult.getTitle().contains("1") || memberResult.getTitle().contains("5") || memberResult.getTitle().contains("8") || memberResult.getTitle().contains("12") |
|
|
|
|| memberResult.getTitle().contains("2") || memberResult.getTitle().contains("6") || memberResult.getTitle().contains("9") || memberResult.getTitle().contains("13")) { |
|
|
|
|| memberResult.getTitle().contains("2") || memberResult.getTitle().contains("6") || memberResult.getTitle().contains("9") || memberResult.getTitle().contains("13") |
|
|
|
|| memberResult.getTitle().contains("20") || memberResult.getTitle().contains("21")) { |
|
|
|
title.setGj(title.getGj() + 1); |
|
|
|
continue; |
|
|
|
} |
|
|
|
if (memberResult.getTitle().contains("3") || memberResult.getTitle().contains("10") || memberResult.getTitle().contains("14")) { |
|
|
|
if (memberResult.getTitle().contains("3") || memberResult.getTitle().contains("10") || memberResult.getTitle().contains("14") || memberResult.getTitle().contains("19")) { |
|
|
|
title.setZj(title.getZj() + 1); |
|
|
|
continue; |
|
|
|
} |
|
|
|
if (memberResult.getTitle().contains("4") || memberResult.getTitle().contains("7") || memberResult.getTitle().contains("11") || memberResult.getTitle().contains("15") || memberResult.getTitle().contains("16")) { |
|
|
|
if (memberResult.getTitle().contains("4") || memberResult.getTitle().contains("7") || memberResult.getTitle().contains("11") || memberResult.getTitle().contains("15") |
|
|
|
|| memberResult.getTitle().contains("16") || memberResult.getTitle().contains("18")) { |
|
|
|
title.setCj(title.getCj() + 1); |
|
|
|
continue; |
|
|
|
} |
|
|
|
|