From 72931705d234b9a50c4a731de6494e366f09e209 Mon Sep 17 00:00:00 2001
From: elliott <382696293@qq.com>
Date: Fri, 19 Jan 2024 17:40:13 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=AA=E5=99=A8=E5=BA=8F=E5=88=97=E5=8F=B7?=
 =?UTF-8?q?=E5=AF=BC=E5=87=BA=E6=A8=A1=E5=9D=97=E5=BC=80=E5=8F=91-?=
 =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=AF=BC=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../req/WxInstrumentSerialImportVm.java       | 61 ++++++++++++
 .../mapper/WxInstrumentSerialMapper.xml       |  2 +-
 .../WxInstrumentSerialController.java         | 30 +++++-
 .../service/IWxInstrumentSerialService.java   |  9 ++
 .../impl/WxInstrumentSerialServiceImpl.java   | 98 +++++++++++++++++++
 .../views/system/instrumentSerial/index.vue   | 93 +++++++++++++++++-
 6 files changed, 286 insertions(+), 7 deletions(-)
 create mode 100644 flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/domain/req/WxInstrumentSerialImportVm.java

diff --git a/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/domain/req/WxInstrumentSerialImportVm.java b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/domain/req/WxInstrumentSerialImportVm.java
new file mode 100644
index 0000000..6fdad33
--- /dev/null
+++ b/flossom-common/flossom-common-core/src/main/java/com/flossom/common/core/domain/req/WxInstrumentSerialImportVm.java
@@ -0,0 +1,61 @@
+package com.flossom.common.core.domain.req;
+
+import com.flossom.common.core.annotation.Excel;
+import com.flossom.common.core.annotation.Excel.Type;
+
+
+import java.util.Date;
+
+public class WxInstrumentSerialImportVm {
+    /**
+     * 仪器id
+     */
+    @Excel(name = "仪器id",type = Type.IMPORT)
+
+    private Long instrumentId;
+
+    /** 来源 */
+    @Excel(name = "来源",type = Type.IMPORT)
+    private String source;
+
+    /** 序列号 */
+    @Excel(name = "序列号",type = Type.IMPORT)
+    private String serial;
+
+    /** 序列号有效状态，1有效，0无效 */
+    @Excel(name = "有效状态",type = Type.IMPORT)
+    private String validStatus;
+
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source;
+    }
+
+    public String getSerial() {
+        return serial;
+    }
+
+    public void setSerial(String serial) {
+        this.serial = serial;
+    }
+
+    public String getValidStatus() {
+        return validStatus;
+    }
+
+    public void setValidStatus(String validStatus) {
+        this.validStatus = validStatus;
+    }
+
+    public Long getInstrumentId() {
+        return instrumentId;
+    }
+
+    public void setInstrumentId(Long instrumentId) {
+        this.instrumentId = instrumentId;
+    }
+}
diff --git a/flossom-common/flossom-common-core/src/main/resources/mapper/WxInstrumentSerialMapper.xml b/flossom-common/flossom-common-core/src/main/resources/mapper/WxInstrumentSerialMapper.xml
index 54d9a22..53dddc7 100644
--- a/flossom-common/flossom-common-core/src/main/resources/mapper/WxInstrumentSerialMapper.xml
+++ b/flossom-common/flossom-common-core/src/main/resources/mapper/WxInstrumentSerialMapper.xml
@@ -19,7 +19,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </resultMap>
 
     <sql id="selectWxInstrumentSerialVo">
-        select id, instrument_id, instrument_name, serial, binding_status, valid_status, status, create_by, create_time, remark from wx_instrument_serial
+        select id, source,instrument_id, instrument_name, serial, binding_status, valid_status, status, create_by, create_time, remark from wx_instrument_serial
     </sql>
 
     <select id="selectWxInstrumentSerialList" parameterType="WxInstrumentSerial" resultMap="WxInstrumentSerialResult">
diff --git a/flossom-modules/flossom-system/src/main/java/com/flossom/system/controller/WxInstrumentSerialController.java b/flossom-modules/flossom-system/src/main/java/com/flossom/system/controller/WxInstrumentSerialController.java
index 869759d..1ff8746 100644
--- a/flossom-modules/flossom-system/src/main/java/com/flossom/system/controller/WxInstrumentSerialController.java
+++ b/flossom-modules/flossom-system/src/main/java/com/flossom/system/controller/WxInstrumentSerialController.java
@@ -4,9 +4,11 @@ import java.util.List;
 import java.io.IOException;
 import javax.servlet.http.HttpServletResponse;
 
