|
|
@@ -32,24 +32,22 @@ public class ConversationContentTask {
|
|
|
@RequestMapping(value ="/open/pushMsg", method = RequestMethod.GET)
|
|
|
public void pushMsg() {
|
|
|
Integer pageSeq = 0;
|
|
|
- Integer pageEnd = 100;
|
|
|
Integer pageLimit = 100;
|
|
|
Integer count = 0;
|
|
|
//循环获取数据,每次100条,count不足100条时最后一次循序
|
|
|
-// while (count < pageLimit) {
|
|
|
- pageSeq=0;pageEnd=5;
|
|
|
- Map<String, Object> map = conversationContentService.getChatData(pageSeq, pageEnd);
|
|
|
+ while (count < pageLimit) {
|
|
|
+
|
|
|
+ Map<String, Object> map = conversationContentService.getChatData(pageSeq, pageLimit);
|
|
|
List<InputChatMsg> list = (List<InputChatMsg>) map.get("list");
|
|
|
pushChatMsg(list);
|
|
|
-// if (map == null) {
|
|
|
-// break;
|
|
|
-// }
|
|
|
-// if ((int)map.get("total")<100) {
|
|
|
-// break;
|
|
|
-// }
|
|
|
-// pageSeq= pageSeq + pageLimit+1;
|
|
|
-// pageEnd = pageEnd + pageLimit;
|
|
|
-// }
|
|
|
+ if (map == null) {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ if ((int)map.get("total")<100) {
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ pageSeq= pageSeq + pageLimit+1;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
/**
|