elment UI + EasyExcel 實現 導入

来源:https://www.cnblogs.com/lilulin/archive/2023/06/02/17452549.html
-Advertisement-
Play Games

前端組件 <hd-flex> <el-dialog v-model="isUploadDialog" width="50%" lock-scroll=false> <el-upload class="upload-demo" drag :action="url" :on-success="succe ...


前端組件
<hd-flex>
                <el-dialog v-model="isUploadDialog" width="50%" lock-scroll=false>
                    <el-upload
                            class="upload-demo"
                            drag
                            :action="url"
                            :on-success="success"
                            :on-error="error"
                            :headers="uploadHeaders"
                            :limit="1"
                            :on-exceed="handleExceed"
                            :file-list="fileList"
                            accept=".xlsx,.xls">
                        <i class="el-icon-upload"></i>
                        <div class="el-upload__text"><em>點擊上傳</em></div>
                        <div class="el-upload__tip" slot="tip">只能上傳xlsx/xls文件,且不超過500kb</div>
                    </el-upload>
                </el-dialog>
            </hd-flex>

//變數
url: `${conf.BASE_URL}/core/ssqd/importS`,
isUploadDialog: false,
fileList: [],


// 方法
//導入
async importS() {
this.fileList=[];
this.isUploadDialog=true;
},
success(response, file, fileList){
if(response.code=='500'){
this.$hd.message.error(response.errorBody.errorMessage);
}
if(response.code=='200'){
this.$hd.message.ok('導入成功!');
this.isUploadDialog=false;
this.$refs.table.onSearch();
}


},
error(err, file, fileList){
this.$hd.message.error(err);

},
handleRemove(file, fileList) {
console.log(file, fileList)
},
handlePreview(file) {
console.log(file)
},
handleExceed(files, fileList) {
this.$message.warning(
`當前限制選擇 1 個文件,本次選擇了 ${files.length} 個文件,共選擇了 ${
files.length + fileList.length
} 個文件`
)
},
beforeRemove(file, fileList) {
return this.$confirm(`確定移除 ${file.name}?`)
},

Java  

Controller 
	@ApiOperation("上傳")
	@ApiImplicitParams({
			@ApiImplicitParam(name = "file",value = "文件",dataTypeClass = MultipartFile.class,required = true,paramType = "")
	})
	@PostMapping ("/importS")
	public RestResponse<String> uploadExcel(MultipartFile file)throws IOException {
		String HZ = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
		if(".xlsx.xls".indexOf(HZ) < 0){
			throw new BaseException("500","導入的文件類型不正確,只能導入Excel文件");
		}
		EasyExcel.read(file.getInputStream(), SsqdVO.class,new UploadListenerBySsqd(iSsqdService)).sheet() .doRead();;
		return new RestResponse<> ("ok");
	} 

javaBean

package com.hopedove.coreserver.vo.sygl;

import com.alibaba.excel.annotation.ExcelProperty;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;

import com.hopedove.commons.vo.BaseModel;
import lombok.Data;

/**
 * 璇曠罕娓呭崟
 * @TableName T_JS_SYGL_SSQD
 */
@TableName(value ="T_JS_SYGL_SSQD")
@Data
public class SsqdVO  extends BaseModel implements Serializable {
    /**
     * 璇曠罕娓呭崟ID
     */
    @TableId
    private String SSQDID;
    /**
     * 坯布類型
     */
    @ExcelProperty(value ="試紗類型", index = 0)
    private String PBLX;

    /**
     * 布號
     */
    @ExcelProperty(value ="布號", index = 1)
    private String BH;

    /**
     * 支數
     */
    @ExcelProperty(value ="支數", index = 2)
    private String ZS;

    /**
     * 產地
     */
    @ExcelProperty(value ="產地", index = 3)
    private String CD;

    /**
     * 批號
     */
    @ExcelProperty(value ="批號", index = 4)
    private String PH;


    /**
     * 重量
     */
    @ExcelProperty(value ="重量", index = 5)
    private BigDecimal ZL;

    /**
     * 備註
     */
    @ExcelProperty(value ="備註", index = 6)
    private String REMARK;




    @TableField(exist = false)
    private String GY;


}

  監聽器: 判斷上傳表格是否符合要求

package com.hopedove.coreserver.service.impl.sygl;

