| | |
|---|
| | | */
|
|---|
| | | @Transactional
|
|---|
| | | private void inviteSuccess(Long workerId, Long bossId) {
|
|---|
| | | // 同步粉丝消息
|
|---|
| | | teamFansInfoService.addFansInfo(workerId, bossId, new Date());
|
|---|
| | | |
|---|
| | | if (!Constant.IS_TEST) {
|
|---|
| | | UserInviteMQMsg msg = new UserInviteMQMsg(bossId, workerId, null, new Date(),
|
|---|
| | | UserInviteMQMsg.STATE_SUCCESS);
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteSuccess, msg);
|
|---|
| | | message.setStartDeliverTime(java.lang.System.currentTimeMillis() + 5000);
|
|---|
| | | producer.send(message);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|---|
| | | public void run() {
|
|---|
| | | try { // 邀请金币
|
|---|
| | | integralGetService.addInviteLevelOne(bossId, workerId);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.error(e);
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | // 同步粉丝消息
|
|---|
| | | try {
|
|---|
| | | teamFansInfoService.addFansInfo(workerId, bossId, new Date());
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | LogHelper.error(e);
|
|---|
| | | }
|
|---|
