fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

coze优化 + 微信好友微信群聊天同步

Browse Source
This commit is contained in:
Ghost
2025-04-09 09:11:20 +08:00
parent 919317630e
commit c7c499f006
18 changed files with 1663 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

169
Server/application/admin/controller/AdminController.php Normal file
View File

@@ -0,0 +1,169 @@
<?php
namespace app\admin\controller;
use think\facade\Request;
use think\facade\Session;
use app\admin\model\Administrator;
use app\common\util\JwtUtil;
/**
* 超级管理员控制器
*/
class AdminController extends BaseController
{
/**
* 令牌有效期（秒）
*/
const TOKEN_EXPIRE = 7200;
/**
* 管理员登录
* @return \think\response\Json
*/
public function login()
{
// 获取请求参数
$account = input('account', '');
$password = input('password', '');
// 参数验证
if (empty($account) || empty($password)) {
return json(['code' => 400, 'msg' => '账号和密码不能为空']);
}
try {
// 查询管理员
$admin = Administrator::where('account', $account)->find();
// 验证账号是否存在及密码是否正确
if (empty($admin) || md5($password) != $admin['password']) {
return errorJson('账号或密码错误',400);
}
// 验证账号状态
if ($admin['status'] != 1) {
return errorJson('账号已被禁用',400);
}
// 更新登录信息
$admin->lastLoginIp = Request::ip();
$admin->lastLoginTime = time();
$admin->save();
// 构建用户数据
$userData = [
'id' => $admin['id'],
'account' => $admin['account'],
'name' => $admin['name'],
'type' => 'admin' // 标记用户类型为管理员
];
// 生成JWT令牌
$token = JwtUtil::createToken($userData, self::TOKEN_EXPIRE);
$expireTime = time() + self::TOKEN_EXPIRE;
// 缓存用户信息，方便后续验证
Session::set('admin_auth', [
'id' => $admin['id'],
'account' => $admin['account'],
'name' => $admin['name'],
'token' => $token
]);
// 返回登录成功数据
return successJson([
'id' => $admin['id'],
'account' => $admin['account'],
'name' => $admin['name'],
'token' => $token,
'token_expired' => $expireTime,
'lastLoginTime' => date('Y-m-d H:i:s', $admin['lastLoginTime'])
]);
} catch (\Exception $e) {
return errorJson('登录失败：' . $e->getMessage(),500);
}
}
/**
* 刷新令牌
* @return \think\response\Json
*/
public function refreshToken()
{
// 获取Session中保存的管理员信息
$adminAuth = Session::get('admin_auth');
if (empty($adminAuth)) {
return errorJson('未登录或登录已过期',401);
}
try {
// 查询管理员信息
$admin = Administrator::where('id', $adminAuth['id'])->find();
if (empty($admin)) {
Session::delete('admin_auth');
return errorJson('管理员不存在',401);
}
// 构建用户数据
$userData = [
'id' => $admin['id'],
'account' => $admin['account'],
'name' => $admin['name'],
'type' => 'admin' // 标记用户类型为管理员
];
// 生成新令牌
$token = JwtUtil::createToken($userData, self::TOKEN_EXPIRE);
$expireTime = time() + self::TOKEN_EXPIRE;
// 更新Session中的令牌
$adminAuth['token'] = $token;
return successJson([
'token' => $token,
'token_expired' => $expireTime
]);
} catch (\Exception $e) {
return errorJson('刷新令牌失败：' . $e->getMessage(),500);
}
}
/**
* 退出登录
* @return \think\response\Json
*/
public function logout()
{
Session::delete('admin_auth');
return successJson('退出成功');
}
/**
* 获取当前登录管理员信息
* @return \think\response\Json
*/
public function getInfo()
{
// 获取Session中保存的管理员信息
$adminAuth = Session::get('admin_auth');
if (empty($adminAuth)) {
return errorJson('未登录或登录已过期',401);
}
// 查询管理员信息
$admin = Administrator::where('id', $adminAuth['id'])->find();
if (empty($admin)) {
Session::delete('admin_auth');
return errorJson('管理员不存在',401);
}
return successJson([
'id' => $admin['id'],
'account' => $admin['account'],
'name' => $admin['name'],
'lastLoginTime' => date('Y-m-d H:i:s', $admin['lastLoginTime']),
'lastLoginIp' => $admin['lastLoginIp']
]);
}
}

69
Server/application/admin/controller/BaseController.php Normal file
View File

@@ -0,0 +1,69 @@
<?php
namespace app\admin\controller;
use think\Controller;
use think\facade\Request;
use think\facade\Session;
use app\common\util\JwtUtil;
/**
* 后台基础控制器
*/
class BaseController extends Controller
{
// 管理员信息
protected $adminInfo = [];
/**
* 初始化
*/
protected function initialize()
{
parent::initialize();
// 不需要验证登录的方法
$noNeedLogin = ['login'];
// 获取当前操作方法
$action = request()->action();
// 验证登录
if (!in_array($action, $noNeedLogin)) {
$this->checkLogin();
}
}
/**
* 验证登录
*/
protected function checkLogin()
{
// 获取请求头中的Authorization
$token = Request::header('Authorization', '');
if (empty($token)) {
// 尝试从请求参数中获取token
$token = Request::param('token', '');
}
if (empty($token)) {
$this->error('未登录或登录已过期', null, ['code' => 401]);
}
try {
// 验证JWT令牌
$userInfo = JwtUtil::verifyToken($token);
// 验证用户类型
if (empty($userInfo) || $userInfo['type'] !== 'admin') {
$this->error('无效的登录凭证', null, ['code' => 401]);
}
$this->adminInfo = $userInfo;
} catch (\Exception $e) {
$this->error('登录已过期，请重新登录', null, ['code' => 401]);
}
}
}

122
Server/application/admin/model/Administrator.php Normal file
View File

