mq相关提交

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/KylinPerformancesAdminServiceImpl.java

@@ -535,6 +535,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     public boolean changeSysDamai(List<SysDamaiParam> params) {
         try {
             LocalDateTime updatedAt = LocalDateTime.now();
+            String performancesId="";
             for (SysDamaiParam item : params) {
                 if (item.getStatus() != 0 && item.getStatus() != 1) {
                     return false;
@@ -546,12 +547,14 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                     ticketStatus.setSyncDamai(item.getStatus());
                     ticketStatusMapper.update(ticketStatus, new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", item.getId()));
                 } else if (item.getType().equals("performance")) {
+                    performancesId=item.getId();
                     KylinPerformanceStatus performanceStatus = new KylinPerformanceStatus();
                     performanceStatus.setUpdatedAt(updatedAt);
                     performanceStatus.setSyncDamai(item.getStatus());
                     performanceStatusMapper.update(performanceStatus, new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", item.getId()));
                 }
             }
+            dataUtils.updatePerformanceMongo(performancesId);
             return true;
         } catch (Exception e) {
             return false;

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsServiceImpl.java

@@ -936,7 +936,7 @@ public class KylinOrderTicketsServiceImpl extends ServiceImpl<KylinOrderTicketsM
                 KylinTicketTimesVo timeItem = vo.getTicketTimeList().get(x);
                 for (int y = 0; y < timeItem.getTicketList().size(); y++) {
                     KylinTicketVo ticketItem = timeItem.getTicketList().get(y);
-                    if (ticketItem.getTimeId().equals(orderData.getTicketId())) {
+                    if (ticketItem.getTicketsId().equals(orderData.getTicketId())) {
                         isSysDamai = ticketItem.getSysDamai();
                         break;
                     }