| | |
|---|
| | | 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;
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private DataMonitorService dataMonitorService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private RedisManager redisManager;
|
|---|
| | |
|
|---|
| | | private void updateOrder(long startTime, long endTime) {
|
|---|
| | | List<TaoBaoUnionConfig> configList = taoBaoUnionConfigService.getConfigByTypeCache(PidUser.TYPE_FANLI_ANDROID);
|
|---|
| | |
|---|
| | | 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) {
|
|---|
