提交 710742e8 authored 作者: 艾庆国's avatar 艾庆国

Merge branch 'refs/heads/v17.5_order_child_sync_broker_20240617' into test

...@@ -8,4 +8,6 @@ public interface BrokerService { ...@@ -8,4 +8,6 @@ public interface BrokerService {
void orderChildSync(TransportParam param); void orderChildSync(TransportParam param);
TransportVO getOrderChildStatus(String childNo); TransportVO getOrderChildStatus(String childNo);
TransportVO getOrderChildStatus(String childNo, String settlementNo);
} }
...@@ -36,7 +36,13 @@ public class BrokerServiceImpl implements BrokerService { ...@@ -36,7 +36,13 @@ public class BrokerServiceImpl implements BrokerService {
@Override @Override
public TransportVO getOrderChildStatus(String childNo) { public TransportVO getOrderChildStatus(String childNo) {
Result<TransportVO> result = brokerFeign.getTransportByChildNo(childNo, settlementConfig.getBrokerUserCode()); return getOrderChildStatus(childNo, null);
}
@Override
public TransportVO getOrderChildStatus(String childNo, String settlementNo) {
Result<TransportVO> result = brokerFeign.getTransportByChildNo(childNo, settlementConfig.getBrokerUserCode(), settlementNo);
if (result.getCode() != 0) { if (result.getCode() != 0) {
log.info("运单同步网络货运失败, msg:{}", result.getMsg()); log.info("运单同步网络货运失败, msg:{}", result.getMsg());
} }
......
...@@ -23,6 +23,7 @@ public interface BrokerFeign { ...@@ -23,6 +23,7 @@ public interface BrokerFeign {
@RequestMapping(value = "/broker-service/open/transport/getTransportByChildNo", method = RequestMethod.GET) @RequestMapping(value = "/broker-service/open/transport/getTransportByChildNo", method = RequestMethod.GET)
Result<TransportVO> getTransportByChildNo(@RequestParam @NotBlank(message = "运单编号不能为空") String orderCode, Result<TransportVO> getTransportByChildNo(@RequestParam @NotBlank(message = "运单编号不能为空") String orderCode,
@RequestParam @NotNull(message = "userCode不能为空") String userCode); @RequestParam @NotNull(message = "userCode不能为空") String userCode,
@RequestParam String settlementNo);
} }
...@@ -73,8 +73,8 @@ public class NetworkDriverAccountServiceImpl implements NetworkDriverAccountServ ...@@ -73,8 +73,8 @@ public class NetworkDriverAccountServiceImpl implements NetworkDriverAccountServ
WalletResidueCardVO data = result.getData(); WalletResidueCardVO data = result.getData();
NetworkDriverAccount account = networkDriverAccountDao.getOneByField(NetworkDriverAccount::getDriverUserNo, loginUserInfo.getUserNo()).get(); NetworkDriverAccount account = networkDriverAccountDao.getOneByField(NetworkDriverAccount::getDriverUserNo, loginUserInfo.getUserNo()).get();
data.setAssetSum(data.getAssetSum().add(account.getAccountBalance().movePointLeft(2))); data.setAssetSum(data.getAssetSum().add(account.getAccountBalance().movePointLeft(2)));
data.setFrozen(data.getFrozen().add(account.getFrozenBalance()).setScale(2, RoundingMode.UP)); data.setFrozen(data.getFrozen().add(account.getFrozenBalance()).setScale(2, RoundingMode.HALF_UP));
data.setResidue(data.getResidue().add(account.getUsableBalance()).setScale(2, RoundingMode.UP)); data.setResidue(data.getResidue().add(account.getUsableBalance()).setScale(2, RoundingMode.HALF_UP));
return data; return data;
} }
} }
...@@ -327,7 +327,7 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic ...@@ -327,7 +327,7 @@ public class SettlementMqHandlerServiceImpl implements SettlementMqHandlerServic
} }
// 获取状态 // 获取状态
TransportVO result = brokerService.getOrderChildStatus(mq.getChildNo()); TransportVO result = brokerService.getOrderChildStatus(mq.getChildNo(), settlementOwnerDetail.getSettlementNo());
if (result == null){ if (result == null){
log.info("运单号 {} 未找到运单信息",mq.getChildNo()); log.info("运单号 {} 未找到运单信息",mq.getChildNo());
return; return;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论