admin 审核

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

 package com.liquidnet.client.admin.zhengzai.kylin.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.github.pagehelper.PageHelper;
@@ -8,15 +9,19 @@ import com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.PerformanceVoUtils;
 import com.liquidnet.commons.lang.util.BeanUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
+import com.liquidnet.commons.lang.util.JsonUtils;
+import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dao.*;
 import com.liquidnet.service.kylin.dto.param.*;
 import com.liquidnet.service.kylin.dto.vo.admin.KylinPerformanceAgentVo;
 import com.liquidnet.service.kylin.dto.vo.admin.KylinPerformanceDamaiVo;
 import com.liquidnet.service.kylin.dto.vo.admin.KylinPerformanceMemberHistoryVo;
 import com.liquidnet.service.kylin.dto.vo.admin.PerformanceRefundConfigVo;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinPerformanceMisVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketPartnerVo;
 import com.liquidnet.service.kylin.dto.vo.partner.KylinTicketTimesPartnerVo;
+import com.liquidnet.service.kylin.dto.vo.partner.TicketTimesTicketCreatePartnerVo;
 import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.kylin.service.admin.IKylinPerformancesAdminService;
@@ -83,13 +88,7 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     private KylinTicketStatusMapper ticketStatusMapper;
 
     @Autowired
-    private KylinTicketRelationsMapper ticketRelationsMapper;
-
-    @Autowired
-    private KylinTicketTimesMapper ticketTimesMapper;
-
-    @Autowired
-    private KylinTicketTimeRelationMapper ticketTimeRelationMapper;
+    private KylinOrderTicketsMapper kylinOrderTicketsMapper;
 
     @Override
     public KylinPerformanceMisVo performanceDetails(String performancesId) {
@@ -114,14 +113,13 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                 map.put("auditStatus", auditStatus);
                 map.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
                 BasicDBObject objectPerformanceVo = new BasicDBObject("$set", mongoConverter.convertToMongoType(map));
-                mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).findOneAndUpdate(
+                mongoTemplate.getCollection(PerformancePartnerVo.class.getSimpleName()).updateOne(
                         Query.query(Criteria.where("performancesId").is(performancesId)).getQueryObject(),
-                        objectPerformanceVo,
-                        new FindOneAndUpdateOptions().returnDocument(ReturnDocument.AFTER)
+                        objectPerformanceVo
                 );
 
                 KylinPerformanceStatus sqlStatus = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
-                dataUtils.setPerformanceIsTrueName(performancesId,sqlStatus.getIsTrueName());
+                dataUtils.setPerformanceIsTrueName(performancesId, sqlStatus.getIsTrueName());
                 if (sqlStatus.getStatus() == 1) {
                     log.info(" PERFORMANCE  演出审核 第一次");
                     //修改
@@ -159,10 +157,12 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
                     HashMap<String, Object> mapSql = new HashMap<>();
                     mapSql.put("status", 9);
                     mapSql.put("updatedAt", updatedAt.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
-                    performanceVoUtils.updatePerformanceMySql(performancesId, mapSql, performanceVoUtils.getPerformanceMisVo(performancesId), updatedAt, auditStatus);
+                    KylinPerformanceMisVo vo = performanceVoUtils.getPerformanceMisVo(performancesId);
+                    performanceVoUtils.updatePerformanceMySql(performancesId, mapSql, vo, updatedAt, auditStatus);
                     if (sqlStatus.getStatus() >= 6 && sqlStatus.getStatus() != 7) {//若 演出上 则 线判断状态
                         performanceVoUtils.performanceVoStatus(performancesId);
                     }
+                    delOrderTicketsRedis(vo);
                 }
 
                 dataUtils.delPerformanceRedis(performancesId);
@@ -575,8 +575,8 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
         vo.setPerformancesId(kylinPerformances.getPerformancesId());
         vo.setTitle(kylinPerformances.getTitle());
         vo.setIsCanRefund(kylinPerformanceStatus.getIsCanRefund());
-        vo.setRefundCloseTime(kylinPerformanceStatus.getRefundCloseTime()==null?"":DateUtil.Formatter.yyyyMMddHHmmss.format(kylinPerformanceStatus.getRefundCloseTime()));
-        vo.setRefundOpenTime(kylinPerformanceStatus.getRefundOpenTime()==null?"":DateUtil.Formatter.yyyyMMddHHmmss.format(kylinPerformanceStatus.getRefundOpenTime()));
+        vo.setRefundCloseTime(kylinPerformanceStatus.getRefundCloseTime() == null ? "" : DateUtil.Formatter.yyyyMMddHHmmss.format(kylinPerformanceStatus.getRefundCloseTime()));
+        vo.setRefundOpenTime(kylinPerformanceStatus.getRefundOpenTime() == null ? "" : DateUtil.Formatter.yyyyMMddHHmmss.format(kylinPerformanceStatus.getRefundOpenTime()));
         return vo;
     }
 
@@ -648,4 +648,30 @@ public class KylinPerformancesAdminServiceImpl extends ServiceImpl<KylinPerforma
     public List<PerformanceSponsorDao> getPerformanceSponsorList(String sponsorType) {
         return performancesMapper.getPerformanceSponsorList(sponsorType);
     }
+
+    //删除演出下所有订单缓存(订单详情，订单列表)
+    public void delOrderTicketsRedis(KylinPerformanceMisVo vo) {
+
+        //找到所有ticketId
+        List<TicketTimesTicketCreatePartnerVo> timesVoList = vo.getTicketTimes();
+        for (TicketTimesTicketCreatePartnerVo timesVo : timesVoList) {
+            List<String> orderTicketRedisIdList = new ArrayList<>();
+            List<String> userRedisIdList = new ArrayList<>();
+            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());
+                orderTicketIdList.add(item.getOrderTicketsId());
+            }
+            HashMap<String, Object> mapMongo = new HashMap<>();
+            mapMongo.put("useStart",timesVo.getUseStart());
+            mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateMany(
+                    Query.query(Criteria.where("orderTicketsId").in(orderTicketIdList)).getQueryObject(),
+                    new BasicDBObject("$set", mongoConverter.convertToMongoType(mapMongo))
+            );
+
+            dataUtils.delOrderIdUserIdRedis(orderTicketRedisIdList,userRedisIdList);
+        }
+    }
 }

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

