任务模式下才能执行京东/拼多多订单任务

admin

2019-08-03 9715cab3a5c28b498befef79e049481dd5676a02

任务模式下才能执行京东/拼多多订单任务

 fanli/src/main/java/com/yeshi/fanli/job/order/jd/UpdateJDOrderJob.java

@@ -13,6 +13,7 @@
import com.yeshi.fanli.entity.jd.JDOrder;

import com.yeshi.fanli.exception.jd.JDOrderException;

import com.yeshi.fanli.service.inter.jd.JDOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.cmq.JDOrderCMQManager;

import com.yeshi.fanli.util.jd.JDApiUtil;

@@ -57,8 +58,8 @@
     */

    @Scheduled(cron = "0 0/1 * * * ? ")

    public void updateSoonOrder() {

        // if (!Constant.IS_TASK)

        // return;

        if (!Constant.IS_TASK)

            return;

        long now = System.currentTimeMillis();



        JDOrderResult result = JDApiUtil.getOrderList(1, 200, new Date(now), JDApiUtil.ORDER_TYPE_CREATETIME);

@@ -75,8 +76,8 @@
     */

    @Scheduled(cron = "0 0/10 * * * ? ")

    public void updateUpdateOrder() {

        // if (!Constant.IS_TASK)

        // return;

        if (!Constant.IS_TASK)

            return;

        List<JDOrder> jdOrderList = new ArrayList<>();

        int pageSize = 200;

        int page = 1;


 fanli/src/main/java/com/yeshi/fanli/job/order/pdd/UpdatePDDOrderJob.java

@@ -13,9 +13,8 @@
import com.yeshi.fanli.entity.pdd.PDDOrder;

import com.yeshi.fanli.exception.pdd.PDDOrderException;

import com.yeshi.fanli.service.inter.pdd.PDDOrderService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.cmq.JDOrderCMQManager;

import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;



@@ -43,8 +42,8 @@
                 */

                String key = "pdd-order-" + order.getOrderSn();

                String result = redisManager.getCommonString(key);

//                if (!StringUtil.isNullOrEmpty(result))

//                    continue;

                // if (!StringUtil.isNullOrEmpty(result))

                // continue;

                PDDOrderCMQManager.getInstance().addPDDOrder(order.getOrderSn() + "");

                redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新

            } catch (PDDOrderException e) {

@@ -57,8 +56,8 @@
     */

    @Scheduled(cron = "0 0/1 * * * ? ")

    public void updateSoonOrder() {

//        if (!Constant.IS_TASK)

//            return;

        if (!Constant.IS_TASK)

            return;

        Date now = null;

        now = PinDuoDuoApiUtil.getSystemTime();

        if (now == null)

@@ -75,8 +74,8 @@
     */

    @Scheduled(cron = "0 0/30 * * * ? ")

    public void updateUpdateOrder() {

//        if (!Constant.IS_TASK)

//            return;

        if (!Constant.IS_TASK)

            return;

        long endTime = System.currentTimeMillis() - 1000 * 60 * 60L;

        long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24L;

        int page = 1;