行程上报导出

4 years ago · d41357ac75
9 changed files with 122 additions and 26 deletions
--- a/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/IcTripReportRecordDTO.java
+++ b/epmet-user/epmet-user-client/src/main/java/com/epmet/dto/IcTripReportRecordDTO.java
@ -1,5 +1,10 @@
 package com.epmet.dto;

+import com.alibaba.excel.annotation.ExcelIgnore;
+import com.alibaba.excel.annotation.ExcelProperty;
+import com.alibaba.excel.annotation.write.style.ColumnWidth;
+import com.alibaba.excel.annotation.write.style.HeadStyle;
+import com.alibaba.excel.enums.poi.FillPatternTypeEnum;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import lombok.Data;

@ -13,6 +18,7 @@ import java.util.Date;
 * @author generator generator@elink-cn.com
 * @since v1.0.0 2022-03-25
 */
+@HeadStyle(fillPatternType = FillPatternTypeEnum.SOLID_FOREGROUND, fillForegroundColor = 44)
@Data
 public class IcTripReportRecordDTO implements Serializable {

@ -21,137 +27,180 @@ public class IcTripReportRecordDTO implements Serializable {
    /**
     * 主键ID
     */
+    @ExcelIgnore
 	private String id;

    /**
     * 居民端用户所在网格id,数字社区居民所属网格id
     */
+    @ExcelIgnore
    private String gridId;

    /**
     * 居民端上报的：存储用户所在网格的组织id;
     */
+    @ExcelIgnore
    private String agencyId;

    /**
     * agency_id的所有上级
     */
+    @ExcelIgnore
    private String pids;

    /**
     * 客户Id
     */
+    @ExcelIgnore
 	private String customerId;

    /**
     * 姓名
     */
+    @ColumnWidth(15)
+    @ExcelProperty("姓名")
 	private String name;

    /**
     * 手机号
     */
+    @ColumnWidth(15)
+    @ExcelProperty("手机号")
 	private String mobile;

    /**
     * 身份证号
     */
+    @ColumnWidth(22)
+    @ExcelProperty("身份证号")
 	private String idCard;

    /**
     * 用户id
     */
+    @ExcelIgnore
 	private String userId;

    /**
     * 居民端小程序的人：resi;数字社区的居民：icresi;单独录入：input; 导入：import
     */
+    @ExcelIgnore
 	private String userType;

    /**
     * 现居地编码
     */
+    @ExcelIgnore
 	private String presentAddressCode;

    /**
     * 现居地名称eg:山东省青岛市黄岛区玫瑰山路社区
     */
+    @ColumnWidth(50)
+    @ExcelProperty("现居地")
 	private String presentAddress;

    /**
     * 详细地址
     */
+    @ColumnWidth(35)
+    @ExcelProperty("详细地址")
 	private String detailAddress;

    /**
     * 来源地区编码
     */
+    @ExcelIgnore
 	private String sourceAddressCode;

    /**
     * 来源地区地址
     */
+    @ColumnWidth(50)
+    @ExcelProperty("来自地区")
 	private String sourceAddress;

    /**
     * 到达日期
     */
+    @ColumnWidth(25)
+    @ExcelProperty("来到本地时间")
    @JsonFormat(pattern = "yyyy-MM-dd")
 	private Date arriveDate;

    /**
     * 离开日期
     */
+    @ColumnWidth(25)
+    @ExcelProperty("离开本地时间")
    @JsonFormat(pattern = "yyyy-MM-dd")
 	private Date leaveDate;

+    /**
+     * pc行程上报-列表返参：最近一次通知时间
+     */
+    @ColumnWidth(25)
+    @ExcelProperty("最近一次通知时间")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    private Date latestNoticeTime;
+
    /**
     * 备注信息
     */
+    @ColumnWidth(100)
+    @ExcelProperty("备注")
 	private String remark;

    /**
     * 删除标识 1删除；0未删除
     */
+    @ExcelIgnore
 	private String delFlag;

    /**
     * 乐观锁
     */
+    @ExcelIgnore
 	private Integer revision;

    /**
     * 创建人
     */
+    @ExcelIgnore
 	private String createdBy;

    /**
     * 创建时间
     */
+    @ExcelIgnore
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
 	private Date createdTime;

    /**
     * 更新人
     */
+    @ExcelIgnore
 	private String updatedBy;

    /**
     * 更新时间
     */
+    @ExcelIgnore
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
 	private Date updatedTime;

+    @ExcelIgnore
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm")
 	private Date reportTime;


-    /**
-     * pc行程上报-列表返参：最近一次通知时间
-     */
-    private Date latestNoticeTime;
    /**
     * pc行程上报-列表返参：是否加入核酸检测关注名单：true：已加入；false：未加入
     */
+    @ExcelIgnore
    private Boolean heSuanCheck;
+
+    @ColumnWidth(20)
+    @ExcelProperty("核算检测关注名单")
+    private String heSuanCheckDesc;
 }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcTripReportRecordController.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcTripReportRecordController.java
@ -1,10 +1,15 @@
 package com.epmet.controller;

+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.ExcelWriter;
+import com.alibaba.excel.write.metadata.WriteSheet;
 import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.aop.NoRepeatSubmit;
+import com.epmet.commons.tools.constant.NumConstant;
 import com.epmet.commons.tools.dto.form.PageFormDTO;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.security.dto.TokenDto;
+import com.epmet.commons.tools.utils.ExcelUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.ValidatorUtils;
 import com.epmet.constant.IcResiUserConstant;
@ -13,6 +18,8 @@ import com.epmet.dto.form.IcTripReportFormDTO;
 import com.epmet.dto.form.MyReportedTripFormDTO;
 import com.epmet.dto.form.PageTripReportFormDTO;
 import com.epmet.service.IcTripReportRecordService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.ArrayUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@ -33,6 +40,7 @@ import java.util.List;
 * @author generator generator@elink-cn.com
 * @since v1.0.0 2022-03-25
 */
+@Slf4j
@RestController
@RequestMapping("tripreport")
 public class IcTripReportRecordController {
@ -157,5 +165,42 @@ public class IcTripReportRecordController {
        }
    }

+    /**
+     * pc:行程上报-导出
+     * @param tokenDto
+     * @param formDTO
+     * @param response
+     */
+    @NoRepeatSubmit
+    @PostMapping("export")
+    public void export(@LoginUser TokenDto tokenDto, @RequestBody PageTripReportFormDTO formDTO, HttpServletResponse response) {
+        formDTO.setCustomerId(tokenDto.getCustomerId());
+        formDTO.setUserId(tokenDto.getUserId());
+        // formDTO.setCustomerId("45687aa479955f9d06204d415238f7cc");
+        // formDTO.setUserId("35005df15fb0f7c791344f0b424870b7");
+        formDTO.setPage(false);
+        ExcelWriter excelWriter = null;
+        formDTO.setPageSize(NumConstant.TEN_THOUSAND);
+        int pageNo = formDTO.getPageNo();
+        try {
+            // 这里 需要指定写用哪个class去写
+            String fileName = "行程上报.xlsx";
+            excelWriter = EasyExcel.write(ExcelUtils.getOutputStreamForExcel(fileName, response), IcTripReportRecordDTO.class).build();
+            WriteSheet writeSheet = EasyExcel.writerSheet("Sheet1").build();
+            PageData<IcTripReportRecordDTO> data = null;
+            do {
+                data = icTripReportRecordService.page(formDTO);
+                formDTO.setPageNo(++pageNo);
+                excelWriter.write(data.getList(), writeSheet);
+            } while (CollectionUtils.isNotEmpty(data.getList()) && data.getList().size() == formDTO.getPageSize());

+        } catch (Exception e) {
+            log.error("export exception", e);
+        } finally {
+            // 千万别忘记finish 会帮忙关闭流
+            if (excelWriter != null) {
+                excelWriter.finish();
+            }
+        }
+    }
 }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcEpidemicSpecialAttentionDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcEpidemicSpecialAttentionDao.java
