zhongshen_project/addon/live/model/Live.php

<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com
 * =========================================================
 */

namespace addon\live\model;

use addon\weapp\model\Config as WeappConfigModel;
use addon\wxoplatform\model\Config as WxOplatformConfigModel;
use app\model\BaseModel;
use EasyWeChat\Factory;

class Live extends BaseModel
{
    private $app;

    /**
     * 微信直播间接口错误码
     * @var array
     */
    private $room_error = [
        1003 => '商品id不存在',
        47001 => '入参格式不符合规范',
        200002 => '入参错误',
        300001 => '禁止创建/更新商品 或 禁止编辑&更新房间',
        300002 => '名称长度不符合规则',
        300006 => '图片上传失败',
        300022 => '此房间号不存在',
        300023 => '房间状态 拦截（当前房间状态不允许此操作）',
        300024 => '商品不存在',
        300025 => '商品审核未通过',
        300026 => '房间商品数量已经满额',
        300027 => '导入商品失败',
        300028 => '房间名称违规',
        300029 => '主播昵称违规',
        300030 => '主播微信号不合法',
        300031 => '直播间封面图不合规',
        300032 => '直播间分享图违规',
        300033 => '添加商品超过直播间上限',
        300034 => '主播微信昵称长度不符合要求',
        300035 => '主播微信号不存在',
        300036 => '主播微信号未实名认证',
    ];

    /**
     * 微信直播商品接口错误码
     * @var array
     */
    private $goods_error = [
        300001 => '商品创建功能被封禁',
        300002 => '名称长度不符合规则',
        300003 => '价格输入不合规',
        300004 => '商品名称存在违规违法内容',
        300005 => '商品图片存在违规违法内容',
        300006 => '图片上传失败',
        300007 => '线上小程序版本不存在该链接',
        300008 => '添加商品失败',
        300009 => '商品审核撤回失败',
        300010 => '商品审核状态不对',
        300011 => 'API不允许操作非API创建的商品',
        300012 => '没有提审额度（每天500次提审额度）',
        300013 => '提审失败',
        300014 => '审核中，无法删除',
        300017 => '商品未提审',
        300021 => '商品添加成功，审核失败',
    ];


    public function __construct($site_id = 0)
    {
        //微信小程序配置
        $weapp_config_model = new WeappConfigModel();
        $weapp_config = $weapp_config_model->getWeappConfig($site_id);
        $weapp_config = $weapp_config[ "data" ][ "value" ];

        if (isset($weapp_config[ 'is_authopen' ]) && addon_is_exit('wxoplatform')) {
            $plateform_config_model = new WxOplatformConfigModel();
            $plateform_config = $plateform_config_model->getOplatformConfig();
            $plateform_config = $plateform_config[ "data" ][ "value" ];

            $config = [
                'app_id' => $plateform_config[ "appid" ] ?? '',
                'secret' => $plateform_config[ "secret" ] ?? '',
                'token' => $plateform_config[ "token" ] ?? '',
                'aes_key' => $plateform_config[ "aes_key" ] ?? '',
                'log' => [
                    'level' => 'debug',
                    'permission' => 0777,
                    'file' => 'runtime/log/wechat/oplatform.logs',
                ],
            ];
            $open_platform = Factory::openPlatform($config);
            $this->app = $open_platform->miniProgram($weapp_config[ 'authorizer_appid' ], $weapp_config[ 'authorizer_refresh_token' ]);
        } else {
            $config = [
                'app_id' => $weapp_config[ "appid" ] ?? '',
                'secret' => $weapp_config[ "appsecret" ] ?? '',
                'response_type' => 'array',
                'log' => [
                    'level' => 'debug',
                    'permission' => 0777,
                    'file' => 'runtime/log/wechat/easywechat.logs',
                ],
            ];
            $this->app = Factory::miniProgram($config);
        }
    }

    /**
     * 添加永久图片素材
     * @param $path
     * @return array
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function addImageMedia($path)
    {
        try {
            $result = $this->app->media->uploadImage($path);
            if (isset($result[ 'errcode' ])) {
                return $this->error('', '图片上传失败');
            } else {
                return $this->success($result);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 获取直播间列表
     * @param int $start
     * @param int $limit
     * @return array
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function getRoomList($start = 0, $limit = PAGE_LIST_ROWS)
    {
        try {
            $result = $this->app->live->room->getLiveInfo([ 'start' => $start, 'limit' => $limit ]);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success([ 'list' => $result[ 'room_info' ], 'total' => $result[ 'total' ] ]);
            } else {
                return $this->error('', $this->room_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 获取回放视频
     * @param $room_id
     * @param int $start
     * @param int $limit
     * @return array
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function getPlaybackInfo($room_id, $start = 0, $limit = PAGE_LIST_ROWS)
    {
        try {
            $data = [
                'action' => 'get_replay',
                'room_id' => $room_id,
                'start' => $start,
                'limit' => $limit
            ];
            $result = $this->app->live->room->getLiveInfo($data);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success([ 'list' => $result[ 'live_replay' ], 'total' => $result[ 'total' ] ]);
            } else {
                return $this->error('', $this->room_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 创建直播间
     * @param $param
     */
    public function createRoom($param)
    {
        try {
            $result = $this->app->live->room->create($param);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success($result);
            } else {
                return $this->error('', $this->room_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 给直播间添加商品
     * @param int $room_id
     * @param array $goods_ids
     * @return array
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function roomAddGoods(int $room_id, array $goods_ids)
    {
        try {
            $result = $this->app->live->room->addGoods([ 'roomId' => $room_id, 'ids' => $goods_ids ]);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success($result);
            } else {
                return $this->error('', $this->room_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 获取商品列表
     * @param int $start
     * @param int $limit
     * @param int $status
     * @return array
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function getGoodsList($start = 0, $limit = PAGE_LIST_ROWS, $status = 2)
    {
        try {
            $result = $this->app->live->goods->getGoodsList([ 'offset' => $start, 'limit' => $limit, 'status' => $status ]);

            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success($result);
            } else {
                return $this->error('', $this->goods_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 添加商品审核
     * @param $param
     * @return array
     */
    public function addGoodsAudit($param)
    {
        try {
            $result = $this->app->live->goods->add($param);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success($result);
            } else {
                return $this->error('', $this->goods_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 删除商品
     */
    public function deleteGoods($goods_id)
    {
        try {
            $result = $this->app->live->goods->delete([ 'goodsId' => $goods_id ]);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success($result);
            } else {
                return $this->error('', $this->goods_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }

    /**
     * 获取商品状态
     * @param array $goods_ids
     * @return array
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function getGoodsStatus(array $goods_ids)
    {
        try {
            $result = $this->app->live->goods->getStatus([ 'goods_ids' => $goods_ids ]);
            if (isset($result[ 'errcode' ]) && $result[ 'errcode' ] == 0) {
                return $this->success($result[ 'goods' ]);
            } else {
                return $this->error('', $this->goods_error[ abs($result[ 'errcode' ]) ] ?? $result[ 'errmsg' ]);
            }
        } catch (\Exception $e) {
            return $this->error('', $e->getMessage());
        }
    }
}