Browse Source

path类推送有bug修复,使用自己实现的md5,0。0.38

menglu 3 years ago
parent
commit
5d62abc596

+ 2 - 2
ibms-data-sdk/pom.xml

@@ -2,7 +2,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.persagy</groupId>
 	<artifactId>ibms-data-sdk</artifactId>
-	<version>0.0.2</version>
+	<version>0.0.5</version>
 
 	<repositories>
 		<repository>
@@ -214,7 +214,7 @@
 		<dependency>
 			<groupId>com.persagy</groupId>
 			<artifactId>sailfish</artifactId>
-			<version>0.0.36</version>
+			<version>0.0.38</version>
 		</dependency>
 	</dependencies>
 

+ 1 - 1
ibms-data-sdk/src/main/java/com/persagy/ibms/data/sdk/service/websocket/server/WebSocketUtil.java

@@ -363,7 +363,7 @@ public class WebSocketUtil {
 							sendItem.put("data", data);
 							sendArray.add(sendItem);
 							for (String id : idList.keySet()) {
-								SendBatch(id, sendArray);
+								SendAndClear(id, sendArray);
 							}
 						}
 						boolean all_0 = false;

+ 8 - 6
ibms-data-sdk/src/main/java/com/persagy/ibms/data/sdk/util/RWDDownloadUtil.java

@@ -293,9 +293,10 @@ public class RWDDownloadUtil {
 				criteria.put("valid", 1);
 				param.put("criteria", criteria);
 				log.debug("Download object " + code);
-				String post_result = HttpClientUtil.instance("rwd").post_compress(Constant.zkt_dmp_url + "/rwd/instance/object/query?projectId="
-						+ RepositoryContainer.RepositoryProject.projectId + "&groupCode=" + RepositoryContainer.RepositoryProject.groupCode,
-						param.toJSONString());
+				String post_result = HttpClientUtil.instance("rwd")
+						.post_compress(Constant.zkt_dmp_url + "/rwd/instance/object/query?projectId="
+								+ RepositoryContainer.RepositoryProject.projectId + "&groupCode=" + RepositoryContainer.RepositoryProject.groupCode,
+								param.toJSONString());
 				JSONObject resultJSON = JSON.parseObject(post_result);
 				if (!resultJSON.getString("result").equals("success")) {
 					throw new Exception(param.toJSONString() + "\n" + post_result);
@@ -448,9 +449,10 @@ public class RWDDownloadUtil {
 				criteria.put("ibmsClassCode", ibmsClassCode);
 				param.put("criteria", criteria);
 				log.debug("Download object " + ibmsSceneCode + "-" + ibmsClassCode);
-				String post_result = HttpClientUtil.instance("zkt_dmp").post_compress(Constant.zkt_dmp_url + "/rwd/instance/object/query?projectId="
-						+ RepositoryContainer.RepositoryProject.projectId + "&groupCode=" + RepositoryContainer.RepositoryProject.groupCode,
-						param.toJSONString());
+				String post_result = HttpClientUtil.instance("zkt_dmp")
+						.post_compress(Constant.zkt_dmp_url + "/rwd/instance/object/query?projectId="
+								+ RepositoryContainer.RepositoryProject.projectId + "&groupCode=" + RepositoryContainer.RepositoryProject.groupCode,
+								param.toJSONString());
 				JSONObject resultJSON = JSON.parseObject(post_result);
 				if (!resultJSON.getString("result").equals("success")) {
 					throw new Exception(param.toJSONString() + "\n" + post_result);