淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 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,347 +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 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;
      }
    @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 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;
   }
	
	
    @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;
    }


}