From 2b278a1aa078b39d891f3eb00aac729ed2c1c5b3 Mon Sep 17 00:00:00 2001
From: wl <173@qq.com>
Date: 星期一, 25 七月 2022 17:28:58 +0800
Subject: [PATCH] 报案人查询分页处理,处理案件早发时间 修改问题

---
 src/main/java/com/example/jz/service/impl/CauseServiceImpl.java |   54 +++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 45 insertions(+), 9 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 5be530f..c2a73b9 100644
--- a/src/main/java/com/example/jz/service/impl/CauseServiceImpl.java
+++ b/src/main/java/com/example/jz/service/impl/CauseServiceImpl.java
@@ -9,6 +9,7 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.example.jz.dao.*;
 import com.example.jz.enums.CauseEnums;
+import com.example.jz.exception.BusinessException;
 import com.example.jz.modle.PageParam;
 import com.example.jz.modle.dto.AddReportDto;
 import com.example.jz.modle.dto.CauseDto;
@@ -25,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;
 
 /**
@@ -126,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));
+        reportPageParam.getRecords().stream()
                 .map(
                         a -> {
                             CauseReportVo causeReportVo = new CauseReportVo();
@@ -140,6 +141,9 @@
                             return causeReportVo;
                         }
                 ).collect(Collectors.toList());
+        PageParam<CauseReportVo> causeReportVoPageParam = new PageParam<>();
+        BeanUtils.copyProperties(reportPageParam, causeReportVoPageParam);
+        return causeReportVoPageParam;
     }
 
     @Override
@@ -150,16 +154,20 @@
     @Override
     public void deleteCause(Integer id) {
         causeDao.deleteById(id);
+        groupDao.delete(new QueryWrapper<Group>().eq("cause_id", id));
     }
 
     @Override
     @SneakyThrows
+    @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) {
-                        causeLoadDtos.add(data);
+                        if (StringUtils.isNotBlank(data.getName()) && StringUtils.isNotBlank(data.getUserName())) {
+                            causeLoadDtos.add(data);
+                        }
                     }
 
                     @Override
@@ -173,6 +181,9 @@
                 a -> {
                     Cause cause = new Cause();
                     BeanUtils.copyProperties(a, cause);
+                    if (StringUtils.isBlank(a.getStatus())) {
+                        throw new BusinessException("鐘舵�佷笉鑳戒负绌�");
+                    }
                     if (a.getStatus().equals(CauseEnums.UNCHECKED.getMsg())) {
                         cause.setStatus(CauseEnums.UNCHECKED.value());
                     }
@@ -189,8 +200,21 @@
                         cause.setStatus(CauseEnums.HASBEENDROPPED.value());
                     }
                     cause.setCtime(new Date());
-                    cause.setUserId(userDao.selectOne(new QueryWrapper<User>().eq("real_name", a.getUserName())).getId());
-                    causeDao.insert(cause);
+                    if (StringUtils.isBlank(a.getUserName())) {
+                        throw new BusinessException("璐熻矗浜轰笉鍏佽涓虹┖");
+                    }
+                    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();
+                    cause.setUserId(id);
+                    causeService.save(cause);
+                    Group group = new Group();
+                    group.setCtime(new Date());
+                    group.setUserId(id);
+                    group.setGroupName(a.getName());
+                    group.setCauseId(cause.getId());
+                    groupDao.insert(group);
                 });
     }
 
@@ -218,4 +242,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