@@ -0,0 +1,122 @@
<?php
namespace app\admin\model;
use think\Model;
/**
* 超级管理员模型
*/
class Administrator extends Model
{
// 设置表名
protected $name = 'tk_administrators';
// 设置主键
protected $pk = 'id';
// 自动写入时间戳
protected $autoWriteTimestamp = true;
protected $createTime = 'createTime';
protected $updateTime = 'updateTime';
/**
* 获取管理员列表
* @param array $where 查询条件
* @param int $page 页码
* @param int $limit 每页显示数量
* @return array
*/
public static function getList($where = [], $page = 1, $limit = 10)
{
$count = self::where($where)->count();
$list = self::where($where)
->page($page, $limit)
->order('id', 'desc')
->select();
$data = [];
foreach ($list as $item) {
$data[] = [
'id' => $item['id'],
'name' => $item['name'],
'account' => $item['account'],
'status' => $item['status'],
'lastLoginTime' => $item['lastLoginTime'] ? date('Y-m-d H:i:s', $item['lastLoginTime']) : '',
'lastLoginIp' => $item['lastLoginIp'],
'createTime' => date('Y-m-d H:i:s', $item['createTime']),
'updateTime' => date('Y-m-d H:i:s', $item['updateTime'])
];
}
return [
'count' => $count,
'list' => $data
];
}
/**
* 创建管理员
* @param array $data 管理员数据
* @return array
*/
public static function createAdmin($data)
{
// 检查账号是否已存在
$exists = self::where('account', $data['account'])->find();
if ($exists) {
return ['code' => 400, 'msg' => '账号已存在'];
}
// 创建管理员
$admin = new self;
$admin->name = $data['name'];
$admin->account = $data['account'];
$admin->password = md5($data['password']);
$admin->status = isset($data['status']) ? $data['status'] : 1;
$admin->save();
return ['code' => 200, 'msg' => '创建成功', 'data' => $admin];
}
/**
* 修改管理员信息
* @param int $id 管理员ID
* @param array $data 管理员数据
* @return array
*/
public static function updateAdmin($id, $data)
{
// 查询管理员
$admin = self::where('id', $id)->find();
if (!$admin) {
return ['code' => 400, 'msg' => '管理员不存在'];
}
// 如果修改账号，检查账号是否已存在
if (isset($data['account']) && $data['account'] != $admin['account']) {
$exists = self::where('account', $data['account'])->find();
if ($exists) {
return ['code' => 400, 'msg' => '账号已存在'];
}
$admin->account = $data['account'];
}
// 修改信息
if (isset($data['name'])) {
$admin->name = $data['name'];
}
if (isset($data['password']) && !empty($data['password'])) {
$admin->password = md5($data['password']);
}
if (isset($data['status'])) {
$admin->status = $data['status'];
}
$admin->save();
return ['code' => 200, 'msg' => '修改成功'];
}
}

6
Server/application/api/config/route.php
View File

@@ -73,5 +73,11 @@ Route::group('v1', function () {
Route::group('friend', function () {
Route::get('list', 'app\\api\\controller\\WechatFriendController@getList'); // 获取微信好友列表数据 √
});
// Message控制器路由
Route::group('message', function () {
Route::get('getFriendsList', 'app\\api\\controller\\MessageController@getFriendsList'); // 获取微信好友列表 √
Route::get('getChatroomList', 'app\\api\\controller\\MessageController@getChatroomList'); // 同步群聊消息 √
});
});
});

27
Server/application/api/controller/FriendTaskController.php
View File

@@ -11,12 +11,16 @@ class FriendTaskController extends BaseController
* 获取添加好友记录列表
* @return \think\response\Json
*/
public function getlist()
public function getlist($pageIndex,$pageSize,$authorization,$isJob = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', ''));
$authorization = !empty($authorization) ? $authorization : trim($this->request->header('authorization', ''));
if (empty($authorization)) {
return errorJson('缺少授权信息');
if($isJob){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
}
}
try {
@@ -24,8 +28,8 @@ class FriendTaskController extends BaseController
$params = [
'keyword' => $this->request->param('keyword', ''),
'status' => $this->request->param('status', ''),
'pageIndex' => $this->request->param('pageIndex', 0),
'pageSize' => $this->request->param('pageSize', 20)
'pageIndex' => !empty($pageIndex) ? $pageIndex : $this->request->param('pageIndex', 0),
'pageSize' => !empty($pageSize) ? $pageSize : $this->request->param('pageSize', 20),
];
// 设置请求头
@@ -43,10 +47,17 @@ class FriendTaskController extends BaseController
$this->saveFriendTask($item);
}
}
return successJson($response);
if($isJob){
return json_encode(['code'=>200,'msg'=>'获取添加好友记录列表成功','data'=>$response]);
}else{
return successJson($response);
}
} catch (\Exception $e) {
return errorJson('获取添加好友记录列表失败：' . $e->getMessage());
if($isJob){
return json_encode(['code'=>500,'msg'=>'获取添加好友记录列表失败：' . $e->getMessage()]);
}else{
return errorJson('获取添加好友记录列表失败：' . $e->getMessage());
}
}
}

479
Server/application/api/controller/MessageController.php Normal file
View File

