SellerLiveApply.php 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433
  1. <?php
  2. /**
  3. * 机构直播管理
  4. */
  5. namespace app\api\controller;
  6. use think\facade\Lang;
  7. use think\facade\Db;
  8. use GatewayClient\Gateway;
  9. use TencentCloud\Common\Credential;
  10. use TencentCloud\Common\Profile\ClientProfile;
  11. use TencentCloud\Common\Profile\HttpProfile;
  12. use TencentCloud\Common\Exception\TencentCloudSDKException;
  13. use TencentCloud\Live\V20180801\LiveClient;
  14. use TencentCloud\Live\V20180801\Models\DescribeLiveStreamStateRequest;
  15. use AlibabaCloud\Client\AlibabaCloud;
  16. /**
  17. * ============================================================================
  18. * DSKMS多用户商城
  19. * ============================================================================
  20. * 版权所有 2014-2028 长沙德尚网络科技有限公司,并保留所有权利。
  21. * 网站地址: http://www.csdeshang.com
  22. * ----------------------------------------------------------------------------
  23. * 这不是一个自由软件!您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
  24. * 不允许对程序代码以任何形式任何目的的再发布。
  25. * ============================================================================
  26. * 控制器
  27. */
  28. class SellerLiveApply extends MobileSeller {
  29. public function initialize() {
  30. parent::initialize();
  31. Lang::load(base_path() . 'home/lang/' . config('lang.default_lang') . '/live.lang.php');
  32. }
  33. /**
  34. * 显示机构所有直播列表
  35. */
  36. public function get_live_apply_list() {
  37. $live_apply_model = model('live_apply');
  38. $condition[] = array('live_apply_type', 'in', [LIVE_APPLY_TYPE_GOODS]);
  39. $condition[] = array('live_apply_user_type', '=', 2);
  40. $condition[] = array('live_apply_user_id', '=', $this->store_info['store_id']);
  41. $live_apply_list = $live_apply_model->getLiveApplyList($condition, '*', 10);
  42. $goods_model = model('goods');
  43. foreach ($live_apply_list as $key => $val) {
  44. $live_apply_list[$key]['minipro_code'] = '';
  45. if ($val['live_apply_state'] == 1 && file_exists(BASE_UPLOAD_PATH . DIRECTORY_SEPARATOR . ATTACH_LIVE_APPLY . DIRECTORY_SEPARATOR . $val['live_apply_id'] . '.png')) {
  46. $live_apply_list[$key]['minipro_code'] = UPLOAD_SITE_URL . '/' . ATTACH_LIVE_APPLY . '/' . $val['live_apply_id'] . '.png';
  47. }
  48. $goods_commonid = Db::name('live_apply_goods')->where('live_apply_id', $val['live_apply_id'])->column('goods_commonid');
  49. if (!empty($goods_commonid)) {
  50. $goods_list = $goods_model->getGoodsCommonOnlineList(array(array('goods_commonid', 'in', $goods_commonid)), 'goods_name,goods_image', 10);
  51. foreach ($goods_list as $k => $v) {
  52. $goods_list[$k]['goods_image'] = goods_cthumb($v['goods_image']);
  53. }
  54. $live_apply_list[$key]['goods_list'] = $goods_list;
  55. }
  56. }
  57. $result = array_merge(array('live_apply_list' => $live_apply_list), mobile_page($live_apply_model->page_info));
  58. ds_json_encode(10000, '', $result);
  59. }
  60. /**
  61. * 删除直播
  62. */
  63. public function del_live_apply() {
  64. $live_apply_id = intval(input('param.live_apply_id'));
  65. if ($live_apply_id <= 0) {
  66. ds_json_encode(10001, lang('param_error'));
  67. }
  68. $live_apply_model = model('live_apply');
  69. $condition[] = array('live_apply_type', '=', LIVE_APPLY_TYPE_GOODS);
  70. $condition[] = array('live_apply_user_type', '=', 2);
  71. $condition[] = array('live_apply_user_id', '=', $this->store_info['store_id']);
  72. $condition[] = array('live_apply_id', '=', $live_apply_id);
  73. $live_apply = $live_apply_model->getLiveApplyInfo($condition);
  74. if (empty($live_apply)) {
  75. ds_json_encode(10001, lang('param_error'));
  76. }
  77. $live_apply_model->delLiveApply($condition);
  78. ds_json_encode(10000, '');
  79. }
  80. public function get_live_apply_info() {
  81. $msg = '';
  82. $live_apply_id = intval(input('param.live_apply_id'));
  83. if ($live_apply_id <= 0) {
  84. ds_json_encode(10001, lang('param_error'));
  85. }
  86. $live_apply_model = model('live_apply');
  87. $condition = array();
  88. $condition[] = array('live_apply_user_type', '=', 2);
  89. $condition[] = array('live_apply_user_id', '=', $this->store_info['store_id']);
  90. $condition[] = array('live_apply_id', '=', $live_apply_id);
  91. $live_apply = $live_apply_model->getLiveApplyInfo($condition);
  92. if (empty($live_apply)) {
  93. ds_json_encode(10001, lang('live_not_exit'));
  94. }
  95. //判断当前流状态
  96. // require_once root_path() . 'vendor/tencentcloud/tencentcloud-sdk-php/TCloudAutoLoader.php';
  97. if (config('ds_config.video_type') == 'aliyun') {
  98. if (!config('ds_config.aliyun_live_push_domain')) {
  99. ds_json_encode(10001, lang('aliyun_live_push_domain_empty'));
  100. }
  101. if (!config('ds_config.aliyun_live_push_key')) {
  102. ds_json_encode(10001, lang('aliyun_live_push_key_empty'));
  103. }
  104. if (!config('ds_config.aliyun_live_play_domain')) {
  105. ds_json_encode(10001, lang('aliyun_live_play_domain_empty'));
  106. }
  107. if (!config('ds_config.aliyun_live_play_key')) {
  108. ds_json_encode(10001, lang('aliyun_live_play_key_empty'));
  109. }
  110. $regionId = 'cn-shanghai';
  111. AlibabaCloud::accessKeyClient(config('ds_config.aliyun_access_key_id'), config('ds_config.aliyun_access_key_secret'))
  112. ->regionId($regionId)
  113. ->asDefaultClient();
  114. try {
  115. $result = AlibabaCloud::rpc()
  116. ->product('live')
  117. // ->scheme('https') // https | http
  118. ->version('2016-11-01')
  119. ->action('DescribeLiveStreamsOnlineList')
  120. ->method('POST')
  121. ->host('live.aliyuncs.com')
  122. ->options([
  123. 'query' => [
  124. 'RegionId' => $regionId,
  125. 'DomainName' => config('ds_config.aliyun_live_push_domain'),
  126. 'AppName' => "live",
  127. 'StreamName' => 'live_apply_' . $live_apply['live_apply_id'],
  128. 'PageSize' => "1",
  129. 'PageNum' => "1",
  130. 'QueryType' => "strict",
  131. ],
  132. ])
  133. ->request();
  134. if ($result->TotalNum) {
  135. ds_json_encode(10001, '已有另外客户端占用了此直播,请通知管理员解除占用');
  136. }
  137. } catch (\Exception $e) {
  138. ds_json_encode(10001, $e->getMessage());
  139. }
  140. } else {
  141. if (!config('ds_config.live_push_domain')) {
  142. ds_json_encode(10001, lang('live_push_domain_empty'));
  143. }
  144. if (!config('ds_config.live_push_key')) {
  145. ds_json_encode(10001, lang('live_push_key_empty'));
  146. }
  147. if (!config('ds_config.live_play_domain')) {
  148. ds_json_encode(10001, lang('live_play_domain_empty'));
  149. }
  150. try {
  151. $cred = new Credential(config('ds_config.vod_tencent_secret_id'), config('ds_config.vod_tencent_secret_key'));
  152. $httpProfile = new HttpProfile();
  153. $httpProfile->setEndpoint("live.tencentcloudapi.com");
  154. $clientProfile = new ClientProfile();
  155. $clientProfile->setHttpProfile($httpProfile);
  156. $client = new LiveClient($cred, "", $clientProfile);
  157. $req = new DescribeLiveStreamStateRequest();
  158. $params = '{"AppName":"live","DomainName":"' . config('ds_config.live_push_domain') . '","StreamName":"' . 'live_apply_' . $live_apply['live_apply_id'] . '"}';
  159. $req->fromJsonString($params);
  160. $resp = $client->DescribeLiveStreamState($req);
  161. } catch (TencentCloudSDKException $e) {
  162. ds_json_encode(10001, $e->getMessage());
  163. }
  164. if ($resp->StreamState == 'active') {
  165. ds_json_encode(10001, lang('live_occupy'));
  166. }
  167. }
  168. //生成推流url
  169. $live_apply['live_apply_push_url'] = model('live_apply')->getPushUrl('live_apply_' . $live_apply['live_apply_id'], $live_apply['live_apply_end_time']);
  170. //生成拉流url
  171. $live_apply['live_apply_play_url'] = model('live_apply')->getPlayUrl('live_apply_' . $live_apply['live_apply_id'], $live_apply['live_apply_end_time']);
  172. $extral_info = array('live_apply_image' => '');
  173. $live_apply['live_apply_cover_image_url'] = ds_get_pic(ATTACH_COMMON,config('ds_config.default_goods_image'));
  174. if ($live_apply['live_apply_cover_video']) {
  175. $live_apply['live_apply_cover_video_url'] = ds_get_pic( ATTACH_LIVE_APPLY . '/' . $live_apply['live_apply_user_id'] , $live_apply['live_apply_cover_video']);
  176. } elseif ($live_apply['live_apply_cover_image']) {
  177. $live_apply['live_apply_cover_image_url'] = ds_get_pic( ATTACH_LIVE_APPLY . '/' . $live_apply['live_apply_user_id'] , $live_apply['live_apply_cover_image']);
  178. }
  179. $extral_info['live_apply_image'] = $live_apply['live_apply_cover_image_url'];
  180. $online_info = false;
  181. if (config('ds_config.instant_message_register_url')) {
  182. try {
  183. // 设置GatewayWorker服务的Register服务ip和端口,请根据实际情况改成实际值(ip不能是0.0.0.0)
  184. Gateway::$registerAddress = config('ds_config.instant_message_register_url');
  185. $online_info = array(
  186. 'online_count' => Gateway::getClientIdCountByGroup('live_apply_' . $live_apply_id),
  187. 'online_list' => Gateway::getClientSessionsByGroup('live_apply_' . $live_apply_id),
  188. );
  189. } catch (\Exception $e) {
  190. $msg = $e->getMessage();
  191. }
  192. }
  193. ds_json_encode(10000, '', array('live_apply_info' => array_merge($live_apply, $extral_info, array('instant_message_url' => config('ds_config.instant_message_gateway_url'))), 'online_info' => $online_info));
  194. }
  195. public function save_live_apply() {
  196. $live_apply_model = model('live_apply');
  197. $data = array(
  198. 'live_apply_type' => LIVE_APPLY_TYPE_GOODS,
  199. 'live_apply_remark' => input('param.live_apply_remark'),
  200. 'live_apply_play_time' => input('param.live_apply_play_time'),
  201. 'live_apply_name' => input('param.live_apply_name'),
  202. 'live_apply_cover_image' => input('param.live_apply_cover_image'),
  203. 'live_apply_cover_video' => input('param.live_apply_cover_video'),
  204. 'live_apply_add_time' => TIMESTAMP,
  205. 'live_apply_user_type' => 2,
  206. 'live_apply_user_id' => $this->store_info['store_id'],
  207. );
  208. $live_apply_validate = ds_validate('live_apply');
  209. if (!$live_apply_validate->scene('live_apply_save')->check($data)) {
  210. ds_json_encode(10001, $live_apply_validate->getError());
  211. }
  212. $live_apply_id = $live_apply_model->addLiveApply($data);
  213. if ($live_apply_id) {
  214. $goods_ids = ds_delete_param(implode(',', input('param.goods_ids/a')));
  215. if (!empty($goods_ids)) {
  216. $goods_model = model('goods');
  217. $goods_list = $goods_model->getGoodsCommonOnlineList(array(array('goods_commonid', 'in', $goods_ids)), 'goods_commonid,store_id,store_name,goods_name,gc_id,gc_id_1,gc_id_2,gc_id_3,gc_name', 10);
  218. if (!empty($goods_list)) {
  219. $goods_data = array();
  220. foreach ($goods_list as $goods) {
  221. $goods_data[] = array(
  222. 'live_apply_id' => $live_apply_id,
  223. 'goods_commonid' => $goods['goods_commonid'],
  224. 'goods_name' => $goods['goods_name'],
  225. 'gc_id' => $goods['gc_id'],
  226. 'gc_id_1' => $goods['gc_id_1'],
  227. 'gc_id_2' => $goods['gc_id_2'],
  228. 'gc_id_3' => $goods['gc_id_3'],
  229. 'gc_name' => $goods['gc_name'],
  230. 'store_id' => $goods['store_id'],
  231. 'store_name' => $goods['store_name'],
  232. );
  233. }
  234. $live_apply_model->addLiveApplyGoodsAll($goods_data);
  235. }
  236. }
  237. ds_json_encode(10000);
  238. } else {
  239. ds_json_encode(10001, lang('ds_common_op_fail'));
  240. }
  241. }
  242. function join_live() {
  243. session('name');
  244. $live_apply_id = input('param.live_apply_id');
  245. $client_id = input('param.client_id');
  246. if (!config('ds_config.instant_message_register_url')) {
  247. ds_json_encode(10001, lang('instant_message_register_url_empty'));
  248. }
  249. $live_apply_model = model('live_apply');
  250. $condition[] = array('live_apply_user_type', '=', 2);
  251. $condition[] = array('live_apply_state', '=', 1);
  252. $condition[] = array('live_apply_user_id', '=', $this->store_info['store_id']);
  253. $condition[] = array('live_apply_id', '=', $live_apply_id);
  254. $live_apply = $live_apply_model->getLiveApplyInfo($condition);
  255. if (empty($live_apply)) {
  256. ds_json_encode(10001, lang('live_not_exit'));
  257. }
  258. // 设置GatewayWorker服务的Register服务ip和端口,请根据实际情况改成实际值(ip不能是0.0.0.0)
  259. try {
  260. Gateway::$registerAddress = config('ds_config.instant_message_register_url');
  261. // client_id与uid绑定
  262. Gateway::bindUid($client_id, '1:' . $this->store_info['store_id']);
  263. $online_item = array(
  264. 'instant_message_from_avatar' => get_store_logo($this->store_info['store_avatar'], 'store_avatar'),
  265. 'instant_message_from_id' => $this->store_info['store_id'],
  266. 'instant_message_from_type' => 1,
  267. 'instant_message_from_name' => $this->store_info['store_name']
  268. );
  269. Gateway::setSession($client_id, $online_item);
  270. // 加入某个群组(可调用多次加入多个群组)
  271. Gateway::joinGroup($client_id, 'live_apply_' . $live_apply_id);
  272. //更新在线人数
  273. Gateway::sendToGroup('live_apply_' . $live_apply_id, json_encode(array(
  274. 'type' => 'join',
  275. 'online_count' => Gateway::getClientIdCountByGroup('live_apply_' . $live_apply_id),
  276. 'online_list' => Gateway::getClientSessionsByGroup('live_apply_' . $live_apply_id)
  277. )));
  278. } catch (\Exception $e) {
  279. ds_json_encode(10001, $e->getMessage());
  280. }
  281. ds_json_encode(10000, '');
  282. }
  283. function leave_live() {
  284. $live_apply_id = input('param.live_apply_id');
  285. $client_id = input('param.client_id');
  286. $live_apply_push_message = input('param.live_apply_push_message', '');
  287. // if (!$live_apply_push_message) {
  288. // ds_json_encode(10001, '请输入关闭直播理由');
  289. // }
  290. $this->change_live($live_apply_id, 2, $live_apply_push_message);
  291. if ($client_id) {
  292. if (!config('ds_config.instant_message_register_url')) {
  293. ds_json_encode(10001, lang('instant_message_register_url_empty'));
  294. }
  295. // 设置GatewayWorker服务的Register服务ip和端口,请根据实际情况改成实际值(ip不能是0.0.0.0)
  296. try {
  297. Gateway::$registerAddress = config('ds_config.instant_message_register_url');
  298. // client_id与uid绑定
  299. Gateway::unbindUid($client_id, '1:' . $this->store_info['store_id']);
  300. // 加入某个群组(可调用多次加入多个群组)
  301. Gateway::leaveGroup($client_id, 'live_apply_' . $live_apply_id);
  302. //更新在线人数
  303. Gateway::sendToGroup('live_apply_' . $live_apply_id, json_encode(array(
  304. 'type' => 'leave',
  305. 'online_count' => Gateway::getClientIdCountByGroup('live_apply_' . $live_apply_id),
  306. 'online_list' => Gateway::getClientSessionsByGroup('live_apply_' . $live_apply_id),
  307. )));
  308. } catch (\Exception $e) {
  309. ds_json_encode(10001, $e->getMessage());
  310. }
  311. }
  312. ds_json_encode(10000, '');
  313. }
  314. function change_live($live_apply_id = 0, $live_apply_push_state = 0, $live_apply_push_message = '') {
  315. $if_fun = false;
  316. if (input('param.live_apply_push_state')) {
  317. $live_apply_id = input('param.live_apply_id');
  318. $live_apply_push_state = input('param.live_apply_push_state');
  319. $live_apply_push_message = input('param.live_apply_push_message', '');
  320. } else {
  321. $if_fun = true;
  322. }
  323. if ($live_apply_id <= 0) {
  324. ds_json_encode(10001, lang('param_error'));
  325. }
  326. $live_apply_model = model('live_apply');
  327. $condition = array();
  328. $condition[] = array('live_apply_user_type', '=', 2);
  329. $condition[] = array('live_apply_user_id', '=', $this->store_info['store_id']);
  330. $condition[] = array('live_apply_id', '=', $live_apply_id);
  331. $live_apply = $live_apply_model->getLiveApplyInfo($condition);
  332. if (empty($live_apply)) {
  333. ds_json_encode(10001, lang('live_not_exit'));
  334. }
  335. $data = array(
  336. 'live_apply_push_state' => $live_apply_push_state,
  337. 'live_apply_push_message' => $live_apply_push_message,
  338. );
  339. $live_apply_validate = ds_validate('live_apply');
  340. if (!$live_apply_validate->scene('live_apply_change')->check($data)) {
  341. ds_json_encode(10001, $live_apply_validate->getError());
  342. }
  343. $live_apply_model->editLiveApply($data, $condition);
  344. if (!$if_fun) {
  345. ds_json_encode(10000);
  346. }
  347. }
  348. /**
  349. * @api {POST} api/SellerLiveApply/image_upload 上传封面
  350. * @apiVersion 1.0.0
  351. * @apiGroup SellerLiveApply
  352. *
  353. * @apiHeader {String} X-DS-KEY 卖家授权token
  354. *
  355. * @apiParam {File} file 文件
  356. *
  357. * @apiSuccess {String} code 返回码,10000为成功
  358. * @apiSuccess {String} message 返回消息
  359. * @apiSuccess {String} result 店铺图片
  360. */
  361. public function image_upload() {
  362. $store_id = $this->store_info['store_id'];
  363. $store_image_name = 'file';
  364. $file_type = 'image';
  365. if (!empty($_FILES[$store_image_name]['name'])) {
  366. if ($_FILES[$store_image_name]['type'] == 'video/mp4') {
  367. $file_ext = 'mp4';
  368. } else {
  369. $file_ext = ALLOW_IMG_EXT;
  370. }
  371. $res = ds_upload_pic(ATTACH_LIVE_APPLY . DIRECTORY_SEPARATOR . $store_id, $store_image_name,'',$file_ext);
  372. if ($res['code']) {
  373. $file_name = $res['data']['file_name'];
  374. } else {
  375. ds_json_encode(10001, $res['msg']);
  376. }
  377. $data = array();
  378. $data['file_type'] = $file_type;
  379. $data['file_name'] = $file_name;
  380. $data['file_path'] = ds_get_pic( ATTACH_LIVE_APPLY . '/' . $store_id , $file_name);
  381. ds_json_encode(10000, '', $data);
  382. } else {
  383. ds_json_encode(10001, lang('param_error'));
  384. }
  385. }
  386. }