Food/food_server
3
0
Fork 0
Code Issues 10 Pull Requests Actions Packages Projects Releases Wiki Activity

【类 型】：

Browse Source 
【原  因】：
【过  程】：
【影  响】：

# 类型 包含:
# feat：新功能（feature）
# fix：修补bug
# docs：文档（documentation）
# style： 格式（不影响代码运行的变动）
# refactor：重构（即不是新增功能，也不是修改bug的代码变动）
# test：增加测试
# chore：构建过程或辅助工具的变动
This commit is contained in:
air 2025-06-12 18:01:12 +08:00
parent 0fa923f8f3
commit e041021c34
1 changed files with 24 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
FlyCube/MpApi/Controller/AdminController.class.php
View File

@ -265,43 +265,42 @@ class AdminController extends PublicController
*/ */
public function pubMessage() public function pubMessage()
{ {
// 非总管理员，拦截 // 权限校验：非总管理员禁止操作
if ($this->tokenShop_id != C('powerId')) { if ($this->tokenShop_id != C('powerId')) {
echo json_encode(['status' => 0, 'msg' => '没有权限']); echo json_encode(array('status' => 0, 'msg' => '没有权限'));
exit; exit;
} }
// 参数校验 // 参数校验
if (empty($_REQUEST['idArr']) || empty($_REQUEST['message']) || empty($_REQUEST['end_time'])) { if (!isset($_REQUEST['idArr']) || !isset($_REQUEST['message']) || !isset($_REQUEST['endTime'])) {
echo json_encode(['status' => 0, 'msg' => '参数不完整']); echo json_encode(array('status' => 0, 'msg' => '参数不完整'));
exit; exit;
} }
// 格式化 idArr // 参数处理
$idArr = is_array($_REQUEST['idArr']) ? $_REQUEST['idArr'] : explode(',', strval($_REQUEST['idArr'])); $message = trim($_REQUEST['message']);
$endTime = intval($_REQUEST['endTime']);
$idArr = is_array($_REQUEST['idArr']) ? $_REQUEST['idArr'] : explode(',', $_REQUEST['idArr']);
// 构造数据 // 构建插入数据数组
$data = [ $dataList = array();
'message' => trim($_REQUEST['message']), $nowTime = time();
'end_time' => intval($_REQUEST['endTime']), foreach ($idArr as $admin_id) {
'add_time' => time(), $dataList[] = array(
]; 'admin_id' => intval($admin_id),
'message' => $message,
// 数据库操作，逐条插入（假设 message 是发给每个用户单独记录的） 'end_time' => $endTime,
$messageDb = D('message'); 'add_time' => time(),
$success = 0; );
foreach ($idArr as $adminId) {
$data['admin_id'] = intval($adminId); // 关联的管理员ID
if ($messageDb->add($data)) {
$success++;
}
} }
if ($success > 0) { // 插入数据库
echo json_encode(['status' => 1, 'msg' => '公告已成功发布']); $messageDb = D('message');
if ($messageDb->addAll($dataList)) {
echo json_encode(array('status' => 1, 'msg' => '公告已成功发布'));
} else { } else {
echo json_encode(['status' => 0, 'msg' => '公告发布失败']); echo json_encode(array('status' => 0, 'msg' => '公告发布失败'));
} }
} }
/** /**