优化送达签收文件下载功能

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/domain/CaseApplication.java

@@ -227,7 +227,10 @@ public class CaseApplication  extends BaseEntity {
     private List<Integer> caseStatusList;
 
     private List<Integer> annexTypeList;
-
+    /**
+     * 立案申请书(1)、申请人证据材料(2)、仲裁文书(3)、案件视频(4)、身份证件(5)
+     * 被申请人证据材料 (6)、庭审笔录(7)、缴费凭证(8)、视频录制(9)、公章图片(10)、语音转录文件(11)
+     */
     private Integer annexType;
     /**
      * 案件附件列表

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/AdjudicationServiceImpl.java

@@ -10,64 +10,55 @@ import com.google.gson.JsonArray;
 import com.google.gson.JsonObject;
 import com.ruoyi.common.constant.CaseApplicationConstants;
 import com.ruoyi.common.constant.FileTransformation;
-import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.core.domain.entity.EsignHttpResponse;
 import com.ruoyi.common.core.domain.entity.SysDictData;
 import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.exception.EsignDemoException;
 import com.ruoyi.common.exception.ServiceException;
-import com.ruoyi.common.utils.*;
+import com.ruoyi.common.utils.EmailOutUtil;
+import com.ruoyi.common.utils.ObjectFieldUtils;
+import com.ruoyi.common.utils.SmsUtils;
+import com.ruoyi.common.utils.WordUtil;
 import com.ruoyi.common.utils.file.SaaSAPIFileUtils;
 import com.ruoyi.common.utils.thread.MultipleThreadListParam;
-import com.ruoyi.common.utils.thread.MultipleThreadWorkUtil;
 import com.ruoyi.system.mapper.SysDictDataMapper;
 import com.ruoyi.wisdomarbitrate.StringIdsReq;
-import com.ruoyi.wisdomarbitrate.domain.vo.BookSendVO;
-import com.ruoyi.wisdomarbitrate.domain.vo.ColumnValue;
-import com.ruoyi.wisdomarbitrate.mapper.*;
-import com.ruoyi.wisdomarbitrate.utils.CaseLogUtils;
 import com.ruoyi.wisdomarbitrate.domain.*;
 import com.ruoyi.wisdomarbitrate.domain.vo.ArchivesDetailVO;
+import com.ruoyi.wisdomarbitrate.domain.vo.BookSendVO;
+import com.ruoyi.wisdomarbitrate.domain.vo.ColumnValue;
 import com.ruoyi.wisdomarbitrate.domain.vo.LogisticsInfoVO;
+import com.ruoyi.wisdomarbitrate.mapper.*;
 import com.ruoyi.wisdomarbitrate.service.IAdjudicationService;
 import com.ruoyi.wisdomarbitrate.service.ICaseApplicationService;
 import com.ruoyi.wisdomarbitrate.service.ICaseLogRecordService;
+import com.ruoyi.wisdomarbitrate.utils.CaseLogUtils;
 import com.ruoyi.wisdomarbitrate.utils.SignAward;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.poi.ss.usermodel.Sheet;
-import org.apache.poi.xssf.usermodel.XSSFWorkbook;
 import org.apache.poi.xwpf.usermodel.XWPFDocument;
 import org.apache.poi.xwpf.usermodel.XWPFParagraph;
-import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTBookmark;
-import org.openxmlformats.schemas.wordprocessingml.x2006.main.CTP;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.mail.MailSendException;
 import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import org.w3c.dom.Node;
-import org.w3c.dom.NodeList;
 
 import java.io.*;
-import java.math.BigDecimal;
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.net.URLEncoder;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.StandardCopyOption;
-import java.text.NumberFormat;
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
 import java.util.*;
-import java.util.concurrent.CountDownLatch;
 import java.util.function.Function;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
-import static com.ruoyi.common.utils.PageUtils.startPage;
 import static com.ruoyi.common.utils.SecurityUtils.getUsername;
 
 @Service
@@ -110,15 +101,11 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
 
 
     // 仲裁反请求模板内容
-    private final String counterclaim = "在《2022年版仲裁规则》第十八条第（一）项规定的期限内，被申请人向秘书处提交了" +
-            "《仲裁反请求申请书》及证据材料。仲裁委依据《2022年版仲裁规则》第十八条的规定受理了该仲裁反请求案申请。" +
-            "仲裁反请求案件受理后，秘书处向被申请人发送了仲裁反请求通知书及附件，向申请人发送了仲裁反请求通知书及附件、仲裁反请求申请书及附件。";
+    private final String counterclaim = "在《2022年版仲裁规则》第十八条第（一）项规定的期限内，被申请人向秘书处提交了" + "《仲裁反请求申请书》及证据材料。仲裁委依据《2022年版仲裁规则》第十八条的规定受理了该仲裁反请求案申请。" + "仲裁反请求案件受理后，秘书处向被申请人发送了仲裁反请求通知书及附件，向申请人发送了仲裁反请求通知书及附件、仲裁反请求申请书及附件。";
     // 财产保全内容
-    String preservation = "本案受理后，申请人向仲裁委提交了财产保全申请，仲裁委根据《中华人民共和国仲裁法》" +
-            "第二十八条之规定，将该申请提交至法院。";
+    String preservation = "本案受理后，申请人向仲裁委提交了财产保全申请，仲裁委根据《中华人民共和国仲裁法》" + "第二十八条之规定，将该申请提交至法院。";
     // 管辖权异议
-    String jurisdictionalObjection = "本案受理后，被申请人向仲裁委提交了《管辖异议申请书》，认为" +
-            "，仲裁委经审理，当庭驳回了被申请人的管辖异议申请，并告知被申请人具体的事实和理由将在裁决书中一并列明。";
+    String jurisdictionalObjection = "本案受理后，被申请人向仲裁委提交了《管辖异议申请书》，认为" + "，仲裁委经审理，当庭驳回了被申请人的管辖异议申请，并告知被申请人具体的事实和理由将在裁决书中一并列明。";
     // 线上开庭时+线上仲裁
     String onLineDate = "{{onLineDate}}";
     String onLine = "仲裁庭审阅了申请人提交的仲裁申请书、证据材料后，于" + onLineDate + "通过仲裁委智慧仲裁平台开庭审理了本案。";
@@ -129,10 +116,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
     String writtenDate = "{{writtenDate}}";
     String written = "仲裁庭审阅了申请人提交的仲裁申请书、证据材料后，于" + writtenDate + "在仲裁委所在地开庭审理了本案。仲裁庭审阅了申请人提交的仲裁申请书、证据材料后，根据《2022年版仲裁规则》第五十八条的规定对本案进行了书面审理。 ";
     //开庭+缺席审理
-    String absent = "申请人的特别授权委托代理人{{agentName}}" + "出席了庭审。被申请人经依法送达开庭通知，无正当理由未出席庭审，故仲裁庭依据" +
-            "《2022年版仲裁规则》第四十条第（二）项的规定，对本案进行了缺席审理。庭审中，申请人陈述了仲裁请求事项及事实与理由，出示了证据材料并进行了说明，\" +\n" +
-            "            \"发表了意见，回答了仲裁庭的提问，并作了最后陈述。因被申请人缺席庭审，故仲裁庭无法组织调解。" + "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" +
-            "第四十条第（二）项、第五十一条的规定，缺席裁决如下：";
+    String absent = "申请人的特别授权委托代理人{{agentName}}" + "出席了庭审。被申请人经依法送达开庭通知，无正当理由未出席庭审，故仲裁庭依据" + "《2022年版仲裁规则》第四十条第（二）项的规定，对本案进行了缺席审理。庭审中，申请人陈述了仲裁请求事项及事实与理由，出示了证据材料并进行了说明，\" +\n" + "            \"发表了意见，回答了仲裁庭的提问，并作了最后陈述。因被申请人缺席庭审，故仲裁庭无法组织调解。" + "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" + "第四十条第（二）项、第五十一条的规定，缺席裁决如下：";
     // 开庭+出席
     String attend = "申请人的特别授权委托代理人{{agentName}}和被申请人本人出席了庭审。 ";
     // 开庭+出席+被申提供证据
@@ -140,14 +124,11 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
     // 开庭+出席+被申未提供证据
     String onLineAttend = "庭审中，申请人陈述了仲裁请求事项及所依据的事实与理由，被申请人进行了答辩；申请人出示了证据材料，被申请人对对方的证据材料进行了质证； 双方当事人均回答了仲裁庭的提问，进行了辩论，并分别作了最后陈述。双方当事人在仲裁庭的主持下进行了调解，但未能达成调解协议。 ";
     // 被申请人出席答辩意见
-    String resAttendOpinion = "\n（二）被申请人的答辩意见  \n（三）当事人提供的证据材料及对方的质证意见\n" +
-            "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：\n{{applicantFile}}\n被申请人对上述材料的质证意见为：{{respondentOpinion}}\n";
+    String resAttendOpinion = "\n（二）被申请人的答辩意见  \n（三）当事人提供的证据材料及对方的质证意见\n" + "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：\n{{applicantFile}}\n被申请人对上述材料的质证意见为：{{respondentOpinion}}\n";
     // 被申请人出席+被申请人提供了资料
-    String resFile = "被申请人向仲裁庭提交了如下证据材料：\n{{resFile}}" +
-            "申请人对上述材料的质证意见为：{{applicantOpinion}}";
+    String resFile = "被申请人向仲裁庭提交了如下证据材料：\n{{resFile}}" + "申请人对上述材料的质证意见为：{{applicantOpinion}}";
     // 被申请人缺席
-    String resAbsent = "（二）当事人提供的证据材料\n" +
-            "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：\n{{applicantFile}}";
+    String resAbsent = "（二）当事人提供的证据材料\n" + "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：\n{{applicantFile}}";
     // 日期格式化年月日
     SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日");
 
@@ -528,9 +509,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                             default:
                                 break;
                         }
-                    } else if (dictData.getDictLabel().contains("申请人") || dictData.getDictLabel().contains("统一社会信用代码")
-                            || dictData.getDictLabel().contains("法定代表人") || dictData.getDictLabel().contains("法定代表人职位")
-                            || dictData.getDictLabel().contains("代理人")) {
+                    } else if (dictData.getDictLabel().contains("申请人") || dictData.getDictLabel().contains("统一社会信用代码") || dictData.getDictLabel().contains("法定代表人") || dictData.getDictLabel().contains("法定代表人职位") || dictData.getDictLabel().contains("代理人")) {
                         CaseAffiliate affiliate = affiliateMap.get(1);
                         if (affiliate == null) {
                             continue;
@@ -588,12 +567,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
      * @param arbitrateRecordSelect 出裁决书生成记录
      */
     private void saveArbitorFile(Long id, String saveName, String savePath, CaseApplication caseApplicationById, ArbitrateRecord arbitrateRecordSelect) {
-        CaseAttach caseAttach = CaseAttach.builder()
-                .caseAppliId(id)
-                .annexName(saveName)
-                .annexPath(savePath)
-                .annexType(3)
-                .build();
+        CaseAttach caseAttach = CaseAttach.builder().caseAppliId(id).annexName(saveName).annexPath(savePath).annexType(3).build();
         //保存到附件表里,先判断之前有没有,有的话更新,没有的话新增
         List<CaseAttach> caseAttachList = caseAttachMapper.getCaseAttachByCaseIdAndType(caseAttach);
         if (caseAttachList != null && caseAttachList.size() > 0) {
@@ -614,7 +588,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
         //修改案件状态
         caseApplicationById.setCaseStatus(CaseApplicationConstants.VERPRIF_ARBITRATION);
         Integer arbitratMethod = caseApplicationById.getArbitratMethod();
-        if(arbitratMethod==1){
+        if (arbitratMethod == 1) {
             caseApplicationById.setLockStatus(1);
         }
         caseApplicationMapper.submitCaseApplication(caseApplicationById);
@@ -657,12 +631,10 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             //电子邮件送达
             JavaMailSender javaMailSender = emailOutUtil.rebuildMailSender();
             if (appEmail != null) {
-                emailOutUtil.sendMessageCarryFile(appEmail, "案件裁决书", "您的裁决书已送达,详情请查阅附件", file
-                        , "hjbjava@163.com", javaMailSender);
+                emailOutUtil.sendMessageCarryFile(appEmail, "案件裁决书", "您的裁决书已送达,详情请查阅附件", file, "hjbjava@163.com", javaMailSender);
             }
             if (resEmail != null) {
-                emailOutUtil.sendMessageCarryFile(resEmail, "案件裁决书", "您的裁决书已送达,详情请查阅附件", file
-                        , "hjbjava@163.com", javaMailSender);
+                emailOutUtil.sendMessageCarryFile(resEmail, "案件裁决书", "您的裁决书已送达,详情请查阅附件", file, "hjbjava@163.com", javaMailSender);
 
             }
             //修改案件状态
@@ -709,10 +681,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                     String trackNum = affiliate.getTrackNum();
                     if (trackNum != null) {
                         // 构造查询字符串参数
-                        String queryParameters = String.format("key=%s&com=%s&no=%s&phone=%d",
-                                URLEncoder.encode(key, "UTF-8"),
-                                URLEncoder.encode(com, "UTF-8"),
-                                URLEncoder.encode(trackNum, "UTF-8"), null);
+                        String queryParameters = String.format("key=%s&com=%s&no=%s&phone=%d", URLEncoder.encode(key, "UTF-8"), URLEncoder.encode(com, "UTF-8"), URLEncoder.encode(trackNum, "UTF-8"), null);
                         // 拼接到API URL中
                         String fullUrl = apiUrl + "?" + queryParameters;
                         URL url = new URL(fullUrl);
@@ -782,6 +751,9 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
         return AjaxResult.success("归档成功,案件状态已改为已归档");
     }
 
+    @Autowired
+    DownFileService downFileService;
+
     @Override
     @Transactional
     public AjaxResult service(Long id, String appEmail, String resEmail, String apptrackingNum, String restrackingNum) {
@@ -800,11 +772,42 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                     int startIndex = prefix.length();
                     String path = caseAttach.getAnnexPath() + annexName.substring(startIndex);
                     File file = new File(path);
-                    // todo 部署放开
+                    //判断文件是否存在
                     if (!file.exists()) {
-                        return AjaxResult.error("未生成裁决书");
+//                        return AjaxResult.error("未生成裁决书");
+                        //若不存在则从e签宝下载PDF文件
+                        try {
+                            SealSignRecord sealSignRecord = new SealSignRecord();
+                            sealSignRecord.setCaseAppliId(caseApplication.getId());
+                            //3为"签署用印记录表"的状态为签署完成
+                            sealSignRecord.setSignFlowStatus(3);
+                            List<SealSignRecord> sealSignRecords = sealSignRecordMapper.selectSealSignRecord(sealSignRecord);
+                            if (sealSignRecords != null && sealSignRecords.size() > 0) {
+                                SealSignRecord sealSignRecord1 = sealSignRecords.get(0);
+                                downFileService.downPdfFileFormEsign(sealSignRecord1.getSignFlowid(), caseAttach.getCaseAppliId());
+                                //下载成功后重新查询
+                                List<CaseAttach> caseAttachList1 = caseAttachMapper.queryCaseAttachList(caseApplication1);
+                                for (CaseAttach caseAttach1 : caseAttachList1) {
+                                    if (caseAttach1.getAnnexType() == 3) {
+                                        annexName = caseAttach.getAnnexName();
+                                        prefix = "/profile/upload/";
+                                        startIndex = prefix.length();
+                                        path = caseAttach.getAnnexPath() + annexName.substring(startIndex);
+                                        File file1 = new File(path);
+                                        if (!file1.exists()) {
+                                            return AjaxResult.error("未生成裁决书");
+                                        }
+                                        caseAttachList = caseAttachList1;
+                                        break;
+                                    }
+                                }
+                            }
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
                     }
-
+                    //找到签署后的PDF文件后调出该循环
+                    break;
                 }
             }
         }
@@ -857,33 +860,33 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
         sendMailRecord1.setCreateBy(getUsername());
         if (resEmailFlag) {
             sendMailRecord1.setSendStatus(1);
-        }else {
+        } else {
             sendMailRecord1.setSendStatus(0);
         }
         sendMailRecordMapper.saveSendMailRecord(sendMailRecord1);
-        if(!appEmailFlag&&!resEmailFlag){
+        if (!appEmailFlag && !resEmailFlag) {
             throw new ServiceException("裁决书发送失败");
         }
-        if(!appEmailFlag){
+        if (!appEmailFlag) {
             throw new ServiceException("申请人裁决书发送失败");
         }
-        if(!resEmailFlag){
+        if (!resEmailFlag) {
             throw new ServiceException("被申请人裁决书发送失败");
         }
         // 发送短信
-        if (appEmailFlag||resEmailFlag) {
+        if (appEmailFlag || resEmailFlag) {
 
             if (CollectionUtil.isNotEmpty(caseAffiliates)) {
                 SmsUtils.SendSmsRequest request = new SmsUtils.SendSmsRequest();
                 request.setTemplateId("1990362");
                 for (CaseAffiliate affiliate : caseAffiliates) {
-                    String telphone=null;
-                    if(appEmailFlag&&affiliate.getIdentityType()==1){
-                         telphone = affiliate.getContactTelphone();
-                    }else if(resEmailFlag&&affiliate.getIdentityType()==2){
-                         telphone = affiliate.getContactTelphone();
+                    String telphone = null;
+                    if (appEmailFlag && affiliate.getIdentityType() == 1) {
+                        telphone = affiliate.getContactTelphone();
+                    } else if (resEmailFlag && affiliate.getIdentityType() == 2) {
+                        telphone = affiliate.getContactTelphone();
                     }
-                    if(StrUtil.isEmpty(telphone)){
+                    if (StrUtil.isEmpty(telphone)) {
                         continue;
                     }
 
@@ -966,9 +969,9 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
 //                Boolean aBoolean = emailOutUtil.sendEmil(email, "您好，您的{"+caseApplication1.getCaseNum()+"}案件，审核后的裁决书在附件中请查阅", appUid +"裁决书", fileList, null);
 //           //     Thread.sleep(20);
                 // 收到退信的所有id，即发送失败的uuid
-            //    emailOutUtil.receiverMail();
-          //      Thread.sleep(3);
-           //   List<String> messageIds = emailOutUtil.receiverMail();
+                //    emailOutUtil.receiverMail();
+                //      Thread.sleep(3);
+                //   List<String> messageIds = emailOutUtil.receiverMail();
 //                if (aBoolean&&(CollectionUtil.isEmpty(messageIds)||!messageIds.contains(appUid))) {
 //                    return Boolean.TRUE;
 //                }
@@ -1085,9 +1088,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             datas.put("acceptDate", registerDateStr);
             //反请求
             Integer adjudicaCounter = caseApplication1.getAdjudicaCounter();
-            String counterclaim = "在《2022年版仲裁规则》第十八条第（一）项规定的期限内，被申请人向秘书处提交了" +
-                    "《仲裁反请求申请书》及证据材料。仲裁委依据《2022年版仲裁规则》第十八条的规定受理了该仲裁反请求案申请。" +
-                    "仲裁反请求案件受理后，秘书处向被申请人发送了仲裁反请求通知书及附件，向申请人发送了仲裁反请求通知书及附件、仲裁反请求申请书及附件。";
+            String counterclaim = "在《2022年版仲裁规则》第十八条第（一）项规定的期限内，被申请人向秘书处提交了" + "《仲裁反请求申请书》及证据材料。仲裁委依据《2022年版仲裁规则》第十八条的规定受理了该仲裁反请求案申请。" + "仲裁反请求案件受理后，秘书处向被申请人发送了仲裁反请求通知书及附件，向申请人发送了仲裁反请求通知书及附件、仲裁反请求申请书及附件。";
             if (adjudicaCounter == null) {
                 datas.put("counterclaim", null);
             } else if (adjudicaCounter == 1) {
@@ -1097,8 +1098,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             }
             //财产保全
             Integer properPreser = caseApplication1.getProperPreser();
-            String preservation = "本案受理后，申请人向仲裁委提交了财产保全申请，仲裁委根据《中华人民共和国仲裁法》" +
-                    "第二十八条之规定，将该申请提交至法院。";
+            String preservation = "本案受理后，申请人向仲裁委提交了财产保全申请，仲裁委根据《中华人民共和国仲裁法》" + "第二十八条之规定，将该申请提交至法院。";
             if (properPreser == null) {
                 datas.put("preservation", null);
             } else if (properPreser == 1) {
@@ -1108,8 +1108,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             }
             //管辖权异议
             Integer objectiJuris = caseApplication1.getObjectiJuris();
-            String jurisdictionalObjection = "本案受理后，被申请人向仲裁委提交了《管辖异议申请书》，认为" +
-                    "，仲裁委经审理，当庭驳回了被申请人的管辖异议申请，并告知被申请人具体的事实和理由将在裁决书中一并列明。";
+            String jurisdictionalObjection = "本案受理后，被申请人向仲裁委提交了《管辖异议申请书》，认为" + "，仲裁委经审理，当庭驳回了被申请人的管辖异议申请，并告知被申请人具体的事实和理由将在裁决书中一并列明。";
             if (objectiJuris == null) {
                 datas.put("jurisdictionalObjection", null);
             } else if (objectiJuris == 1) {
@@ -1160,14 +1159,10 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             } else if (isAbsence == 1) {
                 //缺席审理
                 String absent1 = "申请人的特别授权委托代理人";
-                String absent2 = "出席了庭审。被申请人经依法送达开庭通知，无正当理由未出席庭审，故仲裁庭依据" +
-                        "《2022年版仲裁规则》第四十条第（二）项的规定，对本案进行了缺席审理。";
-                String absent3 = "庭审中，申请人陈述了仲裁请求事项及事实与理由，出示了证据材料并进行了说明，" +
-                        "发表了意见，回答了仲裁庭的提问，并作了最后陈述。因被申请人缺席庭审，故仲裁庭无法组织调解。";
-                String absent4 = "（二/三）当事人提供的证据材料\n" +
-                        "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：";
-                String absent5 = "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" +
-                        "第四十条第（二）项、第五十一条的规定，缺席裁决如下：";
+                String absent2 = "出席了庭审。被申请人经依法送达开庭通知，无正当理由未出席庭审，故仲裁庭依据" + "《2022年版仲裁规则》第四十条第（二）项的规定，对本案进行了缺席审理。";
+                String absent3 = "庭审中，申请人陈述了仲裁请求事项及事实与理由，出示了证据材料并进行了说明，" + "发表了意见，回答了仲裁庭的提问，并作了最后陈述。因被申请人缺席庭审，故仲裁庭无法组织调解。";
+                String absent4 = "（二/三）当事人提供的证据材料\n" + "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：";
+                String absent5 = "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" + "第四十条第（二）项、第五十一条的规定，缺席裁决如下：";
                 datas.put("absent1", absent1);
                 datas.put("absent2", absent2);
                 datas.put("absent3", absent3);
@@ -1179,13 +1174,9 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                 String attend1 = "申请人的特别授权委托代理人";
                 String attend2 = "和被申请人本人/的特别授权委托代理人";
                 String attend3 = "出席了庭审。";
-                String attend4 = "庭审中，申请人陈述了仲裁请求事项及所依据的事实与理由，被申请人进行了答辩；" +
-                        "双方当事人均出示了证据材料并对对方的证据材料进行了质证；申请人出示了证据材料，" +
-                        "被申请人对对方的证据材料进行了质证；双方当事人均回答了仲裁庭的提问，进行了辩论，" +
-                        "并分别作了最后陈述。双方当事人在仲裁庭的主持下进行了调解，但未能达成调解协议。";
+                String attend4 = "庭审中，申请人陈述了仲裁请求事项及所依据的事实与理由，被申请人进行了答辩；" + "双方当事人均出示了证据材料并对对方的证据材料进行了质证；申请人出示了证据材料，" + "被申请人对对方的证据材料进行了质证；双方当事人均回答了仲裁庭的提问，进行了辩论，" + "并分别作了最后陈述。双方当事人在仲裁庭的主持下进行了调解，但未能达成调解协议。";
                 String attend5 = "（二）被申请人的答辩意见";
-                String attend6 = "（二/三）当事人提供的证据材料及对方的质证意见\n" +
-                        "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：";
+                String attend6 = "（二/三）当事人提供的证据材料及对方的质证意见\n" + "申请人为证明其主张的事实和理由，向仲裁庭提交了如下证据材料：";
                 String attend7 = "被申请人对上述材料的质证意见为：";
                 datas.put("attend1", attend1);
                 datas.put("attend2", attend2);
@@ -1199,13 +1190,11 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                 datas.put("resAgentName", nameAgentList.get(1));
                 if (arbitratMethod == 1) {
                     //被申出席+开庭
-                    String attend8 = "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" +
-                            "第五十一条的规定，裁决如下：";
+                    String attend8 = "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" + "第五十一条的规定，裁决如下：";
                     datas.put("attend8", attend8);
                 } else {
                     //被申出席+书面
-                    String attend9 = "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" +
-                            "第五十一条、第五十八条的规定，裁决如下：";
+                    String attend9 = "综上，仲裁庭依据《上海仲裁委员会仲裁规则》（2022年7月1日起施行的版本）" + "第五十一条、第五十八条的规定，裁决如下：";
                     datas.put("attend9", attend9);
                 }
             }
@@ -1221,8 +1210,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                         if (isImageFile) {
                             String annexPath = "/home/ruoyi" + caseAttach.getAnnexPath();
                             System.out.println("路径是===========" + annexPath);
-                            PictureRenderData pictureRenderData = WordUtil
-                                    .rebuildImageContent(100, 100, null, annexPath);
+                            PictureRenderData pictureRenderData = WordUtil.rebuildImageContent(100, 100, null, annexPath);
                             datas.put("resEvidenceMaterial", pictureRenderData);
                         }
                     } else if (caseAttach.getAnnexType() == 2) {   //申请人证据材料
@@ -1231,8 +1219,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                         if (isImageFile) {
                             String annexPath = "/home/ruoyi" + caseAttach.getAnnexPath();
                             System.out.println("路径是===========" + annexPath);
-                            PictureRenderData pictureRenderData = WordUtil
-                                    .rebuildImageContent(100, 100, null, annexPath);
+                            PictureRenderData pictureRenderData = WordUtil.rebuildImageContent(100, 100, null, annexPath);
                             //申请人证据材料
                             datas.put("appEvidenceMaterial", pictureRenderData);
                         }
@@ -1270,12 +1257,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
 
 
             //将裁决书更新到附件表里
-            CaseAttach caseAttach = CaseAttach.builder()
-                    .caseAppliId(id)
-                    .annexName(saveName)
-                    .annexPath(savePath)
-                    .annexType(3)
-                    .build();
+            CaseAttach caseAttach = CaseAttach.builder().caseAppliId(id).annexName(saveName).annexPath(savePath).annexType(3).build();
             int i = caseAttachMapper.updateCaseAttachBycaseid(caseAttach);
 
 
@@ -1408,9 +1390,9 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             Gson gson = new Gson();
             if (StrUtil.isNotEmpty(identityInfo.getBody())) {
                 JsonObject identityInfoJsonObject = gson.fromJson(identityInfo.getBody(), JsonObject.class);
-                if(identityInfoJsonObject!=null&&!identityInfoJsonObject.get("data").isJsonNull()) {
+                if (identityInfoJsonObject != null && !identityInfoJsonObject.get("data").isJsonNull()) {
                     JsonObject identityInfoData = identityInfoJsonObject.getAsJsonObject("data");
-                    if (identityInfoData != null && !identityInfoData.get("psnId") .isJsonNull()) {
+                    if (identityInfoData != null && !identityInfoData.get("psnId").isJsonNull()) {
                         idsReq.setPsnId(identityInfoData.get("psnId").getAsString());
                     }
                 }
@@ -1423,7 +1405,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                 JsonObject signUrlJsonObject = gson.fromJson(batchSignUrl.getBody(), JsonObject.class);
                 if (signUrlJsonObject != null && !signUrlJsonObject.get("data").isJsonNull()) {
                     JsonObject signUrlData = signUrlJsonObject.getAsJsonObject("data");
-                    if (signUrlData != null&& !signUrlData.get("batchSignUrlWithoutLogin").isJsonNull()) {
+                    if (signUrlData != null && !signUrlData.get("batchSignUrlWithoutLogin").isJsonNull()) {
                         // 免登录批量签链接（链接有效期2小时）
                         String url = signUrlData.get("batchSignUrlWithoutLogin").getAsString();
                         // batchSignUrl 需登录批量签链接（链接有效期2小时）,batchSignShortUrl需登录批量签短链接（链接有效期2小时）,batchSignShortUrlWithoutLogin免登录批量签短链接（链接有效期2小时）
@@ -1459,7 +1441,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             }
             Integer batchNumber = idsReq.getBatchNumber();
             Integer caseStatus = CaseApplicationConstants.SIGN_ARBITRATION;
-            List<CaseApplication> caseApplications = sealSignRecordMapper.selectsignFlow(batchNumber,caseStatus);
+            List<CaseApplication> caseApplications = sealSignRecordMapper.selectsignFlow(batchNumber, caseStatus);
             if (caseApplications != null && caseApplications.size() > 0) {
                 List<String> signFlowIds = caseApplications.stream().map(CaseApplication::getSignFlowId).collect(Collectors.toList());
                 idsReq.setIds(signFlowIds);
@@ -1478,7 +1460,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                     }
                 }
 
-            }else{
+            } else {
                 throw new ServiceException("这个批号没有批量签名的案件");
             }
 
@@ -1498,9 +1480,9 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             Gson gson = new Gson();
             if (StrUtil.isNotEmpty(identityInfo.getBody())) {
                 JsonObject identityInfoJsonObject = gson.fromJson(identityInfo.getBody(), JsonObject.class);
-                if(identityInfoJsonObject!=null&&!identityInfoJsonObject.get("data").isJsonNull()) {
+                if (identityInfoJsonObject != null && !identityInfoJsonObject.get("data").isJsonNull()) {
                     JsonObject identityInfoData = identityInfoJsonObject.getAsJsonObject("data");
-                    if (identityInfoData != null && !identityInfoData.get("psnId") .isJsonNull()) {
+                    if (identityInfoData != null && !identityInfoData.get("psnId").isJsonNull()) {
                         idsReq.setPsnId(identityInfoData.get("psnId").getAsString());
                     }
                 }
@@ -1510,7 +1492,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
             }
             Integer batchNumber = idsReq.getBatchNumber();
             Integer caseStatus = CaseApplicationConstants.ARBITRATED_SEAL;
-            List<CaseApplication> caseApplications = sealSignRecordMapper.selectsignFlow(batchNumber,caseStatus);
+            List<CaseApplication> caseApplications = sealSignRecordMapper.selectsignFlow(batchNumber, caseStatus);
             if (caseApplications != null && caseApplications.size() > 0) {
                 List<String> signFlowIds = caseApplications.stream().map(CaseApplication::getSignFlowId).collect(Collectors.toList());
                 idsReq.setIds(signFlowIds);
@@ -1520,7 +1502,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                     JsonObject signUrlJsonObject = gson.fromJson(batchSignUrl.getBody(), JsonObject.class);
                     if (signUrlJsonObject != null && !signUrlJsonObject.get("data").isJsonNull()) {
                         JsonObject signUrlData = signUrlJsonObject.getAsJsonObject("data");
-                        if (signUrlData != null&& !signUrlData.get("batchSignUrlWithoutLogin").isJsonNull()) {
+                        if (signUrlData != null && !signUrlData.get("batchSignUrlWithoutLogin").isJsonNull()) {
                             // 免登录批量签链接（链接有效期2小时）
                             String url = signUrlData.get("batchSignUrlWithoutLogin").getAsString();
                             // batchSignUrl 需登录批量签链接（链接有效期2小时）,batchSignShortUrl需登录批量签短链接（链接有效期2小时）,batchSignShortUrlWithoutLogin免登录批量签短链接（链接有效期2小时）
@@ -1529,7 +1511,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                     }
                 }
 
-            }else{
+            } else {
                 throw new ServiceException("这个批号没有批量用印的案件");
             }
         } catch (EsignDemoException e) {
@@ -1561,7 +1543,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                 return AjaxResult.error(e.getMessage());
             }
 
-        }else{
+        } else {
             throw new ServiceException("这个批号没有批量归档的案件");
         }
 
@@ -1698,33 +1680,33 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
                 sendMailRecord1.setCreateBy(getUsername());
                 if (resEmailFlag) {
                     sendMailRecord1.setSendStatus(1);
-                }else {
+                } else {
                     sendMailRecord1.setSendStatus(0);
                 }
                 sendMailRecordMapper.saveSendMailRecord(sendMailRecord1);
-                if(!appEmailFlag&&!resEmailFlag){
+                if (!appEmailFlag && !resEmailFlag) {
                     throw new ServiceException("裁决书发送失败");
                 }
-                if(!appEmailFlag){
+                if (!appEmailFlag) {
                     throw new ServiceException("申请人裁决书发送失败");
                 }
-                if(!resEmailFlag){
+                if (!resEmailFlag) {
                     throw new ServiceException("被申请人裁决书发送失败");
                 }
                 // 发送短信
-                if (appEmailFlag||resEmailFlag) {
+                if (appEmailFlag || resEmailFlag) {
 
                     if (CollectionUtil.isNotEmpty(caseAffiliates)) {
                         SmsUtils.SendSmsRequest request = new SmsUtils.SendSmsRequest();
                         request.setTemplateId("1990362");
                         for (CaseAffiliate affiliate : caseAffiliates) {
-                            String telphone=null;
-                            if(appEmailFlag&&affiliate.getIdentityType()==1){
+                            String telphone = null;
+                            if (appEmailFlag && affiliate.getIdentityType() == 1) {
                                 telphone = affiliate.getContactTelphone();
-                            }else if(resEmailFlag&&affiliate.getIdentityType()==2){
+                            } else if (resEmailFlag && affiliate.getIdentityType() == 2) {
                                 telphone = affiliate.getContactTelphone();
                             }
-                            if(StrUtil.isEmpty(telphone)){
+                            if (StrUtil.isEmpty(telphone)) {
                                 continue;
                             }
 
@@ -1770,7 +1752,7 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
 
             }
 
-        }else{
+        } else {
             throw new ServiceException("这个批号没有批量送达裁决书的案件");
         }
         return AjaxResult.success("仲裁文书送达成功");
@@ -1856,5 +1838,4 @@ public class AdjudicationServiceImpl implements IAdjudicationService {
         return bookmarkList;
     }
 
-
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/impl/DownFileService.java

@@ -0,0 +1,76 @@
+package com.ruoyi.wisdomarbitrate.service.impl;
+
+import com.google.gson.Gson;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonObject;
+import com.ruoyi.common.constant.FileTransformation;
+import com.ruoyi.common.core.domain.entity.EsignHttpResponse;
+import com.ruoyi.common.exception.EsignDemoException;
+import com.ruoyi.common.utils.file.SaaSAPIFileUtils;
+import com.ruoyi.wisdomarbitrate.domain.CaseApplication;
+import com.ruoyi.wisdomarbitrate.domain.CaseAttach;
+import com.ruoyi.wisdomarbitrate.mapper.CaseAttachMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.io.File;
+import java.io.IOException;
+import java.time.LocalDate;
+import java.util.UUID;
+
+/**
+ * 下载文件
+ */
+@Service
+public class DownFileService {
+    @Autowired
+    CaseAttachMapper caseAttachMapper;
+
+    /**
+     * 从E签宝下载签署完成后的PDF文件
+     */
+    public void downPdfFileFormEsign(String signFlowId, Long caseAppliId) throws EsignDemoException, IOException {
+        Gson gson = new Gson();
+        EsignHttpResponse fileDownload = SaaSAPIFileUtils.fileDownloadUrl(signFlowId);
+        JsonObject fileDownloadJsonObject = gson.fromJson(fileDownload.getBody(), JsonObject.class);
+        JsonObject fileDownloadData = fileDownloadJsonObject.getAsJsonObject("data");
+        JsonArray filesArray = fileDownloadData.get("files").getAsJsonArray();
+        if (filesArray != null && filesArray.size() > 0) {
+            JsonObject fileObject = (JsonObject) filesArray.get(0);
+            String fileDownloadUrl = fileObject.get("downloadUrl").toString();
+            LocalDate now = LocalDate.now();
+            String year = Integer.toString(now.getYear());
+            String month = String.format("%02d", now.getMonthValue());
+            String day = String.format("%02d", now.getDayOfMonth());
+            String saveFolderPath = "/home/ruoyi/uploadPath/upload/" + year + "/" + month + "/" + day;
+            String fileName = UUID.randomUUID().toString().replace("-", "") + ".pdf";
+            String saveName = "/profile/upload/" + year + "/" + month + "/" + day + "/" + fileName;
+            String savePath = "/home/ruoyi/uploadPath/upload/";
+            // 创建日期目录
+            File saveFolder = new File(saveFolderPath);
+            if (!saveFolder.exists()) {
+                saveFolder.mkdirs();
+            }
+            String resultFilePath = saveFolderPath + "/" + fileName;
+            File resultFilePathFile = new File(resultFilePath);
+            if (!resultFilePathFile.exists()) {
+                resultFilePathFile.createNewFile();
+            }
+            String fileDownloadUrlnew = fileDownloadUrl.substring(1, fileDownloadUrl.length() - 1);
+            boolean downLoadFile = FileTransformation.downLoadFileByUrl(fileDownloadUrlnew, resultFilePath);
+            if (downLoadFile) {
+                //立案申请书(1)、申请人证据材料(2)、仲裁文书(3)、案件视频(4)、身份证件(5)、
+                // 被申请人证据材料 (6)、庭审笔录(7)、缴费凭证(8)、视频录制(9)、公章图片(10)、语音转录文件(11)
+                caseAttachMapper.deleteCaseAttachByCasedIdAndType(caseAppliId, 3);
+                CaseAttach caseAttach = new CaseAttach();
+                caseAttach.setCaseAppliId(caseAppliId);
+                caseAttach.setAnnexType(3);
+                caseAttach.setAnnexPath(savePath);
+                caseAttach.setAnnexName(saveName);
+                caseAttachMapper.save(caseAttach);
+            }
+
+        }
+    }
+
+}