package com.kede.common.task; import com.kede.wechat.bo.InputChatMsg; import com.kede.wechat.service.ConversationContentService; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; import java.sql.SQLOutput; import java.util.List; import java.util.Map; import java.util.StringJoiner; @Component @RestController public class ConversationContentTask { @Resource private ConversationContentService conversationContentService; /** * 获取企业微信聊天记录 */ // @Scheduled(cron = "0 0/5 * * * ?") @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) { pageEnd=3; Map map = conversationContentService.getChatData(pageSeq, pageEnd); List list = (List) map.get("list"); pushChatMsg(list); // if (map == null) { // break; // } // if ((int)map.get("total")<100) { // break; // } // pageSeq= pageSeq + pageLimit+1; // pageEnd = pageEnd + pageLimit; // } } private void pushChatMsg(List list) { for (InputChatMsg chatMsg : list) { System.out.println(chatMsg); String from = chatMsg.getFrom(); String chatName = conversationContentService.getChatName(from); System.out.println("from"+chatName); String tolist = chatMsg.getTolist(); //用逗号分割 String[] tolistArr = tolist.split(","); for (String tolistName : tolistArr) { String tolistName1 = conversationContentService.getChatName(tolistName); System.out.println("toList="+tolistName1); } } } }