@ -8,7 +8,6 @@ import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;

 import java.util.List;
-import java.util.Set;

 /**
 * 疫情特别关注
@ -60,5 +59,5 @@ public interface IcEpidemicSpecialAttentionDao extends BaseDao<IcEpidemicSpecial
     * @param attentionType
     * @return
     */
-    List<String> getIdCardList(@Param("customerId") String customerId,@Param("idCardSet") Set<String> idCardSet, @Param("attentionType") Integer attentionType);
+    List<String> getIdCardList(@Param("customerId") String customerId,@Param("idCardSet") List<String> idCardSet, @Param("attentionType") Integer attentionType);
 }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/IcEpidemicSpecialAttentionService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/IcEpidemicSpecialAttentionService.java
@ -12,7 +12,6 @@ import com.epmet.entity.IcEpidemicSpecialAttentionEntity;
 import java.io.InputStream;
 import java.util.List;
 import java.util.Map;
-import java.util.Set;

 /**
 * 疫情特别关注
@ -130,5 +129,5 @@ public interface IcEpidemicSpecialAttentionService extends BaseService<IcEpidemi
     * @param idCardSet
     * @return
     */
-    List<String> getHeSuanIdCardList(String customerId,Set<String> idCardSet);
+    List<String> getHeSuanIdCardList(String customerId,List<String> idCardSet);
 }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/IcNoticeService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/IcNoticeService.java
@ -10,7 +10,6 @@ import com.epmet.entity.IcNoticeEntity;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
-import java.util.Set;

 /**
 * 防疫通知
@ -104,5 +103,5 @@ public interface IcNoticeService extends BaseService<IcNoticeEntity> {
     * @param idCardSet
     * @return
     */
-    Map<String, Date> getUserLatestNoticeTime(String customerId,Set<String> idCardSet);
+    Map<String, Date> getUserLatestNoticeTime(String customerId,List<String> idCardSet);
 }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcEpidemicSpecialAttentionServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcEpidemicSpecialAttentionServiceImpl.java
@ -17,7 +17,6 @@ import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
 import com.epmet.commons.tools.redis.common.bean.AgencyInfoCache;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ConvertUtils;
-import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.utils.ExcelPoiUtils;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.constants.ImportTaskConstants;
@ -30,7 +29,6 @@ import com.epmet.dto.form.VaccinationListFormDTO;
 import com.epmet.dto.result.UploadImgResultDTO;
 import com.epmet.dto.result.VaccinationListResultDTO;
 import com.epmet.entity.IcEpidemicSpecialAttentionEntity;
-import com.epmet.enums.AttentionTypeEnum;
 import com.epmet.enums.ChannelEnum;
 import com.epmet.excel.ImportEpidemicSpecialAttention;
 import com.epmet.excel.error.EpidemicSpecialAttentionErrorModel;
@ -54,13 +52,9 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.commons.CommonsMultipartFile;

 import java.io.IOException;
+import java.io.InputStream;
 import java.io.OutputStream;
 import java.util.*;
-import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
 import java.util.stream.Collectors;

 /**
@ -401,7 +395,7 @@ public class IcEpidemicSpecialAttentionServiceImpl extends BaseServiceImpl<IcEpi
     * @return
     */
    @Override
