|
@ -1,5 +1,6 @@
|
|
|
package com.yihu.jw.care.endpoint.consult;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.yihu.jw.care.aop.ObserverRequired;
|
|
@ -145,6 +146,39 @@ public class PatientConsultEndpoint extends EnvelopRestEndpoint {
|
|
|
@ApiOperation(value = "im推送个推消息")
|
|
|
public Envelop sendGetuiMessage(String sessionId,String type,String contentType,String senderName,String senderId,String targetId,String content){
|
|
|
try {
|
|
|
String zzdMessage = "";
|
|
|
switch (contentType){
|
|
|
case "1":
|
|
|
zzdMessage = senderName+":"+content;
|
|
|
break;
|
|
|
case "2":
|
|
|
zzdMessage = senderName+"发来了一条图片消息";
|
|
|
break;
|
|
|
case "3":
|
|
|
zzdMessage = senderName+"发来了一条语音消息";
|
|
|
break;
|
|
|
case "6":
|
|
|
try {
|
|
|
JSONObject jsonObject = JSON.parseObject(content);
|
|
|
zzdMessage = jsonObject.getString("title");
|
|
|
}catch (Exception e){
|
|
|
zzdMessage = content;
|
|
|
}
|
|
|
break;
|
|
|
case "7":
|
|
|
JSONObject jsonObject = JSON.parseObject(content);
|
|
|
zzdMessage = jsonObject.getString("msg");
|
|
|
break;
|
|
|
case "12":
|
|
|
zzdMessage = senderName+"发来了一条视频消息";
|
|
|
break;
|
|
|
case "29":
|
|
|
zzdMessage = senderName+"邀请您进行语音/视频通话";
|
|
|
break;
|
|
|
default:
|
|
|
logger.info(senderName+":"+content);
|
|
|
break;
|
|
|
}
|
|
|
String body = "收到来自"+senderName+"的一条消息,请关注并及时处理。";
|
|
|
String peerName = null;
|
|
|
String sql = "SELECT name from im_internet_hospital.sessions WHERE id = '"+sessionId+"'";
|
|
@ -158,8 +192,9 @@ public class PatientConsultEndpoint extends EnvelopRestEndpoint {
|
|
|
String url = "/chatroom/index?type="+type+"&peerId="+senderId+"&action=callVideo&peerName="+peerName+"&sessionId="+sessionId+"&content="+content;
|
|
|
logger.info("url="+url);
|
|
|
messageUtil.sendDoctorGetuiMessage(targetId,"4",url,"im消息",body);
|
|
|
|
|
|
// messageUtil.sendDoctorDingdingMessage(null,targetId,"text","4",body,null,null);
|
|
|
if(StringUtils.isNotBlank(zzdMessage)){
|
|
|
messageUtil.sendDoctorDingdingMessage(null,targetId,"text","4",zzdMessage,null,null);
|
|
|
}
|
|
|
return Envelop.getSuccess("请求成功");
|
|
|
}catch (Exception e){
|
|
|
e.printStackTrace();
|