[search-console-b2b] move ParsedQueueMessage

search-console-b2b/src/main/java/com/uas/search/console/b2b/jms/JmsListener.java

@@ -3,7 +3,6 @@ package com.uas.search.console.b2b.jms;
 import com.alibaba.druid.pool.DruidDataSource;
 import com.alibaba.fastjson.JSONException;
 import com.uas.search.console.b2b.DruidDBConfiguration;
-import com.uas.search.console.b2b.model.ParsedQueueMessage;
 import com.uas.search.console.b2b.service.IndexService;
 import com.uas.search.console.b2b.util.SearchConstants;
 import com.uas.search.console.b2b.util.SearchConstants.DataSourceQualifier;

search-console-b2b/src/main/java/com/uas/search/console/b2b/model/ParsedQueueMessage.java → search-console-b2b/src/main/java/com/uas/search/console/b2b/jms/ParsedQueueMessage.java

@@ -1,86 +1,86 @@
-package com.uas.search.console.b2b.model;
-
-import java.util.Arrays;
-
-/**
- * 对数据库队列里的消息进行解析后所得到的数据
- * 
- * @author sunyj
- * @since 2016年7月7日 下午8:50:13
- */
-public class ParsedQueueMessage {
-
-	/**
-	 * 数据库中表的改动为insert类型
-	 */
-	public static final int INSERT = 1;
-
-	/**
-	 * 改动为update类型
-	 */
-	public static final int UPDATE = 2;
-
-	/**
-	 * 改动为delete类型
-	 */
-	public static final int DELETE = 3;
-
-	/**
-	 * 表改动后，解析消息时，更改的类型
-	 */
-	private int methodType;
-
-	/**
-	 * 存放解析出来的对象
-	 */
-	private Object[] objects;
-
-	/**
-	 * 是否为insert类型
-	 * 
-	 * @return
-	 */
-	public boolean isInsert() {
-		return methodType == INSERT;
-	}
-
-	/**
-	 * 是否为update类型
-	 * 
-	 * @return
-	 */
-	public boolean isUpdate() {
-		return methodType == UPDATE;
-	}
-
-	/**
-	 * 是否为delete类型
-	 * 
-	 * @return
-	 */
-	public boolean isDelete() {
-		return methodType == DELETE;
-	}
-
-	public int getMethodType() {
-		return methodType;
-	}
-
-	public void setMethodType(int methodType) {
-		this.methodType = methodType;
-	}
-
-	public Object[] getObjects() {
-		return objects;
-	}
-
-	public void setObjects(Object[] objects) {
-		this.objects = objects;
-	}
-
-	@Override
-	public String toString() {
-		return "ParsedQueueMessage [methodType=" + methodType + ", object=" + Arrays.toString(objects) + "]";
-	}
-
-}
+package com.uas.search.console.b2b.jms;
+
+import java.util.Arrays;
+
+/**
+ * 对数据库队列里的消息进行解析后所得到的数据
+ * 
+ * @author sunyj
+ * @since 2016年7月7日 下午8:50:13
+ */
+public class ParsedQueueMessage {
+
+	/**
+	 * 数据库中表的改动为insert类型
+	 */
+	public static final int INSERT = 1;
+
+	/**
+	 * 改动为update类型
+	 */
+	public static final int UPDATE = 2;
+
+	/**
+	 * 改动为delete类型
+	 */
+	public static final int DELETE = 3;
+
+	/**
+	 * 表改动后，解析消息时，更改的类型
+	 */
+	private int methodType;
+
+	/**
+	 * 存放解析出来的对象
+	 */
+	private Object[] objects;
+
+	/**
+	 * 是否为insert类型
+	 * 
+	 * @return
+	 */
+	public boolean isInsert() {
+		return methodType == INSERT;
+	}
+
+	/**
+	 * 是否为update类型
+	 * 
+	 * @return
+	 */
+	public boolean isUpdate() {
+		return methodType == UPDATE;
+	}
+
+	/**
+	 * 是否为delete类型
+	 * 
+	 * @return
+	 */
+	public boolean isDelete() {
+		return methodType == DELETE;
+	}
+
+	public int getMethodType() {
+		return methodType;
+	}
+
+	public void setMethodType(int methodType) {
+		this.methodType = methodType;
+	}
+
+	public Object[] getObjects() {
+		return objects;
+	}
+
+	public void setObjects(Object[] objects) {
+		this.objects = objects;
+	}
+
+	@Override
+	public String toString() {
+		return "ParsedQueueMessage [methodType=" + methodType + ", object=" + Arrays.toString(objects) + "]";
+	}
+
+}

search-console-b2b/src/main/java/com/uas/search/console/b2b/jms/QueueMessageParser.java

