订单爬取时间调整

Administrator

2018-10-31 7e0c39b083de1c6f6aba49909b63d177e3f7ea3e

订单爬取时间调整

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

@@ -27,6 +27,8 @@
import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;

import com.yeshi.fanli.util.CMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.taobao.TaoBao110Util;

import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

@@ -68,6 +70,9 @@


    @Resource

    private DataMonitorService dataMonitorService;



    @Resource

    private RedisManager redisManager;



    private void updateOrder(long startTime, long endTime) {

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

@@ -122,7 +127,25 @@
                while (its.hasNext()) {

                    String key = its.next();

                    List<TaoBaoOrder> orders = map.get(key);

                    String redisKey = "addorderqueue-" + key;

                    // redis做频率限制

                    try {

                        if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {

                            continue;

                        }



                    } catch (Exception e) {



                    }



                    CMQManager.getInstance().addTaoBaoOrderMsg(key, orders);



                    try {

                        // 6小时内不再处理

                        redisManager.cacheCommonString(redisKey, "1", 60 * 60 * 6);

                    } catch (Exception e) {



                    }

                }

            }

        } catch (Exception e) {