| | |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | |
|---|
| | | import com.yeshi.fanli.dto.mq.order.body.CommonOrderMQMsg; |
|---|
| | | import com.yeshi.fanli.util.Constant; |
|---|
| | | import com.yeshi.fanli.util.mq.cmq.order.OrdersCMQManager; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import com.xxl.job.core.biz.model.ReturnT; |
|---|
| | |
|---|
| | | String result = redisManager.getCommonString(key); |
|---|
| | | // 判断 |
|---|
| | | if (StringUtil.isNullOrEmpty(result)) { |
|---|
| | | SuningOrderCMQManager.getInstance().addSuningOrder(order.getOrderCode() + ""); |
|---|
| | | OrdersCMQManager.getInstance().addOrder(new CommonOrderMQMsg(order.getOrderCode() + "",Constant.SOURCE_TYPE_SUNING)); |
|---|
| | | redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新 |
|---|
| | | } |
|---|
| | | } catch (SuningOrderException e) { |
|---|
