From 1c3f11dfd7493a4c4a8d41e2499477840bcc070c Mon Sep 17 00:00:00 2001
From: baizonghao <1719256278@qq.com>
Date: 星期五, 19 五月 2023 15:01:46 +0800
Subject: [PATCH] 限制文件大小,用户,报案人审核筛选

---
 src/main/java/com/example/jz/controller/WxAppController.java |   94 ++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 92 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/example/jz/controller/WxAppController.java b/src/main/java/com/example/jz/controller/WxAppController.java
index c947455..9a86f93 100644
--- a/src/main/java/com/example/jz/controller/WxAppController.java
+++ b/src/main/java/com/example/jz/controller/WxAppController.java
@@ -7,6 +7,7 @@
 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.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.example.jz.auth.TokenJwtManager;
 import com.example.jz.dao.UserDao;
 import com.example.jz.modle.R;
@@ -14,6 +15,9 @@
 import com.example.jz.modle.vo.*;
 import com.example.jz.service.*;
 import com.example.jz.utils.HttpUtil;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiResponse;
 import lombok.SneakyThrows;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,12 +28,16 @@
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.client.RestTemplate;
 
+import javax.annotation.Resource;
+import java.io.Serializable;
+import java.sql.Array;
 import java.util.*;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
 @RestController
 @RequestMapping("/wx")
