ruoyi-admin/src/main/java/com/ruoyi/web/controller/system/SysDictDataController.java

@@ -1,19 +1,6 @@
 package com.ruoyi.web.controller.system;
 
-import java.util.ArrayList;
-import java.util.List;
-import javax.servlet.http.HttpServletResponse;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.security.access.prepost.PreAuthorize;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.DeleteMapping;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.PutMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import com.ruoyi.common.annotation.Anonymous;
 import com.ruoyi.common.annotation.Log;
 import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.AjaxResult;
@@ -24,6 +11,14 @@ import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.poi.ExcelUtil;
 import com.ruoyi.system.service.ISysDictDataService;
 import com.ruoyi.system.service.ISysDictTypeService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * 数据字典信息
@@ -82,6 +77,20 @@ public class SysDictDataController extends BaseController
         }
         return success(data);
     }
+    /**
+     * 根据字典类型查询字典数据信息,跳过token
+     */
+    @Anonymous
+    @GetMapping(value = "/type/skipToken/{dictType}")
+    public AjaxResult skipToken(@PathVariable String dictType)
+    {
+        List<SysDictData> data = dictTypeService.selectDictDataByType(dictType);
+        if (StringUtils.isNull(data))
+        {
+            data = new ArrayList<SysDictData>();
+        }
+        return success(data);
+    }
 
     /**
      * 新增字典类型

ruoyi-admin/src/main/java/com/ruoyi/web/controller/wisdomarbitrate/mscase/MsCaseApplicationController.java

@@ -73,6 +73,7 @@ public class MsCaseApplicationController extends BaseController {
     /**
      * 新增案件
      */
+    // todo 重复提交校验
     @PostMapping("/insert")
     public AjaxResult insert(@RequestBody MsCaseApplicationVO caseApplication )
     {

ruoyi-admin/src/main/java/com/ruoyi/web/controller/wisdomarbitrate/mscase/MsSignSealController.java

@@ -77,6 +77,22 @@ public class MsSignSealController  extends BaseController {
 
     }
 
+    /**
+     * 印章审核回调
+     */
+    @Anonymous
+    @PostMapping("/sealCheckCallback")
+    public AjaxResult sealCheckCallback() throws Exception {
+        boolean checkResult= SignVerifyUtils.checkSignuter();
+        if(checkResult){
+            String reqbodystr =SignVerifyUtils.getRequestBody();
+            return msSignSealService.sealCheckCallback(reqbodystr);
+        }else {
+            return AjaxResult.error("error");
+        }
+
+    }
+
     /**
      * 查询案件进度
      */

ruoyi-admin/src/main/resources/application.yml

@@ -18,7 +18,7 @@ ruoyi:
 # 开发环境配置
 server:
   # 测试环境6001，开发环境7001
-  port: 6001
+  port: 7001
   servlet:
     # 应用的访问路径
     context-path: /
@@ -193,7 +193,7 @@ arbitrateConfig:
   url: http://121.40.189.20:9001/callArbitrateCaseApplication/generateCaseApplication
 # 回调通知
 signSealCallbackConfig:
-  url: http://121.40.189.20:6001/mssignSeal/signSeaalCaseApplicaCallback
+  url: http://121.40.189.20:7001/mssignSeal/signSeaalCaseApplicaCallback
 #  onlyOffice系统url配置
 onlyOfficeConfig:
 #  url: http://172.16.0.254:9090/files/upload

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/mapper/dept/DeptIdentifyMapper.java

@@ -3,6 +3,7 @@ package com.ruoyi.wisdomarbitrate.mapper.dept;
 import com.ruoyi.wisdomarbitrate.domain.dto.dept.DeptIdentify;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
+import tk.mybatis.mapper.entity.Example;
 
 import java.util.List;
 
@@ -24,4 +25,5 @@ public interface DeptIdentifyMapper {
      * @return
      */
     String selectById(@Param("id") Long identifyId);
+
 }

ruoyi-system/src/main/java/com/ruoyi/wisdomarbitrate/service/mscase/MsSignSealService.java

@@ -37,4 +37,6 @@ public interface MsSignSealService {
     AjaxResult msCaseSignUrlResAPP(MsSignSealDTO dto) throws EsignDemoException;
 
     AjaxResult signSeaalCaseApplicaCallback(String reqbodystr) throws EsignDemoException, IOException;
+
+    AjaxResult sealCheckCallback(String reqbodystr) throws EsignDemoException, IOException;
 }

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

@@ -1865,7 +1865,7 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
         // 申请人预约
         if (vo.getMiniProgressFlag() == null || vo.getMiniProgressFlag().equals( YesOrNoEnum.NO.getCode())) {
             // 新增日志
-            CaseLogUtils.insertCaseLog(vo.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), "申请人选择调解员");
+            CaseLogUtils.insertCaseLog(vo.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), null);
 
             if (StrUtil.isEmpty(msCaseAffiliate.getRespondentIdentityNum())) {
                 return AjaxResult.error("被申请人身份证为空");
@@ -1876,7 +1876,7 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
         } else {
             // 被申请人预约
             // 新增日志
-            CaseLogUtils.insertCaseLog(vo.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), "被申请人选择调解员");
+            CaseLogUtils.insertCaseLog(vo.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), null);
             // 判断申请人是否预约
             caseApplicationService. isReservation( vo,userIds);
 
