后台管理相关Controller注入系统

admin

2020-07-04 f862a844ea7e212f8cc0622b858308e2b91dca2e

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java

@@ -8,6 +8,7 @@


import javax.annotation.Resource;



import com.yeshi.fanli.util.SystemInfoUtil;

import org.springframework.context.annotation.Lazy;

import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

@@ -34,6 +35,7 @@
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleExtraInfoSerivce;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;

import com.yeshi.fanli.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

@@ -84,8 +86,8 @@
   @Resource(name = "taskExecutor")

   private TaskExecutor executor;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   public UserInfo getBoss(final long uid) {

      return threeSaleMapper.selectBoss(uid);

@@ -99,7 +101,7 @@
      if (worker.getId() == null)// 该用户还不存在

      {

         // 保存用户

         UserInfo inviteeUser = userInfoService.addUser(worker, Constant.APPID);

         UserInfo inviteeUser = userInfoService.addUser(worker,worker.getSystem());

         if (inviteeUser == null)

            throw new ThreeSaleException(2, "创建用户失败");

         // 保存关系

@@ -441,7 +443,7 @@
               UserInviteMQMsg.STATE_SUCCESS);

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteSuccess, msg);

         message.setStartDeliverTime(java.lang.System.currentTimeMillis() + 5000);

         producer.send(message);

         rocketMQManager.sendNormalMsg(message,5000L, null);

      }



      executor.execute(new Runnable() {