添加message回执，添加chat-route模块

README.md

@@ -31,12 +31,12 @@
 > dispatch(IMConnection, IMRequest)<br>
 
 #### 业务处理流程<br>
-> Received：
-> findHandler(id).dispatch() -> UserHandler
+> Received：<br>
+> findHandler(id).dispatch() -> UserHandler<br>
 >
-> UserHandler.dispatch()
->    switch(cmdId)
->    // doCommand
+> UserHandler.dispatch()<br>
+>    switch(cmdId)<br>
+>    // doCommand<br>
 >
 > UserHandler <- UserService <- UserRepository<br>
   

chat-biz/src/main/java/io/ganguo/chat/biz/ApplicationConfig.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/ApplicationConfig.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz;
+package io.ganguo.chat.route.biz;
 
 import com.mongodb.Mongo;
 import com.mongodb.MongoClient;

chat-biz/src/main/java/io/ganguo/chat/biz/bean/ClientType.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/bean/ClientType.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz.bean;
+package io.ganguo.chat.route.biz.bean;
 
 /**
  * Created by Tony on 2/19/15.

chat-biz/src/main/java/io/ganguo/chat/biz/bean/Gender.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/bean/Gender.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz.bean;
+package io.ganguo.chat.route.biz.bean;
 
 /**
  * @author Tony

chat-biz/src/main/java/io/ganguo/chat/biz/bean/Presence.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/bean/Presence.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz.bean;
+package io.ganguo.chat.route.biz.bean;
 
 /**
  * Created by Tony on 2/21/15.

chat-biz/src/main/java/io/ganguo/chat/biz/entity/BaseEntity.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/entity/BaseEntity.java

@@ -1,9 +1,7 @@
-package io.ganguo.chat.biz.entity;
+package io.ganguo.chat.route.biz.entity;
 
 import org.springframework.data.annotation.Id;
 
-import java.math.BigInteger;
-
 /**
  * Created by Tony on 2/19/15.
  */

chat-biz/src/main/java/io/ganguo/chat/biz/entity/Login.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/entity/Login.java

@@ -1,6 +1,5 @@
-package io.ganguo.chat.biz.entity;
+package io.ganguo.chat.route.biz.entity;
 
-import org.springframework.data.annotation.Id;
 import org.springframework.data.mongodb.core.index.Indexed;
 import org.springframework.data.mongodb.core.mapping.Document;
 

chat-biz/src/main/java/io/ganguo/chat/biz/entity/Message.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/entity/Message.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz.entity;
+package io.ganguo.chat.route.biz.entity;
 
 
 import org.springframework.data.mongodb.core.mapping.Document;
