| | |
| | | |
| | | import cn.hutool.json.JSONObject; |
| | | import cn.hutool.json.JSONUtil; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.core.toolkit.StringUtils; |
| | |
| | | import com.example.jz.modle.entity.*; |
| | | import com.example.jz.modle.vo.CauseVo; |
| | | import com.example.jz.modle.vo.MemberVo; |
| | | import com.example.jz.modle.vo.ReportVo; |
| | | import com.example.jz.service.*; |
| | | import com.example.jz.utils.HttpUtil; |
| | | import lombok.SneakyThrows; |
| | |
| | | private final String wxApp_accessToken_verify_url = "https://api.weixin.qq.com/cgi-bin/token"; |
| | | |
| | | @Value("${wx.appid}") |
| | | private String appid; |
| | | private String appid; |
| | | |
| | | @Value("${wx.secret}") |
| | | private String secret; |
| | |
| | | MessageService messageService; |
| | | @Autowired |
| | | GroupUserService groupUserService; |
| | | @Autowired |
| | | PublicityService publicityService; |
| | | |
| | | @GetMapping("/login") |
| | | @SneakyThrows |
| | |
| | | loginMessage.put("id", id); |
| | | loginMessage.put("token", token); |
| | | loginMessage.put("role", role); |
| | | loginMessage.put("time",user1.getUserIdcard()); |
| | | loginMessage.put("time", user1.getUserIdcard()); |
| | | return R.ok(loginMessage); |
| | | } |
| | | |
| | |
| | | @GetMapping("/user/group/list") |
| | | public R getUserMessage(@RequestParam Integer id, @RequestParam String newDate, @RequestParam String lastDate) { |
| | | ArrayList<Map<String, Object>> list = new ArrayList<>(); |
| | | reportService.list((new QueryWrapper<Report>().eq("user_id", id)).groupBy("user_id")) |
| | | reportService.list((new QueryWrapper<Report>().eq("user_id", id))) |
| | | .forEach(item -> |
| | | { |
| | | GroupUser groupUser = groupUserService.getOne(new QueryWrapper<GroupUser>().eq("user_id", item.getId())); |
| | |
| | | |
| | | @GetMapping("/group/user/sendMsg") |
| | | public R sendUserMsg(@RequestParam Integer id, @RequestParam Integer groupId, @RequestParam String msg) { |
| | | if (StringUtils.isBlank(msg)){ |
| | | if (StringUtils.isBlank(msg)) { |
| | | return R.failed("msg is blank"); |
| | | } |
| | | Message message = new Message(); |
| | |
| | | message.setReportName(userService.getOne(new QueryWrapper<User>().eq("id", reportService.getOne(new QueryWrapper<Report>().eq("id", id)).getUserId())).getRealName()); |
| | | return R.ok(messageService.save(message)); |
| | | } |
| | | |
| | | @GetMapping("/group/member/detail") |
| | | public R getMemberDetail(@RequestParam Integer id) { |
| | | Report report = reportService.getOne(new LambdaQueryWrapper<Report>().eq(Report::getId, id)); |
| | | ReportVo reportVo = new ReportVo(); |
| | | BeanUtils.copyProperties(report, reportVo); |
| | | User user = userDao.selectOne(new LambdaQueryWrapper<User>().eq(User::getId, report.getUserId())); |
| | | reportVo.setReporterName(user.getRealName()); |
| | | reportVo.setMobile(user.getUserMobile()); |
| | | reportVo.setIdcard(user.getUserIdcard()); |
| | | return R.ok(reportVo); |
| | | } |
| | | |
| | | @GetMapping("/manager/report") |
| | | public R queryReport() { |
| | | return R.ok(reportService.list(new LambdaQueryWrapper<Report>().eq(Report::getStatus, 0)) |
| | | .stream() |
| | | .map(item -> { |
| | | ReportVo reportVo = new ReportVo(); |
| | | BeanUtils.copyProperties(item, reportVo); |
| | | User user = userDao.selectOne(new LambdaQueryWrapper<User>().eq(User::getId, item.getUserId())); |
| | | reportVo.setReporterName(user.getRealName()); |
| | | reportVo.setMobile(user.getUserMobile()); |
| | | reportVo.setIdcard(user.getUserIdcard()); |
| | | return reportVo; |
| | | }) |
| | | .collect(Collectors.toList())); |
| | | } |
| | | |
| | | @GetMapping("/publicity") |
| | | public R queryPublicity(@RequestParam(required = false) Integer size) { |
| | | List<Publicity> publicityList = publicityService.list(new LambdaQueryWrapper<Publicity>().eq(Publicity::getStatus, 1)); |
| | | if (size != null) { |
| | | return R.ok(publicityList.stream().limit(size)); |
| | | } |
| | | return R.ok(publicityList); |
| | | } |
| | | } |