@@ -14,7 +14,6 @@ import com.alibaba.fastjson.JSONException;
 import com.alibaba.fastjson.JSONObject;
 import com.uas.search.b2b.exception.SearchException;
 import com.uas.search.b2b.service.SearchService.Table_name;
-import com.uas.search.console.b2b.model.ParsedQueueMessage;
 import com.uas.search.console.b2b.util.ClassAndTableNameUtils;
 import com.uas.search.console.b2b.util.JSONUtils;
 

search-console-b2b/src/main/java/com/uas/search/console/b2b/service/IndexService.java

@@ -3,7 +3,7 @@ package com.uas.search.console.b2b.service;
 import com.uas.search.b2b.model.SPage;
 import com.uas.search.b2b.service.SearchService.Table_name;
 import com.uas.search.console.b2b.jms.platformb2b.LuceneMessage;
-import com.uas.search.console.b2b.model.ParsedQueueMessage;
+import com.uas.search.console.b2b.jms.ParsedQueueMessage;
 import com.uas.search.console.b2b.support.DownloadHelper;
 import com.uas.search.console.b2b.util.SearchConstants.DataSourceQualifier;
 
@@ -11,7 +11,7 @@ import java.util.List;
 
 /**
  * 索引处理
- * 
+ *
  * @author sunyj
  * @since 2016年11月10日 上午9:55:00
  */
@@ -19,7 +19,7 @@ public interface IndexService {
 
 	/**
 	 * 创建指定表的索引
-	 * 
+	 *
 	 * @param tableNames
 	 *            可为空，指定的表，默认创建所有表的索引
 	 * @param fromFiles
@@ -32,7 +32,7 @@ public interface IndexService {
 
 	/**
 	 * 下载指定表的数据至本地文件中，以供建索引用
-	 * 
+	 *
 	 * @param tableNames
 	 *            可为空，指定的表，默认下载所有表的数据
 	 * @return 花费总时间 ms
@@ -72,34 +72,34 @@ public interface IndexService {
 
 	/**
 	 * 将新对象添加在lucene索引中
-	 * 
+	 *
 	 * @param <T>
-	 * 
+	 *
 	 * @param obj
 	 */
 	public <T> T save(T obj);
 
 	/**
 	 * 根据新对象对lucene索引进行更新
-	 * 
+	 *
 	 * @param <T>
-	 * 
+	 *
 	 * @param obj
 	 */
 	public <T> T update(T obj);
 
 	/**
 	 * 将对象从lucene索引中删除
-	 * 
+	 *
 	 * @param <T>
-	 * 
+	 *
 	 * @param obj
 	 */
 	public <T> T delete(T obj);
 
 	/**
 	 * 根据自队列消息解析出来的对象，对lucene索引进行添加、更新或删除操作
-	 * 
+	 *
 	 * @param parsedQueueMessage
 	 *            自队列消息解析出来的对象
 	 * @return 维护的对象
@@ -108,7 +108,7 @@ public interface IndexService {
 
 	/**
 	 * 根据实体类型名维护出问题的表的索引
-	 * 
+	 *
 	 * @param tableName
 	 *            需维护的实体类型名
 	 * @param ids
@@ -121,7 +121,7 @@ public interface IndexService {
 
 	/**
 	 * 根据实体类型名维护出问题的表的索引
-	 * 
+	 *
 	 * @param tableName
 	 *            需维护的实体类型名
 	 * @param data
@@ -134,7 +134,7 @@ public interface IndexService {
 
 	/**
 	 * 获取指定数据源实时更新情况的详细信息
-	 * 
+	 *
 	 * @param dataSourceQualifier
 	 *            数据源标识
 	 * @param page
@@ -150,7 +150,7 @@ public interface IndexService {
 
 	/**
 	 * 指定数据源消息队列出队消息
-	 * 
+	 *
 	 * @param dataSourceQualifier
 	 *            数据源标识
 	 * @param messageId

search-console-b2b/src/main/java/com/uas/search/console/b2b/service/impl/IndexServiceImpl.java

@@ -13,7 +13,7 @@ import com.uas.search.console.b2b.jms.platformb2b.LuceneMessage;
 import com.uas.search.console.b2b.jms.platformb2b.LuceneMessageDao;
 import com.uas.search.console.b2b.jms.QueueMessageParser;
 import com.uas.search.console.b2b.model.PageInfo;
-import com.uas.search.console.b2b.model.ParsedQueueMessage;
+import com.uas.search.console.b2b.jms.ParsedQueueMessage;
 import com.uas.search.console.b2b.service.IndexService;
 import com.uas.search.console.b2b.support.DownloadHelper;
 import com.uas.search.console.b2b.support.DownloadService;