@@ -0,0 +1,479 @@
<?php
namespace app\api\controller;
use app\api\model\WechatMessageModel;
use think\facade\Request;
class MessageController extends BaseController
{
/**
* 获取微信好友列表
* @return \think\response\Json
*/
public function getFriendsList($pageIndex = '',$pageSize = '',$authorization = '',$isJob = false)
{
// 获取授权token
$authorization = !empty($authorization) ? $authorization : trim($this->request->header('authorization', ''));
if (empty($authorization)) {
if($isJob){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
}
}
$fromTime = $this->request->param('fromTime', date('Y-m-d 00:00:00', strtotime('-1 days')));
$toTime = $this->request->param('toTime', date('Y-m-d 00:00:00'));
try {
// 构建请求参数
$params = [
'chatroomKeyword' => $this->request->param('chatroomKeyword', ''),
'friendKeyword' => $this->request->param('friendKeyword', ''),
'friendPhoneKeyword' => $this->request->param('friendPhoneKeyword', ''),
'friendPinYinKeyword' => $this->request->param('friendPinYinKeyword', ''),
'friendRegionKeyword' => $this->request->param('friendRegionKeyword', ''),
'friendRemarkKeyword' => $this->request->param('friendRemarkKeyword', ''),
'groupId' => $this->request->param('groupId', null),
'kefuId' => $this->request->param('kefuId', null),
'labels' => $this->request->param('labels', []),
'msgFrom' => $fromTime,
'msgKeyword' => $this->request->param('msgKeyword', ''),
'msgTo' => $toTime,
'msgType' => $this->request->param('msgType', ''),
'pageIndex' => !empty($pageIndex) ? $pageIndex : input('pageIndex', 0),
'pageSize' => !empty($pageSize) ? $pageSize : input('pageSize', 20),
'reverse' => $this->request->param('reverse', false),
'type' => $this->request->param('type', 'friend'),
'wechatAccountIds' => $this->request->param('wechatAccountIds', [])
];
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'json');
// 发送请求获取好友列表
$result = requestCurl($this->baseUrl . 'api/WechatFriend/listWechatFriendForMsgPagination', $params, 'POST', $header, 'json');
$response = handleApiResponse($result);
// 获取同步消息标志
$syncMessages = $this->request->param('syncMessages', true);
// 如果需要同步消息，则获取每个好友的消息
if ($syncMessages && !empty($response['results'])) {
$from = strtotime($fromTime) * 1000;
$to = strtotime($toTime) * 1000;
foreach ($response['results'] as &$friend) {
// 构建获取消息的参数
$messageParams = [
'keyword' => '',
'msgType' => '',
'accountId' => '',
'count' => 100,
'messageId' => '',
'olderData' => true,
'wechatAccountId' => $friend['wechatAccountId'],
'wechatFriendId' => $friend['wechatFriendId'],
'from' => $from,
'to' => $to,
'searchFrom' => 'admin'
];
// 调用获取消息的接口
$messageResult = requestCurl($this->baseUrl . 'api/FriendMessage/searchMessage', $messageParams, 'GET', $header, 'json');
$messageResponse = handleApiResponse($messageResult);
// 保存消息到数据库
if (!empty($messageResponse)) {
foreach ($messageResponse as $item) {
$this->saveMessage($item);
}
}
// 将消息列表添加到好友数据中
$friend['messages'] = $messageResponse ?? [];
}
unset($friend);
}
if($isJob){
return json_encode(['code'=>200,'msg'=>'获取好友列表成功','data'=>$response]);
}else{
return successJson($response);
}
} catch (\Exception $e) {
if($isJob){
return json_encode(['code'=>500,'msg'=>'获取好友列表失败：' . $e->getMessage()]);
}else{
return errorJson('获取好友列表失败：' . $e->getMessage());
}
}
}
/**
* 保存消息记录到数据库
* @param array $item 消息记录数据
*/
private function saveMessage($item)
{
// 检查消息是否已存在
$exists = WechatMessageModel::where('id', $item['id']) ->find();
// 如果消息已存在，直接返回
if ($exists) {
return;
}
// 将毫秒时间戳转换为秒级时间戳
$createTime = isset($item['createTime']) ? strtotime($item['createTime']) : null;
$deleteTime = !empty($item['isDeleted']) ? strtotime($item['deleteTime']) : null;
$wechatTime = isset($item['wechatTime']) ? floor($item['wechatTime'] / 1000) : null;
$data = [
'id' => $item['id'],
'type' => 1,
'accountId' => $item['accountId'],
'content' => $item['content'],
'createTime' => $createTime,
'deleteTime' => $deleteTime,
'isDeleted' => $item['isDeleted'] ?? false,
'isSend' => $item['isSend'] ?? true,
'msgId' => $item['msgId'],
'msgSubType' => $item['msgSubType'] ?? 0,
'msgSvrId' => $item['msgSvrId'] ?? '',
'msgType' => $item['msgType'],
'origin' => $item['origin'] ?? 0,
'recallId' => $item['recallId'] ?? false,
'sendStatus' => $item['sendStatus'] ?? 0,
'synergyAccountId' => $item['synergyAccountId'] ?? 0,
'tenantId' => $item['tenantId'],
'wechatAccountId' => $item['wechatAccountId'],
'wechatFriendId' => $item['wechatFriendId'],
'wechatTime' => $wechatTime
];
// 创建新记录
WechatMessageModel::create($data);
}
/**
* 获取微信群聊列表
* @return \think\response\Json
*/
public function getChatroomList($pageIndex = '',$pageSize = '',$authorization = '',$isJob = false)
{
// 获取授权token
$authorization = !empty($authorization) ? $authorization : trim($this->request->header('authorization', ''));
if (empty($authorization)) {
if($isJob){
return json_encode(['code'=>500,'msg'=>'缺少授权信息']);
}else{
return errorJson('缺少授权信息');
}
}
$fromTime = $this->request->param('fromTime', date('Y-m-d 00:00:00', strtotime('-1 days')));
$toTime = $this->request->param('toTime', date('Y-m-d 00:00:00'));
try {
// 构建请求参数
$params = [
'chatroomKeyword' => $this->request->param('chatroomKeyword', ''),
'friendKeyword' => $this->request->param('friendKeyword', ''),
'friendInKeyword' => $this->request->param('friendInKeyword', ''),
'friendInTimeKeyword' => $this->request->param('friendInTimeKeyword', ''),
'friendOutKeyword' => $this->request->param('friendOutKeyword', ''),
'friendRemarkKeyword' => $this->request->param('friendRemarkKeyword', ''),
'groupId' => $this->request->param('groupId', null),
'kefuId' => $this->request->param('kefuId', null),
'labels' => $this->request->param('labels', []),
'msgFrom' => $fromTime,
'msgKeyword' => $this->request->param('msgKeyword', ''),
'msgTo' => $toTime,
'msgType' => $this->request->param('msgType', ''),
'pageIndex' => $this->request->param('pageIndex', 0),
'pageSize' => $this->request->param('pageSize', 100),
'reverse' => $this->request->param('reverse', false),
'type' => $this->request->param('type', 'chatroom'),
'wechatAccountIds' => $this->request->param('wechatAccountIds', [])
];
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'json');
// 发送请求获取群聊列表
$result = requestCurl($this->baseUrl . 'api/WechatChatroom/listWechatChatroomForMsgPagination', $params, 'POST', $header, 'json');
$response = handleApiResponse($result);
// 获取同步消息标志
$syncMessages = $this->request->param('syncMessages', true);
// 如果需要同步消息，则获取每个群的消息
if ($syncMessages && !empty($response)) {
$from = strtotime($fromTime) * 1000;
$to = strtotime($toTime) * 1000;
foreach ($response['results'] as &$chatroom) {
// 构建获取消息的参数
$messageParams = [
'keyword' => '',
'msgType' =>'',
'accountId' => '',
'count' => 100,
'messageId' => '',
'olderData' => true,
'wechatId' => '',
'wechatAccountId' => $chatroom['wechatAccountId'],
'wechatChatroomId' => $chatroom['wechatChatroomId'],
'from' => $from,
'to' => $to,
'searchFrom' => 'admin'
];
// 调用获取消息的接口
$messageResult = requestCurl($this->baseUrl . 'api/ChatroomMessage/searchMessage', $messageParams, 'GET', $header, 'json');
$messageResponse = handleApiResponse($messageResult);
// 保存消息到数据库
if (!empty($messageResponse)) {
foreach ($messageResponse as $item) {
$this->saveChatroomMessage($item);
}
}
// 将消息列表添加到群聊数据中
$chatroom['messages'] = $messageResponse ?? [];
}
unset($chatroom);
}
if($isJob){
return json_encode(['code'=>200,'msg'=>'获取群聊列表成功','data'=>$response]);
}else{
return successJson($response);
}
} catch (\Exception $e) {
if($isJob){
return json_encode(['code'=>500,'msg'=>'获取群聊列表失败：' . $e->getMessage()]);
}else{
return errorJson('获取群聊列表失败：' . $e->getMessage());
}
}
}
/**
* 保存群聊消息记录到数据库
* @param array $item 消息记录数据
*/
private function saveChatroomMessage($item)
{
// 检查消息是否已存在
$exists = WechatMessageModel::where('id', $item['id']) ->find();
// 如果消息已存在，直接返回
if ($exists) {
return;
}
// 处理发送者信息
$sender = $item['sender'] ?? [];
// 处理消息内容，提取真正的消息内容
$originalContent = $item['content'] ?? '';
$processedContent = $this->processMessageContent($originalContent);
// 将毫秒时间戳转换为秒级时间戳
$createTime = isset($item['createTime']) ? strtotime($item['createTime']) : null;
$deleteTime = !empty($item['isDeleted']) ? strtotime($item['deleteTime']) : null;
$wechatTime = isset($item['wechatTime']) ? floor($item['wechatTime'] / 1000) : null;
$data = [
'id' => $item['id'],
'type' => 2,
'wechatChatroomId' => $item['wechatChatroomId'],
// sender信息，添加sender前缀
'senderNickname' => $sender['nickname'] ?? '',
'senderWechatId' => $sender['wechatId'] ?? '',
'senderIsAdmin' => $sender['isAdmin'] ?? false,
'senderIsDeleted' => $sender['isDeleted'] ?? false,
'senderChatroomNickname' => $sender['chatroomNickname'] ?? '',
'senderWechatAccountId' => $sender['wechatAccountId'] ?? '',
// 其他字段
'wechatAccountId' => $item['wechatAccountId'],
'tenantId' => $item['tenantId'],
'accountId' => $item['accountId'],
'synergyAccountId' => $item['synergyAccountId'] ?? 0,
'content' => $processedContent, // 使用处理后的内容
'originalContent' => $originalContent, // 保存原始内容
'msgType' => $item['msgType'],
'msgSubType' => $item['msgSubType'] ?? 0,
'msgSvrId' => $item['msgSvrId'] ?? '',
'isSend' => $item['isSend'] ?? true,
'createTime' => $createTime,
'isDeleted' => $item['isDeleted'] ?? false,
'deleteTime' => $deleteTime,
'sendStatus' => $item['sendStatus'] ?? 0,
'wechatTime' => $wechatTime,
'origin' => $item['origin'] ?? 0,
'msgId' => $item['msgId'],
'recallId' => $item['recallId'] ?? false
];
// 创建新记录
WechatMessageModel::create($data);
}
/**
* 处理消息内容，提取真正的消息内容
* @param string $content 原始内容
* @return string 处理后的内容
*/
private function processMessageContent($content)
{
if (empty($content)) {
return '';
}
// 处理普通消息格式：wxid_vr2qafb1vg0d22:\n安德玛儿童
if (preg_match('/^[^:]+:\n(.+)$/s', $content, $matches)) {
return trim($matches[1]);
}
// 如果没有匹配到格式，则返回原始内容
return $content;
}
/**
* 用户聊天记录
* @return \think\response\Json
*/
public function getMessageList()
{
// 获取授权token
$authorization = trim($this->request->header('authorization', ''));
if (empty($authorization)) {
return errorJson('缺少授权信息');
}
try {
// 构建请求参数
$params = [
'keyword' => $this->request->param('keyword', ''),
'msgType' => $this->request->param('msgType', ''),
'accountId' => $this->request->param('accountId', ''),
'count' => $this->request->param('count', 100),
'messageId' => $this->request->param('messageId', ''),
'olderData' => $this->request->param('olderData', true),
'wechatAccountId' => $this->request->param('wechatAccountId', ''),
'wechatFriendId' => $this->request->param('wechatFriendId', ''),
'from' => $this->request->param('from', ''),
'to' => $this->request->param('to', ''),
'searchFrom' => $this->request->param('searchFrom', 'admin')
];
// 参数验证
if (empty($params['wechatAccountId'])) {
return errorJson('微信账号ID不能为空');
}
if (empty($params['wechatFriendId'])) {
return errorJson('好友ID不能为空');
}
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'json');
// 发送请求获取聊天记录
$result = requestCurl($this->baseUrl . 'api/FriendMessage/searchMessage', $params, 'GET', $header, 'json');
$response = handleApiResponse($result);
// 保存数据到数据库
if (!empty($response)) {
foreach ($response as $item) {
$this->saveMessage($item);
}
}
return successJson($response);
} catch (\Exception $e) {
return errorJson('获取聊天记录失败：' . $e->getMessage());
}
}
/**
* 获取群聊消息列表
* @return \think\response\Json
*/
public function getChatroomMessages()
{
// 获取授权token
$authorization = trim($this->request->header('authorization', ''));
if (empty($authorization)) {
return errorJson('缺少授权信息');
}
try {
// 构建请求参数
$params = [
'keyword' => $this->request->param('keyword', ''),
'msgType' => $this->request->param('msgType', ''),
'accountId' => $this->request->param('accountId', ''),
'count' => $this->request->param('count', 100),
'messageId' => $this->request->param('messageId', ''),
'olderData' => $this->request->param('olderData', true),
'wechatId' => $this->request->param('wechatId', ''),
'wechatAccountId' => $this->request->param('wechatAccountId', ''),
'wechatChatroomId' => $this->request->param('wechatChatroomId', ''),
'from' => $this->request->param('from', strtotime(date('Y-m-d 00:00:00', strtotime('-1 days')))),
'to' => $this->request->param('to', strtotime(date('Y-m-d 00:00:00'))),
'searchFrom' => $this->request->param('searchFrom', 'admin')
];
// 参数验证
if (empty($params['wechatAccountId'])) {
return errorJson('微信账号ID不能为空');
}
if (empty($params['wechatChatroomId'])) {
return errorJson('群聊ID不能为空');
}
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'json');
// 发送请求获取群聊消息
$result = requestCurl($this->baseUrl . 'api/ChatroomMessage/searchMessage', $params, 'GET', $header, 'json');
$response = handleApiResponse($result);
// 保存数据到数据库
if (!empty($response)) {
foreach ($response as $item) {
$res = $this->saveChatroomMessage($item);
if(!$res){
return errorJson('保存群聊消息失败');
}
}
}
return successJson($response);
} catch (\Exception $e) {
return errorJson('获取群聊消息失败：' . $e->getMessage());
}
}
}

