auti_boofly_mush_api/app/models/wechat/WechatReply.php

<?php
/**
 * @author: xaboy<365615158@qq.com>
 * @day: 2017/11/22
 */

namespace app\models\wechat;

use app\models\system\SystemConfig;
use crmeb\traits\ModelTrait;
use crmeb\basic\BaseModel;
use crmeb\services\UtilService;
use crmeb\services\WechatService;
use think\facade\Route as Url;

/**
 * 关键字 model
 * Class WechatReply
 * @package app\models\wechat
 */
class WechatReply extends BaseModel
{
    /**
     * 数据表主键
     * @var string
     */
    protected $pk = 'id';

    /**
     * 模型名称
     * @var string
     */
    protected $name = 'wechat_reply';

    use ModelTrait;

    public static $reply_type = ['text', 'image', 'news', 'voice'];

    public static function getDataByKey($key)
    {
        $resdata = ['data' => ''];
        $data = WechatKey::where('keys', $key)->find();
        $resdata = self::where('id', $data['reply_id'])->find();
        $resdata['data'] = json_decode($resdata['data'], true);
        $resdata['key'] = $key;
        return $resdata;
    }

    /**
     * 查询一条
     *
     * @param $key
     * @return array|null|\think\Model
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function getKeyInfo($id)
    {
        $resdata = ['data' => ''];
        $resdata = self::where('id', $id)->find();
        $keys = WechatKey::where('reply_id', $resdata['id'])->column('keys');
        $resdata['data'] = json_decode($resdata['data'], true);
        $resdata['key'] = implode(',',$keys);
        return $resdata;
    }

    public function getUrlAttr($value, $data)
    {
        return $value == '' ? Url::buildUrl('index/index/news', ['id' => $data['id']]) : $value;
    }

    /**
     * @param $data
     * @param $key
     * @param $type
     * @param int $status
     * @return bool
     */
    public static function redact($data, $id, $key, $type, $status = 1)
    {
        $method = 'tidy' . ucfirst($type);
        $res = self::$method($data, $id);
        if (!$res) return false;
        $count = self::where('id', $id)->count();
        if ($count) {
            $res = self::edit(['type' => $type, 'data' => json_encode($res), 'status' => $status], $id, 'id');
            if (!$res) return self::setErrorInfo('保存失败!');
        } else {
            $reply = self::create([
                'type' => $type,
                'data' => json_encode($res),
                'status' => $status,
            ]);
            $insertData = explode(',',$key);
            foreach ($insertData as $k=>$v){
                $arr[$k]['keys'] = $v;
                $arr[$k]['reply_id'] = $reply->id;
            }
            $obj = new WechatKey();
            $res = $obj->saveAll($arr);
            if (!$res) return self::setErrorInfo('保存失败!');
        }
        return true;
    }

    /**
     * @param $key
     * @param string $field
     * @param int $hide
     * @return bool
     */
    public static function changeHide($key, $field = 'id', $hide = 0)
    {
        return self::edit(compact('hide'), $key, $field);
    }


    /**
     * 整理文本输入的消息
     * @param $data
     * @param $key
     * @return array|bool
     */
    public static function tidyText($data, $id)
    {
        $res = [];
        if (!isset($data['content']) || $data['content'] == '')
            return self::setErrorInfo('请输入回复信息内容');
        $res['content'] = $data['content'];
        return $res;
    }

    /**
     * 整理图片资源
     * @param $data
     * @param $key
     * @return array|bool|mixed
     */
    public static function tidyImage($data, $id)
    {
        if (!isset($data['src']) || $data['src'] == '')
            return self::setErrorInfo('请上传回复的图片');
        $reply = self::get(['id' => $id]);
        if ($reply) $reply['data'] = json_decode($reply['data'], true);
        if ($reply && isset($reply['data']['src']) && $reply['data']['src'] == $data['src']) {
            $res = $reply['data'];
        } else {
            $res = [];
            //TODO 图片转media
            $res['src'] = $data['src'];
            $material = (WechatService::materialService()->uploadImage(UtilService::urlToPath($data['src'])));
            $res['media_id'] = $material->media_id;
            $dataEvent = ['media_id' => $material->media_id, 'path' => $res['src'], 'url' => $material->url];
            $type = 'image';
            event('WechatMaterialAfter', [$dataEvent, $type]);
        }
        return $res;
    }

