mall/modules/admin/models/live/LiveCallbackForm.php

<?php

/**
 * 重庆赤晓店信息科技有限公司
 * https://www.chixiaodian.com
 * Copyright (c) 2023 赤店商城 All rights reserved.
 */

namespace app\modules\admin\models\live;

use app\models\ErpInventory;
use app\models\ErpInventoryProp;
use app\models\ErpInventoryPropLog;
use app\models\ErpInventoryLog;
use app\models\ErpPurchaseinOrder;
use app\models\ErpPurchasein;
use app\models\ErpPurchaseoutOrder;
use app\models\ErpPurchaseout;
use app\models\ErpSupplier;
use app\models\Goods;
use app\models\GoodsCat;
use app\models\Cat;
use app\models\Option;
use app\constants\OptionSetting;
use app\models\Order;
use app\models\OrderDetail;
use app\models\User;
use app\models\SaasUser;
use app\models\Warehouse;
use app\models\WarehouseZone;
use app\models\LiveConfig;
use app\models\LiveAnchor;
use app\models\LiveCat;
use app\models\LiveRoom;
use app\models\LiveComment;
use app\models\LiveFollow;
use app\models\LiveGoods;

class LiveCallbackForm extends LiveForm {
    public static function callback($data) {
        $command = $data['action'];
        debug_log([__FUNCTION__, __LINE__, $command, $data], __CLASS__ . '.log');
        $command = 'cb_' . $command;
        if($data['data']){
            $data = json_decode($data['data'], true);
        }
        $res = call_user_func_array([new self(), $command], [$data]);
        if($res['code'] === 0){
            $res['code'] = 200;
        }
        debug_log([__FUNCTION__, __LINE__, $command, $res], __CLASS__ . '.log');
        return $res;
    }
    
    public function cb_publish($data) {
        $decode = self::decodePath($data['appname'], $data['id']);
        $this->anchorSaveKey($decode['anchor_id'], 'is_push', 1);
        $this->roomSaveKey($decode['room_id'], 'on_time', new \yii\db\Expression('IF(on_time <= 0, '. (time() - 2) .', on_time)'));
        $this->roomSaveKey($decode['room_id'], 'off_time', 0);
        $this->roomSaveKey($decode['room_id'], 'pre_play_time', 0);
        return [
            'code' => 0,
        ];
    }
    
    public function cb_publish_done($data) {
        $decode = self::decodePath($data['appname'], $data['id']);
        $this->anchorSaveKey($decode['anchor_id'], 'is_push', 0);
        $this->roomSaveKey($decode['room_id'], 'off_time', time());
        self::roomTimeoutClose($decode['room_id']);
        return [
            'code' => 0,
        ];
    }
    
    public static function record() {
        $data = file_get_contents("php://input");
        $data = json_decode($data, true);
        $uri = $data['uri'];
        if (empty($uri)) {
            return false;
        }
        $decode = self::decodePath($data['app'], $data['stream']);
        self::roomRecordAdd($decode['room_id'], $uri);
        return [
            'code' => 0,
        ];
    }

}