在线编辑 在线编辑文件转换失败则在标准详情时 重新加入Mq

adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java

@@ -1,6 +1,5 @@
 package com.adc.da.slrs.sarBussionessStand.service.impl;
 
-import cn.hutool.core.bean.BeanUtil;
 import com.adc.da.att.entity.AttFileEO;
 import com.adc.da.att.service.IAttFileEOService;
 import com.adc.da.att.vo.AttFileVo;
@@ -8,14 +7,12 @@ import com.adc.da.common.*;
 import com.adc.da.exception.AdcDaBaseException;
 import com.adc.da.http.ResponseMessage;
 import com.adc.da.http.Result;
-import com.adc.da.login.util.UserUtils;
 import com.adc.da.mq.CreateMQService;
 import com.adc.da.mq.CreateStandMQService;
 import com.adc.da.person.dao.PersonCollectEODao;
 import com.adc.da.person.entity.TsPersonCollect;
 import com.adc.da.person.page.PersonCollectEOPage;
 import com.adc.da.person.service.IPersonCollectEOService;
-import com.adc.da.search.entity.SarBussionessStandEO;
 import com.adc.da.search.entity.StandLawsEO;
 import com.adc.da.search.service.StandLawsSearchService;
 import com.adc.da.slrs.NewsFeed.entity.NewsFeed;
@@ -24,20 +21,13 @@ import com.adc.da.slrs.OnlineFileLog.dao.OnlineFileLogDao;
 import com.adc.da.slrs.OnlineFileLog.entity.OnlineFileLog;
 import com.adc.da.slrs.esRevisePlan.dao.EsRevisePlanDao;
 import com.adc.da.slrs.esRevisePlan.dao.EsRevisePlanLogDao;
-import com.adc.da.slrs.esRevisePlan.entity.EsRevisePlan;
-import com.adc.da.slrs.esRevisePlan.entity.EsRevisePlanLog;
-import com.adc.da.slrs.esRevisePlan.service.IEsRevisePlanService;
-import com.adc.da.slrs.esRevisePlan.dao.EsRevisePlanDao;
-import com.adc.da.slrs.esRevisePlan.dao.EsRevisePlanLogDao;
 import com.adc.da.slrs.esRevisePlan.service.IEsRevisePlanService;
 import com.adc.da.slrs.otConvertMq.dao.OtConvertMqDao;
 import com.adc.da.slrs.otConvertMq.entity.OtConvertMq;
 import com.adc.da.slrs.sarBussStandAttrInfo.dao.SarBussStandAttrInfoDao;
-import com.adc.da.slrs.sarBussStandAttrInfo.entity.BusProcessEvaluationHis;
 import com.adc.da.slrs.sarBussStandAttrInfo.entity.SarBussStandAttrInfo;
 import com.adc.da.slrs.sarBussStandAttrInfo.service.ISarBussStandAttrInfoService;
 import com.adc.da.slrs.sarBussStandAttrInfo.entity.SarBussStandAttrInfoExecl;
-import com.adc.da.slrs.sarBussStandAttrInfo.service.ISarBussStandAttrInfoService;
 import com.adc.da.slrs.sarBussStandFile.dao.SarBussStandFileDao;
 import com.adc.da.slrs.sarBussStandFile.entity.SarBussStandFile;
 import com.adc.da.slrs.sarBussStandItems.dao.SarBussStandItemsDao;
@@ -54,98 +44,55 @@ import com.adc.da.slrs.sarBussionessStand.dao.SarBussionessStandDao;
 import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStandExport;
 import com.adc.da.slrs.sarBussionessStand.service.ISarBussionessStandService;
 import com.adc.da.slrs.sarBussionessStandState.dao.SarBussionessStandStateDao;
-import com.adc.da.slrs.sarBussionessStandState.service.ISarBussionessStandStateService;
-import com.adc.da.slrs.sarEnterpriseStandardEvaluation.service.IQualityEvaluationService;
 import com.adc.da.slrs.sarInstitution.dao.TsInstitutionDao;
-import com.adc.da.slrs.sarInstitution.entity.TsInstitution;
 import com.adc.da.slrs.sarLawsInfo.service.ISarLawsInfoService;
 import com.adc.da.slrs.sarBussionessStandState.entity.SarBussionessStandState;
