青羊经侦大队-数据平台
7560238de78178a8b8ecf21c0b490f2f8c55f967..a93cecfb49c06cd39f363bc6202a8779ab15b06e
2022-12-26 wl
fix: 工作台群消息
a93cec 对比 | 目录
2022-12-26 wl
fix: 小程序公告
e43e2f 对比 | 目录
4个文件已修改
91 ■■■■ 已修改文件
src/main/java/com/example/jz/controller/WxAppController.java 49 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/example/jz/modle/vo/ReportVo.java 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/example/jz/service/impl/GroupServiceImpl.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/example/jz/service/impl/WorkbenchServiceImpl.java 29 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/example/jz/controller/WxAppController.java
@@ -3,6 +3,7 @@
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;
@@ -12,6 +13,7 @@
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;
@@ -38,7 +40,7 @@
    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;
@@ -66,6 +68,8 @@
    MessageService messageService;
    @Autowired
    GroupUserService groupUserService;
    @Autowired
    PublicityService publicityService;
    @GetMapping("/login")
    @SneakyThrows
@@ -126,7 +130,7 @@
        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);
    }
@@ -200,7 +204,7 @@
    @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()));
@@ -394,7 +398,7 @@
    @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();
@@ -405,4 +409,41 @@
        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);
    }
}
src/main/java/com/example/jz/modle/vo/ReportVo.java
@@ -1,5 +1,6 @@
package com.example.jz.modle.vo;
import com.example.jz.modle.entity.Report;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@@ -12,7 +13,7 @@
 */
@Data
@ApiModel(description = "待审核人员", value = "CauseVo")
public class ReportVo {
public class ReportVo extends Report {
    //报案人
    @ApiModelProperty(value = "报案人",dataType = "String")
    private String reporterName;
@@ -24,8 +25,8 @@
    @ApiModelProperty(value = "报案人身份证号",dataType = "String")
    //报案人身份证号
    private String idcard;
    //报案人id
    @ApiModelProperty(value = "id",dataType = "Integer")
    private Integer id;
//
//    //报案人id
//    @ApiModelProperty(value = "id",dataType = "Integer")
//    private Integer id;
}
src/main/java/com/example/jz/service/impl/GroupServiceImpl.java
@@ -80,7 +80,7 @@
    @Override
    public List<Announcement> getAllNotice(Integer id) {
        return announcementDao.selectList(new LambdaQueryWrapper<>(Announcement.class).eq(Announcement::getGroupId, id));
        return announcementDao.selectList(new LambdaQueryWrapper<>(Announcement.class).eq(Announcement::getGroupId, id).eq(Announcement::getStatus,1));
    }
    @Override
src/main/java/com/example/jz/service/impl/WorkbenchServiceImpl.java
@@ -12,6 +12,7 @@
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
@Service
public class WorkbenchServiceImpl implements WorkbenchService {
@@ -69,17 +70,17 @@
        //查询待审核人
        List<Report> reports = reportDao.selectList(new QueryWrapper<Report>().eq("status", 0).orderByDesc("ctime").last("limit 5"));
        ArrayList<ReportVo> reportVos = new ArrayList<>();
        if(!reports.isEmpty()){
        if (!reports.isEmpty()) {
            reports.forEach(a -> {
                User user = userDao.selectOne(new QueryWrapper<User>().eq("id", a.getUserId()));
                ReportVo reportVo = new ReportVo();
                if (user!=null){
                if (user != null) {
                    reportVo.setReporterName(user.getRealName());
                    String regex = "(?<=[\\d]{3})\\d(?=[\\d]{4})";
                    reportVo.setIdcard(user.getUserIdcard().replaceAll(regex, "*"));
                    reportVo.setMobile(user.getUserMobile());
                }
                reportVo.setId(a.getId());
//                reportVo.setId(a.getId());
                reportVos.add(reportVo);
            });
        }
@@ -88,17 +89,13 @@
    @Override
    public List<MessageVo> getGroupMessage() {
        ArrayList<MessageVo> messageVos = new ArrayList<>();
        if (!messageVos.isEmpty()){
            messageDao.selectList(new QueryWrapper<Message>().orderByDesc("ctime")).stream()
                    .filter(item->item.getUserId()!=null).limit(5).forEach(a -> {
                        MessageVo messageVo = new MessageVo();
                        messageVo.setGroupName(groupDao.selectOne(new QueryWrapper<Group>().eq("id", a.getGroupId())).getGroupName());
                        BeanUtils.copyProperties(a, messageVo);
                        messageVo.setUserName(a.getReportName());
                        messageVos.add(messageVo);
                    });
        }
        return messageVos;
        return messageDao.selectList(new QueryWrapper<Message>().orderByDesc("ctime")).stream()
                .filter(item -> item.getUserId() != null).limit(5).map(a -> {
                    MessageVo messageVo = new MessageVo();
                    messageVo.setGroupName(groupDao.selectOne(new QueryWrapper<Group>().eq("id", a.getGroupId())).getGroupName());
                    BeanUtils.copyProperties(a, messageVo);
                    messageVo.setUserName(a.getReportName());
                    return messageVo;
                }).collect(Collectors.toList());
    }
}
}