修改场次

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

@@ -651,7 +651,6 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
 
     //删除演出下所有订单缓存(订单详情，订单列表)
     public void delOrderTicketsRedis(KylinPerformanceMisVo vo) {
-
         //找到所有ticketId
         List<TicketTimesTicketCreatePartnerVo> timesVoList = vo.getTicketTimes();
         for (TicketTimesTicketCreatePartnerVo timesVo : timesVoList) {
@@ -660,18 +659,22 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
             List<String> orderTicketIdList = new ArrayList<>();
             List<OrderIdsDao> orderIdsDaoList = kylinOrderTicketsMapper.getOrderUserIdByTimesId(timesVo.getTicketTimesId());
             for (OrderIdsDao item : orderIdsDaoList) {
-                orderTicketRedisIdList.add(KylinRedisConst.ORDER+item.getOrderTicketsId());
-                userRedisIdList.add(KylinRedisConst.ORDER_LIST+item.getUserId());
+                orderTicketRedisIdList.add(KylinRedisConst.ORDER + item.getOrderTicketsId());
+                userRedisIdList.add(KylinRedisConst.ORDER_LIST + item.getUserId());
                 orderTicketIdList.add(item.getOrderTicketsId());
             }
             HashMap<String, Object> mapMongo = new HashMap<>();
-            mapMongo.put("useStart",timesVo.getUseStart());
+            mapMongo.put("useStart", timesVo.getUseStart());
+            long time1 = System.currentTimeMillis();
             mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateMany(
                     Query.query(Criteria.where("orderTicketsId").in(orderTicketIdList)).getQueryObject(),
                     new BasicDBObject("$set", mongoConverter.convertToMongoType(mapMongo))
             );
+            log.debug("修改 mongo time -> " + (System.currentTimeMillis() - time1) + " ms ");
 
-            dataUtils.delOrderIdUserIdRedis(orderTicketRedisIdList,userRedisIdList);
+            time1 = System.currentTimeMillis();
+            dataUtils.delOrderIdUserIdRedis(orderTicketRedisIdList, userRedisIdList);
+            log.debug("修改 mongo time -> " + (System.currentTimeMillis() - time1) + " ms ");
         }
     }
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/QueueUtils.java

+package com.liquidnet.client.admin.zhengzai.kylin.utils;
+
+import com.liquidnet.commons.lang.util.CollectionUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.connection.stream.StreamRecords;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+
+@Component
+public class QueueUtils {
+
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    /**
+     * 发送消息 - REDIS
+     *
+     * @param streamKey Redis消费Key
+     * @param jsonMsg   Json字符串
+     */
+    public void sendMsgByRedis(String streamKey, String jsonMsg) {
+        HashMap<String, String> map = CollectionUtil.mapStringString();
+        map.put("message", jsonMsg);
+        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+    }
+}