11
Server/application/api/model/WechatMessageModel.php Normal file
View File

@@ -0,0 +1,11 @@
<?php
namespace app\api\model;
use think\Model;
class WechatMessageModel extends Model
{
// 设置表名
protected $name = 'wechat_message';
}

2
Server/application/command.php
View File

@@ -16,4 +16,6 @@ return [
'friendTask:list' => 'app\command\FriendTaskCommand', // 添加好友任务列表
'wechatList:list' => 'app\command\WechatListCommand', // 微信客服列表
'account:list' => 'app\command\AccountListCommand', // 公司账号列表
'message:friendsList' => 'app\command\MessageFriendsListCommand', // 微信好友列表
'message:chatroomList' => 'app\command\MessageChatroomListCommand', // 微信群聊列表
];

57
Server/application/command/MessageChatroomListCommand.php Normal file
View File

@@ -0,0 +1,57 @@
<?php
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\facade\Log;
use think\Queue;
use app\job\MessageChatroomListJob;
class MessageChatroomListCommand extends Command
{
protected function configure()
{
$this->setName('message:chatroomList')
->setDescription('获取微信群聊消息列表，并根据分页自动处理下一页');
}
protected function execute(Input $input, Output $output)
{
$output->writeln('开始处理微信群聊消息列表...');
try {
// 初始页码
$pageIndex = 0;
$pageSize = 100; // 每页获取100条记录
// 将第一页任务添加到队列
$this->addToQueue($pageIndex, $pageSize);
$output->writeln('微信群聊消息列表任务已添加到队列');
} catch (\Exception $e) {
Log::error('微信群聊消息列表任务添加失败：' . $e->getMessage());
$output->writeln('微信群聊消息列表任务添加失败：' . $e->getMessage());
return false;
}
return true;
}
/**
* 添加任务到队列
* @param int $pageIndex 页码
* @param int $pageSize 每页大小
*/
protected function addToQueue($pageIndex, $pageSize)
{
$data = [
'pageIndex' => $pageIndex,
'pageSize' => $pageSize
];
// 添加到队列，设置任务名为 friend_task
Queue::push(MessageChatroomListJob::class, $data, 'message_chatroom_list');
}
}

