DBErp 3.0.0-rc.2：中小企业进销存的开源新选择，从部署到二次开发

# docker-compose.yml — DBErp 最小部署示例
# 请根据项目官方文档调整镜像名、端口和数据卷路径

version: "3.8"

services:
  dberp-db:
    image: mysql:8.0
    restart: unless-stopped
    environment:
      MYSQL_ROOT_PASSWORD: "ChangeMeRootPwd2024"
      MYSQL_DATABASE: dberp
      MYSQL_USER: dberp
      MYSQL_PASSWORD: "ChangeMeDbPwd2024"
    volumes:
      - dberp-db-data:/var/lib/mysql
      - ./init-db:/docker-entrypoint-initdb.d  # 初始化 SQL 脚本放这里
    ports:
      - "127.0.0.1:3306:3306"   # 仅本地访问，生产环境不要暴露

  dberp-app:
    image: dberp/dberp:3.0.0-rc2   # 替换为官方发布的镜像名
    restart: unless-stopped
    depends_on:
      - dberp-db
    environment:
      DB_HOST: dberp-db
      DB_PORT: 3306
      DB_NAME: dberp
      DB_USER: dberp
      DB_PASS: "ChangeMeDbPwd2024"
      APP_ADMIN_EMAIL: admin@example.com
      APP_ADMIN_PASSWORD: "ChangeMeAdminPwd2024"
    volumes:
      - dberp-app-data:/var/www/html/upload  # 上传文件持久化
    ports:
      - "8080:80"

volumes:
  dberp-db-data:
  dberp-app-data:

# 1. 克隆或下载项目配置
mkdir dberp-deploy && cd dberp-deploy
# 将上面的 docker-compose.yml 保存到当前目录

# 2. 如果项目提供了初始化 SQL，放到 init-db/ 目录
mkdir -p init-db
# cp /path/to/dberp-init.sql init-db/

# 3. 启动
docker compose up -d

# 4. 检查状态
docker compose ps
docker compose logs dberp-app --tail 30

# 5. 访问
# 浏览器打开 http://localhost:8080
# 用 APP_ADMIN_EMAIL / APP_ADMIN_PASSWORD 登录

-- 在商品表增加字段（具体表名以项目实际 Schema 为准）
ALTER TABLE dberp_goods ADD COLUMN shelf_life_days INT DEFAULT NULL COMMENT '保质期天数';

-- 创建临期预警视图
CREATE OR REPLACE VIEW v_goods_near_expiry AS
SELECT
    g.goods_id,
    g.goods_name,
    g.shelf_life_days,
    i.in_stock_date,
    DATEDIFF(CURDATE(), i.in_stock_date) AS days_in_stock,
    g.shelf_life_days - DATEDIFF(CURDATE(), i.in_stock_date) AS days_remaining
FROM dberp_goods g
JOIN dberp_inventory i ON g.goods_id = i.goods_id
WHERE g.shelf_life_days IS NOT NULL
  AND (g.shelf_life_days - DATEDIFF(CURDATE(), i.in_stock_date)) <= 30;

#!/usr/bin/env python3
"""库存预警推送 — 定时检查低库存商品，推送到企业微信群"""
import requests
import pymysql
import os
from datetime import datetime

DB_CONFIG = {
    "host": os.getenv("DB_HOST", "127.0.0.1"),
    "port": int(os.getenv("DB_PORT", "3306")),
    "user": os.getenv("DB_USER", "dberp"),
    "password": os.getenv("DB_PASS", "ChangeMeDbPwd2024"),
    "database": os.getenv("DB_NAME", "dberp"),
}

WECHAT_WEBHOOK = os.getenv("WECHAT_WEBHOOK_URL", "")

ALERT_THRESHOLD = int(os.getenv("STOCK_ALERT_THRESHOLD", "10"))  # 默认低于 10 件预警


def check_low_stock():
    conn = pymysql.connect(**DB_CONFIG)
    try:
        with conn.cursor() as cur:
            cur.execute(
                """
                SELECT g.goods_name, i.actual_stock, i.warehouse_name
                FROM dberp_goods g
                JOIN dberp_inventory i ON g.goods_id = i.goods_id
                WHERE i.actual_stock <= %s
                ORDER BY i.actual_stock ASC
                """,
                (ALERT_THRESHOLD,),
            )
            return cur.fetchall()
    finally:
        conn.close()


def send_wechat_alert(items):
    if not WECHAT_WEBHOOK:
        print("未配置 WECHAT_WEBHOOK_URL，仅打印预警：")
        for name, stock, warehouse in items:
            print(f"  [{warehouse}] {name} — 库存 {stock} 件")
        return

    lines = [f"**库存预警** ({datetime.now().strftime('%Y-%m-%d %H:%M')})"]
    for name, stock, warehouse in items:
        lines.append(f"- [{warehouse}] **{name}** — 仅剩 {stock} 件")

    payload = {
        "msgtype": "markdown",
        "markdown": {"content": "\n".join(lines)},
    }
    resp = requests.post(WECHAT_WEBHOOK, json=payload, timeout=10)
    print(f"推送结果: {resp.status_code}")


if __name__ == "__main__":
    low_items = check_low_stock()
    if low_items:
        send_wechat_alert(low_items)
    else:
        print("当前无低库存商品")