订单爬取规则再次修改

admin

2019-03-09 2aa4dc51f09d2591ef62efc1596d583a52a8d712

订单爬取规则再次修改

 fanli/src/main/java/com/yeshi/fanli/job/UpdateOrderJob.java

@@ -105,9 +105,10 @@
        }

        return orderList;

    }

	


    /**

     * 获取第三方普通订单

     * 
     * @param startTime

     * @param span

     * @return

@@ -129,13 +130,14 @@


    /**

     * 获取某个区间段的订单

     * 
     * @param startTime

     * @param endTime

     * @return

     */

    public static List<TaoBaoOrder> getCommonOrder(long startTime, long endTime) {

        List<TaoBaoOrder> orderList = new ArrayList<>();

        long span =(endTime - startTime)%1000==0? (endTime - startTime)/1000:(endTime - startTime)/1000+1;

        long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1;

        int count = (int) (span / 1200);

        if (span % 1200 != 0)

            count++;

@@ -153,17 +155,17 @@
        }

        return orderList;

    }

	
	


    /**

     * 爬取三方订单

     * 
     * @param startTime

     * @param endTime

     * @return

     */

    public static List<TaoBaoOrder> getThirdCommonOrder(long startTime, long endTime) {

        List<TaoBaoOrder> orderList = new ArrayList<>();

        long span =(endTime - startTime)%1000==0? (endTime - startTime)/1000:(endTime - startTime)/1000+1;

        long span = (endTime - startTime) % 1000 == 0 ? (endTime - startTime) / 1000 : (endTime - startTime) / 1000 + 1;

        int count = (int) (span / 1200);

        if (span % 1200 != 0)

            count++;

@@ -200,36 +202,38 @@
    }



    public void updateOrder(long startTime, long endTime) {

//        老版本处理方式

        List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

        List<TaoBaoOrder> orderList = new ArrayList<>();

        try {

            orderList = TaoBaoOrderUtil.getOrderList(startTime, endTime, configList.get(0));

        } catch (TaoBaoOrderException e2) {

            try {

                LogHelper.errorDetailInfo(e2);

            } catch (Exception e) {

                e.printStackTrace();

            }

        }

        List<TaoBaoOrder> thirdOrderList = new ArrayList<>();

        try {

            thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(startTime, endTime, configList.get(0));

        } catch (TaoBaoOrderException e2) {

            try {

                LogHelper.errorDetailInfo(e2);

            } catch (Exception e) {

                e.printStackTrace();

            }

        }

        if (thirdOrderList != null && thirdOrderList.size() > 0)

            orderList.addAll(thirdOrderList);

//新版本处理方式		
//        List<TaoBaoOrder> orderList=    getCommonOrder(startTime, endTime);

//        List<TaoBaoOrder> tempOrderList2=getThirdCommonOrder(startTime, endTime);

//        if(tempOrderList2!=null&&tempOrderList2.size()>0)

//            orderList.addAll(tempOrderList2);

		
        // 老版本处理方式

        // List<TaoBaoUnionConfig> configList =

        // taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);

        // List<TaoBaoOrder> orderList = new ArrayList<>();

        // try {

        // orderList = TaoBaoOrderUtil.getOrderList(startTime, endTime,

        // configList.get(0));

        // } catch (TaoBaoOrderException e2) {

        // try {

        // LogHelper.errorDetailInfo(e2);

        // } catch (Exception e) {

        // e.printStackTrace();

        // }

        // }

        // List<TaoBaoOrder> thirdOrderList = new ArrayList<>();

        // try {

        // thirdOrderList = TaoBaoOrderUtil.getThirdServiceOrderList(startTime,

        // endTime, configList.get(0));

        // } catch (TaoBaoOrderException e2) {

        // try {

        // LogHelper.errorDetailInfo(e2);

        // } catch (Exception e) {

        // e.printStackTrace();

        // }

        // }

        // if (thirdOrderList != null && thirdOrderList.size() > 0)

        // orderList.addAll(thirdOrderList);

        // 新版本处理方式

        List<TaoBaoOrder> orderList = getCommonOrder(startTime, endTime);

        List<TaoBaoOrder> tempOrderList2 = getThirdCommonOrder(startTime, endTime);

        if (tempOrderList2 != null && tempOrderList2.size() > 0)

            orderList.addAll(tempOrderList2);



        LogHelper.orderInfo("正在执行订单爬取结束，共有订单:" + orderList.size());

        addOrder(orderList);

@@ -348,10 +352,10 @@
    }



    // 每15分钟爬取一次

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

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

    public void doJob1() {

//        if (!Constant.IS_TASK)

//            return;

        // if (!Constant.IS_TASK)

        // return;

        long currentTime = System.currentTimeMillis();

        String h = TimeUtil.getGernalTime(currentTime, "HH");

        String m = TimeUtil.getGernalTime(currentTime, "mm");

@@ -371,8 +375,8 @@
    public void doJob6() {

        if (!Constant.IS_TASK)

            return;

        long endTime=System.currentTimeMillis();

        updateOrder(endTime-1000*60*20L, endTime);

        long endTime = System.currentTimeMillis();

        updateOrder(endTime - 1000 * 60 * 20L, endTime);

    }



    // 返利


 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoKeOrderApiUtil.java

@@ -134,7 +134,7 @@
        orderQuery.orderScene = 1;

        orderQuery.pageNo = page;

        orderQuery.pageSize = 100;

        orderQuery.orderCountType = 2;

        orderQuery.orderCountType = 1;

        return queryTaoBaoOrder(orderQuery, appKey, appSecret);

    }



@@ -158,6 +158,7 @@
        orderQuery.orderScene = 1;

        orderQuery.pageNo = page;

        orderQuery.pageSize = 100;

        orderQuery.orderCountType = 2;

        return queryTaoBaoOrder(orderQuery, appKey, appSecret);

    }