From 8a92712c881f3b487d926fe4638ff94bd414e4c1 Mon Sep 17 00:00:00 2001
From: wl <173@qq.com>
Date: 星期二, 26 七月 2022 10:05:20 +0800
Subject: [PATCH] 报案人是否进群

---
 src/main/java/com/example/jz/service/impl/CauseServiceImpl.java |   43 +++++++++++++++++++++++++++++++++----------
 1 files changed, 33 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/example/jz/service/impl/CauseServiceImpl.java b/src/main/java/com/example/jz/service/impl/CauseServiceImpl.java
index f5156b6..5a33c46 100644
--- a/src/main/java/com/example/jz/service/impl/CauseServiceImpl.java
+++ b/src/main/java/com/example/jz/service/impl/CauseServiceImpl.java
@@ -26,9 +26,7 @@
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -127,8 +125,10 @@
     }
 
     @Override
-    public List<CauseReportVo> getReporterList(Integer causeId) {
-        return reportDao.selectList(new QueryWrapper<Report>().eq("cause_id", causeId)).stream()
+    public PageParam<CauseReportVo> getReporterList(Integer causeId) {
+        PageParam<Report> PageParam = new PageParam<>();
+        PageParam<Report> reportPageParam = reportDao.selectPage(PageParam, new QueryWrapper<Report>().eq("cause_id", causeId));
+        List<CauseReportVo> causeReportVos = reportPageParam.getRecords().stream()
                 .map(
                         a -> {
                             CauseReportVo causeReportVo = new CauseReportVo();
@@ -138,9 +138,19 @@
                             causeReportVo.setUserMobile(user.getUserMobile());
                             causeReportVo.setUserIdcard(causeReportVo.getUserIdcard().replaceAll("(?<=[\\d]{3})\\d(?=[\\d]{4})", "*"));
                             causeReportVo.setUserName(user.getRealName());
+                            if (groupUserDao.selectOne(new QueryWrapper<GroupUser>().eq("user_id", a.getId())) == null) {
+                                causeReportVo.setIsIntoGroup("0");
+                            } else {
+                                causeReportVo.setIsIntoGroup("1");
+                            }
                             return causeReportVo;
                         }
                 ).collect(Collectors.toList());
+
+        PageParam<CauseReportVo> causeReportVoPageParam = new PageParam<>();
+        BeanUtils.copyProperties(reportPageParam, causeReportVoPageParam);
+        causeReportVoPageParam.setRecords(causeReportVos);
+        return causeReportVoPageParam;
     }
 
     @Override
@@ -151,6 +161,7 @@
     @Override
     public void deleteCause(Integer id) {
         causeDao.deleteById(id);
+        groupDao.delete(new QueryWrapper<Group>().eq("cause_id", id));
     }
 
     @Override
@@ -158,10 +169,10 @@
     @Transactional(rollbackFor = BusinessException.class)
     public void loadFile(MultipartFile multipartFile) {
         ArrayList<CauseLoadDto> causeLoadDtos = new ArrayList<>();
-        EasyExcel.read(multipartFile.getInputStream(),CauseLoadDto.class, new AnalysisEventListener<CauseLoadDto>() {
+        EasyExcel.read(multipartFile.getInputStream(), CauseLoadDto.class, new AnalysisEventListener<CauseLoadDto>() {
                     @Override
                     public void invoke(CauseLoadDto data, AnalysisContext context) {
-                        if (StringUtils.isNotBlank(data.getName())&&StringUtils.isNotBlank(data.getUserName())){
+                        if (StringUtils.isNotBlank(data.getName()) && StringUtils.isNotBlank(data.getUserName())) {
                             causeLoadDtos.add(data);
                         }
                     }
@@ -177,7 +188,7 @@
                 a -> {
                     Cause cause = new Cause();
                     BeanUtils.copyProperties(a, cause);
-                    if (StringUtils.isBlank(a.getStatus())){
+                    if (StringUtils.isBlank(a.getStatus())) {
                         throw new BusinessException("鐘舵�佷笉鑳戒负绌�");
                     }
                     if (a.getStatus().equals(CauseEnums.UNCHECKED.getMsg())) {
@@ -196,10 +207,10 @@
                         cause.setStatus(CauseEnums.HASBEENDROPPED.value());
                     }
                     cause.setCtime(new Date());
-                    if (StringUtils.isBlank(a.getUserName())){
+                    if (StringUtils.isBlank(a.getUserName())) {
                         throw new BusinessException("璐熻矗浜轰笉鍏佽涓虹┖");
                     }
-                    if (userDao.selectOne(new QueryWrapper<User>().eq("real_name", a.getUserName()))==null){
+                    if (userDao.selectOne(new QueryWrapper<User>().eq("real_name", a.getUserName())) == null) {
                         throw new BusinessException("璐熻矗浜轰笉瀛樺湪");
                     }
                     Integer id = userDao.selectOne(new QueryWrapper<User>().eq("real_name", a.getUserName())).getId();
@@ -238,4 +249,16 @@
                 .setCauseId(groupDao.selectOne(new QueryWrapper<Group>().eq("id", addReportDto.getGroupId())).getCauseId());
         return reportDao.insert(report) > 0;
     }
+
+    @Override
+    public List<Map<String, String>> getCauseIdAndName() {
+        ArrayList<Map<String, String>> maps = new ArrayList<>();
+        causeDao.selectList(null).stream().forEach(a -> {
+            Map<String, String> map = new HashMap<>();
+            map.put("id", a.getId().toString());
+            map.put("name", a.getName());
+            maps.add(map);
+        });
+        return maps;
+    }
 }
\ No newline at end of file

--
Gitblit v1.8.0