@@ -2225,6 +2225,7 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
         if (currentFlow == null) {
             throw new ServiceException("未找到当前流程节点");
         }
+        Integer mediaResult = req.getMediaResult();
         MsCaseAffiliate caseAffiliate = msCaseAffiliateMapper.selectByPrimaryKey(req.getId());
         if (application.getMediationMethod().equals("1")) {
             // 线上调解
@@ -2237,9 +2238,7 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
                     msCaseAttachMapper.updateCaseAttach(attach);
                 }
             }
-            Integer mediaResult = req.getMediaResult();
-            if(mediaResult!=null){
-                if(mediaResult.intValue()==1){
+                if(mediaResult ==1){
                     //达成调解
                         List<MsCaseAttach> caseAttachList = msCaseAttachMapper.queryAnnexPathByCaseId(req.getId());
                         if (caseAttachList != null && caseAttachList.size() > 0) {
@@ -2898,7 +2897,7 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
                         }
                 }
 
-            }
+
         } else {
             // 线下调解
             List<MsCaseAttach> attachList = req.getAttachList();
@@ -2911,14 +2910,45 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
                 attach.setCaseAppliId(req.getId());
                 msCaseAttachMapper.updateCaseAttach(attach);
             }
-           // msCaseAttachMapper.batchSave(attachList);
             // 修改案件状态为待送达
             Example flowExample = new Example(MsCaseFlow.class);
-            flowExample.createCriteria().andEqualTo("caseStatusName", "待送达");
+            if(mediaResult ==1 || mediaResult == 5){
+                // 达成调解，达成和解，案件状态改为待送达
+                flowExample.createCriteria().andEqualTo("caseStatusName", "待送达");
+            } else if(mediaResult == 2 || mediaResult == 3){
+                // 未达成调解，未达成调解但不在争议改为结束状态
+                flowExample.createCriteria().andEqualTo("caseStatusName", "结束");
+            }
+            else if(mediaResult == 4){
+                //  未达成调解但同意引入仲裁系统，改为结束状态，并调仲裁新增接口
+                flowExample.createCriteria().andEqualTo("caseStatusName", "结束");
+                String accessSec = "mCFMA6ffe938v79m";
+                MsCaseApplicationVO applicationVO = new MsCaseApplicationVO();
+                BeanUtils.copyProperties(application,applicationVO);
+
+                CaseApplicationVO caseApplicationVO = new CaseApplicationVO();
+                BeanUtils.copyProperties(applicationVO,caseApplicationVO);
+                boolean importFlag = applicationVO.isImportFlag();
+                if(importFlag==true){
+                    caseApplicationVO.setImportFlag(1);
+                }else {
+                    caseApplicationVO.setImportFlag(0);
+                }
+                String paramsbody = JSONUtil.toJsonStr(caseApplicationVO);
+                long timestamp = System.currentTimeMillis();
+                String signStr = SignCheckUtils.getSign(paramsbody, accessSec, timestamp);
+                String urlstr = arbitrateUrl;
+                HttpResponse httpResponse = HttpRequest.post(urlstr)
+                        .header("timestampstr", String.valueOf(timestamp))
+                        .header("signstr", signStr)
+                        .body(paramsbody)
+                        .execute();
+            }
             MsCaseFlow caseFlow = caseFlowMapper.selectOneByExample(flowExample);
             if(caseFlow != null){
                 application.setCaseFlowId(caseFlow.getId());
                 application.setCaseStatusName(caseFlow.getCaseStatusName());
+                application.setMediaResult(mediaResult);
                 msCaseApplicationMapper.updateByPrimaryKey(application);
                 // 新增日志
                 CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),"");
