|
@@ -161,7 +161,7 @@ class MessageProcessing {
|
|
|
messageTypeDataCenterRel =0
|
|
|
/** 查询待处理的消息 */
|
|
|
val messageList =
|
|
|
- synchronousMessageRelService.select(SFilter.not(SFilter.eq("sign", 0))).order("createTime").exec()
|
|
|
+ synchronousMessageRelService.select(SFilter.not(SFilter.eq("sign", 0)),SFilter.lte("count",30)).order("createTime").exec()
|
|
|
if (messageList.size>0) {
|
|
|
/** 处理消息 */
|
|
|
dataCenterSync.dataSyncRel(messageList)
|