Commit 5f4cc0b3 authored by huyuchen's avatar huyuchen

明细接口改造

parent 570d744c
...@@ -309,12 +309,14 @@ public class TIncomeServiceImpl extends ServiceImpl<TIncomeMapper, TIncome> impl ...@@ -309,12 +309,14 @@ public class TIncomeServiceImpl extends ServiceImpl<TIncomeMapper, TIncome> impl
tIncomeDetail.setCreateTime(new Date()); tIncomeDetail.setCreateTime(new Date());
tIncomeDetail.setDataCreateMonth(DateUtil.addMonth(0)); tIncomeDetail.setDataCreateMonth(DateUtil.addMonth(0));
tIncomeDetailService.save(tIncomeDetail); tIncomeDetailService.save(tIncomeDetail);
// 不存在,直接新增 synchronized (this) {
if (incomeList == null || incomeList.isEmpty()) { // 不存在,直接新增
return this.savePaymentIncome(tIncomeDetail,paymentId); if (incomeList == null || incomeList.isEmpty()) {
} else { return this.savePaymentIncome(tIncomeDetail, paymentId);
// 核心判断 } else {
return this.copyCore(tIncomeDetail, incomeList, detailList,paymentId,true); // 核心判断
return this.copyCore(tIncomeDetail, incomeList, detailList, paymentId, true);
}
} }
} }
......
...@@ -3208,11 +3208,9 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa ...@@ -3208,11 +3208,9 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
int i = (int) Math.ceil((double) count / CommonConstants.TEN_THOUSAND_INT); int i = (int) Math.ceil((double) count / CommonConstants.TEN_THOUSAND_INT);
for (int j = 0; j < i; j++) { for (int j = 0; j < i; j++) {
sumList = baseMapper.getTPaymentSocialIncomeInfo(searchVo, user.getId()); sumList = baseMapper.getTPaymentSocialIncomeInfo(searchVo, user.getId());
synchronized (this) { if (Common.isNotNull(sumList)) {
if (Common.isNotNull(sumList)) { //生成收入
//生成收入 createIncomeInfo(sumList, CommonConstants.ONE_STRING, mapSelectVo, redisKey);
createIncomeInfo(sumList, CommonConstants.ONE_STRING, mapSelectVo, redisKey);
}
} }
} }
} }
...@@ -3227,11 +3225,9 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa ...@@ -3227,11 +3225,9 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
int i = (int) Math.ceil((double) count / CommonConstants.TEN_THOUSAND_INT); int i = (int) Math.ceil((double) count / CommonConstants.TEN_THOUSAND_INT);
for (int j = 0; j < i; j++) { for (int j = 0; j < i; j++) {
sumList = baseMapper.getTPaymentFundIncomeInfo(searchVo, user.getId()); sumList = baseMapper.getTPaymentFundIncomeInfo(searchVo, user.getId());
synchronized (this) { if (Common.isNotNull(sumList)) {
if (Common.isNotNull(sumList)) { //生成公积金收入
//生成公积金收入 createIncomeInfo(sumList, CommonConstants.TWO_STRING, mapSelectVo, redisKey);
createIncomeInfo(sumList, CommonConstants.TWO_STRING, mapSelectVo, redisKey);
}
} }
} }
} }
......
...@@ -284,7 +284,7 @@ public class DoJointSocialTask { ...@@ -284,7 +284,7 @@ public class DoJointSocialTask {
if (!Common.isEmpty(info) && Common.isNotNull(info.getData())) { if (!Common.isEmpty(info) && Common.isNotNull(info.getData())) {
sendBack = info.getData(); sendBack = info.getData();
} }
} else { } else if(CommonConstants.TWO_STRING.equals(income.getFeeType())) {
EkpIncomeParamRisk sendParam = new EkpIncomeParamRisk(); EkpIncomeParamRisk sendParam = new EkpIncomeParamRisk();
this.copyToEkpRisk(income, sendParam); this.copyToEkpRisk(income, sendParam);
R<String> info = ekpDaprUtil.pushRiskInfoToEkp(sendParam); R<String> info = ekpDaprUtil.pushRiskInfoToEkp(sendParam);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment