From e6a2b78ffe066d2f32a878df5eb6588d0e8ebff2 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期日, 18 九月 2022 20:11:49 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/crm/manager/controller/CstmrController.java |  119 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 117 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/zy/crm/manager/controller/CstmrController.java b/src/main/java/com/zy/crm/manager/controller/CstmrController.java
index 89c97dd..b56f090 100644
--- a/src/main/java/com/zy/crm/manager/controller/CstmrController.java
+++ b/src/main/java/com/zy/crm/manager/controller/CstmrController.java
@@ -12,20 +12,37 @@
 import com.core.exception.CoolException;
 import com.zy.crm.common.web.BaseController;
 import com.zy.crm.manager.entity.Cstmr;
+import com.zy.crm.manager.entity.CstmrType;
 import com.zy.crm.manager.service.CstmrService;
+import com.zy.crm.manager.service.CstmrTypeService;
+import com.zy.crm.system.entity.Dic;
+import com.zy.crm.system.service.DicService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.*;
 
+@Slf4j
 @RestController
 public class CstmrController extends BaseController {
 
     @Autowired
     private CstmrService cstmrService;
+    @Autowired
+    private CstmrTypeService cstmrTypeService;
+    @Autowired
+    private DicService dicService;
 
     @RequestMapping(value = "/cstmr/{id}/auth")
     @ManagerAuth
@@ -85,7 +102,7 @@
             throw new CoolException("瀹㈡埛宸插瓨鍦�");
         }
         cstmr.setHostId(hostId);
-        cstmr.setUuid(cstmrService.getNextUuid(hostId));  // 瀹㈡埛浠e彿
+        cstmr.setUuid(cstmrService.getUuid(hostId));  // 瀹㈡埛浠e彿
         cstmr.setDeptId(getDeptId());               // 鎵�灞為儴闂�
         cstmr.setUserId(getUserId());               // 鎵�灞炰汉鍛�
 
@@ -162,8 +179,106 @@
      * excel瀵煎叆
      */
     @PostMapping(value = "/cstmr/excel/import/auth")
-    @ManagerAuth
+    @ManagerAuth(memo = "鐢叉柟鍗曚綅Excel瀵煎叆")
+    @Transactional
     public R cstmrExcelImport(MultipartFile file) throws IOException {
+        try (InputStream inStream = file.getInputStream()) {
+            String fileMime = file.getContentType();
+            int excelVersion = 2007;
+            if ("application/vnd.ms-excel".equals(fileMime)) {
+                excelVersion = 2003;
+            }
+            Workbook book = null;
+            if (excelVersion == 2003) {
+                book = new HSSFWorkbook(inStream);
+            }
+            else {  // 褰� excel 鏄� 2007 鏃�
+                book = new XSSFWorkbook(inStream);
+            }
+            Sheet sheet = book.getSheetAt(0);
+            int totalRows = sheet.getPhysicalNumberOfRows() - 1;    // 鎬�
+            Long userId = getUserId();
+            Long hostId = getHostId();
+            Long deptId = getDeptId();
+            Date now = new Date();
+            for (int i = 2; i < totalRows; i++) {
+                Cstmr cstmr = new Cstmr();
+                Row row = sheet.getRow(i);
+                // 瀹㈡埛浠e彿
+                String uuid = row.getCell(0).getStringCellValue();
+                if (!Cools.isEmpty(uuid)) {
+                    if (cstmrService.selectByUuid(hostId, uuid) != null) {
+                        throw new CoolException(uuid + "瀹㈡埛浠e彿宸插瓨鍦紝璇烽噸鏂板鍏�");
+                    } else {
+                        cstmr.setUuid(uuid);
+                    }
+                } else {
+                    cstmr.setUuid(cstmrService.getUuid(hostId));
+                }
+                // 瀹㈡埛浠e彿
+                String name = row.getCell(1).getStringCellValue();
+                if (Cools.isEmpty(name)) {
+                    throw new CoolException("绗�" + i + "琛屽鎴峰悕绉颁笉鑳戒负绌猴紝璇烽噸鏂板鍏�");
+                }
+                cstmr.setName(name);
+                // 瀹㈡埛绫诲埆
+                String type = row.getCell(2).getStringCellValue();
+                if (Cools.isEmpty(type)) {
+                    throw new CoolException("绗�" + i + "琛屽鎴风被鍒笉鑳戒负绌猴紝璇烽噸鏂板鍏�");
+                }
+                CstmrType cstmrType = cstmrTypeService.selectByName(hostId, type);
+                if (null == cstmrType) {
+                    throw new CoolException("绗�" + i + "琛屽鎴风被鍒笉鍚堟硶锛岃閲嶆柊瀵煎叆");
+                }
+                cstmr.setCstmrType(cstmrType.getId());
+                // 瀹㈡埛绫诲埆
+                cstmr.setRela(row.getCell(3).getStringCellValue());
+                // 鐢佃瘽
+                cstmr.setTel(row.getCell(4).getStringCellValue());
+                // 瀹㈡埛鑱旂郴浜�
+                cstmr.setContacts(row.getCell(5).getStringCellValue());
+                // 澶囨敞
+                cstmr.setRemarks(row.getCell(6).getStringCellValue());
+                // 鐪�
+                String province = row.getCell(7).getStringCellValue();
+                Dic dicProvince = dicService.selectByName(province);
+                if (Cools.isEmpty(dicProvince)) {
+                    throw new CoolException("绗�" + i + "琛岀渷鍚嶄笉鍚堟硶锛岃閲嶆柊瀵煎叆");
+                }
+                cstmr.setProvince(dicProvince.getCode());
+                // 甯�
+                String city = row.getCell(8).getStringCellValue();
+                Dic dicCity = dicService.selectByName(city);
+                if (Cools.isEmpty(dicCity)) {
+                    throw new CoolException("绗�" + i + "琛屽競鍚嶄笉鍚堟硶锛岃閲嶆柊瀵煎叆");
+                }
+                cstmr.setCity(dicCity.getCode());
+                // 鍖�
+                String district = row.getCell(9).getStringCellValue();
+                Dic dicDistrict = dicService.selectByName(district);
+                if (Cools.isEmpty(dicDistrict)) {
+                    throw new CoolException("绗�" + i + "琛屽幙鍚嶄笉鍚堟硶锛岃閲嶆柊瀵煎叆");
+                }
+                cstmr.setDistrict(dicDistrict.getCode());
+                // 璇︾粏鍦板潃
+                cstmr.setAddr(row.getCell(10).getStringCellValue());
+                // 鍖哄垎
+                cstmr.setType0(row.getCell(11).getStringCellValue());
+                cstmr.setHostId(hostId);
+                cstmr.setDeptId(deptId);
+                cstmr.setUserId(userId);
+                cstmr.setStatus(1);
+                cstmr.setCreateBy(userId);
+                cstmr.setCreateTime(now);
+                cstmr.setUpdateBy(userId);
+                cstmr.setUpdateTime(now);
+                if (!cstmrService.insert(cstmr)) {
+                    throw new CoolException("淇濆瓨澶辫触锛岃閲嶆柊瀵煎叆");
+                }
+            }
+        }  catch (Exception e) {
+            e.printStackTrace();
+        }
 
         return R.ok();
     }

--
Gitblit v1.9.1