@@ -313,12 +313,18 @@ public class DataUtils {
             redisUtil.del(KylinRedisConst.ORDER_REFUND.concat(id));
         }
     }
+
     public void delOrderRefundVoByOrderId(List<String>  orderIds){
         for (String id : orderIds) {
             redisUtil.del(KylinRedisConst.ORDER_REFUND_BY_ORDER_ID.concat(id));
         }
     }
 
+    public void delOrderIdUserIdRedis(List<String> orderTicketIdList,List<String> userIdList){
+        redisUtil.delList(orderTicketIdList);
+        redisUtil.delList(userIdList);
+    }
+
     /**
      * Object转BigDecimal类型
      *

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisUtil.java

@@ -24,7 +24,6 @@ import java.util.concurrent.TimeUnit;
 public final class RedisUtil {
 
 
-
     @Autowired
     private RedisTemplate<String, Object> redisTemplate;
 
@@ -32,15 +31,11 @@ public final class RedisUtil {
     // =============================common============================
 
     /**
-
      * 指定缓存失效时间
-
+     *
      * @param key  键
-
      * @param time 时间(秒)
-
      * @return
-
      */
 
     public boolean expire(String key, long time) {
@@ -57,13 +52,10 @@ public final class RedisUtil {
 
 
     /**
-
      * 根据key 获取过期时间
-
+     *
      * @param key 键 不能为null
-
      * @return 时间(秒) 返回0代表为永久有效
-
      */
 
     public long getExpire(String key) {
@@ -74,13 +66,10 @@ public final class RedisUtil {
 
 
     /**
-
      * 判断key是否存在
-
+     *
      * @param key 键
-
      * @return true 存在 false不存在
-
      */
 
     public boolean hasKey(String key) {
@@ -106,11 +95,9 @@ public final class RedisUtil {
 
 
     /**
-
      * 删除缓存
-
+     *
      * @param key 可以传一个值 或多个
-
      */
 
     @SuppressWarnings("unchecked")
@@ -133,17 +120,22 @@ public final class RedisUtil {
 
     }
 
+    public void delList(List<String> key) {
+
+        if (key != null && key.size() > 0) {
+            redisTemplate.delete(key);
+        }
+
+    }
+
 
     // ============================String=============================
 
     /**
-
      * 普通缓存获取
-
+     *
      * @param key 键
-
      * @return 值
-
      */
 
     public Object get(String key) {
@@ -154,15 +146,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 普通缓存放入
-
+     *
      * @param key   键
-
      * @param value 值
-
      * @return true成功 false失败
-
      */
 
     public boolean set(String key, Object value) {
@@ -173,22 +161,16 @@ public final class RedisUtil {
         return true;
 
 
-
     }
 
 
     /**
-
      * 普通缓存放入并设置时间
-
+     *
      * @param key   键
-
      * @param value 值
-
      * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
-
      * @return true成功 false 失败
-
      */
 
     public boolean set(String key, Object value, long time) {
@@ -211,15 +193,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 递增
-
+     *
      * @param key   键
-
      * @param delta 要增加几(大于0)
-
      * @return
-
      */
 
     public long incr(String key, long delta) {
@@ -236,15 +214,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 递减
-
+     *
      * @param key   键
-
      * @param delta 要减少几(小于0)
-
      * @return
-
      */
 
     public long decr(String key, long delta) {
@@ -263,15 +237,11 @@ public final class RedisUtil {
     // ================================Map=================================
 
     /**
-
      * HashGet
-
+     *
      * @param key  键 不能为null
-
      * @param item 项 不能为null
-
      * @return 值
-
      */
 
     public Object hget(String key, String item) {
@@ -284,13 +254,10 @@ public final class RedisUtil {
 
 
     /**
-
      * 获取hashKey对应的所有键值
-
+     *
      * @param key 键
-
      * @return 对应的多个键值
-
      */
 
     public Map<Object, Object> hmget(String key) {
@@ -301,15 +268,11 @@ public final class RedisUtil {
 
 
     /**
-
      * HashSet
-
+     *
      * @param key 键
-
      * @param map 对应多个键值
-
      * @return true 成功 false 失败
-
      */
 
     public boolean hmset(String key, Map<String, Object> map) {
@@ -324,17 +287,12 @@ public final class RedisUtil {
 
 
     /**
-
      * HashSet 并设置时间
-
+     *
      * @param key  键
-
      * @param map  对应多个键值
-
      * @param time 时间(秒)
-
      * @return true成功 false失败
-
      */
 
     public boolean hmset(String key, Map<String, Object> map, long time) {
@@ -355,17 +313,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 向一张hash表中放入数据,如果不存在将创建
-
+     *
      * @param key   键
-
      * @param item  项
-
      * @param value 值
-
      * @return true 成功 false失败
-
      */
 
     public boolean hset(String key, String item, Object value) {
@@ -380,19 +333,13 @@ public final class RedisUtil {
 
 
     /**
-
      * 向一张hash表中放入数据,如果不存在将创建
-
+     *
      * @param key   键
-
      * @param item  项
-
      * @param value 值
-
      * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
-
      * @return true 成功 false失败
-
      */
 
     public boolean hset(String key, String item, Object value, long time) {
@@ -413,13 +360,10 @@ public final class RedisUtil {
 
 
     /**
-
      * 删除hash表中的值
-
+     *
      * @param key  键 不能为null
-
      * @param item 项 可以使多个 不能为null
-
      */
 
     public void hdel(String key, Object... item) {
@@ -430,15 +374,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 判断hash表中是否有该项的值
-
+     *
      * @param key  键 不能为null
-
      * @param item 项 不能为null
-
      * @return true 存在 false不存在
-
      */
 
     public boolean hHasKey(String key, String item) {
@@ -449,17 +389,12 @@ public final class RedisUtil {
 
 
     /**
-
      * hash递增 如果不存在,就会创建一个 并把新增后的值返回
-
+     *
      * @param key  键
-
      * @param item 项
-
      * @param by   要增加几(大于0)
-
      * @return
-
      */
 
     public double hincr(String key, String item, double by) {
@@ -470,17 +405,12 @@ public final class RedisUtil {
 
 
     /**
-
      * hash递减
-
+     *
      * @param key  键
-
      * @param item 项
-
      * @param by   要减少记(小于0)
-
      * @return
-
      */
 
     public double hdecr(String key, String item, double by) {
@@ -493,13 +423,10 @@ public final class RedisUtil {
     // ============================set=============================
 
     /**
-
      * 根据key获取Set中的所有值
-
+     *
      * @param key 键
-
      * @return
-
      */
 
     public Set<Object> sGet(String key) {
@@ -512,15 +439,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 根据value从一个set中查询,是否存在
-
+     *
      * @param key   键
-
      * @param value 值
-
      * @return true 存在 false不存在
-
      */
 
     public boolean sHasKey(String key, Object value) {
@@ -533,15 +456,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 将数据放入set缓存
-
+     *
      * @param key    键
-
      * @param values 值 可以是多个
-
      * @return 成功个数
-
      */
 
     public long sSet(String key, Object... values) {
@@ -554,17 +473,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 将set数据放入缓存
-
+     *
      * @param key    键
-
      * @param time   时间(秒)
-
      * @param values 值 可以是多个
-
      * @return 成功个数
-
      */
 
     public long sSetAndTime(String key, long time, Object... values) {
@@ -583,13 +497,10 @@ public final class RedisUtil {
 
 
     /**
-
      * 获取set缓存的长度
-
+     *
      * @param key 键
-
      * @return
-
      */
 
     public long sGetSetSize(String key) {
@@ -602,15 +513,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 移除值为value的
-
+     *
      * @param key    键
-
      * @param values 值 可以是多个
-
      * @return 移除的个数
-
      */
 
     public long setRemove(String key, Object... values) {
@@ -627,17 +534,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 获取list缓存的内容
-
+     *
      * @param key   键
-
      * @param start 开始
-
      * @param end   结束 0 到 -1代表所有值
-
      * @return
-
      */
 
     public List<Object> lGet(String key, long start, long end) {
@@ -650,13 +552,10 @@ public final class RedisUtil {
 
 
     /**
-
      * 获取list缓存的长度
-
+     *
      * @param key 键
-
      * @return
-
      */
 
     public long lGetListSize(String key) {
@@ -669,15 +568,11 @@ public final class RedisUtil {
 
 
     /**
-
      * 通过索引 获取list中的值
-
+     *
      * @param key   键
-
      * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
-
      * @return
-
      */
 
     public Object lGetIndex(String key, long index) {
@@ -691,6 +586,7 @@ public final class RedisUtil {
 
     /**
      * 将list放入缓存
+     *
      * @param key
      * @param value
      * @return
@@ -707,17 +603,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 将list放入缓存
-
+     *
      * @param key   键
-
      * @param value 值
-
      * @param time  时间(秒)
-
      * @return
-
      */
 
     public boolean lSet(String key, Object value, long time) {
@@ -737,6 +628,7 @@ public final class RedisUtil {
 
     /**
      * 将list放入缓存
+     *
      * @param key
      * @param value
      * @return
@@ -753,19 +645,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 将list放入缓存
-
      *
-
      * @param key   键
-
      * @param value 值
-
      * @param time  时间(秒)
-
      * @return
-
      */
 
     public boolean lSet(String key, List<Object> value, long time) {
@@ -784,17 +669,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 根据索引修改list中的某条数据
-
+     *
      * @param key   键
-
      * @param index 索引
-
      * @param value 值
-
      * @return
-
      */
 
     public boolean lUpdateIndex(String key, long index, Object value) {
@@ -809,17 +689,12 @@ public final class RedisUtil {
 
 
     /**
-
      * 移除N个值为value
-
+     *
      * @param key   键
-
      * @param count 移除多少个
-
      * @param value 值
-
      * @return 移除的个数
-
      */
 
     public long lRemove(String key, long count, Object value) {

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/dao/OrderIdsDao.java

+package com.liquidnet.service.kylin.dao;
+
+import lombok.Data;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: PerformanceOrderListDao
+ * @Package com.liquidnet.service.kylin.dao
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/6/4 13:31
+ */
+@Data
+public class OrderIdsDao {
+    String orderTicketsId;
+    String userId;
+}

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/java/com/liquidnet/service/kylin/mapper/KylinOrderTicketsMapper.java

 package com.liquidnet.service.kylin.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.liquidnet.service.kylin.dao.OrderPushDamaiDto;
-import com.liquidnet.service.kylin.dao.OrderScriptDto;
-import com.liquidnet.service.kylin.dao.OrderTicketsListDao;
-import com.liquidnet.service.kylin.dao.PerformanceExpressPerformanceOrderListAdminDao;
+import com.liquidnet.service.kylin.dao.*;
 import com.liquidnet.service.kylin.entity.KylinOrderTickets;
 import org.apache.ibatis.annotations.Param;
 
@@ -38,4 +35,6 @@ public interface KylinOrderTicketsMapper extends BaseMapper<KylinOrderTickets> {
 
     List<KylinOrderTickets> getCanPlaceOrderList(@Param("performanceId") String performanceId, @Param("mid") int mid, @Param("limitNum") int limitNum);
 
+    List<OrderIdsDao> getOrderUserIdByTimesId(@Param("timeId") String timeId);
+
 }

liquidnet-bus-do/liquidnet-service-kylin-do/src/main/resources/com.liquidnet.service.kylin.mapper/KylinOrderTicketsMapper.xml

@@ -341,4 +341,9 @@
         ORDER BY mid ASC
         LIMIT ${limitNum}
     </select>
+
+    <select id="getOrderUserIdByTimesId" resultType="com.liquidnet.service.kylin.dao.OrderIdsDao">
+        select order_tickets_id,user_id from kylin_order_tickets as kot left join kylin_order_ticket_relations as kotr on kotr.order_id = kot.order_tickets_id
+        where time_id =#{timeId}
+    </select>
 </mapper>