| | |
|---|
| | | */ |
|---|
| | | @XxlJob("updateJDOrderHandler") |
|---|
| | | public ReturnT<String> updateJDSoonOrder(String param) throws Exception { |
|---|
| | | if ("1".equalsIgnoreCase(param)) {// 更新本小时内的单 |
|---|
| | | LogHelper.job("开始爬取京东订单"); |
|---|
| | | long now = System.currentTimeMillis(); |
|---|
| | | try { |
|---|
| | | if ("1".equalsIgnoreCase(param)) {// 更新本小时内的单 |
|---|
| | | LogHelper.job("开始爬取京东订单"); |
|---|
| | | long now = System.currentTimeMillis(); |
|---|
| | | |
|---|
| | | JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(now), JDApiUtil.ORDER_TYPE_CREATETIME); |
|---|
| | | if (result != null && result.getOrderList() != null) |
|---|
| | | saveJDOrders(result.getOrderList()); |
|---|
| | | // 查询上个小时的 |
|---|
| | | result = JDApiUtil.getOrderList(1, 200, new Date(now - 1000 * 60 * 60L), JDApiUtil.ORDER_TYPE_CREATETIME); |
|---|
| | | if (result != null && result.getOrderList() != null) |
|---|
| | | 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(); |
|---|
| | | JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(now), JDApiUtil.ORDER_TYPE_CREATETIME); |
|---|
| | | if (result != null && result.getOrderList() != null) |
|---|
| | | saveJDOrders(result.getOrderList()); |
|---|
| | | // 查询上个小时的 |
|---|
| | | result = JDApiUtil.getOrderList(1, 200, new Date(now - 1000 * 60 * 60L), JDApiUtil.ORDER_TYPE_CREATETIME); |
|---|
| | | if (result != null && result.getOrderList() != null) |
|---|
| | | 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(); |
|---|
| | | } |
|---|
| | | }catch(Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return ReturnT.SUCCESS; |
|---|
