From 4f78db00a0aa292655e216c507589df8dd65d7b7 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期三, 12 十一月 2025 17:10:41 +0800
Subject: [PATCH] 管理后台导入,问卷调查

---
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLargeKeyGridUserController.java |  174 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 172 insertions(+), 2 deletions(-)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLargeKeyGridUserController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLargeKeyGridUserController.java
index 9b728c9..7ada13f 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLargeKeyGridUserController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TLargeKeyGridUserController.java
@@ -1,22 +1,47 @@
 package com.ruoyi.web.controller.api;
 
 
+import cn.afterturn.easypoi.excel.ExcelExportUtil;
+import cn.afterturn.easypoi.excel.ExcelImportUtil;
+import cn.afterturn.easypoi.excel.entity.ExportParams;
+import cn.afterturn.easypoi.excel.entity.ImportParams;
+import cn.hutool.json.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.ruoyi.common.annotation.Log;
 import com.ruoyi.common.basic.PageInfo;
 import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.core.exception.ServiceException;
 import com.ruoyi.common.enums.BusinessType;
+import com.ruoyi.common.utils.WebUtils;
+import com.ruoyi.system.export.LargeKeyGridUserImport;
 import com.ruoyi.system.model.TLargeKeyGridUser;
+import com.ruoyi.system.model.TLargeKeyPersonnelType;
 import com.ruoyi.system.query.TLargeKeyGridUserQuery;
 import com.ruoyi.system.service.TLargeKeyGridUserService;
+import com.ruoyi.system.service.TLargeKeyPersonnelTypeService;
 import com.ruoyi.system.vo.TLargeKeyGridUserVO;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+import org.springframework.util.StringUtils;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
+import javax.servlet.ServletOutputStream;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.URLEncoder;
+import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * <p>
@@ -26,15 +51,18 @@
  * @author xiaochen
  * @since 2025-11-11
  */
