Commit 833da1af authored by 陈宏杰's avatar 陈宏杰

老数据处理

parent 5014647f
package cn.quantgroup.report.domain.baihang;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@AllArgsConstructor
@NoArgsConstructor
public class RepairDataOfLoanAccountExt {
private String loanId;
private String orderNo;
private String applyTime;
}
...@@ -2,6 +2,7 @@ package cn.quantgroup.report.mapper.baihang; ...@@ -2,6 +2,7 @@ package cn.quantgroup.report.mapper.baihang;
import cn.quantgroup.report.domain.baihang.BaiHangTimeRecord; import cn.quantgroup.report.domain.baihang.BaiHangTimeRecord;
import cn.quantgroup.report.domain.baihang.LoanInfoZhuDai; import cn.quantgroup.report.domain.baihang.LoanInfoZhuDai;
import cn.quantgroup.report.domain.baihang.RepairDataOfLoanAccountExt;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
import java.util.List; import java.util.List;
...@@ -82,4 +83,7 @@ public interface LoanInfoMapper { ...@@ -82,4 +83,7 @@ public interface LoanInfoMapper {
List<LoanInfoZhuDai> findRealTimeLoanInfoZhuDaiLh(BaiHangTimeRecord timeRecord); List<LoanInfoZhuDai> findRealTimeLoanInfoZhuDaiLh(BaiHangTimeRecord timeRecord);
List<RepairDataOfLoanAccountExt> findRepairDataOfLoanAccountExt(String loanApplicationHistoryId);
} }
...@@ -251,9 +251,20 @@ public class BaiHangFileReportService { ...@@ -251,9 +251,20 @@ public class BaiHangFileReportService {
loanInfoVo.setName(sensitiveFilter(loanInfo.getName())); loanInfoVo.setName(sensitiveFilter(loanInfo.getName()));
loanInfoVo.setPid(sensitiveFilter(loanInfo.getPid())); loanInfoVo.setPid(sensitiveFilter(loanInfo.getPid()));
loanInfoVo.setMobile(sensitiveFilter(loanInfo.getMobile())); loanInfoVo.setMobile(sensitiveFilter(loanInfo.getMobile()));
if (DateUtils.parseDate("yyyy-MM-dd'T'HH:mm:ss",loanInfoVo.getIssueDate()).getTime() < DateUtils.parseDate("yyyy-MM-dd'T'HH:mm:ss",loanInfoVo.getAccountOpenDate()).getTime()){ try {
loanInfoVo.setAccountOpenDate(loanInfoVo.getIssueDate()); if (DateUtils.parseDate("yyyy-MM-dd'T'HH:mm:ss",loanInfoVo.getIssueDate()).getTime() < DateUtils.parseDate("yyyy-MM-dd'T'HH:mm:ss",loanInfoVo.getAccountOpenDate()).getTime()){
loanInfoVo.setApplyDate(loanInfoVo.getIssueDate()); loanInfoVo.setAccountOpenDate(loanInfoVo.getIssueDate());
loanInfoVo.setApplyDate(loanInfoVo.getIssueDate());
}
} catch (Exception e) {
log.error("百行-助贷放款数据组装异常,loan_application_history_id: {}",loanInfoReqId,e);
//处理个别的老数据 loan_application_manifest_history表没数据的情况
List<RepairDataOfLoanAccountExt> repairDataList = loanInfoMapper.findRepairDataOfLoanAccountExt(loanInfoReqId);
if (!CollectionUtils.isEmpty(repairDataList)) {
loanInfoVo.setAccountOpenDate(repairDataList.get(0).getApplyTime());
loanInfoVo.setApplyDate(repairDataList.get(0).getApplyTime());
log.info("百行-助贷放款数据组装异常已修复,loan_application_history_id: {}",loanInfoReqId);
}
} }
if (isDebug && StringUtils.isNotBlank(prefix)) { if (isDebug && StringUtils.isNotBlank(prefix)) {
loanInfoVo.setReqID(prefix+loanInfoVo.getReqID()); loanInfoVo.setReqID(prefix+loanInfoVo.getReqID());
......
...@@ -453,5 +453,11 @@ ...@@ -453,5 +453,11 @@
; ;
</select> </select>
<select id="findRepairDataOfLoanAccountExt" parameterType="java.lang.String" resultType="cn.quantgroup.report.domain.baihang.RepairDataOfLoanAccountExt">
select c.loan_id loanId,d.order_no orderNo,DATE_FORMAT(d.apply_time,'%Y-%m-%dT%H:%i:%S') applyTime
from xyqb.loan_account_ext c
left join xyqb.apply_quota_record d on c.order_no=d.order_no
where c.loan_id = #{loanApplicationHistoryId,jdbcType=VARCHAR}
</select>
</mapper> </mapper>
\ No newline at end of file
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