-    public List<String> getHeSuanIdCardList(String customerId,Set<String> idCardSet) {
+    public List<String> getHeSuanIdCardList(String customerId,List<String> idCardSet) {
        if(CollectionUtils.isEmpty(idCardSet)){
            return new ArrayList<>();
        }
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNoticeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNoticeServiceImpl.java
@ -225,7 +225,7 @@ public class IcNoticeServiceImpl extends BaseServiceImpl<IcNoticeDao, IcNoticeEn
     * @return
     */
    @Override
-    public Map<String, Date> getUserLatestNoticeTime(String customerId,Set<String> idCardSet) {
+    public Map<String, Date> getUserLatestNoticeTime(String customerId,List<String> idCardSet) {
        Map<String, Date> map=new HashMap<>();
        for(String idCard:idCardSet) {
            LambdaQueryWrapper<IcNoticeEntity> wrapper = new LambdaQueryWrapper<>();
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcTripReportRecordServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcTripReportRecordServiceImpl.java
@ -27,6 +27,7 @@ import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.collections4.ListUtils;
 import org.apache.commons.collections4.MapUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@ -69,14 +70,24 @@ public class IcTripReportRecordServiceImpl extends BaseServiceImpl<IcTripReportR
        List<IcTripReportRecordDTO> list = data.getList();
        //3.查询最近一次通知时间、核算检测关注名单
        if (CollectionUtils.isNotEmpty(list)) {
-            Set<String> idCardSet = list.stream().map(m -> m.getIdCard()).collect(Collectors.toSet());
-            Map<String, Date> latestNotice = icNoticeService.getUserLatestNoticeTime(formDTO.getCustomerId(),idCardSet);
-            List<String> gzIdCardList = epidemicSpecialAttentionService.getHeSuanIdCardList(formDTO.getCustomerId(),idCardSet);
+            Map<String, Date> latestNotice = new HashMap<>();
+            List<String> gzIdCardList = new ArrayList<>();
+            List<String> idCardList = list.stream().map(m -> m.getIdCard()).distinct().collect(Collectors.toList());
+            //如果不分页可能会有很多个身份证号
+            List<List<String>> partionList = ListUtils.partition(idCardList, NumConstant.ONE_HUNDRED);
+            partionList.forEach(l -> {
+                Map<String, Date> map = icNoticeService.getUserLatestNoticeTime(formDTO.getCustomerId(), l);
+                List<String> gzIdCards = epidemicSpecialAttentionService.getHeSuanIdCardList(formDTO.getCustomerId(), l);
+                latestNotice.putAll(map);
+                gzIdCardList.addAll(gzIdCards);
+            });
            for (IcTripReportRecordDTO dto : list) {
                //默认未加入
                dto.setHeSuanCheck(false);
+                dto.setHeSuanCheckDesc("未加入");
                if (CollectionUtils.isNotEmpty(gzIdCardList) && gzIdCardList.contains(dto.getIdCard())) {
                    dto.setHeSuanCheck(true);
+                    dto.setHeSuanCheckDesc("已加入");
                }
                if (MapUtils.isNotEmpty(latestNotice) && latestNotice.containsKey(dto.getIdCard())) {
                    dto.setLatestNoticeTime(latestNotice.get(dto.getIdCard()));
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/IcTripReportRecordDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/IcTripReportRecordDao.xml
@ -47,11 +47,11 @@
            <if test='null != sourceAddressCode and "" != sourceAddressCode'>
                AND SOURCE_ADDRESS_CODE like concat(#{sourceAddressCode},'%')
            </if>
-            <if test='null != startTime and "" != startTime'>
-                AND ARRIVE_DATE <![CDATA[ >= ]]> #{startTime}
+            <if test='null != startDate and "" != startDate'>
+                AND ARRIVE_DATE <![CDATA[ >= ]]> #{startDate}
            </if>
-            <if test='null != endTime and "" != endTime'>
-                AND ARRIVE_DATE <![CDATA[ <= ]]> #{endTime}
+            <if test='null != endDate and "" != endDate'>
+                AND ARRIVE_DATE <![CDATA[ <= ]]> #{endDate}
            </if>
        ORDER BY
            r.CREATED_TIME DESC