From 923af8f8eb0d849b92afa8b567036aae2837f202 Mon Sep 17 00:00:00 2001
From: Jinquan_Ou <Jinquan@gdut.com>
Date: 星期五, 21 四月 2023 16:41:00 +0800
Subject: [PATCH] 888

---
 zhang-content/src/main/java/com/ruoyi/service/impl/ZfEventServiceImpl.java |  102 +++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 91 insertions(+), 11 deletions(-)

diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEventServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEventServiceImpl.java
index 998c588..9fef9fc 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEventServiceImpl.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfEventServiceImpl.java
@@ -5,16 +5,23 @@
 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.ZfEvent;
 import com.ruoyi.domain.ZfEvent;
+import com.ruoyi.domain.ZfProperty;
 import com.ruoyi.mapper.ZfEventMapper;
+import com.ruoyi.service.ZInfoUserService;
 import com.ruoyi.service.ZfEventService;
 import lombok.extern.slf4j.Slf4j;
-import org.jetbrains.annotations.NotNull;
 import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
 
+import javax.annotation.Resource;
 import java.util.HashMap;
 import java.util.List;
 
@@ -30,32 +37,105 @@
 @Service
 public class ZfEventServiceImpl extends ServiceImpl<ZfEventMapper, ZfEvent> implements ZfEventService {
 
+    @Resource
+    ZInfoUserService zInfoUserService;
+
+    @Resource
+    ZfEventService zfEventService;
+
+    private String listFamilyIds() {
+        SysUser user = SecurityUtils.getLoginUser().getUser();
+        Long userId = user.getUserId();
+        LambdaQueryWrapper<ZInfoUser> zInfoUserLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        zInfoUserLambdaQueryWrapper.eq(ZInfoUser::getUserId, userId);
+        ZInfoUser zInfoUser = zInfoUserService.getOne(zInfoUserLambdaQueryWrapper);
+        return zInfoUser.getFamilyId();
+    }
+
+
     @Override
     public AjaxResult selectEventList(ZfEvent zfEvent, Integer pageNum, Integer pageSize) {
-        LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent);
+        String familyIds = listFamilyIds();
+        LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent, familyIds);
 
-        Page<ZfEvent> ZfEventPage = new Page<>(pageNum,pageSize);
+        Page<ZfEvent> ZfEventPage = new Page<>(pageNum, pageSize);
         Page<ZfEvent> pageResult = page(ZfEventPage, lqw);
 
         HashMap<String, Object> data = MapUtils.getResult(pageResult);
         return AjaxResult.success(data);
     }
 
+
     @Override
     public List<ZfEvent> selectByCondition(ZfEvent zfEvent) {
-        LambdaQueryWrapper<ZfEvent> lambdaQueryWrapper = buildCondition(zfEvent);
-        List<ZfEvent> list = list(lambdaQueryWrapper);
-        log.info("杩斿洖鐨勬暟鎹负:{}",list);
+        String familyIds = listFamilyIds();
+        LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent, familyIds);
+        List<ZfEvent> list = list(lqw);
+        log.info("杩斿洖鐨勬暟鎹负:{}", list);
         return list;
+    }
+
+    @Override
+    public int addEvent(ZfEvent zfEvent) {
+        String familyIds = listFamilyIds();
+        boolean flag = false;//鍒ゆ柇褰撳墠鐢ㄦ埛鐨刬d鏄惁鏈夋潈鍔犲叆褰撳墠瀹跺涵id鐨勫璞�
+        if (familyIds.contains(",")) {
+            String[] familyList = familyIds.split(",");
+            for (String familyId : familyList) {
+                if (familyId.equals(zfEvent.getFamilyId())) {
+                    flag = true;
+                }
+            }
+        } else {
+            if (zfEvent.getFamilyId().equals(familyIds)) {
+                flag = true;
+            }
+        }
+        if (flag) {
+            boolean save = save(zfEvent);
+            return save ? 1 : 0;
+        } else {
+            throw new RuntimeException("浣犳病鏈夋搷浣滆瀹跺涵鍙蜂负" + zfEvent.getFamilyId() + "鏁版嵁鐨勬潈闄�");
+        }
+    }
+
+    @Override
+    public AjaxResult importExcel(MultipartFile file) {
+        ExcelUtil<ZfEvent> util = new ExcelUtil<>(ZfEvent.class);
+        List<ZfEvent> eventList = null;
+        try {
+            eventList = util.importExcel(file.getInputStream());
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+        log.info("璧勪骇鍒楄〃涓猴細{}", eventList);
+
+        for (ZfEvent zfEvent : eventList) {
+            zfEventService.addEvent(zfEvent);
+        }
+
+        return AjaxResult.success("瀵煎叆鏁版嵁鎴愬姛");
     }
 
     private LambdaQueryWrapper<ZfEvent> buildCondition(ZfEvent zfEvent) {
         LambdaQueryWrapper<ZfEvent> lqw = new LambdaQueryWrapper<>();
-        lqw.like(!StringUtils.isEmpty(zfEvent.getAddress()),ZfEvent::getAddress,zfEvent.getAddress());
-        lqw.like(!StringUtils.isEmpty(zfEvent.getPeople()),ZfEvent::getPeople,zfEvent.getPeople());
-        lqw.like(!StringUtils.isEmpty(zfEvent.getTitle()),ZfEvent::getTitle,zfEvent.getTitle());
-        lqw.like(!StringUtils.isEmpty(zfEvent.getRemark()),ZfEvent::getRemark,zfEvent.getRemark());
-        lqw.like(zfEvent.getCreateTime()!=null,ZfEvent::getCreateTime,zfEvent.getCreateTime());
+        lqw.like(!StringUtils.isEmpty(zfEvent.getAddress()), ZfEvent::getAddress, zfEvent.getAddress());
+        lqw.like(!StringUtils.isEmpty(zfEvent.getPeople()), ZfEvent::getPeople, zfEvent.getPeople());
+        lqw.like(!StringUtils.isEmpty(zfEvent.getTitle()), ZfEvent::getTitle, zfEvent.getTitle());
+        lqw.like(!StringUtils.isEmpty(zfEvent.getRemark()), ZfEvent::getRemark, zfEvent.getRemark());
+        lqw.eq(zfEvent.getHappenTime() != null, ZfEvent::getHappenTime, zfEvent.getHappenTime());
+        lqw.between(zfEvent.getHappenStartTime() != null && zfEvent.getHappenEndTime() != null, ZfEvent::getHappenTime, zfEvent.getHappenStartTime(), zfEvent.getHappenEndTime());
+        return lqw;
+    }
+
+    private LambdaQueryWrapper<ZfEvent> buildCondition(ZfEvent zfEvent, String familyIds) {
+        LambdaQueryWrapper<ZfEvent> lqw = buildCondition(zfEvent);
+        if (familyIds.contains(",")) {
+            String[] familyList = familyIds.split(",");
+            lqw.in(ZfEvent::getFamilyId, familyList);
+        } else {
+            lqw.eq(ZfEvent::getFamilyId, familyIds);
+        }
         return lqw;
     }
 

--
Gitblit v1.9.1