zoujiajian il y a 1 an
Parent
commit
58cca1cd8e

+ 13 - 13
netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpServiceImpl.java

@@ -238,16 +238,16 @@ public class CorpServiceImpl implements CorpService {
 					}
 				})
 				.end()
-//				//企业微信客服 用户进入会话事件
-//				.rule().async(false).msgType("event").event("kf_msg_or_event")
-//				.handler(new CorpMessageHandler() {
-//					@Override
-//					public CorpXmlOutMessage handle(CorpXmlMessage message, Map<String, Object> context, CorpService corpService) throws Exception {
-//						//
-//						return kfMsgOrEvent(message, context);
-//					}
-//				})
-//				.end()
+				//企业微信客服 用户进入会话事件
+				.rule().async(false).msgType("event").event("kf_msg_or_event")
+				.handler(new CorpMessageHandler() {
+					@Override
+					public CorpXmlOutMessage handle(CorpXmlMessage message, Map<String, Object> context, CorpService corpService) throws Exception {
+						//
+						return kfMsgOrEvent(message, context);
+					}
+				})
+				.end()
 		;
 
 	}
@@ -592,9 +592,9 @@ public class CorpServiceImpl implements CorpService {
 		cursor = wxCpKfMsgListResp.getNextCursor();
 		corpKfAccountSyncMsgProgress.setNextCursor(cursor);
 		//同步信息
-		while (wxCpKfMsgListResp.getHasMore() == 1) {
-			syncCorpKfMsg(corpKfAccount, corpKfAccountSessionConfig, corpId, wxCpKfMsgListResp.getNextCursor(), token, limit, corpKfAccountSyncMsgProgress);
-		}
+//		while (wxCpKfMsgListResp.getHasMore() == 1) {
+//			syncCorpKfMsg(corpKfAccount, corpKfAccountSessionConfig, corpId, wxCpKfMsgListResp.getNextCursor(), token, limit, corpKfAccountSyncMsgProgress);
+//		}
 	}
 
 	private void syncKfChatMsg(String corpId, String openKfId, CorpKfAccountSessionConfig corpKfAccountSessionConfig, WxCpKfMsgListResp.WxCpKfMsgItem item) throws Exception {