Merge branch 'dev' into test

liquidnet-bus-api/liquidnet-service-adam-api/src/main/java/com/liquidnet/service/adam/service/IAdamRdmService.java

-package com.liquidnet.service.adam.service;
-
-import com.liquidnet.service.adam.dto.vo.*;
-import com.liquidnet.service.adam.entity.AdamEnters;
-
-import java.util.List;
-
-public interface IAdamRdmService {
-    boolean setUidByMobile(String mobile, String uid);
-
-    String getUidByMobile(String mobile);
-
-    void delUidByMobile(String mobile);
-
-    boolean setUidByPlatformOpenId(String platform, String openId, String uid);
-
-    String getUidByPlatformOpenId(String platform, String openId);
-
-    void delUidByPlatformOpenId(String platform, String openId);
-
-    boolean setUserInfoVoByUid(String uid, AdamUserInfoVo vo);
-
-    AdamUserInfoVo getUserInfoVoByUid(String uid);
-
-    void delUserInfoVoByUid(String uid);
-
-    boolean setRealInfoVoByUid(String uid, AdamRealInfoVo vo);
-
-    AdamRealInfoVo getRealInfoVoByUid(String uid);
-
-    boolean setCertification(int idType, String idNo, String idName);
-
-    boolean isCertification(int idType, String idNo, String idName);
-
-    boolean setThirdPartVoListByUid(String uid, List<AdamThirdPartInfoVo> voList);
-
-    List<AdamThirdPartInfoVo> getThirdPartVoListByUid(String uid);
-
-    AdamThirdPartInfoVo getThirdPartVoByUidPlatform(String uid, String platform);
-
-    void delThirdPartVoListByUid(String uid);
-
-    boolean setEntersVoByUid(String uid, List<AdamEntersVo> list);
-
-    List<AdamEntersVo> getEntersVoByUid(String uid);
-
-    AdamEntersVo getEntersVoByUidEntersId(String uid, String entersId);
-
-    List<AdamEntersVo> getEntersVoByUidEntersIds(String uid, String... entersIds);
-
-    void delEntersVoByUid(String uid);
-
-    boolean setAddressesVoByUid(String uid, List<AdamAddressesVo> list);
-
-    List<AdamAddressesVo> getAddressesVoByUid(String uid);
-
-    AdamAddressesVo getAddressesVoByUidAddressesId(String uid, String addressesId);
-
-    void delAddressesVoByUid(String uid);
-
-    boolean setBlacklistForMember(List<String> uids);
-
-    List<String> getBlacklistForMember();
-
-    boolean setUserMemberVoByUid(String uid, AdamUserMemberVo vo);
-
-    AdamUserMemberVo getUserMemberVoByUid(String uid);
-
-    void delUserMemberVoByUid(String uid);
-
-    AdamMemberSimpleVo getMemberSimpleVo();
-
-    boolean setMemberVoByMemberId(String memberId, AdamMemberVo vo);
-
-    AdamMemberVo getMemberVoByMemberId(String memberId);
-
-    void delMemberVoByMemberId(String memberId);
-
-    boolean setMemberPriceVoByMemberId(String memberId, List<AdamMemberPriceVo> vos);
-
-    List<AdamMemberPriceVo> getMemberPriceVoByMemberId(String memberId);
-
-    AdamMemberPriceVo getMemberPriceVoByPriceId(String memberId, String memberPriceId);
-
-    boolean setMemberRightsVoByMemberId(String memberId, List<AdamMemberRightsVo> vos);
-
-    List<AdamMemberRightsVo> getMemberRightsVoByMemberId(String memberId);
-
-    String getMemberAgreement();
-
-    boolean setShotMemberOrderVoByOrderNo(String orderNo, AdamMemberOrderVo vo);
-
-    AdamMemberOrderVo getShotMemberOrderVoByOrderNo(String orderNo);
-
-    void delShotMemberOrderVoByOrderNo(String orderNo);
-
-    boolean setMaxMemberNo(int val);
-
-    int incrMemberNo();
-
-    int getMaxMemberNo();
-
-    boolean setMemberCodeVoByCode(String memberCode, AdamMemberCodeVo vo);
-
-    AdamMemberCodeVo getMemberCodeVoByCode(String memberCode);
-
-    /**
-     * Temporarily connect Mongo
-     */
-    AdamMemberCodeVo getMemberCodeVoByBuyOrderNo(String buyOrderNo);
-
-    void delMemberCodeVoByCode(String memberCode);
-
-    boolean setTagsForSex(List<AdamTagVo> voList);
-
-    List<AdamTagVo> getTagsForSex();
-
-    boolean setTagsForMusic(List<AdamTagParentVo> voList);
-
-    List<AdamTagParentVo> getTagsForMusic();
-}

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamAddressesController.java