@@ -11,9 +11,12 @@ public class Message extends BaseEntity {
     // uin
     private long to;
     private long from;
+
     private byte type;
+    private boolean read;
     private String message;
     private long createAt;
+    private long readAt;
 
     public long getTo() {
         return to;
@@ -39,6 +42,14 @@ public void setType(byte type) {
         this.type = type;
     }
 
+    public boolean isRead() {
+        return read;
+    }
+
+    public void setRead(boolean read) {
+        this.read = read;
+    }
+
     public String getMessage() {
         return message;
     }
@@ -55,6 +66,14 @@ public void setCreateAt(long createAt) {
         this.createAt = createAt;
     }
 
+    public long getReadAt() {
+        return readAt;
+    }
+
+    public void setReadAt(long readAt) {
+        this.readAt = readAt;
+    }
+
     @Override
     public String toString() {
         return "Message{" +
@@ -68,8 +87,8 @@ public String toString() {
 
     public enum Type {
         SESSION_MSG(0), // 临时会话消息
-        BUDDY_MSG(1),  // 好友消息
-        GROUP_MSG(2);  // 群消息
+        USER_MSG(1),  // 好友消息
+        ROOM_MSG(2);  // 群消息
 
         private byte mValue = 0;
 

chat-biz/src/main/java/io/ganguo/chat/biz/entity/User.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/entity/User.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz.entity;
+package io.ganguo.chat.route.biz.entity;
 
 import org.springframework.data.mongodb.core.index.Indexed;
 import org.springframework.data.mongodb.core.mapping.Document;

chat-biz/src/main/java/io/ganguo/chat/biz/entity/UserDetail.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/entity/UserDetail.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz.entity;
+package io.ganguo.chat.route.biz.entity;
 
 /**
  * @author Tony

chat-biz/src/main/java/io/ganguo/chat/route/biz/repository/LoginRepository.java

@@ -0,0 +1,15 @@
+package io.ganguo.chat.route.biz.repository;
+
+import io.ganguo.chat.route.biz.entity.Login;
+import org.springframework.data.repository.CrudRepository;
+
+import java.math.BigInteger;
+
+/**
+ * Created by Tony on 2/20/15.
+ */
+public interface LoginRepository extends CrudRepository<Login, BigInteger> {
+
+    Login findByUin(long uin);
+
+}

chat-biz/src/main/java/io/ganguo/chat/route/biz/repository/MessageRepository.java

@@ -0,0 +1,13 @@
+package io.ganguo.chat.route.biz.repository;
+
+import io.ganguo.chat.route.biz.entity.Message;
+import org.springframework.data.repository.CrudRepository;
+
+import java.math.BigInteger;
+
+/**
+ * Created by Tony on 2/23/15.
+ */
+public interface MessageRepository extends CrudRepository<Message, BigInteger> {
+
+}

chat-biz/src/main/java/io/ganguo/chat/biz/repository/UserRepository.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/repository/UserRepository.java

@@ -1,7 +1,6 @@
-package io.ganguo.chat.biz.repository;
+package io.ganguo.chat.route.biz.repository;
 
-import io.ganguo.chat.biz.entity.User;
-import org.springframework.data.mongodb.repository.Query;
+import io.ganguo.chat.route.biz.entity.User;
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.stereotype.Repository;
 

chat-biz/src/main/java/io/ganguo/chat/route/biz/service/MessageService.java

@@ -0,0 +1,9 @@
+package io.ganguo.chat.route.biz.service;
+
+/**
+ * Created by Tony on 2/23/15.
+ */
+public interface MessageService {
+
+
+}

chat-biz/src/main/java/io/ganguo/chat/biz/service/UserService.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/service/UserService.java

@@ -1,7 +1,7 @@
-package io.ganguo.chat.biz.service;
+package io.ganguo.chat.route.biz.service;
 
-import io.ganguo.chat.biz.entity.Login;
-import io.ganguo.chat.biz.entity.User;
+import io.ganguo.chat.route.biz.entity.Login;
+import io.ganguo.chat.route.biz.entity.User;
 
 /**
  * Created by Tony on 2/20/15.

chat-biz/src/main/java/io/ganguo/chat/route/biz/service/impl/MessageServiceImpl.java

@@ -0,0 +1,10 @@
+package io.ganguo.chat.route.biz.service.impl;
+
+import io.ganguo.chat.route.biz.service.MessageService;
+
+/**
+ * Created by Tony on 2/23/15.
+ */
+public class MessageServiceImpl implements MessageService {
+
+}

chat-biz/src/main/java/io/ganguo/chat/biz/service/impl/UserServiceImpl.java → chat-biz/src/main/java/io/ganguo/chat/route/biz/service/impl/UserServiceImpl.java

@@ -1,10 +1,10 @@
-package io.ganguo.chat.biz.service.impl;
+package io.ganguo.chat.route.biz.service.impl;
 
-import io.ganguo.chat.biz.entity.Login;
-import io.ganguo.chat.biz.entity.User;
-import io.ganguo.chat.biz.repository.LoginRepository;
-import io.ganguo.chat.biz.repository.UserRepository;
-import io.ganguo.chat.biz.service.UserService;
+import io.ganguo.chat.route.biz.entity.Login;
+import io.ganguo.chat.route.biz.entity.User;
+import io.ganguo.chat.route.biz.repository.LoginRepository;
+import io.ganguo.chat.route.biz.repository.UserRepository;
+import io.ganguo.chat.route.biz.service.UserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

chat-biz/src/test/java/io/ganguo/chat/biz/AbstractIntegrationTest.java → chat-biz/src/test/java/io/ganguo/chat/route/biz/AbstractIntegrationTest.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz;
+package io.ganguo.chat.route.biz;
 
 import org.junit.Before;
 import org.junit.runner.RunWith;

chat-biz/src/test/java/io/ganguo/chat/biz/ApplicationConfigTest.java → chat-biz/src/test/java/io/ganguo/chat/route/biz/ApplicationConfigTest.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz;
+package io.ganguo.chat.route.biz;
 
 import org.junit.Test;
 import org.junit.runner.RunWith;

chat-biz/src/test/java/io/ganguo/chat/biz/Test.java → chat-biz/src/test/java/io/ganguo/chat/route/biz/Test.java

@@ -1,4 +1,4 @@
-package io.ganguo.chat.biz;
+package io.ganguo.chat.route.biz;
 
 import java.util.UUID;
 

chat-biz/src/test/java/io/ganguo/chat/biz/user/TestUserRepository.java → chat-biz/src/test/java/io/ganguo/chat/route/biz/user/TestUserRepository.java

@@ -1,14 +1,12 @@
-package io.ganguo.chat.biz.user;
+package io.ganguo.chat.route.biz.user;
 
-import io.ganguo.chat.biz.AbstractIntegrationTest;
-import io.ganguo.chat.biz.entity.User;
-import io.ganguo.chat.biz.repository.UserRepository;
+import io.ganguo.chat.route.biz.AbstractIntegrationTest;
+import io.ganguo.chat.route.biz.entity.User;
+import io.ganguo.chat.route.biz.repository.UserRepository;
 import org.junit.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 
-import java.math.BigInteger;
 import java.util.Iterator;
-import java.util.List;
 
 /**
  * Created by Tony on 2/20/15.
@@ -21,9 +19,9 @@ public class TestUserRepository extends AbstractIntegrationTest {
     @Test
     public void testSave() {
         User user = new User();
-        user.setUin(0L);
-        user.setAccount("test");
-        user.setPassword("test");
+        user.setUin(2L);
+        user.setAccount("test2");
+        user.setPassword("test2");
         user = userRepository.save(user);
 
         System.out.println("##### " + user);

chat-biz/src/test/java/io/ganguo/chat/biz/user/TestUserService.java → chat-biz/src/test/java/io/ganguo/chat/route/biz/user/TestUserService.java

@@ -1,14 +1,11 @@
-package io.ganguo.chat.biz.user;
+package io.ganguo.chat.route.biz.user;
 
-import io.ganguo.chat.biz.AbstractIntegrationTest;
-import io.ganguo.chat.biz.entity.Login;
-import io.ganguo.chat.biz.entity.User;
-import io.ganguo.chat.biz.service.impl.UserServiceImpl;
+import io.ganguo.chat.route.biz.AbstractIntegrationTest;
+import io.ganguo.chat.route.biz.entity.Login;
+import io.ganguo.chat.route.biz.service.impl.UserServiceImpl;
 import org.junit.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 
-import java.util.UUID;
-
 import static org.junit.Assert.assertNotNull;
 
 /**