添加线程发送消息

portal-manager/src/main/java/com/mortals/xhx/common/utils/SendSubSystemTask.java

@@ -4,6 +4,7 @@ import com.mortals.xhx.feign.area.IApiAreaFeign;
 import com.mortals.xhx.feign.device.IDeviceFeign;
 import com.mortals.xhx.feign.skin.ISkinFillFeign;
 import com.mortals.xhx.feign.skin.ISkinSampleFeign;
+import com.mortals.xhx.utils.SpringUtils;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
@@ -24,12 +25,18 @@ public class SendSubSystemTask implements Runnable {
     private ISkinSampleFeign skinSampleFeign;
     private ISkinFillFeign skinFillFeign;
 
+    public SendSubSystemTask() {
+        apiAreaFeign= SpringUtils.getBean(IApiAreaFeign.class);
+        deviceFeign= SpringUtils.getBean(IDeviceFeign.class);
+        skinSampleFeign= SpringUtils.getBean(ISkinSampleFeign.class);
+        skinFillFeign= SpringUtils.getBean(ISkinFillFeign.class);
+    }
 
     @Override
     public void run() {
         String resp = null;
-
         try {
+            Thread.sleep(2000);
             apiAreaFeign.refreshUser();
             Thread.sleep(2000);
             deviceFeign.refreshUser();

portal-manager/src/main/java/com/mortals/xhx/module/user/service/impl/UserServiceImpl.java

@@ -407,7 +407,7 @@ public class UserServiceImpl extends AbstractCRUDCacheServiceImpl<UserDao, UserE
 
     private void noticeSubSystemRefresh() {
         //用户新增修改，推送消息给子系统进行数据同步
-        SendSubSystemTask sendSubSystemTask = new SendSubSystemTask(apiAreaFeign, deviceFeign, skinSampleFeign, skinFillFeign);
+        SendSubSystemTask sendSubSystemTask = new SendSubSystemTask();
         ThreadPool.getInstance().execute(sendSubSystemTask);
     }