| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869 |
- 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<String, Object> map = conversationContentService.getChatData(pageSeq, pageEnd);
- 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;
- // }
- }
- private void pushChatMsg(List<InputChatMsg> 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);
- }
- }
- }
- }
|