-import com.adc.da.slrs.sarBussionessStandState.service.ISarBussionessStandStateService;
-import com.adc.da.slrs.sarEnterpriseStandardEvaluation.entity.QualityEvaluation;
-import com.adc.da.slrs.sarEnterpriseStandardEvaluation.service.IQualityEvaluationService;
-import com.adc.da.slrs.sarLawsInfo.service.ISarLawsInfoService;
-import com.adc.da.slrs.sarMenuStandard.entity.SarMenuStandardNew;
-import com.adc.da.slrs.sarMenuStandard.service.ISarMenuStandardNewService;
 import com.adc.da.slrs.sarResource.entity.TsResource;
 import com.adc.da.slrs.sarResource.service.ITsResourceService;
 import com.adc.da.slrs.sarStandAttrInfo.dao.SarStandAttrInfoDao;
-import com.adc.da.slrs.sarStandAttrInfo.entity.SarStandAttrInfo;
-import com.adc.da.slrs.sarStandFile.entity.SarStandFile;
-import com.adc.da.slrs.sarStandItems.entity.SarStandItems;
 import com.adc.da.slrs.sarStandardsInfo.dao.SarStandardsInfoDao;
 import com.adc.da.slrs.sarStandardsInfo.entity.SarAdvanceSearchVO;
 import com.adc.da.slrs.sarStandardsInfo.entity.SarBussionessStandEOPage;
 import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo;
 import com.adc.da.slrs.sarUpdLog.service.ISarUpdLogService;
 import com.adc.da.slrs.sarUser.dao.TsUserDao;
-import com.adc.da.slrs.sarUser.entity.TsUser;
-import com.adc.da.slrs.sarUser.entity.UpDTO;
 import com.adc.da.slrs.sarUser.service.ITsUserService;
 import com.adc.da.slrs.sarVppsTree.dao.SarVppsTreeDao;
 import com.adc.da.slrs.sysInfo.service.SysInfoEOService;
 import com.adc.da.sys.constant.ValueStateEnum;
 import com.adc.da.sys.dao.DicTypeEODao;
-import com.adc.da.sys.dao.UserEODao;
 import com.adc.da.sys.entity.DicTypeEO;
-import com.adc.da.sys.entity.UserEO;
 import com.adc.da.sys.sarMenuStandard.entity.SarMenuStandard;
 import com.adc.da.sys.sarMenuStandard.service.ISarMenuStandardService;
 import com.adc.da.sys.util.LoginUserUtil;
 import com.adc.da.util.UUIDUtils;
 import com.adc.da.utils.util.*;
-import com.adc.da.utils.util.DateUtil;
-import com.alibaba.druid.support.json.JSONUtils;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.mysql.cj.x.protobuf.MysqlxDatatypes;
-import lombok.SneakyThrows;
 import net.sf.json.JSONObject;
 import org.apache.commons.beanutils.BeanUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang.StringUtils;
-import org.json.JSONArray;
 import org.apache.commons.lang3.ObjectUtils;
-import org.apache.poi.hssf.usermodel.HSSFCell;
-import org.apache.poi.hssf.usermodel.HSSFCellStyle;
 import org.apache.poi.hssf.usermodel.HSSFDateUtil;
-import org.apache.poi.hssf.usermodel.HSSFRow;
-import org.apache.poi.hssf.usermodel.HSSFSheet;
-import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 import org.apache.poi.ss.usermodel.*;
-import org.apache.poi.xssf.usermodel.XSSFWorkbook;
-import org.json.JSONArray;
 import org.json.JSONTokener;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
-import org.springframework.test.context.testng.AbstractTestNGSpringContextTests;
 import org.springframework.web.multipart.MultipartFile;
 
-import javax.net.ssl.*;
 import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.HttpURLConnection;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.security.SecureRandom;
-import java.security.cert.CertificateException;
-import java.security.cert.X509Certificate;
 import java.sql.Clob;
