hlm_pl_mall/app/common/model/InstantMessage.php

<?php

namespace app\common\model;


use GatewayClient\Gateway;
use think\facade\Db;

/**
 
 * DSKMS多用户商城
 
 * 
 * ----------------------------------------------------------------------------
 * 
 
 * 数据层模型
 */
class  InstantMessage extends BaseModel
{

    public $page_info;
    /**
     * 获取服务机构通知列表
     * @access public
     * @author csdeshang
     * @param type $condition
     * @param type $pagesize
     * @param type $order
     * @return type
     */
    public function getInstantMessageList($condition, $pagesize = '', $order = 'instant_message_id desc')
    {
        if ($pagesize) {
            $result = Db::name('InstantMessage')->where($condition)->order($order)->paginate(['list_rows' => $pagesize, 'query' => request()->param()], false);
            $this->page_info = $result;
            return $result->items();
        } else {
            return Db::name('InstantMessage')->where($condition)->order($order)->select()->toArray();
        }
    }
    /**
     * 取得服务机构通知信息
     * @access public
     * @author csdeshang 
     * @param array $condition 检索条件
     * @param string $fields 字段
     * @param string $order 排序
     * @return array
     */
    public function getInstantMessageInfo($condition = array(), $fields = '*')
    {
        return Db::name('InstantMessage')->where($condition)->field($fields)->order('instant_message_id desc')->find();
    }

    /**
     * 添加服务机构通知信息
     * @access public
     * @author csdeshang  
     * @param array $data 参数数据
     * @return type
     */
    public function addInstantMessage($data)
    {
        switch ($data['instant_message_to_type']) {
            case 0:
                $member_model = model('member');
                $member = $member_model->getMemberInfo(array('member_id' => $data['instant_message_to_id'], 'member_state' => 1));
                if (!$member) {
                    throw new \think\Exception(lang('user_not_exist'), 10006);
                }
                if ($data['instant_message_from_type'] == 0 && $member['member_id'] == $data['instant_message_from_id']) {
                    throw new \think\Exception(lang('chat_self_error'), 10006);
                }
                $to_name = $member['member_name'];
                break;
            case 1:
                $store_model = model('store');
                $store = $store_model->getStoreOnlineInfoByID($data['instant_message_to_id']);
                if (!$store) {
                    throw new \think\Exception(lang('store_not_exist'), 10006);
                }
                if ($data['instant_message_from_type'] == 0 && $store['member_id'] == $data['instant_message_from_id']) {
                    throw new \think\Exception(lang('chat_self_error'), 10006);
                }
                if ($data['instant_message_from_type'] == 1 && $store['store_id'] == $data['instant_message_from_id']) {
                    throw new \think\Exception(lang('chat_self_error'), 10006);
                }
                $to_name = $store['store_name'];
                break;
            case 2:
                $live_apply_model = model('live_apply');
                $live_apply = $live_apply_model->getLiveApplyInfo(array(array('live_apply_id', '=', $data['instant_message_to_id']), array('live_apply_state', '=', 1), array('live_apply_end_time', '>', TIMESTAMP)));
                if (!$live_apply) {
                    throw new \think\Exception(lang('live_not_exit'), 10006);
                }
                $to_name = $live_apply['live_apply_id'] . lang('live_room');
                break;
            default:
                throw new \think\Exception(lang('param_error'), 10006);
        }
        $data['instant_message_to_name'] = $to_name;
        switch ($data['instant_message_type']) {
            case 1:
                $goods_id = $data['instant_message'];
                if (!$goods_id) {
                    throw new \think\Exception(lang('param_error'), 10006);
                }
                $goods_model = model('goods');
                $goods = $goods_model->getGoodsInfoByID($goods_id);
                if (is_array($goods) && !empty($goods)) {
                    $data['instant_message'] = json_encode(array(
                        'goods_id' => $goods['goods_id'],
                        'goods_name' => $goods['goods_name'],
                        'goods_price' => $goods['goods_price'],
                        'goods_image' => $goods['goods_image'],
                    ));
                } else {
                    throw new \think\Exception(lang('goods_not_exit'), 10006);
                }
                break;
        }
        $instant_message_id = Db::name('InstantMessage')->insertGetId($data);
        if (!$instant_message_id) {
            throw new \think\Exception(lang('send_fail'), 10006);
        }

        $data['instant_message_id'] = $instant_message_id;
        $data = $this->formatInstantMessage($data);
        return $data;
    }

    public function formatInstantMessage($data)
    {
        if ($data['instant_message_type'] == 1) {
            $data['instant_message'] = json_decode($data['instant_message'], true);
            $data['instant_message']['goods_image_url'] = goods_cthumb($data['instant_message']['goods_image']);
        }
        $member_model = model('member');
        $store_model = model('store');
        if ($data['instant_message_to_type'] == 0) {
            $member = $member_model->getMemberInfo(array('member_id' => $data['instant_message_to_id'], 'member_state' => 1));
            $data['instant_message_to_avatar'] = get_member_avatar($member ? $member['member_avatar'] : '');
            $data['instant_message_to_info'] = $member;
        } elseif ($data['instant_message_to_type'] == 1) {
            $store = $store_model->getStoreOnlineInfoByID($data['instant_message_to_id']);
            $data['instant_message_to_avatar'] = get_store_logo($store ? $store['store_avatar'] : '');
            $data['instant_message_to_info'] = $store;
        }

        if ($data['instant_message_from_type'] == 0) {
            $member = $member_model->getMemberInfo(array('member_id' => $data['instant_message_from_id'], 'member_state' => 1));
            $data['instant_message_from_avatar'] = get_member_avatar($member ? $member['member_avatar'] : '');
            $data['instant_message_from_info'] = $member;
        } elseif ($data['instant_message_from_type'] == 1) {
            $store = $store_model->getStoreOnlineInfoByID($data['instant_message_from_id']);
            $data['instant_message_from_avatar'] = get_store_logo($store ? $store['store_avatar'] : '');
            $data['instant_message_from_info'] = $store;
        }

        return $data;
    }

    /**
     * 编辑服务机构通知信息
     * @access public
     * @author csdeshang 
     * @param array $data 更新数据
     * @param array $condition 条件
     * @return bool
     */
    public function editInstantMessage($data, $condition = array())
    {
        return Db::name('InstantMessage')->where($condition)->update($data);
    }

    /**
     * 获取服务机构通知数量
     * @access public
     * @author csdeshang 
     * @param array $condition 条件
     * @return bool
     */
    public function getInstantMessageCount($condition = array())
    {
        return Db::name('InstantMessage')->where($condition)->count();
    }


    public function sendInstantMessage($instant_message, $auto = false)
    {

        if (!config('ds_config.instant_message_register_url')) {
            return ds_callback(false, '未设置直播聊天gateway地址');
        }

        // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值(ip不能是0.0.0.0)
        try {
            Gateway::$registerAddress = config('ds_config.instant_message_register_url');
            if ($instant_message['instant_message_to_type'] == 2) {
                Gateway::sendToGroup('live_apply_' . $instant_message['instant_message_to_id'], json_encode($instant_message));
            } elseif ($instant_message['instant_message_to_type'] == 0) {
                Gateway::sendToUid('0:' . $instant_message['instant_message_to_id'], json_encode($instant_message));
            }
        } catch (\Exception $e) {
            return ds_callback(false, $e->getMessage());
        }
        return ds_callback(true);
    }
}