| | |
| | | import com.dy.pipIrrGlobal.pojoBa.BaRolePermissions; |
| | | import com.dy.pipIrrGlobal.pojoBa.BaUser; |
| | | import com.dy.pipIrrGlobal.pojoBa.BaUserRole; |
| | | import com.dy.pipIrrGlobal.voBa.VoSimpleUser; |
| | | import com.dy.pipIrrGlobal.voBa.VoUserInfo; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.dubbo.common.utils.PojoUtils; |
| | |
| | | * @return 用户实体 |
| | | */ |
| | | public BaUser selectById(Long id) { |
| | | return this.dao.selectById(id); |
| | | return this.dao.selectByPrimaryKey(id); |
| | | } |
| | | |
| | | /** |
| | |
| | | Long itemTotal = this.dao.getRecordCount(params); |
| | | |
| | | QueryResultVo<List<VoUserInfo>> rsVo = new QueryResultVo<>() ; |
| | | |
| | | Integer pageCurr = 0; |
| | | Integer pageSize = 10000; |
| | | rsVo.pageCurr = 1; |
| | | rsVo.pageSize = 10000; |
| | | if(queryVo.pageSize != null && queryVo.pageCurr != null) { |
| | | rsVo.pageSize = queryVo.pageSize ; |
| | | rsVo.pageCurr = queryVo.pageCurr; |
| | | pageSize = queryVo.pageSize ; |
| | | pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString()); |
| | | } |
| | | params.put("pageCurr", pageCurr); |
| | | params.put("pageSize", pageSize); |
| | | rsVo.pageSize = queryVo.pageSize ; |
| | | rsVo.pageCurr = queryVo.pageCurr ; |
| | | |
| | | rsVo.calculateAndSet(itemTotal, params); |
| | | |
| | |
| | | if(list_users.size() > 0) { |
| | | for(int i = 0; i < list_users.size(); i++) { |
| | | VoUserInfo voUserInfo = list_users.get(i); |
| | | String userId = voUserInfo.getUserId(); |
| | | String userId = voUserInfo.getId(); |
| | | |
| | | JSONArray array_roleIds = new JSONArray(); |
| | | List<Map<String, Object>> list_roleIds = Optional.ofNullable(this.dao.getRoleIdsByUserId(Long.parseLong(userId))).orElse(new ArrayList<>()); |
| | |
| | | * @return 影响记录数量 |
| | | */ |
| | | @Transactional |
| | | public int save(BaUser po){ |
| | | return this.dao.putin(po) ; |
| | | public Long save(BaUser po){ |
| | | //return this.dao.putin(po) ; |
| | | this.dao.putin(po) ; |
| | | return po.getId(); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @return 插入用户与角色关联记录数量 |
| | | */ |
| | | public int setRoles(Long userId, String[] roleIds) { |
| | | this.urDao.deleteByUserId(userId); |
| | | |
| | | int count = 0; |
| | | if (roleIds != null && roleIds.length > 0) { |
| | | this.urDao.deleteByUserId(userId); |
| | | for (String roleId : roleIds) { |
| | | count += this.urDao.insertSelective(new BaUserRole(userId, Long.parseLong(roleId))); |
| | | } |
| | | } |
| | | return count; |
| | | return 1; |
| | | } |
| | | |
| | | /** |
| | |
| | | if(map.size() == 0) { |
| | | return null; |
| | | } |
| | | voUserInfo.setUserId(String.valueOf(userId)); |
| | | voUserInfo.setId(String.valueOf(userId)); |
| | | voUserInfo.setUserName(map.get("userName").toString()); |
| | | voUserInfo.setPhone(map.get("phone").toString()); |
| | | voUserInfo.setBlockId(map.get("blockId").toString()); |
| | |
| | | voUserInfo.setRoleIds(list_roleIds); |
| | | voUserInfo.setRoleNames(list_roleNames); |
| | | voUserInfo.setPermissions(array_permission); |
| | | |
| | | |
| | | return voUserInfo; |
| | | } |
| | | |
| | | /** |
| | | * 获取简单用户数据列表,数据列表查询条件中使用 |
| | | * @return |
| | | */ |
| | | public List<VoSimpleUser> getSimpleUsers() { |
| | | return dao.getSimpleUsers(); |
| | | } |
| | | |
| | | } |