package cn.cslg.pas.service.importPatent; import cn.cslg.pas.common.model.cronModel.SystemFile; import cn.cslg.pas.common.utils.ReadExcelUtils; import cn.cslg.pas.common.vo.ImportTaskAMVO; import cn.cslg.pas.common.vo.PatentData; import cn.cslg.pas.common.vo.UploadParamsVO; import cn.cslg.pas.common.vo.UploadSettingVO; import cn.cslg.pas.domain.es.Patent; import cn.cslg.pas.domain.es.Text; import cn.cslg.pas.service.common.ExcuteDataToVOService; import cn.cslg.pas.service.common.ExcuteUploadSettingService; import cn.cslg.pas.service.common.FileManagerService; import cn.hutool.core.util.IdUtil; import com.alibaba.fastjson.JSONArray; import org.apache.commons.compress.utils.IOUtils; import org.apache.poi.ss.usermodel.PictureData; import org.apache.poi.ss.usermodel.Sheet; import org.springframework.beans.factory.annotation.Configurable; import org.springframework.context.ApplicationContext; import org.springframework.mock.web.MockMultipartFile; import org.springframework.web.multipart.MultipartFile; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.util.ArrayList; import java.util.Arrays; import java.util.List; @Configurable public class GetPatentPictureFromExcelThread extends Thread { private ImportTaskAMVO importTaskAMVO; private ApplicationContext applicationContext; private SavePatentToEsThread savePatentToEsThread; private Boolean ifProductAll = false; private List uploadParamsVOS; @Override public void run() { try { while (!ifProductAll || uploadParamsVOS.size() > 0 || importTaskAMVO.getProgressVO().equals(1)) { UploadParamsVO uploadParamsVO = uploadParamsVOS.remove(0); PictureData pictureData =uploadParamsVO.getPictureData(); String ext = pictureData.suggestFileExtension(); byte[] data = pictureData.getData(); MultipartFile multipartFile = new MockMultipartFile("file", "filename.txt", "text/plain", data); String picName = IdUtil.simpleUUID() + "." + ext; } } catch (Exception e) { e.printStackTrace(); } } public GetPatentPictureFromExcelThread(ImportTaskAMVO importTaskAMVO, ApplicationContext applicationContext) { this.importTaskAMVO = importTaskAMVO; this.savePatentToEsThread = savePatentToEsThread; this.applicationContext = applicationContext; } public void awakeTask(Patent patent) { // patents.add(patent); // if (taskLock.tryLock()) { // taskCondition.signalAll(); // taskLock.unlock(); // } } // public void setIfProductAll(Boolean ifProductAll) { this.ifProductAll = ifProductAll; } }