淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/job/order/OrderStatisticJob.java

@@ -1,134 +1,183 @@
package com.yeshi.fanli.job.order;



import java.util.Date;



import javax.annotation.Resource;



import org.springframework.stereotype.Component;



import com.xxl.job.core.biz.model.ReturnT;

import com.xxl.job.core.handler.annotation.XxlJob;

import com.yeshi.fanli.service.manger.order.OrderMoneyStatisticManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;



//订单统计任务

@Component

public class OrderStatisticJob {



   @Resource

   private OrderMoneyStatisticManager orderMoneyStatisticManager;



   public OrderStatisticJob() {



   }



   /**

    * 同步返利与分享赚

    * @Title: syncFanliAndShareData

    * @Description: 
    * @param param

    * @return

    * @throws Exception 
    * ReturnT<String> 返回类型

    * @throws

    */

   @XxlJob("order-statistic-syncFanliAndShareData")

   public ReturnT<String> syncFanliAndShareData(String param) throws Exception {

      long startTime = System.currentTimeMillis();

      if (!StringUtil.isNullOrEmpty(param)) {

         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");

      }



      Date start = new Date(

            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));



      Date end = new Date(TimeUtil.convertToTimeTemp(

            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));



      orderMoneyStatisticManager.syncFanliAndShareData(start, end);

      return ReturnT.SUCCESS;

   }



   /**

    * 同步团队数据

    * @Title: syncTeamData

    * @Description: 
    * @param param

    * @return

    * @throws Exception 
    * ReturnT<String> 返回类型

    * @throws

    */

   @XxlJob("order-statistic-syncTeamData")

   public ReturnT<String> syncTeamData(String param) throws Exception {

      long startTime = System.currentTimeMillis();

      if (!StringUtil.isNullOrEmpty(param)) {

         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");

      }



      Date start = new Date(

            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));



      Date end = new Date(TimeUtil.convertToTimeTemp(

            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));



      orderMoneyStatisticManager.syncTeamData(start, end);

      return ReturnT.SUCCESS;

   }



   /**

    * 同步订单数量

    * @Title: syncOrderNum

    * @Description: 
    * @param param

    * @return

    * @throws Exception 
    * ReturnT<String> 返回类型

    * @throws

    */

   @XxlJob("order-statistic-syncOrderNum")

   public ReturnT<String> syncOrderNum(String param) throws Exception {

      long startTime = System.currentTimeMillis();

      if (!StringUtil.isNullOrEmpty(param)) {

         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");

      }



      Date start = new Date(

            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));



      Date end = new Date(TimeUtil.convertToTimeTemp(

            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));



      orderMoneyStatisticManager.syncOrderNum(start, end);

      return ReturnT.SUCCESS;

   }



   /**

    * 同步分红

    * @Title: syncDividents

    * @Description: 
    * @param param

    * @return

    * @throws Exception 
    * ReturnT<String> 返回类型

    * @throws

    */

   @XxlJob("order-statistic-syncDividents")

   public ReturnT<String> syncDividents(String param) throws Exception {

      long startTime = System.currentTimeMillis();

      if (!StringUtil.isNullOrEmpty(param)) {

         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");

      }



      Date start = new Date(

            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));



      Date end = new Date(TimeUtil.convertToTimeTemp(

            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));



      orderMoneyStatisticManager.syncDividents(start, end);

      return ReturnT.SUCCESS;

   }



}

package com.yeshi.fanli.job.order;

import java.util.Calendar;
import java.util.Date;

import javax.annotation.Resource;

import org.springframework.stereotype.Component;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
import com.yeshi.fanli.service.manger.order.OrderMoneyStatisticManager;
import com.yeshi.fanli.util.StringUtil;
import org.yeshi.utils.TimeUtil;

//订单统计任务
@Component
public class OrderStatisticJob {

   @Resource
   private OrderMoneyStatisticManager orderMoneyStatisticManager;

   public OrderStatisticJob() {

   }

