mirror of
https://github.com/crmeb/CRMEB.git
synced 2025-12-28 22:50:18 +00:00
288 lines
8.6 KiB
PHP
288 lines
8.6 KiB
PHP
<?php
|
||
/**
|
||
* @author: xaboy<365615158@qq.com>
|
||
* @day: 2017/11/28
|
||
*/
|
||
|
||
namespace app\admin\model\wechat;
|
||
|
||
use app\admin\model\user\User;
|
||
use think\facade\Cache;
|
||
use crmeb\traits\ModelTrait;
|
||
use crmeb\basic\BaseModel;
|
||
use app\admin\model\wechat\WechatUser as UserModel;
|
||
|
||
/**
|
||
* 微信用户行为记录 model
|
||
* Class WechatMessage
|
||
* @package app\admin\model\wechat
|
||
*/
|
||
class WechatMessage extends BaseModel
|
||
{
|
||
|
||
/**
|
||
* 数据表主键
|
||
* @var string
|
||
*/
|
||
protected $pk = 'id';
|
||
|
||
/**
|
||
* 模型名称
|
||
* @var string
|
||
*/
|
||
protected $name = 'wechat_message';
|
||
|
||
use ModelTrait;
|
||
|
||
protected $insert = ['add_time'];
|
||
|
||
/**
|
||
* 微信用户操作的基本所有操作
|
||
* @var array
|
||
*/
|
||
public static $mold = array(
|
||
'event_subscribe' => '关注微信号',
|
||
'event_unsubscribe' => '取消关注微信号',
|
||
'event_scan' => '扫码',
|
||
'event_templatesendjobfinish' => '进入小程序',
|
||
'event_location' => '获取位置',
|
||
'event_click' => '点击微信菜单关键字',
|
||
'event_view' => '点击微信菜单链接',
|
||
'event_view_miniprogram' => '点击微信菜单进入小程序',
|
||
'text' => '收到文本消息',
|
||
'image' => '收到图片消息',
|
||
'video' => '收到视频消息',
|
||
'voice' => '收到声音消息',
|
||
'location' => '收到位置消息',
|
||
'link' => '收到链接消息',
|
||
'event_scan_subscribe' => '扫码关注'
|
||
);
|
||
|
||
public static function setAddTimeAttr($value)
|
||
{
|
||
return time();
|
||
}
|
||
|
||
public static function setMessage($result, $openid, $type)
|
||
{
|
||
if (is_object($result) || is_array($result)) $result = json_encode($result);
|
||
$add_time = time();
|
||
$data = compact('result', 'openid', 'type', 'add_time');
|
||
return self::create($data);
|
||
}
|
||
|
||
public static function setOnceMessage($result, $openid, $type, $unique, $cacheTime = 172800)
|
||
{
|
||
$cacheName = 'wechat_message_' . $type . '_' . $unique;
|
||
if (Cache::has($cacheName)) return true;
|
||
$res = self::setMessage($result, $openid, $type);
|
||
if ($res) Cache::set($cacheName, 1, $cacheTime);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 按钮事件
|
||
* @param $Event
|
||
* @return mixed
|
||
*/
|
||
public static function tidyEvent($Event)
|
||
{
|
||
$res = array(
|
||
'msg' => $Event['EventKey'],
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 取消关注事件扫码
|
||
* @param $Event
|
||
* @return mixed
|
||
*/
|
||
public static function tidyNull()
|
||
{
|
||
$res = array(
|
||
'msg' => '无',
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 整理文本显示的数据
|
||
* @param $text 收到的文本消息
|
||
* return 返回收到的消息
|
||
*/
|
||
public static function tidyText($text)
|
||
{
|
||
$res = array(
|
||
'rep_id' => '1',
|
||
'MsgId' => $text['MsgId'],
|
||
'Content' => $text['Content'],
|
||
'msg' => $text['Content'],
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 整理图片显示的数据
|
||
* @param $image
|
||
* @return mixed
|
||
*/
|
||
public static function tidyImage($image)
|
||
{
|
||
$res = array(
|
||
'rep_id' => '2',
|
||
'MsgId' => $image['MsgId'],
|
||
'PicUrl' => $image['PicUrl'],
|
||
'MediaId' => $image['MediaId'],
|
||
'msg' => '媒体ID：' . $image['MediaId'],
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 整理视屏显示的数据
|
||
* @param $video
|
||
* @return mixed
|
||
*/
|
||
public static function tidyVideo($video)
|
||
{
|
||
$res = array(
|
||
'rep_id' => '3',
|
||
'MsgId' => $video['MsgId'],
|
||
'MediaId' => $video['MediaId'],
|
||
'msg' => '媒体ID：' . $video['MediaId'],
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 整理声音显示的数据
|
||
* @param $voice
|
||
* @return mixed
|
||
*/
|
||
public static function tidyVoice($voice)
|
||
{
|
||
$res = array(
|
||
'rep_id' => '4',
|
||
'MsgId' => $voice['MsgId'],
|
||
'MediaId' => $voice['MediaId'],
|
||
'msg' => '媒体ID：' . $voice['MediaId'],
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 地理位置
|
||
* @param $location
|
||
* @return array
|
||
*/
|
||
public static function tidyLocation($location)
|
||
{
|
||
$res = array(
|
||
'rep_id' => '5',
|
||
'MsgId' => $location['MsgId'],
|
||
'Label' => $location['Label'],
|
||
'msg' => $location['Label'],
|
||
);
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取用户扫码点击事件
|
||
* @param array $where
|
||
* @return array
|
||
*/
|
||
public static function systemPage($where = array())
|
||
{
|
||
$model = new self;
|
||
$model = $model->alias('m');
|
||
if ($where['nickname'] !== '') {
|
||
$user = UserModel::where('nickname', 'LIKE', "%$where[nickname]%")->field('openid')->select();
|
||
if (empty($user->toArray())) $model = $model->where('m.id', 0);
|
||
foreach ($user as $v) {
|
||
$model = $model->where('m.openid', $v['openid']);
|
||
}
|
||
}
|
||
if ($where['type'] !== '') $model = $model->where('m.type', $where['type']);
|
||
if ($where['data'] !== '') {
|
||
list($startTime, $endTime) = explode(' - ', $where['data']);
|
||
$model = $model->where('m.add_time', '>', strtotime($startTime));
|
||
$model = $model->where('m.add_time', '<', strtotime($endTime));
|
||
}
|
||
$model = $model->field('u.nickname,m.*')->join('WechatUser u', 'u.openid=m.openid')->order('m.id desc');
|
||
return self::page($model, function ($item) {
|
||
switch ($item['type']) {
|
||
case 'text':
|
||
$item['result_arr'] = self::tidyText(json_decode($item['result'], true));
|
||
break;
|
||
case 'image':
|
||
$item['result_arr'] = self::tidyImage(json_decode($item['result'], true));
|
||
break;
|
||
case 'video':
|
||
$item['result_arr'] = self::tidyVideo(json_decode($item['result'], true));
|
||
break;
|
||
case 'voice':
|
||
$item['result_arr'] = self::tidyVoice(json_decode($item['result'], true));
|
||
break;
|
||
case 'location':
|
||
$item['result_arr'] = self::tidyLocation(json_decode($item['result'], true));
|
||
break;
|
||
case 'event_click':
|
||
$item['result_arr'] = self::tidyEvent(json_decode($item['result'], true));
|
||
break;
|
||
case 'event_view':
|
||
$item['result_arr'] = self::tidyEvent(json_decode($item['result'], true));
|
||
break;
|
||
case 'event_subscribe':
|
||
$item['result_arr'] = self::tidyNull();
|
||
break;
|
||
case 'event_unsubscribe':
|
||
$item['result_arr'] = self::tidyNull();
|
||
break;
|
||
case 'event_scan':
|
||
$item['result_arr'] = self::tidyNull();
|
||
break;
|
||
default :
|
||
$item['result_arr'] = ['msg' => $item['type']];
|
||
break;
|
||
}
|
||
$item['type_name'] = isset(self::$mold[$item['type']]) ? self::$mold[$item['type']] : '未知';
|
||
}, $where);
|
||
}
|
||
|
||
/*
|
||
* 获取应为记录数据
|
||
*
|
||
*/
|
||
public static function getViweList($date, $class = [])
|
||
{
|
||
$model = new self();
|
||
switch ($date) {
|
||
case null:
|
||
case 'today':
|
||
case 'week':
|
||
case 'year':
|
||
if ($date == null) $date = 'month';
|
||
$model = $model->whereTime('add_time', $date);
|
||
break;
|
||
case 'quarter':
|
||
$time = User::getMonth('n');
|
||
$model = $model->where('add_time', 'between', $time);
|
||
break;
|
||
default:
|
||
list($startTime, $endTime) = explode('-', $date);
|
||
$model = $model->where('add_time', '>', strtotime($startTime));
|
||
$model = $model->where('add_time', '<', strtotime($endTime));
|
||
break;
|
||
}
|
||
$list = $model->field(['type', 'count(*) as num', 'result'])->group('type')->limit(0, 20)->select()->toArray();
|
||
$viwe = [];
|
||
foreach ($list as $key => $item) {
|
||
$now_list['name'] = isset(self::$mold[$item['type']]) ? self::$mold[$item['type']] : '未知';
|
||
$now_list['value'] = $item['num'];
|
||
$now_list['class'] = isset($class[$key]) ? $class[$key] : '';
|
||
$viwe[] = $now_list;
|
||
}
|
||
return $viwe;
|
||
}
|
||
} |