package com.yeshi.fanli.service.impl.taobao;
|
|
import java.util.Date;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.apache.ibatis.annotations.Param;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;
|
import com.yeshi.fanli.entity.admin.ReslutOrder;
|
import com.yeshi.fanli.entity.bus.user.HongBaoV2;
|
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
|
import com.yeshi.fanli.vo.order.TaoBaoOrderVO;
|
|
@Service
|
public class TaoBaoOrderServiceImpl implements TaoBaoOrderService {
|
|
@Resource
|
private TaoBaoOrderMapper taoBaoOrderMapper;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Override
|
public void addTaoBaoOrderList(List<TaoBaoOrder> list) {
|
if (list == null || list.size() == 0)
|
return;
|
Map<String, List<TaoBaoOrder>> map = TaoBaoOrderUtil.classifyTaoBaoOrderByOrderId(list);
|
Iterator<String> its = map.keySet().iterator();
|
while (its.hasNext()) {
|
String orderId = its.next();
|
String key = "addorder-" + orderId;
|
// redis做频率限制
|
try {
|
if (Constant.IS_OUTNET) {
|
if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {
|
continue;
|
}
|
}
|
|
} catch (Exception e) {
|
|
}
|
addTaoBaoOrder(orderId, map.get(orderId));
|
try {
|
// 6小时内不再处理
|
if (Constant.IS_OUTNET)
|
redisManager.cacheCommonString(key, "1", 60 * 60 * 6);
|
} catch (Exception e) {
|
|
}
|
|
}
|
}
|
|
@Transactional
|
@Override
|
public void addTaoBaoOrder(String orderId, List<TaoBaoOrder> list) {
|
List<TaoBaoOrder> oldOrderList = taoBaoOrderMapper.selectTaoBaoOrderByOrderId(orderId);
|
if (oldOrderList == null || oldOrderList.size() == 0) {
|
for (TaoBaoOrder taoBaoOrder : list) {
|
taoBaoOrder.setLatestUpdateTime(new Date());
|
taoBaoOrderMapper.insertSelective(taoBaoOrder);
|
}
|
} else {
|
boolean hasPayOrder = false;
|
for (TaoBaoOrder order : oldOrderList)
|
if (order.getOrderState().equalsIgnoreCase("订单付款")) {
|
hasPayOrder = true;
|
break;
|
}
|
// 删除原来的订单，加入新订单
|
if (hasPayOrder) {
|
taoBaoOrderMapper.deleteByOrderId(orderId);
|
for (TaoBaoOrder taoBaoOrder : list) {
|
taoBaoOrder.setLatestUpdateTime(new Date());
|
taoBaoOrderMapper.insertSelective(taoBaoOrder);
|
}
|
}
|
}
|
}
|
|
@Override
|
public List<TaoBaoOrder> getTaoBaoOrderByOrderId(String orderId) {
|
return taoBaoOrderMapper.selectTaoBaoOrderByOrderId(orderId);
|
}
|
|
@Override
|
public List<ReslutOrder> queryJoinHongBao(int start, int count, String key, String startTime, String endTime,
|
Integer type, Integer days) throws Exception {
|
return taoBaoOrderMapper.queryJoinHongBao(start, count, key, startTime, endTime, type, days);
|
}
|
|
@Override
|
public int countQueryJoinHongBao(String key, String startTime, String endTime, Integer type, Integer days)
|
throws Exception {
|
return taoBaoOrderMapper.countQueryJoinHongBao(key, startTime, endTime, type, days);
|
}
|
|
@Override
|
public double countEstimate(String date) throws Exception {
|
return taoBaoOrderMapper.countEstimate(date);
|
}
|
|
@Override
|
public List<TaoBaoOrder> getStateByOrderIdAndPayment(String orderId, String payment) throws Exception {
|
return taoBaoOrderMapper.getStateByOrderIdAndPayment(orderId, payment);
|
}
|
|
|
@Override
|
public List<TaoBaoOrderVO> listQuery(int start, int count, String key,
|
String startTime, String endTime, Integer state) throws Exception {
|
|
List<TaoBaoOrderVO> listData = taoBaoOrderMapper.listQuery(start, count, key, startTime, endTime, state);
|
|
for (TaoBaoOrderVO taoBaoOrderVO : listData) {
|
|
String orderState = taoBaoOrderVO.getOrderState();
|
if ("订单付款".equals(orderState)) {
|
taoBaoOrderVO.setOrderState("1");
|
}else if ("订单结算".equals(orderState) || "订单成功".equals(orderState)) {
|
taoBaoOrderVO.setOrderState("2");
|
} else if ("订单失效".equals(orderState)) {
|
taoBaoOrderVO.setOrderState("3");
|
}
|
}
|
|
return listData;
|
}
|
|
@Override
|
public long countQuery(String key, String startTime, String endTime,
|
Integer state) throws Exception {
|
return taoBaoOrderMapper.countQuery(key, startTime, endTime, state);
|
}
|
|
}
|
