From 8e3f58c38fd3d552125ada6afdf88e7fc2b380a0 Mon Sep 17 00:00:00 2001
From: Jinquan_Ou <Jinquan@gdut.com>
Date: 星期一, 17 四月 2023 12:47:32 +0800
Subject: [PATCH] 888

---
 zhang-content/src/main/java/com/ruoyi/service/impl/ZfEventServiceImpl.java |   87 +++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 83 insertions(+), 4 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..fb803c4 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,9 +37,26 @@
 @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> pageResult = page(ZfEventPage, lqw);
@@ -40,13 +64,57 @@
         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);
+        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) {
@@ -59,4 +127,15 @@
         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