src/Biz/CloudData/Service/Impl/CloudDataServiceImpl.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Biz\CloudData\Service\Impl;

use Biz\BaseService;
use Biz\CloudData\Dao\CloudDataDao;
use Biz\CloudData\Service\CloudDataService;
use Biz\System\Service\LogService;
use Biz\CloudPlatform\CloudAPIFactory;

class CloudDataServiceImpl extends BaseService implements CloudDataService
{
    public function push($name, array $body = array(), $timestamp = 0, $level = 'normal')
    {
        try {
            return CloudAPIFactory::create('event')->push($name, $body, $timestamp);
        } catch (\Exception $e) {
            $this->getLogService()->error('cloud_data', 'push', "{$name} 事件发送失败", array('message' => $e->getMessage()));

            if ($level == 'important') {
                $user = $this->getCurrentUser();
                $fields = array(
                    'name' => $name,
                    'body' => $body,
                    'timestamp' => $timestamp,
                    'createdUserId' => $user['id'],
                );
                $this->getCloudDataDao()->create($fields);
            }

            return false;
        }
    }

    public function searchCloudDataCount($conditions)
    {
        return $this->getCloudDataDao()->count($conditions);
    }

    public function searchCloudDatas($conditions, $orderBy, $start, $limit)
    {
        return $this->getCloudDataDao()->search($conditions, $orderBy, $start, $limit);
    }

    public function deleteCloudData($id)
    {
        return $this->getCloudDataDao()->delete($id);
    }

    /**
     * @return CloudDataDao
     */
    protected function getCloudDataDao()
    {
        return $this->createDao('CloudData:CloudDataDao');
    }

    /**
     * @return LogService
     */