From 2ffc6557f2daeadcd9cee4ba0a5c58539efdd7af Mon Sep 17 00:00:00 2001 From: dimengzhe <251008545@qq.com> Date: Fri, 12 Aug 2022 08:49:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=92=E4=BA=A7=E6=B6=88=E6=81=AF=E6=8E=A8?= =?UTF-8?q?=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BusVehicleApplyService.java | 39 ++-- .../bussalesorder/BusSalesOrderService.java | 2 +- .../portal/api/sysuser/SysUserFeign.java | 4 + .../api/sysuser/SysUserFeignFallback.java | 5 + .../portal/biz/sysuser/SysUserMapper.java | 2 + .../portal/biz/sysuser/SysUserMapper.xml | 167 ++++++++++-------- .../anrui/portal/biz/sysuser/SysUserRest.java | 5 + .../portal/biz/sysuser/SysUserService.java | 46 ++--- 8 files changed, 150 insertions(+), 120 deletions(-) diff --git a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java index 507412fda9..1e8cac8f2b 100644 --- a/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java +++ b/anrui-base/anrui-base-biz/src/main/java/com/yxt/anrui/base/biz/busvehicleapply/BusVehicleApplyService.java @@ -41,7 +41,6 @@ import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrg; import com.yxt.anrui.portal.api.sysstafforg.SysStaffOrgFeign; import com.yxt.anrui.portal.api.sysuser.SysUserFeign; import com.yxt.anrui.portal.api.sysuser.SysUserVo; -import com.yxt.anrui.portal.api.sysuser.UserQuery; import com.yxt.common.base.service.MybatisBaseService; import com.yxt.common.base.utils.JPushServer; import com.yxt.common.base.utils.PagerUtil; @@ -376,7 +375,7 @@ public class BusVehicleApplyService extends MybatisBaseService> nodeVoList = getNextNodesForSubmit(getNodeQuery); - //根据组织架构、角色两个参数取相关符合条件的用户信息 - UserQuery userQuery = new UserQuery(); - userQuery.setRoleSid(nodeVoList.getData().get(0).getCandidateGroups().get(0)); - userQuery.setOrgSidPath(orgSidPath); - List sysUserVos = sysUserFeign.getUserByRole(userQuery).getData(); - StringBuilder nextNodeUserSids = new StringBuilder(); - List stringList = new ArrayList<>(); - for (SysUserVo su : sysUserVos) { - stringList.add(su.getSid()); -// nextNodeUserSids.append(su.getSid()).append(","); - } - //符合条件的用户的sid,拼接的字符串 -// String nextNodeUserSids_ = nextNodeUserSids.toString(); + List stringList = Arrays.asList(nextSid.split(",")); + //根据用户的sid查询用户的id + ResultBean stringList1 = sysUserFeign.selectIdBySid(stringList); + List stringList2 = Arrays.asList(stringList1.getData().split(",")); //标题、内容、消息类别key、消息类别名称、 - JPushServer.sendPushAlias("排产申请审批", busVehicleApply.getCreateByName() + "的排产申请", "msg_type", "系统消息", stringList.toArray(new String[stringList.size()])); + String msgSid = getMessage(stringList); + for (int i = 0; i < stringList2.size(); i++) { + JPushServer.sendPushAlias("排产申请审批", busVehicleApply.getCreateByName() + "的排产申请", "msg_type", "审批中心", stringList2.get(i)); + } + + } public String getMessage(List list) { + //1、buttons:int[]{3,4,5}、taskId、taskName、procInsId、taskDefKey + //根据taskDefKey、流程标识、以及 + + // 1、保存消息体 AppMessageDto messageDto = new AppMessageDto(); ResultBean> messageBean = messageTypeFeign.selectAppMsgTypeList("0002"); if (messageBean.getSuccess() && messageBean.getData() != null) { List typeVoList = messageBean.getData(); for (MessageTypeVo message : typeVoList) { - if (message.getMsgType().equals("系统消息")) { + if (message.getMsgType().equals("审批中心")) { messageDto.setMsgTypeSid(message.getMsgTypeSid()); messageDto.setMsgType(message.getMsgType()); } diff --git a/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorder/BusSalesOrderService.java b/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorder/BusSalesOrderService.java index 155b49f126..e48094c756 100644 --- a/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorder/BusSalesOrderService.java +++ b/anrui-buscenter/anrui-buscenter-biz/src/main/java/com/yxt/anrui/buscenter/biz/bussalesorder/BusSalesOrderService.java @@ -1317,7 +1317,7 @@ public class BusSalesOrderService extends MybatisBaseService>> getUserByOrgSid(@RequestParam("orgSid") String orgSid, @RequestParam("userSid") String userSid); + + @ApiOperation(value = "根据用户sid获取用户id") + @PostMapping(value = "selectIdBySid") + ResultBean selectIdBySid(@RequestBody List stringList); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysuser/SysUserFeignFallback.java b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysuser/SysUserFeignFallback.java index 0ffcb8a014..de4fd4ee46 100644 --- a/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysuser/SysUserFeignFallback.java +++ b/anrui-portal/anrui-portal-api/src/main/java/com/yxt/anrui/portal/api/sysuser/SysUserFeignFallback.java @@ -184,4 +184,9 @@ public class SysUserFeignFallback implements SysUserFeign { public ResultBean>> getUserByOrgSid(String orgSid, String userSid) { return null; } + + @Override + public ResultBean selectIdBySid(List stringList) { + return null; + } } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.java index c62449e8b0..54b3820692 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.java @@ -179,4 +179,6 @@ public interface SysUserMapper extends BaseMapper { * @return */ int updateAppIdAll(); + + String selectIdBySid(@Param("list") List stringList); } \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.xml b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.xml index 63184626b0..d90db0ae87 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.xml +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserMapper.xml @@ -5,59 +5,59 @@ @@ -146,7 +146,7 @@ @@ -154,21 +154,23 @@ @@ -201,19 +203,19 @@ @@ -224,14 +226,14 @@ sso.orgName, sp.name as postName FROM sys_user su - LEFT JOIN sys_staffinfo st - ON su.`staffSid` = st.`sid` - LEFT JOIN sys_staff_org sso - ON st.`sid` = sso.`staffSid` - LEFT JOIN sys_staff_post ssp - ON st.sid = ssp.`staffSid` - LEFT JOIN sys_post sp - ON ssp.`postSid` = sp.`sid` + LEFT JOIN sys_staffinfo st + ON su.`staffSid` = st.`sid` + LEFT JOIN sys_staff_org sso + ON st.`sid` = sso.`staffSid` + LEFT JOIN sys_staff_post ssp + ON st.sid = ssp.`staffSid` + LEFT JOIN sys_post sp + ON ssp.`postSid` = sp.`sid` WHERE su.sid != #{userSid} AND sso.`orgSidPath` LIKE concat('%' , #{orgSid} @@ -241,7 +243,7 @@ select si.name, su.sid, su.staffSid from sys_user_role sr - left join sys_user su on sr.userSid = su.sid - left join sys_staffinfo si on si.sid = su.staffSid + left join sys_user su on sr.userSid = su.sid + left join sys_staffinfo si on si.sid = su.staffSid where sr.roleSid = #{roleSid} - update sys_user set appId = NULL where mobile = #{mobile} + update sys_user + set appId = NULL + where mobile = #{mobile} - update sys_user set appId = NULL + update sys_user + set appId = NULL + + \ No newline at end of file diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserRest.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserRest.java index 24ac46018d..3b76c560d7 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserRest.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserRest.java @@ -589,4 +589,9 @@ public class SysUserRest implements SysUserFeign { public ResultBean>> getUserByOrgSid(String orgSid, String userSid) { return sysUserService.getUserByOrgSid(orgSid, userSid); } + + @Override + public ResultBean selectIdBySid(List stringList) { + return sysUserService.selectIdBySid(stringList); + } } diff --git a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java index 346ea26b36..d4afa75bc1 100644 --- a/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java +++ b/anrui-portal/anrui-portal-biz/src/main/java/com/yxt/anrui/portal/biz/sysuser/SysUserService.java @@ -531,7 +531,7 @@ public class SysUserService extends MybatisBaseService { SysUser user = baseMapper.selectByUserName(mobile); if (user == null) { user = baseMapper.selectByMobile(mobile); - if(user == null){ + if (user == null) { return ResultBean.fireFail().setMsg("该手机号暂时还未注册,请先注册"); } @@ -860,27 +860,27 @@ public class SysUserService extends MybatisBaseService { public ResultBean getUsersByRoleSid(String roleSid) { List users = baseMapper.getUsersByRoleSid(roleSid); - List l=new ArrayList<>(); - for(SysUserVo s:users){ - l.add(s.getDepartmentName()==null?"":s.getDepartmentName()); + List l = new ArrayList<>(); + for (SysUserVo s : users) { + l.add(s.getDepartmentName() == null ? "" : s.getDepartmentName()); } HashSet set = new HashSet(l); //把List集合所有元素清空 l.clear(); //把HashSet对象添加至List集合 l.addAll(set); - List> r=new ArrayList<>(); - for(String s:l){ - if(StringUtils.isNotBlank(s)){ - Map m=new HashMap<>(); - List us=new ArrayList<>(); - for(SysUserVo su:users){ - if(s!=null&&s.equals(su.getDepartmentName())){ + List> r = new ArrayList<>(); + for (String s : l) { + if (StringUtils.isNotBlank(s)) { + Map m = new HashMap<>(); + List us = new ArrayList<>(); + for (SysUserVo su : users) { + if (s != null && s.equals(su.getDepartmentName())) { us.add(su); } } - m.put("dept",s); - m.put("users",us); + m.put("dept", s); + m.put("users", us); r.add(m); } } @@ -895,11 +895,11 @@ public class SysUserService extends MybatisBaseService { String levelTypeKey = sysRoleService.getLevelType(query.getRoleSid()); if (StringUtils.isNotBlank(levelTypeKey)) { String orgSidPath = query.getOrgSidPath(); - if(StringUtils.isBlank(orgSidPath)){ + if (StringUtils.isBlank(orgSidPath)) { sysUserVoList = baseMapper.getUserByRoleSid(query.getRoleSid()); - }else{ - if(query.getOrgSidPath().split("/").length>=Integer.parseInt(levelTypeKey)-1){ + } else { + if (query.getOrgSidPath().split("/").length >= Integer.parseInt(levelTypeKey) - 1) { String levelOrgSid = query.getOrgSidPath().split("/")[Integer.parseInt(levelTypeKey) - 1]; sysUserVoList = baseMapper.getUserByRole(query.getRoleSid(), levelOrgSid); } @@ -914,14 +914,14 @@ public class SysUserService extends MybatisBaseService { public ResultBean>> getUserByOrgSid(String orgSid, String userSid) { ResultBean rb = ResultBean.fireFail(); - List> user = baseMapper.getUserByOrgSid(orgSid,userSid); + List> user = baseMapper.getUserByOrgSid(orgSid, userSid); for (Map map : user) { StringBuilder namePath = new StringBuilder(); String name = map.get("name"); String orgName = map.get("orgName"); String postName = map.get("postName"); namePath.append(name).append("(").append(orgName).append(" ").append(postName).append(")"); - map.put("namePath",namePath.toString()); + map.put("namePath", namePath.toString()); } /*List> user = new ArrayList<>(); for (Map map : userByOrgSid) { @@ -943,11 +943,17 @@ public class SysUserService extends MybatisBaseService { public ResultBean updateAppIdByMobile(String mobile) { ResultBean rb = ResultBean.fireFail(); - if(StringUtils.isNotBlank(mobile)){ + if (StringUtils.isNotBlank(mobile)) { baseMapper.updateAppIdByMobile(mobile); - }else{ + } else { baseMapper.updateAppIdAll(); } return rb.success().setMsg("解绑成功"); } + + public ResultBean selectIdBySid(List stringList) { + ResultBean rb = ResultBean.fireFail(); + String ids = baseMapper.selectIdBySid(stringList); + return rb.success().setData(ids); + } } \ No newline at end of file