@@ -6,8 +6,8 @@ import com.liquidnet.commons.lang.util.CurrentUtil;
 import com.liquidnet.commons.lang.util.SensitizeUtil;
 import com.liquidnet.service.adam.dto.AdamAddressesParam;
 import com.liquidnet.service.adam.dto.vo.AdamAddressesVo;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamAddressesService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
 import io.swagger.annotations.Api;
@@ -39,7 +39,7 @@ import java.util.List;
 @RequestMapping("addr")
 public class AdamAddressesController {
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamAddressesService adamAddressesService;
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamEntersController.java

@@ -7,7 +7,7 @@ import com.liquidnet.commons.lang.util.SensitizeUtil;
 import com.liquidnet.service.adam.dto.AdamEntersParam;
 import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
 import com.liquidnet.service.adam.service.IAdamEntersService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
 import io.swagger.annotations.Api;
@@ -40,7 +40,7 @@ import java.util.Optional;
 @RequestMapping("enters")
 public class AdamEntersController {
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamEntersService adamEntersService;
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamLoginController.java

@@ -59,7 +59,7 @@ public class AdamLoginController {
     @Autowired
     DefaultAcsClient defaultAcsClient;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamUserService adamUserService;
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamMemberController.java

@@ -7,7 +7,7 @@ import com.liquidnet.service.adam.dto.vo.AdamMemberSimpleVo;
 import com.liquidnet.service.adam.dto.vo.AdamMemberVo;
 import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
 import com.liquidnet.service.adam.service.IAdamMemberService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserMemberService;
 import com.liquidnet.service.base.ResponseDto;
 import io.swagger.annotations.Api;
@@ -31,7 +31,7 @@ import javax.validation.constraints.NotBlank;
 @RequestMapping("member")
 public class AdamMemberController {
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamMemberService adamMemberService;
     @Autowired

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamMemberOrderController.java

@@ -15,7 +15,7 @@ import com.liquidnet.service.adam.dto.AdamMemberOrderParam;
 import com.liquidnet.service.adam.dto.AdamMemberOrderResult;
 import com.liquidnet.service.adam.dto.vo.*;
 import com.liquidnet.service.adam.service.IAdamMemberOrderService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserService;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.ResponseDto;
@@ -48,7 +48,7 @@ public class AdamMemberOrderController {
     @Autowired
     Environment env;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamMemberOrderService adamMemberOrderService;
     @Autowired

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/AdamUserController.java

@@ -10,7 +10,7 @@ import com.liquidnet.commons.lang.util.SensitizeUtil;
 import com.liquidnet.service.adam.dto.AdamThirdPartParam;
 import com.liquidnet.service.adam.dto.AdamUserInfoParam;
 import com.liquidnet.service.adam.dto.vo.*;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserInfoService;
 import com.liquidnet.service.adam.service.IAdamUserService;
 import com.liquidnet.service.base.ErrorMapping;
@@ -43,7 +43,7 @@ public class AdamUserController {
     @Autowired
     Environment env;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamUserService adamUserService;
     @Autowired

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/controller/admin/AdamMemberAdminController.java

@@ -7,7 +7,7 @@ import com.liquidnet.service.adam.dto.AdamMemberParam;
 import com.liquidnet.service.adam.dto.vo.AdamMemberVo;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
 import com.liquidnet.service.adam.entity.AdamMember;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.admin.IAdamMemberAdminService;
 import com.liquidnet.service.adam.service.admin.IAdamMemberCodeAdminService;
 import com.liquidnet.service.base.ResponseDto;
@@ -35,7 +35,7 @@ public class AdamMemberAdminController extends AdamBaseController {
     @Autowired
     IAdamMemberCodeAdminService adamMemberCodeAdminService;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
     @ApiOperationSupport(order = 1)
     @ApiOperation(value = "添加会员卡")

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamRdmServiceImpl.java → liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/AdamRdmService.java

-package com.liquidnet.service.adam.service.impl;
+package com.liquidnet.service.adam.service;
 
 import com.liquidnet.common.cache.redis.util.RedisUtil;
+import com.liquidnet.commons.lang.util.DateUtil;
 import com.liquidnet.commons.lang.util.SensitizeUtil;
 import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.vo.*;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.kylin.constant.KylinRedisConst;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Sort;
@@ -16,6 +18,7 @@ import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
 import java.time.LocalDateTime;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Optional;
@@ -23,18 +26,16 @@ import java.util.stream.Collectors;
 
 @Slf4j
 @Service
-public class AdamRdmServiceImpl implements IAdamRdmService {
+public class AdamRdmService {
     @Autowired
     MongoTemplate mongoTemplate;
     @Autowired
     RedisUtil redisUtil;
 
-    @Override
     public boolean setUidByMobile(String mobile, String uid) {
         return redisUtil.set(AdamRedisConst.IDENTITY_MOBILE.concat(mobile), uid);
     }
 
-    @Override
     public String getUidByMobile(String mobile) {
         String key = AdamRedisConst.IDENTITY_MOBILE.concat(mobile);
         long s = System.currentTimeMillis();
@@ -54,17 +55,14 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return val;
     }
 
-    @Override
     public void delUidByMobile(String mobile) {
         redisUtil.del(AdamRedisConst.IDENTITY_MOBILE.concat(mobile));
     }
 
-    @Override
     public boolean setUidByPlatformOpenId(String platform, String openId, String uid) {
         return redisUtil.set(AdamRedisConst.IDENTITY_THIRD_PARTY + platform + ":" + openId, uid);
     }
 
-    @Override
     public String getUidByPlatformOpenId(String platform, String openId) {
         String key = AdamRedisConst.IDENTITY_THIRD_PARTY + platform + ":" + openId;
         long s = System.currentTimeMillis();
@@ -84,17 +82,14 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return val;
     }
 
-    @Override
     public void delUidByPlatformOpenId(String platform, String openId) {
         redisUtil.del(AdamRedisConst.IDENTITY_THIRD_PARTY + platform + ":" + openId);
     }
 
-    @Override
     public boolean setUserInfoVoByUid(String uid, AdamUserInfoVo vo) {
         return redisUtil.set(AdamRedisConst.INFO_USER.concat(uid), vo);
     }
 
-    @Override
     public AdamUserInfoVo getUserInfoVoByUid(String uid) {
         String rk = AdamRedisConst.INFO_USER.concat(uid);
         long s = System.currentTimeMillis();
@@ -111,17 +106,14 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public void delUserInfoVoByUid(String uid) {
         redisUtil.del(AdamRedisConst.INFO_USER.concat(uid));
     }
 
-    @Override
     public boolean setRealInfoVoByUid(String uid, AdamRealInfoVo vo) {
         return redisUtil.set(AdamRedisConst.INFO_REAL_NAME.concat(uid), vo);
     }
 
-    @Override
     public AdamRealInfoVo getRealInfoVoByUid(String uid) {
         String rk = AdamRedisConst.INFO_REAL_NAME.concat(uid);
         long s = System.currentTimeMillis();
@@ -142,23 +134,19 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public boolean setCertification(int idType, String idNo, String idName) {
         return redisUtil.set(AdamRedisConst.INFO_CERTIFICATION + idType + idNo, idName);
     }
 
-    @Override
     public boolean isCertification(int idType, String idNo, String idName) {
         String o = (String) redisUtil.get(AdamRedisConst.INFO_CERTIFICATION + idType + idNo);
         return !StringUtils.isEmpty(o) && o.equals(idName);
     }
 
-    @Override
     public boolean setThirdPartVoListByUid(String uid, List<AdamThirdPartInfoVo> voList) {
         return redisUtil.set(AdamRedisConst.INFO_THIRD_PARTY.concat(uid), voList);
     }
 
-    @Override
     public List<AdamThirdPartInfoVo> getThirdPartVoListByUid(String uid) {
         String rk = AdamRedisConst.INFO_THIRD_PARTY.concat(uid);
         long s = System.currentTimeMillis();
@@ -175,7 +163,6 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return thirdPartInfoVos;
     }
 
-    @Override
     public AdamThirdPartInfoVo getThirdPartVoByUidPlatform(String uid, String platform) {
         List<AdamThirdPartInfoVo> vos = this.getThirdPartVoListByUid(uid);
         if (!CollectionUtils.isEmpty(vos)) {
@@ -189,17 +176,14 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return null;
     }
 
-    @Override
     public void delThirdPartVoListByUid(String uid) {
         redisUtil.del(AdamRedisConst.INFO_THIRD_PARTY.concat(uid));
     }
 
-    @Override
     public boolean setEntersVoByUid(String uid, List<AdamEntersVo> list) {
         return redisUtil.set(AdamRedisConst.INFO_ENTERS.concat(uid), list);
     }
 
-    @Override
     public List<AdamEntersVo> getEntersVoByUid(String uid) {
         String rk = AdamRedisConst.INFO_ENTERS.concat(uid);
         long s = System.currentTimeMillis();
@@ -218,28 +202,23 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vos;
     }
 
-    @Override
     public AdamEntersVo getEntersVoByUidEntersId(String uid, String entersId) {
         return this.getEntersVoByUid(uid).stream().filter(r -> r.getEntersId().equals(entersId)).findAny().orElse(null);
     }
 
-    @Override
     public List<AdamEntersVo> getEntersVoByUidEntersIds(String uid, String... entersIds) {
         List<String> entersIdList = Arrays.asList(entersIds);
         return this.getEntersVoByUid(uid).stream().filter(r -> entersIdList.contains(r.getEntersId())).collect(Collectors.toList());
     }
 
-    @Override
     public void delEntersVoByUid(String uid) {
         redisUtil.del(AdamRedisConst.INFO_ENTERS.concat(uid));
     }
 
-    @Override
     public boolean setAddressesVoByUid(String uid, List<AdamAddressesVo> list) {
         return redisUtil.set(AdamRedisConst.INFO_ADDRESSES.concat(uid), list);
     }
 
-    @Override
     public List<AdamAddressesVo> getAddressesVoByUid(String uid) {
         String rk = AdamRedisConst.INFO_ADDRESSES.concat(uid);
         long s = System.currentTimeMillis();
@@ -258,32 +237,26 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vos;
     }
 
-    @Override
     public AdamAddressesVo getAddressesVoByUidAddressesId(String uid, String addressesId) {
         return this.getAddressesVoByUid(uid).stream().filter(r -> r.getAddressesId().equals(addressesId)).findAny().orElse(null);
     }
 
-    @Override
     public void delAddressesVoByUid(String uid) {
         redisUtil.del(AdamRedisConst.INFO_ADDRESSES.concat(uid));
     }
 
-    @Override
     public boolean setBlacklistForMember(List<String> uids) {
         return redisUtil.set(AdamRedisConst.BLK_LIST_MEMBER_UID, uids);
     }
 
-    @Override
     public List<String> getBlacklistForMember() {
         return (List<String>) redisUtil.get(AdamRedisConst.BLK_LIST_MEMBER_UID);
     }
 
-    @Override
     public boolean setUserMemberVoByUid(String uid, AdamUserMemberVo vo) {
         return redisUtil.set(AdamRedisConst.INFO_USER_MEMBER.concat(uid), vo);
     }
 
-    @Override
     public AdamUserMemberVo getUserMemberVoByUid(String uid) {
         String rk = AdamRedisConst.INFO_USER_MEMBER.concat(uid);
         long s = System.currentTimeMillis();
@@ -302,12 +275,10 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public void delUserMemberVoByUid(String uid) {
         redisUtil.del(AdamRedisConst.INFO_USER_MEMBER.concat(uid));
     }
 
-    @Override
     public AdamMemberSimpleVo getMemberSimpleVo() {
         AdamMemberSimpleVo vo = (AdamMemberSimpleVo) redisUtil.get(AdamRedisConst.INFO_MEMBER_SIMPLE);
         if (null == vo) {
@@ -325,12 +296,10 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public boolean setMemberVoByMemberId(String memberId, AdamMemberVo vo) {
         return redisUtil.set(AdamRedisConst.INFO_MEMBER_CATEGORY.concat(memberId), vo);
     }
 
-    @Override
     public AdamMemberVo getMemberVoByMemberId(String memberId) {
         String key = AdamRedisConst.INFO_MEMBER_CATEGORY.concat(memberId);
         long s = System.currentTimeMillis();
@@ -348,17 +317,14 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public void delMemberVoByMemberId(String memberId) {
         redisUtil.del(AdamRedisConst.INFO_MEMBER_CATEGORY.concat(memberId));
     }
 
-    @Override
     public boolean setMemberPriceVoByMemberId(String memberId, List<AdamMemberPriceVo> vos) {
         return redisUtil.set(AdamRedisConst.INFO_MEMBER_PRICE.concat(memberId), vos);
     }
 
-    @Override
     public List<AdamMemberPriceVo> getMemberPriceVoByMemberId(String memberId) {
         String key = AdamRedisConst.INFO_MEMBER_PRICE.concat(memberId);
         long s = System.currentTimeMillis();
@@ -377,7 +343,6 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vos;
     }
 
-    @Override
     public AdamMemberPriceVo getMemberPriceVoByPriceId(String memberId, String memberPriceId) {
         long s = System.currentTimeMillis();
         List<AdamMemberPriceVo> vos = this.getMemberPriceVoByMemberId(memberId);
@@ -395,12 +360,10 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return null;
     }
 
-    @Override
     public boolean setMemberRightsVoByMemberId(String memberId, List<AdamMemberRightsVo> vos) {
         return redisUtil.set(AdamRedisConst.INFO_MEMBER_RIGHTS.concat(memberId), vos);
     }
 
-    @Override
     public List<AdamMemberRightsVo> getMemberRightsVoByMemberId(String memberId) {
         List<AdamMemberRightsVo> vos = (List<AdamMemberRightsVo>) redisUtil.get(AdamRedisConst.INFO_MEMBER_RIGHTS.concat(memberId));
         if (CollectionUtils.isEmpty(vos)) {
@@ -419,7 +382,6 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vos;
     }
 
-    @Override
     public String getMemberAgreement() {
         String val = (String) redisUtil.get(AdamRedisConst.INFO_MEMBER_AGREEMENT);
         if (StringUtils.isEmpty(val)) {
@@ -430,12 +392,10 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return val;
     }
 
-    @Override
     public boolean setShotMemberOrderVoByOrderNo(String orderNo, AdamMemberOrderVo vo) {
         return redisUtil.set(AdamRedisConst.SHOT_MEMBER_ORDER + orderNo, vo);
     }
 
-    @Override
     public AdamMemberOrderVo getShotMemberOrderVoByOrderNo(String orderNo) {
         String key = AdamRedisConst.SHOT_MEMBER_ORDER + orderNo;
         long s = System.currentTimeMillis();
@@ -454,33 +414,27 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public void delShotMemberOrderVoByOrderNo(String orderNo) {
         redisUtil.del(AdamRedisConst.SHOT_MEMBER_ORDER + orderNo);
     }
 
-    @Override
     public boolean setMaxMemberNo(int val) {
         return redisUtil.set(AdamRedisConst.INCR_MEMBER_NO, val);
     }
 
-    @Override
     public int incrMemberNo() {
         return (int) redisUtil.incr(AdamRedisConst.INCR_MEMBER_NO, 1);
     }
 
-    @Override
     public int getMaxMemberNo() {
         Object o = redisUtil.get(AdamRedisConst.INCR_MEMBER_NO);
         return null == o ? -1 : (int) o;
     }
 
-    @Override
     public boolean setMemberCodeVoByCode(String memberCode, AdamMemberCodeVo vo) {
         return redisUtil.set(AdamRedisConst.INFO_MEMBER_CODE.concat(memberCode), vo);
     }
 
-    @Override
     public AdamMemberCodeVo getMemberCodeVoByCode(String memberCode) {
         String key = AdamRedisConst.INFO_MEMBER_CODE.concat(memberCode);
         long s = System.currentTimeMillis();
@@ -498,7 +452,9 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
+    /**
+     * Temporarily connect Mongo
+     */
     public AdamMemberCodeVo getMemberCodeVoByBuyOrderNo(String buyOrderNo) {
         Query query = Query.query(Criteria.where("buyOrderNo").is(buyOrderNo));
         query.fields().include("code").include("memberNo").include("state").include("type");
@@ -510,28 +466,31 @@ public class AdamRdmServiceImpl implements IAdamRdmService {
         return vo;
     }
 
-    @Override
     public void delMemberCodeVoByCode(String memberCode) {
         redisUtil.del(AdamRedisConst.INFO_MEMBER_CODE.concat(memberCode));
     }
 
-    @Override
     public boolean setTagsForSex(List<AdamTagVo> voList) {
         return redisUtil.set(AdamRedisConst.INFO_TAGS_SEX, voList);
     }
 
-    @Override
     public List<AdamTagVo> getTagsForSex() {
         return (List<AdamTagVo>) redisUtil.get(AdamRedisConst.INFO_TAGS_SEX);
     }
 
-    @Override
     public boolean setTagsForMusic(List<AdamTagParentVo> voList) {
         return redisUtil.set(AdamRedisConst.INFO_TAGS_MUSIC, voList);
     }
 
-    @Override
     public List<AdamTagParentVo> getTagsForMusic() {
         return (List<AdamTagParentVo>) redisUtil.get(AdamRedisConst.INFO_TAGS_MUSIC);
     }
+
+
+
+    /* ========================================================== | Other micro-service data inquiry */
+
+    public KylinPerformanceVo kylinPerformanceVos(String performancesId) {
+        return (KylinPerformanceVo) redisUtil.get(KylinRedisConst.PERFORMANCES + performancesId);
+    }
 }

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamAddressesServiceImpl.java

@@ -6,7 +6,7 @@ import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.adam.dto.AdamAddressesParam;
 import com.liquidnet.service.adam.dto.vo.AdamAddressesVo;
 import com.liquidnet.service.adam.service.IAdamAddressesService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.SqlMapping;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
@@ -22,8 +22,6 @@ import org.springframework.data.mongodb.core.convert.MongoConverter;
 import org.springframework.data.mongodb.core.query.Criteria;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
 import java.time.LocalDateTime;
@@ -49,7 +47,7 @@ public class AdamAddressesServiceImpl implements IAdamAddressesService {
     @Autowired
     RabbitTemplate rabbitTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
     @Override
 //    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamCollectionServiceImpl.java

@@ -6,11 +6,12 @@ import com.liquidnet.service.adam.dto.vo.AdamCollectBaseVo;
 import com.liquidnet.service.adam.dto.vo.AdamCollectInfoVo;
 import com.liquidnet.service.adam.dto.vo.AdamCollectVo;
 import com.liquidnet.service.adam.service.IAdamCollectionService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.feign.kylin.api.FeignKylinPerformanceClient;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
+import com.mongodb.client.result.DeleteResult;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
@@ -45,7 +46,7 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService {
     @Autowired
     RabbitTemplate rabbitTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
     /* ---------------- 外部服务API ---------------- */
     @Autowired
@@ -78,15 +79,11 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService {
     public void del(String uid, String type, String... contentIds) {
         LocalDateTime now = LocalDateTime.now();
 
-//        AdamCollectBaseVo delVo = AdamCollectBaseVo.getNew();
-//        delVo.setState(2);
-//        delVo.setUpdatedAt(now);
-
-        UpdateResult updateResult = mongoTemplate.getCollection(AdamCollectBaseVo.class.getSimpleName()).updateMany(
-                Query.query(Criteria.where("uid").is(uid).and("type").is(type)
-                        .and("contentId").in(contentIds).and("state").is(1)).getQueryObject(),
-                new Document("$set", new Document("state", 2).append("updatedAt", now)));
-        if (updateResult.getModifiedCount() > 0) {
+        DeleteResult deleteResult = mongoTemplate.remove(
+                Query.query(Criteria.where("uid").is(uid).and("type").is(type).and("contentId").in(contentIds)),
+                AdamCollectBaseVo.class.getSimpleName()
+        );
+        if (deleteResult.getDeletedCount() > 0) {
             LinkedList<Object[]> toMqObjs = new LinkedList<>();
             for (String c : contentIds) {
                 toMqObjs.add(new Object[]{now, uid, c});
@@ -98,9 +95,10 @@ public class AdamCollectionServiceImpl implements IAdamCollectionService {
 
     @Override
     public boolean queryState(String uid, String type, String contentId) {
-        long count = mongoTemplate.count(Query.query(Criteria.where("uid").is(uid).and("type").is(type)
-                .and("contentId").is(contentId).and("state").is(1)), AdamCollectBaseVo.class.getSimpleName());
-        return count > 0;
+        return mongoTemplate.exists(
+                Query.query(Criteria.where("uid").is(uid).and("contentId").is(contentId).and("type").is(type).and("state").is(1)),
+                AdamCollectBaseVo.class.getSimpleName()
+        );
     }
 
     @Override

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamDisposedServiceImpl.java

@@ -8,11 +8,12 @@ import com.liquidnet.service.adam.dto.vo.AdamDisposedBaseVo;
 import com.liquidnet.service.adam.dto.vo.AdamDisposedUserVo;
 import com.liquidnet.service.adam.dto.vo.AdamDisposedVo;
 import com.liquidnet.service.adam.service.IAdamDisposedService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.base.SqlMapping;
 import com.liquidnet.service.feign.kylin.api.FeignKylinPerformanceClient;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
+import com.mongodb.client.result.DeleteResult;
 import com.mongodb.client.result.UpdateResult;
 import lombok.extern.slf4j.Slf4j;
 import org.bson.Document;
@@ -47,7 +48,7 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService {
     @Autowired
     RabbitTemplate rabbitTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
 
     /* ---------------- 外部服务API ---------------- */
@@ -80,17 +81,12 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService {
     @Override
     public void del(String uid, String type, String... contentIds) {
         LocalDateTime now = LocalDateTime.now();
-        String nowStr = DateUtil.format(now, DateUtil.Formatter.yyyyMMddHHmmss);
 
-//        AdamDisposedBaseVo delVo = AdamDisposedBaseVo.getNew();
-//        delVo.setState(2);
-//        delVo.setUpdatedAt(now);
-
-        UpdateResult updateResult = mongoTemplate.getCollection(AdamDisposedBaseVo.class.getSimpleName()).updateMany(
-                Query.query(Criteria.where("uid").is(uid).and("type").is(type)
-                        .and("contentId").in(contentIds).and("state").is(1)).getQueryObject(),
-                new Document("$set", new Document("state", 2).append("updatedAt", now)));
-        if (updateResult.getModifiedCount() > 0) {
+        DeleteResult deleteResult = mongoTemplate.remove(
+                Query.query(Criteria.where("uid").is(uid).and("type").is(type).and("contentId").in(contentIds)),
+                AdamDisposedBaseVo.class.getSimpleName()
+        );
+        if (deleteResult.getDeletedCount() > 0) {
             LinkedList<Object[]> toMqObjs = new LinkedList<>();
             for (String c : contentIds) {
                 toMqObjs.add(new Object[]{now, uid, c});
@@ -102,9 +98,10 @@ public class AdamDisposedServiceImpl implements IAdamDisposedService {
 
     @Override
     public boolean queryState(String uid, String type, String contentId) {
-        long count = mongoTemplate.count(Query.query(Criteria.where("uid").is(uid).and("type").is(type)
-                .and("contentId").is(contentId).and("state").is(1)), AdamDisposedBaseVo.class.getSimpleName());
-        return count > 0;
+        return mongoTemplate.exists(
+                Query.query(Criteria.where("uid").is(uid).and("contentId").is(contentId).and("type").is(type).and("state").is(1)),
+                AdamDisposedBaseVo.class.getSimpleName()
+        );
     }
 
     @Override

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamEntersServiceImpl.java

@@ -6,7 +6,7 @@ import com.liquidnet.commons.lang.util.*;
 import com.liquidnet.service.adam.dto.AdamEntersParam;
 import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
 import com.liquidnet.service.adam.service.IAdamEntersService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.base.ErrorMapping;
 import com.liquidnet.service.base.SqlMapping;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
@@ -50,7 +50,7 @@ public class AdamEntersServiceImpl implements IAdamEntersService {
     @Autowired
     RabbitTemplate rabbitTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
 
     private static final String PHP_API_REAL_NAME = "/IdCardCheckVerification";

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamMemberOrderServiceImpl.java

@@ -11,8 +11,8 @@ import com.liquidnet.service.adam.dto.AdamMemberOrderResult;
 import com.liquidnet.service.adam.dto.vo.*;
 import com.liquidnet.service.adam.entity.AdamMemberOrder;
 import com.liquidnet.service.adam.mapper.AdamMemberOrderMapper;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamMemberOrderService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserMemberService;
 import com.liquidnet.service.adam.util.MemberUtil;
 import com.liquidnet.service.base.ErrorMapping;
@@ -49,7 +49,7 @@ public class AdamMemberOrderServiceImpl extends ServiceImpl<AdamMemberOrderMappe
     @Autowired
     RabbitTemplate rabbitTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     IAdamUserMemberService adamUserMemberService;
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserInfoServiceImpl.java

@@ -9,7 +9,7 @@ import com.liquidnet.commons.lang.util.JsonUtils;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
 import com.liquidnet.service.adam.entity.AdamUserInfo;
 import com.liquidnet.service.adam.mapper.AdamUserInfoMapper;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserInfoService;
 import com.liquidnet.service.base.SqlMapping;
 import com.mongodb.client.model.FindOneAndUpdateOptions;
@@ -45,7 +45,7 @@ public class AdamUserInfoServiceImpl extends ServiceImpl<AdamUserInfoMapper, Ada
     @Autowired
     MongoTemplate mongoTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
     @Autowired
     RabbitTemplate rabbitTemplate;
     @Autowired

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserMemberServiceImpl.java

@@ -6,7 +6,7 @@ import com.liquidnet.service.adam.dto.vo.AdamMemberVo;
 import com.liquidnet.service.adam.dto.vo.AdamUserMemberVo;
 import com.liquidnet.service.adam.entity.AdamUserMember;
 import com.liquidnet.service.adam.mapper.AdamUserMemberMapper;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserMemberService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,7 +26,7 @@ public class AdamUserMemberServiceImpl extends ServiceImpl<AdamUserMemberMapper,
     @Autowired
     MongoTemplate mongoTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
     @Override
     public String getNextMemberNo(String memberId) {

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/AdamUserServiceImpl.java

@@ -12,8 +12,8 @@ import com.liquidnet.service.adam.dto.AdamThirdPartParam;
 import com.liquidnet.service.adam.dto.vo.*;
 import com.liquidnet.service.adam.entity.AdamEnters;
 import com.liquidnet.service.adam.entity.AdamRealName;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamEntersService;
-import com.liquidnet.service.adam.service.IAdamRdmService;
 import com.liquidnet.service.adam.service.IAdamRealNameService;
 import com.liquidnet.service.adam.service.IAdamUserService;
 import com.liquidnet.service.base.ErrorMapping;
@@ -67,7 +67,7 @@ public class AdamUserServiceImpl implements IAdamUserService {
     @Autowired
     IAdamRealNameService adamRealNameService;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
 
 

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/admin/AdamMemberCodeAdminServiceImpl.java

@@ -5,7 +5,7 @@ import com.liquidnet.service.adam.dto.AdamMemberCodeParam;
 import com.liquidnet.service.adam.dto.vo.AdamMemberCodeVo;
 import com.liquidnet.service.adam.entity.AdamMemberCode;
 import com.liquidnet.service.adam.mapper.AdamMemberCodeMapper;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.IAdamUserMemberService;
 import com.liquidnet.service.adam.service.admin.IAdamMemberCodeAdminService;
 import com.liquidnet.service.adam.util.MemberUtil;
@@ -29,7 +29,7 @@ public class AdamMemberCodeAdminServiceImpl extends ServiceImpl<AdamMemberCodeMa
     @Autowired
     IAdamUserMemberService adamUserMemberService;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
     @Override
     public String createGiftCode(AdamMemberCodeParam param) {

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/service/impl/admin/AdamMemberServiceAdminImpl.java

@@ -8,7 +8,7 @@ import com.liquidnet.service.adam.dto.AdamMemberParam;
 import com.liquidnet.service.adam.dto.vo.AdamMemberVo;
 import com.liquidnet.service.adam.entity.AdamMember;
 import com.liquidnet.service.adam.mapper.AdamMemberMapper;
-import com.liquidnet.service.adam.service.IAdamRdmService;
+import com.liquidnet.service.adam.service.AdamRdmService;
 import com.liquidnet.service.adam.service.admin.IAdamMemberAdminService;
 import com.liquidnet.service.base.ResponseDto;
 import lombok.extern.slf4j.Slf4j;
@@ -31,7 +31,7 @@ public class AdamMemberServiceAdminImpl extends ServiceImpl<AdamMemberMapper, Ad
     @Autowired
     MongoTemplate mongoTemplate;
     @Autowired
-    IAdamRdmService adamRdmService;
+    AdamRdmService adamRdmService;
 
     @Override
     public AdamMemberVo add(AdamMemberParam param) {

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

@@ -252,7 +252,7 @@ public class KylinPerformancesServiceImpl extends ServiceImpl<KylinPerformancesM
         Query query = new BasicQuery(queryObject);
         String nowTimeStr = DateUtil.getNowTime();
         query.addCriteria(Criteria.where("timeEnd").gte(nowTimeStr));
-        query.addCriteria(Criteria.where("appStatus").in(3, 6, 8, 9, 10));
+        query.addCriteria(Criteria.where("appStatus").in(6, 8, 9, 10));
 
         long count = mongoTemplate.count(query, KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());