Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
C
cash-loan-flow-boss
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
QG
cash-loan-flow-boss
Commits
a8cb175b
Commit
a8cb175b
authored
Feb 21, 2020
by
shangying
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
提现给h5提现留入口,修复和增了异常处理逻辑
parent
4cf776fe
Changes
6
Show whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
74 additions
and
21 deletions
+74
-21
CashWithdrawalServiceImpl.java
.../oneclickdata/service/impl/CashWithdrawalServiceImpl.java
+32
-18
LoanOperationServiceImpl.java
...i/oneclickdata/service/impl/LoanOperationServiceImpl.java
+10
-1
OneClickDataOperateJobServiceImpl.java
...kdata/service/impl/OneClickDataOperateJobServiceImpl.java
+1
-1
OneClickDataQueueOperateServiceImpl.java
...ata/service/impl/OneClickDataQueueOperateServiceImpl.java
+2
-1
GuBeiBataSourceConfiguration.java
...ss/spi/paycenter/source/GuBeiBataSourceConfiguration.java
+15
-0
GuBeiDataSource.java
...ashloanflowboss/spi/paycenter/source/GuBeiDataSource.java
+14
-0
No files found.
src/main/java/cn/quantgroup/cashloanflowboss/api/oneclickdata/service/impl/CashWithdrawalServiceImpl.java
View file @
a8cb175b
...
@@ -116,17 +116,26 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
...
@@ -116,17 +116,26 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
}
}
public
JSONObject
applyLoan
(
OneClickData
oneClickData
,
String
md5Keywy
,
String
aesKeywy
){
public
JSONObject
applyLoan
(
OneClickData
oneClickData
,
String
md5Keywy
,
String
aesKeywy
){
Map
<
String
,
String
>
paras
=
new
HashMap
<
String
,
String
>()
;
JSONObject
result
=
null
;
String
bankCardNumber
=
BankCardNumberGenerator
.
generate
(
BankNameEnum
.
CCB
,
BankCardTypeEnum
.
DEBIT
);
String
bankCardNumber
=
BankCardNumberGenerator
.
generate
(
BankNameEnum
.
CCB
,
BankCardTypeEnum
.
DEBIT
);
String
bankCode
=
"CCB"
;
String
bankCode
=
"CCB"
;
String
bankName
=
"建设银行"
;
String
bankName
=
"建设银行"
;
boolean
formIdIsTrue
=
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID910
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID920
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID940
.
getDesc
());
boolean
formIdIsTrue
=
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID910
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID920
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID940
.
getDesc
());
if
(
formIdIsTrue
){
if
(
formIdIsTrue
){
bankCardNumber
=
getBankCardNumberLasterNumberIsEvenNumbers
();
bankCardNumber
=
getBankCardNumberLasterNumberIsEvenNumbers
();
bankCode
=
"P
INGAN
"
;
bankCode
=
"P
AB
"
;
bankName
=
"平安银行"
;
bankName
=
"平安银行"
;
result
=
getH5CashWithdrawal
(
oneClickData
,
md5Keywy
,
aesKeywy
,
bankCardNumber
,
bankCode
,
bankName
);
}
else
{
result
=
getAPICashWithdrawal
(
oneClickData
,
md5Keywy
,
aesKeywy
,
bankCardNumber
,
bankCode
,
bankName
);
}
}
return
result
;
}
public
JSONObject
getAPICashWithdrawal
(
OneClickData
oneClickData
,
String
md5Keywy
,
String
aesKeywy
,
String
bankCardNumber
,
String
bankCode
,
String
bankName
){
Map
<
String
,
String
>
paras
=
new
HashMap
<
String
,
String
>();
String
channelCode
=
"ZHANGZHONG"
;
String
channelCode
=
"ZHANGZHONG"
;
String
url
=
""
;
String
url
=
""
;
if
(
oneClickData
.
getChannelCode
().
trim
().
equals
(
ChannelEnum
.
ZHANGHZONG
.
getCode
())){
if
(
oneClickData
.
getChannelCode
().
trim
().
equals
(
ChannelEnum
.
ZHANGHZONG
.
getCode
())){
...
@@ -158,10 +167,13 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
...
@@ -158,10 +167,13 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
content_map
.
put
(
"content"
,
encryptContent
);
content_map
.
put
(
"content"
,
encryptContent
);
log
.
info
(
"获取当前的paras={}"
,
paras
);
log
.
info
(
"获取当前的paras={}"
,
paras
);
JSONObject
result
=
HttpRequest
.
doPostReturnResponseJson
(
url
,
content_map
);
JSONObject
result
=
HttpRequest
.
doPostReturnResponseJson
(
url
,
content_map
);
return
result
;
return
result
;
}
}
public
JSONObject
getH5CashWithdrawal
(
OneClickData
oneClickData
,
String
md5Keywy
,
String
aesKeywy
,
String
bankCardNumber
,
String
bankCode
,
String
bankName
){
return
null
;
}
/**
/**
* 掌众的申请提现
* 掌众的申请提现
...
@@ -244,28 +256,29 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
...
@@ -244,28 +256,29 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
String
bankCardNumber
=
BankCardNumberGenerator
.
generate
(
BankNameEnum
.
CCB
,
BankCardTypeEnum
.
DEBIT
);
String
bankCardNumber
=
BankCardNumberGenerator
.
generate
(
BankNameEnum
.
CCB
,
BankCardTypeEnum
.
DEBIT
);
String
bankCode
=
"CCB"
;
String
bankCode
=
"CCB"
;
String
bankName
=
"建设银行"
;
String
bankName
=
"建设银行"
;
JSONObject
result
=
null
;
boolean
formIdIsTrue
=
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID910
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID920
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID940
.
getDesc
());
boolean
formIdIsTrue
=
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID910
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID920
.
getDesc
())
||
oneClickData
.
getFundCorpId
().
equals
(
ResposeResultEnum
.
FUNDCORPID940
.
getDesc
());
if
(
formIdIsTrue
){
if
(
formIdIsTrue
){
bankCardNumber
=
getBankCardNumberLasterNumberIsEvenNumbers
();
bankCardNumber
=
getBankCardNumberLasterNumberIsEvenNumbers
();
bankCode
=
"P
INGAN
"
;
bankCode
=
"P
AB
"
;
bankName
=
"平安银行"
;
bankName
=
"平安银行"
;
}
}
else
{
Map
<
String
,
String
>
paras
=
new
HashMap
<
String
,
String
>();
Map
<
String
,
String
>
paras
=
new
HashMap
<
String
,
String
>();
paras
.
put
(
"channelOrderNumber"
,
oneClickData
.
getChannelOrderNo
());
paras
.
put
(
"channelOrderNumber"
,
oneClickData
.
getChannelOrderNo
());
paras
.
put
(
"bankCardNumber"
,
bankCardNumber
);
paras
.
put
(
"bankCardNumber"
,
bankCardNumber
);
paras
.
put
(
"bankCode"
,
bankCode
);
paras
.
put
(
"bankCode"
,
bankCode
);
paras
.
put
(
"bankName"
,
bankName
);
paras
.
put
(
"bankName"
,
bankName
);
paras
.
put
(
"reservePhoneNumber"
,
oneClickData
.
getPhone
());
paras
.
put
(
"reservePhoneNumber"
,
oneClickData
.
getPhone
());
String
encryptContent
=
GetEncryptContentAndMd5
.
getEncryptContent
(
paras
,
aesKeywy
,
md5Keywy
);
String
encryptContent
=
GetEncryptContentAndMd5
.
getEncryptContent
(
paras
,
aesKeywy
,
md5Keywy
);
Map
<
String
,
String
>
content_map
=
new
HashMap
<
String
,
String
>();
Map
<
String
,
String
>
content_map
=
new
HashMap
<
String
,
String
>();
content_map
.
put
(
"content"
,
encryptContent
);
content_map
.
put
(
"content"
,
encryptContent
);
log
.
info
(
"获取当前的paras={}"
,
paras
);
log
.
info
(
"获取当前的paras={}"
,
paras
);
JSONObject
result
=
HttpRequest
.
doPostReturnResponseJson
(
url
,
content_map
);
result
=
HttpRequest
.
doPostReturnResponseJson
(
url
,
content_map
);
}
return
result
;
return
result
;
}
}
...
@@ -277,6 +290,7 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
...
@@ -277,6 +290,7 @@ public class CashWithdrawalServiceImpl implements CashWithdrawalService{
int
isEven
=
bankCardNumberOriganCv
%
2
;
int
isEven
=
bankCardNumberOriganCv
%
2
;
if
(
isEven
==
0
){
if
(
isEven
==
0
){
log
.
info
(
"获取当前的bankCardNumberOrigan={},bankCardNumberOriganCv={}"
,
bankCardNumberOrigan
,
bankCardNumberOriganCv
);
log
.
info
(
"获取当前的bankCardNumberOrigan={},bankCardNumberOriganCv={}"
,
bankCardNumberOrigan
,
bankCardNumberOriganCv
);
// 在支付中心插入一条绑卡信息
}
else
{
}
else
{
getBankCardNumberLasterNumberIsEvenNumbers
();
getBankCardNumberLasterNumberIsEvenNumbers
();
...
...
src/main/java/cn/quantgroup/cashloanflowboss/api/oneclickdata/service/impl/LoanOperationServiceImpl.java
View file @
a8cb175b
...
@@ -7,6 +7,7 @@ import cn.quantgroup.cashloanflowboss.api.oneclickdata.repository.OneClickDataRe
...
@@ -7,6 +7,7 @@ import cn.quantgroup.cashloanflowboss.api.oneclickdata.repository.OneClickDataRe
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.FundsAllocationplanService
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.FundsAllocationplanService
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.LoanOperationService
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.LoanOperationService
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.PhoneInfoService
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.PhoneInfoService
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.ScheduleService
;
import
cn.quantgroup.cashloanflowboss.core.base.Result
;
import
cn.quantgroup.cashloanflowboss.core.base.Result
;
import
cn.quantgroup.cashloanflowboss.spi.clf.model.LoanProgress
;
import
cn.quantgroup.cashloanflowboss.spi.clf.model.LoanProgress
;
import
cn.quantgroup.cashloanflowboss.spi.xyqb.entity.LoanApplicationHistory
;
import
cn.quantgroup.cashloanflowboss.spi.xyqb.entity.LoanApplicationHistory
;
...
@@ -46,6 +47,8 @@ public class LoanOperationServiceImpl implements LoanOperationService{
...
@@ -46,6 +47,8 @@ public class LoanOperationServiceImpl implements LoanOperationService{
private
FundsAllocationplanService
fundsAllocationplanService
;
private
FundsAllocationplanService
fundsAllocationplanService
;
@Autowired
@Autowired
private
PhoneInfoService
phoneInfoService
;
private
PhoneInfoService
phoneInfoService
;
@Autowired
private
ScheduleService
scheduleService
;
@Value
(
"${opapi.http.net}"
)
@Value
(
"${opapi.http.net}"
)
private
String
opapiHttp
;
private
String
opapiHttp
;
@Value
(
"${clotho.http.net}"
)
@Value
(
"${clotho.http.net}"
)
...
@@ -249,7 +252,13 @@ public class LoanOperationServiceImpl implements LoanOperationService{
...
@@ -249,7 +252,13 @@ public class LoanOperationServiceImpl implements LoanOperationService{
* */
* */
@Override
@Override
public
JSONObject
payNotify
(
OneClickData
oneClickData
,
String
payStatus
)
{
public
JSONObject
payNotify
(
OneClickData
oneClickData
,
String
payStatus
)
{
try
{
//JOB执行
scheduleService
.
fetchDataLoanJob
();
scheduleService
.
loanDataJob
();
}
catch
(
Exception
e
){
log
.
info
(
"错误信息={}"
,
e
.
toString
());
}
String
url
=
apiHttp
+
"/ex/paycenter/pay_notify"
;
String
url
=
apiHttp
+
"/ex/paycenter/pay_notify"
;
long
payTime
=
System
.
currentTimeMillis
();
long
payTime
=
System
.
currentTimeMillis
();
...
...
src/main/java/cn/quantgroup/cashloanflowboss/api/oneclickdata/service/impl/OneClickDataOperateJobServiceImpl.java
View file @
a8cb175b
package
cn
.
quantgroup
.
cashloanflowboss
.
api
.
oneclickdata
.
service
.
impl
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.entity.OneClickData
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.model.LoanStatusEnum
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.model.TypeEnum
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.repository.OneClickDataRespository
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.*
;
import
cn.quantgroup.cashloanflowboss.spi.clf.model.LoanProgress
;
import
cn.quantgroup.cashloanflowboss.spi.xyqb.entity.LoanApplicationHistory
;
import
cn.quantgroup.cashloanflowboss.spi.xyqb.entity.QuotaCredit
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
java.util.List
;
import
java.util.Objects
;
/** * Created by shang on 2019/12/12. */
@Slf4j
@Service
public
class
OneClickDataOperateJobServiceImpl
implements
OneClickDataOperateJobService
{
@Autowired
private
PhoneInfoService
phoneInfoService
;
@Autowired
private
LoanOperationService
loanOperationService
;
@Autowired
private
OneClickDataRespository
oneClickDataRespository
;
@Autowired
private
CreditGrantingService
creditGrantingService
;
@Autowired
private
OneClickDataQueueOperateService
oneClickDataQueueOperateService
;
@Override
public
void
excuteCreditSuccessJob
()
{
}
@Override
public
void
excuteCreditFailJob
()
{
}
@Override
public
void
excuteSelectCreditStatusJob
()
{
//查找请求类型:2授信成功、3授信失败、4放款成功、5放款失败、6清算的单,7提现,并且当前的授信状态是0授信中 List<OneClickData> oneClickDataList=oneClickDataRespository.findByCreditStatusAndTypeNotIn(0, 1); if(oneClickDataList.size()>0 || oneClickDataList !=null) { for (OneClickData oneClickData : oneClickDataList) { // 当前授信中的单在apply_quota 查看状态是apply_status=1 时间倒序,进行授信请求操作 log.info("打印一下oneClickData.getUserId()={},oneClickData.getChannelCode()={}",oneClickData.getUserId(),oneClickData.getChannelCode()); QuotaCredit quotaCredit1 = phoneInfoService.selectUserAuditRecords(Long.parseLong(oneClickData.getUserId()), Long.parseLong(oneClickData.getChannelCode())); if (Objects.isNull(quotaCredit1)) { log.info("不符合授信审核申请的条件"); } else { //如何条件的单进行授信申请请求 log.info("符合授信审核申请的条件oneClickData={},quotaCredit1={}", oneClickData, quotaCredit1); try { creditGrantingService.authAmountAuditNotifyMq(oneClickData, quotaCredit1); } catch (Exception e) { log.info("进入异常e={}", e); } } } }else{ log.info("oneClickDataList为空={}",oneClickDataList); } } @Override public void excuteFundSucessJob() { } @Override public void excuteFundFailJob() { } @Override public void excuteFundJob() { //查找请求类型:4放款成功、5放款失败、6清算的单,并且当前的授信状态是2但是 List<OneClickData> oneClickDataList = oneClickDataRespository.findByCreditStatusAndTypeNotIn(2, 1, 2, 3, 7); if (oneClickDataList.size() > 0 || oneClickDataList != null) { for (OneClickData oneClickData : oneClickDataList) { log.info("打印一下oneClickData.getUserId()={},oneClickData.getLoanId={}", oneClickData.getUserId(),oneClickData.getLoanId()); if(StringUtils.isNotEmpty(oneClickData.getLoanId()) || StringUtils.isNotEmpty(oneClickData.getUserId())){ String loanOrUserId=""; if(StringUtils.isNotEmpty(oneClickData.getLoanId())){ loanOrUserId=oneClickData.getLoanId(); }else { loanOrUserId=oneClickData.getUserId(); } LoanApplicationHistory loanApplicationHistory = loanOperationService.selectLoanIdOrUserId(Long.parseLong(loanOrUserId)); if (Objects.isNull(loanApplicationHistory)) { log.info("不符合放款条件的单"); } else { log.info("符合放款条件loanApplicationHistory={}", loanApplicationHistory); String progress=loanApplicationHistory.getProgress().getDescription().trim(); //提现操作尚未成功,重新操作提现 if(LoanProgress.WAITING_FUND.getDescription().equals(progress) ){ log.info("二次风控成功:20,未进行金额放款21"); oneClickDataQueueOperateService.applyLendingNotifyOnly(oneClickData); }else if( LoanProgress.START_ORDER.getDescription().equals(progress)){ log.info("提现完毕50,二次风控没有成功"); oneClickDataQueueOperateService.getBingSucc(oneClickData); }else if(LoanProgress.FINAL_SENDED_TO_FUNDING_CORP.getDescription().equals(progress)){ try { String payStatus="3"; if(oneClickData.getType() == TypeEnum.LOANFAIL.getCode() ){ payStatus="4"; }else { payStatus="3"; } loanOperationService.payNotify(oneClickData,payStatus); } catch (Exception e) { log.info("进入异常e={}", e.getMessage()); } }else if(LoanProgress.CHECK_REPAYMENT_PLAN.getDescription().equals(progress)){ log.info("当前已经是放款状态了,直接修改放款成功15"); oneClickDataRespository.updateLoanStatusById(LoanStatusEnum.CHECK_REPAYMENT_PLAN.getCode(), oneClickData.getId()); }else { log.info("当前的放款状态不对,非20 21 ,请查看数据库状态"); oneClickDataRespository.updateLoanStatusById(LoanStatusEnum.LOAN_SCHEDULE_FAIL.getCode(), oneClickData.getId()); } } }else{ log.info("尚未生成放款单,未进入提现环节的错误数据"); } } }else{ log.info("oneClickDataList为空={}",oneClickDataList); } } @Override public void excuteSelectFundStatusJob() { } }
package
cn
.
quantgroup
.
cashloanflowboss
.
api
.
oneclickdata
.
service
.
impl
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.entity.OneClickData
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.model.LoanStatusEnum
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.model.TypeEnum
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.repository.OneClickDataRespository
;
import
cn.quantgroup.cashloanflowboss.api.oneclickdata.service.*
;
import
cn.quantgroup.cashloanflowboss.spi.clf.model.LoanProgress
;
import
cn.quantgroup.cashloanflowboss.spi.xyqb.entity.LoanApplicationHistory
;
import
cn.quantgroup.cashloanflowboss.spi.xyqb.entity.QuotaCredit
;
import
lombok.extern.slf4j.Slf4j
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
java.util.List
;
import
java.util.Objects
;
/** * Created by shang on 2019/12/12. */
@Slf4j
@Service
public
class
OneClickDataOperateJobServiceImpl
implements
OneClickDataOperateJobService
{
@Autowired
private
PhoneInfoService
phoneInfoService
;
@Autowired
private
LoanOperationService
loanOperationService
;
@Autowired
private
OneClickDataRespository
oneClickDataRespository
;
@Autowired
private
CreditGrantingService
creditGrantingService
;
@Autowired
private
OneClickDataQueueOperateService
oneClickDataQueueOperateService
;
@Override
public
void
excuteCreditSuccessJob
()
{
}
@Override
public
void
excuteCreditFailJob
()
{
}
@Override
public
void
excuteSelectCreditStatusJob
()
{
//查找请求类型:2授信成功、3授信失败、4放款成功、5放款失败、6清算的单,7提现,并且当前的授信状态是0授信中 List<OneClickData> oneClickDataList=oneClickDataRespository.findByCreditStatusAndTypeNotIn(0, 1); if(oneClickDataList.size()>0 || oneClickDataList !=null) { for (OneClickData oneClickData : oneClickDataList) { // 当前授信中的单在apply_quota 查看状态是apply_status=1 时间倒序,进行授信请求操作 log.info("打印一下oneClickData.getUserId()={},oneClickData.getChannelCode()={}",oneClickData.getUserId(),oneClickData.getChannelCode()); QuotaCredit quotaCredit1 = phoneInfoService.selectUserAuditRecords(Long.parseLong(oneClickData.getUserId()), Long.parseLong(oneClickData.getChannelCode())); if (Objects.isNull(quotaCredit1)) { log.info("不符合授信审核申请的条件"); } else { //如何条件的单进行授信申请请求 log.info("符合授信审核申请的条件oneClickData={},quotaCredit1={}", oneClickData, quotaCredit1); try { creditGrantingService.authAmountAuditNotifyMq(oneClickData, quotaCredit1); } catch (Exception e) { log.info("进入异常e={}", e); } } } }else{ log.info("oneClickDataList为空={}",oneClickDataList); } } @Override public void excuteFundSucessJob() { } @Override public void excuteFundFailJob() { } @Override public void excuteFundJob() { //查找请求类型:4放款成功、5放款失败、6清算的单,并且当前的授信状态是2但是 List<OneClickData> oneClickDataList = oneClickDataRespository.findByCreditStatusAndTypeNotIn(2, 1, 2, 3, 7); if (oneClickDataList.size() > 0 || oneClickDataList != null) { for (OneClickData oneClickData : oneClickDataList) { log.info("打印一下oneClickData.getUserId()={},oneClickData.getLoanId={}", oneClickData.getUserId(),oneClickData.getLoanId()); if(StringUtils.isNotEmpty(oneClickData.getLoanId()) || StringUtils.isNotEmpty(oneClickData.getUserId())){ String loanOrUserId=""; LoanApplicationHistory loanApplicationHistory =null; if(StringUtils.isNotEmpty(oneClickData.getLoanId())){ loanOrUserId=oneClickData.getLoanId(); loanApplicationHistory = loanOperationService.selectLoanIdOrUserId(Long.parseLong(loanOrUserId)); }else { loanOrUserId=oneClickData.getUserId(); loanApplicationHistory = loanOperationService.selectLoanIdOrUserId(Long.parseLong(loanOrUserId)); if(Objects.nonNull(loanApplicationHistory)){ log.info("打印一下loanApplicationHistory.id={},oneClickData.id={}", loanApplicationHistory.getId(), oneClickData.getId()); String loanId=String.valueOf(loanApplicationHistory.getId()); Long oneClickId=oneClickData.getId(); oneClickDataRespository.updateById(loanId,oneClickId); }else { log.info("当前的数据没有查看到,不符合放款条件哦!!!"); } } if (Objects.isNull(loanApplicationHistory)) { log.info("不符合放款条件的单"); } else { log.info("符合放款条件loanApplicationHistory={}", loanApplicationHistory); String progress=loanApplicationHistory.getProgress().getDescription().trim(); //提现操作尚未成功,重新操作提现 if(LoanProgress.WAITING_FUND.getDescription().equals(progress) ){ log.info("二次风控成功:20,未进行金额放款21"); oneClickDataQueueOperateService.applyLendingNotifyOnly(oneClickData); }else if( LoanProgress.START_ORDER.getDescription().equals(progress)){ log.info("提现完毕50,二次风控没有成功"); oneClickDataQueueOperateService.getBingSucc(oneClickData); }else if(LoanProgress.FINAL_SENDED_TO_FUNDING_CORP.getDescription().equals(progress)){ try { String payStatus="3"; if(oneClickData.getType() == TypeEnum.LOANFAIL.getCode() ){ payStatus="4"; }else { payStatus="3"; } loanOperationService.payNotify(oneClickData,payStatus); } catch (Exception e) { log.info("进入异常e={}", e.getMessage()); } }else if(LoanProgress.CHECK_REPAYMENT_PLAN.getDescription().equals(progress)){ log.info("当前已经是放款状态了,直接修改放款成功15"); oneClickDataRespository.updateLoanStatusById(LoanStatusEnum.CHECK_REPAYMENT_PLAN.getCode(), oneClickData.getId()); }else { log.info("当前的放款状态不对,非20 21 ,请查看数据库状态"); oneClickDataRespository.updateLoanStatusById(LoanStatusEnum.LOAN_SCHEDULE_FAIL.getCode(), oneClickData.getId()); } } }else{ log.info("尚未生成放款单,未进入提现环节的错误数据"); } } }else{ log.info("oneClickDataList为空={}",oneClickDataList); } } @Override public void excuteSelectFundStatusJob() { } }
\ No newline at end of file
\ No newline at end of file
...
...
src/main/java/cn/quantgroup/cashloanflowboss/api/oneclickdata/service/impl/OneClickDataQueueOperateServiceImpl.java
View file @
a8cb175b
...
@@ -226,7 +226,8 @@ public class OneClickDataQueueOperateServiceImpl implements OneClickDataQueueOpe
...
@@ -226,7 +226,8 @@ public class OneClickDataQueueOperateServiceImpl implements OneClickDataQueueOpe
updatContractStatus
(
oneClickData
);
updatContractStatus
(
oneClickData
);
}
}
}
else
{
}
else
{
return
result
;
log
.
info
(
"当前的合同状态是对的contract.getGenerateStatus() ={}"
,
contract
.
getGenerateStatus
());
}
}
String
payStatus
=
"3"
;
String
payStatus
=
"3"
;
// 通过申请类型确定是否要放款成功、失败
// 通过申请类型确定是否要放款成功、失败
...
...
src/main/java/cn/quantgroup/cashloanflowboss/spi/paycenter/source/GuBeiBataSourceConfiguration.java
0 → 100644
View file @
a8cb175b
//package cn.quantgroup.cashloanflowboss.spi.paycenter.source;
//
//import org.springframework.context.annotation.ComponentScan;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
//import org.springframework.transaction.annotation.EnableTransactionManagement;
//
///**
// * Created by shang on 2020/2/20.
// */
//@Configuration
//@EnableTransactionManagement
//@EnableJpaRepositories(basePackages = {"cn.quantgroup"}, entityManagerFactoryRef = "guBeiEntityManager", transactionManagerRef = "guBeiTransactionManager", includeFilters = @ComponentScan.Filter(GuBeiDataSource.class))
//public class GuBeiBataSourceConfiguration {
//}
src/main/java/cn/quantgroup/cashloanflowboss/spi/paycenter/source/GuBeiDataSource.java
0 → 100644
View file @
a8cb175b
//package cn.quantgroup.cashloanflowboss.spi.paycenter.source;
//
//import java.lang.annotation.ElementType;
//import java.lang.annotation.Retention;
//import java.lang.annotation.RetentionPolicy;
//import java.lang.annotation.Target;
//
///**
// * Created by shang on 2020/2/20.
// */
//@Target({ElementType.TYPE})
//@Retention(RetentionPolicy.RUNTIME)
//public @interface GuBeiDataSource {
//}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment