| | |
|---|
| | | */
|
|---|
| | | @XxlJob("updateJDOrderHandler")
|
|---|
| | | public ReturnT<String> updateJDSoonOrder(String param) throws Exception {
|
|---|
| | | if ("1".equalsIgnoreCase(param)) {//更新本小时内的单
|
|---|
| | | if ("1".equalsIgnoreCase(param)) {// 更新本小时内的单
|
|---|
| | | LogHelper.job("开始爬取京东订单");
|
|---|
| | | long now = System.currentTimeMillis();
|
|---|
| | |
|
|---|
| | |
|---|
| | | saveJDOrders(result.getOrderList());
|
|---|
| | | } else if ("1hour".equalsIgnoreCase(param)) {// 更新1小时内的订单
|
|---|
| | | updateUpdateOrder();
|
|---|
| | | } else if ("1day".equalsIgnoreCase(param)) {// 更新1天内的订单
|
|---|
| | | updateLatestDayOrder(new Date(System.currentTimeMillis()));
|
|---|
| | | } else if ("3day".equalsIgnoreCase(param)) {// 更新最近3天更新的数据
|
|---|
| | | updateLatest3DayOrder();
|
|---|
| | | }
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 更新最近一天的数据
|
|---|
| | | * |
|---|
| | | * @param date
|
|---|
| | | */
|
|---|
| | | public void updateLatestDayOrder(Date date) {
|
|---|
| | | Date now = new Date();
|
|---|
| | | List<JDOrder> orderList = new ArrayList<>();
|
|---|
| | | Date startTime = new Date(date.getTime() - 1000 * 60 * 60 * 24L);
|
|---|
| | | // 一个小时为一个步长
|
|---|
| | | for (int i = 0; i < 24; i++) {
|
|---|
| | | Date da = new Date(startTime.getTime() + 1000 * 60 * 60L * i);
|
|---|
| | | if (da.getTime() > now.getTime())
|
|---|
| | | break;
|
|---|
| | | List<JDOrder> tempOrderList = getHourOrder(da);
|
|---|
| | | if (tempOrderList != null && tempOrderList.size() > 0)
|
|---|
| | | orderList.addAll(tempOrderList);
|
|---|
| | | }
|
|---|
| | | saveJDOrders(orderList);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 更新最近3天的订单（每天早上凌晨0点过10分，早上8点过10分）
|
|---|
| | | */
|
|---|
| | | public void updateLatest3DayOrder() {
|
|---|