    /**
     * 整理声音资源
     * @param $data
     * @param $key
     * @return array|bool|mixed
     */
    public static function tidyVoice($data, $id)
    {
        if (!isset($data['src']) || $data['src'] == '')
            return self::setErrorInfo('请上传回复的声音');
        $reply = self::get(['id' => $id]);
        if ($reply) $reply['data'] = json_decode($reply['data'], true);
        if ($reply && isset($reply['data']['src']) && $reply['data']['src'] == $data['src']) {
            $res = $reply['data'];
        } else {
            $res = [];
            //TODO 声音转media
            $res['src'] = $data['src'];
            $material = (WechatService::materialService()->uploadVoice(UtilService::urlToPath($data['src'])));
            $res['media_id'] = $material->media_id;
            $dataEvent = ['media_id' => $material->media_id, 'path' => $res['src']];
            $type = 'voice';
            event('WechatMaterialAfter', [$dataEvent, $type]);
        }
        return $res;
    }

    /**
     * 整理图文资源
     * @param $data
     * @param $key
     * @return bool
     */
    public static function tidyNews($data, $id = 0)
    {
//        $data = $data['list'];
        if (!count($data))
            return self::setErrorInfo('请选择图文消息');
        $siteUrl = SystemConfig::getConfigValue('site_url');
        foreach ($data as $k => $v) {
            if (empty($v['url'])) $data[$k]['url'] = $siteUrl . '/news_detail/' . $v['id'];
            if ($v['image']) $data[$k]['image'] = $v['image'];
        }
        return $data;
    }

    /**
     * 获取所有关键字
     * @param array $where
     * @return array
     */
    public static function getKeyAll($where = array())
    {
        $model = new self;
        $model = $model->alias('r')
            ->join('wechat_key k', 'r.id=k.reply_id')
            ->field('k.keys,r.*')
            ->group('r.id');
        if ($where['key'] !== '') $model = $model->where('k.keys', 'LIKE', "%$where[key]%");
        $model = $model->where('k.keys', '<>', 'subscribe');
        $model = $model->where('k.keys', '<>', 'default');
        if ($where['type'] != '') $model = $model->where('r.type', $where['type']);
        $count = $model->count();
        $list = $model->page((int)$where['page'], (int)$where['limit'])
            ->select()
            ->each(function ($item) {
                if ($item['data']) $item['data'] = json_decode($item['data'], true);
                switch ($item['type']){
                    case 'text':
                        $item['typeName'] = '文字消息';
                        break;
                    case  'image':
                        $item['typeName'] = '图片消息';
                        break;
                    case 'news':
                        $item['typeName'] = '图文消息';
                        break;
                    case 'voice':
                        $item['typeName'] = '声音消息';
                        break;
                }
                $keys = WechatKey::where('reply_id',$item['id'])->column('keys');
                $item['key'] = implode(',',$keys);
            });
        return compact('count', 'list');
    }

    /**
     * 获取关键字
     * @param $key
     * @param string $default
     * @return array|\EasyWeChat\Message\Image|\EasyWeChat\Message\News|\EasyWeChat\Message\Text|\EasyWeChat\Message\Voice
     */
    public static function reply($key, $default = '')
    {
        $res = self::where('id', function ($query) use($key){
            $query->name('wechat_key')->where('keys',$key)->field(['reply_id'])->select();
        })->where('status', '1')->find();
        if (empty($res)) $res = self::whereIn('id', function ($query){
            $query->name('wechat_key')->where('keys','default')->field(['reply_id'])->select();
        })->where('status', '1')->find();
        if (empty($res)) return WechatService::transfer();
        $res['data'] = json_decode($res['data'], true);
        if ($res['type'] == 'text') {
            return WechatService::textMessage($res['data']['content']);
        } else if ($res['type'] == 'image') {
            return WechatService::imageMessage($res['data']['media_id']);
        } else if ($res['type'] == 'news') {
            return WechatService::newsMessage($res['data']);
        } else if ($res['type'] == 'voice') {
            return WechatService::voiceMessage($res['data']['media_id']);
        }
    }


}