记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 5b84e00d authored by Tice's avatar Tice
Browse files
Options

Merge branch 'dev_merchant' into dev_merchant_tice

parents b5a5d714 5a2a66f5
Hide whitespace changes
Inline Side-by-side
Showing with 687 additions and 0 deletions
liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/pom.xml
View file @ 5b84e00d
...@@ -30,11 +30,20 @@ ...@@ -30,11 +30,20 @@
<artifactId>liquidnet-common-cache-redis</artifactId> <artifactId>liquidnet-common-cache-redis</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-merchant-api</artifactId> <artifactId>liquidnet-service-merchant-api</artifactId>
<version>1.0-SNAPSHOT</version> <version>1.0-SNAPSHOT</version>
</dependency> </dependency>
<dependency>
<groupId>com.liquidnet</groupId>
<artifactId>liquidnet-service-kylin-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency> <dependency>
<groupId>com.liquidnet</groupId> <groupId>com.liquidnet</groupId>
<artifactId>liquidnet-api-feign-platform</artifactId> <artifactId>liquidnet-api-feign-platform</artifactId>
......
liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/util/InnerUtils.java 0 → 100644
View file @ 5b84e00d
package com.liquidnet.service.merchant.util;
import org.springframework.stereotype.Component;
@Component
public class InnerUtils {
// public AdamUserInfoSimpleVo getUserInfo() throws Exception {
// MultiValueMap<String, String> header = CollectionUtil.linkedMultiValueMapStringString();
// header.add("Accept", "application/json;charset=UTF-8");
// header.add("Authorization", "Bearer " + CurrentUtil.getToken());
// String resultData = HttpUtil.post(adamUrl + "/adam/user/gif/mobile", null, header);
// ResponseDto<AdamUserInfoSimpleVo> innerReturnVo = JsonUtils.fromJson(resultData, new TypeReference<ResponseDto<AdamUserInfoSimpleVo>>() {
// });
// return innerReturnVo.getData();
// }
}
liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/util/MongoMerchantUtils.java 0 → 100644
View file @ 5b84e00d
package com.liquidnet.service.merchant.util;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.liquidnet.common.cache.redis.util.RedisUtil;
import com.liquidnet.commons.lang.util.DateUtil;
import com.liquidnet.service.kylin.constant.KylinRedisConst;
import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketTimesVo;
import com.liquidnet.service.kylin.dto.vo.middle.KylinTicketVo;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
import com.liquidnet.service.kylin.entity.*;
import com.liquidnet.service.kylin.mapper.*;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
@Component
public class MongoMerchantUtils {
// @Autowired
// private KylinPerformancesMapper performancesMapper;
// @Autowired
// private KylinPerformanceStatusMapper performanceStatusMapper;
// @Autowired
// private KylinPerformanceRelationsMapper performanceRelationsMapper;
// @Autowired
// private KylinTicketTimesMapper ticketTimesMapper;
// @Autowired
// private KylinTicketTimeRelationMapper ticketTimeRelationMapper;
// @Autowired
// private KylinTicketsMapper ticketsMapper;
// @Autowired
// private KylinTicketStatusMapper ticketStatusMapper;
// @Autowired
// private KylinTicketRelationsMapper ticketRelationsMapper;
// @Autowired
// private RedisUtil redisUtil;
// @Autowired
// private DataUtils dataUtils;
//
// public KylinPerformanceVo combinePerformanceVoData(String performancesId) {
// try {
// KylinPerformanceVo voData = new KylinPerformanceVo();
//
// //演出数据
// KylinPerformances p1 = performancesMapper.selectOne(new UpdateWrapper<KylinPerformances>().eq("performances_id", performancesId));
// KylinPerformanceStatus p2 = performanceStatusMapper.selectOne(new UpdateWrapper<KylinPerformanceStatus>().eq("performance_id", performancesId));
// KylinPerformanceRelations p3 = performanceRelationsMapper.selectOne(new UpdateWrapper<KylinPerformanceRelations>().eq("performance_id", performancesId));
// //场地相关数据
// KylinFields fields = new KylinFields();
// String cityName = (String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_name");
// fields.setCityId(Integer.parseInt((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_id")));
// fields.setLatitude((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "latitude"));
// fields.setLongitude((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "longitude"));
// fields.setCityName((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "city_name"));
// fields.setName((String) redisUtil.getDB15RedisHGet(KylinRedisConst.FIELDS + ":" + p3.getFieldId(), "name"));
//
// //相关状态时间初始变量
// LocalDateTime stopSellTime = null;
// LocalDateTime sellTime = null;
// LocalDateTime sellMemberTime = null;
//
// int isLackRegister = 0;
// int isMember = 0;
// int isExclusive = 0;
// int isAdvance = 0;
// int isDiscount = 0;
// int payCountdownMinute = 15;
// BigDecimal price = new BigDecimal("0.00");
//
// //场次数据
// List<KylinTicketTimeRelation> tt3 = ticketTimeRelationMapper.selectList(new UpdateWrapper<KylinTicketTimeRelation>().eq("performance_id", performancesId));
// List<KylinTicketTimesVo> timeList = new ArrayList<>();
// for (int x = 0; x < tt3.size(); x++) {
// KylinTicketTimeRelation times = tt3.get(x);
// KylinTicketTimes tt1 = ticketTimesMapper.selectOne(new UpdateWrapper<KylinTicketTimes>().eq("ticket_times_id", times.getTimesId()));
//
// //票种数据
// List<KylinTicketRelations> t3 = ticketRelationsMapper.selectList(new UpdateWrapper<KylinTicketRelations>().eq("times_id", times.getTimesId()));
// List<KylinTicketVo> ticketList = new ArrayList<>();
// for (int y = 0; y < t3.size(); y++) {
// KylinTicketRelations ticket = t3.get(y);
// KylinTickets t1 = ticketsMapper.selectOne(new UpdateWrapper<KylinTickets>().eq("tickets_id", ticket.getTicketId()));
// KylinTicketStatus t2 = ticketStatusMapper.selectOne(new UpdateWrapper<KylinTicketStatus>().eq("ticket_id", ticket.getTicketId()));
//// if(t2.getStatus()==7){
//// continue;
//// }
// KylinTicketVo kylinTicketVo = new KylinTicketVo();
// kylinTicketVo.setTimeId(ticket.getTimesId());
// kylinTicketVo.setTicket(t1);
// kylinTicketVo.setTicketStatus(t2);
// ticketList.add(kylinTicketVo);
//
//// //票种 库存redis
//// if (!redisUtil.hHasKey(KylinRedisConst.PERFORMANCES_INVENTORY + kylinTicketVo.getTicketsId(), KylinRedisConst.SURPLUS_GENERAL)) {
//// dataUtils.setSurplusGeneral(kylinTicketVo.getTicketsId(), t2.getTotalGeneral());
//// dataUtils.setSurplusExchange(kylinTicketVo.getTicketsId(), t2.getSurplusExchange());
//// }
//
// if (kylinTicketVo.getIsMember() == 1) {
// if (kylinTicketVo.getMemberPrice().compareTo(kylinTicketVo.getPrice()) != 0) {
// isDiscount = 1;
// }
//
// if (DateUtil.compareStrDay(DateUtil.getNowTime(), kylinTicketVo.getMemberTimeStart()) < 0) {
// isAdvance = 1;
// }
// if (kylinTicketVo.getIsMember() == 1) {
// isMember = 1;
// }
// if (kylinTicketVo.getIsExclusive() == 1) {
// isExclusive = 1;
// }
//
// if (isAdvance == 0 && isDiscount == 0 && isExclusive == 0) {
// isMember = 0;
// }
// }
// if (kylinTicketVo.getIsLackRegister() == 1) {
// isLackRegister = 1;
// }
// payCountdownMinute = t1.getPayCountdownMinute();
// if (price.compareTo(new BigDecimal("0.00")) == 0) {
// price = kylinTicketVo.getPrice();
// } else {
// if (kylinTicketVo.getPrice().compareTo(price) < 0) {
// price = kylinTicketVo.getPrice();
// }
// }
// if ((stopSellTime == null || stopSellTime.isBefore(t1.getTimeEnd())) && (t2.getStatus() >= 6 && t2.getStatus() != 7)) {
// stopSellTime = t1.getTimeEnd();
// }
// if ((sellMemberTime == null || sellMemberTime.isAfter(t1.getTimeStart().plusMinutes(-t1.getAdvanceMinuteMember()))) && (t2.getStatus() >= 6 && t2.getStatus() != 7)) {
// sellMemberTime = t1.getTimeStart().plusMinutes(-t1.getAdvanceMinuteMember());
// }
// if ((sellTime == null || sellTime.isAfter(t1.getTimeStart())) && (t2.getStatus() >= 6 && t2.getStatus() != 7)) {
// sellTime = t1.getTimeStart();
// }
// }
//
//// if(ticketList.size()>0) {
// KylinTicketTimesVo kylinTicketTimesVo = new KylinTicketTimesVo();
// kylinTicketTimesVo.setTicketTimes(tt1);
// kylinTicketTimesVo.setPerformanceId(times.getPerformanceId());
// kylinTicketTimesVo.setTimeId(times.getTimesId());
// kylinTicketTimesVo.setTicketList(ticketList);
// timeList.add(kylinTicketTimesVo);
//// }
// }
//
// voData.setPerformance(p1);
// voData.setPerformanceStatus(p2);
// voData.setPerformanceRelations(p3);
// voData.setFieldsData(fields, cityName);
// if (stopSellTime == null) {
// stopSellTime = DateUtil.Formatter.yyyyMMddHHmmss.parse("2030-12-01 12:00:00");
// }
// if (sellTime == null) {
// sellTime = DateUtil.Formatter.yyyyMMddHHmmss.parse("2030-12-01 12:00:00");
// }
// if (sellMemberTime == null) {
// sellMemberTime = DateUtil.Formatter.yyyyMMddHHmmss.parse("2030-12-01 12:00:00");
// }
//
// voData.setTimePriceVipAndLack(isLackRegister, isMember, isExclusive, price, stopSellTime, sellMemberTime, sellTime, isAdvance, isDiscount, payCountdownMinute);
// voData.setTicketTimeList(timeList);
// voData.setAppStatus(p2.getStatus());
// return voData;
// } catch (Exception e) {
// e.printStackTrace();
// return null;
// }
// }
//
// /**
// * @param userId 用户id
// * @param type 1新增 2修改
// * @param orderId 订单id [需要新增或者修改的订单id]
// */
// public Boolean resetOrderListVo(String userId, Integer type, String orderId, KylinOrderTicketVo dataSingle) {
// List<KylinOrderListVo> vo = new ArrayList<>();
// List<KylinOrderListVo> redisVo = new ArrayList();
// KylinOrderListVo voItem = new KylinOrderListVo();
// KylinOrderTicketVo data;
// if (dataSingle == null) {
// data = dataUtils.getOrderTicketVo(orderId);
// } else {
// data = dataSingle;
// }
// BeanUtils.copyProperties(data, voItem);
// List<KylinOrderListVo> redisData = dataUtils.getOrderList(userId);
// if (type == 1) {
// redisVo.add(voItem);
// if (redisData.size() > 0) {
// if (redisData.get(0).getOrderTicketsId().equals(orderId)) {
// redisData.remove(0);
// }
// }
// }
//
// redisVo.addAll(redisData);
//
// switch (type) {
// case 1:
// for (int i = 0; i < redisVo.size(); i++) {
// if (i == 40) {
// break;
// }
// if (i == 0) {
// vo.add(voItem);
// } else {
// vo.add(redisVo.get(i));
// }
// }
// if (redisVo.size() == 0) {
// vo.add(voItem);
// }
// dataUtils.setOrderList(userId, vo);
// return true;
// case 2:
// for (int i = 0; i < redisVo.size(); i++) {
// if (i == 40) {
// break;
// }
// if (redisVo.get(i).getOrderTicketsId().equals(orderId)) {
// vo.add(voItem);
// } else {
// vo.add(redisVo.get(i));
// }
// }
// dataUtils.setOrderList(userId, vo);
// return true;
// default:
// return false;
// }
// }
}
liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/util/ObjectUtil.java
View file @ 5b84e00d
package com.liquidnet.service.merchant.util; package com.liquidnet.service.merchant.util;
import com.liquidnet.service.merchant.dto.vo.MerchantFieldsAppliesVo; import com.liquidnet.service.merchant.dto.vo.MerchantFieldsAppliesVo;
import com.mongodb.BasicDBObject;
import java.util.ArrayList; import java.util.ArrayList;
public class ObjectUtil { public class ObjectUtil {
private static final ArrayList<MerchantFieldsAppliesVo> merchantFieldsAppliesVoArrayList = new ArrayList<>(); private static final ArrayList<MerchantFieldsAppliesVo> merchantFieldsAppliesVoArrayList = new ArrayList<>();
private static final BasicDBObject basicDBObject = new BasicDBObject();
public static ArrayList<MerchantFieldsAppliesVo> getMerchantFieldsAppliesVoArrayList() { public static ArrayList<MerchantFieldsAppliesVo> getMerchantFieldsAppliesVoArrayList() {
return (ArrayList<MerchantFieldsAppliesVo>) merchantFieldsAppliesVoArrayList.clone(); return (ArrayList<MerchantFieldsAppliesVo>) merchantFieldsAppliesVoArrayList.clone();
} }
public static BasicDBObject cloneBasicDBObject() {
return (BasicDBObject) basicDBObject.clone();
}
} }
liquidnet-bus-service/liquidnet-service-merchant/liquidnet-service-merchant-impl/src/main/java/com/liquidnet/service/merchant/util/RedisMerchantUtils.java 0 → 100644
View file @ 5b84e00d
package com.liquidnet.service.merchant.util;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.liquidnet.common.cache.redis.util.RedisUtil;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.kylin.constant.KylinRedisConst;
import com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressRouteVo;
import com.liquidnet.service.kylin.dto.vo.express.KylinOrderExpressVo;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketEntitiesVo;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinOrderTicketVo;
import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
import com.liquidnet.service.kylin.dto.vo.returns.KylinOrderListVo;
import com.liquidnet.service.kylin.entity.KylinBuyNotice;
import com.liquidnet.service.kylin.entity.KylinOrderCoupons;
import com.liquidnet.service.kylin.mapper.KylinBuyNoticeMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Sort;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
@Component
public class RedisMerchantUtils {
// @Autowired
// private KylinBuyNoticeMapper buyNoticeMapper;
// @Autowired
// private RedisUtil redisUtil;
// @Autowired
// private MongoVoUtils mongoVoUtils;
//
// /**
// * 根据 购票须知 id 获取 购票须知文案
// *
// * @param buyNoticeIds 购票须知 数组
// * @return 购票须知 json串
// */
// public String getBuyNoticeJsonString(List<String> buyNoticeIds) {
// List<KylinBuyNotice> data = buyNoticeMapper.selectList(new UpdateWrapper<KylinBuyNotice>().in("buy_notice_id", buyNoticeIds));
// return JsonUtils.toJson(data);
// }
//
// public List<KylinBuyNotice> getBuyNotice() {
// Object obj = redisUtil.get(KylinRedisConst.BUY_NOTICE);
// if (obj != null) {
// return (List<KylinBuyNotice>) obj;
// } else {
// //TODO 降级
// return null;
// }
// }
//
// /**
// * 初始化普通库存
// *
// * @param ticketId 票id
// * @param totalGeneral 普通库存
// */
// public void setSurplusGeneral(String ticketId, int totalGeneral) {
// redisUtil.set(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, totalGeneral);
// }
//
// /**
// * 获取普通剩余库存
// *
// * @param ticketId 票id
// * @return 普通剩余库存
// */
// public int getSurplusGeneral(String ticketId) {
// return (int) redisUtil.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL);
// }
//
// /**
// * 修改普通库存 并 返回修改后的数量
// *
// * @param ticketId 票id
// * @param surplusGeneral 普通库存
// * @return 普通剩余库存
// */
// public int changeSurplusGeneral(String ticketId, int surplusGeneral) {
// if (surplusGeneral > 0) {
// return (int) redisUtil.incr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, surplusGeneral);
// } else {
// return (int) redisUtil.decr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL, Math.abs(surplusGeneral));
// }
// }
//
// /**
// * 判断 当前库存是否售罄
// *
// * @param ticketId 票id
// * @return boolean
// */
// public boolean ticketIsSoldOut(String ticketId) {
// if (0 >= getSurplusGeneral(ticketId)) {
// return true;
// } else {
// return false;
// }
// }
//
// /**
// * 初始化兑换库存
// *
// * @param ticketId 票id
// * @param totalExchange 兑换库存
// */
// public void setSurplusExchange(String ticketId, int totalExchange) {
// redisUtil.set(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE, totalExchange);
// }
//
// /**
// * 获取兑换剩余库存
// *
// * @param ticketId 票id
// * @return 兑换剩余库存
// */
// public int getSurplusExchange(String ticketId) {
// return (int) redisUtil.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE);
// }
//
// /**
// * 变更兑换库存 并 返回 修改后的数量
// *
// * @param ticketId 票id
// * @param surplusExchange 普通库存
// * @return 兑换剩余库存
// */
// public int changeSurplusExchange(String ticketId, int surplusExchange) {
// if (surplusExchange > 0) {
// return (int) redisUtil.incr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE, surplusExchange);
// } else {
// return (int) redisUtil.decr(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE, Math.abs(surplusExchange));
// }
// }
//
// public void setOrderList(String userId, List<KylinOrderListVo> vo) {
// redisUtil.set(KylinRedisConst.ORDER_LIST + userId, vo);
// }
//
// public List<KylinOrderListVo> getOrderList(String userId) {
// Object obj = redisUtil.get(KylinRedisConst.ORDER_LIST + userId);
// if (obj != null) {
// return (List<KylinOrderListVo>) obj;
// } else {
// List<KylinOrderListVo> voList = mongoTemplate.find(Query.query(Criteria.where("userId").is(userId))
// .with(Sort.by(Sort.Direction.DESC, "createdAt")).limit(40),
// KylinOrderListVo.class, KylinOrderTicketVo.class.getSimpleName());
// for (KylinOrderListVo item : voList) {
// item.setStatus(item.getStatus());
// }
// redisUtil.set(KylinRedisConst.ORDER_LIST + userId, voList);
// return voList;
// }
// }
//
// /**
// * 演出是否实名
// *
// * @param performanceId
// * @param isTrueName
// */
// public void setPerformanceIsTrueName(String performanceId, int isTrueName) {
// redisUtil.set(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId, isTrueName);
// }
//
// /**
// * 根据订单id 获取 订单vo 详情
// *
// * @param orderId
// * @return
// */
// public KylinOrderTicketVo getOrderTicketVo(String orderId) {
// Object obj = redisUtil.get(KylinRedisConst.ORDER + orderId);
// if (obj != null) {
// return (KylinOrderTicketVo) obj;
// } else {
// KylinOrderTicketVo ticketData = mongoTemplate.findOne(Query.query(Criteria.where("orderTicketsId").is(orderId)), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName());
// List<KylinOrderTicketEntitiesVo> kylinOrderTicketEntitiesVoList = mongoTemplate.find(Query.query(Criteria.where("orderId").is(orderId)), KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName());
// ticketData.setEntitiesVoList(kylinOrderTicketEntitiesVoList);
// redisUtil.set(KylinRedisConst.ORDER + orderId, ticketData);
// return ticketData;
// }
// }
//
// /**
// * 删除订单redis
// *
// * @param orderId
// */
// public void delOrderTicketRedis(String orderId) {
// redisUtil.del(KylinRedisConst.ORDER + orderId);
// }
//
//
// /**
// * 删除 验票账号 redis
// *
// * @param checkUserId
// */
// public void delCheckUserRedis(String checkUserId) {
// redisUtil.del(KylinRedisConst.CHECK_USER + checkUserId);
// }
//
//
// /**
// * 删除 验票账号关系 vo
// *
// * @param checkUserId
// */
// public void delCheckUserRelationRedis(String checkUserId) {
// redisUtil.del(KylinRedisConst.CHECK_USER_RELATION + checkUserId);
// }
//
//
// public void updatePerformanceMongo(String performanceIds, KylinPerformanceVo paramVo) {
// //查询 mysql 数据
// KylinPerformanceVo vo;
// if (null == paramVo) {
// vo = mongoVoUtils.combinePerformanceVoData(performanceIds);
// } else {
// vo = paramVo;
// }
// if (vo != null) {
// try {
// //删除 mongo数据
// mongoTemplate.remove(Query.query(Criteria.where("performancesId").is(performanceIds)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
// } catch (Exception e) {
// e.printStackTrace();
// }
// try {
// //新增 mongo数据
// mongoTemplate.insert(vo, KylinPerformanceVo.class.getSimpleName());
// } catch (Exception e) {
// e.printStackTrace();
// }
// try {
// //删除redis
// redisUtil.del(KylinRedisConst.PERFORMANCES + performanceIds);
// // 大龙相关 演出列表
// redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_CITYNAME + vo.getCityName());
// redisUtil.del(KylinRedisConst.PERFORMANCES_ROADLIST + vo.getRoadShowId());
// redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_SYSTEM_RECOMMEND);
// redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_RECOMMEND);
// redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_NOTICE);
// redisUtil.del(KylinRedisConst.PERFORMANCES_LIST_EXCLUSIVE);
// } catch (Exception e) {
// e.printStackTrace();
// }
// } else {
// }
// }
//
// /**
// * @param performanceId 演出id
// * @param ticketId 票种id
// * @param buyCount 购买数量 大于 0 增加 小于 0 减少 对应 支付 退款表
// */
// public void changeBuyInfo(String userId, String idCard, String performanceId, String ticketId, int buyCount) {
// String redisKey;
//
// int isTrueName = getPerformanceIsTrueName(performanceId);
//
// if (0 == isTrueName) {
// redisKey = KylinRedisConst.USERID_BUY_INFO + userId;
// } else {
// redisKey = KylinRedisConst.IDCARD_BUY_INFO + idCard;
// }
//
// String performanceIdKey = redisKey + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId;
// String ticketIdKey = redisKey + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId;
//
// if (buyCount > 0) {
// redisUtil.incr(ticketIdKey, buyCount);
// redisUtil.incr(performanceIdKey, buyCount);
// } else {
// redisUtil.decr(ticketIdKey, Math.abs(buyCount));
// redisUtil.decr(performanceIdKey, Math.abs(buyCount));
// }
// }
//
//
// // 获取 用户维度 演出购买数量
// public int getUserPBuyCount(String userId, String performanceId) {
// try {
// return (int) redisUtil.get(KylinRedisConst.USERID_BUY_INFO + userId + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId);
// } catch (Exception e) {
// return 0;
// }
// }
//
// // 获取 用户维度 票种购买数量
// public int getUserTBuyCount(String userId, String ticketId) {
// try {
// return (int) redisUtil.get(KylinRedisConst.USERID_BUY_INFO + userId + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId);
// } catch (Exception e) {
// return 0;
// }
// }
//
// // 获取 证件维度 演出购买数量
// public int getIdCardPBuyCount(String idCard, String performanceId) {
// try {
// return (int) redisUtil.get(KylinRedisConst.IDCARD_BUY_INFO + idCard + ":" + KylinRedisConst.PERFORMANCE_ID + ":" + performanceId);
// } catch (Exception e) {
// return 0;
// }
// }
//
// // 获取 证件维度 票种购买数量
// public int getIdCardTBuyCount(String idCard, String ticketId) {
// try {
// return (int) redisUtil.get(KylinRedisConst.IDCARD_BUY_INFO + idCard + ":" + KylinRedisConst.TICKET_ID + ":" + ticketId);
// } catch (Exception e) {
// return 0;
// }
// }
//
// /**
// * 删除订单redis
// *
// * @param orderEntitiesId
// */
// public void delOrderTicketEntitiesRedis(String orderEntitiesId) {
// redisUtil.del(KylinRedisConst.ORDER_ENTITIES + orderEntitiesId);
// }
//
// /**
// * 根据演出id 获取 演出vo 详情
// *
// * @param performanceId
// * @return
// */
// public KylinPerformanceVo getPerformanceVo(String performanceId) {
// Object obj = redisUtil.get(KylinRedisConst.PERFORMANCES + performanceId);
// if (obj != null) {
// return (KylinPerformanceVo) obj;
// } else {
// KylinPerformanceVo performanceData = mongoTemplate.findOne(Query.query(Criteria.where("performancesId").is(performanceId)), KylinPerformanceVo.class, KylinPerformanceVo.class.getSimpleName());
// redisUtil.set(KylinRedisConst.PERFORMANCES + performanceId, performanceData);
// return performanceData;
// }
// }
//
// /**
// * 演出是否实名
// *
// * @param performanceId
// */
// public int getPerformanceIsTrueName(String performanceId) {
// Object obj = redisUtil.get(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId);
// if (obj != null) {
// return (int) obj;
// } else {
// int isTrueName = getPerformanceVo(performanceId).getIsTrueName();
// redisUtil.set(KylinRedisConst.PERFORMANCES_TRUE_NAME + performanceId, isTrueName);
// return isTrueName;
// }
// }
//
//
// public void delOrderRefundVo(String orderRefundsId) {
// redisUtil.del(KylinRedisConst.ORDER_REFUND + orderRefundsId);
// }
//
// public void delOrderRefundVoByOrderId(String orderId) {
// redisUtil.del(KylinRedisConst.ORDER_REFUND_BY_ORDER_ID + orderId);
// }
//
// /**
// * 演出订单快递信息
// *
// * @param orderId
// * @param kylinOrderExpressVo
// */
// public void setOrderExpressInfo(String orderId, KylinOrderExpressVo kylinOrderExpressVo) {
// String redisKey = KylinRedisConst.ORDER_EXPRESS_INFO.concat(orderId);
// redisUtil.set(redisKey, kylinOrderExpressVo);
// }
//
// /**
// * 演出订单快递路由
// */
// public LinkedList<KylinOrderExpressRouteVo> getOrderExpressRoute(String orderTicketsId) { // 获取
// String redisKey = KylinRedisConst.ORDER_ROUTE_INFO.concat(orderTicketsId);
// return (LinkedList<KylinOrderExpressRouteVo>) redisUtil.get(redisKey);
// }
//
// public void setOrderExpressRoute(String orderTicketsId, LinkedList<KylinOrderExpressRouteVo> routeList) {
// String redisKey = KylinRedisConst.ORDER_ROUTE_INFO.concat(orderTicketsId);
// redisUtil.set(redisKey, routeList);
// }
//
// // 获取订单券的使用情况
// public ArrayList<KylinOrderCoupons> getOrderCoupon(String orderId) {
// String redisKey = KylinRedisConst.ORDER_COUPON.concat(orderId);
// Object obj = redisUtil.get(redisKey);
// if (obj == null) {
// return ObjectUtil.getKylinOrderCouponsArrayList();
// } else {
// return (ArrayList<KylinOrderCoupons>) obj;
// }
// }
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment