package com.yeshi.fanli.job.order.taobao;
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.yeshi.fanli.dao.taobao.TaoBaoOrderBackUpDao;
|
import com.yeshi.fanli.dto.taobao.WeiQuanOrderResult;
|
import com.yeshi.fanli.entity.bus.user.LostOrder;
|
import com.yeshi.fanli.entity.bus.user.Order;
|
import com.yeshi.fanli.entity.order.CommonOrder;
|
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
|
import com.yeshi.fanli.entity.taobao.TaoBaoOrderBackUp;
|
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
|
import com.yeshi.fanli.log.LogHelper;
|
import com.yeshi.fanli.service.inter.common.DataMonitorService;
|
import com.yeshi.fanli.service.inter.order.*;
|
import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
|
import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;
|
import com.yeshi.fanli.util.*;
|
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeOrderApiUtil;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.TimeUtil;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
//从淘宝爬去订单更新
|
@Component
|
public class TaoBaoOrderBackUpJob {
|
@Resource
|
private TaoBaoOrderBackUpDao taoBaoOrderBackUpDao;
|
|
//同步某一天的订单
|
private void syncOrder(Date day, int queryType, int status, int orderSence) {
|
long startTime = TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(day.getTime(), "yyyy-MM-dd"), "yyyy-MM-dd");
|
long endTime = startTime + 1000 * 60 * 60 * 24L;
|
List<TaoBaoOrderBackUp> backUpList = TaoKeOrderApiUtil.getTaoBaoOrderBackUpList(startTime, endTime, status, queryType, orderSence);
|
for (TaoBaoOrderBackUp backUp : backUpList) {
|
backUp.setUpdateTime(new Date());
|
taoBaoOrderBackUpDao.save(backUp);
|
}
|
}
|
|
|
/**
|
* 同步订单
|
*
|
* @param day
|
*/
|
public void syncOrder(Date day) {
|
syncOrder(day, 1, 12, 1);
|
syncOrder(day, 1, 13, 1);
|
syncOrder(day, 1, 3, 1);
|
|
syncOrder(day, 3, 12, 1);
|
syncOrder(day, 3, 13, 1);
|
syncOrder(day, 3, 3, 1);
|
}
|
|
|
//同步90天到88天的订单
|
@XxlJob("order-taobao-backUpOrderHandler")
|
public ReturnT<String> syncOrder(String param) throws Exception {
|
long now = TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd"), "yyyy-MM-dd");
|
for (int i = 90; i > 87; i--) {
|
syncOrder(new Date(now - 1000 * 60 * 60L * 24 * i));
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
|
}
|
