admin
2019-12-18 3a7a632f98016f0041366c579517a05ca06fa903
京东订单爬取时间优化
2个文件已修改
13 ■■■■ 已修改文件
fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java 12 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/util/jd/JDUtil.java 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java
@@ -37,9 +37,16 @@
     */
    public void saveJDOrders(List<JDOrder> jdOrderList) {
        for (JDOrder order : jdOrderList) {
            LogHelper.orderInfo("京东订单:" + order.getOrderId()+"-"+order.getValidCode());
            LogHelper.orderInfo("京东订单:" + order.getOrderId() + "-" + order.getValidCode());
            if (order.getValidCode() == 15)// 过滤掉待付款
                continue;
            //防止多个商品拆单问题,爬取
            if (order.getOrderItemList().size() > 1
                    && order.getOrderTime() > System.currentTimeMillis() - 1000 * 60 * 2L) {
                continue;
            }
            try {
                jdOrderService.addJDOrder(order);
                /**
@@ -47,6 +54,7 @@
                 */
                String key = "jd-order-" + order.getOrderId();
                String result = redisManager.getCommonString(key);
                // 判断
                JDOrderCMQManager.getInstance().addJDOrder(order.getOrderId() + "");
                redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新
@@ -63,7 +71,7 @@
    public void updateSoonOrder() {
        if (!Constant.IS_TASK)
            return;
        LogHelper.job("开始爬取京东订单");
        LogHelper.job("开始爬取京东订单");
        long now = System.currentTimeMillis();
        JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(now), JDApiUtil.ORDER_TYPE_CREATETIME);
fanli/src/main/java/com/yeshi/fanli/util/jd/JDUtil.java
@@ -29,7 +29,6 @@
import org.yeshi.utils.HttpUtil;
import com.yeshi.fanli.dto.GoodsClassDTO;
import com.yeshi.fanli.dto.douyin.DouYinGoods;
import com.yeshi.fanli.dto.jd.JDCommissionInfo;
import com.yeshi.fanli.dto.jd.JDCouponInfo;
import com.yeshi.fanli.dto.jd.JDPingouInfo;