alert('无效的请求方式'); window.location.href='rebate_summary.php';";
exit;
}
// 获取表单数据
$customerId = isset($_POST['customer_id']) ? intval($_POST['customer_id']) : 0;
$totalRebateAmount = isset($_POST['total_rebate_amount']) ? floatval($_POST['total_rebate_amount']) : 0;
$notes = isset($_POST['notes']) ? mysqli_real_escape_string($conn, $_POST['notes']) : '';
$items = isset($_POST['items']) ? $_POST['items'] : [];
// 验证基本数据
if ($customerId <= 0) {
echo "";
exit;
}
if ($totalRebateAmount <= 0) {
echo "";
exit;
}
if (empty($items)) {
echo "";
exit;
}
// 开始事务
$conn->begin_transaction();
try {
// 获取当前登录的员工ID
$employeeId = $_SESSION['employee_id'];
// 1. 创建主兑换记录
$insertRedemption = "INSERT INTO rebate_redemptions
(customer_id, redemption_date, total_rebate_amount, status, notes, created_by)
VALUES (?, NOW(), ?, 1, ?, ?)";
$stmt = $conn->prepare($insertRedemption);
$stmt->bind_param("idsi", $customerId, $totalRebateAmount, $notes, $employeeId);
if (!$stmt->execute()) {
throw new Exception("创建兑换记录失败: " . $stmt->error);
}
$redemptionId = $conn->insert_id;
$stmt->close();
// 2. 创建兑换明细记录
$insertItemStmt = $conn->prepare("INSERT INTO rebate_redemption_items
(redemption_id, order_id, order_item_id, product_id, quantity, rebate_amount, rebate_rule_id)
VALUES (?, ?, ?, ?, ?, ?, ?)");
foreach ($items as $item) {
$orderId = intval($item['order_id']);
$orderItemId = intval($item['order_item_id']);
$productId = intval($item['product_id']);
$quantity = intval($item['quantity']);
$rebateAmount = floatval($item['item_rebate_total']);
$rebateRuleId = intval($item['rebate_rule_id']);
$insertItemStmt->bind_param("iiiiidi", $redemptionId, $orderId, $orderItemId, $productId, $quantity, $rebateAmount, $rebateRuleId);
if (!$insertItemStmt->execute()) {
throw new Exception("创建兑换明细记录失败: " . $insertItemStmt->error);
}
}
$insertItemStmt->close();
// 提交事务
$conn->commit();
//向所有财务发送消息提示
// 获取客户名称
$customerQuery = "SELECT cs_code FROM customer WHERE id = $customerId";
$customerResult = $conn->query($customerQuery);
$customerName = "未知客户";
if ($customerRow = $customerResult->fetch_assoc()) {
$customerName = $customerRow['cs_code'];
}
// 查询所有财务人员
$financeStaffQuery = "SELECT id, em_user FROM employee WHERE em_permission_role_id = 6 AND login_forbidden = 0";
$financeStaffResult = $conn->query($financeStaffQuery);
if ($financeStaffResult && $financeStaffResult->num_rows > 0) {
$financeStaffIds = [];
while ($staff = $financeStaffResult->fetch_assoc()) {
$financeStaffIds[] = $staff['id'];
}
// 构建消息内容
$messageTitle = "新的返点兑换申请";
$messageContent = "客户 {$customerName} 提交了一笔返点兑换申请，金额：¥" . number_format($totalRebateAmount, 2) . "。\n";
$messageContent = textDecode($messageContent);
$messageContent .= "兑换ID：{$redemptionId}\n";
$messageContent .= "处理人：{$_SESSION['employee_name']}\n";
$messageContent .= "申请时间：" . date('Y-m-d H:i:s') . "\n";
$messageContent .= "请及时处理。";
// 发送消息给所有财务人员
sendMessage(
$messageTitle,
$messageContent,
3, // 订单相关
1, // 部分群发
$financeStaffIds,
1 // 重要
);
}
// 返回成功消息
echo "";
} catch (Exception $e) {
// 回滚事务
$conn->rollback();
// 显示错误信息
echo "";
}
?>