记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit a3d22cc0 authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

修改消费日志

parent ec65912f
Hide whitespace changes
Inline Side-by-side
Showing with 10 additions and 6 deletions
liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java
View file @ a3d22cc0
...@@ -614,12 +614,16 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService { ...@@ -614,12 +614,16 @@ public class KylinOrderTicketsServiceImpl implements IKylinOrderTicketsService {
log.debug("redis 修改订单列表 -> time:" + (currentTime) + "毫秒"); log.debug("redis 修改订单列表 -> time:" + (currentTime) + "毫秒");
// 执行sql // 执行sql
String sqlData = SqlMapping.gets(sqls, sqlsDataB, sqlsDataC, sqlsDataD, sqlsDataA); try {
currentTime = System.currentTimeMillis(); String sqlData = SqlMapping.gets(sqls, sqlsDataB, sqlsDataC, sqlsDataD, sqlsDataA);
rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE, MQConst.ROUTING_KEY_SQL_ORDER_CREATE, currentTime = System.currentTimeMillis();
sqlData); rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CREADE, MQConst.ROUTING_KEY_SQL_ORDER_CREATE,
currentTime = System.currentTimeMillis() - currentTime; sqlData);
log.debug("MQ 发送 -> time:" + (currentTime) + "毫秒"); currentTime = System.currentTimeMillis() - currentTime;
log.debug("MQ 发送 -> time:" + (currentTime) + "毫秒");
}catch (Exception e){
log.error("WARNING Kylin MQ Error = " + e.getMessage());
}
log.info(UserPathDto.setData("下单(唤起支付)", payOrderParam, payResultVo)); log.info(UserPathDto.setData("下单(唤起支付)", payOrderParam, payResultVo));
return ResponseDto.success(payResultVo); return ResponseDto.success(payResultVo);
}catch (Exception e){ }catch (Exception e){
......
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