feat(消息模块): 优化消息查询逻辑,支持俱乐部消息展示

- 修改了 User、Activity、Circle、Club 和 Game 控制器中的消息查询逻辑
- 增加了对俱乐部成员的判断,使得俱乐部消息能够展示给相关用户
- 调整了消息表中的字段名称,统一使用 user_id 替代 target_id
- 优化了订单创建流程,只在需要时创建订单
- 更新了活动模型中的 costKey 属性,以适应新的费用结构
- 添加了新的费用类型翻译,以支持多退少补等功能
This commit is contained in:
2025-06-06 12:00:13 +08:00
parent d788227ff1
commit c9a8b9d5e8
9 changed files with 63 additions and 32 deletions

View File

@@ -363,7 +363,7 @@ class User extends Common
'name' => $user['nickname'], 'name' => $user['nickname'],
'avatar' => $user['avatar'], 'avatar' => $user['avatar'],
'from_id' => $user['id'], 'from_id' => $user['id'],
'target_id' => $params['user_id'], 'user_id' => $params['user_id'],
'content' => json_encode([ 'content' => json_encode([
'topic' => '好友消息', 'topic' => '好友消息',
'time' => date('Y-m-d H:i:s'), 'time' => date('Y-m-d H:i:s'),
@@ -386,17 +386,31 @@ class User extends Common
public function msgGroup() public function msgGroup()
{ {
$params = $this->request->param(); $params = $this->request->param();
$member = Menber::where('user_id', $this->auth->id)->where('role', '>', 1)->column('club_id');
$query1 = Message::field('*,count(*) as num')->where('user_id', $this->auth->id); if (!empty($member)) {
$query2 = Message::field('*,count(*) as num')->where('user_id', $this->auth->id); $query1 = Message::field('*,count(*) as num')->where(function ($q1) use ($member) {
$q1->where('user_id', $this->auth->id)
->whereOr(function ($q2) use ($member) {
$q2->where('type', 3)->whereIn('from_id', $member);
});
});
$query2 = Message::field('*,count(*) as num')->where(function ($q1) use ($member) {
$q1->where('user_id', $this->auth->id)
->whereOr(function ($q2) use ($member) {
$q2->where('type', 3)->whereIn('from_id', $member);
});
});
} else {
$query1 = Message::field('*,count(*) as num')->where('user_id', $this->auth->id);
$query2 = Message::field('*,count(*) as num')->where('user_id', $this->auth->id);
}
if (isset($params['type'])) { if (isset($params['type'])) {
$query1->where('type', $params['type']); $query1->where('type', $params['type']);
$query2->where('type', $params['type']); $query2->where('type', $params['type']);
} }
$query1->group('from_id')->order('update_time', 'desc'); $query1->group('from_id')->order('update_time', 'desc');
$query2->group('from_id')->order('update_time', 'desc'); $query2->group('from_id')->order('update_time', 'desc');
$num = $query2->where('status', 0)->column('count(*) as num', 'from_id'); // ->column('count(*) as num', 'gender'); $num = $query2->where('status', 0)->column('count(*) as num', 'from_id');
// dd($num);
$res = $query1->paginate($params['pageSize'] ?? 10); $res = $query1->paginate($params['pageSize'] ?? 10);
$list = $res->items(); $list = $res->items();
foreach ($list as &$r) { foreach ($list as &$r) {
@@ -410,8 +424,17 @@ class User extends Common
public function msg() public function msg()
{ {
$params = $this->request->param(); $params = $this->request->param();
$member = Menber::where('user_id', $this->auth->id)->where('role', '>', 1)->column('club_id');
$query = Message::where('user_id', $this->auth->id); if (!empty($member)) {
$query = Message::where(function ($q1) use ($member) {
$q1->where('user_id', $this->auth->id) //用户消息
->whereOr(function ($q2) use ($member) { //俱乐部消息
$q2->where('type', 3)->whereIn('from_id', $member);
});
});
} else {
$query = Message::where('user_id', $this->auth->id);
}
if (isset($params['type'])) { if (isset($params['type'])) {
$query->where('type', $params['type']); $query->where('type', $params['type']);
} }

View File

@@ -235,18 +235,21 @@ class Activity extends Base
$this->error('报名人数错误'); $this->error('报名人数错误');
} }
} }
$orderCreate = new OrderCreate($params); $cost = json_decode($game['cost'], true);
$result = $orderCreate->calc('create'); if (!empty($cost['type']) && ($cost['type'] == 10 || $cost['type'] == 30)) {
$order = $orderCreate->create($result); $orderCreate = new OrderCreate($params);
$join = new GameJoin; $result = $orderCreate->calc('create');
$join->allowField(true)->save([ $order = $orderCreate->create($result);
'act_id' => $game['act_id'], $join = new GameJoin;
'game_id' => $game['id'], $join->allowField(true)->save([
'user_id' => $this->auth->id, 'act_id' => $game['act_id'],
'order_id' => $order['id'], 'game_id' => $game['id'],
'status' => 0, //待支付 'user_id' => $this->auth->id,
'users' => json_encode($params['users'] ?? []) 'order_id' => $order['id'],
]); 'status' => 0, //待支付
'users' => json_encode($params['users'] ?? [])
]);
}
foreach ($participant as &$p) { foreach ($participant as &$p) {
$p['game_join_id'] = $join->id; $p['game_join_id'] = $join->id;
} }
@@ -258,6 +261,6 @@ class Activity extends Base
$this->error($e->getMessage(), $e); $this->error($e->getMessage(), $e);
} }
$this->success('Success', $order); $this->success('Success', $order ?? []);
} }
} }

