From 1293d3dba10c4e291dfbce4c936f952875557edb Mon Sep 17 00:00:00 2001
From: lishuai <260038442@qq.com>
Date: 星期二, 26 十二月 2023 18:40:49 +0800
Subject: [PATCH] 配置信息对接调整提交

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/RetentionServiceImpl.java |  110 +++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 106 insertions(+), 4 deletions(-)

diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/RetentionServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/RetentionServiceImpl.java
index f9ae463..a715a63 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/RetentionServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/RetentionServiceImpl.java
@@ -1,31 +1,51 @@
 package com.doumee.service.business.impl;
 
+import cn.hutool.core.lang.PatternPool;
+import cn.hutool.core.lang.Validator;
+import cn.hutool.core.util.ReUtil;
 import com.doumee.core.model.PageData;
 import com.doumee.core.model.PageWrap;
+import com.doumee.core.utils.Constants;
 import com.doumee.core.utils.Utils;
+import com.doumee.dao.admin.request.RetentionQuery;
 import com.doumee.dao.business.RetentionMapper;
-import com.doumee.dao.business.model.Retention;
+import com.doumee.dao.business.join.RetentionJoinMapper;
+import com.doumee.dao.business.model.*;
+import com.doumee.dao.system.SystemDictDataMapper;
+import com.doumee.dao.system.model.SystemDictData;
+import com.doumee.dao.system.vo.RetentionVo;
 import com.doumee.service.business.RetentionService;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
-import java.util.List;
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
 
 /**
  * 鍦ㄥ巶浜哄憳淇℃伅 琛紙婊炵暀锛塖ervice瀹炵幇
  * @author 姹熻箘韫�
- * @date 2023/11/23 18:16
+ * @date 2023/11/30 15:33
  */
 @Service
 public class RetentionServiceImpl implements RetentionService {
 
     @Autowired
     private RetentionMapper retentionMapper;
+
+    @Autowired
+    private RetentionJoinMapper retentionJoinMapper;
+
+    @Autowired
+    private SystemDictDataMapper systemDictDataMapper;
+
 
     @Override
     public Integer create(Retention retention) {
@@ -83,7 +103,7 @@
         QueryWrapper<Retention> wrapper = new QueryWrapper<>(retention);
         return retentionMapper.selectList(wrapper);
     }
-  
+
     @Override
     public PageData<Retention> findPage(PageWrap<Retention> pageWrap) {
         IPage<Retention> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
@@ -171,4 +191,86 @@
         QueryWrapper<Retention> wrapper = new QueryWrapper<>(retention);
         return retentionMapper.selectCount(wrapper);
     }
+
+    @Override
+    public PageData<Retention> findTrainTimePage(PageWrap<Retention> pageWrap) {
+        IPage<Retention> retentionIPage = getDataInfo(pageWrap);
+        if(null != retentionIPage && retentionIPage.getRecords().size() > 0) {
+            List<String> codes = Arrays.asList(Constants.FTP_RESOURCE_PATH,Constants.MEMBER_IMG);
+            List<SystemDictData> list = systemDictDataMapper.list(codes);
+            Map<String,SystemDictData> dataMap = list.stream().collect(Collectors.toMap(SystemDictData::getLabel, Function.identity()));
+            retentionIPage.getRecords().stream().forEach(obj->{
+                obj.setFaceImg(dataMap.get(Constants.FTP_RESOURCE_PATH).getCode()
+                        +dataMap.get(Constants.MEMBER_IMG).getCode()
+                        +obj.getFaceImg());
+            });
+        }
+        return PageData.from(retentionIPage);
+    }
+
+    /**
+     * 瀵煎嚭
+     *
+     * @param pageWrap 鍒嗛〉瀵硅薄
+     * @return PageData<RetentionVo>
+     */
+    public List<RetentionVo> findPageExcel(PageWrap<Retention> pageWrap) {
+        IPage<Retention> retentionInfo = getDataInfo(pageWrap);
+        List<RetentionVo> retentionVoList = new ArrayList<>();
+        if(null != retentionInfo && retentionInfo.getRecords().size() > 0) {
+            for (Retention obj:retentionInfo.getRecords()) {
+                RetentionVo vo = new RetentionVo();
+                vo.setCompanyName(obj.getCompanyName());
+                if(null != obj.getType()) {
+                    if(Constants.ZERO == obj.getType()){
+                        vo.setTypeName(Constants.Status.LW_FK.getDes());
+                    }else if(Constants.ONE == obj.getType()) {
+                        vo.setTypeName(Constants.Status.PT_FK.getDes());
+                    }else {
+                        vo.setTypeName(Constants.Status.NB_FK.getDes());
+                    }
+                }else {
+                    vo.setTypeName("");
+                }
+                vo.setName(obj.getName());
+                vo.setPhone(obj.getPhone());
+                vo.setIdcardNo(obj.getIdcardNo());
+                vo.setDeviceName(obj.getDeviceName());
+                vo.setEventDate(obj.getEventDate());
+                retentionVoList.add(vo);
+            }
+        }
+        return retentionVoList;
+    }
+
+    private  IPage<Retention> getDataInfo(PageWrap<Retention> pageWrap) {
+        //鏄惁鏄暟瀛�
+        boolean number = Validator.isNumber(pageWrap.getModel().getKeyWords());
+        //鏄惁鍖呭惈涓枃
+        boolean b = Validator.hasChinese(pageWrap.getModel().getKeyWords());
+        //鏄惁鍖呭惈鑻辨枃
+        boolean hasWord = ReUtil.contains(PatternPool.WORD, pageWrap.getModel().getKeyWords());
+
+        IPage<Retention> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
+        MPJLambdaWrapper<Retention> queryWrapper = new MPJLambdaWrapper<>();
+        Utils.MP.blankToNull(pageWrap.getModel());
+        queryWrapper.leftJoin(Company.class,Company::getId,Retention::getId);
+        queryWrapper.selectAll(Retention.class)
+                .selectAs(Company::getName,Retention::getCompanyName);
+        queryWrapper.like(number,Retention::getPhone,pageWrap.getModel().getKeyWords())
+                .like((b||hasWord),Retention::getName,pageWrap.getModel().getKeyWords())
+                .eq(Objects.nonNull(pageWrap.getModel().getType()),
+                        Retention::getType,
+                        pageWrap.getModel().getType())
+                .like(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),
+                        Company::getName,
+                        pageWrap.getModel().getCompanyName())
+                .ge(Objects.nonNull(pageWrap.getModel().getStartTime()),
+                        Retention::getEventDate,pageWrap.getModel().getStartTime())
+                .le(Objects.nonNull(pageWrap.getModel().getEndTime()),
+                        Retention::getEventDate,pageWrap.getModel().getStartTime());
+        queryWrapper.orderByDesc(Retention::getCreateDate);
+        IPage<Retention> retentionIPage = retentionJoinMapper.selectJoinPage(page, Retention.class, queryWrapper);
+        return retentionIPage;
+    }
 }

--
Gitblit v1.9.3