| | |
|---|
| | | import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg;
|
|---|
| | | import com.yeshi.fanli.log.LogHelper;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.invite.TeamFansInfoService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | | import net.sf.json.JSONObject;
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private TeamFansInfoService teamFansInfoService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private ThreeSaleDetailService threeSaleDetailService;
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public Action consume(Message message, ConsumeContext context) {
|
|---|
| | |
|---|
| | | UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(),UserInviteMQMsg.class);
|
|---|
| | | if (mqMsg != null) {
|
|---|
| | | teamFansInfoService.updateFansNum(mqMsg.getBossId());
|
|---|
| | | |
|---|
| | | threeSaleDetailService.addByWorkerUid(mqMsg.getWorkerId());
|
|---|
| | | }
|
|---|
| | | } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userMoneyAdd.name())) {// 资金到账
|
|---|
| | | // 更新近60天到账
|
|---|