57
Server/application/command/MessageFriendsListCommand.php Normal file
View File

@@ -0,0 +1,57 @@
<?php
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\facade\Log;
use think\Queue;
use app\job\MessageFriendsListJob;
class MessageFriendsListCommand extends Command
{
protected function configure()
{
$this->setName('message:friendsList')
->setDescription('获取好友消息列表，并根据分页自动处理下一页');
}
protected function execute(Input $input, Output $output)
{
$output->writeln('开始处理好友消息列表...');
try {
// 初始页码
$pageIndex = 0;
$pageSize = 100; // 每页获取100条记录
// 将第一页任务添加到队列
$this->addToQueue($pageIndex, $pageSize);
$output->writeln('好友消息列表任务已添加到队列');
} catch (\Exception $e) {
Log::error('好友消息列表任务添加失败：' . $e->getMessage());
$output->writeln('好友消息列表任务添加失败：' . $e->getMessage());
return false;
}
return true;
}
/**
* 添加任务到队列
* @param int $pageIndex 页码
* @param int $pageSize 每页大小
*/
protected function addToQueue($pageIndex, $pageSize)
{
$data = [
'pageIndex' => $pageIndex,
'pageSize' => $pageSize
];
// 添加到队列，设置任务名为 friend_task
Queue::push(MessageFriendsListJob::class, $data, 'message_friends_list');
}
}

2
Server/application/job/FriendTaskJob.php
View File

@@ -81,7 +81,7 @@ class FriendTaskJob
}
// 调用添加好友任务获取方法
$result = $friendTaskController->getlist($pageIndex,$pageSize,$authorization);
$result = $friendTaskController->getlist($pageIndex,$pageSize,$authorization,true);
$response = json_decode($result,true);

123
Server/application/job/MessageChatroomListJob.php Normal file
View File

