GetPatentPictureFromExcelThread.java 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  1. package cn.cslg.pas.service.importPatent;
  2. import cn.cslg.pas.common.model.cronModel.SystemFile;
  3. import cn.cslg.pas.common.utils.ReadExcelUtils;
  4. import cn.cslg.pas.common.vo.ImportTaskAMVO;
  5. import cn.cslg.pas.common.vo.PatentData;
  6. import cn.cslg.pas.common.vo.UploadParamsVO;
  7. import cn.cslg.pas.common.vo.UploadSettingVO;
  8. import cn.cslg.pas.domain.es.Patent;
  9. import cn.cslg.pas.domain.es.Text;
  10. import cn.cslg.pas.service.common.ExcuteDataToVOService;
  11. import cn.cslg.pas.service.common.ExcuteUploadSettingService;
  12. import cn.cslg.pas.service.common.FileManagerService;
  13. import cn.hutool.core.util.IdUtil;
  14. import com.alibaba.fastjson.JSONArray;
  15. import org.apache.commons.compress.utils.IOUtils;
  16. import org.apache.poi.ss.usermodel.PictureData;
  17. import org.apache.poi.ss.usermodel.Sheet;
  18. import org.springframework.beans.factory.annotation.Configurable;
  19. import org.springframework.context.ApplicationContext;
  20. import org.springframework.mock.web.MockMultipartFile;
  21. import org.springframework.web.multipart.MultipartFile;
  22. import java.io.ByteArrayInputStream;
  23. import java.io.File;
  24. import java.io.FileOutputStream;
  25. import java.io.InputStream;
  26. import java.util.ArrayList;
  27. import java.util.Arrays;
  28. import java.util.List;
  29. @Configurable
  30. public class GetPatentPictureFromExcelThread extends Thread {
  31. private ImportTaskAMVO importTaskAMVO;
  32. private ApplicationContext applicationContext;
  33. private SavePatentToEsThread savePatentToEsThread;
  34. private Boolean ifProductAll = false;
  35. private List<UploadParamsVO> uploadParamsVOS;
  36. @Override
  37. public void run() {
  38. try {
  39. while (!ifProductAll || uploadParamsVOS.size() > 0 || importTaskAMVO.getProgressVO().equals(1)) {
  40. UploadParamsVO uploadParamsVO = uploadParamsVOS.remove(0);
  41. PictureData pictureData =uploadParamsVO.getPictureData();
  42. String ext = pictureData.suggestFileExtension();
  43. byte[] data = pictureData.getData();
  44. MultipartFile multipartFile = new MockMultipartFile("file", "filename.txt", "text/plain", data);
  45. String picName = IdUtil.simpleUUID() + "." + ext;
  46. }
  47. } catch (Exception e) {
  48. e.printStackTrace();
  49. }
  50. }
  51. public GetPatentPictureFromExcelThread(ImportTaskAMVO importTaskAMVO, ApplicationContext applicationContext) {
  52. this.importTaskAMVO = importTaskAMVO;
  53. this.savePatentToEsThread = savePatentToEsThread;
  54. this.applicationContext = applicationContext;
  55. }
  56. public void awakeTask(Patent patent) {
  57. // patents.add(patent);
  58. // if (taskLock.tryLock()) {
  59. // taskCondition.signalAll();
  60. // taskLock.unlock();
  61. // }
  62. }
  63. //
  64. public void setIfProductAll(Boolean ifProductAll) {
  65. this.ifProductAll = ifProductAll;
  66. }
  67. }