diff --git a/FlyCube/MpApi/Controller/AdminController.class.php b/FlyCube/MpApi/Controller/AdminController.class.php index d48018c..b239466 100644 --- a/FlyCube/MpApi/Controller/AdminController.class.php +++ b/FlyCube/MpApi/Controller/AdminController.class.php @@ -265,43 +265,42 @@ class AdminController extends PublicController */ public function pubMessage() { - // 非总管理员,拦截 + // 权限校验:非总管理员禁止操作 if ($this->tokenShop_id != C('powerId')) { - echo json_encode(['status' => 0, 'msg' => '没有权限']); + echo json_encode(array('status' => 0, 'msg' => '没有权限')); exit; } // 参数校验 - if (empty($_REQUEST['idArr']) || empty($_REQUEST['message']) || empty($_REQUEST['end_time'])) { - echo json_encode(['status' => 0, 'msg' => '参数不完整']); + if (!isset($_REQUEST['idArr']) || !isset($_REQUEST['message']) || !isset($_REQUEST['endTime'])) { + echo json_encode(array('status' => 0, 'msg' => '参数不完整')); 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 = [ - 'message' => trim($_REQUEST['message']), - 'end_time' => intval($_REQUEST['endTime']), - 'add_time' => time(), - ]; - - // 数据库操作,逐条插入(假设 message 是发给每个用户单独记录的) - $messageDb = D('message'); - $success = 0; - - foreach ($idArr as $adminId) { - $data['admin_id'] = intval($adminId); // 关联的管理员ID - if ($messageDb->add($data)) { - $success++; - } + // 构建插入数据数组 + $dataList = array(); + $nowTime = time(); + foreach ($idArr as $admin_id) { + $dataList[] = array( + 'admin_id' => intval($admin_id), + 'message' => $message, + 'end_time' => $endTime, + 'add_time' => time(), + ); } - if ($success > 0) { - echo json_encode(['status' => 1, 'msg' => '公告已成功发布']); + // 插入数据库 + $messageDb = D('message'); + + if ($messageDb->addAll($dataList)) { + echo json_encode(array('status' => 1, 'msg' => '公告已成功发布')); } else { - echo json_encode(['status' => 0, 'msg' => '公告发布失败']); + echo json_encode(array('status' => 0, 'msg' => '公告发布失败')); } } /**