@@ -0,0 +1,123 @@
<?php
namespace app\job;
use think\queue\Job;
use think\facade\Log;
use think\Queue;
use think\facade\Config;
use app\api\controller\MessageController;
use app\common\service\AuthService;
class MessageChatroomListJob
{
/**
* 队列任务处理
* @param Job $job 队列任务
* @param array $data 任务数据
* @return void
*/
public function fire(Job $job, $data)
{
try {
// 如果任务执行成功后删除任务
if ($this->processMessageChatroomList($data, $job->attempts())) {
$job->delete();
Log::info('微信群聊消息列表任务执行成功，页码：' . $data['pageIndex']);
} else {
if ($job->attempts() > 3) {
// 超过重试次数，删除任务
Log::error('微信群聊消息列表任务执行失败，已超过重试次数，页码：' . $data['pageIndex']);
$job->delete();
} else {
// 任务失败，重新放回队列
Log::warning('微信群聊消息列表任务执行失败，重试次数：' . $job->attempts() . '，页码：' . $data['pageIndex']);
$job->release(Config::get('queue.failed_delay', 10));
}
}
} catch (\Exception $e) {
// 出现异常，记录日志
Log::error('微信群聊消息列表任务异常：' . $e->getMessage());
if ($job->attempts() > 3) {
$job->delete();
} else {
$job->release(Config::get('queue.failed_delay', 10));
}
}
}
/**
* 处理微信群聊消息列表获取
* @param array $data 任务数据
* @param int $attempts 重试次数
* @return bool
*/
protected function processMessageChatroomList($data, $attempts)
{
// 获取参数
$pageIndex = isset($data['pageIndex']) ? $data['pageIndex'] : 0;
$pageSize = isset($data['pageSize']) ? $data['pageSize'] : 100;
Log::info('开始获取微信群聊消息列表，页码：' . $pageIndex . '，页大小：' . $pageSize);
// 实例化控制器
$messageController = new MessageController();
// 构建请求参数
$params = [
'pageIndex' => $pageIndex,
'pageSize' => $pageSize
];
// 设置请求信息
$request = request();
$request->withGet($params);
// 获取系统授权信息
$authorization = AuthService::getSystemAuthorization();
if (empty($authorization)) {
Log::error('获取系统授权信息失败');
return false;
}
// 调用添加好友任务获取方法
$result = $messageController->getChatroomList($pageIndex,$pageSize,$authorization,true);
$response = json_decode($result,true);
// 判断是否成功
if ($response['code'] == 200) {
$data = $response['data'];
// 判断是否有下一页
if (!empty($data) && count($data['results']) > 0) {
// 有下一页，将下一页任务添加到队列
$nextPageIndex = $pageIndex + 1;
$this->addNextPageToQueue($nextPageIndex, $pageSize);
Log::info('添加下一页任务到队列，页码：' . $nextPageIndex);
}
return true;
} else {
$errorMsg = isset($response['msg']) ? $response['msg'] : '未知错误';
Log::error('获取微信群聊消息列表失败：' . $errorMsg);
return false;
}
}
/**
* 添加下一页任务到队列
* @param int $pageIndex 页码
* @param int $pageSize 每页大小
*/
protected function addNextPageToQueue($pageIndex, $pageSize)
{
$data = [
'pageIndex' => $pageIndex,
'pageSize' => $pageSize
];
// 添加到队列，设置任务名为 message_chatroom_list
Queue::push(self::class, $data, 'message_chatroom_list');
}
}

124
Server/application/job/MessageFriendsListJob.php Normal file
View File

@@ -0,0 +1,124 @@
<?php
namespace app\job;
use think\queue\Job;
use think\facade\Log;
use think\Queue;
use think\facade\Config;
use app\api\controller\MessageController;
use app\common\service\AuthService;
class MessageFriendsListJob
{
/**
* 队列任务处理
* @param Job $job 队列任务
* @param array $data 任务数据
* @return void
*/
public function fire(Job $job, $data)
{
try {
// 如果任务执行成功后删除任务
if ($this->processMessageFriendsList($data, $job->attempts())) {
$job->delete();
Log::info('好友消息列表任务执行成功，页码：' . $data['pageIndex']);
} else {
if ($job->attempts() > 3) {
// 超过重试次数，删除任务
Log::error('好友消息列表任务执行失败，已超过重试次数，页码：' . $data['pageIndex']);
$job->delete();
} else {
// 任务失败，重新放回队列
Log::warning('好友消息列表任务执行失败，重试次数：' . $job->attempts() . '，页码：' . $data['pageIndex']);
$job->release(Config::get('queue.failed_delay', 10));
}
}
} catch (\Exception $e) {
// 出现异常，记录日志
Log::error('好友消息列表任务异常：' . $e->getMessage());
if ($job->attempts() > 3) {
$job->delete();
} else {
$job->release(Config::get('queue.failed_delay', 10));
}
}
}
/**
* 处理好友消息列表获取
* @param array $data 任务数据
* @param int $attempts 重试次数
* @return bool
*/
protected function processMessageFriendsList($data, $attempts)
{
// 获取参数
$pageIndex = isset($data['pageIndex']) ? $data['pageIndex'] : 0;
$pageSize = isset($data['pageSize']) ? $data['pageSize'] : 100;
Log::info('开始获取好友消息列表，页码：' . $pageIndex . '，页大小：' . $pageSize);
// 实例化控制器
$messageController = new MessageController();
// 构建请求参数
$params = [
'pageIndex' => $pageIndex,
'pageSize' => $pageSize
];
// 设置请求信息
$request = request();
$request->withGet($params);
// 获取系统授权信息
$authorization = AuthService::getSystemAuthorization();
if (empty($authorization)) {
Log::error('获取系统授权信息失败');
return false;
}
// 调用添加好友任务获取方法
$result = $messageController->getFriendsList($pageIndex,$pageSize,$authorization,true);
$response = json_decode($result,true);
// 判断是否成功
if ($response['code'] == 200) {
$data = $response['data'];
// 判断是否有下一页
if (!empty($data) && count($data['results']) > 0) {
// 有下一页，将下一页任务添加到队列
$nextPageIndex = $pageIndex + 1;
$this->addNextPageToQueue($nextPageIndex, $pageSize);
Log::info('添加下一页任务到队列，页码：' . $nextPageIndex);
}
return true;
} else {
$errorMsg = isset($response['msg']) ? $response['msg'] : '未知错误';
Log::error('获取好友消息列表失败：' . $errorMsg);
return false;
}
}
/**
* 添加下一页任务到队列
* @param int $pageIndex 页码
* @param int $pageSize 每页大小
*/
protected function addNextPageToQueue($pageIndex, $pageSize)
{
$data = [
'pageIndex' => $pageIndex,
'pageSize' => $pageSize
];
// 添加到队列，设置任务名为 message_friends_list
Queue::push(self::class, $data, 'message_friends_list');
}
}

8
Server/application/store/config/route.php
View File

@@ -30,4 +30,12 @@ Route::group('v1/store', function () {
Route::get('switch-status', 'app\\store\\controller\\SystemConfigController@getSwitchStatus'); // 获取系统开关状态
Route::post('update-switch-status', 'app\\store\\controller\\SystemConfigController@updateSwitchStatus'); // 更新系统开关状态
});
// 数据统计相关路由
Route::group('statistics', function () {
Route::get('overview', 'app\\store\\controller\\StatisticsController@getOverview'); // 获取数据概览
Route::get('customer-analysis', 'app\\store\\controller\\StatisticsController@getCustomerAnalysis'); // 获取客户分析数据
Route::get('interaction-analysis', 'app\\store\\controller\\StatisticsController@getInteractionAnalysis'); // 获取互动分析数据
});
})->middleware(['jwt']);

