Browse Source

发送模板消息修改

yeshijie 7 years ago
parent
commit
5373a3f44f

+ 5 - 3
src/server/models/client/wechat.client.js

@ -266,8 +266,10 @@ class WechatClient extends RedisModel {
                    }
                    let first = "您的健康咨询有新的回复";
                    if(targetUserId!=message.sender_id){
                        first = "您的家人("+message.sender_name+")的健康咨询有新的回复";
                    if(message.receiver&&message.receiver != targetUserId){
                        first = "您的家人("+message.receiverName+")的健康咨询有新的回复";
                    }else {
                        message.receiver = targetUserId;
                    }
                    // 发送模板消息
@ -275,7 +277,7 @@ class WechatClient extends RedisModel {
                        touser: openid,
                        template_id: config.wechatConfig.template.consultTemplate,
                        url: config.wechatConfig.baseUrl + "/wx/html/yszx/html/consulting-doctor.html?openid=" + openid +
                        "&consult=" + topic.id + "&toUser=" + targetUserId + "&toName=" + targetUserName+"&represented="+message.sender_id,
                        "&consult=" + topic.id + "&toUser=" + targetUserId + "&toName=" + targetUserName+"&represented="+message.receiver,
                        data: {
                            first: {value: first, color: "#000000"}
                            , remark: {value: "", color: "#000000"}

+ 2 - 0
src/server/models/sessions/sessions.js

@ -1415,6 +1415,8 @@ class Sessions extends RedisModel {
                    } else {
                        res.forEach(function (participant) {
                            if (participant.id != message.sender_id){
                                message.receiver = participant.pid;
                                message.receiverName = participant.pname;
                                WechatClient.sendMessage(participant.id, participant.name, message);
                            }
                        })

+ 3 - 3
src/server/repository/mysql/participant.repo.js

@ -89,9 +89,9 @@ class ParticipantRepo {
     */
    static findFamilyIds(sessionId, handler){
        let sql =
            "SELECT u.id, u.name, true is_patient, p.participant_role,u.avatar " +
            "FROM sessions s, participants p, patients u ,wlyy.wlyy_patient_family_member m " +
            "WHERE s.id = ? and s.id = p.session_id and p.participant_id = m.patient AND m.family_member = u.id and m.is_authorize = 1 ";
            "SELECT u.id, u.name, true is_patient, p.participant_role,u.avatar,ps.name pname,ps.id pid " +
            "FROM sessions s, participants p, patients u ,wlyy.wlyy_patient_family_member m,patients ps " +
            "WHERE s.id = ? and s.id = p.session_id and p.participant_id = m.patient AND m.family_member = u.id and m.is_authorize = 1 and p.participant_id = ps.id ";
        //新增发送代理人
        ImDb.execQuery({