* @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']); } } }