地理设施导入，设备导入

service-iot/service-iot-biz/src/main/java/com/usky/iot/controller/web/BaseGgpFacilityController.java

@@ -13,6 +13,7 @@ import com.usky.iot.service.BaseGgpFacilityService;
 import com.usky.iot.service.vo.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
@@ -192,5 +193,19 @@ public class BaseGgpFacilityController {
         return ApiResult.success(baseGgpFacilityService.facilityPopInfo(id));
     }
 
+    /**
+     * 地理设施-导入
+     *
+     * @param file 导入文件
+     * @return
+     * @throws Exception
+     */
+    @Log(title = "地理设施", businessType = BusinessType.IMPORT)
+    @PostMapping("/facilityImport")
+    public ApiResult<Void> facilityImport(@RequestParam("file") MultipartFile file){
+        baseGgpFacilityService.facilityImport(file);
+        return ApiResult.success();
+    }
+
 }
 

service-iot/service-iot-biz/src/main/java/com/usky/iot/controller/web/DmpDeviceInfoController.java

@@ -80,13 +80,11 @@ public class DmpDeviceInfoController {
     /**
      * 批量导入
      * @param multipartFiles
-     * @param productId
      * @return
      */
     @PostMapping("/addByFile")
-    public ApiResult<Void> addByFile(@RequestParam(value = "file") MultipartFile multipartFiles,
-                                     @RequestParam("productId") Integer productId){
-        dmpDeviceInfoService.addByFile(productId,multipartFiles);
+    public ApiResult<Void> addByFile(@RequestParam(value = "file") MultipartFile multipartFiles){
+        dmpDeviceInfoService.addByFile(multipartFiles);
         return ApiResult.success();
     }
 

service-iot/service-iot-biz/src/main/java/com/usky/iot/domain/BaseGgpFacility.java

@@ -50,7 +50,7 @@ public class BaseGgpFacility implements Serializable {
     /**
      * 设施类型(1、天然水源 2、五万方综合体 3、三到五万方综合体 4、拟列区级重大火灾隐患单位 5、拟列市级重大火灾隐患单位 6、一般重大火灾隐患单位 7、扣分5以下九小场所 8、扣分6-14九小场所 9、扣分15-24九小场所 10、钢瓶九小场所 11、电瓶车九小场所 12、三合一九小场所 13、重点单位微站 14、一般单位微站 15、居委会微站 16、村委会微站)
      */
-    private Integer facilityType;
+    private String facilityType;
 
     /**
      * 经度(当设施类型为点时使用该字段)

service-iot/service-iot-biz/src/main/java/com/usky/iot/mapper/BaseFacilityTypeMapper.java

@@ -22,5 +22,5 @@ public interface BaseFacilityTypeMapper extends CrudMapper<BaseFacilityType> {
     List<BaseGgpFacilityTypeNumVO> typeNormalNumList(@Param("tenantId") Integer tenantId);
     List<BaseGgpFacilityTypeNumVO> typeUpkeepNumList(@Param("tenantId") Integer tenantId);
     List<BaseGgpFacilityTypeNumVO> typeCloseNumList(@Param("tenantId") Integer tenantId);
-    List<BaseFacilityType> typeList(@Param("typeId") Integer typeId);
+    List<BaseFacilityType> typeList(@Param("typeId") String typeId);
 }

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/BaseGgpFacilityService.java

@@ -9,6 +9,7 @@ import com.usky.iot.service.vo.BaseFacilityDeviceVO;
 import com.usky.iot.service.vo.BaseGgpFacilityExportVo;
 import com.usky.iot.service.vo.BaseGgpFacilityRequest;
 import com.usky.iot.service.vo.BaseGgpFacilityVO;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
 
@@ -55,4 +56,6 @@ public interface BaseGgpFacilityService extends CrudService<BaseGgpFacility> {
      * @param id  主键ID
      */
     List<Object> facilityPopInfo(Integer id);
+
+    void facilityImport(MultipartFile multipartFile);
 }

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/DmpDeviceInfoService.java

@@ -45,7 +45,7 @@ public interface DmpDeviceInfoService extends CrudService<DmpDeviceInfo> {
      */
     int deviceCountByProductId(Integer productId);
 
-    void addByFile(Integer productId, MultipartFile multipartFiles);
+    void addByFile(MultipartFile multipartFiles);
 
     void importDeviceInfo(List<DmpDeviceInfo> list);
 

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/impl/BaseGgpFacilityServiceImpl.java

@@ -1,5 +1,7 @@
 package com.usky.iot.service.impl;
 
+import cn.afterturn.easypoi.excel.ExcelImportUtil;
+import cn.afterturn.easypoi.excel.entity.ImportParams;
 import cn.hutool.core.collection.CollectionUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -9,6 +11,8 @@ import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.usky.common.core.bean.CommonPage;
+import com.usky.common.core.exception.BusinessException;
+import com.usky.common.core.util.BeanMapperUtils;
 import com.usky.common.core.util.UUIDUtils;
 import com.usky.common.security.utils.SecurityUtils;
 import com.usky.iot.domain.*;
@@ -23,6 +27,9 @@ import com.usky.system.model.LoginUser;
 import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import org.springframework.web.multipart.MultipartFile;
 
 import java.text.SimpleDateFormat;
 import java.time.LocalDateTime;
@@ -401,4 +408,41 @@ public class BaseGgpFacilityServiceImpl extends AbstractCrudService<BaseGgpFacil
         list.add(map);
         return list;
     }
+
+    @Override
+    public void facilityImport(MultipartFile multipartFile) {
+        ImportParams params = new ImportParams();
+        params.setHeadRows(1);
+        params.setTitleRows(1);
+        String err="文件导入失败";
+        try {
+            List<FacilityImportVo> facilityImportVos = ExcelImportUtil.importExcel(multipartFile.getInputStream(),
+                    FacilityImportVo.class, params);
+            if (CollectionUtils.isNotEmpty(facilityImportVos)){
+                int rot=0;
+                for (FacilityImportVo facilityImportVo:facilityImportVos) {
+                    BaseGgpFacility baseGgpFacility = BeanMapperUtils.map(facilityImportVo, BaseGgpFacility.class);
+                    if (StringUtils.isBlank(baseGgpFacility.getFacilityType())||StringUtils.isBlank(baseGgpFacility.getFacilityName())||StringUtils.isBlank(baseGgpFacility.getAddress())||StringUtils.isBlank(baseGgpFacility.getLatitude())||StringUtils.isBlank(baseGgpFacility.getLongitude())){
+                        int h=rot+3;
+                        err="文件导入失败，第"+h+"行数据导入失败,必填字段不能为空";
+                        throw  new BusinessException(err);
+                    }
+                    try{
+                        this.add(baseGgpFacility);
+                    }catch (Exception e){
+                        int h=rot+3;
+                        err="文件导入失败，第"+h+"行数据导入失败";
+                        throw  new BusinessException(err);
+                    }
+                    rot++;
+                }
+            }else {
+                err="文件不能为空";
+                throw new BusinessException(err);
+            }
+        }catch (Exception e){
+            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+            throw  new BusinessException(err);
+        }
+    }
 }

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/impl/DmpDeviceInfoServiceImpl.java

@@ -25,13 +25,11 @@ import com.usky.common.security.utils.SecurityUtils;
 import com.usky.iot.mapper.DmpDeviceInfoMapper;
 import com.usky.iot.service.DmpDeviceInfoService;
 import com.usky.iot.service.DmpDeviceStatusService;
-import com.usky.iot.service.vo.BaseFacilityDeviceVO;
-import com.usky.iot.service.vo.DmpDeviceExcelVO;
-import com.usky.iot.service.vo.DmpDeviceExportVO;
-import com.usky.iot.service.vo.DmpDeviceInfoRequest;
+import com.usky.iot.service.vo.*;
 import org.apache.poi.ss.usermodel.Workbook;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.interceptor.TransactionAspectSupport;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.ServletOutputStream;
@@ -138,9 +136,39 @@ public class DmpDeviceInfoServiceImpl extends AbstractCrudService<DmpDeviceInfoM
     }
 
     @Override