5
Server/application/store/controller/BaseController.php
View File

@@ -38,19 +38,18 @@ class BaseController extends Api
$device = Db::name('device_user')
->alias('du')
->join('device d', 'd.id = du.deviceId','left')
->join('wechat_account wa', 'd.id = wa.currentDeviceId','left')
->where([
'du.userId' => $this->userInfo['id'],
'du.companyId' => $this->userInfo['companyId']
])
->field('d.*')
->field('d.*,wa.id as wechatAccountId,wa.wechatId,wa.alias')
->find();
// 将设备信息存入缓存
if ($device) {
Cache::set($cacheKey, $device, $this->cacheExpire);
}
}
$this->device = $device;
}

392
Server/application/store/controller/StatisticsController.php Normal file
View File

@@ -0,0 +1,392 @@
<?php
namespace app\store\controller;
use app\store\model\WechatFriendModel;
use app\store\model\WechatMessageModel;
use think\facade\Db;
/**
* 数据统计控制器
*/
class StatisticsController extends BaseController
{
/**
* 获取数据概览
*/
public function getOverview()
{
try {
$companyId = $this->userInfo['companyId'];
$wechatAccountId = $this->device['wechatAccountId'];
// 获取时间范围
$timeRange = $this->getTimeRange();
$startTime = $timeRange['start_time'];
$endTime = $timeRange['end_time'];
$lastStartTime = $timeRange['last_start_time'];
$lastEndTime = $timeRange['last_end_time'];
// 1. 总客户数
$totalCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereTime('createTime', '>=', $startTime)
->whereTime('createTime', '<', $endTime)
->count();
// 上期总客户数
$lastTotalCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereTime('createTime', '>=', $lastStartTime)
->whereTime('createTime', '<', $lastEndTime)
->count();
// 2. 新增客户数
$newCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereTime('createTime', '>=', $startTime)
->whereTime('createTime', '<', $endTime)
->count();
// 上期新增客户数
$lastNewCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereTime('createTime', '>=', $lastStartTime)
->whereTime('createTime', '<', $lastEndTime)
->count();
//3. 互动次数
$interactionCount = WechatMessageModel::where(['wechatAccountId'=> $wechatAccountId])
->where('createTime', '>=', strtotime($startTime))
->where('createTime', '<', strtotime($endTime))
->count();
// 上期互动次数
$lastInteractionCount = WechatMessageModel::where(['wechatAccountId'=> $wechatAccountId])
->where('createTime', '>=', strtotime($lastStartTime))
->where('createTime', '<', strtotime($lastEndTime))
->count();
// 计算环比增长率
$customerGrowth = $this->calculateGrowth($totalCustomers, $lastTotalCustomers);
$newCustomerGrowth = $this->calculateGrowth($newCustomers, $lastNewCustomers);
$interactionGrowth = $this->calculateGrowth($interactionCount, $lastInteractionCount);
$data = [
'total_customers' => [
'value' => $totalCustomers,
'growth' => $customerGrowth
],
'new_customers' => [
'value' => $newCustomers,
'growth' => $newCustomerGrowth
],
'interaction_count' => [
'value' => $interactionCount,
'growth' => $interactionGrowth
]
];
return successJson($data);
} catch (\Exception $e) {
return errorJson('获取数据概览失败：' . $e->getMessage());
}
}
/**
* 获取客户分析数据
*/
public function getCustomerAnalysis()
{
try {
$companyId = $this->userInfo['companyId'];
$wechatAccountId = $this->device['wechatAccountId'];
// 获取时间范围
$timeRange = $this->getTimeRange();
$startTime = $timeRange['start_time'];
$endTime = $timeRange['end_time'];
// 1. 客户增长趋势数据
$totalCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereTime('createTime', '<', $endTime)
->count();
$newCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereTime('createTime', '>=', $startTime)
->whereTime('createTime', '<', $endTime)
->count();
// 计算流失客户数（假设超过30天未互动的客户为流失客户）
$lostCustomers = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId,'isDeleted'=> 1])
->whereTime('deleteTime', '<', date('Y-m-d', strtotime('-30 days')))
->count();
// 2. 客户来源分布数据
// 朋友推荐
$friendRecommend = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereIn('addFrom', [17, 1000017])
->count();
// 微信搜索
$wechatSearch = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereIn('addFrom', [3, 15, 1000003, 1000015])
->count();
// 微信群
$wechatGroup = WechatFriendModel::where(['wechatAccountId'=> $wechatAccountId])
->whereIn('addFrom', [14, 1000014])
->count();
// 其他渠道（总数减去已知渠道）
$otherSource = $totalCustomers - $friendRecommend - $wechatSearch - $wechatGroup;
$otherSource = max(0, $otherSource); // 确保不会出现负数
// 计算百分比
$calculatePercentage = function($value) use ($totalCustomers) {
if ($totalCustomers <= 0) return 0;
return round(($value / $totalCustomers) * 100, 2);
};
$sourceDistribution = [
[
'name' => '朋友推荐',
'value' => $calculatePercentage($friendRecommend) . '%',
'count' => $friendRecommend
],
[
'name' => '微信搜索',
'value' => $calculatePercentage($wechatSearch) . '%',
'count' => $wechatSearch
],
[
'name' => '微信群',
'value' => $calculatePercentage($wechatGroup) . '%',
'count' => $wechatGroup
],
[
'name' => '其他渠道',
'value' => $calculatePercentage($otherSource) . '%',
'count' => $otherSource
]
];
$data = [
'trend' => [
'total' => $totalCustomers,
'new' => $newCustomers,
'lost' => $lostCustomers
],
'source_distribution' => $sourceDistribution
];
return successJson($data);
} catch (\Exception $e) {
return errorJson('获取客户分析数据失败：' . $e->getMessage());
}
}
/**
* 获取互动分析数据
*/
public function getInteractionAnalysis()
{
try {
$companyId = $this->userInfo['companyId'];
$wechatAccountId = $this->device['wechatAccountId'];
// 获取时间范围
$timeRange = $this->getTimeRange();
$startTime = $timeRange['start_time'];
$endTime = $timeRange['end_time'];
// 转换为时间戳
$startTimestamp = strtotime($startTime);
$endTimestamp = strtotime($endTime);
// 1. 互动频率分析
// 高频互动用户数（每天3次以上）
$highFrequencyUsers = WechatMessageModel::where(['wechatAccountId' => $wechatAccountId])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->field('wechatFriendId, COUNT(*) as count')
->group('wechatFriendId')
->having('count > 3')
->count();
// 中频互动用户数（每天1-3次）
$midFrequencyUsers = WechatMessageModel::where(['wechatAccountId' => $wechatAccountId])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->field('wechatFriendId, COUNT(*) as count')
->group('wechatFriendId')
->having('count >= 1 AND count <= 3')
->count();
// 低频互动用户数（仅有1次）
$lowFrequencyUsers = WechatMessageModel::where(['wechatAccountId' => $wechatAccountId])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->field('wechatFriendId, COUNT(*) as count')
->group('wechatFriendId')
->having('count = 1')
->count();
// 2. 互动内容分析
// 文字消息数量
$textMessages = WechatMessageModel::where([
'wechatAccountId' => $wechatAccountId,
'msgType' => 1
])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->count();
// 图片互动数量
$imgInteractions = WechatMessageModel::where([
'wechatAccountId' => $wechatAccountId,
'msgType' => 3
])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->count();
// 群聊互动数量
$groupInteractions = WechatMessageModel::where([
'wechatAccountId' => $wechatAccountId,
'type' => 2
])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->count();
// 产品咨询数量 (通过消息内容模糊查询)
$productInquiries = WechatMessageModel::where([
'wechatAccountId' => $wechatAccountId
])
->where('createTime', '>=', $startTimestamp)
->where('createTime', '<', $endTimestamp)
->where('content', 'like', '%产品%')
->whereOr('content', 'like', '%价格%')
->whereOr('content', 'like', '%购买%')
->whereOr('content', 'like', '%优惠%')
->count();
// 构建返回数据
$data = [
'frequency_analysis' => [
'high_frequency' => $highFrequencyUsers,
'mid_frequency' => $midFrequencyUsers,
'low_frequency' => $lowFrequencyUsers,
'chart_data' => [
['name' => '高频互动', 'value' => $highFrequencyUsers],
['name' => '中频互动', 'value' => $midFrequencyUsers],
['name' => '低频互动', 'value' => $lowFrequencyUsers]
]
],
'content_analysis' => [
'text_messages' => $textMessages,
'img_interactions' => $imgInteractions,
'group_interactions' => $groupInteractions,
'product_inquiries' => $productInquiries,
'chart_data' => [
['name' => '文字互动', 'value' => $textMessages],
['name' => '图片互动', 'value' => $imgInteractions],
['name' => '群聊互动', 'value' => $groupInteractions],
['name' => '产品咨询', 'value' => $productInquiries]
]
]
];
return successJson($data);
} catch (\Exception $e) {
return errorJson('获取互动分析数据失败：' . $e->getMessage());
}
}
/**
* 获取时间范围
*/
private function getTimeRange()
{
// 可选：today, yesterday, this_week, last_week, this_month, this_quarter, this_year
$timeType = input('time_type', 'this_week');
switch ($timeType) {
case 'today': // 今日
$startTime = date('Y-m-d');
$endTime = date('Y-m-d', strtotime('+1 day'));
$lastStartTime = date('Y-m-d', strtotime('-1 day')); // 昨日
$lastEndTime = $startTime;
break;
case 'yesterday': // 昨日
$startTime = date('Y-m-d', strtotime('-1 day'));
$endTime = date('Y-m-d');
$lastStartTime = date('Y-m-d', strtotime('-2 day')); // 前日
$lastEndTime = $startTime;
break;
case 'this_week': // 本周
$startTime = date('Y-m-d', strtotime('monday this week'));
$endTime = date('Y-m-d', strtotime('monday next week'));
$lastStartTime = date('Y-m-d', strtotime('monday last week')); // 上周一
$lastEndTime = $startTime;
break;
case 'last_week': // 上周
$startTime = date('Y-m-d', strtotime('monday last week'));
$endTime = date('Y-m-d', strtotime('monday this week'));
$lastStartTime = date('Y-m-d', strtotime('monday last week', strtotime('last week'))); // 上上周一
$lastEndTime = $startTime;
break;
case 'this_month': // 本月
$startTime = date('Y-m-01');
$endTime = date('Y-m-d', strtotime(date('Y-m-01') . ' +1 month'));
$lastStartTime = date('Y-m-01', strtotime('-1 month')); // 上月初
$lastEndTime = $startTime;
break;
case 'this_quarter': // 本季度
$month = date('n');
$quarter = ceil($month / 3);
$startMonth = ($quarter - 1) * 3 + 1;
$startTime = date('Y-') . str_pad($startMonth, 2, '0', STR_PAD_LEFT) . '-01';
$endTime = date('Y-m-d', strtotime($startTime . ' +3 month'));
// 上季度
$lastStartTime = date('Y-m-d', strtotime($startTime . ' -3 month'));
$lastEndTime = $startTime;
break;
case 'this_year': // 本年度
$startTime = date('Y-01-01');
$endTime = (date('Y') + 1) . '-01-01';
$lastStartTime = (date('Y') - 1) . '-01-01'; // 去年初
$lastEndTime = $startTime;
break;
default:
$startTime = date('Y-m-d', strtotime('monday this week'));
$endTime = date('Y-m-d', strtotime('monday next week'));
$lastStartTime = date('Y-m-d', strtotime('monday last week'));
$lastEndTime = $startTime;
}
return [
'start_time' => $startTime,
'end_time' => $endTime,
'last_start_time' => $lastStartTime,
'last_end_time' => $lastEndTime
];
}
/**
* 计算环比增长率
*/
private function calculateGrowth($current, $last)
{
if ($last == 0) {
return $current > 0 ? 100 : 0;
}
return round((($current - $last) / $last) * 100, 1);
}
}

11
Server/application/store/model/WechatFriendModel.php Normal file
View File

@@ -0,0 +1,11 @@
<?php
namespace app\store\model;
use think\Model;
class WechatFriendModel extends Model
{
protected $name = 'wechat_friend';
}

11
Server/application/store/model/WechatMessageModel.php Normal file
View File

@@ -0,0 +1,11 @@
<?php
namespace app\store\model;
use think\Model;
class WechatMessageModel extends Model
{
protected $name = 'wechat_message';
}