-import java.sql.Connection;
-import java.text.DateFormat;
-import java.text.DecimalFormat;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 /**
  * <p>
@@ -205,18 +152,12 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
     @Autowired
     private SarBussStandFileDao sarBussStandFileEODao;
 
-    @Autowired
-    private SarStandardsInfoDao sarStandardsInfoEODao;
-
     @Autowired
     private CreateStandMQService createStandMQService;
 
     @Autowired
     private ISarUpdLogService sarUpdLogEOService;
 
-    @Autowired
-    private ITsResourceService sarMenuEOService;
-
     @Autowired
     private PersonCollectEODao personCollectEODao;
 
@@ -248,21 +189,9 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
     @Autowired
     private ISarBussionessStandService iSarBussionessStandService;
 
-    @Autowired
-    private IQualityEvaluationService qualityEvaluationService;
-
     @Autowired
     IEsRevisePlanService iEsRevisePlanService;
 
-    @Autowired
-    private EsRevisePlanDao esRevisePlanDao;
-
-    @Autowired
-    private ISarBussionessStandStateService bussionessStandStateService;
-
-    @Autowired
-    private EsRevisePlanLogDao esRevisePlanLogDao;
-
     @Autowired
     private ISarBussStandAttrInfoService sarBussStandAttrInfoService;
 
@@ -278,8 +207,9 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
 
     @Autowired
     private TsInstitutionDao tsInstitutionDao;
-    @Autowired
-    private IAttFileEOService iAttFileEOService;
+
+//    @Autowired
+//    private IAttFileEOService iAttFileEOService;
 
     @Autowired
     private SarBussionessStandStateDao sarBussionessStandStateDao;
@@ -1420,7 +1350,14 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
            }
             sarBussionessStandEO = newStandList.get(0);
         }
-        //企标文本状态
+        // 处理 在线编辑pdf存储失败问题  发布稿的在线编辑文件 判断文件表是否有没有则 添加 每次进入 都进行判断
+        Object fbgbuss = sarBussionessStandEO.getAttrInfoCaseMap().get("fbgbuss");
+        if(fbgbuss!=null) {
+            String fbgbussStr = fbgbuss.toString();
+            if(StringUtils.isNotBlank(fbgbussStr)){
+                sarStandFilePdf(fbgbussStr);
+            }
+        }
         return sarBussionessStandEO;
     }
 
@@ -4541,7 +4478,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
                          String fbgBuss = "";
                          for(String idInfo :splitInfo){
                              if(StringUtils.isNotBlank(idInfo)) {
-                                 AttFileEO byId = iAttFileEOService.getFileInfo(idInfo);
+                                 AttFileEO byId = attFileEOService.getFileInfo(idInfo);
                                  if (StringUtils.isNotBlank(fbgbussName)) {
                                      fbgbussName = fbgbussName + "," + byId.getOldFileName();
                                  } else {
@@ -4949,4 +4886,40 @@ public class SarBussionessStandServiceImpl extends ServiceImpl<SarBussionessStan
         }
     }
 
+    /*
+        未转换成刚的文件此处进行 转换
+     */
+    private String sarStandFilePdf(String fileIds){
+        String[] split = fileIds.split(",");
+        for (String fileId : split){
+            QueryWrapper<SarBussStandFile> objectQueryWrapper = new QueryWrapper<>();
+            objectQueryWrapper.eq("ORI_ATT_ID",fileId);
+            objectQueryWrapper.eq("USE_MODEL","SOURCE_FILE");
+            objectQueryWrapper.ne("FILE_SUFFIX","pdf");
+            objectQueryWrapper.ne("FILE_SUFFIX","PDF");
+            List<SarBussStandFile> sarBussStandFiles = sarBussStandFileEODao.selectList(objectQueryWrapper);
+            // 为空暂不处理 不为空则意味pdf生成失败
+            if(!sarBussStandFiles.isEmpty() && sarBussStandFiles.size()==1){
+//                createStandFileAppend(\);
+                AttFileEO fileInfo = attFileEOService.getFileInfo(sarBussStandFiles.get(0).getOriAttId());
+                String filePath = fileInfo.getFilePath() + fileInfo.getFileName();
+                OtConvertMq convert = new OtConvertMq();
+                convert.setLawsId(sarBussStandFiles.get(0).getStandId());
+                convert.setAttId(fileInfo.getId());
+                convert.setFilePath(filePath);
+                convert.setAddOrUp("0");
+                convert.setFileSuffix(fileInfo.getFileSuffix());
+                convert.setStandFileClassify(sarBussStandFiles.get(0).getStandFileClassify());
+                convert.setConvertType(SarTypeEnum.BUSINESS.getValue());
+                if(elasflag) {
+                    try {
+                        convertMq.sendMQ(convert);
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+        }
+        return "2";
+    }
 }