View File

@@ -236,7 +236,7 @@ class Circle extends Base
'name' => '通知消息', 'name' => '通知消息',
'avatar' => '', 'avatar' => '',
'from_id' => 1, 'from_id' => 1,
'target_id' => $model->user_id, 'user_id' => $model->user_id,
'content' => json_encode([ 'content' => json_encode([
'topic' => '影圈审核', 'topic' => '影圈审核',
'result' => ($params['status'] == 1) ? '通过' : '不通过', 'result' => ($params['status'] == 1) ? '通过' : '不通过',

View File

@@ -227,8 +227,7 @@ class Club extends Base
'type' => 3, 'type' => 3,
'name' => $club->name, 'name' => $club->name,
'avatar' => $club->logo, 'avatar' => $club->logo,
'from_id' => $this->auth->id, 'from_id' => $club->id,
'target_id' => $club->id,
'content' => json_encode([ 'content' => json_encode([
'topic' => '俱乐部加入申请', 'topic' => '俱乐部加入申请',
'俱乐部名称' => $club->name, '俱乐部名称' => $club->name,
@@ -301,8 +300,7 @@ class Club extends Base
'type' => 3, 'type' => 3,
'name' => $club->name, 'name' => $club->name,
'avatar' => $club->logo, 'avatar' => $club->logo,
'from_id' => $this->auth->id, 'from_id' => $club->id,
'target_id' => $params['club_id'],
'content' => json_encode([ 'content' => json_encode([
'topic' => '俱乐部加入申请', 'topic' => '俱乐部加入申请',
'俱乐部名称' => $club->name, '俱乐部名称' => $club->name,

View File

@@ -118,7 +118,7 @@ class Game extends Base
'name' => '系统消息', 'name' => '系统消息',
'avatar' => '', 'avatar' => '',
'from_id' => 0, 'from_id' => 0,
'target_id' => $join->user_id, 'user_id' => $join->user_id,
'content' => json_encode([ 'content' => json_encode([
'topic' => '退出', 'topic' => '退出',
'content' => '已退出 ' . $model['name'] . ' 活动', 'content' => '已退出 ' . $model['name'] . ' 活动',
@@ -180,7 +180,7 @@ class Game extends Base
'name' => '系统消息', 'name' => '系统消息',
'avatar' => '', 'avatar' => '',
'from_id' => 0, 'from_id' => 0,
'target_id' => $j->user_id, 'user_id' => $j->user_id,
'content' => json_encode([ 'content' => json_encode([
'topic' => '评论', 'topic' => '评论',
'content' => $model['name'] . ' 活动已取消', 'content' => $model['name'] . ' 活动已取消',

View File

@@ -2,12 +2,12 @@
namespace addons\shopro\controller\zy; namespace addons\shopro\controller\zy;
use app\admin\model\zy\link\Visitor;
use think\Db; use think\Db;
use think\Exception; use think\Exception;
use app\admin\model\zy\Tags; use app\admin\model\zy\Tags;
use think\exception\PDOException; use think\exception\PDOException;
use app\admin\model\zy\link\Message; use app\admin\model\zy\link\Visitor;
use app\admin\model\shopro\user\User; use app\admin\model\shopro\user\User;
use app\admin\model\zy\circle\Circle; use app\admin\model\zy\circle\Circle;
use app\admin\model\zy\link\Complaint; use app\admin\model\zy\link\Complaint;

View File

@@ -79,5 +79,4 @@ return [
'Week5' => '周五', 'Week5' => '周五',
'Week6' => '周六', 'Week6' => '周六',
]; ];

View File

@@ -17,4 +17,12 @@ return [
'Status-1' => '取消', 'Status-1' => '取消',
'Status0' => '待支付', 'Status0' => '待支付',
'Status1' => '已支付', 'Status1' => '已支付',
'Cost10' => '报名时收取',
'Cost21' => '活动后收取:固定',
'Cost22' => '活动后收取AA',
'Cost23' => '活动后收取女固定男AA',
'Cost24' => '活动后收取AA男比女高X元',
'Cost25' => '活动后收取AA男比女高X%',
'Cost30' => '多退少补',
]; ];

View File

@@ -29,7 +29,7 @@ class Activity extends Model
public $costKey = ['man' => '男报名费', 'woman' => '女报名费', 'extra' => '附加费', 'server' => '服务费']; public $costKey = ['pay_type' => '支付方式', 'male' => '男费', 'woman' => '女费', 'extra' => '附加费', 'server' => '服务费'];