+@Api(tags = "寰俊灏忕▼搴忔帴鍙�")
 public class WxAppController {
 
     private final String wxApp_userCode_verify_url = "https://api.weixin.qq.com/sns/jscode2session";
@@ -69,6 +77,10 @@
     GroupUserService groupUserService;
     @Autowired
     PublicityService publicityService;
+    @Autowired
+    private AnnouncementService announcementService;
+    @Autowired
+    private PoliceAnnouncementService policeAnnouncementService;
 
     @GetMapping("/checkIdentity")
     public R checkIdentity(@RequestParam String code, @RequestParam String phoneNumberCode) throws Exception {
@@ -263,6 +275,36 @@
         return R.ok(reportService.save(report));
     }
 
+    @PostMapping("/user/policeAddReport")
+    public R policeAddReport(@RequestBody ReportVXVO reportVXVO) {
+        User one = userService.getOne(Wrappers.<User>lambdaQuery().eq(User::getUserMobile, reportVXVO.getPhone()));
+        if (Objects.nonNull(one)){
+             return R.ok("璇ユ墜鏈哄彿宸茶娉ㄥ唽");
+        }
+
+        User user = new User();
+
+        user.setUserMobile(reportVXVO.getPhone());
+        user.setRealName(reportVXVO.getRealName());
+        user.setSex(reportVXVO.getSex());
+        user.setUserIdcard(reportVXVO.getUserIdCard());
+        user.setLocation(reportVXVO.getLocation());
+        user.setWorkingLocation(reportVXVO.getWorkingLocation());
+        user.setCtime(new Date());
+        userService.save(user);
+
+        Report report = new Report();
+        BeanUtils.copyProperties(reportVXVO, report);
+        report.setAmountInvolved(reportVXVO.getAmountInvolved());
+        report.setUserId(user.getId());
+        report.setPic(user.getPic());
+        report.setIsInGroup(0);
+        report.setCtime(new Date());
+        report.setStatus(0);
+        report.setReportMethod("鎵爜鎶ユ");
+        return R.ok(reportService.save(report));
+    }
+
     @PutMapping ("/user/addReport")
     public R addReport1(@RequestBody ReportVXVO reportVXVO) {
         User user = userService.getOne(new QueryWrapper<User>().eq("id", reportVXVO.getUserId()));
@@ -383,6 +425,7 @@
                     HashMap<String, Object> messageMap = new HashMap<>();
                     messageMap.put("text", item.getText());
                     messageMap.put("time", item.getCtime());
+                    messageMap.put("messageId", item.getId());
                     if (item.getUserId() != null) {
                         Report report = reportService.getOne(new QueryWrapper<Report>().eq("id", item.getUserId()));
                         User user = userService.getOne(new QueryWrapper<User>().eq("id", report.getUserId()));
@@ -396,6 +439,7 @@
                         messageMap.put("sex", user.getSex());
                         messageMap.put("pic", user.getPic());
                         messageMap.put("role", 0);
+                        messageMap.put("remark", user.getUserMemo());
                     } else {
                         messageMap.put("id", item.getCopId());
                         User user = userService.getOne(new QueryWrapper<User>().eq("id", item.getCopId()));
@@ -555,6 +599,10 @@
         if (StringUtils.isBlank(msg)) {
             return R.failed("msg is blank");
         }
+        GroupUser one = groupUserService.getOne(new LambdaQueryWrapper<GroupUser>().eq(GroupUser::getUserId, id).eq(GroupUser::getGroupId, groupId));
+        if (one.getBanSpeech() == 1){
+            return R.failed("璇ョ敤鎴峰凡缁忚绂佽█");
+        }
         Message message = new Message();
         message.setUserId(id);
         message.setText(msg);
@@ -576,9 +624,15 @@
         return R.ok(reportVo);
     }
 
+    /**
+     *
+     * @param id
+     * @return
+     */
     @GetMapping("/manager/report")
-    public R queryReport() {
-        return R.ok(reportService.list(new LambdaQueryWrapper<Report>().eq(Report::getStatus, 0))
+    public R queryReport(@RequestParam Integer id) {
+        List<Integer> collect = causeService.list(Wrappers.<Cause>lambdaQuery().eq(Cause::getUserId, id)).stream().map(cause -> cause.getId()).collect(Collectors.toList());
+        R<List<ReportVo>> ok = R.ok(reportService.list(new LambdaQueryWrapper<Report>().eq(Report::getStatus, 0).in(Report::getCauseId, collect))
                 .stream()
                 .map(item -> {
                     ReportVo reportVo = new ReportVo();
@@ -592,6 +646,7 @@
                     return reportVo;
                 })
                 .collect(Collectors.toList()));
+        return ok;
     }
 
     @GetMapping("/publicity")
@@ -602,4 +657,39 @@
         }
         return R.ok(publicityList);
     }
+
+    @GetMapping("/publicity/{id}")
+    @ApiOperation("閫氳繃涓婚敭鏌ヨ鍗曟潯鏁版嵁")
+    public R<Publicity> selectOne(@PathVariable Serializable id) {
+        return R.ok(publicityService.getById(id));
+    }
+
+    @ApiOperation(httpMethod = "POST", value = "缇ゅ叕鍛婃坊鍔�")
+    @PostMapping("/announcement/add")
+    public R insert(@RequestParam(value = "groupId") Integer groupId, @RequestParam String announcement) {
+        Announcement announcement1 = new Announcement();
+        announcement1.setText(announcement);
+        announcement1.setStatus(1);
+        return R.ok(announcementService.vxAdd(groupId, announcement1));
+    }
+
+    @ApiOperation(httpMethod = "DELETE", value = "缇ゅ叕鍛婂垹闄�")
+    @DeleteMapping("/announcement/delete")
+    public R delete(@RequestParam(value = "id") Integer id) {
+        announcementService.removeById(id);
+        return R.ok();
+    }
+
+    @ApiOperation(httpMethod = "GET", value = "鏌ョ湅缇ゅ叕鍛�")
+    @GetMapping("/getAnnouncements")
+    public R getAnnouncements(@RequestParam(value = "groupId") Integer groupId) {
+        return R.ok(announcementService.getAnnouncements(groupId));
+    }
+
+    @GetMapping("policeAnnouncement/list")
+    @ApiOperation(httpMethod = "GET", value = "璀︽柟鍏憡")
+    public R getPoliceAnnouncement(){
+        List<PoliceAnnouncement> list = policeAnnouncementService.list(Wrappers.<PoliceAnnouncement>lambdaQuery().eq(PoliceAnnouncement::getStatus, 1).orderByDesc(PoliceAnnouncement::getCtime));
+        return R.ok(list);
+    }
 }

--
Gitblit v1.8.0