| | |
|---|
| | | import org.springframework.scheduling.annotation.Scheduled;
|
|---|
| | | 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.dto.jd.JDOrderResult;
|
|---|
| | | import com.yeshi.fanli.entity.jd.JDOrder;
|
|---|
| | | import com.yeshi.fanli.exception.jd.JDOrderException;
|
|---|
| | |
|---|
| | | import com.yeshi.fanli.util.RedisManager;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | | import com.yeshi.fanli.util.cmq.JDOrderCMQManager;
|
|---|
| | | import com.yeshi.fanli.util.cmq.order.JDOrderCMQManager;
|
|---|
| | | import com.yeshi.fanli.util.jd.JDApiUtil;
|
|---|
| | |
|
|---|
| | | //从淘宝爬去订单更新
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 快速订单更新（爬取本小时内的单,每分钟一次）
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0 0/1 * * * ? ")
|
|---|
| | | public void updateSoonOrder() {
|
|---|
| | | if (!Constant.IS_TASK)
|
|---|
| | | return;
|
|---|
| | | @XxlJob("updateJDSoonOrderHandler")
|
|---|
| | | public ReturnT<String> startPreDividents(String param) throws Exception {
|
|---|
| | |
|
|---|
| | | LogHelper.job("开始爬取京东订单");
|
|---|
| | | long now = System.currentTimeMillis();
|
|---|
| | |
|
|---|
| | |
|---|
| | | result = JDApiUtil.getOrderList(1, 200, new Date(now - 1000 * 60 * 60L), JDApiUtil.ORDER_TYPE_CREATETIME);
|
|---|
| | | if (result != null && result.getOrderList() != null)
|
|---|
| | | saveJDOrders(result.getOrderList());
|
|---|
| | |
|
|---|
| | | return ReturnT.SUCCESS;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