-    public void addByFile(Integer productId, MultipartFile multipartFiles) {
-        List<DmpDeviceInfo> deviceByFile = getDeviceByFile(productId, multipartFiles);
-        this.saveBatch(deviceByFile);
+    public void addByFile(MultipartFile multipartFiles) {
+        ImportParams params = new ImportParams();
+        params.setHeadRows(1);
+        params.setTitleRows(1);
+        String err="文件导入失败";
+        try {
+            List<DeviceImportVo> deviceImportVos = ExcelImportUtil.importExcel(multipartFiles.getInputStream(),
+                    DeviceImportVo.class, params);
+            if (CollectionUtils.isNotEmpty(deviceImportVos)){
+                int rot=0;
+                for (DeviceImportVo deviceImportVo:deviceImportVos) {
+                    DmpDeviceInfo dmpDeviceInfo = BeanMapperUtils.map(deviceImportVo, DmpDeviceInfo.class);
+                    if (StringUtils.isBlank(dmpDeviceInfo.getDeviceId())||StringUtils.isBlank(dmpDeviceInfo.getProductCode())||StringUtils.isBlank(dmpDeviceInfo.getDeviceName())||StringUtils.isBlank(dmpDeviceInfo.getInstallAddress())){
+                        int h=rot+3;
+                        err="文件导入失败，第"+h+"行数据导入失败,必填字段不能为空";
+                        throw  new BusinessException(err);
+                    }
+                    try{
+                        this.add(dmpDeviceInfo);
+                    }catch (Exception e){
+                        int h=rot+3;
+                        err="文件导入失败，第"+h+"行数据导入失败";
+                        throw  new BusinessException(err);
+                    }
+                    rot++;
+                }
+            }else {
+                err="文件不能为空";
+                throw new BusinessException(err);
+            }
+        }catch (Exception e){
+            throw  new BusinessException(err);
+        }
     }
 
     @Override

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/vo/DeviceImportVo.java

@@ -0,0 +1,46 @@
+package com.usky.iot.service.vo;
+
+import cn.afterturn.easypoi.excel.annotation.Excel;
+
+import lombok.Data;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author han
+ * @since 2023-07-27
+ */
+@Data
+public class DeviceImportVo{
+    /**
+     * 系统编号（必填）
+     */
+    @Excel(name = "系统编号（必填）")
+    private String productCode;
+
+    /**
+     * 设备id（必填）
+     */
+    @Excel(name = "设备id（必填）")
+    private String deviceId;
+
+    /**
+     * 设备名称（必填）
+     */
+    @Excel(name = "设备名称（必填）")
+    private String deviceName;
+    /**
+     * SIM
+     */
+    @Excel(name = "SIM")
+    private String simCode;
+
+    /**
+     * 安装位置描述（必填）
+     */
+    @Excel(name = "安装位置描述（必填）")
+    private String installAddress;
+
+}

service-iot/service-iot-biz/src/main/java/com/usky/iot/service/vo/facilityImportVo.java

@@ -0,0 +1,64 @@
+package com.usky.iot.service.vo;
+
+import cn.afterturn.easypoi.excel.annotation.Excel;
+
+import lombok.Data;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author han
+ * @since 2023-07-27
+ */
+@Data
+public class FacilityImportVo{
+    /**
+     * 设施类型（必填）
+     */
+    @Excel(name = "设施类型（必填）")
+    private String facilityType;
+
+    /**
+     * 设施名称（必填）
+     */
+    @Excel(name = "设施名称（必填）")
+    private String facilityName;
+
+    /**
+     * 设施地址（必填）
+     */
+    @Excel(name = "设施地址（必填）")
+    private String address;
+    /**
+     * 联系人
+     */
+    @Excel(name = "联系人")
+    private String contact;
+
+    /**
+     * 联系电话
+     */
+    @Excel(name = "联系电话")
+    private String contactPhone;
+
+    /**
+     * 备注
+     */
+    @Excel(name = "备注")
+    private String facilityDesc;
+
+    /**
+     * 经度（必填）
+     */
+    @Excel(name = "经度（必填）")
+    private String longitude;
+
+    /**
+     * 维度（必填）
+     */
+    @Excel(name = "维度（必填）")
+    private String latitude;
+
+}

service-iot/service-iot-biz/src/main/resources/mapper/iot/BaseFacilityTypeMapper.xml

@@ -71,11 +71,11 @@
         GROUP BY d.id
     </select>
     <select id="typeList" resultType="com.usky.iot.domain.BaseFacilityType">
-        SELECT id,type_name as typeName,type_abbrevia as typeAbbrevia
+        SELECT id,type_code,type_name as typeName,type_abbrevia as typeAbbrevia
         FROM base_facility_type
         <where>
             <if test="typeId != null and typeId != ''">
-                and id = #{typeId}
+                and type_code = #{typeId}
             </if>
         </where>
     </select>