+@Slf4j
 @Api(tags = "大屏-重点人员-网格人员")
 @RestController
 @RequestMapping("/t-large-key-grid-user")
 public class TLargeKeyGridUserController {
 
     private final TLargeKeyGridUserService largeKeyGridUserService;
+    private final TLargeKeyPersonnelTypeService largeKeyPersonnelTypeService;
     @Autowired
-    public TLargeKeyGridUserController(TLargeKeyGridUserService largeKeyGridUserService) {
+    public TLargeKeyGridUserController(TLargeKeyGridUserService largeKeyGridUserService, TLargeKeyPersonnelTypeService largeKeyPersonnelTypeService) {
         this.largeKeyGridUserService = largeKeyGridUserService;
+        this.largeKeyPersonnelTypeService = largeKeyPersonnelTypeService;
     }
 
     /**
@@ -111,6 +139,148 @@
     public R<Boolean> deleteByIds(@RequestBody List<String> ids) {
         return R.ok(largeKeyGridUserService.removeByIds(ids));
     }
-    
+
+    @ApiOperation(value = "重点人员-网格人员导入模板下载")
+    @GetMapping("/import-template")
+    public void importTemplate() {
+        List<LargeKeyGridUserImport> largeLargeKeyGridUserImports = new ArrayList<>();
+        LargeKeyGridUserImport largeLargeKeyGridUserImport = new LargeKeyGridUserImport();
+        largeLargeKeyGridUserImports.add(largeLargeKeyGridUserImport);
+        Workbook workbook = ExcelExportUtil.exportExcel(new ExportParams(), LargeKeyGridUserImport.class, largeLargeKeyGridUserImports);
+        HttpServletResponse response = WebUtils.response();
+        ServletOutputStream outputStream = null;
+        try {
+            String fileName = URLEncoder.encode("重点人员-网格人员信息导入模板.xls", "utf-8");
+            response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
+            response.setHeader("content-Type", "application/vnd.ms-excel");
+            response.setHeader("Pragma", "no-cache");
+            response.setHeader("Cache-Control", "no-cache");
+            outputStream = response.getOutputStream();
+            workbook.write(outputStream);
+        } catch (IOException e) {
+            e.printStackTrace();
+            System.out.println("重点人员-网格人员导入模板下载失败!");
+        } finally {
+            try {
+                outputStream.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    @Log(title = "重点人员-网格人员信息-重点人员信息导入", businessType = BusinessType.INSERT)
+    @ApiOperation(value = "重点人员信息导入")
+    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
+    @PostMapping("/import")
+    public R<String> importInfo(@RequestPart("file") MultipartFile file) {
+        List<TLargeKeyGridUser> largeKeyGridUsers = new ArrayList<>();
+        ImportParams params = new ImportParams();
+        params.setHeadRows(1); //表头行数
+        InputStream inputStream = null;
+        List<LargeKeyGridUserImport> largeKeyGridUserImports;
+        try {
+            inputStream = file.getInputStream();
+            largeKeyGridUserImports = ExcelImportUtil.importExcel(inputStream,
+                    LargeKeyGridUserImport.class, params);
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("重点人员信息导入失败:{}", e.getMessage());
+            throw new ServiceException("重点人员信息导入失败!");
+        } finally {
+            try {
+                inputStream.close();
+            } catch (IOException e) {
+                throw new ServiceException(e.getMessage());
+            }
+        }
+        if (CollectionUtils.isEmpty(largeKeyGridUserImports)) {
+            throw new ServiceException("重点人员信息数据为空!");
+        }
+        JSONObject result = new JSONObject();
+        int i = 1;
+        for (LargeKeyGridUserImport largeKeyGridUserImport : largeKeyGridUserImports) {
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getGridInfo())){
+                result.append("第"+i+"行:[", "网格"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getCommunityName())){
+                result.append("第"+i+"行:[", "小区名称"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getBuildingInfo())){
+                result.append("第"+i+"行:[", "楼栋信息"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getUnitNumber())){
+                result.append("第"+i+"行:[", "单元号"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getHouseNumber())){
+                result.append("第"+i+"行:[", "门牌号"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getUserName())){
+                result.append("第"+i+"行:[", "姓名"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getUserSexStr())){
+                result.append("第"+i+"行:[", "性别"+"]不能为空");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getIdCard())){
+                result.append("第"+i+"行:[", "身份证号"+"]不能为空");
+                continue;
+            }
+            if (largeKeyGridUserImport.getIdCard().matches("^$|(^[1-9]\\\\d{7}((0\\\\d)|(1[0-2]))(([0-2]\\\\d)|3[0-1])\\\\d{3}$)|(^[1-9]\\\\d{5}[1-9]\\\\d{3}((0\\\\d)|(1[0-2]))(([0-2]\\\\d)|3[0-1])((\\\\d{4})|\\\\d{3}[Xx])$)")){
+                result.append("第"+i+"行:[", "身份证号"+"]格式不正确");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getContactNumber())){
+                result.append("第"+i+"行:[", "联系电话"+"]不能为空");
+                continue;
+            }
+            if (largeKeyGridUserImport.getContactNumber().matches("^1[3-9]\\\\d{9}$")){
+                result.append("第"+i+"行:[", "联系电话"+"]格式不正确");
+                continue;
+            }
+            if (!StringUtils.hasLength(largeKeyGridUserImport.getTypeName())){
+                result.append("第"+i+"行:[", "类型名称"+"]不能为空");
+                continue;
+            }
+            TLargeKeyGridUser largeKeyGridUser = new TLargeKeyGridUser();
+            BeanUtils.copyProperties(largeKeyGridUserImport, largeKeyGridUser);
+
+            switch (largeKeyGridUserImport.getUserSexStr()){
+                case "男":
+                    largeKeyGridUser.setUserSex(1);
+                    break;
+                case "女":
+                    largeKeyGridUser.setUserSex(2);
+                    break;
+                default:
+                    result.append("第"+i+"行:[", "性别"+"]格式错误");
+                    continue;
+            }
+
+            TLargeKeyPersonnelType largeKeyPersonnelType = largeKeyPersonnelTypeService.getOne(Wrappers.lambdaQuery(TLargeKeyPersonnelType.class)
+                    .eq(TLargeKeyPersonnelType::getTypeName, largeKeyGridUserImport.getTypeName())
+                    .last("LIMIT 1"));
+            if(Objects.isNull(largeKeyPersonnelType)){
+                result.append("第"+i+"行:[", "类型名称"+"]不存在");
+                continue;
+            }
+            largeKeyGridUser.setTypeId(largeKeyPersonnelType.getId());
+            largeKeyGridUser.setUserType(1);
+            largeKeyGridUsers.add(largeKeyGridUser);
+            i++;
+        }
+        largeKeyGridUserService.saveBatch(largeKeyGridUsers);
+        if(!result.isEmpty()){
+            return R.fail(result.toString());
+        }
+        return R.ok();
+    }
+
 }
 

--
Gitblit v1.7.1