修改消费日志

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

@@ -45,7 +45,7 @@ import java.util.*;
  */
 @Service
 @Slf4j
-public class DMCheckOrderTimeImpl extends ServiceImpl<KylinOrderTicketsMapper, KylinOrderTickets>{
+public class DMCheckOrderTimeImpl extends ServiceImpl<KylinOrderTicketsMapper, KylinOrderTickets> {
 
     @Autowired
     private DataUtils dataUtils;
@@ -95,13 +95,6 @@ public class DMCheckOrderTimeImpl extends ServiceImpl<KylinOrderTicketsMapper, K
 
         if (orderDataList.size() > 0) {
             //mysql
-            String orderStr = "";
-            for (int i = 0; i < orderIdList.size(); i++) {
-                String orderTicketId = orderIdList.get(i);
-                orderStr += "'" + orderTicketId + "',";
-            }
-            orderStr = orderStr.substring(0, orderStr.length() - 1);
-
             KylinOrderTickets orderTickets = new KylinOrderTickets();
             orderTickets.setUpdatedAt(now);
             orderTicketsMapper.update(orderTickets, new UpdateWrapper<KylinOrderTickets>().in("order_tickets_id", orderIdList));
@@ -149,6 +142,7 @@ public class DMCheckOrderTimeImpl extends ServiceImpl<KylinOrderTicketsMapper, K
                         break;
                     }
                 }
+                log.debug("MQLIST SIZE  = " + mqList.size());
                 rabbitTemplate.convertAndSend(MQConst.EXCHANGES_LIQUIDNET_SQL_ORDER_CLOSE, MQConst.ROUTING_KEY_SQL_ORDER_CLOSE, OrderCloseMapping.get(mqList));
             }
         }