   /**
    * 同步返利与分享赚
    * @Title: syncFanliAndShareData
    * @Description: 
    * @param param
    * @return
    * @throws Exception 
    * ReturnT<String> 返回类型
    * @throws
    */
   @XxlJob("order-statistic-syncFanliAndShareData")
   public ReturnT<String> syncFanliAndShareData(String param) throws Exception {
      long startTime = System.currentTimeMillis();
      if (!StringUtil.isNullOrEmpty(param)) {
         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");
      } else {// 每天零点需要同步上一天的数据
         Calendar calendar = Calendar.getInstance();
         calendar.setTimeInMillis(startTime);
         if (calendar.get(Calendar.HOUR_OF_DAY) == 0) {
            Date start = new Date(TimeUtil.convertToTimeTemp(
                  TimeUtil.getGernalTime(startTime - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

            Date end = new Date(
                  TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

            orderMoneyStatisticManager.syncFanliAndShareData(start, end);
         }
      }

      Date start = new Date(
            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

      Date end = new Date(TimeUtil.convertToTimeTemp(
            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

      orderMoneyStatisticManager.syncFanliAndShareData(start, end);
      return ReturnT.SUCCESS;
   }

   /**
    * 同步团队数据
    * @Title: syncTeamData
    * @Description: 
    * @param param
    * @return
    * @throws Exception 
    * ReturnT<String> 返回类型
    * @throws
    */
   @XxlJob("order-statistic-syncTeamData")
   public ReturnT<String> syncTeamData(String param) throws Exception {
      long startTime = System.currentTimeMillis();
      if (!StringUtil.isNullOrEmpty(param)) {
         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");
      } else {// 每天零点需要同步上一天的数据
         Calendar calendar = Calendar.getInstance();
         calendar.setTimeInMillis(startTime);
         if (calendar.get(Calendar.HOUR_OF_DAY) == 0) {
            Date start = new Date(TimeUtil.convertToTimeTemp(
                  TimeUtil.getGernalTime(startTime - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

            Date end = new Date(
                  TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

            orderMoneyStatisticManager.syncTeamData(start, end);
         }
      }

      Date start = new Date(
            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

      Date end = new Date(TimeUtil.convertToTimeTemp(
            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

      orderMoneyStatisticManager.syncTeamData(start, end);
      return ReturnT.SUCCESS;
   }

   /**
    * 同步订单数量
    * @Title: syncOrderNum
    * @Description: 
    * @param param
    * @return
    * @throws Exception 
    * ReturnT<String> 返回类型
    * @throws
    */
   @XxlJob("order-statistic-syncOrderNum")
   public ReturnT<String> syncOrderNum(String param) throws Exception {
      long startTime = System.currentTimeMillis();
      if (!StringUtil.isNullOrEmpty(param)) {
         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");
      } else {// 每天零点需要同步上一天的数据
         Calendar calendar = Calendar.getInstance();
         calendar.setTimeInMillis(startTime);
         if (calendar.get(Calendar.HOUR_OF_DAY) == 0) {
            Date start = new Date(TimeUtil.convertToTimeTemp(
                  TimeUtil.getGernalTime(startTime - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

            Date end = new Date(
                  TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

            orderMoneyStatisticManager.syncOrderNum(start, end);
         }
      }

      Date start = new Date(
            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

      Date end = new Date(TimeUtil.convertToTimeTemp(
            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

      orderMoneyStatisticManager.syncOrderNum(start, end);
      return ReturnT.SUCCESS;
   }

   /**
    * 同步分红
    * @Title: syncDividents
    * @Description: 
    * @param param
    * @return
    * @throws Exception 
    * ReturnT<String> 返回类型
    * @throws
    */
   @XxlJob("order-statistic-syncDividents")
   public ReturnT<String> syncDividents(String param) throws Exception {
      long startTime = System.currentTimeMillis();
      if (!StringUtil.isNullOrEmpty(param)) {
         startTime = TimeUtil.convertToTimeTemp(param, "yyyy-MM-dd");
      } else {// 每天零点需要同步上一天的数据
         Calendar calendar = Calendar.getInstance();
         calendar.setTimeInMillis(startTime);
         if (calendar.get(Calendar.HOUR_OF_DAY) == 0) {
            Date start = new Date(TimeUtil.convertToTimeTemp(
                  TimeUtil.getGernalTime(startTime - 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

            Date end = new Date(
                  TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

            orderMoneyStatisticManager.syncDividents(start, end);
         }
      }

      Date start = new Date(
            TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(startTime, "yyyy-MM-dd"), "yyyy-MM-dd"));

      Date end = new Date(TimeUtil.convertToTimeTemp(
            TimeUtil.getGernalTime(startTime + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"));

      orderMoneyStatisticManager.syncDividents(start, end);
      return ReturnT.SUCCESS;
   }

}