chat.js 4.88 KB
'use strict';
const orderModel = require('../../home/models/order');
const crypto = global.yoho.crypto;
const imApi = require('../models/im-api');
const userApi = require('../../passport/models/auth-helper');
const imModel = require('../models/im');
const helpers = global.yoho.helpers;
const sign = global.yoho.sign;

exports.appAdapter = (req, res, next) => {
    if (req.yoho.isApp) {
        req.query.client_secret = req.yoho.client_secret;

        if (sign.checkSign(req.query)) {
            let uid = (req.query.uid || '').trim();

            req.user.uid = uid;
        }
    }

    next();
};

exports.page = (req, res, next) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.query.uid;
    }


    userApi.profile(req.user.uid)
        .then(userinfo => {
            userinfo = userinfo.data;

            res.render('chat/index', {
                module: 'service',
                page: 'chat',
                pageStyle: 'service-chat',
                width750: true,
                localCss: true,
                imServer: global.yoho.config.domains.imServer,
                imSocket: global.yoho.config.domains.imSocket,
                userData: {
                    uid: uid,
                    encrypteduid: crypto.encryption(null, uid + ''),
                    avatar: helpers.image(userinfo.head_ico, 100, 100),
                    uname: userinfo.profile_name
                }
            });
        })
        .catch(next);

};

exports.getOrders = (req, res, next) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.query.uid;
    }

    orderModel.getOrders({
        type: req.query.type || 1,
        page: req.query.page || 1,
        gender: req.query.gender || '1,3',
        yh_channel: req.query.channel || 1,
        uid
    }).then(result => {
        res.render('chat/chat-order', {
            layout: false,
            orders: result
        });
    }).catch(next);
};

/**
 *  获取历史消息
 *  Request:
 *
 */
exports.fetchHistory = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.query.uid;
    }

    const endTime = req.query.endTime;

    imApi.fetchImHistory(uid, endTime).then(result => {
        res.json(result);
    });
};


exports.msghistory = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.query.uid;
    }


    imApi.fetchImHistory(uid).then(result => {
        res.json(result);
    });
};

/**
 *  Request: 发表留言
 *  type: POST
 *  params:
 *      conversationId  会话id
 *      content    留言内容
 */
exports.saveMSG = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.body.uid;
    }

    const conversationId = req.body.conversationId;
    const content = req.body.content;

    imApi.saveMessage(uid, conversationId, content)
        .then(result => {
            res.json(result);
        });
};

/**
 *  Request:    获取订单
 *  type:   GET
 *
 *  TODO:
 *      1.  分页, 目前接口不支持
 *      2.  失败情况
 */
exports.fetchOrders = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.query.uid;
    }


    imApi.fetchOrderList(uid)
        .then(result => {
            imModel.handleOrderList(result.data, 128, 170);
            res.json(result);
        }).catch(() =>{
            return res.json({
                code: 500,
                data: []
            });
        });
};

exports.saveEvalute = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.body.uid;
    }


    const conversationId = req.body.conversationId;
    const promoter = req.body.promoter;
    const stars = req.body.stars;
    const reasonMsg = req.body.reasonMsg || '';

    imApi.saveEvalute(uid, conversationId, promoter, stars, reasonMsg)
        .then(result => {
            return res.json(result);
        }).catch(() => {
            return res.json({
                code: 500,
                message: '评价失败'
            });
        });
};


exports.queryGlobalOrder = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.query.uid;
    }


    let emptyOrder = {
        code: 200,
        data: [],
        message: '获取失败'
    };

    imApi.queryGlobalOrder(uid)
        .then(result=> {
            imModel.handleOrderList(result.data, 128, 170);
            res.json(result);
        }, () => {
            res.json(emptyOrder);
        });
};

/**
 *  Request: 获取评价原因
 *  type: GET
 *  params:
 *      cvId  会话id
 */
exports.queryReasons = (req, res) => {
    let uid = req.user.uid;

    if (!uid) {
        uid = req.body.uid;
    }

    const cvId = req.query.conversationId;

    imApi.queryReasons(cvId)
        .then(result=> {
            res.json(result);
        })
        .catch(() => {
            return res.json({
                code: 500,
                message: '拉取评价原因失败'
            });
        });
};