提款状态查询定时任务接口开发

src/main/java/com/sunxung/factoring/entity/smb/FinancingLoanInfo.java

@@ -43,6 +43,12 @@ public class FinancingLoanInfo extends BaseEntity {
     @TableField("customer_type")
     private Integer customerType;
 
+    /**
+     * 用户唯一标识
+     */
+    @TableField("open_id")
+    private String openId;
+
     /**
      * 供应商企业信息Id
      */
@@ -55,6 +61,12 @@ public class FinancingLoanInfo extends BaseEntity {
     @TableField(exist = false)
     private String supplierName;
 
+    /**
+     * 供应商统一社会信用代码
+     */
+    @TableField(exist = false)
+    private String socialCreditCode;
+
     /**
      * 资方ID
      */
@@ -348,6 +360,22 @@ public class FinancingLoanInfo extends BaseEntity {
         this.supplierName = supplierName;
     }
 
+    public String getSocialCreditCode() {
+        return socialCreditCode;
+    }
+
+    public void setSocialCreditCode(String socialCreditCode) {
+        this.socialCreditCode = socialCreditCode;
+    }
+
+    public String getOpenId() {
+        return openId;
+    }
+
+    public void setOpenId(String openId) {
+        this.openId = openId;
+    }
+
     @Override
     public String toString() {
         return "FinancingLoanInfo{" +

src/main/java/com/sunxung/factoring/job/impl/SmbTaskJob.java

@@ -1,6 +1,7 @@
 package com.sunxung.factoring.job.impl;
 
 import com.sunxung.factoring.service.smb.IFinancingFromInvestorsService;
+import com.sunxung.factoring.service.smb.IFinancingLoanInfoService;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -22,6 +23,8 @@ public class SmbTaskJob {
     @Autowired
     private IFinancingFromInvestorsService financingFromInvestorsService;
 
+    @Autowired
+    private IFinancingLoanInfoService financingLoanInfoService;
 
     @Scheduled(cron = "0 0/30 * * * ?")
     public void process() {
@@ -30,4 +33,13 @@ public class SmbTaskJob {
         log.info("苏商定时任务任务执行结束...");
     }
 
+    /**
+     * 苏商提款状态查询接口（每小时执行一次）
+     */
+    @Scheduled(cron = "0 0 */1 * * ?")
+    public void withdrawStatusProcess() {
+        log.info("苏商提款状态查询定时任务执行开始...");
+        financingLoanInfoService.withdrawStatusQuery();
+        log.info("苏商提款状态查询定时任务执行结束...");
+    }
 }

src/main/java/com/sunxung/factoring/service/smb/IFinancingLoanInfoService.java

@@ -1,8 +1,8 @@
 package com.sunxung.factoring.service.smb;
 
+import com.baomidou.mybatisplus.extension.service.IService;
 import com.sunxung.factoring.entity.GridPage;
 import com.sunxung.factoring.entity.smb.FinancingLoanInfo;
-import com.baomidou.mybatisplus.extension.service.IService;
 import com.sunxung.factoring.entity.smb.vo.FinancingLoanInfoSearch;
 
 /**
@@ -30,4 +30,9 @@ public interface IFinancingLoanInfoService extends IService<FinancingLoanInfo> {
      * @return
      */
     FinancingLoanInfo getDetail(Long id);
+
+    /**
+     * 提款状态查询
+     */
+    void withdrawStatusQuery();
 }

src/main/java/com/sunxung/factoring/service/smb/impl/FinancingLoanInfoServiceImpl.java

@@ -1,5 +1,7 @@
 package com.sunxung.factoring.service.smb.impl;
 
+import cn.hutool.core.collection.CollectionUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
@@ -10,8 +12,11 @@ import com.sunxung.factoring.entity.smb.vo.FinancingLoanInfoSearch;
 import com.sunxung.factoring.mapper.smb.FinancingLoanInfoMapper;
 import com.sunxung.factoring.service.entprise.IEnterpriseService;
 import com.sunxung.factoring.service.smb.IFinancingLoanInfoService;
+import com.sunxung.factoring.service.smbApi.api.SMBApiService;
+import com.sunxung.factoring.service.smbApi.resp.LoanApplyStatusResp;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
 
@@ -28,6 +33,8 @@ public class FinancingLoanInfoServiceImpl extends ServiceImpl<FinancingLoanInfoM
 
     @Autowired
     private IEnterpriseService enterpriseService;
+    @Autowired
+    private SMBApiService smbApiService;
 
     @Override
     public GridPage<FinancingLoanInfo> findBySearch(FinancingLoanInfoSearch search) {
@@ -44,8 +51,37 @@ public class FinancingLoanInfoServiceImpl extends ServiceImpl<FinancingLoanInfoM
             Enterprise enterprise = enterpriseService.getById(financingLoanInfo.getcEnterpriseId());
             if (enterprise != null) {
                 financingLoanInfo.setSupplierName(enterprise.getCorporateName());
+                financingLoanInfo.setSocialCreditCode(enterprise.getSocialCreditCode());
             }
         }
         return financingLoanInfo;
     }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void withdrawStatusQuery() {
+        //查询所有放款状态为处理中的放款信息
+        List<FinancingLoanInfo> loanInfoList = list(new QueryWrapper<FinancingLoanInfo>().eq("payout_status", "01"));
+        if (CollectionUtil.isNotEmpty(loanInfoList)) {
+            for (FinancingLoanInfo loanInfo : loanInfoList) {
+                LoanApplyStatusResp loanApplyStatusResp = smbApiService.loanApplyStatusQuery(loanInfo.getOpenId(), loanInfo.getPayoutNo());
+                if (loanApplyStatusResp != null) {
+                    //借据编号
+                    loanInfo.setDueBillNo(loanApplyStatusResp.getDuebillNo());
+                    //到期日期
+                    loanInfo.setMaturityDate(loanApplyStatusResp.getMaturity());
+                    //提款申请日期
+                    loanInfo.setLoanApplyDate(loanApplyStatusResp.getLoanApplyTime());
+                    //放款日期
+                    loanInfo.setPayoutDate(loanApplyStatusResp.getPayoutDate());
+                    //放款状态
+                    loanInfo.setPayoutStatus(loanApplyStatusResp.getStatus());
+                    //放款金额
+                    loanInfo.setLoanAmount(loanApplyStatusResp.getBusiAmt());
+                    updateById(loanInfo);
+                }
+            }
+        }
+
+    }
 }

src/main/java/com/sunxung/factoring/service/smbApi/api/impl/SMBApiServiceImpl.java

@@ -219,7 +219,8 @@ public class SMBApiServiceImpl implements SMBApiService {
         loanApplyStatusQuery.setProductCode(smbConfiguration.getProductCode());
         loanApplyStatusQuery.setSysCode(smbConfiguration.getSysCode());
         loanApplyStatusQuery.setPlatformCode(smbConfiguration.getPlatformCode());
-        loanApplyStatusQuery.setBizNo(bizNo);
+        loanApplyStatusQuery.setPayoutNo(bizNo);
+      //  loanApplyStatusQuery.setBizNo(bizNo);
         SnbRequestBean snbRequestBean = new SnbRequestBean();
         snbRequestBean.setPayLoadBean(loanApplyStatusQuery);
         snbRequestBean.setOpenId(openId);

src/main/java/com/sunxung/factoring/web/smb/FinancingLoanInfoController.java

@@ -1,6 +1,7 @@
 package com.sunxung.factoring.web.smb;
 
 import com.sunxung.factoring.entity.GridPage;
+import com.sunxung.factoring.entity.ResponseJson;
 import com.sunxung.factoring.entity.smb.FinancingFromInvestors;
 import com.sunxung.factoring.entity.smb.FinancingLoanInfo;
 import com.sunxung.factoring.entity.smb.vo.FinancingFromInvestorsSearchVo;
@@ -36,7 +37,7 @@ public class FinancingLoanInfoController {
      * @return
      */
     @GetMapping("/detail")
-    public FinancingLoanInfo getDetail(Long id){
-        return financingLoanInfoService.getDetail(id);
+    public ResponseJson<FinancingLoanInfo> getDetail(Long id){
+        return new ResponseJson<>(financingLoanInfoService.getDetail(id));
     }
 }

src/main/resources/data/update/smb0826.sql

@@ -30,6 +30,7 @@ CREATE TABLE `financing_loan_info` (
         `quota_disburse_batch` int(11) DEFAULT NULL COMMENT '额度支用批次',
         `customer_type` tinyint(1) DEFAULT NULL COMMENT '客户类型',
         `c_enterprise_id` bigint(20) DEFAULT NULL COMMENT '供应商企业信息Id',
+        `open_id` varchar(100) DEFAULT '' COMMENT '用户唯一标识',
         `financing_management_id` bigint(20) DEFAULT NULL  COMMENT '资方ID',
         `financing_institution_name` varchar(200) DEFAULT NULL COMMENT '资方名称',
         `loan_amount` varchar(50) DEFAULT NULL COMMENT '放款金额',

src/main/resources/mapper/smb/FinancingLoanInfoMapper.xml

@@ -15,6 +15,7 @@
         <result column="customer_type" property="customerType" />
         <result column="c_enterprise_id" property="cEnterpriseId" />
         <result column="corporate_name" property="supplierName" />
+        <result column="open_id" property="openId" />
         <result column="financing_management_id" property="financingManagementId" />
         <result column="financing_institution_name" property="financingInstitutionName" />
         <result column="loan_amount" property="loanAmount" />