1：状态轮训接口封装

ruoyi-system/src/main/java/com/ruoyi/opt/service/impl/ProcessInfoServiceImpl.java

@@ -101,33 +101,10 @@ public class ProcessInfoServiceImpl implements IProcessInfoService
     {
         try {
             String status = processInfo.getProcessStsCd();
-            CompanyInfo companyInfo = companyInfoMapper.selectCompanyInfoByCompanyId(processInfo.getCompanyId());
             processInfo.setUpdateTime(DateUtils.getNowDate());
             //判断是什么操作，如果是03 04表示是审核操作   05表示已支付操作
             if ("03".equals(status) || "04".equals(status)){
-                //审核操作,先组装参数
-                CheckInformBo checkInformBo = new CheckInformBo();
-                if ("04".equals(status)){   //审核通过
-                    checkInformBo.setCode("01");
-                } else {   //审核不通过
-                    checkInformBo.setCode("02");
-                    checkInformBo.setMessage(processInfo.getRejectReason());   //拒绝原因
-                }
-                checkInformBo.setProcessId(processInfo.getProcessId());
-                checkInformBo.setApplyPolicyNo(null);    //投保单号
-                checkInformBo.setPremium(processInfo.getPremiumAmt());    //保费
-                checkInformBo.setTotalAmt(processInfo.getLoanAmt());       //保额
-                //开户行
-                if (!ObjectUtils.isEmpty(companyInfo)){
-                    checkInformBo.setSkKHH(companyInfo.getBasicAccountBank());    //收款开户行
-                    checkInformBo.setSkAccount(companyInfo.getBasicAccountNo());   //收款账号
-                }
-                checkInformBo.setPostscript(processInfo.getPostscript());
-                String checkJsonString = JSONObject.valueAsStr(checkInformBo);
-                //http请求调用
-                String testCheckUrl = testHttps + checklUrl;
-                String prodCheckUrl = prodHttps + checklUrl;
-                String checkResult = HttpUtils.sendPost(testCheckUrl, checkJsonString);
+                String checkResult = getCheckInform(processInfo);
                 //解析json结果
                 Map<String, Object> resultMap = JSON.parseObject(checkResult, Map.class);
                 if ("0000".equals(resultMap.get("code").toString())){
@@ -137,23 +114,7 @@ public class ProcessInfoServiceImpl implements IProcessInfoService
                     return AjaxResult.error(resultMap.get("message").toString());
                 }
             } else if ("05".equals(processInfo.getProcessStsCd())){
-                //已支付操作   开始组装参数
-                PayInfomBo payInfomBo = new PayInfomBo();
-                payInfomBo.setProcessId(processInfo.getProcessId());
-                payInfomBo.setApplyPolicyNo(null);    //投保单号
-                if (!ObjectUtils.isEmpty(companyInfo)){
-                    payInfomBo.setCompanyName(companyInfo.getCompanyNm());
-                    payInfomBo.setCompanySocialNo(companyInfo.getCompanySocialNo());
-                    payInfomBo.setPayAccountName(null);
-                    payInfomBo.setPayBank(companyInfo.getBasicAccountBank());
-                    payInfomBo.setPayAccount(companyInfo.getBasicAccountNo());
-                }
-                payInfomBo.setCost(null);
-                String payJsonString = JSONObject.valueAsStr(payInfomBo);
-                //http请求调用
-                String testPayUrl = testHttps + payUrl;
-                String prodPayUrl = prodHttps + payUrl;
-                String payResult = HttpUtils.sendPost(testPayUrl, payJsonString);
+                String payResult = getPayInform(processInfo);
                 //解析json结果
                 Map<String, Object> resultMap = JSON.parseObject(payResult, Map.class);
                 if ("0000".equals(resultMap.get("code").toString())){
@@ -173,6 +134,83 @@ public class ProcessInfoServiceImpl implements IProcessInfoService
             return AjaxResult.error("订单修改失败，未知错误，请联系相关人员！");
         }
     }
+    
+    
+    /**
+    * @desc : 封装审核参数并返回
+    * @author : wangming
+    * @createTime : 2022/9/8 9:12
+    * @param : [pIds]
+    * @return : int
+    */
+    private String getCheckInform(ProcessInfo processInfoParam){
+        //开始组装参数
+        Long pid = processInfoParam.getpId();   //拿到主键id
+        String status = processInfoParam.getProcessStsCd();  //状态
+        //查询订单表信息
+        ProcessInfo processInfo = processInfoMapper.selectProcessInfoByPId(pid);
+        //查询企业信息
+        CompanyInfo companyInfo = companyInfoMapper.selectCompanyInfoByCompanyId(processInfo.getCompanyId());
+        //审核操作,先组装参数
+        CheckInformBo checkInformBo = new CheckInformBo();
+        if ("04".equals(status)){   //审核通过
+            checkInformBo.setCode("01");
+        } else {   //审核不通过
+            checkInformBo.setCode("02");
+            checkInformBo.setMessage(processInfo.getRejectReason());   //拒绝原因
+        }
+        checkInformBo.setProcessId(processInfo.getProcessId());
+        checkInformBo.setApplyPolicyNo(null);    //投保单号
+        checkInformBo.setPremium(processInfo.getPremiumAmt());    //保费
+        checkInformBo.setTotalAmt(processInfo.getLoanAmt());       //保额
+        //开户行
+        if (!ObjectUtils.isEmpty(companyInfo)){
+            checkInformBo.setSkKHH(companyInfo.getBasicAccountBank());    //收款开户行
+            checkInformBo.setSkAccount(companyInfo.getBasicAccountNo());   //收款账号
+        }
+        checkInformBo.setPostscript(processInfo.getPostscript());
+        String checkJsonString = JSONObject.valueAsStr(checkInformBo);
+        //http请求调用
+        String testCheckUrl = testHttps + checklUrl;
+        String prodCheckUrl = prodHttps + checklUrl;
+        String checkResult = HttpUtils.sendPost(testCheckUrl, checkJsonString);
+        return checkResult;
+    }
+
+    /**
+    * @desc : 封装支付参数并返回
+    * @author : wangming
+    * @createTime : 2022/9/8 9:38
+    * @param : []
+    * @return : java.lang.String
+    */
+    private String getPayInform(ProcessInfo processInfoParam){
+        //开始组装参数
+        Long pid = processInfoParam.getpId();   //拿到主键id
+        String status = processInfoParam.getProcessStsCd();  //状态
+        //查询订单表信息
+        ProcessInfo processInfo = processInfoMapper.selectProcessInfoByPId(pid);
+        //查询企业信息
+        CompanyInfo companyInfo = companyInfoMapper.selectCompanyInfoByCompanyId(processInfo.getCompanyId());
+        //已支付操作   开始组装参数
+        PayInfomBo payInfomBo = new PayInfomBo();
+        payInfomBo.setProcessId(processInfo.getProcessId());
+        payInfomBo.setApplyPolicyNo(null);    //投保单号
+        if (!ObjectUtils.isEmpty(companyInfo)){
+            payInfomBo.setCompanyName(companyInfo.getCompanyNm());
+            payInfomBo.setCompanySocialNo(companyInfo.getCompanySocialNo());
+            payInfomBo.setPayAccountName(null);
+            payInfomBo.setPayBank(companyInfo.getBasicAccountBank());
+            payInfomBo.setPayAccount(companyInfo.getBasicAccountNo());
+        }
+        payInfomBo.setCost(null);
+        String payJsonString = JSONObject.valueAsStr(payInfomBo);
+        //http请求调用
+        String testPayUrl = testHttps + payUrl;
+        String prodPayUrl = prodHttps + payUrl;
+        String payResult = HttpUtils.sendPost(testPayUrl, payJsonString);
+        return payResult;
+    }
 
     /**
      * 批量删除保函订单