+import com.flossom.common.core.domain.entity.SysUser;
 import com.flossom.common.core.domain.entity.WxInstrumentSerial;
 import com.flossom.common.core.domain.entity.WxUserInstrument;
 import com.flossom.common.core.domain.req.WxInstrumentSerialExportVm;
+import com.flossom.common.core.domain.req.WxInstrumentSerialImportVm;
 import com.flossom.common.core.domain.req.WxUserInstrumentExportVm;
 import com.flossom.common.core.utils.poi.ExcelUtil;
 import com.flossom.common.core.web.controller.BaseController;
@@ -15,6 +17,7 @@ import com.flossom.common.core.web.page.TableDataInfo;
 import com.flossom.common.log.annotation.Log;
 import com.flossom.common.log.enums.BusinessType;
 import com.flossom.common.security.annotation.RequiresPermissions;
+import com.flossom.common.security.utils.SecurityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -25,6 +28,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 import com.flossom.system.service.IWxInstrumentSerialService;
+import org.springframework.web.multipart.MultipartFile;
 
 /**
  * 仪器序列号关联Controller
@@ -125,7 +129,7 @@ public class WxInstrumentSerialController extends BaseController
      */
     @RequiresPermissions("system:instrumentSerial:remove")
     @Log(title = "仪器序列号关联", businessType = BusinessType.DELETE)
-    @DeleteMapping("/removeAll}")
+    @DeleteMapping("/removeAll")
     public AjaxResult removeAll()
     {
         return toAjax(wxInstrumentSerialService.deleteAll());
@@ -133,7 +137,7 @@ public class WxInstrumentSerialController extends BaseController
 
 
     /**
-     * 批量导出用户列表
+     * 批量导出列表
      */
     @Log(title = "批量导出", businessType = BusinessType.EXPORT)
     @PostMapping("/batchExport")
@@ -142,4 +146,26 @@ public class WxInstrumentSerialController extends BaseController
         ExcelUtil<WxInstrumentSerialExportVm> util = new ExcelUtil<WxInstrumentSerialExportVm>(WxInstrumentSerialExportVm.class);
         util.exportExcel(response, wxInstrumentSerialExportVms, "仪器序列号", wxInstrumentSerial.getExportFields());
     }
+    /**
+     * 仪器导入模板
+     */
+    @PostMapping("/importTemplate")
+    public void importTemplate(HttpServletResponse response) throws IOException
+    {
+        ExcelUtil<WxInstrumentSerialImportVm> util = new ExcelUtil<WxInstrumentSerialImportVm>(WxInstrumentSerialImportVm.class);
+        util.importTemplateExcel(response, "仪器序列号导入模板");
+    }
+
+    @Log(title = "仪器序列号", businessType = BusinessType.IMPORT)
+    @PostMapping("/importData")
+    public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception
+    {
+        ExcelUtil<WxInstrumentSerialImportVm> util = new ExcelUtil<WxInstrumentSerialImportVm>(WxInstrumentSerialImportVm.class);
+        List<WxInstrumentSerialImportVm> WxInstrumentSerialImportList = util.importExcel(file.getInputStream());
+        String message = wxInstrumentSerialService.handleImportData(WxInstrumentSerialImportList);
+//        String operName = SecurityUtils.getUsername();
+//        String message = userService.importUser(userList, updateSupport, operName);
+        return success(message);
+    }
+
 }
diff --git a/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/IWxInstrumentSerialService.java b/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/IWxInstrumentSerialService.java
index d08c841..eb2ca30 100644
--- a/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/IWxInstrumentSerialService.java
+++ b/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/IWxInstrumentSerialService.java
@@ -2,6 +2,7 @@ package com.flossom.system.service;
 
 import com.flossom.common.core.domain.entity.WxInstrumentSerial;
 import com.flossom.common.core.domain.req.WxInstrumentSerialExportVm;
+import com.flossom.common.core.domain.req.WxInstrumentSerialImportVm;
 
 import java.util.List;
 
@@ -83,5 +84,13 @@ public interface IWxInstrumentSerialService
      */
     public List<WxInstrumentSerialExportVm> handleExportData(WxInstrumentSerial wxInstrumentSerial);
 
+    /**
+     * 批量导入仪器序列号列表数据
+     *
+     * @param wxInstrumentSerialImportVmList 导入的list列表
+     * @return 结果
+     */
+    public String handleImportData(List<WxInstrumentSerialImportVm> wxInstrumentSerialImportVmList);
+
 
 }
