From cccaee8585c23b8580c75fb060ccd79d981cb7db Mon Sep 17 00:00:00 2001 From: zy_Java <654600784@qq.com> Date: Thu, 26 Nov 2020 17:47:24 +0800 Subject: [PATCH] =?UTF-8?q?20201126v1.9=E4=BF=AE=E6=94=B9=E8=A3=81?= =?UTF-8?q?=E5=88=A4=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cloudutil/feign/TallFeignClient.java | 10 ++ .../ccsens/mt/service/CompeteTaskService.java | 136 +++++++++++++++--- 2 files changed, 124 insertions(+), 22 deletions(-) diff --git a/cloudutil/src/main/java/com/ccsens/cloudutil/feign/TallFeignClient.java b/cloudutil/src/main/java/com/ccsens/cloudutil/feign/TallFeignClient.java index 86337fd7..65a55a79 100644 --- a/cloudutil/src/main/java/com/ccsens/cloudutil/feign/TallFeignClient.java +++ b/cloudutil/src/main/java/com/ccsens/cloudutil/feign/TallFeignClient.java @@ -220,6 +220,11 @@ public interface TallFeignClient { */ @RequestMapping("/roles/saveMember") JsonResponse saveMemberInRole(MemberRoleDto.SaveMemberInRole saveMember); + /** + * 将成员从角色内删除 + */ + @RequestMapping("/roles/deleteMember") + JsonResponse deleteMemberInRole(MemberRoleDto.SaveMemberInRole saveMember); /** @@ -375,6 +380,11 @@ class TallFeignClientFallBack implements FallbackFactory { return JsonResponse.newInstance().fail(); } + @Override + public JsonResponse deleteMemberInRole(MemberRoleDto.SaveMemberInRole saveMember) { + return JsonResponse.newInstance().fail(); + } + @Override public JsonResponse queryMemberByPhone(MemberRoleDto.GetMemberByPhone getMemberByPhone) { return JsonResponse.newInstance().fail(); diff --git a/mt/src/main/java/com/ccsens/mt/service/CompeteTaskService.java b/mt/src/main/java/com/ccsens/mt/service/CompeteTaskService.java index 5572bedf..236000e5 100644 --- a/mt/src/main/java/com/ccsens/mt/service/CompeteTaskService.java +++ b/mt/src/main/java/com/ccsens/mt/service/CompeteTaskService.java @@ -347,6 +347,100 @@ public class CompeteTaskService implements ICompeteTaskService { List competeJudgmentList = competeJudgmentDao.selectByExample(competeJudgmentExample); if (CollectionUtil.isNotEmpty(competeJudgmentList)) { competeJudgment = competeJudgmentList.get(0); + Long userId = null; + Long memberId = null; + if(!judgmentInfo.getJudgmentPhone().equalsIgnoreCase(competeJudgment.getPhone())){ + //添加成员 + MemberRoleDto.SaveMember saveMember = new MemberRoleDto.SaveMember(); + saveMember.setMemberName(judgmentInfo.getJudgmentName()); + saveMember.setProjectId(tallProjectId); + saveMember.setPhone(judgmentInfo.getJudgmentPhone()); + saveMember.setRoleId(Arrays.asList(competeJudgment.getRoleId())); + saveMember.setToken(token); + log.info("在tall内添加成员：{}", saveMember); + JsonResponse memberJsonResponse = tallFeignClient.saveMember(saveMember); + log.info("添加成员后返回：{}", memberJsonResponse); + //如果成员已存在，查询成员信息然后添加至角色内 + //失败return + if (ObjectUtil.isNull(memberJsonResponse)) { + log.info("调用tall返回null"); + return; + } + if(memberJsonResponse.getCode() != 200 && memberJsonResponse.getCode() != 21){ + log.info("调用tall异常后返回：{}", memberJsonResponse.getMsg()); + return; + } + if(memberJsonResponse.getCode() == 200){ + MemberVo.Member member = memberJsonResponse.getData(); + if(ObjectUtil.isNotNull(member)){ + userId = member.getUserId(); + memberId = member.getMemberId(); + } + } + //code等于21代表成员已存在 + if (memberJsonResponse.getCode() == 21) { + log.info("该成员已存在：{}", memberJsonResponse.getMsg()); + //查询该手机号在项目内的成员的id + MemberRoleDto.GetMemberByPhone getMemberByPhone = new MemberRoleDto.GetMemberByPhone(); + getMemberByPhone.setProjectId(tallProjectId); + getMemberByPhone.setPhone(judgmentInfo.getJudgmentPhone()); + getMemberByPhone.setToken(token); + log.info("查找该手机号以前的成员信息：{}", judgmentInfo.getJudgmentPhone()); + JsonResponse memberListJsonResponse = tallFeignClient.queryMemberByPhone(getMemberByPhone); + log.info("查找该手机号以前的成员信息返回：{}", memberListJsonResponse); + //失败return + if (ObjectUtil.isNull(memberListJsonResponse)) { + log.info("调用tall返回null"); + return; + } + if(memberListJsonResponse.getCode() != 200){ + log.info("调用tall异常后返回：{}", memberJsonResponse.getMsg()); + return; + } + + MemberVo.MemberList memberList = memberListJsonResponse.getData(); + if (ObjectUtil.isNotNull(memberList)) { + memberId = memberList.getMemberId(); + userId = memberList.getUserId(); + } + } + //将该成员添加至角色下 + if (ObjectUtil.isNotNull(competeJudgment.getRoleId()) && ObjectUtil.isNotNull(competeJudgment.getMemberId())) { + MemberRoleDto.SaveMemberInRole saveMemberInRole = new MemberRoleDto.SaveMemberInRole(); + saveMemberInRole.setRoleId(competeJudgment.getRoleId()); + saveMemberInRole.setMemberId(competeJudgment.getMemberId()); + saveMemberInRole.setToken(token); + log.info("将该成员添加至角色内"); + JsonResponse jsonResponse = tallFeignClient.deleteMemberInRole(saveMemberInRole); + if (ObjectUtil.isNull(jsonResponse)) { + log.info("调用tall返回null"); + return; + } + if(jsonResponse.getCode() != 200){ + log.info("调用tall异常后返回：{}", jsonResponse.getMsg()); + return; + } + } + //将该成员添加至角色下 + if (ObjectUtil.isNotNull(competeJudgment.getRoleId()) && ObjectUtil.isNotNull(memberId)) { + MemberRoleDto.SaveMemberInRole saveMemberInRole = new MemberRoleDto.SaveMemberInRole(); + saveMemberInRole.setRoleId(competeJudgment.getRoleId()); + saveMemberInRole.setMemberId(memberId); + saveMemberInRole.setToken(token); + log.info("将该成员添加至角色内"); + JsonResponse jsonResponse = tallFeignClient.saveMemberInRole(saveMemberInRole); + if (ObjectUtil.isNull(jsonResponse)) { + log.info("调用tall返回null"); + return; + } + if(jsonResponse.getCode() != 200){ + log.info("调用tall异常后返回：{}", jsonResponse.getMsg()); + return; + } + } + } + //删除旧成员角色关联 + //添加新成员角色关联 competeJudgment.setName(judgmentInfo.getJudgmentName()); competeJudgment.setPhone(judgmentInfo.getJudgmentPhone()); competeJudgment.setRemark(judgmentInfo.getRemark()); @@ -354,10 +448,10 @@ public class CompeteTaskService implements ICompeteTaskService { competeJudgment.setProjectId(project.getId()); competeJudgment.setSite(siteJudgment.getSite()); competeJudgment.setChiefJudgment((byte) judgmentInfo.getJudgmentNum()); + competeJudgment.setUserId(userId); + competeJudgment.setRoleId(memberId); competeJudgmentDao.updateByPrimaryKeySelective(competeJudgment); - //修改角色 - //修改成员 - //修改任务 + } else { // TODO //添加角色 @@ -410,7 +504,7 @@ public class CompeteTaskService implements ICompeteTaskService { log.info("调用tall异常后返回：{}", memberJsonResponse.getMsg()); return; } - if(roleJsonResponse.getCode() == 200){ + if(memberJsonResponse.getCode() == 200){ MemberVo.Member member = memberJsonResponse.getData(); if(ObjectUtil.isNotNull(member)){ userId = member.getUserId(); @@ -442,26 +536,24 @@ public class CompeteTaskService implements ICompeteTaskService { memberId = memberList.getMemberId(); userId = memberList.getUserId(); } - - //将该成员添加至角色下 - if (ObjectUtil.isNotNull(roleId) && ObjectUtil.isNotNull(memberId)) { - MemberRoleDto.SaveMemberInRole saveMemberInRole = new MemberRoleDto.SaveMemberInRole(); - saveMemberInRole.setRoleId(roleId); - saveMemberInRole.setMemberId(memberId); - saveMemberInRole.setToken(token); - log.info("将该成员添加至角色内"); - JsonResponse jsonResponse = tallFeignClient.saveMemberInRole(saveMemberInRole); - if (ObjectUtil.isNull(jsonResponse)) { - log.info("调用tall返回null"); - return; - } - if(jsonResponse.getCode() != 200){ - log.info("调用tall异常后返回：{}", jsonResponse.getMsg()); - return; - } + } + //将该成员添加至角色下 + if (ObjectUtil.isNotNull(roleId) && ObjectUtil.isNotNull(memberId)) { + MemberRoleDto.SaveMemberInRole saveMemberInRole = new MemberRoleDto.SaveMemberInRole(); + saveMemberInRole.setRoleId(roleId); + saveMemberInRole.setMemberId(memberId); + saveMemberInRole.setToken(token); + log.info("将该成员添加至角色内"); + JsonResponse jsonResponse = tallFeignClient.saveMemberInRole(saveMemberInRole); + if (ObjectUtil.isNull(jsonResponse)) { + log.info("调用tall返回null"); + return; + } + if(jsonResponse.getCode() != 200){ + log.info("调用tall异常后返回：{}", jsonResponse.getMsg()); + return; } } - //添加任务 //查找场次信息表 CompeteStartOrderExample startOrderExample = new CompeteStartOrderExample();