@@ -2927,7 +2957,7 @@ public class MsCaseApplicationServiceImpl implements MsCaseApplicationService {
         }
 
 
-        return AjaxResult.error();
+        return AjaxResult.success();
     }
 
     /**

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

@@ -350,7 +350,7 @@ public class MsCasePaymentServiceImpl implements MsCasePaymentService {
         }
         // 新增日志
         if (dto.getYesOrNo().equals(YesOrNoEnum.YES.getCode())) {
-            CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), "确认已缴费");
+            CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), null);
         }else {
             CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(), "拒绝确认缴费，拒绝原因为："+dto.getReason());
         }
@@ -509,7 +509,7 @@ public class MsCasePaymentServiceImpl implements MsCasePaymentService {
         application.setCaseFlowId(nextFlow.getId());
         application.setCaseStatusName(nextFlow.getCaseStatusName());
         caseApplicationMapper.updateByPrimaryKeySelective(application);
-        CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),"确认缴费");
+        CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),null);
     }
 
 

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

@@ -411,7 +411,7 @@ public class MsSignSealServiceImpl implements MsSignSealService {
                 application.setCaseFlowId(nextFlow.getId());
                 application.setCaseStatusName(nextFlow.getCaseStatusName());
                 caseApplicationMapper.updateByPrimaryKeySelective(application);
-                CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),"用印申请");
+                CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),null);
             }
         } else {
             // 单独
@@ -421,7 +421,7 @@ public class MsSignSealServiceImpl implements MsSignSealService {
             application.setCaseFlowId(nextFlow.getId());
             application.setCaseStatusName(nextFlow.getCaseStatusName());
             caseApplicationMapper.updateByPrimaryKeySelective(application);
-            CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),"用印申请");
+            CaseLogUtils.insertCaseLog(application.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),null);
         }
         return AjaxResult.success("用印申请成功");
 
@@ -786,7 +786,7 @@ public class MsSignSealServiceImpl implements MsSignSealService {
             caseApplicationselect.setCaseFlowId(nextFlow.getId());
             caseApplicationselect.setCaseStatusName(nextFlow.getCaseStatusName());
             caseApplicationMapper.updateByPrimaryKeySelective(caseApplicationselect);
-            CaseLogUtils.insertCaseLog(caseApplicationselect.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),"签收");
+            CaseLogUtils.insertCaseLog(caseApplicationselect.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),null);
         }
 //        if (dto.getIsSignRespon() != null && dto.getIsSignRespon().intValue() == 1) {
 //            caseAffiliate.setIsSignRespon(1);
@@ -810,7 +810,7 @@ public class MsSignSealServiceImpl implements MsSignSealService {
             caseApplicationselect.setCaseFlowId(nextFlow.getId());
             caseApplicationselect.setCaseStatusName(nextFlow.getCaseStatusName());
             caseApplicationMapper.updateByPrimaryKeySelective(caseApplicationselect);
-            CaseLogUtils.insertCaseLog(caseApplicationselect.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),"签收");
+            CaseLogUtils.insertCaseLog(caseApplicationselect.getId(), currentFlow.getNodeId(), currentFlow.getCaseStatusName(),null);
         }
 
         return AjaxResult.success("签收成功");
@@ -1056,8 +1056,6 @@ public class MsSignSealServiceImpl implements MsSignSealService {
             MsCaseFlow currentFlow = caseFlowMapper.selectByPrimaryKey(caseApplicationselect.getCaseFlowId());
             Integer caseNode = currentFlow.getNodeId();
             String caseStatusName = currentFlow.getCaseStatusName();
-
-
             if("SIGN_MISSON_COMPLETE".equals(action) && signResult==2){
                 if(mediaResult.intValue()==1){
                     //调解
@@ -1344,6 +1342,86 @@ public class MsSignSealServiceImpl implements MsSignSealService {
         return AjaxResult.success("success");
     }
 
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public AjaxResult sealCheckCallback(String reqbodystr) throws EsignDemoException, IOException {
+        JSONObject jsonObjectCallback = JSONObject.parseObject(reqbodystr);
+        Gson gson = new Gson();
+        if (jsonObjectCallback != null) {
+            int auditStatus = jsonObjectCallback.getIntValue("auditStatus");
+            String action = jsonObjectCallback.getString("action");
+            String orgId = jsonObjectCallback.getString("orgId");
+            String sealId = jsonObjectCallback.getString("sealId");
+
+            SealManage sealManage = new SealManage();
+            DeptIdentify deptIdentify1 = new DeptIdentify();
+            deptIdentify1.setOrgId(orgId);
+            List<DeptIdentify> deptIdentifies = deptIdentifyMapper.selectDeptIdentify(deptIdentify1);
+            if (deptIdentifies != null && deptIdentifies.size() > 0) {
+                Long iddeptIdent = deptIdentifies.get(0).getId();
+                SealManage sealManageSel = new SealManage();
+                sealManageSel.setIdentifyId(iddeptIdent);
+                sealManageSel.setSealId(sealId);
+                List<String> sealIdList = new ArrayList<>();
+                List<SealManage> selectSealList = sealManageMapper.selectSealList(sealManageSel);
+                if (selectSealList != null && selectSealList.size() > 0) {
+                    sealManage = selectSealList.get(0);
+                }
+            }
+
+            if("SEAL_AUDIT".equals(action) && auditStatus==1){
+                EsignHttpResponse response = SignAward.getOrgSeal(orgId, sealId);
+                JSONObject jsonObject = JSONObject.parseObject(response.getBody());
+                int code = jsonObject.getIntValue("code");
+                if (code == 0) {
+                    JSONObject data = jsonObject.getJSONObject("data");
+                    int sealStatus = data.getIntValue("sealStatus");
+                    if (sealStatus == 1) {//印章状态 1已启用，2待审核，3审核不通过，4 挂起
+                        //已启用证明审核通过,下载到数据库
+                        String sealImageDownloadUrl = data.getString("sealImageDownloadUrl");
+                        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("-", "") + ".jpg";
+                        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();
+                        }
+                        boolean downLoadFile = FileTransformation.downLoadFileByUrl(sealImageDownloadUrl, resultFilePath);
+                        if (downLoadFile) {
+                            MsCaseAttach caseAttach = new MsCaseAttach();
+                            caseAttach.setAnnexType(AnnexTypeEnum.SEAL_PICTURE.getCode());  //10代表印章图片
+                            caseAttach.setAnnexPath(savePath);
+                            caseAttach.setAnnexName(saveName);
+                            int i1 = caseAttachMapper.save(caseAttach);
+                            if (i1 > 0) {
+                                //将附件id保存到公章管理表里
+                                Long annexId1 = caseAttach.getAnnexId();
+                                sealManage.setAnnexId(annexId1);
+                                sealManage.setSealStatus(1);
+                                sealManage.setIsUse(0);
+                                sealManageMapper.updateSealManage(sealManage);
+                            }
+                        }
+                    }
+                }
+            }
+        }else{
+            return AjaxResult.error("error");
+        }
+        return AjaxResult.success("success");
+    }
+
     /**
      * 通过邮件发送裁决书文件
      *

ruoyi-system/src/main/resources/generator/config.properties

@@ -7,6 +7,6 @@ targetprojectpath=D:/ymPro/Mediation-Backend/ruoyi-system/src/main/resources/map
 #模块名称
 moduleName=mscase
 #表名
-tableName=ms_case_affiliate
+tableName=ms_case_audit
 #主键
 premaryId=id

ruoyi-system/src/main/resources/mapper/wisdomarbitrate/dept/SealManageMapper.xml

@@ -23,6 +23,9 @@
             <if test="sealStatus != null">
                 AND seal_status = #{sealStatus}
             </if>
+            <if test="sealId != null  and sealId != ''">
+                AND seal_id = #{sealId}
+            </if>
         </where>
     </select>