| | |
|---|
| | | */ |
|---|
| | | private final String UPLOAD_EXCEL = "社区党员数据导入模板.xlsx"; |
|---|
| | | |
|---|
| | | @ApiOperation(value = "社区所有党组织",response = PartyOrganizationVO.class) |
|---|
| | | @ApiOperation(value = "社区所有党组织", response = PartyOrganizationVO.class) |
|---|
| | | @GetMapping("listpartyorganization") |
|---|
| | | public R listPartyOrganization() { |
|---|
| | | Long communityId = this.getCommunityId(); |
|---|
| | | log.info("社区所有党组织社区id【{}】",communityId); |
|---|
| | | log.info("社区所有党组织社区id【{}】", communityId); |
|---|
| | | return partyBuildingService.listPartyOrganization(communityId); |
|---|
| | | } |
|---|
| | | @OperLog(operModul = "党员管理",operType = 1) |
|---|
| | | |
|---|
| | | @OperLog(operModul = "党员管理", operType = 1) |
|---|
| | | @ApiOperation(value = "新增党员") |
|---|
| | | @PostMapping("addpartybuildingmember") |
|---|
| | | public R addPartyBuildingMember(@RequestBody PartyBuildingMemberVO partyBuildingMemberVO) { |
|---|
| | |
|---|
| | | partyBuildingMemberVO.setCommunityId(communityId); |
|---|
| | | R r = partyBuildingService.addPartyBuildingMember(partyBuildingMemberVO); |
|---|
| | | if (R.isOk(r)) { |
|---|
| | | R r1=userService.updateUserIsPartymember(partyBuildingMemberVO.getIdCard()); |
|---|
| | | R r1 = userService.updateUserIsPartymember(partyBuildingMemberVO.getIdCard()); |
|---|
| | | } |
|---|
| | | return r; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @OperLog(operModul = "党员管理",operType = 2) |
|---|
| | | @OperLog(operModul = "党员管理", operType = 2) |
|---|
| | | @ApiOperation(value = "编辑党员") |
|---|
| | | @PutMapping("updatepartybuildingmember") |
|---|
| | | public R updatePartyBuildingMember(@RequestBody PartyBuildingMemberVO partyBuildingMemberVO) { |
|---|
| | | Long id = partyBuildingMemberVO.getId(); |
|---|
| | | if (null==id||0==id) { |
|---|
| | | if (null == id || 0 == id) { |
|---|
| | | return R.fail("党员id不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.updatePartyBuildingMember(partyBuildingMemberVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "下载模板-导入党员") |
|---|
| | | @GetMapping(value = "downloadtemplate",headers="Accept=application/octet-stream") |
|---|
| | | public ResponseEntity<InputStreamResource> downloadTemplate(HttpServletResponse response, HttpServletRequest request) throws IOException, SftpException { |
|---|
| | | @GetMapping(value = "downloadtemplate", headers = "Accept=application/octet-stream") |
|---|
| | | public R downloadTemplate(HttpServletResponse response) throws IOException, SftpException { |
|---|
| | | SFTPUtil sftp = new SFTPUtil(); |
|---|
| | | sftp.login(); |
|---|
| | | InputStream inputStream = sftp.downloadInputStream(FtpConstants.FTPFILEPATH_MUBAN, UPLOAD_EXCEL); |
|---|
| | | HttpHeaders headers = new HttpHeaders(); |
|---|
| | | headers.add("Cache-Control", "no-cache, no-store, must-revalidate"); |
|---|
| | | headers.add("Content-Disposition", String.format("attachment; filename=\"%s\"", UPLOAD_EXCEL)); |
|---|
| | | headers.add("Pragma", "no-cache"); |
|---|
| | | headers.add("Expires", "0"); |
|---|
| | | // 配置文件下载 |
|---|
| | | response.setHeader("content-type", "application/octet-stream"); |
|---|
| | | response.setContentType("application/octet-stream"); |
|---|
| | | // 下载文件能正常显示中文 |
|---|
| | | response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(UPLOAD_EXCEL, "UTF-8")); |
|---|
| | | response.setCharacterEncoding("UTF-8"); |
|---|
| | | |
|---|
| | | return ResponseEntity |
|---|
| | | .ok() |
|---|
| | | .headers(headers) |
|---|
| | | // .contentLength(file.contentLength()) |
|---|
| | | .contentType(MediaType.parseMediaType("application/msexcel")) |
|---|
| | | .body(new InputStreamResource(inputStream)); |
|---|
| | | |
|---|
| | | // 实现文件下载 |
|---|
| | | byte[] buffer = new byte[1024]; |
|---|
| | | BufferedInputStream bis = null; |
|---|
| | | try { |
|---|
| | | bis = new BufferedInputStream(inputStream); |
|---|
| | | OutputStream os = response.getOutputStream(); |
|---|
| | | int i = bis.read(buffer); |
|---|
| | | while (i != -1) { |
|---|
| | | os.write(buffer, 0, i); |
|---|
| | | i = bis.read(buffer); |
|---|
| | | } |
|---|
| | | } catch (Exception exception) { |
|---|
| | | log.error("下载出错"); |
|---|
| | | return R.fail(); |
|---|
| | | } finally { |
|---|
| | | if (null != bis) { |
|---|
| | | bis.close(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return R.ok(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "上传照片") |
|---|
| | | @PostMapping(value = "uploadimage",consumes = "multipart/*",headers = "content-type=multipart/form-date") |
|---|
| | | @PostMapping(value = "uploadimage", consumes = "multipart/*", headers = "content-type=multipart/form-date") |
|---|
| | | public R uploadImage(@RequestParam MultipartFile file, HttpServletRequest request) { |
|---|
| | | String name = file.getOriginalFilename(); |
|---|
| | | try { |
|---|
| | |
|---|
| | | InputStream is = file.getInputStream(); |
|---|
| | | sftp.uploadMore(FtpConstants.FTPFILEPATH_IDCARD, name, is); |
|---|
| | | sftp.logout(); |
|---|
| | | return R.ok(FtpConstants.HTTP_URL+"/idcard/" + name); |
|---|
| | | return R.ok(FtpConstants.HTTP_URL + "/idcard/" + name); |
|---|
| | | } catch (Exception e) { |
|---|
| | | log.error("上传照片失败【{}】", e.getMessage()); |
|---|
| | | return R.fail(); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "批量新增党员导入excel") |
|---|
| | | @PostMapping(value = "downloadtemplate", consumes = "multipart/*",headers = "content-type=multipart/form-date") |
|---|
| | | @PostMapping(value = "downloadtemplate", consumes = "multipart/*", headers = "content-type=multipart/form-date") |
|---|
| | | public R downloadTemplate(@RequestParam MultipartFile file, HttpServletRequest request) { |
|---|
| | | String fileName = file.getOriginalFilename(); //获取文件名 |
|---|
| | | if (!fileName.equals(UPLOAD_EXCEL)) { |
|---|
| | | return R.fail(400, "文件名字错误"); |
|---|
| | | } |
|---|
| | | log.info("传入文件名字【{}】",fileName); |
|---|
| | | InputStream inputStream = null; |
|---|
| | | try { |
|---|
| | | inputStream = file.getInputStream();//todo 导入要看数据库有无重复数据 加入社区字段 身份证字段导入重复判断 |
|---|
| | | EasyExcel.read(inputStream, PartyBuildingMemberExcelVO.class, new PartyBuildingMemberExcelListen(partyBuildingService)).sheet().doRead(); |
|---|
| | | } catch (IOException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | log.error("导入模板失败【{}】",e.getMessage()); |
|---|
| | | log.error("导入模板失败【{}】", e.getMessage()); |
|---|
| | | } |
|---|
| | | return R.ok(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "党员管理分页查询",response = PartyBuildingMemberVO.class) |
|---|
| | | @ApiOperation(value = "党员管理分页查询", response = PartyBuildingMemberVO.class) |
|---|
| | | @PostMapping("pagepartyorganization") |
|---|
| | | public R pagePartyOrganization(@RequestBody PagePartyOrganizationVO pagePartyOrganizationVO) { |
|---|
| | | pagePartyOrganizationVO.setCommunityId(this.getCommunityId()); |
|---|
| | | return partyBuildingService.pagePartyOrganization(pagePartyOrganizationVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "党员档案--党员活动",response = PartyBuildingActivityVO.class) |
|---|
| | | @ApiOperation(value = "党员档案--党员活动", response = PartyBuildingActivityVO.class) |
|---|
| | | @PostMapping("listpartymemberactivities") |
|---|
| | | public R listPartyMemberActivities(@RequestBody PartyBuildingActivityVO partyBuildingActivityVO) { |
|---|
| | | return partyBuildingService.listPartyMemberActivities(partyBuildingActivityVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "活动报名名单分页查询",response = PageActivityMembersVO.class) |
|---|
| | | @ApiOperation(value = "活动报名名单分页查询", response = PageActivityMembersVO.class) |
|---|
| | | @PostMapping("pageactivitymembers") |
|---|
| | | public R pageActivityMembers(@RequestBody PageActivityMembersVO pageActivityMembersVO) { |
|---|
| | | return partyBuildingService.pageActivityMembers(pageActivityMembersVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "活动详情",response = PartyBuildingActivityVO.class) |
|---|
| | | @ApiOperation(value = "活动详情", response = PartyBuildingActivityVO.class) |
|---|
| | | @GetMapping("activityinfo") |
|---|
| | | public R activityinfo(@RequestParam("id") Long id) { |
|---|
| | | Long userId = this.getUserId(); |
|---|
| | | return partyBuildingService.activityinfo(id,userId); |
|---|
| | | return partyBuildingService.activityinfo(id, userId); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "新增党员活动") |
|---|
| | |
|---|
| | | @PutMapping("updateactivity") |
|---|
| | | public R updateActivity(@RequestBody PartyBuildingActivityVO partyBuildingActivityVO) { |
|---|
| | | Long id = partyBuildingActivityVO.getId(); |
|---|
| | | if (null==id||0==id) {//todo 修改报名人数 最低人数 0 的判断 |
|---|
| | | if (null == id || 0 == id) {//todo 修改报名人数 最低人数 0 的判断 |
|---|
| | | return R.fail("主键不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.updateActivity(partyBuildingActivityVO); |
|---|
| | |
|---|
| | | @PutMapping("releaseactivity") |
|---|
| | | public R releaseActivity(@RequestBody PartyBuildingActivityVO partyBuildingActivityVO) { |
|---|
| | | Long id = partyBuildingActivityVO.getId(); |
|---|
| | | if (null==id||0==id) { |
|---|
| | | if (null == id || 0 == id) { |
|---|
| | | return R.fail("主键不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.releaseActivity(id); |
|---|
| | |
|---|
| | | @DeleteMapping("deleteactivity") |
|---|
| | | public R deleteActivity(@RequestBody PartyBuildingActivityVO partyBuildingActivityVO) { |
|---|
| | | Long id = partyBuildingActivityVO.getId(); |
|---|
| | | if (null==id||0==id) { |
|---|
| | | if (null == id || 0 == id) { |
|---|
| | | return R.fail("主键不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.deleteActivity(id); |
|---|
| | |
|---|
| | | String cancelReason = partyBuildingActivityVO.getCancelReason(); |
|---|
| | | boolean emptycancelReason = ObjectUtils.isEmpty(cancelReason); |
|---|
| | | boolean emptyid = ObjectUtils.isEmpty(id); |
|---|
| | | if (emptycancelReason||emptyid) { |
|---|
| | | if (emptycancelReason || emptyid) { |
|---|
| | | return R.fail("参数不全"); |
|---|
| | | } |
|---|
| | | R r = partyBuildingService.cancelActivity(partyBuildingActivityVO); |
|---|
| | | if (R.isOk(r)) { |
|---|
| | | R r1=partyBuildingService.selectAllPartyBuildingActivityMembers(id); |
|---|
| | | R r1 = partyBuildingService.selectAllPartyBuildingActivityMembers(id); |
|---|
| | | if (R.isOk(r1)) { |
|---|
| | | List<Long> userIds=(List<Long>)r1.getData(); |
|---|
| | | List<Long> userIds = (List<Long>) r1.getData(); |
|---|
| | | userIds.forEach(aLong -> { |
|---|
| | | SysUserNoticeVO sysUserNoticeVO=new SysUserNoticeVO(); |
|---|
| | | SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO(); |
|---|
| | | sysUserNoticeVO.setUserId(aLong); |
|---|
| | | sysUserNoticeVO.setType(1); |
|---|
| | | sysUserNoticeVO.setTitle("活动因故取消"); |
|---|
| | | sysUserNoticeVO.setBusinessType(2); |
|---|
| | | sysUserNoticeVO.setBusinessTitle(partyBuildingActivityVO.getName()); |
|---|
| | | sysUserNoticeVO.setBusinessContent(String.format("取消原因%s",partyBuildingActivityVO.getCancelReason())); |
|---|
| | | sysUserNoticeVO.setBusinessContent(String.format("取消原因%s", partyBuildingActivityVO.getCancelReason())); |
|---|
| | | sysUserNoticeVO.setBusinessId(id); |
|---|
| | | sysUserNoticeVO.setStatus(0); |
|---|
| | | sysUserNoticeVO.setBusinessStatus(1); |
|---|
| | |
|---|
| | | return r; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "分页查询党员活动",response = PageActivityMembersVO.class) |
|---|
| | | @ApiOperation(value = "分页查询党员活动", response = PageActivityMembersVO.class) |
|---|
| | | @PostMapping("pageactivity") |
|---|
| | | public R pageActivity(@RequestBody PartyBuildingActivityVO partyBuildingActivityVO) { |
|---|
| | | Long CommunityId=this.getCommunityId(); |
|---|
| | | Long CommunityId = this.getCommunityId(); |
|---|
| | | partyBuildingActivityVO.setCommunityId(CommunityId); |
|---|
| | | return partyBuildingService.pageActivity(partyBuildingActivityVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "社区下拉选择党员",response = PartyBuildingMemberVO.class) |
|---|
| | | @ApiOperation(value = "社区下拉选择党员", response = PartyBuildingMemberVO.class) |
|---|
| | | @GetMapping("listpartymember") |
|---|
| | | public R listPartyMember() { |
|---|
| | | Long communityId =this.getCommunityId(); |
|---|
| | | Long communityId = this.getCommunityId(); |
|---|
| | | return partyBuildingService.listPartyMember(communityId); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "社区下拉选择身份",response = RoleVO.class) |
|---|
| | | @ApiOperation(value = "社区下拉选择身份", response = RoleVO.class) |
|---|
| | | @GetMapping("listidentity") |
|---|
| | | public R listIdentity() { |
|---|
| | | Long communityId =this.getCommunityId(); |
|---|
| | | Long communityId = this.getCommunityId(); |
|---|
| | | return userService.listIdentity(communityId); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @OperLog(operModul = "党委管理",operType = 1) |
|---|
| | | @OperLog(operModul = "党委管理", operType = 1) |
|---|
| | | @ApiOperation(value = "新增党委") |
|---|
| | | @PostMapping("addpartycommittee") |
|---|
| | | public R addPartyCommittee(@RequestBody PartyCommitteeVO partyCommitteeVO) { |
|---|
| | | Long communityId =this.getCommunityId(); |
|---|
| | | Long communityId = this.getCommunityId(); |
|---|
| | | partyCommitteeVO.setCommunityId(communityId); |
|---|
| | | return partyBuildingService.addPartyCommittee(partyCommitteeVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @OperLog(operModul = "党委管理",operType = 2) |
|---|
| | | @OperLog(operModul = "党委管理", operType = 2) |
|---|
| | | @ApiOperation(value = "编辑党委") |
|---|
| | | @PutMapping("updatepartycommittee") |
|---|
| | | public R updatePartyCommittee(@RequestBody PartyCommitteeVO partyCommitteeVO) { |
|---|
| | |
|---|
| | | return partyBuildingService.updatePartyCommittee(partyCommitteeVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @OperLog(operModul = "党委管理",operType = 3) |
|---|
| | | @OperLog(operModul = "党委管理", operType = 3) |
|---|
| | | @ApiOperation(value = "删除党委") |
|---|
| | | @DeleteMapping("deletepartycommittee") |
|---|
| | | public R deletePartyCommittee(@RequestBody PartyCommitteeVO partyCommitteeVO) { |
|---|
| | |
|---|
| | | return partyBuildingService.deletePartyCommittee(partyCommitteeVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "分页党委查询",response = PartyCommitteeVO.class) |
|---|
| | | @ApiOperation(value = "分页党委查询", response = PartyCommitteeVO.class) |
|---|
| | | @PostMapping("pagepartycommittee") |
|---|
| | | public R pagePartyCommittee(@RequestBody PartyCommitteeVO partyCommitteeVO) { |
|---|
| | | Long communityId = this.getCommunityId(); |
|---|
| | |
|---|
| | | @PutMapping("updatedynamic") |
|---|
| | | public R updateYnamic(@RequestBody PartyBuildingComPbDynVO partyCommitteeVO) { |
|---|
| | | Long id = partyCommitteeVO.getId(); |
|---|
| | | if (null==id||0==id) { |
|---|
| | | if (null == id || 0 == id) { |
|---|
| | | return R.fail("动态主键不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.updateYnamic(partyCommitteeVO); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "动态/政策文件详情",response = PartyBuildingComPbDynVO.class) |
|---|
| | | @ApiOperation(value = "动态/政策文件详情", response = PartyBuildingComPbDynVO.class) |
|---|
| | | @GetMapping("infodynamic") |
|---|
| | | public R infoYnamic(@RequestParam("id") Long id) { |
|---|
| | | return partyBuildingService.infoYnamic(id); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @ApiOperation(value = "分页查询党员动态/政策文件",response = PartyCommitteeVO.class) |
|---|
| | | @ApiOperation(value = "分页查询党员动态/政策文件", response = PartyCommitteeVO.class) |
|---|
| | | @PostMapping("pagedynamic") |
|---|
| | | public R pageYnamic(@RequestBody PartyBuildingComPbDynVO partyBuildingComPbDynVO) { |
|---|
| | | Integer type = partyBuildingComPbDynVO.getType(); |
|---|
| | | if (null==type||0==type) { |
|---|
| | | if (null == type || 0 == type) { |
|---|
| | | return R.fail("类型不能为空"); |
|---|
| | | } |
|---|
| | | Long communityId=this.getCommunityId(); |
|---|
| | | Long communityId = this.getCommunityId(); |
|---|
| | | partyBuildingComPbDynVO.setCommunityId(communityId); |
|---|
| | | return partyBuildingService.pageYnamic(partyBuildingComPbDynVO); |
|---|
| | | } |
|---|
| | |
|---|
| | | @DeleteMapping("deletedynamic") |
|---|
| | | public R deleteYnamic(@RequestBody PartyBuildingComPbDynVO partyBuildingComPbDynVO) { |
|---|
| | | Long id = partyBuildingComPbDynVO.getId(); |
|---|
| | | if (null==id||0==id) { |
|---|
| | | if (null == id || 0 == id) { |
|---|
| | | return R.fail("动态主键不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.deleteYnamic(id); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | @OperLog(operModul = "党员管理",operType = 3) |
|---|
| | | @OperLog(operModul = "党员管理", operType = 3) |
|---|
| | | @ApiOperation(value = "删除党员") |
|---|
| | | @DeleteMapping("deletepartybuildingmember") |
|---|
| | | public R deleteDynUser(@RequestBody PartyBuildingMemberVO partyBuildingMemberVO){ |
|---|
| | | public R deleteDynUser(@RequestBody PartyBuildingMemberVO partyBuildingMemberVO) { |
|---|
| | | Long id = partyBuildingMemberVO.getId(); |
|---|
| | | if (null==id||0==id) { |
|---|
| | | if (null == id || 0 == id) { |
|---|
| | | return R.fail("党员主键不能为空"); |
|---|
| | | } |
|---|
| | | return partyBuildingService.deleteDynUser(id); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
