|
|
|
@ -1,19 +1,15 @@
|
|
|
|
|
package com.ms.api.queue.consumer;
|
|
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
|
import com.doudian.open.api.order_searchList.data.OrderSearchListData;
|
|
|
|
|
import com.doudian.open.api.order_searchList.param.OrderSearchListParam;
|
|
|
|
|
import com.jinritemai.cloud.base.core.util.AuthThreadLocalUtil;
|
|
|
|
|
import com.jinritemai.cloud.base.core.util.LogUtils;
|
|
|
|
|
import com.ms.api.bo.ShopBO;
|
|
|
|
|
import com.ms.api.queue.ConsumerListener;
|
|
|
|
|
import com.ms.api.queue.Group;
|
|
|
|
|
import com.ms.api.queue.Topic;
|
|
|
|
|
import com.ms.api.queue.message.RsyncOrderMessage;
|
|
|
|
|
import com.ms.api.queue.message.RsyncOrderPageMessage;
|
|
|
|
|
import com.ms.api.service.RsyncOrderService;
|
|
|
|
|
import com.ms.api.service.ShopService;
|
|
|
|
|
import com.ms.api.util.DDApi;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
|
|
|
|
|