Browse Source

1:承保回调接口

wangming 2 years ago
parent
commit
b3b92ee0ee

+ 7 - 5
ruoyi-admin/src/main/java/com/ruoyi/web/controller/opt/OptController.java

@@ -130,24 +130,26 @@ public class OptController {
     public R coverTheCallback(@RequestBody CoverBo coverBo){
         try {
             //接到消息开始拆解参数
+            log.info("1111111111111111111111111开始");
             if (!ObjectUtils.allNotNull(coverBo)){
                 return R.paramNull("参数不可为空!");
             }
             //拿到参数开始入库修改
-            LambdaUpdateWrapper<ProcessInfo> updateWrapper = new UpdateWrapper<ProcessInfo>().lambda();
+            /*LambdaUpdateWrapper<ProcessInfo> updateWrapper = new UpdateWrapper<ProcessInfo>().lambda();
             updateWrapper.eq(ProcessInfo::getProcessId, coverBo.getProcessId())
                     .set(ProcessInfo::getPolicyDlUrl, coverBo.getPolicyDlUrl())
                     .set(ProcessInfo::getProcessStsCd, coverBo.getStatus());
-            boolean update = processInfoService.update(null, updateWrapper);
+            boolean update = processInfoService.update(null, updateWrapper);*/
+            ProcessInfo processInfo1 = new ProcessInfo();
+            processInfo1.setProcessId(coverBo.getProcessId());
+            processInfoService.updateProcessInfoByProcessId(processInfo1);
             //修改成功,去调www承保回调接口    组装参数
             ProcessBo processBo = new ProcessBo();
             processBo.setProcessId(coverBo.getProcessId());
             processBo.setAppId(coverBo.getAppId());
             processBo.setSign("uAQMdCTPJl48zDYZ6\\/BrpfsYaBAk6LY5YFBidLhQvGc=");
             //查出来保单信息
-            LambdaQueryWrapper<ProcessInfo> queryWrapper = new QueryWrapper<ProcessInfo>().lambda().eq(ProcessInfo::getProcessId, coverBo.getProcessId());
-            ProcessInfo processInfo = processInfoService.getOne(queryWrapper);
-            processBo.setPolicyDlUrl(processInfo.getPolicyDlUrl());
+            processBo.setPolicyDlUrl(coverBo.getPolicyDlUrl());
 
             String coverParam = JSONObject.valueAsStr(processBo);
             String coverHttpUrl = testHttps + coverUrl;

+ 12 - 1
ruoyi-system/src/main/java/com/ruoyi/opt/mapper/ProcessInfoMapper.java

@@ -4,6 +4,8 @@ import java.util.List;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.ruoyi.opt.domain.ProcessInfo;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
 
 /**
  * 保函订单Mapper接口
@@ -11,8 +13,17 @@ import com.ruoyi.opt.domain.ProcessInfo;
  * @author chengpan
  * @date 2022-09-06
  */
-public interface ProcessInfoMapper extends BaseMapper<ProcessInfo>
+public interface ProcessInfoMapper /*extends BaseMapper<ProcessInfo>*/
 {
+    /**
+     * 查询保函订单
+     *
+     * @param pId 保函订单主键
+     * @return 保函订单
+     */
+    public int updateProcessInfoByProcessId(ProcessInfo processInfo);
+
+
     /**
      * 查询保函订单
      * 

+ 12 - 1
ruoyi-system/src/main/java/com/ruoyi/opt/service/IProcessInfoService.java

@@ -12,8 +12,19 @@ import com.ruoyi.opt.domain.ProcessInfo;
  * @author chengpan
  * @date 2022-09-06
  */
-public interface IProcessInfoService extends IService<ProcessInfo>
+public interface IProcessInfoService /*extends IService<ProcessInfo>*/
 {
+
+
+    /**
+     * 根据processId修改
+     *
+     * @param pId 保函订单主键
+     * @return 保函订单
+     */
+    public int updateProcessInfoByProcessId(ProcessInfo processInfo);
+
+
     /**
      * 查询保函订单
      * 

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

@@ -38,7 +38,7 @@ import org.springframework.util.ObjectUtils;
 @Service
 @EnableTransactionManagement
 @Slf4j
-public class ProcessInfoServiceImpl extends ServiceImpl<ProcessInfoMapper, ProcessInfo> implements IProcessInfoService
+public class ProcessInfoServiceImpl /*extends ServiceImpl<ProcessInfoMapper, ProcessInfo>*/ implements IProcessInfoService
 {
     @Autowired
     private ProcessInfoMapper processInfoMapper;
@@ -58,6 +58,12 @@ public class ProcessInfoServiceImpl extends ServiceImpl<ProcessInfoMapper, Proce
     @Value("${templateUrl}")
     private String templateUrl;
 
+    @Override
+    public int updateProcessInfoByProcessId(ProcessInfo processInfo) {
+        int i = processInfoMapper.updateProcessInfoByProcessId(processInfo);
+        return i;
+    }
+
     /**
      * 查询保函订单
      * 

+ 24 - 0
ruoyi-system/src/main/resources/mapper/opt/ProcessInfoMapper.xml

@@ -123,6 +123,30 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         where p_id = #{pId}
     </update>
 
+    <update id="updateProcessInfoByProcessId" parameterType="ProcessInfo">
+        update t_process_info
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="processId != null">process_id = #{processId},</if>
+            <if test="processStsCd != null">process_sts_cd = #{processStsCd},</if>
+            <if test="premiumAmt != null">premium_amt = #{premiumAmt},</if>
+            <if test="loanAmt != null">loan_amt = #{loanAmt},</if>
+            <if test="policySignUrl != null">policy_sign_url = #{policySignUrl},</if>
+            <if test="policyDlUrl != null">policy_dl_url = #{policyDlUrl},</if>
+            <if test="eInvoiceUrl != null">e_invoice_url = #{eInvoiceUrl},</if>
+            <if test="projectId != null">project_id = #{projectId},</if>
+            <if test="companyId != null">company_id = #{companyId},</if>
+            <if test="expireTime != null">expire_time = #{expireTime},</if>
+            <if test="approvedTime != null">approved_time = #{approvedTime},</if>
+            <if test="postscript != null">postscript = #{postscript},</if>
+            <if test="rejectReason != null">reject_reason = #{rejectReason},</if>
+            <if test="applyTime != null">apply_time = #{applyTime},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+        </trim>
+        where process_id = #{processId}
+    </update>
+
     <delete id="deleteProcessInfoByPId" parameterType="Long">
         delete from t_process_info where p_id = #{pId}
     </delete>