From fb6eb1e6b9df772d243b5ade8b9e3dd08028e935 Mon Sep 17 00:00:00 2001 From: Administrator <Administrator@MS-20170306HGUF> Date: 星期二, 25 二月 2020 20:05:56 +0800 Subject: [PATCH] 刷单标识 --- fanli/src/main/java/com/yeshi/fanli/service/impl/count/CommonOrderCountServiceImpl.java | 665 +++++++++++++++++++++++++++--------------------------- 1 files changed, 335 insertions(+), 330 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/count/CommonOrderCountServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/count/CommonOrderCountServiceImpl.java index 9e7da62..f7aa9e0 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/count/CommonOrderCountServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/count/CommonOrderCountServiceImpl.java @@ -1,330 +1,335 @@ -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.CountOrderInfoDao; -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 com.yeshi.fanli.util.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 CountOrderInfoDao countOrderInfoDao; - - - @Resource - private CountOrderTrackRateDao countOrderTrackRateDao; - - - @Override - public Long countByState(Integer state) { - return commonOrderCountMapper.countByState(state); - } - - 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) { - return commonOrderCountMapper.countSameShopOrderByUidAndHongBaoType(typeList, uid, minSameShopGoodsCount); - } - - @Override - public long countSameGoodsOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) { - return commonOrderCountMapper.countSameGoodsOrderByUidAndHongBaoType(typeList, uid, minSameGoodsOrderCount); - } - - - @Override - public List<Long> getSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) { - return commonOrderCountMapper.getSameShopOrderByUidAndHongBaoType(typeList, uid, 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 Integer countDownOrderUserByUidAndDate(Date preDay, List<Long> list) { - return commonOrderCountMapper.countDownOrderUserByUidAndDate(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); - } - - -} +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.CountOrderInfoDao; +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 com.yeshi.fanli.util.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 CountOrderInfoDao countOrderInfoDao; + + + @Resource + private CountOrderTrackRateDao countOrderTrackRateDao; + + + @Override + public Long countByState(Integer state) { + return commonOrderCountMapper.countByState(state); + } + + @Override + public Integer countOderByUidAndLess10(Long uid) { + return commonOrderCountMapper.countOderByUidAndLess10(uid); + } + + 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) { + return commonOrderCountMapper.countSameShopOrderByUidAndHongBaoType(typeList, uid, minSameShopGoodsCount); + } + + @Override + public long countSameGoodsOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) { + return commonOrderCountMapper.countSameGoodsOrderByUidAndHongBaoType(typeList, uid, minSameGoodsOrderCount); + } + + + @Override + public List<Long> getSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) { + return commonOrderCountMapper.getSameShopOrderByUidAndHongBaoType(typeList, uid, 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 Integer countDownOrderUserByUidAndDate(Date preDay, List<Long> list) { + return commonOrderCountMapper.countDownOrderUserByUidAndDate(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); + } + + +} -- Gitblit v1.8.0