import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
import com.alibaba.nacos.common.utils.CollectionUtils;
import com.hedu.sweet.starter.utils.exception.BusinException;
import com.hopedove.coreserver.service.sygl.ISsqdService;
import com.hopedove.coreserver.vo.sygl.SsqdVO;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

public class UploadListenerBySsqd extends AnalysisEventListener<SsqdVO>  {


    private ISsqdService iSsqdService;

    public UploadListenerBySsqd(ISsqdService iSsqdService) {
        this.iSsqdService = iSsqdService;
    }


    private List<SsqdVO> list = new ArrayList<>(100);


    @Override
    public void invoke(SsqdVO ssqdVO, AnalysisContext analysisContext) {
        //業務判斷
        System.out.println("***"+ssqdVO+"***");
        list.add(ssqdVO);
//        if (list.size() > 100) {
//            wjgbpclService.saveData(list);//保存到資料庫
//            list = ListUtils.newArrayListWithExpectedSize(100);
//        }
    }


    @Override
    public void doAfterAllAnalysed(AnalysisContext analysisContext) {
        if (CollectionUtils.isNotEmpty(list)) {
            System.out.println("***結束***");
            System.out.println(list);
            iSsqdService.saveData(list);
        }else{
            throw new BusinException("500","導入的文件為空,請填寫信息後重新導入。");
        }
    }
    /**
     * 在這裡進行模板的判斷
     * @param headMap 存放著導入表格的表頭,鍵是索引,值是名稱
     * @param context
     */
    @Override
    public void invokeHeadMap(Map<Integer, String> headMap, AnalysisContext context) {
        String isNull = "";
        if (context.readRowHolder().getRowIndex() == 0) {
            String[] headList = {"試紗類型","布號","支數","產地","批號","重量","備註"};
            for (int i = 0; i < headList.length; i++) {
                try {
                    if (!headMap.get(i).equals(headList[i])) {
                        isNull = "導入模板不正確,請重新導入";
                        break;
                    }
                } catch (Exception e) {
                    isNull = "導入模板不正確,請重新導入";
                    break;
                }
            }
        }
        if(isNull!=""){
            throw new BusinException("500",isNull);
        }

    }

}

  實現類

	@Override
	public void saveData(List<SsqdVO> list) {
		//出現空的數據行,只有邊框沒有值-處理
		list = tableNullLineRemove(list);
		String msg = "";
		if(list.size() > 0){

			if (StringUtil.isEmpty(msg)) {
				// 驗證輸入數據重覆性
				msg = checkMxList(list);
			}

			if (StringUtil.isEmpty(msg)) {
				// excel數據插入資料庫
				List<SsqdVO> arr = new ArrayList<>(100);
				for (int i = 0; i < list.size(); i++) {
					SsqdVO bean= list.get(i);
					bean = nullToString(bean);
					arr.add(bean);
				}
				if (CollectionUtils.isNotEmpty(list)) {
					if(!importAdd(list)){//導入
						throw new BusinException("500","導入的文件有效記錄數超過1000條,請分批次多次導入");
					}
				}
			}
		}
		if(!StringUtil.isEmpty(msg)){
			throw new BusinException("500",msg);
		}
	}

	/**
	 * 驗證輸入數據重覆性
	 * @param list
	 * @return
	 */
	private String checkMxList(List<SsqdVO> list) {
		List<String> errMsgList = new ArrayList<String>();
		String msg = "";
		if (list.size() > 0) {
			// 把頁面的數據進行重覆性檢驗
			for (int i = 0; i < list.size(); i++) {
				SsqdVO mxModel = list.get(i);
				String PBLX = StringUtil.nullToSring(mxModel.getPBLX());
				String BH = StringUtil.nullToSring(mxModel.getBH());
				String ZS = StringUtil.nullToSring(mxModel.getZS());
				String ZL = StringUtil.nullToSring(mxModel.getZL());
				//當紗織類型,布號,支數和重量都為空,那麼這條記錄既不交驗,也不添加
				if(StringUtil.isEmpty(PBLX) && StringUtil.isEmpty(BH) && StringUtil.isEmpty(ZS) && StringUtil.isEmpty(ZL)){
					continue;
				}
				for (int j = 1; j < list.size(); j++) {

					if (i != j) {
						SsqdVO mxModelSec =  list.get(j);
						String PBLXsec = mxModelSec.getPBLX();
						String BHsec = StringUtil.nullToSring(mxModelSec.getBH());
						String ZSsec = StringUtil.nullToSring(mxModelSec.getZS());
						String ZLsec = StringUtil.nullToSring(mxModelSec.getZL());
						//當紗織類型,布號,支數和重量都為空,那麼這條記錄既不交驗,也不添加
						if(StringUtil.isEmpty(PBLXsec) && StringUtil.isEmpty(BHsec) && StringUtil.isEmpty(ZSsec) && StringUtil.isEmpty(ZLsec)){
							continue;
						}
						if(PBLX.equals(PBLXsec) && "2".equals(PBLX)){
							if ((StringUtil.nullToSring(mxModelSec.getBH()))
									.equals(StringUtil.nullToSring(mxModel.getBH()))
									&& (StringUtil.nullToSring(mxModelSec.getZS()))
									.equals(StringUtil.nullToSring(mxModel.getZS()))
									&& (StringUtil.nullToSring(mxModelSec.getZL()))
									.equals(StringUtil.nullToSring(mxModel.getZL()))
									&& (StringUtil.nullToSring(mxModelSec.getSC()))
									.equals(StringUtil.nullToSring(mxModel.getSC()))
									&& (StringUtil.nullToSring(mxModelSec.getSH()))
									.equals(StringUtil.nullToSring(mxModel.getSH()))
									&& (StringUtil.nullToSring(mxModelSec.getGY()))
									.equals(StringUtil.nullToSring(mxModel.getGY()))) {
								msg="導入文檔第" + (i+1) + "行數據記錄與第" + (j+1)
										+ "行數據記錄重覆</br>";
								/*errMsgList.add("導入文檔第" + (i+1) + "行數據記錄與第" + j
										+ "行數據記錄重覆</br>");*/
							}
						} else {
							if ((StringUtil.nullToSring(mxModelSec.getBH()))
									.equals(StringUtil.nullToSring(mxModel.getBH()))
									&& (StringUtil.nullToSring(mxModelSec.getZS()))
									.equals(StringUtil.nullToSring(mxModel.getZS()))
									&& (StringUtil.nullToSring(mxModelSec.getZL()))
									.equals(StringUtil.nullToSring(mxModel.getZL()))) {
								msg="導入文檔第" + (i+1) + "行數據記錄與第" + (j+1)
										+ "行數據記錄重覆</br>";
								/*errMsgList.add("導入文檔第" + (i+1) + "行數據記錄與第" + j
										+ "行數據記錄重覆</br>")*/;
							}
						}
					}
				}
			}
		}

		return msg;
	}

	private Boolean importAdd(List<SsqdVO> list) {
		UserDTO userBean = UserUtil.getUserInfo();
		int index = 0 ;
		List <Map <String, String>> addList = new ArrayList <Map <String, String>>();
		for (int i = 0; i < list.size(); i++) {
			SsqdVO entry = list.get(i);
		//保存的處理邏輯
		
		}
		iSsqdDao.insertSSQD(addList);
		iSsqdDao.insertSSRZGY(addList);
		return true;
	}
	private SsqdVO nullToString(SsqdVO params) {
		Map<String,Object> map = new HashMap<>();
		Field[] fields = params.getClass().getDeclaredFields();
		try {
			for (Field field : fields
			) {
				//設置允許通過反射訪問私有變數
				field.setAccessible(true);
				map.put(field.getName(),field.get(params)==null? "":field.get(params));
			}

		}catch (Exception e){
			e.printStackTrace();
		}
		return MapUntil.mapToBean(map,new SsqdVO());
	}
	private List<SsqdVO> tableNullLineRemove(List<SsqdVO> list) {
		List<SsqdVO> l = new ArrayList<>();
		//當紗織類型,布號,支數和重量都為空,那麼這條記錄既不交驗,也不添加
		for (SsqdVO model:list
		) {
			if(model.getPBLX()==null && model.getBH() ==null&&model.getZS()==null &&model.getZL()==null){
				continue;
			}else{
				l.add(model);
			}
		}
		return l;
	}

  SQL  oracle資料庫批量新增

    <insert id="insertSSQD" parameterType="list">
        insert all
        <foreach collection="list" item="item">
        <![CDATA[
        into T_JS_SYGL_SSQD
        (
        SSQDID,
        RSQDBH,
        BH,
        PBLX,
        PBMC,
        ZS,
        CREATER,
        CRENAME,
        UPDATER,
        BMXXID,
        BMMC,
        JGXXID,
        JGMC,
        ZTXXID,
        ZTMC
        ]]>
        <if test=" item.ZL != null and item.ZL != '' ">,ZL </if>
        <if test=" item.SH != null and item.SH != '' ">,SH </if>
        <if test=" item.ZFMYQ != null and item.ZFMYQ != '' ">,ZFMYQ </if>
        <if test=" item.XSYQ != null and item.XSYQ != '' ">,XSYQ </if>
        <if test=" item.SG != null and item.SG != '' ">,SG </if>
        <if test=" item.REMARK != null and item.REMARK != '' ">,REMARK </if>
        <if test=" item.CD != null and item.CD != '' ">,CD </if>
        <if test=" item.PH != null and item.PH != '' ">,PH </if>
        <if test=" item.SC != null and item.SC != '' ">,SC </if>
        ) VALUES(
        <![CDATA[
        #{item.SSQDID},
        #{item.RSQDBH},
        #{item.BH},
        #{item.PBLX},
        #{item.PBMC},
        #{item.ZS},
        #{item.CREATER},
        #{item.CRENAME},
        #{item.UPDATER},
        #{item.BMXXID},
        #{item.BMMC},
        #{item.JGXXID},
        #{item.JGMC},
        #{item.ZTXXID},
        #{item.ZTMC}
        ]]>
        <if test=" item.ZL != null and item.ZL != '' ">,#{item.ZL} </if>
        <if test=" item.SH != null and item.SH != '' ">,#{item.SH} </if>
        <if test=" item.ZFMYQ != null and item.ZFMYQ != '' ">,#{item.ZFMYQ} </if>
        <if test=" item.XSYQ != null and item.XSYQ != '' ">,#{item.XSYQ} </if>
        <if test=" item.SG != null and item.SG != '' ">,#{item.SG} </if>
        <if test=" item.REMARK != null and item.REMARK != '' ">,#{item.REMARK} </if>
        <if test=" item.CD != null and item.CD != '' ">,#{item.CD} </if>
        <if test=" item.PH != null and item.PH != '' ">,#{item.PH} </if>
        <if test=" item.SC != null and item.SC != '' ">,#{item.SC} </if>
        )

        </foreach>
        select * from dual
    </insert>

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • ## 概述 Java 對客戶程式的通信過程進行了抽象,提供了通用的協議處理框架,該框架封裝了 Socket,主要包括以下類: - URL 類:統一資源定位符,表示客戶程式要訪問的遠程資源 - URLConnection 類:表示客戶程式與遠程伺服器的連接,客戶程式可以從 URLConnection ...
  • 基於java的美食菜譜分享系統設計與實現,餐飲分享平臺設計與實現,可用於美食線上分享平臺,作為世界各地愛好美食的人們的橋梁,為其創造一個氛圍好的平臺,促進美食世界的文化交流。該系統是一個供商家或者個人推薦美食的網站,網站不支持交易僅供分享。 ...
  • > 本文首發於公眾號:Hunter後端 > 原文鏈接:[celery筆記二之建立celery項目、配置及幾種載入方式](https://mp.weixin.qq.com/s/KZjuypZ-e9EHi7XkKXt0Xg) 接下來我們創建一個 celery 項目,文件夾及目錄如下: ```python ...
  • **原文鏈接:** [為什麼說 Go 語言字元串是不可變的?](https://mp.weixin.qq.com/s/AOb6AjKwyTwLeAUou0AU-Q) 最近有讀者留言說,平時在寫代碼的過程中,是會對字元串進行修改的,但網上都說 Go 語言字元串是不可變的,這是為什麼呢? 這個問題本身並 ...
  • aliases: [] tags : " " summary: [基於TCP/IP和UDP協議的Java Socket網路通信編程] author : [yaenli] notekey: [20230512-143738] # Socket 網路模型 Socket編程是在TCP/IP、UDP協議上的 ...
  • # Rust Web 全棧開發之增加教師管理功能 ## 增加教師管理功能 ### 目標 #### Actix HTTP Server #### Actix App - Routes - GET /teachers - GET / teachers /{teacher_id} - POST /teac ...
  • ## 教程簡介 Google Charts 是一個純粹的基於JavaScript的圖表庫,旨在通過添加互動式圖表功能來增強Web應用程式.它支持各種圖表.在Chrome,Firefox,Safari,Internet Explorer(IE)等標準瀏覽器中使用SVG繪製圖表.在傳統的IE 6中,VM ...
  • ## 教程簡介 Excel是辦公室自動化中非常重要的一款軟體,Excel函數則是Excel中的內置函數。Excel函數共包含11類,分別是資料庫函數、日期與時間函數、工程函數、財務函數、信息函數、邏輯函數、查詢和引用函數、數學和三角函數、統計函數、文本函數以及用戶自定義函數。 熟練且高效的使用Exc ...
一周排行
    -Advertisement-
    Play Games
  • PasteSpider是什麼? 一款使用.net編寫的開源的Linux容器部署助手,支持一鍵發佈,平滑升級,自動伸縮, Key-Value配置,項目網關,環境隔離,運行報表,差量升級,私有倉庫,集群部署,版本管理等! 30分鐘上手,讓開發也可以很容易的學會在linux上部署你得項目! [從需求角度介 ...
  • SQLSugar是什麼 **1. 輕量級ORM框架,專為.NET CORE開發人員設計,它提供了簡單、高效的方式來處理資料庫操作,使開發人員能夠更輕鬆地與資料庫進行交互 2. 簡化資料庫操作和數據訪問,允許開發人員在C#代碼中直接操作資料庫,而不需要編寫複雜的SQL語句 3. 支持多種資料庫,包括但 ...
  • 在C#中,經常會有一些耗時較長的CPU密集型運算,因為如果直接在UI線程執行這樣的運算就會出現UI不響應的問題。解決這類問題的主要途徑是使用多線程,啟動一個後臺線程,把運算操作放在這個後臺線程中完成。但是原生介面的線程操作有一些難度,如果要更進一步的去完成線程間的通訊就會難上加難。 因此,.NET類 ...
  • 一:背景 1. 講故事 前些天有位朋友在微信上丟了一個崩潰的dump給我,讓我幫忙看下為什麼出現了崩潰,在 Windows 的事件查看器上顯示的是經典的 訪問違例 ,即 c0000005 錯誤碼,不管怎麼說有dump就可以上windbg開幹了。 二:WinDbg 分析 1. 程式為誰崩潰了 在 Wi ...
  • CSharpe中的IO+NPOI+序列化 文件文件夾操作 學習一下常見的文件、文件夾的操作。 什麼是IO流? I:就是input O:就是output,故稱:輸入輸出流 將數據讀入記憶體或者記憶體輸出的過程。 常見的IO流操作,一般說的是[記憶體]與[磁碟]之間的輸入輸出。 作用 持久化數據,保證數據不再 ...
  • C#.NET與JAVA互通之MD5哈希V2024 配套視頻: 要點: 1.計算MD5時,SDK自帶的計算哈希(ComputeHash)方法,輸入輸出參數都是byte數組。就涉及到字元串轉byte數組轉換時,編碼選擇的問題。 2.輸入參數,字元串轉byte數組時,編碼雙方要統一,一般為:UTF-8。 ...
  • CodeWF.EventBus,一款靈活的事件匯流排庫,實現模塊間解耦通信。支持多種.NET項目類型,如WPF、WinForms、ASP.NET Core等。採用簡潔設計,輕鬆實現事件的發佈與訂閱。通過有序的消息處理,確保事件得到妥善處理。簡化您的代碼,提升系統可維護性。 ...
  • 一、基本的.NET框架概念 .NET框架是一個由微軟開發的軟體開發平臺,它提供了一個運行時環境(CLR - Common Language Runtime)和一套豐富的類庫(FCL - Framework Class Library)。CLR負責管理代碼的執行,而FCL則提供了大量預先編寫好的代碼, ...
  • 本章將和大家分享在ASP.NET Core中如何使用高級客戶端NEST來操作我們的Elasticsearch。 NEST是一個高級別的Elasticsearch .NET客戶端,它仍然非常接近原始Elasticsearch API的映射。所有的請求和響應都是通過類型來暴露的,這使得它非常適合快速上手 ...
  • 參考delphi的代碼更改為C# Delphi 檢測密碼強度 規則(仿 google) 仿 google 評分規則 一、密碼長度: 5 分: 小於等於 4 個字元 10 分: 5 到 7 字元 25 分: 大於等於 8 個字元 二、字母: 0 分: 沒有字母 10 分: 全都是小(大)寫字母 20 ...