| | |
|---|
| | | import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.body.UserPhoneOpenMQMsg;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.ThreeSale;
|
|---|
| | | import com.yeshi.fanli.entity.bus.user.UserInfo;
|
|---|
| | | import com.yeshi.fanli.log.LogHelper;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.invite.TeamFansInfoService;
|
|---|
| | |
|---|
| | | JSONObject json = JSONObject.fromObject(new String(message.getBody()));
|
|---|
| | | UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(), UserInviteMQMsg.class);
|
|---|
| | | if (mqMsg != null) {
|
|---|
| | | ThreeSale ts = threeSaleSerivce.selectByWorkerId(mqMsg.getWorkerId());
|
|---|
| | | if (ts == null)
|
|---|
| | | return Action.ReconsumeLater;
|
|---|
| | |
|
|---|
| | | // 更新上级的粉丝数量
|
|---|
| | | teamFansInfoService.updateFansNum(mqMsg.getBossId());
|
|---|
| | | // 添加粉丝信息
|
|---|
| | |
|
|---|
| | | teamFansInfoService.addFansInfo(mqMsg.getWorkerId(), mqMsg.getBossId(), mqMsg.getSuccessTime());
|
|---|
| | |
|
|---|
| | | threeSaleDetailService.addByWorkerUid(mqMsg.getWorkerId());
|
|---|
| | |
|
|---|
