php如何实现商品通知

发布时间：2022-01-06 14:27:00 作者：iii
来源：亿速云阅读：210

# PHP如何实现商品通知

## 引言

在电子商务系统中，商品通知功能是提升用户体验和促进销售的重要手段。通过实时或定时通知，用户可以及时了解商品价格变动、库存更新、促销活动等信息。本文将详细介绍如何使用PHP实现商品通知功能，包括数据库设计、邮件通知、短信通知、WebSocket实时推送等多种实现方式。

---

## 目录

1. **需求分析**
2. **数据库设计**
3. **邮件通知实现**
4. **短信通知实现**
5. **WebSocket实时推送**
6. **定时任务（Cron Job）**
7. **安全性考虑**
8. **性能优化**
9. **总结**

---

## 1. 需求分析

商品通知功能通常包括以下场景：
- **价格变动通知**：当商品价格下降时通知订阅用户。
- **库存恢复通知**：当缺货商品重新上架时通知用户。
- **促销活动通知**：针对特定用户群体发送促销信息。
- **订单状态通知**：如发货、派送等状态的更新。

---

## 2. 数据库设计

### 核心表结构

#### 用户订阅表（user_subscriptions）
```sql
CREATE TABLE `user_subscriptions` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) NOT NULL,
  `product_id` int(11) NOT NULL,
  `notification_type` enum('price_drop','restock','promotion') NOT NULL,
  `threshold_value` decimal(10,2) DEFAULT NULL, -- 价格阈值
  `is_active` tinyint(1) DEFAULT 1,
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `user_product_type` (`user_id`,`product_id`,`notification_type`)
);

商品表（products）

CREATE TABLE `products` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) NOT NULL,
  `price` decimal(10,2) NOT NULL,
  `stock` int(11) NOT NULL,
  `last_price` decimal(10,2) DEFAULT NULL, -- 用于比较价格变动
  `is_promoting` tinyint(1) DEFAULT 0,
  `updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
);

通知日志表（notification_logs）

CREATE TABLE `notification_logs` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) NOT NULL,
  `product_id` int(11) NOT NULL,
  `notification_type` varchar(50) NOT NULL,
  `content` text NOT NULL,
  `sent_via` enum('email','sms','push') NOT NULL,
  `status` enum('pending','sent','failed') DEFAULT 'pending',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
);

3. 邮件通知实现

使用PHPMailer发送邮件

require 'vendor/autoload.php';

function sendPriceDropEmail($userEmail, $productName, $oldPrice, $newPrice) {
    $mail = new PHPMailer\PHPMailer\PHPMailer();
    $mail->isSMTP();
    $mail->Host = 'smtp.example.com';
    $mail->SMTPAuth = true;
    $mail->Username = 'your_email@example.com';
    $mail->Password = 'your_password';
    $mail->SMTPSecure = 'tls';
    $mail->Port = 587;
    
    $mail->setFrom('noreply@example.com', 'Store Name');
    $mail->addAddress($userEmail);
    $mail->Subject = "Price Drop Alert: $productName";
    $mail->Body = "The price of $productName has dropped from $oldPrice to $newPrice!";
    
    if(!$mail->send()) {
        logError("Mailer Error: " . $mail->ErrorInfo);
        return false;
    }
    return true;
}

邮件模板化（使用Twig）

$loader = new \Twig\Loader\FilesystemLoader('templates');
$twig = new \Twig\Environment($loader);

$htmlContent = $twig->render('price_drop.html.twig', [
    'productName' => $product->name,
    'oldPrice' => $oldPrice,
    'newPrice' => $newPrice,
    'productUrl' => "https://example.com/products/{$product->id}"
]);

4. 短信通知实现

使用Twilio API

require 'vendor/autoload.php';
use Twilio\Rest\Client;

function sendSMSNotification($phoneNumber, $message) {
    $accountSid = 'your_account_sid';
    $authToken = 'your_auth_token';
    
    $client = new Client($accountSid, $authToken);
    
    try {
        $client->messages->create(
            $phoneNumber,
            [
                'from' => '+1234567890',
                'body' => $message
            ]
        );
        return true;
    } catch (Exception $e) {
        logError("SMS Error: " . $e->getMessage());
        return false;
    }
}

5. WebSocket实时推送

使用Ratchet实现WebSocket服务器

use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class ProductNotification implements MessageComponentInterface {
    protected $clients;

    public function __construct() {
        $this->clients = new \SplObjectStorage;
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        // 处理客户端订阅请求
        $data = json_decode($msg, true);
        if ($data['action'] === 'subscribe') {
            $userId = $data['userId'];
            // 存储用户连接信息...
        }
    }

    // 其他必要方法...
}

// 启动服务器
$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new ProductNotification()
        )
    ),
    8080
);
$server->run();

前端连接示例

const socket = new WebSocket('ws://yourserver:8080');
socket.onmessage = function(e) {
    const notification = JSON.parse(e.data);
    showDesktopNotification(notification);
};

6. 定时任务（Cron Job）

价格变动检测脚本

// check_price_drops.php
$products = $db->query("SELECT * FROM products WHERE price != last_price");
foreach ($products as $product) {
    $subscribers = $db->query("
        SELECT u.email 
        FROM user_subscriptions s
        JOIN users u ON s.user_id = u.id
        WHERE s.product_id = {$product['id']} 
        AND s.notification_type = 'price_drop'
        AND s.is_active = 1
    ");
    
    foreach ($subscribers as $user) {
        sendPriceDropEmail($user['email'], $product['name'], $product['last_price'], $product['price']);
    }
    
    // 更新最后记录价格
    $db->query("UPDATE products SET last_price = {$product['price']} WHERE id = {$product['id']}");
}

设置Cron Job

# 每天上午10点执行
0 10 * * * /usr/bin/php /path/to/check_price_drops.php

7. 安全性考虑

输入验证：对所有用户输入进行过滤
频率限制：防止通知滥用
敏感数据加密：如用户手机号、邮箱
HTTPS：确保WebSocket连接安全
权限控制：验证通知发送权限

8. 性能优化

队列系统：使用Redis或RabbitMQ处理大量通知
批量处理：合并相同类型的通知
缓存机制：缓存商品信息减少数据库查询
异步处理：使用Gearman等工具异步发送通知

9. 总结

本文详细介绍了PHP实现商品通知的完整方案，包括： - 通过数据库设计存储订阅关系 - 使用邮件和短信发送通知 - WebSocket实现实时推送 - 定时任务检测商品变动 - 安全性和性能优化建议

实际项目中可根据需求选择合适的通知方式组合，并注意处理高并发场景下的性能问题。

”`

注：实际使用时需要根据项目具体情况调整代码，特别是安全凭证和服务器配置部分应妥善处理。文章总字数约2050字，可根据需要增减细节。