package com.yeshi.fanli.service.impl.count;
|
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Service;
|
import org.yeshi.utils.DateUtil;
|
|
import com.yeshi.fanli.dao.mybatis.jd.JDOrderItemMapper;
|
import com.yeshi.fanli.dao.mybatis.order.CommonOrderCountMapper;
|
import com.yeshi.fanli.dao.mybatis.pdd.PDDOrderMapper;
|
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;
|
import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;
|
import com.yeshi.fanli.dao.user.count.CountOrderTrackRateDao;
|
import com.yeshi.fanli.dto.ChartTDO;
|
import com.yeshi.fanli.dto.order.CountOrderDTO;
|
import com.yeshi.fanli.entity.admin.count.CountOrderTrackRate;
|
import com.yeshi.fanli.entity.admin.count.CountOrderTrackRate.OrderTrackRateEnum;
|
import com.yeshi.fanli.service.inter.order.CommonOrderCountService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
import org.yeshi.utils.TimeUtil;
|
|
@Service
|
public class CommonOrderCountServiceImpl implements CommonOrderCountService {
|
|
@Resource
|
private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper;
|
|
@Resource
|
private TaoBaoOrderMapper taoBaoOrderMapper;
|
|
@Resource
|
private JDOrderItemMapper jdOrderItemMapper;
|
|
@Resource
|
private PDDOrderMapper pddOrderMapper;
|
|
@Resource
|
private CommonOrderCountMapper commonOrderCountMapper;
|
|
@Resource
|
private CountOrderTrackRateDao countOrderTrackRateDao;
|
|
@Override
|
public Long countByState(Integer state) {
|
return commonOrderCountMapper.countByState(state);
|
}
|
|
@Override
|
public Integer countOderByUidAndLess10(Long uid) {
|
Date date = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 90L);
|
return commonOrderCountMapper.countOderByUidAndLess10(uid, date,new BigDecimal(9));
|
}
|
|
public List<ChartTDO> dayFactory(String startTime, String endTime, List<ChartTDO> list) throws Exception {
|
List<ChartTDO> listObject = new ArrayList<ChartTDO>();
|
if (startTime.equals(endTime)) {
|
ChartTDO chartTDO = list.get(0);
|
String showValue = chartTDO.getShowValue();
|
if (showValue == null) {
|
chartTDO.setShowValue("0");
|
}
|
listObject.add(chartTDO);
|
return listObject;
|
}
|
|
String plusDay = "";
|
for (int i = 0; i < 1000; i++) {
|
if (i == 0) {
|
plusDay = startTime;
|
} else {
|
plusDay = DateUtil.plusDay(i, startTime);
|
}
|
|
String total = null;
|
for (int j = 0; j < list.size(); j++) {
|
ChartTDO chartTDO = list.get(j);
|
String showDate = chartTDO.getShowDate();
|
if (plusDay.equalsIgnoreCase(showDate)) {
|
total = chartTDO.getShowValue();
|
break;
|
}
|
}
|
if (total == null) {
|
total = "0";
|
}
|
ChartTDO chartTDO = new ChartTDO();
|
chartTDO.setShowDate(plusDay);
|
chartTDO.setShowValue(total);
|
listObject.add(chartTDO);
|
|
if (plusDay.equals(endTime)) {
|
break; // 时间结束
|
}
|
}
|
|
return listObject;
|
}
|
|
public List<ChartTDO> monthFactory(List<ChartTDO> list) {
|
List<ChartTDO> listObject = new ArrayList<ChartTDO>();
|
// 12 个月处理
|
for (int i = 1; i <= 12; i++) {
|
String total = null;
|
for (int j = 0; j < list.size(); j++) {
|
ChartTDO chartTDO = list.get(j);
|
String month = chartTDO.getShowDate();
|
if ((i + "").equalsIgnoreCase(month) || i == Integer.parseInt(month)) {
|
total = chartTDO.getShowValue();
|
break;
|
}
|
}
|
|
if (total == null) {
|
total = "0";
|
}
|
|
ChartTDO chartTDO = new ChartTDO();
|
chartTDO.setShowValue(total);
|
if (i < 10) {
|
chartTDO.setShowDate("0" + i);
|
} else {
|
chartTDO.setShowDate(i + "");
|
}
|
listObject.add(chartTDO);
|
}
|
return listObject;
|
}
|
|
public List<ChartTDO> yearFactory(List<ChartTDO> list) {
|
List<ChartTDO> listObject = new ArrayList<ChartTDO>();
|
for (int i = 0; i < list.size(); i++) {
|
ChartTDO chartTDO = list.get(i);
|
String showValue = chartTDO.getShowValue();
|
if (showValue == null) {
|
chartTDO.setShowValue("0");
|
}
|
listObject.add(chartTDO);
|
}
|
return listObject;
|
}
|
|
|
@Override
|
public List<ChartTDO> countWeiQaunOrderMoney(Integer dateType, String year, String startTime, String endTime)
|
throws Exception {
|
return taoBaoWeiQuanOrderMapper.countWeiQaunOrderMoney(dateType, year, startTime, endTime);
|
}
|
|
@Override
|
public List<ChartTDO> countWeiQaunOrderNumber(Integer dateType, String year, String startTime, String endTime)
|
throws Exception {
|
return taoBaoWeiQuanOrderMapper.countWeiQaunOrderNumber(dateType, year, startTime, endTime);
|
}
|
|
@Override
|
public Map<String, Object> countOrderNumberBySettleTime(Long uid, Integer state, Integer day) {
|
return commonOrderCountMapper.countOrderNumberBySettleTime(uid, state, day);
|
}
|
|
/**
|
* 根据结算时间筛选 上个月已结算的订订单数量
|
*
|
* @param uid
|
* @return
|
*/
|
@Override
|
public Map<String, Object> lastMonthSettleOrderNumber(Long uid) {
|
return countOrderNumberBySettleTime(uid, 2, 4); // 根据
|
}
|
|
@Override
|
public BigDecimal getMoneyByOrderNo(String orderNo) {
|
return commonOrderCountMapper.getMoneyByOrderNo(orderNo);
|
}
|
|
@Override
|
public long countValidOrderByDate(Long uid, String dateTime) {
|
return commonOrderCountMapper.countValidOrderByDate(uid, dateTime);
|
}
|
|
@Override
|
public long countSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) {
|
|
Date date = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 365);
|
return commonOrderCountMapper.countSameShopOrderByUidAndHongBaoType(typeList, uid, minSameShopGoodsCount, date);
|
}
|
|
private List<Long> getExcudeGoodsIds() {
|
List<Long> shopIds = new ArrayList<>();
|
shopIds.add(2549841410L);//天猫国际官方直营
|
shopIds.add(725677994L);//天猫超市
|
shopIds.add(4066234693L);//天猫国际海外仓直购
|
shopIds.add(123971619L);//天猫国际进口超市
|
shopIds.add(231452441L);//天猫会员店
|
shopIds.add(464516896L);//天猫精灵官方旗舰店
|
shopIds.add(1862759827L);//天猫魔盒官方旗舰店
|
shopIds.add(1910146537L);//天猫超市生鲜店
|
shopIds.add(2928278102L);//阿里健康
|
return shopIds;
|
}
|
|
@Override
|
public long countSameGoodsOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) {
|
//排除特殊店铺
|
List<Long> shopIds = getExcudeGoodsIds();
|
Date date = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 365L);
|
return commonOrderCountMapper.countSameGoodsOrderByUidAndHongBaoType(typeList, uid, shopIds, minSameGoodsOrderCount, date);
|
}
|
|
@Override
|
public List<Long> listSameGoodsIdByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) {
|
//排除特殊店铺
|
List<Long> shopIds = getExcudeGoodsIds();
|
|
Date date = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 365L);
|
return commonOrderCountMapper.listSameGoodsIdByUidAndHongBaoType(typeList, uid, shopIds, minSameGoodsOrderCount, date);
|
}
|
|
|
@Override
|
public List<Long> getSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) {
|
//排除特殊店铺
|
List<Long> shopIds = getExcudeGoodsIds();
|
return commonOrderCountMapper.getSameShopOrderByUidAndHongBaoType(typeList, uid, shopIds, minSameShopGoodsCount);
|
}
|
|
@Override
|
public List<Long> getSameGoodsOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) {
|
return commonOrderCountMapper.getSameGoodsOrderByUidAndHongBaoType(typeList, uid, minSameGoodsOrderCount);
|
}
|
|
|
@Override
|
public Integer countOderByUidAndDate(Date preDay, Long uid) {
|
return commonOrderCountMapper.countOderByUidAndDate(preDay, uid);
|
}
|
|
@Override
|
public List<CountOrderDTO> countValidOrderByDay(String preDay) {
|
return commonOrderCountMapper.countValidOrderByDay(preDay);
|
}
|
|
@Override
|
public List<Long> getUidByValidOrderByDay(String preDay) {
|
return commonOrderCountMapper.getUidByValidOrderByDay(preDay);
|
}
|
|
|
@Override
|
public Integer countDownOrderUserByUidAndDate(Date preDay, List<Long> list) {
|
return commonOrderCountMapper.countDownOrderUserByUidAndDate(preDay, list);
|
}
|
|
@Override
|
public List<Long> getDownOrderUserByListUidAndDate(Date preDay, List<Long> list) {
|
return commonOrderCountMapper.getDownOrderUserByListUidAndDate(preDay, list);
|
}
|
|
|
@Override
|
public List<CountOrderDTO> countCommissionByDay(String preDay) {
|
return commonOrderCountMapper.countCommissionByDay(preDay);
|
}
|
|
|
@Override
|
public Integer countOderByDate(String preDay) {
|
return commonOrderCountMapper.countOderByDate(preDay);
|
}
|
|
@Override
|
public BigDecimal countCommissionByDate(String preDay) {
|
return commonOrderCountMapper.countCommissionByDate(preDay);
|
}
|
|
|
@Override
|
public List<CountOrderTrackRate> getOrderTrackRate(int type, Date startTime, Date endTime) {
|
|
OrderTrackRateEnum trackRateEnum = null;
|
if (type == 1) {
|
trackRateEnum = OrderTrackRateEnum.taobao;
|
} else if (type == 2) {
|
trackRateEnum = OrderTrackRateEnum.jd;
|
} else if (type == 3) {
|
trackRateEnum = OrderTrackRateEnum.pdd;
|
} else {
|
trackRateEnum = OrderTrackRateEnum.taobao;
|
}
|
|
// 重新查询统计今日以及空缺
|
initOrderTrackRate(trackRateEnum);
|
|
return countOrderTrackRateDao.query(trackRateEnum, startTime, endTime);
|
}
|
|
// 初始化统计
|
private void initOrderTrackRate(OrderTrackRateEnum trackRateEnum) {
|
try {
|
CountOrderTrackRate lastRecord = countOrderTrackRateDao.getMaxDate(trackRateEnum);
|
Date lastDay = null;
|
if (lastRecord != null && lastRecord.getDay() != null) {
|
lastDay = lastRecord.getDay();
|
}
|
|
if (lastDay == null) {
|
lastDay = TimeUtil.parse("2018-01-01");
|
}
|
|
Date today = new Date();
|
int betweenDays = DateUtil.daysBetween2(lastDay, today);
|
if (betweenDays > 0) {
|
for (int i = 0; i <= betweenDays; i++) {
|
addOrderTrackRateCount(DateUtil.plusDay(i, lastDay), trackRateEnum);
|
}
|
} else {
|
// 重新统计昨日
|
addOrderTrackRateCount(DateUtil.reduceDay2(1, lastDay), trackRateEnum);
|
// 重新统计今日
|
addOrderTrackRateCount(TimeUtil.getGernalTime(today.getTime()), trackRateEnum);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
private void addOrderTrackRateCount(String preDay, OrderTrackRateEnum trackRateEnum) throws Exception {
|
int value = trackRateEnum.getValue();
|
Long count = commonOrderCountMapper.countOrderBySourceTypeAndDay(preDay, value);
|
if (count == null) {
|
count = 0L;
|
}
|
|
Long total = null;
|
switch (value) {
|
case Constant.SOURCE_TYPE_TAOBAO:
|
total = taoBaoOrderMapper.countOrderByDay(preDay);
|
break;
|
case Constant.SOURCE_TYPE_JD:
|
total = jdOrderItemMapper.countOrderByDay(preDay);
|
break;
|
case Constant.SOURCE_TYPE_PDD:
|
total = pddOrderMapper.countOrderByDay(preDay);
|
break;
|
}
|
|
if (total == null)
|
total = 0L;
|
|
CountOrderTrackRate record = new CountOrderTrackRate();
|
record.setNum(count);
|
record.setTotalNum(total);
|
record.setDay(TimeUtil.parse(preDay));
|
record.setType(trackRateEnum.name());
|
record.setId(StringUtil.Md5(preDay + trackRateEnum.name()));
|
countOrderTrackRateDao.save(record);
|
}
|
|
|
@Override
|
public Long countOrderBySourceTypeAndDay(int source, String preDay) {
|
return commonOrderCountMapper.countOrderBySourceTypeAndDay(preDay, source);
|
}
|
|
@Override
|
public long countOrderBySourceAndNearDay(Long uid, int source, int day) {
|
Long count = commonOrderCountMapper.countOrderBySourceAndNearDay(uid, source, day);
|
if (count == null) {
|
count = 0L;
|
}
|
return count;
|
}
|
|
@Override
|
public long countHistoryOrderNum(Long uid) {
|
Long count = commonOrderCountMapper.countHistoryOrderNum(uid);
|
if (count == null) {
|
count = 0L;
|
}
|
return count;
|
}
|
|
|
}
|
