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

Skip to content

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

票种上下线修改

parent 6cf901ef
Hide whitespace changes
Inline Side-by-side
Showing with 41 additions and 44 deletions
liquidnet-bus-service/liquidnet-service-slime/liquidnet-service-slime-impl/src/main/java/com/liquidnet/service/slime/service/impl/KylinTicketsPartnerServiceImpl.java
View file @ fc9ac9fc
......@@ -372,37 +372,35 @@ public class KylinTicketsPartnerServiceImpl implements IKylinTicketsPartnerServi
}
}
KylinTicketTimesVo ticketTimesData;
KylinTicketVo ticketData = null;
for (int x = 0; x < vo.getTicketTimeList().size(); x++) {
ticketTimesData = vo.getTicketTimeList().get(x);
for (int y = 0; y < ticketTimesData.getTicketList().size(); y++) {
KylinTicketVo ticketItem = ticketTimesData.getTicketList().get(y);
if (ticketItem.getTicketsId().equals(ticketsId)) {
ticketData = ticketItem;
break;
if (ticketItem != null && ticketItem.getStatus() >= 3 && ticketItem.getStatus() != 4 && ticketItem.getStatus() != 6) {//未提审||被拒绝
//mysql
queueUtil.sendMsgByRedis(MQConst.SlimeQueue.SQL_SLIME_TICKET_UPDATE.getKey(),
SqlMapping.get("kylin_ticket_status.update_status",
9, updatedAt, ticketsId, updatedAt, updatedAt
));
//mongo
KylinTicketPartnerVo ticketPartnerVo = KylinTicketPartnerVo.getNew();
ticketPartnerVo.setTicketsId(ticketsId);
ticketPartnerVo.setStatus(9);
mongoSlimeUtils.updateTicketPartnerVo(ticketPartnerVo);
mongoSlimeUtils.updateKylinPerformanceVoById(vo);
redisSlimeUtils.delPerformanceVo(performancesId);
performanceUtils.performanceVoStatus(performancesId, null);
log.info(UserPathDto.setPartnerData("0", "onLine", "performancesId=" + performancesId + ",ticketsId=" + ticketsId, "上线成功"));
return ResponseDto.success("上线成功");
} else {
return ResponseDto.failure(ErrorMapping.get(20110));
}
}
}
break;
}
if (ticketData != null && ticketData.getStatus() >= 3 && ticketData.getStatus() != 4 && ticketData.getStatus() != 6) {//未提审||被拒绝
//mysql
queueUtil.sendMsgByRedis(MQConst.SlimeQueue.SQL_SLIME_TICKET_UPDATE.getKey(),
SqlMapping.get("kylin_ticket_status.update_status",
9, updatedAt, ticketsId, updatedAt, updatedAt
));
//mongo
KylinTicketPartnerVo ticketPartnerVo = KylinTicketPartnerVo.getNew();
ticketPartnerVo.setTicketsId(ticketsId);
ticketPartnerVo.setStatus(9);
mongoSlimeUtils.updateTicketPartnerVo(ticketPartnerVo);
performanceUtils.performanceVoStatus(performancesId, null);
redisSlimeUtils.delPerformanceVo(performancesId);
log.info(UserPathDto.setPartnerData("0", "onLine", "performancesId=" + performancesId + ",ticketsId=" + ticketsId, "上线成功"));
return ResponseDto.success("上线成功");
} else {
return ResponseDto.failure(ErrorMapping.get(20110));
}
return ResponseDto.failure(ErrorMapping.get(20110));
} catch (Exception e) {
e.printStackTrace();
log.info(UserPathDto.setPartnerData("0", "onLine", "performancesId=" + performancesId + ",ticketsId=" + ticketsId, "上线失败"));
......@@ -424,36 +422,35 @@ public class KylinTicketsPartnerServiceImpl implements IKylinTicketsPartnerServi
}
}
KylinTicketTimesVo ticketTimesData;
KylinTicketVo ticketData = null;
for (int x = 0; x < vo.getTicketTimeList().size(); x++) {
ticketTimesData = vo.getTicketTimeList().get(x);
for (int y = 0; y < ticketTimesData.getTicketList().size(); y++) {
KylinTicketVo ticketItem = ticketTimesData.getTicketList().get(y);
if (ticketItem.getTicketsId().equals(ticketsId)) {
ticketData = ticketItem;
break;
if (ticketItem != null && ticketItem.getStatus() >= 3 && ticketItem.getStatus() != 4) {//未提审||被拒绝 && ticketData.getStatus() != 7
//mysql
queueUtil.sendMsgByRedis(MQConst.SlimeQueue.SQL_SLIME_TICKET_UPDATE.getKey(),
SqlMapping.get("kylin_ticket_status.update_status",
7, updatedAt, ticketsId, updatedAt, updatedAt
));
// mongo 操作
KylinTicketPartnerVo ticketPartnerVo = KylinTicketPartnerVo.getNew();
ticketPartnerVo.setTicketsId(ticketsId);
ticketPartnerVo.setStatus(7);
ticketItem.setStatus(7);
mongoSlimeUtils.updateTicketPartnerVo(ticketPartnerVo);
mongoSlimeUtils.updateKylinPerformanceVoById(vo);
redisSlimeUtils.delPerformanceVo(performancesId);
performanceUtils.performanceVoStatus(performancesId, null);
log.info(UserPathDto.setPartnerData("0", "outLine", "performancesId=" + performancesId + ",ticketsId=" + ticketsId, "下线成功"));
return ResponseDto.success("下线成功");
} else {
return ResponseDto.failure(ErrorMapping.get(20111));
}
}
}
break;
}
if (ticketData != null && ticketData.getStatus() >= 3 && ticketData.getStatus() != 4 && ticketData.getStatus() != 7) {//未提审||被拒绝
//mysql
queueUtil.sendMsgByRedis(MQConst.SlimeQueue.SQL_SLIME_TICKET_UPDATE.getKey(),
SqlMapping.get("kylin_ticket_status.update_status",
7, updatedAt, ticketsId, updatedAt, updatedAt
));
// mongo 操作
KylinTicketPartnerVo ticketPartnerVo = KylinTicketPartnerVo.getNew();
ticketPartnerVo.setTicketsId(ticketsId);
ticketPartnerVo.setStatus(7);
mongoSlimeUtils.updateTicketPartnerVo(ticketPartnerVo);
performanceUtils.performanceVoStatus(performancesId, null);
redisSlimeUtils.delPerformanceVo(performancesId);
log.info(UserPathDto.setPartnerData("0", "outLine", "performancesId=" + performancesId + ",ticketsId=" + ticketsId, "下线成功"));
return ResponseDto.success("下线成功");
} else {
return ResponseDto.failure(ErrorMapping.get(20111));
}
return ResponseDto.failure(ErrorMapping.get(20111));
} catch (Exception e) {
e.printStackTrace();
log.info(UserPathDto.setPartnerData("0", "outLine", "performancesId=" + performancesId + ",ticketsId=" + ticketsId, "下线失败"));
......
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