提交 3a273f2c authored 作者: huyufan's avatar huyufan

Merge remote-tracking branch 'origin/v10.7_borrowing_and_repayment_20240118' into test

...@@ -24,6 +24,7 @@ import org.springframework.stereotype.Component; ...@@ -24,6 +24,7 @@ import org.springframework.stereotype.Component;
import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus; import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.List; import java.util.List;
...@@ -43,6 +44,7 @@ public class OwnerLoanAccountThawListener { ...@@ -43,6 +44,7 @@ public class OwnerLoanAccountThawListener {
private final OwnerLoanAccountRunningWaterRecordDao ownerLoanAccountRunningWaterRecordDao; private final OwnerLoanAccountRunningWaterRecordDao ownerLoanAccountRunningWaterRecordDao;
@RabbitListener(queues = RabbitKeyConstants.OWNER_LOAN_THAW_QUEUE) @RabbitListener(queues = RabbitKeyConstants.OWNER_LOAN_THAW_QUEUE)
@Transactional(rollbackFor = Exception.class)
public void onMessage(String message) { public void onMessage(String message) {
log.info("货主借款冻结释放监听器{}", message); log.info("货主借款冻结释放监听器{}", message);
List<OwnerLoanAccountRunningWaterRecord> runningWaterRecordList = ownerLoanAccountRunningWaterRecordDao.getListByChildNoAndRunningWaterType(message); List<OwnerLoanAccountRunningWaterRecord> runningWaterRecordList = ownerLoanAccountRunningWaterRecordDao.getListByChildNoAndRunningWaterType(message);
...@@ -69,7 +71,7 @@ public class OwnerLoanAccountThawListener { ...@@ -69,7 +71,7 @@ public class OwnerLoanAccountThawListener {
String childNo = record.getChildNo(); String childNo = record.getChildNo();
BigDecimal balance = record.getAlterationBalance(); BigDecimal balance = record.getAlterationBalance();
//解冻借款 //解冻借款
orderChildLoanComponent.thawOwnerLoanAccount(loanNo, loanType, ownerUserNo, record.getMobile(), ownerUserName, childNo, balance); orderChildLoanComponent.thawOwnerLoanAccount(loanNo, loanType, ownerUserNo, ownerUserName, record.getMobile(), childNo, balance);
} }
} }
} }
...@@ -25,7 +25,7 @@ public interface OwnerLoanRecordMapper extends BaseMapper<OwnerLoanRecord> { ...@@ -25,7 +25,7 @@ public interface OwnerLoanRecordMapper extends BaseMapper<OwnerLoanRecord> {
IPage<OwnerLoanRecordVO> pageByParam(@Param("page") Page<OwnerLoanRecordVO> page, @Param("param") PageOwnerLoanRecordOfOwner param); IPage<OwnerLoanRecordVO> pageByParam(@Param("page") Page<OwnerLoanRecordVO> page, @Param("param") PageOwnerLoanRecordOfOwner param);
@Update("update owner_loan_record set loan_residue_balance = loan_residue_balance + #{loanResidueBalance}" + @Update("update owner_loan_record set loan_residue_balance = loan_residue_balance + #{account.loanResidueBalance}" +
",modified_time=#{now}" ",modified_time=#{now}"
+ "where id = #{account.id} and modified_time = #{account.modifiedTime}" + "where id = #{account.id} and modified_time = #{account.modifiedTime}"
) )
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论