123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132 |
- <?php
- // +----------------------------------------------------------------------
- // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
- // +----------------------------------------------------------------------
- // | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
- // +----------------------------------------------------------------------
- // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
- // +----------------------------------------------------------------------
- // | Author: CRMEB Team <admin@crmeb.com>
- // +----------------------------------------------------------------------
- namespace app\wap\model\live;
- use basic\ModelBasic;
- use traits\ModelTrait;
- use think\Db;
- use think\Url;
- use app\wap\model\special\Special;
- use service\SystemConfigService;
- use app\wap\model\user\WechatUser;
- use app\wap\model\user\User;
- use app\wap\model\routine\RoutineTemplate;
- use service\WechatTemplateService;
- use app\wap\model\wap\SmsTemplate;
- use app\wap\model\store\StoreOrder;
- use app\index\controller\PushJob;
- /**直播信息表
- * Class LiveStudio
- * @package app\wap\model\live
- */
- class LiveStudio extends ModelBasic
- {
- use ModelTrait;
- /**列表获取
- * @param $limit
- * @param $is_member
- * @return array
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\ModelNotFoundException
- * @throws \think\exception\DbException
- */
- public static function getLiveList($limit, $is_member)
- {
- $model = self::where(['l.is_del' => 0, 's.is_show' => 1, 's.status' => 1, 's.is_del' => 0])->alias('l')
- ->join('special s', 's.id = l.special_id');
- if (!$is_member) $model = $model->where(['s.is_mer_visible' => 0]);
- $list = $model->field(['s.title', 's.image', 's.browse_count', 's.status','s.fake_sales', 's.is_mer_visible', 'l.is_play', 's.id', 'l.playback_record_id', 'l.start_play_time'])
- ->limit($limit)->order('s.sort DESC,l.sort DESC,l.add_time DESC')->select();
- $list = count($list) > 0 ? $list->toArray() : [];
- foreach ($list as $key => &$item) {
- if ($item['playback_record_id'] && !$item['is_play']) {
- $item['status'] = 2;//没在直播 有回放
- } else if ($item['is_play']) {
- $item['status'] = 1;//正在直播
- } else if (!$item['playback_record_id'] && !$item['is_play'] && strtotime($item['start_play_time']) > time()) {
- $item['status'] = 3;//等待直播
- } else {
- $item['status'] = 4;//直播结束
- }
- if ($item['start_play_time']) {
- $item['start_play_time'] = date('m-d H:i', strtotime($item['start_play_time']));
- }
- $count = Special::learning_records($item['id']);
- $item['records'] = processingData(bcadd($count, $item['fake_sales'], 0));
- }
- return $list;
- }
- /**获取单个直播
- * @param $live_one_id
- * @return array|false|\PDOStatement|string|\think\Model
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\ModelNotFoundException
- * @throws \think\exception\DbException
- */
- public static function getLiveOne($live_one_id)
- {
- return self::where(['l.is_del' => 0, 's.is_show' => 1,'s.status' => 1, 's.is_del' => 0])->alias('l')
- ->join('special s', 's.id = l.special_id')
- ->field(['s.title', 's.image', 'l.is_play', 's.id'])
- ->where('l.is_play', 1)->where('s.id', $live_one_id)
- ->order('l.sort DESC,l.add_time DESC')->find();
- }
- public function getStartPlayTimeAttr($time)
- {
- return $time;//返回create_time原始数据,不进行时间戳转换。
- }
- /**直播提醒
- * @return bool
- * @throws \think\db\exception\DataNotFoundException
- * @throws \think\db\exception\ModelNotFoundException
- * @throws \think\exception\DbException
- */
- public static function userRemindList()
- {
- $data = self::where(['l.is_del' => 0, 'l.is_remind' => 1, 'l.is_reminded' => 0, 's.is_show' => 1,'s.status' => 1, 's.is_del' => 0])->alias('l')
- ->join('special s', 's.id = l.special_id')->field('l.*,s.pay_type,s.member_pay_type')->select();
- $data = count($data) > 0 ? $data->toArray() : [];
- if (count($data) <= 0) return true;
- foreach ($data as $key => $item) {
- $start_play_time = strtotime($item['start_play_time']);
- if (bcsub($start_play_time, time(), 0) > bcmul($item['remind_time'], 60, 0)) continue;
- self::where('id', $item['id'])->update(['is_reminded' => 1]);
- if (bcsub($start_play_time, time(), 0) > 0) {
- if ($item['pay_type'] == 1 && $item['member_pay_type'] == 1) {
- $orderList = StoreOrder::where(['cart_id' => $item['special_id'], 'type' => 0])->column("uid");
- } elseif ($item['pay_type'] == 1 && $item['member_pay_type'] == 0) {
- $order = StoreOrder::where(['cart_id' => $item['special_id'], 'type' => 0])->column("uid");
- $user = User::where('is_h5user', 0)->where('level', 1)->column("uid");
- $orderList = array_merge($order, $user);
- } else {
- $orderList = User::where('is_h5user', 0)->column("uid");
- }
- if(count($orderList)<0) continue;
- $orderList = array_unique($orderList);
- $dat['id'] = $item['special_id'];
- $dat['site_url'] = SystemConfigService::get('site_url');
- $dat['live_title'] = $item['live_title'];
- $dat['start_play_time'] = $item['start_play_time'];
- foreach ($orderList as $k => $v) {
- $dat['uid'] = $v;
- PushJob::actionWithDoPinkJob($dat, 'doLiveStudioJob');
- }
- }
- }
- }
- }
|