package cn.com.goldenwater.dcproj.controller.ducha; import cn.com.goldenwater.core.web.BaseController; import cn.com.goldenwater.core.web.BaseResponse; import cn.com.goldenwater.dcproj.constValue.AdCodeLabel; import cn.com.goldenwater.dcproj.constValue.CommonLabel; import cn.com.goldenwater.dcproj.dao.BisInspOrgDao; import cn.com.goldenwater.dcproj.dto.AddRlationPersDto; import cn.com.goldenwater.dcproj.dto.GroupLeaderDto; import cn.com.goldenwater.dcproj.dto.InspTypeDto; import cn.com.goldenwater.dcproj.dto.LoginDto; import cn.com.goldenwater.dcproj.dto.LoginUser; import cn.com.goldenwater.dcproj.dto.PersListDto; import cn.com.goldenwater.dcproj.model.BisInspAll; import cn.com.goldenwater.dcproj.model.BisInspAllRlation; import cn.com.goldenwater.dcproj.model.BisInspAllRlationPers; import cn.com.goldenwater.dcproj.model.BisInspOrg; import cn.com.goldenwater.dcproj.model.BisInspPersOrg; import cn.com.goldenwater.dcproj.model.GwComFile; import cn.com.goldenwater.dcproj.model.InspType; import cn.com.goldenwater.dcproj.model.OlBisInspOrg; import cn.com.goldenwater.dcproj.param.BisInspAllParam; import cn.com.goldenwater.dcproj.param.BisInspAllRlationParam; import cn.com.goldenwater.dcproj.param.BisInspAllRlationPersParam; import cn.com.goldenwater.dcproj.param.BisInspOrgParam; import cn.com.goldenwater.dcproj.param.BisInspPersOrgParam; import cn.com.goldenwater.dcproj.param.GroupLeaderParam; import cn.com.goldenwater.dcproj.param.TacInspYearBatchGroupPersParam; import cn.com.goldenwater.dcproj.param.UpdateCallNumberParam; import cn.com.goldenwater.dcproj.param.UserListByCurUserParam; import cn.com.goldenwater.dcproj.param.UserRoleParam; import cn.com.goldenwater.dcproj.service.BisInspAllRlationPersService; import cn.com.goldenwater.dcproj.service.BisInspAllRlationService; import cn.com.goldenwater.dcproj.service.BisInspAllService; import cn.com.goldenwater.dcproj.service.BisInspMeetInvitationService; import cn.com.goldenwater.dcproj.service.BisInspPersOrgService; import cn.com.goldenwater.dcproj.service.GwComFileService; import cn.com.goldenwater.dcproj.service.LoginService; import cn.com.goldenwater.dcproj.service.OlBisInspOrgService; import cn.com.goldenwater.dcproj.service.TacInspYearBatchGroupPersService; import cn.com.goldenwater.dcproj.service.impl.system.OrganizationTreeImpl; import cn.com.goldenwater.dcproj.target.Authority; import cn.com.goldenwater.dcproj.target.Log; import cn.com.goldenwater.dcproj.target.VerifyBean; import cn.com.goldenwater.dcproj.util.Base64Util; import cn.com.goldenwater.dcproj.utils.*; import cn.com.goldenwater.id.util.UuidUtil; import cn.com.goldenwater.target.CheckException; import com.github.pagehelper.PageInfo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.MapUtils; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.Assert; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.multipart.MultipartFile; import javax.annotation.PostConstruct; import javax.servlet.http.HttpServletRequest; import java.io.File; import java.io.IOException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.concurrent.TimeUnit; /** * @author zhaohg * @date 2019-2-23 */ @Api(value = "新用户管理", tags = "006新用户管理") @RestController @RequestMapping("/bis/insp") public class BisInspAllRlationPersController extends BaseController { private Logger logger = LoggerFactory.getLogger(getClass()); @Value("${api.url}") private String apiUrl; @Value("${smsCode}") private String smsCode; @Value("${getFile.prefix}") public String prefix; @Value("${web.upload-path}") public String fileDir; @Autowired private BisInspAllRlationPersService bisInspAllRlationPersService; @Autowired private BisInspAllRlationService bisInspAllRlationService; @Autowired private OrganizationTreeImpl organizationTree; @Autowired private GwComFileService gwComFileService; @Autowired private RedisTemplate redisTemplate; @Autowired private BisInspMeetInvitationService bisInspMeetInvitationService; @Autowired private TacInspYearBatchGroupPersService groupPersService; @Autowired private OlBisInspOrgService olBisInspOrgService; @Autowired private OlBisInspOrgService inspOrgService; @Autowired private BisInspPersOrgService persOrgService; @Autowired private LoginService loginService; @PostConstruct public void Cache() { Object newSmscode = redisTemplate.opsForValue().get("smsCode"); if (newSmscode == null) { redisTemplate.opsForValue().set("smsCode", smsCode); } } @RequestMapping(value = "/test/{month}", method = {RequestMethod.GET}) public BaseResponse test(@PathVariable String month) { // countTaskService.washWxPic(request); gwComFileService.changeSmallImg("2020", month); return buildSuccessResponse("更新完成!!"); } @GetMapping("/getCaptchaImage") public BaseResponse getCaptcha() throws Exception { String uuid = UuidUtil.uuid(); ImgResult imgResult = VerifyCodeUtils.VerifyCode(4); this.redisTemplate.opsForValue().set(uuid, imgResult.getCode(), 10L, TimeUnit.MINUTES); Map map = new HashMap<>(2); map.put("imgCodeId", uuid); map.put("img", imgResult.getImg()); logger.info("--------------------imgCode:" + imgResult.getCode() + "------------------------------"); return buildSuccessResponse(map); } @Log @ApiOperation(value = "用户发送短信", notes = "用户发送短信") @RequestMapping(value = "/sendMessage", method = {RequestMethod.POST}) public BaseResponse sendMessage(@RequestParam(required = true) String phone, @RequestParam(required = false) String imgCodeId, @RequestParam(required = false) String code, HttpServletRequest request) throws Exception { if (code.length() != 4) { return buildFailResponse("验证码有误！"); } String uuidCode = ""; Object object = this.redisTemplate.opsForValue().get(imgCodeId); if (object != null) { uuidCode = object.toString(); } String inputCode = Base64Util.encodeStr(code.toLowerCase()); if (!(uuidCode.equalsIgnoreCase(inputCode))) { return buildFailResponse(1500, "您输入的验证码不正确或已过期，请点击验证码图片刷新，重新输入！"); } uuidCode = UuidUtil.uuid(); redisTemplate.opsForValue().set(phone, uuidCode + "_" + imgCodeId, 10L, TimeUnit.MINUTES); redisTemplate.delete(imgCodeId); redisTemplate.opsForValue().set(imgCodeId, uuidCode); boolean flag = this.bisInspAllRlationPersService.sendMessage(phone); if (flag) { return buildSuccessResponse(); } return buildFailResponse(1002, "您还不是本系统用户，请联系系统管理员"); } /** * 新版本登录接口 * * @param loginDto phone、code * @param request 请求 * @return 判断能否登录，登录成果返回用户信息 */ @ApiOperation(value = "用户验证码登录", notes = "与普通登录返回相同") @RequestMapping(value = "/loginByCode", method = {RequestMethod.POST}) public BaseResponse loginByCode(@RequestBody LoginDto loginDto, HttpServletRequest request) { return loginService.login(loginDto, request); } /** * 手机号密码登录接口 * * @param loginDto phone、pwd * @param request 请求 * @return 判断能否登录，登录成果返回用户信息 */ @ApiOperation(value = "用户验证码登录", notes = "与普通登录返回相同") @RequestMapping(value = "/loginByPwd", method = {RequestMethod.POST}) public BaseResponse loginByPwd(@RequestBody LoginDto loginDto, HttpServletRequest request) { return loginService.loginByPwd(loginDto, request); } /** * 更新密码为m5加密后的 * * @param */ @ApiOperation(value = "更新密码为m5加密后的", notes = "更新密码为m5加密后的") @RequestMapping(value = "/updatePwdMd5", method = {RequestMethod.POST}) public BaseResponse updatePwdMd5() { return loginService.updatePwdMd5(); } // /** // * 旧版本登录接口 // * // * @param phone 手机号 // * @param code 验证码 // * @param request 请求 // * @return 判断能否登录，登录成果返回用户信息 // */ // @ApiOperation(value = "用户验证码登录", notes = "与普通登录返回相同") // @RequestMapping(value = "/loginByCode", method = {RequestMethod.POST}) // public BaseResponse loginByCode(@RequestParam String phone, @RequestParam String code, HttpServletRequest request) { // if (code.length() != 6) { // return buildFailResponse("验证码有误！"); // } // // 根据phone-code获取用户信息 // BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.loginByCode(phone, code); // boolean logincode = true; // if (bisInspAllRlationPers == null) { // GwStaticUser gwStaticUser = gwStaticUserDao.get(phone); // if (gwStaticUser != null) { // String newSmscode = smsCode; // // 判断是否与固定验证码相同，相同时获取用户信息 // if (newSmscode.equals(code)) { // BisInspAllRlationPersParam inspAllRlationPersParam = new BisInspAllRlationPersParam(); // inspAllRlationPersParam.setMobilenumb(phone); // bisInspAllRlationPers = bisInspAllRlationPersService.getBy(inspAllRlationPersParam); // logincode = false; // } // } // } // // //发送信息成功后记录数据 // if (logincode) { // String yzm = (String) redisTemplate.opsForValue().get(phone); // if (StringUtils.isBlank(yzm)) { // return buildFailResponse("图片验证码已经过期，请重新验证!!"); // } // String[] arrays = yzm.split("_"); // //验证码为arrays[0] // String yzmReal = (String) redisTemplate.opsForValue().get(arrays[1]); // if (StringUtils.isBlank(yzm) || "null".equals(yzm)) { // return buildFailResponse("图片验证码已经过期，请重新输入!!"); // } // if (!yzmReal.equals(arrays[0])) { // return buildFailResponse("图片验证码已经过期，请重新验输入!"); // } // redisTemplate.delete(phone); // redisTemplate.delete(arrays[1]); // } // if (bisInspAllRlationPers == null) { // BisInspAllRlationPersParam allRlationPersParam = new BisInspAllRlationPersParam(); // allRlationPersParam.setMobilenumb(phone); // bisInspAllRlationPers = bisInspAllRlationPersService.getBy(allRlationPersParam); // if (bisInspAllRlationPers == null) { // return buildFailResponse(1002, "该手机号尚未注册", "", ""); // } // return buildFailResponse(1001, "验证码错误", "", ""); // } else { // bisInspAllRlationPers.setPwd(null); // bisInspAllRlationPers = getBisInspAllRlations(bisInspAllRlationPers); // BisInspAllRlationPers pers = new BisInspAllRlationPers(); // pers.setGuid(bisInspAllRlationPers.getGuid()); // pers.setLoginTm(new Date()); // if (StringUtils.isBlank(bisInspAllRlationPers.getPersType())) { // bisInspAllRlationPers.setPersType("3"); // pers.setPersType("3"); // } // bisInspAllRlationPersService.update(pers); // String uuid = UuidUtil.uuid(); // bisInspAllRlationPersService.sendChannel(uuid, bisInspAllRlationPers, request, PlusEnum.ADD.getNumber()); // String accessToken = JWTTokenUtil.sign(bisInspAllRlationPersService.getLoginUser(bisInspAllRlationPers), bisInspAllRlationPers.getGuid()); // // redisTemplate.opsForValue().set(uuid, accessToken, JWTTokenUtil.maxAge, TimeUnit.MILLISECONDS); // redisTemplate.opsForValue().set(uuid + bisInspAllRlationPers.getGuid(), accessToken, JWTTokenUtil.refreshmaxAge, TimeUnit.MILLISECONDS); // bisInspAllRlationPers.setMobilenumb(UserMsgSectrityUtils.blurPhone(bisInspAllRlationPers.getMobilenumb())); // return buildSuccessResponse(bisInspAllRlationPers, uuid); // } // } /** * 江苏数字看板、 需要手机号码模拟登陆。 * * @param map 手机号码 * @param request * @return */ @ApiOperation(value = "", notes = "") @RequestMapping(value = "/getTokenByTel", method = {RequestMethod.POST}) public BaseResponse loginByPhone(@RequestBody Map map, HttpServletRequest request) { // 判断是否与固定验证码相同，相同时获取用户信息 BisInspAllRlationPersParam inspAllRlationPersParam = new BisInspAllRlationPersParam(); inspAllRlationPersParam.setMobilenumb(map.get("phone")); BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.getBy(inspAllRlationPersParam); if (bisInspAllRlationPers == null) { return buildFailResponse(1002, "该手机号尚未注册", "", ""); } bisInspAllRlationPers.setPwd(null); bisInspAllRlationPers = getBisInspAllRlations(bisInspAllRlationPers); BisInspAllRlationPers pers = new BisInspAllRlationPers(); pers.setGuid(bisInspAllRlationPers.getGuid()); pers.setLoginTm(new Date()); if (StringUtils.isBlank(bisInspAllRlationPers.getPersType())) { bisInspAllRlationPers.setPersType("3"); pers.setPersType("3"); } bisInspAllRlationPersService.update(pers); String uuid = UuidUtil.uuid(); //bisInspAllRlationPersService.sendChannel(uuid, bisInspAllRlationPers, request, PlusEnum.ADD.getNumber()); String accessToken = JWTTokenUtil.sign(bisInspAllRlationPersService.getLoginUser(bisInspAllRlationPers), bisInspAllRlationPers.getGuid()); redisTemplate.opsForValue().set(uuid, accessToken, JWTTokenUtil.maxAge, TimeUnit.MILLISECONDS); redisTemplate.opsForValue().set(uuid + bisInspAllRlationPers.getGuid(), accessToken, JWTTokenUtil.refreshmaxAge, TimeUnit.MILLISECONDS); bisInspAllRlationPers.setMobilenumb(UserMsgSectrityUtils.blurPhone(bisInspAllRlationPers.getMobilenumb())); // TODO 有时间做个加密处理 return buildSuccessResponse(bisInspAllRlationPers, uuid); } @Autowired private BisInspOrgDao bisInspOrgDao; private BisInspAllRlationPers getBisInspAllRlations(BisInspAllRlationPers bisInspAllRlationPers) { // 1.设置默认显示机构和所能看到的所有机构 BisInspOrg bisInspOrg = new BisInspOrg(); if (StringUtils.isNotBlank(bisInspAllRlationPers.getOrgId())) { // 设置所有能看到的机构 BisInspOrgParam inspOrgParam = new BisInspOrgParam(); inspOrgParam.setPersId(bisInspAllRlationPers.getGuid()); List inspOrgList = bisInspOrgDao.findPersOrgList(inspOrgParam); bisInspAllRlationPers.setAllOrg(inspOrgList); String orgId = bisInspAllRlationPers.getOrgId(); // 获取所有orgId 判断用户所属机构是否在其中，没有 选择第一个机构 为默认机构 if (inspOrgList != null && inspOrgList.size() > 0) { orgId = inspOrgList.get(0).getOrgId(); for (BisInspOrg org : inspOrgList) { if (org.getOrgId().equals(bisInspAllRlationPers.getOrgId())) { orgId = bisInspAllRlationPers.getOrgId(); break; } } } bisInspOrg = olBisInspOrgService.getDefaultOrg(orgId); bisInspAllRlationPers.setDefaultOrg(bisInspOrg); } if (StringUtils.isNotBlank(bisInspAllRlationPers.getGuid())) { List allNode = organizationTree.getAllNode(bisInspAllRlationPers.getGuid(), "", bisInspAllRlationPers.getOrgId(), "", "", "", "", ""); if (allNode.size() > 0) { StringBuffer s = new StringBuffer(); s.append("1"); String sk = "0"; String ry = "000"; String sh = "0"; String ogc = "0"; String dxs = "0"; String sz = "0"; String sd = "0"; for (BisInspAll b : allNode) { if ("001".equals(b.getId().substring(0, 3))) { sk = "1"; } if ("002".equals(b.getId().substring(0, 3))) { ry = "111"; } if ("003".equals(b.getId().substring(0, 3))) { sh = "1"; } if ("004".equals(b.getId().substring(0, 3))) { ogc = "1"; } if ("005".equals(b.getId().substring(0, 3))) { dxs = "1"; } if ("006".equals(b.getId().substring(0, 3))) { sz = "1"; } if ("011".equals(b.getId().substring(0, 3))) { sd = "1"; } } s.append(sk).append(ry).append(sh).append(ogc).append(dxs).append(sz).append(sd); bisInspAllRlationPers.setJurisdiction(s.toString()); } else { bisInspAllRlationPers.setJurisdiction("100000000"); } bisInspAllRlationPers.setAllNode(allNode); } return bisInspAllRlationPers; } @Authority(roles = "1") @ApiOperation(value = "添加人员") @RequestMapping(value = "/insert", method = {RequestMethod.POST}) @Transactional(rollbackFor = Exception.class) public BaseResponse insert(@RequestParam(value = "file", required = false) MultipartFile file, BisInspAllRlationPers bisInspAllRlationPers) throws Exception { BisInspAllRlationPers inspAllRlationPers = bisInspAllRlationPersService.get(getCurrentPersId()); if (inspAllRlationPers == null) { return buildFailResponse("当前用户不存在!!"); } if (!"1".equals(inspAllRlationPers.getPersType())) { return buildFailResponse(9993, "当前用户无权限执行该操作!!"); } if (file != null) { Calendar dat = Calendar.getInstance(); //写入文件 String originalFilename = file.getOriginalFilename(); GwComFile gwComFile = new GwComFile(); String uuid = UuidUtil.uuid(); gwComFile.setId(uuid); gwComFile.setFileName(originalFilename); gwComFile.setFileSize((double) file.getSize()); gwComFile.setFileExt(originalFilename.substring(1 + originalFilename.lastIndexOf("."))); String filePath = prefix + dat.get(Calendar.YEAR) + File.separator + (dat.get(Calendar.MONTH) + 1) + File.separator + dat.get(Calendar.DAY_OF_MONTH) + File.separator + uuid + "." + gwComFile.getFileExt(); gwComFile.setFilePath(filePath); if (!FileExtUtil.valFileExt(gwComFile.getFileExt())) { return buildFailResponse(9993, "文件类型允许!!"); } //写入文件 String filePath2 = dat.get(Calendar.YEAR) + File.separator + (dat.get(Calendar.MONTH) + 1) + File.separator + dat.get(Calendar.DAY_OF_MONTH); gwComFileService.writeFile(gwComFile, file, filePath2); bisInspAllRlationPers.setImgurl(filePath); } BisInspAllRlationPers p = bisInspAllRlationPersService.createUser(bisInspAllRlationPers); return buildSuccessResponse(p.getGuid()); } private void addPreOrg(BisInspAllRlationPers bisInspAllRlationPers) { //先删除授权，再添加机构授权 BisInspPersOrgParam persOrgParam = new BisInspPersOrgParam(); persOrgParam.setPersId(bisInspAllRlationPers.getGuid()); persOrgService.deleteBy(persOrgParam); if (StringUtils.isNotBlank(bisInspAllRlationPers.getOrgId())) { OlBisInspOrg olBisInspOrg = olBisInspOrgService.get(bisInspAllRlationPers.getOrgId()); if (olBisInspOrg != null) { bisInspAllRlationPers.setOrgNm(olBisInspOrg.getOrgNm()); bisInspAllRlationPers.setProvince(olBisInspOrg.getAdCode()); } BisInspPersOrg inspPersOrg = new BisInspPersOrg(); inspPersOrg.setOrgId(bisInspAllRlationPers.getOrgId()); inspPersOrg.setPersId(bisInspAllRlationPers.getGuid()); if (StringUtils.isNotBlank(bisInspAllRlationPers.getPersType())) { inspPersOrg.setUserType(bisInspAllRlationPers.getPersType()); } else { inspPersOrg.setUserType(AdCodeLabel.GROUP_LEADER); } BisInspPersOrgParam bisInspPersOrgParam = new BisInspPersOrgParam(); bisInspPersOrgParam.setPersId(inspPersOrg.getPersId()); bisInspPersOrgParam.setOrgId(inspPersOrg.getOrgId()); if (null == persOrgService.getBy(bisInspPersOrgParam)) { persOrgService.insert(inspPersOrg); } } } @ApiOperation(value = "根据id获取人员（对象详情）") @RequestMapping(value = "/{id}", method = {RequestMethod.GET}) public BaseResponse info(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) { String currentPersId = getCurrentPersId(); BisInspAllRlationPers rlationPers = bisInspAllRlationPersService.getById(id); BisInspAllRlationPers currentPers = bisInspAllRlationPersService.getById(currentPersId); rlationPers.setMobilenumb(UserMsgSectrityUtils.blurPhoneNotExc(rlationPers.getMobilenumb())); if (rlationPers != null) { rlationPers.setPwd(null); if (!"1".equals(currentPers.getPersType()) && !getCurrentPersId().equals(rlationPers.getGuid())) { rlationPers = null; } } return buildSuccessResponse(rlationPers); } @Authority(roles = "1") @ApiOperation(value = "根据ID删除人员") @RequestMapping(value = "/delete/{id}", method = {RequestMethod.POST}) public BaseResponse delete(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) { if ("80df1213ad9f493e85a771d6f4b18a17".equals(id)) { return buildFailResponse("管理员账户不允许删除！"); } BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.get(id); int ret = bisInspAllRlationPersService.delete(id); /** * 删除小鱼账号信息 */ try { bisInspMeetInvitationService.batchUsersDel(bisInspAllRlationPers); } catch (IOException e) { e.printStackTrace(); } return buildSuccessResponse(); } @ApiOperation(value = "根据ID添加账号到小鱼通讯录") @RequestMapping(value = "/meeting/add/{id}", method = {RequestMethod.POST}) public BaseResponse addToMeetingUser(@ApiParam(name = "id", value = "id", required = true) @PathVariable String id) { BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.get(id); /** * 添加小鱼账号信息 */ try { int code = bisInspMeetInvitationService.batchUser(bisInspAllRlationPers); if(0==code){ return buildSuccessResponse(); }else { return buildFailResponse(); } } catch (Exception e) { logger.error("添加小鱼账号信息 Exception",e.getMessage()); } return buildSuccessResponse(); } @ApiOperation(value = "绑定人员机构关系") @RequestMapping(value = "/add/presorg", method = {RequestMethod.POST}) public BaseResponse> presorg(@RequestBody List inspPersOrgList) { if (inspPersOrgList == null || inspPersOrgList.isEmpty()) { return buildFailResponse(); } //先删除 BisInspPersOrgParam persOrgParam = new BisInspPersOrgParam(); BisInspPersOrg inspPersOrgOne = inspPersOrgList.get(0); persOrgParam.setPersId(inspPersOrgOne.getPersId()); if (StringUtils.isNotBlank(inspPersOrgOne.getPersId())) { persOrgService.deleteBy(persOrgParam); } //添加 for (BisInspPersOrg inspPersOrg : inspPersOrgList) { inspPersOrg.setUserType(AdCodeLabel.GROUP_LEADER); persOrgService.insert(inspPersOrg); } /* OlBisInspOrg olBisInspOrg = olBisInspOrgService.get(inspPersOrgOne.getOrgId()); if (olBisInspOrg != null) { //更新默认 BisInspAllRlationPers inspAllRlationPers = new BisInspAllRlationPers(); inspAllRlationPers.setOrgId(inspPersOrgOne.getOrgId()); inspAllRlationPers.setOrgNm(olBisInspOrg.getOrgNm()); inspAllRlationPers.setGuid(inspPersOrgOne.getPersId()); bisInspAllRlationPersService.update(inspAllRlationPers); }*/ return buildSuccessResponse(inspPersOrgList); } @Autowired private BisInspAllService bisInspAllService; @ApiOperation(value = "获取系统中的所有督查类型") @RequestMapping(value = "/listInspType", method = {RequestMethod.GET}) public BaseResponse> listInspType() { return buildSuccessResponse(bisInspAllService.listInspType()); } @Authority(roles = "1") @ApiOperation(value = "获取系统中的已经绑定的所有督查类型") @RequestMapping(value = "/list/{orgId}/{persId}", method = {RequestMethod.GET}) public BaseResponse> listBindInspType(@PathVariable String orgId, @PathVariable String persId) { BisInspAllParam inspAllRParam = new BisInspAllParam(); inspAllRParam.setOrgId(orgId); String province = inspOrgService.getProvince(orgId); inspAllRParam.setProvince(province); inspAllRParam.setPersId(persId); List inspAllRlationList = bisInspAllService.findExistList(inspAllRParam); for (BisInspAllRlation allRlation : inspAllRlationList) { String id = allRlation.getId().substring(0, 3); allRlation.setId(id); allRlation.setPersid(persId); allRlation.setAdCode(province); } return buildSuccessResponse(inspAllRlationList); } @Authority(roles = "1") @ApiOperation(value = "删除系统中的已经绑定的所有督查类型,code位类型编码，如001小水库") @RequestMapping(value = "/del/{orgId}/{persId}/{code}", method = {RequestMethod.GET}) public BaseResponse delBindInspType(@PathVariable String orgId, @PathVariable String persId, @PathVariable String code) { String id = code + orgId; BisInspAllParam inspAllParam = new BisInspAllParam(); inspAllParam.setPid(id); List inspAlls = bisInspAllService.findList(inspAllParam); if (inspAlls != null && !inspAlls.isEmpty()) { return buildFailResponse("删除失败，改督查类型已经存在关联数据!!"); } bisInspAllService.delete(id); return buildSuccessResponse("删除成功"); } @ApiOperation(value = "个人账户更新登录") @RequestMapping(value = "/updatePassword", method = {RequestMethod.POST}) public BaseResponse updatePassword(@RequestBody BisInspAllRlationPers bisInspAllRlationPers) { String currentPersId = getCurrentPersId(); BisInspAllRlationPers currentPers = bisInspAllRlationPersService.getById(currentPersId); if (currentPersId != bisInspAllRlationPers.getGuid()) { if (!currentPers.getPersType().equals("1")) { return buildFailResponse("无权限操作！"); } } if (StringUtils.isNotBlank(bisInspAllRlationPers.getGuid()) && StringUtils.isNotBlank(bisInspAllRlationPers.getPwd())) { bisInspAllRlationPers.setPwd(MD5.getMD5(aesUtil.desEncrypt(bisInspAllRlationPers.getPwd()))); bisInspAllRlationPersService.updatePassword(bisInspAllRlationPers); } return buildSuccessResponse(); } @Autowired private BisInspAllRlationService rlationService; @Authority(roles = "1") @ApiOperation(value = "管理员绑定人员管理员和督查类型") @RequestMapping(value = "/add/inspType", method = {RequestMethod.POST}) @Transactional(rollbackFor = Exception.class) public BaseResponse> addInspType(@RequestBody List inspTypeList, String delPersId, String delOrgId) { BisInspAllRlationPers inspAllRlationPers = bisInspAllRlationPersService.get(getCurrentPersId()); if (inspAllRlationPers == null) { return buildFailResponse("当前用户不存在!!"); } if (!"1".equals(inspAllRlationPers.getPersType())) { return buildFailResponse(9993, "当前用户无权限执行该操作!!"); } // 1. 获取 OrgId、 persId、 province 删除所有 与用户-省关联的 数据 BisInspAllRlationParam bisInspAllRlationParam = new BisInspAllRlationParam(); OlBisInspOrg bisInspOrg = null; // 判断 inspTypeList 是否为空，空就只删除数据，不添加数据 if (inspTypeList.size() == 0) { bisInspAllRlationParam.setOrgId(delOrgId); bisInspAllRlationParam.setPersid(delPersId); bisInspAllRlationParam.setProvince(inspOrgService.get(delOrgId).getRlcode()); rlationService.deleteBy(bisInspAllRlationParam); return buildSuccessResponse(); } else { InspType inspTypeOne = inspTypeList.get(0); bisInspAllRlationParam.setOrgId(inspTypeOne.getOrgId()); bisInspAllRlationParam.setPersid(inspTypeOne.getPersId()); bisInspOrg = inspOrgService.get(inspTypeOne.getOrgId()); bisInspAllRlationParam.setProvince(bisInspOrg.getRlcode()); rlationService.deleteBy(bisInspAllRlationParam); } // 2. 循环要添加的督查类别， 添加督查类别 for (InspType inspType : inspTypeList) { BisInspAll rootBisInsp = bisInspAllService.get(inspType.getCode()); // 如果没有这个督查类别就添加督查类别 if (rootBisInsp == null) { rootBisInsp = new BisInspAll(); rootBisInsp.setId(inspType.getCode()); rootBisInsp.setPnm(inspType.getName()); rootBisInsp.setPid(CommonLabel.INIT_DATA); bisInspAllService.insert(rootBisInsp); } String orgId = inspType.getOrgId(); if (inspType.getOrgId().length() == 2) { orgId = "0" + orgId; } // 添加 督查 BisInspAll tree String id = inspType.getCode() + orgId; BisInspAll inspAll = bisInspAllService.get(id); if (inspAll == null) { inspAll = new BisInspAll(); inspAll.setOrgId(inspType.getOrgId()); inspAll.setId(id); inspAll.setPnm(bisInspOrg.getOrgNm() + inspType.getName()); inspAll.setPid(inspType.getCode()); inspAll.setProvince(bisInspOrg.getRlcode()); if (AdCodeLabel.PARENT_ADCODE.equals(bisInspOrg.getRlcode())) { inspAll.setProvince(""); } bisInspAllService.insert(inspAll); } // 重点添加督查 BisInspAllRlation BisInspAllRlationParam rlationParam = new BisInspAllRlationParam(); rlationParam.setPersid(inspType.getPersId()); rlationParam.setId(id); rlationParam.setProvince(bisInspOrg.getRlcode()); BisInspAllRlation allRlation = rlationService.getBy(rlationParam); if (allRlation == null) { allRlation = new BisInspAllRlation(); allRlation.setAdCode(bisInspOrg.getRlcode()); if (AdCodeLabel.PARENT_ADCODE.equals(bisInspOrg.getRlcode())) { allRlation.setAdCode(""); } allRlation.setPersid(inspType.getPersId()); allRlation.setId(id); BisInspAllRlationPers allRlationPers = bisInspAllRlationPersService.get(inspType.getPersId()); if (allRlationPers != null) { allRlation.setPertype(allRlationPers.getPersType()); } allRlation.setOrgId(orgId); allRlation.setType(String.valueOf(Integer.parseInt(inspType.getCode()))); rlationService.insert(allRlation); } } return buildSuccessResponse(inspTypeList); } @Authority(roles = "1") @ApiOperation(value = "管理员绑定人员管理员和督查类型") @RequestMapping(value = "/batchAdd/inspType", method = {RequestMethod.POST}) @Transactional(rollbackFor = Exception.class) public BaseResponse batchAddInspType(@RequestBody InspTypeDto inspTypeDto) { if (CollectionUtils.isEmpty(inspTypeDto.getPersIdList()) && CollectionUtils.isEmpty(inspTypeDto.getPhoneList())) { return buildFailResponse(); } if (CollectionUtils.isEmpty(inspTypeDto.getInspTypeList())) { return buildFailResponse(); } List inspTypeList = inspTypeDto.getInspTypeList(); if (CollectionUtils.isNotEmpty(inspTypeDto.getPersIdList())) { inspTypeDto.getPersIdList().forEach(persId -> { BisInspAllRlationPers p = bisInspAllRlationPersService.get(persId); Optional.ofNullable(p).ifPresent(per -> { for (InspType inspType : inspTypeList) { inspType.setPersId(per.getGuid()); inspType.setOrgId(per.getOrgId()); } addInspType(inspTypeList, per.getGuid(), per.getOrgId()); }); }); } else { inspTypeDto.getPhoneList().forEach(phone -> { BisInspAllRlationPers p = bisInspAllRlationPersService.getBy(Builder.of(BisInspAllRlationPersParam::new) .with(BisInspAllRlationPersParam::setMobilenumb, phone) .build()); Optional.ofNullable(p).ifPresent(per -> { for (InspType inspType : inspTypeList) { inspType.setPersId(per.getGuid()); inspType.setOrgId(per.getOrgId()); } addInspType(inspTypeList, per.getGuid(), per.getOrgId()); }); }); } return buildSuccessResponse(); } @Authority(roles = "1") @ApiOperation(value = "更新人员信息") @RequestMapping(value = "/update", method = {RequestMethod.POST}) public BaseResponse update(@RequestParam(value = "file", required = false) MultipartFile file, @ApiParam(name = "bisInspAllRlationPers", value = "BisInspAllRlationPers", required = true) BisInspAllRlationPers bisInspAllRlationPers) { Assert.notNull(bisInspAllRlationPers.getGuid(), "主键guid为必填参数"); BisInspAllRlationPers inspAllRlationPers = bisInspAllRlationPersService.get(getCurrentPersId()); if (inspAllRlationPers == null) { return buildFailResponse("当前用户不存在!!"); } if (!getCurrentPersId().equals(bisInspAllRlationPers.getGuid()) && !"1".equals(inspAllRlationPers.getPersType())) { return buildFailResponse(9993, "当前用户无权限执行该操作!!"); } if (file != null) { Calendar dat = Calendar.getInstance(); //写入文件 String originalFilename = file.getOriginalFilename(); GwComFile gwComFile = new GwComFile(); gwComFile.setId(bisInspAllRlationPers.getGuid()); gwComFile.setFileName(originalFilename); gwComFile.setFileSize((double) file.getSize()); gwComFile.setFileExt(originalFilename.substring(1 + originalFilename.lastIndexOf("."))); String filePath = prefix + dat.get(Calendar.YEAR) + File.separator + (dat.get(Calendar.MONTH) + 1) + File.separator + dat.get(Calendar.DAY_OF_MONTH) + File.separator + bisInspAllRlationPers.getGuid() + "." + gwComFile.getFileExt(); gwComFile.setFilePath(filePath); if ("JPEG".equals(gwComFile.getFileExt().toUpperCase()) || "JPG".equals(gwComFile.getFileExt().toUpperCase()) || "PNG".equals(gwComFile.getFileExt().toUpperCase())) { //写入文件 String filePath2 = dat.get(Calendar.YEAR) + File.separator + (dat.get(Calendar.MONTH) + 1) + File.separator + dat.get(Calendar.DAY_OF_MONTH); gwComFileService.writeFile(gwComFile, file, filePath2); bisInspAllRlationPers.setImgurl(filePath); } } // addPreOrg(bisInspAllRlationPers); if (StringUtils.isNotBlank(bisInspAllRlationPers.getPwd())) { bisInspAllRlationPers.setPwd(MD5.getMD5(aesUtil.desEncrypt(bisInspAllRlationPers.getPwd().replace(" ", "+")))); } bisInspAllRlationPersService.update(bisInspAllRlationPers); /* //添加人员到小鱼账号 try { bisInspMeetInvitationService.batchUser(bisInspAllRlationPers); } catch (IOException e) { e.printStackTrace(); }*/ return buildSuccessResponse(bisInspAllRlationPers); } @Authority(roles = "1") @ApiOperation(value = "批量更新人员信息") @PostMapping("/batchUpdateType") public BaseResponse batchUpdateType(@RequestBody Map params) { BisInspAllRlationPers inspAllRlationPers = bisInspAllRlationPersService.get(getCurrentPersId()); Optional.ofNullable(inspAllRlationPers).orElseThrow(() -> new CheckException("当前用户不存在!!")); if (!"1".equals(inspAllRlationPers.getPersType())) { return buildFailResponse(9993, "当前用户无权限执行该操作!!"); } List persIdList = (List) params.get("persIdList"); String persType = MapUtils.getString(params, "persType"); if (CollectionUtils.isEmpty(persIdList)) { return buildFailResponse("persIdList is blank"); } if (StringUtils.isBlank(persType)) { return buildFailResponse("persType is blank"); } BisInspAllRlationPers p = new BisInspAllRlationPers(); p.setPersType(persType); persIdList.forEach(id -> { p.setGuid(id); bisInspAllRlationPersService.update(p); }); return buildSuccessResponse(); } @ApiOperation(value = "根据条件获取人员信息列表", notes = "参数字段说明:{\n\r" + " \"guid\"：\"人员ID\",\n\r" + " \"orgId\"：\"机构Id\",\n\r" + " \"orgNm\"：\"机构名称\",\n\r" + " \"dpnm\"：\"部门名称\",\n\r" + " \"dppost\"：\"职称\",\n\r" + " \"school\"：\"学校\",\n\r" + " \"persName\"：\"姓名\",\n\r" + " };\n\r" + "返回结构说明: {\n\r" + " \"code\"：\"请求状态码\",\n\r" + " \"data(数据信息对象) \": {\n\r" + " \"endRow\"：\"尾行\",\n\r" + " \"firstPage\"：\"首页\",\n\r" + " \"hasNextPage\"：\"是否有下一页\",\n\r" + " \"hasPreviousPage\"：\"是否有前一页\",\n\r" + " \"isFirstPage\"：\"是否是第一页\",\n\r" + " \"isLastPage\"：\"是否是最后一页\",\n\r" + " \"lastPage\"：\"最后页\",\n\r" + " \"hasPreviousPage\"：\"是否有前一页\",\n\r" + " \"list（结果集）\"：[\n\r" + " {\n\r" + " \"guid\"：\"人员ID\",\n\r" + " \"orgId\"：\"机构ID\",\n\r" + " \"orgNm\"：\"机构名称\",\n\r" + " \"admDuty\"：\"职务\",\n\r" + " \"orgGrad\"：\"职责\",\n\r" + " \"idnm\"：\"工作证号\",\n\r" + " \"plst\"：\"政治面貌\",\n\r" + " \"school\"：\"学校\",\n\r" + " \"specialty\"：\"专业\",\n\r" + " \"imgurl\"：\"照片地址\",\n\r" + " \"persName\"：\"人员姓名\",\n\r" + " \"pwd\"：\"密码\",\n\r" + " \"telnumb\"：\"电话号码\",\n\r" + " \"mobilenumb\"：\"手机号码\",\n\r" + " \"email\"：\"邮箱\",\n\r" + " \"bornDate\"：\"出生日期\",\n\r" + " \"collTime\"：\"录入日期\",\n\r" + " \"remark\"：\"备注\",\n\r" + " \"faxnumb\"：\"传真号码\",\n\r" + " }\n\r" + " ],\n\r" + " \"navigateFirstPage\"：\"未知\",\n\r" + " \"navigateLastPage\"：\"未知\",\n\r" + " \"navigatePages\"：\"未知\",\n\r" + " \"list（结果集）\"：[\n\r" + " ],\n\r" + " \"nextPage\"：\"下一页\",\n\r" + " \"pageNum\"：\"页码\",\n\r" + " \"pageSize\"：\"每页多少条\",\n\r" + " \"pages\"：\"总页数\",\n\r" + " \"prePage\"：\"前一页\",\n\r" + " \"size\"：\"未知\",\n\r" + " \"startRow\"：\"未知\",\n\r" + " \"total\"：\"总条数\",\n\r" + " },\n\r" + " \"message\"：\"响应消息\",\n\r" + " \"path\"：\"路径\",\n\r" + " \"success\"：\"是否成功\",\n\r" + " \"throwable\"：\"异常\",\n\r" + " }") @Authority(roles = "1") @RequestMapping(value = "/list", method = {RequestMethod.POST}) public BaseResponse> list(@RequestBody BisInspAllRlationPersParam p) { PageInfo list = bisInspAllRlationPersService.findPersData(p); for (int i = 0; i < list.getList().size(); i++) { String tel = list.getList().get(i).getMobilenumb() == null ? "" : list.getList().get(i).getMobilenumb().toString(); if (!"".equals(tel)) { list.getList().get(i).setMobilenumb(TelUtil.getTel(tel)); } } return buildSuccessResponse(list); } @ApiOperation(value = "根据id获取人员（对象详情）") @RequestMapping(value = "/createWork", method = {RequestMethod.GET}) public BaseResponse createWork() { boolean bol = bisInspAllRlationPersService.createWork(); return buildSuccessResponse("true"); } @ApiOperation(value = "设置组长") @RequestMapping(value = "/setHeadMan", method = {RequestMethod.GET}) public BaseResponse setHeadMan(@ApiParam(name = "BisInspAllRlation", value = "BisInspAllRlation", required = true) BisInspAllRlation bisInspAllRlation) { int i = bisInspAllRlationPersService.setHeadMan(bisInspAllRlation); return buildSuccessResponse(); } @ApiOperation(value = "修改密码", notes = "参数字段说明:{\n\r" + " \"userCode\"：\"用户编码\",\n\r" + " \"oldPassword\"：\"旧密码\",\n\r" + " \"newPassword\"：\"新 密码\",\n\r" + " };\n\r" + "返回结构说明：{\n\r" + " \"success\"：\"是否成功（true为成功，false为失败）\",\n\r" + " \"code\"：\"错误代码\",\n\r" + " \"message\"：\"描述信息\",\n\r" + " \"throwable\"：\"异常信息\",\n\r" + " \"data\"：null") @RequestMapping(value = "changePassword", method = RequestMethod.POST) public BaseResponse changePassword(String userCode, String password, String newPassword) { Assert.notNull(userCode, "主键id为必填参数"); Assert.notNull(password, "修改前密码不能为空"); Assert.notNull(newPassword, "新密码不能为空"); int ret = bisInspAllRlationPersService.changePassword(userCode, password, newPassword); if (0 == ret) { return buildFailResponse(0, "用户不存在"); } if (2 == ret) { return buildFailResponse(2, "原密码错误，修改密码失败"); } return buildSuccessResponse(); } @ApiOperation(value = "修改用户（关联角色）") @RequestMapping(value = "updateUser", method = RequestMethod.POST) public BaseResponse updateUser(@ApiParam(name = "bisInspAllRlationPers", value = "bisInspAllRlationPers", required = true) @RequestBody BisInspAllRlationPers bisInspAllRlationPers) { Assert.notNull(bisInspAllRlationPers, "用户对象不能为空"); Assert.notNull(bisInspAllRlationPers.getGuid(), "用户ID不能为空"); BisInspAllRlationPers inspAllRlationPers = bisInspAllRlationPersService.get(getCurrentPersId()); if (inspAllRlationPers == null) { return buildFailResponse("当前用户不存在!!"); } //只有管理员能够操作 if (!"1".equals(inspAllRlationPers.getPersType())) { return buildFailResponse(9993, "当前用户无权限执行该操作!!"); } logger.info("修改用户权限1"); ArrayList userRoleParams = new ArrayList<>(); if (null != bisInspAllRlationPers.getRoleIds() && bisInspAllRlationPers.getRoleIds().size() > 0) { for (String roleId : bisInspAllRlationPers.getRoleIds()) { UserRoleParam userRoleParam = new UserRoleParam(); userRoleParam.setUserId(bisInspAllRlationPers.getGuid()); userRoleParam.setRoleId(roleId); userRoleParams.add(userRoleParam); } } UserRoleParam param = new UserRoleParam(); param.setUserId(bisInspAllRlationPers.getGuid()); BisInspAllRlationPers per = new BisInspAllRlationPers(); per.setGuid(bisInspAllRlationPers.getGuid()); if (StringUtils.isNotBlank(bisInspAllRlationPers.getOwnerSystem())) { per.setOwnerSystem(bisInspAllRlationPers.getOwnerSystem()); bisInspAllRlationPersService.update(per); } logger.info("修改用户权限2"); bisInspAllRlationPersService.updateUser(userRoleParams, param); logger.info("修改用户权限3"); /* //修改用户类型，为用户添加节点 if (bisInspAllRlationPers.getPersType() != null) { bisInspAllRlationPersService.updateUserNode(bisInspAllRlationPers.getGuid(), bisInspAllRlationPers.getPersType(), getCurrentOrgId()); }*/ return buildSuccessResponse(); } @Authority(roles = "1") @ApiOperation(value = "修改用户（关联角色）") @PostMapping("/batch/updateRole") public BaseResponse batchUpdateRole(@RequestBody Map params) { BisInspAllRlationPers inspAllRlationPers = bisInspAllRlationPersService.get(getCurrentPersId()); if (inspAllRlationPers == null) { return buildFailResponse("当前用户不存在!!"); } //只有管理员能够操作 if (!"1".equals(inspAllRlationPers.getPersType())) { return buildFailResponse(9993, "当前用户无权限执行该操作!!"); } List roleIds = (List) params.get("roleIds"); List persIdList = (List) params.get("persIdList"); if (CollectionUtils.isEmpty(persIdList) || CollectionUtils.isEmpty(roleIds)) { return buildFailResponse("roleIds or persIdList is blank"); } persIdList.stream().distinct().forEach(id -> updateRole(id, roleIds)); return buildSuccessResponse(); } /** * 更新用户角色 * * @param guid 用户ID * @param roleIds 角色ID */ private void updateRole(String guid, List roleIds) { List userRoleParams = new ArrayList<>(); for (String roleId : roleIds) { UserRoleParam userRoleParam = new UserRoleParam(guid, roleId); userRoleParams.add(userRoleParam); } UserRoleParam param = new UserRoleParam(); param.setUserId(guid); bisInspAllRlationPersService.updateUser(userRoleParams, param); } @ApiOperation(value = "获取在线用户个数", notes = "参数字段说明:{\n\r" + " \"startTime\"：\"统计开始时间(非必填),默认统计最近两小时的在线人员\",\n\r" + " \"endTime\"：\"统计结束时间(非必填)\",\n\r" + " };\n\r" + "返回结构说明：{\n\r" + " \"success\"：\"是否成功（true为成功，false为失败）\",\n\r" + " \"code\"：\"错误代码\",\n\r" + " \"message\"：\"描述信息\",\n\r" + " \"throwable\"：\"异常信息\",\n\r" + " \"data\"：\"在线人数\"") @RequestMapping(value = "/getCountOnlinePers", method = RequestMethod.GET) public BaseResponse getCountOnlinePers(@RequestParam(required = false) String startTime, @RequestParam(required = false) String endTime) { if (StringUtils.isBlank(endTime)) { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Calendar calendar = Calendar.getInstance(); endTime = sdf.format(calendar.getTime()); calendar.set(Calendar.HOUR, calendar.get(Calendar.HOUR) - 2); startTime = sdf.format(calendar.getTime()); } String province = olBisInspOrgService.getProvince(getCurrentOrgId()); int ret = bisInspAllRlationPersService.selectCountOnlinePers(startTime, endTime, province); return buildSuccessResponse(ret); } @ApiOperation(value = "获取在线用户", notes = "参数字段说明:{\n\r" + " \"startTime\"：\"统计开始时间(非必填),默认统计最近两小时的在线人员\",\n\r" + " \"endTime\"：\"统计结束时间(非必填)\",\n\r" + " };\n\r" + "返回结构说明: {\n\r" + " \"code\"：\"请求状态码\",\n\r" + " \"data(数据信息对象) \": {\n\r" + " \"endRow\"：\"尾行\",\n\r" + " \"firstPage\"：\"首页\",\n\r" + " \"hasNextPage\"：\"是否有下一页\",\n\r" + " \"hasPreviousPage\"：\"是否有前一页\",\n\r" + " \"isFirstPage\"：\"是否是第一页\",\n\r" + " \"isLastPage\"：\"是否是最后一页\",\n\r" + " \"lastPage\"：\"最后页\",\n\r" + " \"hasPreviousPage\"：\"是否有前一页\",\n\r" + " \"list（结果集）\"：[\n\r" + " {\n\r" + " \"guid\"：\"人员ID\",\n\r" + " \"orgId\"：\"机构ID\",\n\r" + " \"orgNm\"：\"机构名称\",\n\r" + " \"admDuty\"：\"职务\",\n\r" + " \"orgGrad\"：\"职责\",\n\r" + " \"idnm\"：\"工作证号\",\n\r" + " \"plst\"：\"政治面貌\",\n\r" + " \"school\"：\"学校\",\n\r" + " \"specialty\"：\"专业\",\n\r" + " \"imgurl\"：\"照片地址\",\n\r" + " \"persName\"：\"人员姓名\",\n\r" + " \"pwd\"：\"密码\",\n\r" + " \"telnumb\"：\"电话号码\",\n\r" + " \"mobilenumb\"：\"手机号码\",\n\r" + " \"email\"：\"邮箱\",\n\r" + " \"bornDate\"：\"出生日期\",\n\r" + " \"collTime\"：\"录入日期\",\n\r" + " \"remark\"：\"备注\",\n\r" + " \"faxnumb\"：\"传真号码\",\n\r" + " }\n\r" + " ],\n\r" + " \"navigateFirstPage\"：\"未知\",\n\r" + " \"navigateLastPage\"：\"未知\",\n\r" + " \"navigatePages\"：\"未知\",\n\r" + " \"list（结果集）\"：[\n\r" + " ],\n\r" + " \"nextPage\"：\"下一页\",\n\r" + " \"pageNum\"：\"页码\",\n\r" + " \"pageSize\"：\"每页多少条\",\n\r" + " \"pages\"：\"总页数\",\n\r" + " \"prePage\"：\"前一页\",\n\r" + " \"size\"：\"未知\",\n\r" + " \"startRow\"：\"未知\",\n\r" + " \"total\"：\"总条数\",\n\r" + " },\n\r" + " \"message\"：\"响应消息\",\n\r" + " \"path\"：\"路径\",\n\r" + " \"success\"：\"是否成功\",\n\r" + " \"throwable\"：\"异常\",\n\r" + " }") @RequestMapping(value = "/getOnlinePers", method = RequestMethod.GET) public BaseResponse getCountOnlinePers2(@RequestParam(required = false) String sttm, @RequestParam(required = false) String entm) { if (StringUtils.isBlank(entm)) { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Calendar calendar = Calendar.getInstance(); entm = sdf.format(calendar.getTime()); calendar.set(Calendar.HOUR, calendar.get(Calendar.HOUR) - 2); sttm = sdf.format(calendar.getTime()); } List> ret = bisInspAllRlationPersService.selectOnlinePers(sttm, entm, getCurrentOrgId()); return buildSuccessResponse(ret); } @ApiOperation(value = "更新人员小鱼账号") @RequestMapping(value = "/updateCallNumber", method = {RequestMethod.POST}) public BaseResponse updateCallNumber(HttpServletRequest request, @RequestBody UpdateCallNumberParam param ) throws Exception { if (StringUtils.isBlank(param.getPersId())) { param.setPersId(request.getHeader("persId")); } if (StringUtils.isBlank(param.getPersId())) { throw new Exception("缺少persId"); } if (StringUtils.isBlank(param.getCallNumber())) { throw new Exception("缺少callNumber"); } BisInspAllRlationPers p = new BisInspAllRlationPers(); p.setGuid(param.getPersId()); p.setCallnumber(param.getCallNumber()); int ret = bisInspAllRlationPersService.update(p); if (ret == -2147482646) { return buildSuccessResponse(p); } else { return buildFailResponse(500, "更新失败", request.getRequestURI(), ""); } } @ApiOperation(value = "获取小组组长信息") @RequestMapping(value = "getLeaderByGroup", method = RequestMethod.POST) public BaseResponse getLeaderByGroup(@RequestBody GroupLeaderParam groupLeaderParam) { BisInspOrg inspOrg = bisInspOrgDao.get(getCurrentOrgId()); if (inspOrg != null && !inspOrg.getRlcode().startsWith(AdCodeLabel.START_PARENT_ADCODE)) { groupLeaderParam.setProvince(inspOrg.getRlcode()); } return buildSuccessResponse(this.bisInspAllRlationPersService.getLeaderByGroup(groupLeaderParam)); } // @Authority(roles = "1") @VerifyBean @ApiOperation(value = "获取用户列表（用户管理界面）") @RequestMapping(value = "listByCurUser", method = RequestMethod.POST) public BaseResponse> listByCurUser(@RequestBody UserListByCurUserParam param) throws Exception { String addvcd = AdLevelUtil.getAddvcd(olBisInspOrgService.getRlProvince(getCurrentOrgId())); BisInspOrg inspOrg = bisInspOrgDao.get(getCurrentOrgId()); if (inspOrg != null && !inspOrg.getRlcode().startsWith(AdCodeLabel.START_PARENT_ADCODE)) { param.setProvince(AdLevelUtil.getAddvcd(inspOrg.getRlcode())); } else { param.setOrgId(""); } PageInfo list = bisInspAllRlationPersService.listByCurUser(param, addvcd); return buildSuccessResponse(list); } @Authority @ApiOperation(value = "获取督查组中人员类型--人员类型(1：组长；2：组员；3：联络员；4：专家；11：前期专家；12：监管专家；13：计划专家；14：财务专家；15：质量专家；16：安全专家；19：助理；20：特派员)") @RequestMapping(value = "/getPerType", method = RequestMethod.POST) public BaseResponse> getPerType(@ApiParam(name = "inspGroupId", value = "组ID", required = true) @RequestParam String inspGroupId, @ApiParam(name = "persId", value = "人员ID", required = true) @RequestParam String persId) { BisInspAllRlationParam param = new BisInspAllRlationParam(); param.setId(inspGroupId); param.setPersid(persId); List list = bisInspAllRlationService.findList(param); if (list == null || list.size() == 0) { list = new ArrayList<>(); BisInspAllRlation bisInspAllRlation = new BisInspAllRlation(); bisInspAllRlation.setId(inspGroupId); bisInspAllRlation.setPersid(persId); bisInspAllRlation.setPertype("1"); list.add(bisInspAllRlation); } return buildSuccessResponse(list); } @Authority @ApiOperation(value = "获取稽察组中人员类型--人员类型(1：组长；2：组员；3：联络员；4：专家；11：前期专家；12：监管专家；13：计划专家；14：财务专家；15：质量专家；16：安全专家；19：助理；20：特派员)") @RequestMapping(value = "/getPerTypeNew", method = RequestMethod.GET) public BaseResponse> getPerTypeNew(@ApiParam(name = "inspGroupId", value = "组ID", required = true) @RequestParam String inspGroupId, @ApiParam(name = "persId", value = "人员ID", required = true) @RequestParam String persId) { BisInspAllRlationPers pers = bisInspAllRlationPersService.get(persId); List list = new ArrayList<>(); if ("1".equals(pers.getPersType())) { BisInspAllRlation bisInspAllRlation = new BisInspAllRlation(); bisInspAllRlation.setId(inspGroupId); bisInspAllRlation.setPersid(persId); bisInspAllRlation.setPertype("1"); list.add(bisInspAllRlation); } if (list.size() == 0) { TacInspYearBatchGroupPersParam param = new TacInspYearBatchGroupPersParam(); param.setGroupId(inspGroupId); param.setPersId(persId); List rlations = groupPersService.findPersList(param); list.addAll(rlations); } if (list.size() == 0) { BisInspAllRlation bisInspAllRlation = new BisInspAllRlation(); bisInspAllRlation.setId(inspGroupId); bisInspAllRlation.setPersid(persId); bisInspAllRlation.setPertype("1"); list.add(bisInspAllRlation); } return buildSuccessResponse(list); } @ApiOperation(value = "获取加密公钥，并且把对应私钥储存到Redis") @RequestMapping(value = "/getPubKey", method = RequestMethod.POST) public BaseResponse getPubKey() { Map keyMap = Encryption.genKeyPair(); redisTemplate.opsForValue().set(keyMap.get(0), keyMap.get(1), 10, TimeUnit.MINUTES); return buildSuccessResponse(keyMap.get(0)); } @ApiOperation(value = "退出系统") @RequestMapping(value = "/logOut", method = RequestMethod.GET) public BaseResponse logOut(HttpServletRequest request) { String uuid = request.getHeader(CommonLabel.ACCESS_TOKEN); String accessToken = (String) redisTemplate.opsForValue().get(uuid); if (StringUtils.isNotBlank(accessToken)) { String persId = request.getHeader(CommonLabel.PERSID); LoginUser inspAllRlationPers = JWTTokenUtil.unsign(accessToken, persId); if (inspAllRlationPers != null) { BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.get(inspAllRlationPers.getPersId()); //bisInspAllRlationPersService.sendChannel(uuid, bisInspAllRlationPers, request, PlusEnum.PLUS.getNumber()); } } redisTemplate.delete(uuid); return buildSuccessResponse(); } @ApiOperation(value = "添加多用户") @RequestMapping(value = "/updateListUsers", method = RequestMethod.POST) public BaseResponse updateUsers(@ApiParam(name = "AddRlationPersDto", value = "AddRlationPersDto", required = true) @RequestBody AddRlationPersDto addRlationPersDto) { return buildSuccessResponse(bisInspAllRlationPersService.updateListUsers(addRlationPersDto)); } @ApiOperation(value = "获取对象信息") @RequestMapping(value = "/getUserById", method = RequestMethod.POST) public BaseResponse getUserById(HttpServletRequest request) { String persId = request.getHeader(CommonLabel.PERSID); BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.get(persId); return buildSuccessResponse(bisInspAllRlationPers); } @ApiOperation(value = "获取对象信息") @RequestMapping(value = "/getUserInfo", method = RequestMethod.POST) public BaseResponse getUserInfo(@RequestParam String persId) { BisInspAllRlationPers bisInspAllRlationPers = bisInspAllRlationPersService.get(persId); bisInspAllRlationPers = getBisInspAllRlations(bisInspAllRlationPers); return buildSuccessResponse(bisInspAllRlationPers); } }