From 3cfa0bda6574d0c39db120c457e98a168aa193e8 Mon Sep 17 00:00:00 2001
From: Jinquan_Ou <Jinquan@gdut.com>
Date: 星期日, 23 四月 2023 17:15:20 +0800
Subject: [PATCH] 完成婚姻

---
 zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanServiceImpl.java |  290 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 290 insertions(+), 0 deletions(-)

diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanServiceImpl.java
index 5918df5..cdb1eec 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanServiceImpl.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfCleanServiceImpl.java
@@ -1,11 +1,35 @@
 package com.ruoyi.service.impl;
 
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.utils.MapUtils;
+import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.domain.ZInfoUser;
+import com.ruoyi.domain.ZfClean;
+
 import com.ruoyi.domain.ZfClean;
 import com.ruoyi.mapper.ZfCleanMapper;
+import com.ruoyi.service.ZInfoUserService;
 import com.ruoyi.service.ZfCleanService;
+
+import com.ruoyi.util.ArraysUtil;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import static com.ruoyi.constant.MenuAuthority.CLEAN_LIST;
 
 /**
  * <p>
@@ -16,6 +40,272 @@
  * @since 2023-03-12
  */
 @Service
+@Slf4j
 public class ZfCleanServiceImpl extends ServiceImpl<ZfCleanMapper, ZfClean> implements ZfCleanService {
 
+    @Resource
+    ZInfoUserService zInfoUserService;
+
+    @Resource
+    ZfCleanService zfCleanService;
+
+    private LambdaQueryWrapper<ZfClean> buildCondition(ZfClean zfClean) {
+        LambdaQueryWrapper<ZfClean> lqw = new LambdaQueryWrapper<>();
+        lqw.eq(zfClean.getKind() != null, ZfClean::getKind, zfClean.getKind())
+                .like(StringUtils.isNotEmpty(zfClean.getSuitable()), ZfClean::getSuitable, zfClean.getSuitable())
+                .like(StringUtils.isNotEmpty(zfClean.getType()), ZfClean::getType, zfClean.getType())
+                .like(StringUtils.isNotEmpty(zfClean.getMethod()), ZfClean::getMethod, zfClean.getMethod())
+                .like(StringUtils.isNotEmpty(zfClean.getPlace()), ZfClean::getPlace, zfClean.getPlace())
+                .like(StringUtils.isNotEmpty(zfClean.getLocation()), ZfClean::getLocation, zfClean.getLocation())
+                .like(StringUtils.isNotEmpty(zfClean.getRemark()), ZfClean::getRemark, zfClean.getRemark())
+                .eq(zfClean.getHappenTime() != null, ZfClean::getHappenTime, zfClean.getHappenTime())
+                .between(zfClean.getHappenStartTime() != null && zfClean.getHappenEndTime() != null, ZfClean::getHappenTime, zfClean.getHappenStartTime(), zfClean.getHappenEndTime());
+        return lqw;
+    }
+
+    private LambdaQueryWrapper<ZfClean> buildCondition(ZfClean zfClean, String familyIds, String secondFamilyAuthority) {
+        //妯$硦鏌ヨ鐨勬潯浠�
+        LambdaQueryWrapper<ZfClean> lqw = buildCondition(zfClean);
+
+        //瀹氫箟涓�涓竷灏旀爣璁帮紝鏍囪绗竴瀹跺涵鍙锋槸鍚︽湁閫楀彿
+        boolean flag = false;
+
+        StringBuilder secondFamilyIdsBuffer = new StringBuilder();
+
+        //澶勭悊浼犲叆鐨剆econdFamilyAuthority   3{2007 2018 2015},4{2007 2019}
+
+        if (StringUtils.isNotEmpty(secondFamilyAuthority)) {
+
+            if (secondFamilyAuthority.contains(",")) {
+                //閫楀彿闅斿紑寰楀埌濡備笅涓诧細3{2007 2018 2015}
+                String[] authorityList = secondFamilyAuthority.split(",");
+                for (String authorityAndId : authorityList) {
+                    setSecondFamilyAuthority(secondFamilyIdsBuffer, authorityAndId);
+                }
+
+                //鎶婂悗闈㈢殑閫楀彿鍘绘帀
+                if (secondFamilyIdsBuffer.length() > 1) {
+                    secondFamilyIdsBuffer.deleteCharAt(secondFamilyIdsBuffer.length() - 1);
+                }
+
+            } else {
+                setSecondFamilyAuthority(secondFamilyIdsBuffer, secondFamilyAuthority);
+                //鎶婂悗闈㈢殑閫楀彿鍘绘帀
+                if (secondFamilyIdsBuffer.length() > 1) {
+                    secondFamilyIdsBuffer.deleteCharAt(secondFamilyIdsBuffer.length() - 1);
+                }
+            }
+        }
+        //灏哠tringBuffer杞垚String
+        String secondFamilyIds = secondFamilyIdsBuffer.toString();
+
+        //绗竴瀹跺涵鍙风殑鏉′欢
+        if (familyIds.contains(",")) {
+            flag = true;
+        }
+
+        //绗簩瀹跺涵鍙风殑鏉′欢
+        if (StringUtils.isNotEmpty(secondFamilyIds)) {
+            if (secondFamilyIds.contains(",")) {
+                String[] secondFamilyIdList = secondFamilyIds.split(",");
+                if (flag) {
+                    //濡傛灉绗竴瀹跺涵鍙峰拰绗簩瀹跺涵鍙烽兘鏈夐�楀彿
+                    String[] familyList = familyIds.split(",");
+                    String[] totalFamilyIdList = ArraysUtil.appendToArray(familyList, secondFamilyIdList);
+                    lqw.in(ZfClean::getFamilyId, totalFamilyIdList);
+                } else {
+                    //濡傛灉绗竴瀹跺涵鍙锋病鏈夐�楀彿浣嗘槸绗簩瀹跺涵鍙锋湁閫楀彿
+                    String[] totalFamilyIdList = ArraysUtil.appendToArray(secondFamilyIdList, familyIds);
+                    lqw.in(ZfClean::getFamilyId, totalFamilyIdList);
+                }
+
+            } else {
+                if (flag) {
+                    //濡傛灉绗竴瀹跺涵鍙锋湁閫楀彿浣嗙浜屽搴彿娌℃湁閫楀彿
+                    String[] familyList = familyIds.split(",");
+                    String[] totalFamilyIdList = ArraysUtil.appendToArray(familyList, secondFamilyIds);
+                    lqw.in(ZfClean::getFamilyId, totalFamilyIdList);
+                } else {
+                    //濡傛灉绗竴瀹跺涵鍙峰拰绗簩瀹跺涵鍙烽兘娌℃湁閫楀彿
+                    String[] totalFamilyIdList = ArraysUtil.appendToArray(familyIds, secondFamilyIds);
+                    lqw.in(ZfClean::getFamilyId, totalFamilyIdList);
+                }
+            }
+        } else {
+            //濡傛灉娌℃湁绗簩瀹跺涵鍙�
+            if (flag) {
+                String[] familyList = familyIds.split(",");
+                lqw.in(ZfClean::getFamilyId, familyList);
+            } else {
+                lqw.eq(ZfClean::getFamilyId, familyIds);
+            }
+
+        }
+
+        lqw.orderByDesc(ZfClean::getCreateTime);
+        return lqw;
+    }
+
+    private void setSecondFamilyAuthority(StringBuilder secondFamilyIdsBuffer, String authorityAndId) {
+        //寰楀埌鏉冮檺涓�
+        String authorities = authorityAndId.substring(2, authorityAndId.length() - 1);
+
+        if (authorities.contains(" ")) {
+            //绌烘牸闅斿紑寰楀埌鑿滃崟id锛岀湅鏄惁鏈夊搴旂殑鏉冮檺
+            String[] authorityIdList = authorities.split(" ");
+            for (String s : authorityIdList) {
+                if (s.equals(CLEAN_LIST)) {
+                    secondFamilyIdsBuffer.append(authorityAndId.charAt(0)).append(",");
+                    break;
+                }
+            }
+        } else {
+            if (authorities.equals(CLEAN_LIST)) {
+                secondFamilyIdsBuffer.append(authorityAndId.charAt(0)).append(",");
+            }
+        }
+    }
+
+    private ZInfoUser getMySelf() {
+        SysUser user = SecurityUtils.getLoginUser().getUser();
+        Long userId = user.getUserId();
+        LambdaQueryWrapper<ZInfoUser> zInfoUserLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        zInfoUserLambdaQueryWrapper.eq(ZInfoUser::getUserId, userId);
+        return zInfoUserService.getOne(zInfoUserLambdaQueryWrapper);
+    }
+
+    private String listFamilyIds() {
+        ZInfoUser mySelf = getMySelf();
+        return mySelf.getFamilyId();
+    }
+
+    private String listSecondFamilyIds() {
+        ZInfoUser mySelf = getMySelf();
+        return mySelf.getSecondFamilyId();
+    }
+
+    @Override
+    public List<ZfClean> selectByCondition(ZfClean zfClean) {
+        String familyIds = listFamilyIds();
+        String secondFamilyIds = listSecondFamilyIds();
+        LambdaQueryWrapper<ZfClean> lambdaQueryWrapper = buildCondition(zfClean, familyIds, secondFamilyIds);
+        List<ZfClean> beanRecords = list(lambdaQueryWrapper);
+        log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", beanRecords);
+        return markOwnData(familyIds, beanRecords);
+    }
+
+    private static List<ZfClean> markOwnData(String familyIds, List<ZfClean> beanRecords) {
+        return beanRecords.stream().peek(record -> {
+            String recordFamilyId = record.getFamilyId();
+            if (familyIds.contains(",")) {
+                String[] familyIdList = familyIds.split(",");
+                for (String familyId : familyIdList) {
+                    if (familyId.equals(recordFamilyId)) {
+                        record.setOwnData(1);
+                    }
+                }
+            } else {
+                if (familyIds.equals(recordFamilyId)) {
+                    record.setOwnData(1);
+                }
+            }
+        }).collect(Collectors.toList());
+    }
+
+    @Override
+    public AjaxResult selectDataList(ZfClean zfClean, Integer pageNum, Integer pageSize) {
+        String familyIds = listFamilyIds();
+        String secondFamilyAuthority = listSecondFamilyIds();
+        LambdaQueryWrapper<ZfClean> lqw = buildCondition(zfClean, familyIds, secondFamilyAuthority);
+
+        Page<ZfClean> zfCleanPage = new Page<>(pageNum, pageSize);
+        Page<ZfClean> pageResult = page(zfCleanPage, lqw);
+
+        List<ZfClean> beanRecords = pageResult.getRecords();//寰楀埌鏌ヨ鍑烘潵鐨勬暟鎹�
+
+        List<ZfClean> dtoResult = markOwnData(familyIds, beanRecords);
+
+        HashMap<String, Object> data = MapUtils.getResult(pageResult, dtoResult);
+        return AjaxResult.success(data);
+    }
+
+    @Override
+    public AjaxResult addData(ZfClean zfClean) {
+
+        String familyIds = listFamilyIds();
+        boolean flag = false;//鍒ゆ柇褰撳墠鐢ㄦ埛鐨刬d鏄惁鏈夋潈鍔犲叆褰撳墠瀹跺涵id鐨勫璞�
+        if (familyIds.contains(",")) {
+            String[] familyList = familyIds.split(",");
+            for (String familyId : familyList) {
+                if (familyId.equals(zfClean.getFamilyId())) {
+                    flag = true;
+                }
+            }
+        } else {
+            if (zfClean.getFamilyId().equals(familyIds)) {
+                flag = true;
+            }
+        }
+        if (flag) {
+            if (save(zfClean)) {
+                return AjaxResult.success();
+            } else {
+                return AjaxResult.error();
+            }
+
+        } else {
+            throw new RuntimeException("浣犳病鏈夋搷浣滆瀹跺涵鍙蜂负" + zfClean.getFamilyId() + "鏁版嵁鐨勬潈闄�");
+        }
+    }
+
+    @Override
+    public AjaxResult addData2(ZfClean zfClean) {
+        ZInfoUser mySelf = getMySelf();
+        String myFamilyId = mySelf.getFamilyId();
+
+        if (StringUtils.isNotEmpty(zfClean.getFamilyId())) {
+            throw new RuntimeException("瀵煎叆鏁版嵁鏃舵偍涓嶈兘鎸囧畾瀹跺涵鍙�");
+        }
+
+        if (StringUtils.isEmpty(myFamilyId)) {
+            throw new RuntimeException("鎮ㄨ繕鏈姞鍏ヤ换浣曞搴�");
+        }
+
+        if (myFamilyId.contains(",")) {
+            String[] myFamilyIds = myFamilyId.split(",");
+            //榛樿娣诲姞绗竴涓搴殑鏁版嵁
+            zfClean.setFamilyId(myFamilyIds[0]);
+        } else {
+            zfClean.setFamilyId(myFamilyId);
+        }
+
+        if (save(zfClean)) {
+            return AjaxResult.success();
+        } else {
+            return AjaxResult.error();
+        }
+    }
+
+
+    @Override
+    @Transactional
+    public AjaxResult importExcel(MultipartFile file) {
+        ExcelUtil<ZfClean> util = new ExcelUtil<>(ZfClean.class);
+        List<ZfClean> propertyList = null;
+        try {
+            propertyList = util.importExcel(file.getInputStream());
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        log.info("璧勪骇鍒楄〃涓猴細{}", propertyList);
+
+        for (ZfClean zfClean : propertyList) {
+            zfCleanService.addData2(zfClean);
+        }
+
+        return AjaxResult.success("瀵煎叆鏁版嵁鎴愬姛");
+
+    }
+
+
 }

--
Gitblit v1.9.1