diff --git a/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/impl/WxInstrumentSerialServiceImpl.java b/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/impl/WxInstrumentSerialServiceImpl.java
index f8aeda9..d9c5757 100644
--- a/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/impl/WxInstrumentSerialServiceImpl.java
+++ b/flossom-modules/flossom-system/src/main/java/com/flossom/system/service/impl/WxInstrumentSerialServiceImpl.java
@@ -1,13 +1,22 @@
 package com.flossom.system.service.impl;
 
 import java.util.List;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
+import com.flossom.common.core.domain.entity.SysUser;
+import com.flossom.common.core.domain.entity.WxInstrument;
 import com.flossom.common.core.domain.entity.WxInstrumentSerial;
 import com.flossom.common.core.domain.req.WxInstrumentSerialExportVm;
+import com.flossom.common.core.domain.req.WxInstrumentSerialImportVm;
+import com.flossom.common.core.exception.ServiceException;
+import com.flossom.common.core.mapper.WxInstrumentMapper;
 import com.flossom.common.core.mapper.WxInstrumentSerialMapper;
 import com.flossom.common.core.utils.DateUtils;
+import com.flossom.common.core.utils.StringUtils;
 import org.apache.commons.compress.utils.Lists;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -23,8 +32,12 @@ import org.springframework.util.CollectionUtils;
 @Service
 public class WxInstrumentSerialServiceImpl implements IWxInstrumentSerialService
 {
+    private static final Logger log = LoggerFactory.getLogger(WxInstrumentSerialServiceImpl.class);
+
     @Autowired
     private WxInstrumentSerialMapper wxInstrumentSerialMapper;
+    @Autowired
+    private WxInstrumentMapper wxInstrumentMapper;
 
     /**
      * 查询仪器序列号关联
@@ -65,6 +78,18 @@ public class WxInstrumentSerialServiceImpl implements IWxInstrumentSerialService
     public int insertWxInstrumentSerial(WxInstrumentSerial wxInstrumentSerial)
     {
         wxInstrumentSerial.setCreateTime(DateUtils.getNowDate());
+        if (Objects.nonNull(wxInstrumentSerial.getInstrumentId())) {
+            WxInstrument wxInstrument = wxInstrumentMapper.selectWxInstrumentById(wxInstrumentSerial.getInstrumentId());
+            if (Objects.nonNull(wxInstrument)) {
+                wxInstrumentSerial.setInstrumentName(wxInstrument.getName());
+            }
+        }
+        WxInstrumentSerial instrumentSerial = new WxInstrumentSerial();
+        instrumentSerial.setSerial(wxInstrumentSerial.getSerial());
+        List<WxInstrumentSerial> wxInstrumentSerials = wxInstrumentSerialMapper.selectWxInstrumentSerialList(instrumentSerial);
+        if (!CollectionUtils.isEmpty(wxInstrumentSerials)) {
+            throw new ServiceException("序列号已经存在，请确定后再新增！");
+        }
         return wxInstrumentSerialMapper.insertWxInstrumentSerial(wxInstrumentSerial);
     }
 
@@ -152,4 +177,77 @@ public class WxInstrumentSerialServiceImpl implements IWxInstrumentSerialService
         }
         return resultList;
     }
+
+    @Override
+    public String handleImportData(List<WxInstrumentSerialImportVm> wxInstrumentSerialImportVmList) {
+        if (StringUtils.isNull(wxInstrumentSerialImportVmList) || wxInstrumentSerialImportVmList.size() == 0)
+        {
+            throw new ServiceException("导入的仪器序列号数据不能为空！");
+        }
+        // 初始化计数器
+        int successNum = 0;
+        int failureNum = 0;
+        StringBuilder successMsg = new StringBuilder();
+        StringBuilder failureMsg = new StringBuilder();
+
+        for (WxInstrumentSerialImportVm instrumentSerialImport : wxInstrumentSerialImportVmList) {
+            try {
+                // 先判断仪器ID是否存在
+                if (Objects.isNull(instrumentSerialImport.getInstrumentId()) || Objects.isNull(instrumentSerialImport.getSerial())){
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、仪器ID/序列号不能为空");
+                } else {
+                    WxInstrument wxInstrument = wxInstrumentMapper.selectWxInstrumentById(instrumentSerialImport.getInstrumentId());
+                    if (Objects.isNull(wxInstrument)) {
+                        failureNum++;
+                        failureMsg.append("<br/>" + failureNum + "、仪器不存在,请先维护后再导入");
+                    }
+                    WxInstrumentSerial instrumentSerial = new WxInstrumentSerial();
+                    instrumentSerial.setSerial(instrumentSerialImport.getSerial());
+                    List<WxInstrumentSerial> wxInstrumentSerialList = wxInstrumentSerialMapper.selectWxInstrumentSerialList(instrumentSerial);
+                    if (CollectionUtils.isEmpty(wxInstrumentSerialList)) {
+                        if(Objects.nonNull(wxInstrument)) {
+                            // 开始插入数据
+                            WxInstrumentSerial insertRecord = new WxInstrumentSerial();
+                            insertRecord.setCreateTime(DateUtils.getNowDate());
+                            insertRecord.setInstrumentName(wxInstrument.getName());
+                            insertRecord.setSerial(instrumentSerialImport.getSerial());
+                            insertRecord.setSource(instrumentSerialImport.getSource());
+                            insertRecord.setInstrumentId(wxInstrument.getId());
+                            if (StringUtils.isEmpty(instrumentSerialImport.getValidStatus())) {
+                                instrumentSerialImport.setValidStatus("有效") ;
+                            }
+                            insertRecord.setValidStatus(instrumentSerialImport.getValidStatus().trim().equals("有效")?1:0);
+                            wxInstrumentSerialMapper.insertWxInstrumentSerial(insertRecord);
+                            successNum++;
+                            successMsg.append("<br/>" + successNum + "、序列号 " + insertRecord.getSerial() + " 导入成功");
+                        }
+                    } else {
+                        failureNum++;
+                        failureMsg.append("<br/>" + failureNum + "、序列号已经存在");
+                    }
+                }
+
+            } catch (Exception e) {
+                failureNum++;
+                String msg = "<br/>" + failureNum + "、仪器ID " + instrumentSerialImport.getInstrumentId() + " 导入失败：";
+                failureMsg.append(msg + e.getMessage());
+                log.error(msg, e);
+            }
+        }
+        if (failureNum > 0)
+        {
+            failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确");
+            throw new ServiceException(failureMsg.toString());
+        }
+        else
+        {
+            successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条：");
+        }
+        if (StringUtils.isNotEmpty(successMsg.toString()) && !"null".equals(successMsg.toString())) {
+            return successMsg.toString();
+        } else {
+            return failureMsg.toString();
+        }
+    }
 }
diff --git a/flossom-ui/src/views/system/instrumentSerial/index.vue b/flossom-ui/src/views/system/instrumentSerial/index.vue
index 1d98375..9d00595 100644
--- a/flossom-ui/src/views/system/instrumentSerial/index.vue
+++ b/flossom-ui/src/views/system/instrumentSerial/index.vue
@@ -150,7 +150,7 @@
           <span v-show="scope.row.validStatus == 1">有效</span>
         </template>
       </el-table-column>
-      <el-table-column label="来源" align="center" prop="remark" />
+      <el-table-column label="来源" align="center" prop="source" />
       <el-table-column label="创建时间" align="center" prop="createTime" width="100">
         <template slot-scope="scope">
           <span>{{ parseTime(scope.row.createTime, '{y}-{m}-{d} {h}:{m}:{s}') }}</span>
@@ -197,7 +197,7 @@
 <!--        <el-form-item label="仪器id" prop="instrumentId">-->
 <!--          <el-input v-model="form.instrumentId" placeholder="请输入仪器id" />-->
 <!--        </el-form-item>-->
-        <el-form-item label="仪器型号" prop="instrumentName">
+        <el-form-item label="仪器型号" prop="instrumentId">
           <el-select :disabled="isDisabled(form)"
             v-model="form.instrumentId"
             placeholder="请选择型号"
@@ -224,6 +224,42 @@
         <el-button @click="cancel">取 消</el-button>
       </div>
     </el-dialog>
+    <!-- 导入对话框 -->
+    <el-dialog :title="title" :visible.sync="importVisible" width="500px" append-to-body>
+      <el-form ref="form" :model="form" label-width="80px">
+        <el-form-item label="模板下载" prop="serial" >
+          <el-button
+            type="primary"
+            plain
+            @click="importTemplate"
+          >点击下载
+          </el-button>
+        </el-form-item>
+        <el-form-item label="模板上传" prop="serial" >
+          <el-upload
+            ref="upload"
+            :limit="1"
+            accept=".xls, .xlsx"
+            :headers="upload.headers"
+            :action="upload.url+ '?updateSupport=' + upload.updateSupport"
+            :disabled="upload.isUploading"
+            :on-progress="handleFileUploadProgress"
+            :on-success="handleFileSuccess"
+            :auto-upload="false"
+            drag
+          >
+            <i class="el-icon-upload"></i>
+            <div class="el-upload__text">将文件拖到此处，或<em>点击上传</em></div>
+            <div class="el-upload__tip" slot="tip">只能上传.xls,.xlsx 文件</div>
+          </el-upload>
+        </el-form-item>
+      </el-form>
+      <div slot="footer" class="dialog-footer">
+        <el-button type="primary" @click="submitFileForm">导 入</el-button>
+        <el-button @click="importCancel">取 消</el-button>
+      </div>
+    </el-dialog>
+
     <!-- 详情记录对话框 -->
     <el-dialog :title="detailTitle" :visible.sync="detailOpen" width="880px" append-to-body>
       <el-table v-loading="loading" :data="userInstrumentLogList">
@@ -256,7 +292,7 @@
       />
     </el-dialog>
 
-<!-- 二维码-->
+    <!-- 二维码-->
     <el-dialog :title="codeTitle" :visible.sync="codeOpen" width="780px" append-to-body>
         <div class="demo-image__lazy">
           <el-image :key="codeUrl" :src="codeUrl" :preview-src-list="[codeUrl]" lazy></el-image>
@@ -312,6 +348,7 @@
 <script>
 import { listSerial, getSerial, delSerial, addSerial, updateSerial,delSerialAll,updateStatus } from "@/api/system/instrumentSerial";
 import {listInstrument} from "@/api/system/instrument";
+import {getToken} from "@/utils/auth";
 import {listLog} from "@/api/system/userInstrumentLog"
 
 export default {
@@ -333,6 +370,8 @@ export default {
       instrumentList: [],
       // 有效无效展示框
       validStatusVisible: false,
+      // 导入展示框
+      importVisible: false,
       // 遮罩层
       loading: true,
       // 选中数组
@@ -391,12 +430,27 @@ export default {
         status: null,
         instrumentIdArray: null,
       },
+      // 导入参数
+      upload: {
+        // 是否显示弹出层（用户导入）
+        open: false,
+        // 弹出层标题（用户导入）
+        title: "",
+        // 是否禁用上传
+        isUploading: false,
+        // 是否更新已经存在的用户数据
+        updateSupport: 0,
+        // 设置上传的请求头部
+        headers: { Authorization: "Bearer " + getToken() },
+        // 上传的地址
+        url: process.env.VUE_APP_BASE_API + "/system/instrumentSerial/importData"
+      },
       // 表单参数
       form: {},
       // 表单校验
       rules: {
         instrumentId: [
-          { required: true, message: "仪器id不能为空", trigger: "blur" }
+          { required: true, message: "仪器名称不能为空", trigger: "blur" }
         ],
         instrumentName: [
           { required: true, message: "仪器名称不能为空", trigger: "blur" }
@@ -443,6 +497,11 @@ export default {
       this.open = false;
       this.reset();
     },
+    importCancel(){
+      this.importVisible = false;
+      this.upload.isUploading = false;
+      this.$refs.upload.clearFiles();
+    },
     // 表单重置
     reset() {
       this.form = {
@@ -557,11 +616,15 @@ export default {
       if (this.batchOperateValue == 2) {
         this.exportFieldsVisible = true;
       }
+      if (this.batchOperateValue == 3) {
+        this.importVisible = true;
+      }
       if (this.batchOperateValue == 4) {
         if (this.ids.length == 0) {
           this.$message.error("请选择数据");
           return
         }
+        const ids =  this.ids;
         this.$modal.confirm('确定将选择的数据删除？【请谨慎操作，一旦成功将无法撤销】').then(function() {
           return delSerial(ids);
         }).then(() => {
@@ -665,9 +728,31 @@ export default {
         this.exportFieldList.createTime = null;
       }
     },
+    // 关闭弹窗
     cancelUpdateStatusDialog (){
       this.validStatusVisible = false;
     },
+    // 文件上传中处理
+    handleFileUploadProgress(event, file, fileList) {
+      this.upload.isUploading = true;
+    },
+    // 文件上传成功处理
+    handleFileSuccess(response, file, fileList, item) {
+      this.importVisible = false;
+      this.upload.isUploading = false;
+      this.$refs.upload.clearFiles();
+      this.$alert("<div style='overflow: auto;overflow-x: hidden;max-height: 70vh;padding: 10px 20px 0;'>" + response.msg + "</div>", "导入结果", { dangerouslyUseHTMLString: true });
+      this.getList();
+    },
+    /** 下载模板操作 */
+    importTemplate() {
+      this.download('system/instrumentSerial/importTemplate', {
+      }, `仪器序列号模板_${new Date().getTime()}.xlsx`)
+    },
+    // 提交上传文件
+    submitFileForm() {
+      this.$refs.upload.submit();
+    }
   }
 };
 </script>