|
@ -23,9 +23,7 @@ import javax.jms.JMSException;
|
|
import javax.jms.Message;
|
|
import javax.jms.Message;
|
|
import javax.jms.MessageListener;
|
|
import javax.jms.MessageListener;
|
|
import javax.jms.TextMessage;
|
|
import javax.jms.TextMessage;
|
|
import java.util.Date;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
import java.util.*;
|
|
|
|
|
|
/**
|
|
/**
|
|
* Created by chenweida on 2017/9/9.
|
|
* Created by chenweida on 2017/9/9.
|
|
@ -98,6 +96,12 @@ public class HealthArtListener implements MessageListener {
|
|
// HealthEduArticleES one = (HealthEduArticleES)JSONObject.toBean(JSONObject.fromObject(textMessage.getText()),HealthEduArticleES.class);
|
|
// HealthEduArticleES one = (HealthEduArticleES)JSONObject.toBean(JSONObject.fromObject(textMessage.getText()),HealthEduArticleES.class);
|
|
// logger.info(jo.toString());
|
|
// logger.info(jo.toString());
|
|
// System.out.printf(healthEduArticleES.toString());
|
|
// System.out.printf(healthEduArticleES.toString());
|
|
|
|
net.sf.json.JSONArray jsonArray = obj.get("openidSet")!=null?(net.sf.json.JSONArray)obj.get("openidSet"):null;
|
|
|
|
Set<String> openidSet = new HashSet<>();
|
|
|
|
for(int i=0;i<jsonArray.size();i++){
|
|
|
|
openidSet.add(jsonArray.get(i).toString());
|
|
|
|
}
|
|
|
|
healthEduArticleES.setOpenidSet(openidSet);
|
|
sendWxTemplateAndIM(healthEduArticleES);
|
|
sendWxTemplateAndIM(healthEduArticleES);
|
|
//返回服务器表示消息消费成功
|
|
//返回服务器表示消息消费成功
|
|
message.acknowledge();
|
|
message.acknowledge();
|