| | |
|---|
| | | import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
|
|---|
| | | import com.yeshi.fanli.util.CMQManager;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.RedisKeyEnum;
|
|---|
| | | import com.yeshi.fanli.util.RedisManager;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | |
|---|
| | | while (its.hasNext()) {
|
|---|
| | | String key = its.next();
|
|---|
| | | List<TaoBaoOrder> orders = map.get(key);
|
|---|
| | | String redisKey = "addorderqueue-" + TaoBaoOrderUtil.getOrderDataHashCode(orders);
|
|---|
| | | ;
|
|---|
| | | String redisKey = RedisKeyEnum.getRedisKey(RedisKeyEnum.addOrderQueue, TaoBaoOrderUtil.getOrderDataHashCode(orders));
|
|---|
| | | // redis做频率限制
|
|---|
| | | try {
|
|---|
| | | if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(redisKey))) {
|
|---|
