From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/service/impl/count/CommonOrderCountServiceImpl.java | 605 ++++++++++++++++++++++++++++++------------------------ 1 files changed, 331 insertions(+), 274 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 f7aa9e0..31c847c 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 @@ -16,7 +16,6 @@ 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; @@ -25,311 +24,369 @@ 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; +import org.yeshi.utils.TimeUtil; @Service public class CommonOrderCountServiceImpl implements CommonOrderCountService { - @Resource - private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper; + @Resource + private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper; - @Resource - private TaoBaoOrderMapper taoBaoOrderMapper; + @Resource + private TaoBaoOrderMapper taoBaoOrderMapper; - @Resource - private JDOrderItemMapper jdOrderItemMapper; + @Resource + private JDOrderItemMapper jdOrderItemMapper; - @Resource - private PDDOrderMapper pddOrderMapper; + @Resource + private PDDOrderMapper pddOrderMapper; - @Resource - private CommonOrderCountMapper commonOrderCountMapper; - - - @Resource - private CountOrderInfoDao countOrderInfoDao; - - - @Resource - private CountOrderTrackRateDao countOrderTrackRateDao; - + @Resource + private CommonOrderCountMapper commonOrderCountMapper; - @Override - public Long countByState(Integer state) { - return commonOrderCountMapper.countByState(state); - } - - @Override - public Integer countOderByUidAndLess10(Long uid) { - return commonOrderCountMapper.countOderByUidAndLess10(uid); - } + @Resource + private CountOrderTrackRateDao countOrderTrackRateDao; - 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; - } + @Override + public Long countByState(Integer state) { + return commonOrderCountMapper.countByState(state); + } - String plusDay = ""; - for (int i = 0; i < 1000; i++) { - if (i == 0) { - plusDay = startTime; - } else { - plusDay = DateUtil.plusDay(i, startTime); - } + @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)); + } - 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); + 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; + } - if (plusDay.equals(endTime)) { - break; // 鏃堕棿缁撴潫 - } - } + String plusDay = ""; + for (int i = 0; i < 1000; i++) { + if (i == 0) { + plusDay = startTime; + } else { + plusDay = DateUtil.plusDay(i, startTime); + } - return listObject; - } + 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); - 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 (plusDay.equals(endTime)) { + break; // 鏃堕棿缁撴潫 + } + } - if (total == null) { - total = "0"; - } + return listObject; + } - 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> 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; + } + } - 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; - } + 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> 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 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); - } + @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); // 鏍规嵁 - } + /** + * 鏍规嵁缁撶畻鏃堕棿绛涢�� 涓婁釜鏈堝凡缁撶畻鐨勮璁㈠崟鏁伴噺 + * + * @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 BigDecimal getMoneyByOrderNo(String orderNo) { + return commonOrderCountMapper.getMoneyByOrderNo(orderNo); + } - @Override - public long countValidOrderByDate(Long uid, String dateTime) { - return commonOrderCountMapper.countValidOrderByDate(uid, dateTime); - } + @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 countSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) { - @Override - public long countSameGoodsOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) { - return commonOrderCountMapper.countSameGoodsOrderByUidAndHongBaoType(typeList, uid, minSameGoodsOrderCount); - } + Date date = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 365); + return commonOrderCountMapper.countSameShopOrderByUidAndHongBaoType(typeList, uid, minSameShopGoodsCount, date); + } - - @Override - public List<Long> getSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) { - return commonOrderCountMapper.getSameShopOrderByUidAndHongBaoType(typeList, uid, minSameShopGoodsCount); - } + 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 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; - } + @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); + } - // 閲嶆柊鏌ヨ缁熻浠婃棩浠ュ強绌虹己 - initOrderTrackRate(trackRateEnum); - - return countOrderTrackRateDao.query(trackRateEnum, startTime, endTime); - } + @Override + public List<Long> listSameGoodsIdByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameGoodsOrderCount) { + //鎺掗櫎鐗规畩搴楅摵 + List<Long> shopIds = getExcudeGoodsIds(); - // 鍒濆鍖栫粺璁� - private void initOrderTrackRate(OrderTrackRateEnum trackRateEnum) { - try { - CountOrderTrackRate lastRecord = countOrderTrackRateDao.getMaxDate(trackRateEnum); - Date lastDay = null; - if (lastRecord != null && lastRecord.getDay() != null) { - lastDay = lastRecord.getDay(); - } + Date date = new Date(System.currentTimeMillis() - 1000 * 60 * 60L * 24 * 365L); + return commonOrderCountMapper.listSameGoodsIdByUidAndHongBaoType(typeList, uid, shopIds, minSameGoodsOrderCount, date); + } - 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(); - } - } - - - + @Override + public List<Long> getSameShopOrderByUidAndHongBaoType(List<Integer> typeList, Long uid, int minSameShopGoodsCount) { + //鎺掗櫎鐗规畩搴楅摵 + List<Long> shopIds = getExcudeGoodsIds(); + return commonOrderCountMapper.getSameShopOrderByUidAndHongBaoType(typeList, uid, shopIds, minSameShopGoodsCount); + } - 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 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; + } + + } -- Gitblit v1.8.0