| | |
|---|
| | | String tag = message.getTag();
|
|---|
| | | if (tag == null)
|
|---|
| | | tag = "";
|
|---|
| | |
|
|---|
| | | if (java.lang.System.currentTimeMillis() <= Constant.NEW_ORDER_FANLI_RULE_TIME) {
|
|---|
| | | return Action.CommitMessage;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 邀请相关
|
|---|
| | | if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
|
|---|
| | | if (tag.equalsIgnoreCase(UserTopicTagEnum.userCloud.name())) {// 用户等级发生变化
|
|---|
| | | if (tag.equalsIgnoreCase(UserTopicTagEnum.userCloud.name())) {
|
|---|
| | | UserCloudMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserCloudMQMsg.class);
|
|---|
| | | if (msg.getType() == UserCloudMQMsg.TYPE_EVALUATE) {
|
|---|
| | | LogHelper.cloudInfo("发圈中信息 -" + msg.getId() );
|
|---|
| | | userCloudService.autoSendByDynamic(msg.getUid(), msg.getId());
|
|---|
| | | } else {
|
|---|
| | | LogHelper.cloudInfo("选品库信息 -" + msg.getId() );
|
|---|
| | | userCloudService.autoSendCustomGoods(msg.getUid(), Long.parseLong(msg.getId()));
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return Action.CommitMessage;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
