合并

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/impl/TaUserServiceImpl.java

 import com.community.huiju.common.code.cache.AppkeyCache;
 import com.community.commom.hk.HKConstant;
 import com.community.commom.hk.HKOpenApi;
+import com.community.huiju.common.messagePush;
 import com.community.huiju.common.perproties.DaSuProperties;
 import com.community.huiju.common.perproties.LoginCodePerproties;
 import com.community.huiju.common.sign.DaSuSign;
     @Autowired
     private TpRoomNoMapper tpRoomNoMapper;
 
+    @Autowired
+    private TpMessageMapper tpMessageMapper;
     @Override
     @Transactional(rollbackFor = Exception.class)
     public ResponseBean login(String loginName, String code, HttpSession session) {
         if ("1".equals(response.getCode())) {
             throw new WisdomException("推送HK失败！");
         }
+        // 推送消息
+        String[] messageArr= new messagePush().messagePushAll( );
+        for (String count : messageArr) {
+            TpMessage message = new TpMessage();
+            message.setCommunityId(userVerify.getCommunityId());
+            message.setMessageType("9");
+            message.setAdviceType("1");
+            message.setModelType("1");
+            message.setUuid(userVerify.getId());
+            message.setUuidType("1");
+            message.setSource("1");
+            message.setMessageContent(count);
+            message.setStatus("1");
+            message.setResult("");
+            message.setMeaasgeTypeId("");
+            message.setReadStatus("0");
+            message.setCreateUser(userElement.getId());
+            message.setCreateDate(new Date());
+            tpMessageMapper.insert(message);
+        }
 
         response.addSuccess(user);
         return response;