Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 203cc7ce21 | |||
| 6d70bd3e37 | |||
| 7b67466a3e | |||
| 182adca282 | |||
| 025f3b7bbc | |||
| c1febfffec | |||
| b42a70ff3b |
+21
-23
@@ -1,37 +1,35 @@
|
|||||||
name: DB Backup
|
name: DB Backup
|
||||||
|
|
||||||
on:
|
on:
|
||||||
# 定时备份已暂停(保留手动触发)。恢复时取消下面 schedule 的注释即可。
|
# 每日定时备份(北京时间 02:00)。手动触发亦可。
|
||||||
# schedule:
|
schedule:
|
||||||
# - cron: '0 18 * * *' # UTC 18:00 = 北京时间 02:00
|
- cron: '0 18 * * *' # UTC 18:00 = 北京时间 02:00
|
||||||
workflow_dispatch:
|
workflow_dispatch:
|
||||||
|
|
||||||
|
concurrency:
|
||||||
|
group: db-backup
|
||||||
|
cancel-in-progress: false
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
backup:
|
backup:
|
||||||
runs-on: ubuntu-latest
|
runs-on: mac
|
||||||
steps:
|
steps:
|
||||||
- name: Setup SSH
|
- uses: actions/checkout@v4
|
||||||
run: |
|
|
||||||
mkdir -p ~/.ssh
|
|
||||||
printf '%s' "${{ secrets.EC2_SSH_KEY }}" > ~/.ssh/ec2.pem
|
|
||||||
chmod 600 ~/.ssh/ec2.pem
|
|
||||||
ssh-keyscan -H ${{ secrets.EC2_HOST }} >> ~/.ssh/known_hosts
|
|
||||||
|
|
||||||
- name: Dump MySQL to NAS
|
- name: Dump MySQL to local backup dir
|
||||||
env:
|
env:
|
||||||
|
EC2_SSH_KEY: ${{ secrets.EC2_SSH_KEY }}
|
||||||
EC2_HOST: ${{ secrets.EC2_HOST }}
|
EC2_HOST: ${{ secrets.EC2_HOST }}
|
||||||
EC2_USER: ${{ secrets.EC2_USER }}
|
EC2_USER: ${{ secrets.EC2_USER }}
|
||||||
DB_PASSWORD: ${{ secrets.DB_PASSWORD }}
|
run: sh scripts/ci/backup-db.sh
|
||||||
run: |
|
|
||||||
BACKUP_DIR=/volume1/docker/backups/jiu-db
|
|
||||||
mkdir -p $BACKUP_DIR
|
|
||||||
FILENAME="jiu_db_$(date +%Y%m%d_%H%M%S).sql.gz"
|
|
||||||
ssh -i ~/.ssh/ec2.pem ${EC2_USER}@${EC2_HOST} \
|
|
||||||
"docker exec jiu_mysql mysqldump -uroot -p${DB_PASSWORD} jiu_db" \
|
|
||||||
| gzip > ${BACKUP_DIR}/${FILENAME}
|
|
||||||
find $BACKUP_DIR -name "*.sql.gz" -mtime +30 -delete
|
|
||||||
echo "Saved: ${BACKUP_DIR}/${FILENAME}"
|
|
||||||
|
|
||||||
- name: Cleanup SSH key
|
- name: Notify (Telegram)
|
||||||
if: always()
|
if: always()
|
||||||
run: rm -f ~/.ssh/ec2.pem
|
env:
|
||||||
|
TELEGRAM_TOKEN: ${{ secrets.TELEGRAM_TOKEN }}
|
||||||
|
TELEGRAM_CHAT_ID: ${{ secrets.TELEGRAM_CHAT_ID }}
|
||||||
|
run: |
|
||||||
|
if [ "${{ job.status }}" = "success" ]; then ICON="✅"; LABEL="数据库备份成功"; else ICON="❌"; LABEL="数据库备份失败"; fi
|
||||||
|
curl -f -X POST "https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage" \
|
||||||
|
-d "chat_id=${TELEGRAM_CHAT_ID}" \
|
||||||
|
--data-urlencode "text=${ICON} 岩美 ${LABEL}" > /dev/null || true
|
||||||
|
|||||||
@@ -5,6 +5,22 @@ All notable changes to this project will be documented in this file.
|
|||||||
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
||||||
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
||||||
|
|
||||||
|
## [1.0.67] - 2026-06-21
|
||||||
|
|
||||||
|
### 改进
|
||||||
|
- 选择器改为服务端全量搜索:选供应商/客户时按关键词查全部往来单位(不再只在已加载的首页里找);出库「选择商品」弹窗的搜索也改为实时查全部库存,输入即按编码/名称/系列匹配,不再漏掉未加载的商品
|
||||||
|
|
||||||
|
## [1.0.66] - 2026-06-21
|
||||||
|
|
||||||
|
### 改进
|
||||||
|
- 入库/出库列表「日期」列改名为「入库时间/出库时间」,移除恒为空的旧「审核时间」列
|
||||||
|
- 日期选择改为可直接键入的输入框 + 日历图标:能直接打年份(选老年份方便),支持只填到年或年月(自动补为月初)
|
||||||
|
|
||||||
|
## [1.0.65] - 2026-06-21
|
||||||
|
|
||||||
|
### 改进
|
||||||
|
- 入库录入改为「每行一个独立产品」:每条明细对应一个独立编号,同名同规格录多次也各自独立(配合后端 server-v1.0.69)
|
||||||
|
|
||||||
## [1.0.64] - 2026-06-20
|
## [1.0.64] - 2026-06-20
|
||||||
|
|
||||||
### 新功能
|
### 新功能
|
||||||
|
|||||||
@@ -5,6 +5,21 @@
|
|||||||
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
|
||||||
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
|
||||||
|
|
||||||
|
## [1.0.71] - 2026-06-21
|
||||||
|
|
||||||
|
### 改进
|
||||||
|
- 公开店铺商品页只展示「当前有库存」的商品,并返回每个商品的在库数量与商品编码(序列号),无货商品不再露出
|
||||||
|
|
||||||
|
## [1.0.70] - 2026-06-21
|
||||||
|
|
||||||
|
### 改进
|
||||||
|
- 商品名称/系列/规格选择接口支持关键词搜索(按名称或编码),为客户端选择器的服务端全量搜索提供支撑
|
||||||
|
|
||||||
|
## [1.0.69] - 2026-06-21
|
||||||
|
|
||||||
|
### 改进
|
||||||
|
- 入库录入改为「每行一个独立产品」:每条明细新建独立商品、发独立序列号(同名同规格录多次也各自独立),不再复用已有商品编号,符合"每个货品一个唯一编号"的管理方式
|
||||||
|
|
||||||
## [1.0.68] - 2026-06-21
|
## [1.0.68] - 2026-06-21
|
||||||
|
|
||||||
### 修复
|
### 修复
|
||||||
|
|||||||
@@ -85,6 +85,42 @@ func nextProductCode(tx *gorm.DB, shopID uint64) (string, error) {
|
|||||||
return fmt.Sprintf("P%03d", maxN+1), nil
|
return fmt.Sprintf("P%03d", maxN+1), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// createIndependentProduct 为入库明细新建一个独立产品(特有产品/序列号),返回新 product。
|
||||||
|
// "入库每行 = 一个特有产品"模型:每条明细建一个独立 product、发新序列号,不按名称复用。
|
||||||
|
// 含 nextProductCode 自增 + 撞 uk_shop_code 唯一约束时重试。必须在事务内调用。
|
||||||
|
func createIndependentProduct(tx *gorm.DB, shopID uint64, name, series, spec, batchNo string, prodDate *model.Date, price float64) (model.Product, error) {
|
||||||
|
namePinyin, nameInitials := util.ToPinyin(name)
|
||||||
|
var prod model.Product
|
||||||
|
var err error
|
||||||
|
for attempt := 0; attempt < 5; attempt++ {
|
||||||
|
code, e := nextProductCode(tx, shopID)
|
||||||
|
if e != nil {
|
||||||
|
return model.Product{}, e
|
||||||
|
}
|
||||||
|
prod = model.Product{
|
||||||
|
TenantBase: model.TenantBase{ShopID: shopID},
|
||||||
|
PublicID: uuid.New().String(),
|
||||||
|
Code: code,
|
||||||
|
Name: name,
|
||||||
|
Series: series,
|
||||||
|
Spec: spec,
|
||||||
|
BatchNo: batchNo,
|
||||||
|
ProductionDate: prodDate,
|
||||||
|
PurchasePrice: price,
|
||||||
|
NamePinyin: namePinyin,
|
||||||
|
NameInitials: nameInitials,
|
||||||
|
}
|
||||||
|
prod.ID = 0
|
||||||
|
if err = tx.Create(&prod).Error; err == nil || !errors.Is(err, gorm.ErrDuplicatedKey) {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
return model.Product{}, err
|
||||||
|
}
|
||||||
|
return prod, nil
|
||||||
|
}
|
||||||
|
|
||||||
// Create POST /api/v1/products
|
// Create POST /api/v1/products
|
||||||
func (h *ProductHandler) Create(c *gin.Context) {
|
func (h *ProductHandler) Create(c *gin.Context) {
|
||||||
shopID := middleware.GetShopID(c)
|
shopID := middleware.GetShopID(c)
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package handler
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"net/http"
|
"net/http"
|
||||||
|
"strings"
|
||||||
|
|
||||||
"github.com/gin-gonic/gin"
|
"github.com/gin-gonic/gin"
|
||||||
"gorm.io/gorm"
|
"gorm.io/gorm"
|
||||||
@@ -24,7 +25,12 @@ func NewProductOptionHandler(db *gorm.DB) *ProductOptionHandler {
|
|||||||
func (h *ProductOptionHandler) ListNames(c *gin.Context) {
|
func (h *ProductOptionHandler) ListNames(c *gin.Context) {
|
||||||
shopID := middleware.GetShopID(c)
|
shopID := middleware.GetShopID(c)
|
||||||
items := make([]model.ProductNameOption, 0)
|
items := make([]model.ProductNameOption, 0)
|
||||||
h.db.Where("shop_id = ?", shopID).Order("id ASC").Find(&items)
|
q := h.db.Where("shop_id = ?", shopID)
|
||||||
|
if kw := strings.TrimSpace(c.Query("keyword")); kw != "" {
|
||||||
|
like := "%" + kw + "%"
|
||||||
|
q = q.Where("name LIKE ? OR code LIKE ?", like, like)
|
||||||
|
}
|
||||||
|
q.Order("id ASC").Find(&items)
|
||||||
util.RespondSuccess(c, items)
|
util.RespondSuccess(c, items)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -85,7 +91,12 @@ func (h *ProductOptionHandler) DeleteName(c *gin.Context) {
|
|||||||
func (h *ProductOptionHandler) ListSeries(c *gin.Context) {
|
func (h *ProductOptionHandler) ListSeries(c *gin.Context) {
|
||||||
shopID := middleware.GetShopID(c)
|
shopID := middleware.GetShopID(c)
|
||||||
items := make([]model.ProductSeriesOption, 0)
|
items := make([]model.ProductSeriesOption, 0)
|
||||||
h.db.Where("shop_id = ?", shopID).Order("id ASC").Find(&items)
|
q := h.db.Where("shop_id = ?", shopID)
|
||||||
|
if kw := strings.TrimSpace(c.Query("keyword")); kw != "" {
|
||||||
|
like := "%" + kw + "%"
|
||||||
|
q = q.Where("name LIKE ? OR code LIKE ?", like, like)
|
||||||
|
}
|
||||||
|
q.Order("id ASC").Find(&items)
|
||||||
util.RespondSuccess(c, items)
|
util.RespondSuccess(c, items)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -146,7 +157,12 @@ func (h *ProductOptionHandler) DeleteSeries(c *gin.Context) {
|
|||||||
func (h *ProductOptionHandler) ListSpecs(c *gin.Context) {
|
func (h *ProductOptionHandler) ListSpecs(c *gin.Context) {
|
||||||
shopID := middleware.GetShopID(c)
|
shopID := middleware.GetShopID(c)
|
||||||
items := make([]model.ProductSpecOption, 0)
|
items := make([]model.ProductSpecOption, 0)
|
||||||
h.db.Where("shop_id = ?", shopID).Order("id ASC").Find(&items)
|
q := h.db.Where("shop_id = ?", shopID)
|
||||||
|
if kw := strings.TrimSpace(c.Query("keyword")); kw != "" {
|
||||||
|
like := "%" + kw + "%"
|
||||||
|
q = q.Where("name LIKE ? OR code LIKE ?", like, like)
|
||||||
|
}
|
||||||
|
q.Order("id ASC").Find(&items)
|
||||||
util.RespondSuccess(c, items)
|
util.RespondSuccess(c, items)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,86 @@
|
|||||||
|
package handler
|
||||||
|
|
||||||
|
import (
|
||||||
|
"net/http"
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
"github.com/stretchr/testify/assert"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
|
||||||
|
"github.com/wangjia/jiu/backend/internal/middleware"
|
||||||
|
"github.com/wangjia/jiu/backend/internal/model"
|
||||||
|
"github.com/wangjia/jiu/backend/testutil"
|
||||||
|
)
|
||||||
|
|
||||||
|
// setupOptionRouter 注册 product-options 名称路由(含 JWT)。
|
||||||
|
func setupOptionRouter(db *gorm.DB) *gin.Engine {
|
||||||
|
h := NewProductOptionHandler(db)
|
||||||
|
r := gin.New()
|
||||||
|
r.Use(gin.Recovery())
|
||||||
|
api := r.Group("/api/v1")
|
||||||
|
api.Use(middleware.JWT(db))
|
||||||
|
names := api.Group("/product-options/names")
|
||||||
|
names.GET("", h.ListNames)
|
||||||
|
return r
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestProductOptionHandler_ListNamesKeyword(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "OPT001")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
token := getAuthToken(user.ID, shop.ID, "admin")
|
||||||
|
r := setupOptionRouter(db)
|
||||||
|
|
||||||
|
db.Create(&model.ProductNameOption{
|
||||||
|
TenantBase: model.TenantBase{ShopID: shop.ID}, Code: "P001", Name: "茅台",
|
||||||
|
})
|
||||||
|
db.Create(&model.ProductNameOption{
|
||||||
|
TenantBase: model.TenantBase{ShopID: shop.ID}, Code: "P002", Name: "五粮液",
|
||||||
|
})
|
||||||
|
|
||||||
|
// 1. 无 keyword → 返回全部
|
||||||
|
w := makeRequest(r, "GET", "/api/v1/product-options/names", token, nil)
|
||||||
|
assert.Equal(t, http.StatusOK, w.Code)
|
||||||
|
data := parseResponse(w)["data"].([]interface{})
|
||||||
|
assert.Len(t, data, 2)
|
||||||
|
|
||||||
|
// 2. keyword 命中名称
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/product-options/names?keyword=五粮", token, nil)
|
||||||
|
assert.Equal(t, http.StatusOK, w.Code)
|
||||||
|
data = parseResponse(w)["data"].([]interface{})
|
||||||
|
assert.Len(t, data, 1)
|
||||||
|
assert.Equal(t, "五粮液", data[0].(map[string]interface{})["name"])
|
||||||
|
|
||||||
|
// 3. keyword 命中编码
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/product-options/names?keyword=P001", token, nil)
|
||||||
|
assert.Equal(t, http.StatusOK, w.Code)
|
||||||
|
data = parseResponse(w)["data"].([]interface{})
|
||||||
|
assert.Len(t, data, 1)
|
||||||
|
assert.Equal(t, "茅台", data[0].(map[string]interface{})["name"])
|
||||||
|
|
||||||
|
// 4. keyword 无命中 → 空
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/product-options/names?keyword=不存在", token, nil)
|
||||||
|
assert.Equal(t, http.StatusOK, w.Code)
|
||||||
|
data = parseResponse(w)["data"].([]interface{})
|
||||||
|
assert.Len(t, data, 0)
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestProductOptionHandler_ListNamesIsolation(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shopA := testutil.CreateTestShop(db, "OPT_A")
|
||||||
|
userA := testutil.CreateTestUser(db, shopA.ID, "adminA", "pass", "admin")
|
||||||
|
tokenA := getAuthToken(userA.ID, shopA.ID, "admin")
|
||||||
|
shopB := testutil.CreateTestShop(db, "OPT_B")
|
||||||
|
r := setupOptionRouter(db)
|
||||||
|
|
||||||
|
db.Create(&model.ProductNameOption{
|
||||||
|
TenantBase: model.TenantBase{ShopID: shopB.ID}, Name: "他店商品",
|
||||||
|
})
|
||||||
|
|
||||||
|
// A 店即使 keyword 命中 B 店数据也查不到(shop_id 隔离)
|
||||||
|
w := makeRequest(r, "GET", "/api/v1/product-options/names?keyword=他店", tokenA, nil)
|
||||||
|
assert.Equal(t, http.StatusOK, w.Code)
|
||||||
|
data := parseResponse(w)["data"].([]interface{})
|
||||||
|
assert.Len(t, data, 0)
|
||||||
|
}
|
||||||
@@ -202,12 +202,14 @@ type publicProductImage struct {
|
|||||||
type publicProductResp struct {
|
type publicProductResp struct {
|
||||||
ID uint64 `json:"id"`
|
ID uint64 `json:"id"`
|
||||||
PublicID string `json:"public_id"`
|
PublicID string `json:"public_id"`
|
||||||
|
Code string `json:"code"`
|
||||||
Name string `json:"name"`
|
Name string `json:"name"`
|
||||||
Series string `json:"series"`
|
Series string `json:"series"`
|
||||||
Spec string `json:"spec"`
|
Spec string `json:"spec"`
|
||||||
Brand string `json:"brand"`
|
Brand string `json:"brand"`
|
||||||
Unit string `json:"unit"`
|
Unit string `json:"unit"`
|
||||||
SalePrice float64 `json:"sale_price"`
|
SalePrice float64 `json:"sale_price"`
|
||||||
|
Quantity float64 `json:"quantity"`
|
||||||
Images []publicProductImage `json:"images"`
|
Images []publicProductImage `json:"images"`
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -234,8 +236,15 @@ func (h *PublicHandler) ListShopProducts(c *gin.Context) {
|
|||||||
pageSize = 20
|
pageSize = 20
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 仅列「有库存」的商品:JOIN 库存按 product 聚合(数量>0)的子查询。
|
||||||
|
stockSub := h.db.Model(&model.Inventory{}).
|
||||||
|
Select("product_id, SUM(quantity) AS qty").
|
||||||
|
Where("shop_id = ? AND deleted_at IS NULL AND quantity > 0", shop.ID).
|
||||||
|
Group("product_id")
|
||||||
|
|
||||||
query := h.db.Model(&model.Product{}).
|
query := h.db.Model(&model.Product{}).
|
||||||
Where("shop_id = ? AND public_id IS NOT NULL AND public_id != '' AND deleted_at IS NULL", shop.ID)
|
Joins("JOIN (?) AS stk ON stk.product_id = products.id", stockSub).
|
||||||
|
Where("products.shop_id = ? AND products.public_id IS NOT NULL AND products.public_id != '' AND products.deleted_at IS NULL", shop.ID)
|
||||||
|
|
||||||
var total int64
|
var total int64
|
||||||
if err := query.Count(&total).Error; err != nil {
|
if err := query.Count(&total).Error; err != nil {
|
||||||
@@ -248,12 +257,33 @@ func (h *PublicHandler) ListShopProducts(c *gin.Context) {
|
|||||||
if err := query.Preload("Images").
|
if err := query.Preload("Images").
|
||||||
Offset(offset).
|
Offset(offset).
|
||||||
Limit(pageSize).
|
Limit(pageSize).
|
||||||
Order("id DESC").
|
Order("products.id DESC").
|
||||||
Find(&products).Error; err != nil {
|
Find(&products).Error; err != nil {
|
||||||
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 取本页商品的在库总量(IN 限定在本页 ≤pageSize 个 id,开销小)
|
||||||
|
qtyMap := make(map[uint64]float64, len(products))
|
||||||
|
if len(products) > 0 {
|
||||||
|
pageIDs := make([]uint64, len(products))
|
||||||
|
for i, p := range products {
|
||||||
|
pageIDs[i] = p.ID
|
||||||
|
}
|
||||||
|
var stockRows []struct {
|
||||||
|
ProductID uint64
|
||||||
|
Qty float64
|
||||||
|
}
|
||||||
|
h.db.Model(&model.Inventory{}).
|
||||||
|
Select("product_id, SUM(quantity) AS qty").
|
||||||
|
Where("shop_id = ? AND deleted_at IS NULL AND quantity > 0 AND product_id IN ?", shop.ID, pageIDs).
|
||||||
|
Group("product_id").
|
||||||
|
Scan(&stockRows)
|
||||||
|
for _, s := range stockRows {
|
||||||
|
qtyMap[s.ProductID] = s.Qty
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
listData := make([]publicProductResp, len(products))
|
listData := make([]publicProductResp, len(products))
|
||||||
for i, p := range products {
|
for i, p := range products {
|
||||||
imgs := make([]publicProductImage, len(p.Images))
|
imgs := make([]publicProductImage, len(p.Images))
|
||||||
@@ -263,12 +293,14 @@ func (h *PublicHandler) ListShopProducts(c *gin.Context) {
|
|||||||
listData[i] = publicProductResp{
|
listData[i] = publicProductResp{
|
||||||
ID: p.ID,
|
ID: p.ID,
|
||||||
PublicID: p.PublicID,
|
PublicID: p.PublicID,
|
||||||
|
Code: p.Code,
|
||||||
Name: p.Name,
|
Name: p.Name,
|
||||||
Series: p.Series,
|
Series: p.Series,
|
||||||
Spec: p.Spec,
|
Spec: p.Spec,
|
||||||
Brand: p.Brand,
|
Brand: p.Brand,
|
||||||
Unit: p.Unit,
|
Unit: p.Unit,
|
||||||
SalePrice: p.SalePrice,
|
SalePrice: p.SalePrice,
|
||||||
|
Quantity: qtyMap[p.ID],
|
||||||
Images: imgs,
|
Images: imgs,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,125 @@
|
|||||||
|
package handler
|
||||||
|
|
||||||
|
import (
|
||||||
|
"encoding/json"
|
||||||
|
"net/http"
|
||||||
|
"net/http/httptest"
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
"github.com/stretchr/testify/assert"
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
|
||||||
|
"github.com/wangjia/jiu/backend/internal/model"
|
||||||
|
"github.com/wangjia/jiu/backend/testutil"
|
||||||
|
)
|
||||||
|
|
||||||
|
func setupPublicRouter(db *gorm.DB) *gin.Engine {
|
||||||
|
h := NewPublicHandler(db)
|
||||||
|
r := gin.New()
|
||||||
|
r.Use(gin.Recovery())
|
||||||
|
r.GET("/api/v1/public/shops/:shop_code/products", h.ListShopProducts)
|
||||||
|
return r
|
||||||
|
}
|
||||||
|
|
||||||
|
// 给商品补 public_id(CreateTestProduct 默认不设)
|
||||||
|
func setPublicID(db *gorm.DB, productID uint64, pub string) {
|
||||||
|
require := func(err error) {
|
||||||
|
if err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
require(db.Model(&model.Product{}).Where("id = ?", productID).Update("public_id", pub).Error)
|
||||||
|
}
|
||||||
|
|
||||||
|
func addInventory(db *gorm.DB, shopID, warehouseID, productID uint64, qty float64) {
|
||||||
|
wid := warehouseID
|
||||||
|
pid := productID
|
||||||
|
if err := db.Create(&model.Inventory{
|
||||||
|
ShopID: shopID,
|
||||||
|
WarehouseID: &wid,
|
||||||
|
ProductID: &pid,
|
||||||
|
Quantity: qty,
|
||||||
|
}).Error; err != nil {
|
||||||
|
panic(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPublicHandler_ListShopProducts_InStockOnly(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "PUB001")
|
||||||
|
wh := testutil.CreateTestWarehouse(db, shop.ID, "仓")
|
||||||
|
r := setupPublicRouter(db)
|
||||||
|
|
||||||
|
// A:有库存 5 → 应出现,quantity=5
|
||||||
|
pa := testutil.CreateTestProduct(db, shop.ID, "茅台A")
|
||||||
|
setPublicID(db, pa.ID, "pub-a")
|
||||||
|
addInventory(db, shop.ID, wh.ID, pa.ID, 5)
|
||||||
|
|
||||||
|
// B:有 public_id 但无库存 → 不出现
|
||||||
|
pb := testutil.CreateTestProduct(db, shop.ID, "五粮液B")
|
||||||
|
setPublicID(db, pb.ID, "pub-b")
|
||||||
|
|
||||||
|
// C:两条库存 3+2 → 出现,quantity=5
|
||||||
|
pc := testutil.CreateTestProduct(db, shop.ID, "汾酒C")
|
||||||
|
setPublicID(db, pc.ID, "pub-c")
|
||||||
|
addInventory(db, shop.ID, wh.ID, pc.ID, 3)
|
||||||
|
addInventory(db, shop.ID, wh.ID, pc.ID, 2)
|
||||||
|
|
||||||
|
// D:有库存但无 public_id → 不出现
|
||||||
|
pd := testutil.CreateTestProduct(db, shop.ID, "无公开D")
|
||||||
|
addInventory(db, shop.ID, wh.ID, pd.ID, 9)
|
||||||
|
|
||||||
|
w := httptest.NewRecorder()
|
||||||
|
req, _ := http.NewRequest("GET", "/api/v1/public/shops/PUB001/products", nil)
|
||||||
|
r.ServeHTTP(w, req)
|
||||||
|
require.Equal(t, http.StatusOK, w.Code)
|
||||||
|
|
||||||
|
var resp map[string]interface{}
|
||||||
|
require.NoError(t, json.Unmarshal(w.Body.Bytes(), &resp))
|
||||||
|
|
||||||
|
// 只 A、C 两个有库存 + 有 public_id
|
||||||
|
assert.Equal(t, float64(2), resp["total"])
|
||||||
|
data := resp["data"].([]interface{})
|
||||||
|
require.Len(t, data, 2)
|
||||||
|
|
||||||
|
byName := map[string]map[string]interface{}{}
|
||||||
|
for _, it := range data {
|
||||||
|
m := it.(map[string]interface{})
|
||||||
|
byName[m["name"].(string)] = m
|
||||||
|
}
|
||||||
|
|
||||||
|
require.Contains(t, byName, "茅台A")
|
||||||
|
require.Contains(t, byName, "汾酒C")
|
||||||
|
assert.NotContains(t, byName, "五粮液B") // 无库存
|
||||||
|
assert.NotContains(t, byName, "无公开D") // 无 public_id
|
||||||
|
|
||||||
|
// 数量正确(C 聚合 3+2=5)
|
||||||
|
assert.Equal(t, float64(5), byName["茅台A"]["quantity"])
|
||||||
|
assert.Equal(t, float64(5), byName["汾酒C"]["quantity"])
|
||||||
|
// 带上了序列号 code
|
||||||
|
assert.Equal(t, "P-茅台A", byName["茅台A"]["code"])
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPublicHandler_ListShopProducts_Isolation(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shopA := testutil.CreateTestShop(db, "PUBA")
|
||||||
|
shopB := testutil.CreateTestShop(db, "PUBB")
|
||||||
|
whB := testutil.CreateTestWarehouse(db, shopB.ID, "仓B")
|
||||||
|
r := setupPublicRouter(db)
|
||||||
|
|
||||||
|
// B 店有个有库存商品
|
||||||
|
pb := testutil.CreateTestProduct(db, shopB.ID, "他店商品")
|
||||||
|
setPublicID(db, pb.ID, "pub-x")
|
||||||
|
addInventory(db, shopB.ID, whB.ID, pb.ID, 7)
|
||||||
|
|
||||||
|
// 查 A 店:看不到 B 店商品
|
||||||
|
w := httptest.NewRecorder()
|
||||||
|
req, _ := http.NewRequest("GET", "/api/v1/public/shops/"+shopA.Code+"/products", nil)
|
||||||
|
r.ServeHTTP(w, req)
|
||||||
|
require.Equal(t, http.StatusOK, w.Code)
|
||||||
|
var resp map[string]interface{}
|
||||||
|
require.NoError(t, json.Unmarshal(w.Body.Bytes(), &resp))
|
||||||
|
assert.Equal(t, float64(0), resp["total"])
|
||||||
|
}
|
||||||
@@ -106,19 +106,28 @@ func (h *StockInHandler) Create(c *gin.Context) {
|
|||||||
}
|
}
|
||||||
req.OrderNo = orderNo
|
req.OrderNo = orderNo
|
||||||
|
|
||||||
// 计算总金额;自动生成批次号
|
// 事务内:每条明细新建一个独立产品(特有产品/序列号,不按名称复用),回填 product_id,再建单。
|
||||||
var total float64
|
err = h.db.Transaction(func(tx *gorm.DB) error {
|
||||||
for i := range req.Items {
|
var total float64
|
||||||
req.Items[i].ShopID = shopID
|
for i := range req.Items {
|
||||||
req.Items[i].TotalPrice = req.Items[i].Quantity * req.Items[i].UnitPrice
|
it := &req.Items[i]
|
||||||
total += req.Items[i].TotalPrice
|
it.ShopID = shopID
|
||||||
if req.Items[i].BatchNo == "" {
|
if it.BatchNo == "" {
|
||||||
req.Items[i].BatchNo = fmt.Sprintf("%s-%02d", req.OrderNo, i+1)
|
it.BatchNo = fmt.Sprintf("%s-%02d", req.OrderNo, i+1)
|
||||||
|
}
|
||||||
|
prod, e := createIndependentProduct(tx, shopID, it.ProductName, it.Series, it.Spec, it.BatchNo, it.ProductionDate, it.UnitPrice)
|
||||||
|
if e != nil {
|
||||||
|
return e
|
||||||
|
}
|
||||||
|
it.ProductID = prod.ID
|
||||||
|
it.ProductCode = prod.Code // 保留快照,兼容现有查询(瘦身阶段再去)
|
||||||
|
it.TotalPrice = it.Quantity * it.UnitPrice
|
||||||
|
total += it.TotalPrice
|
||||||
}
|
}
|
||||||
}
|
req.TotalAmount = total
|
||||||
req.TotalAmount = total
|
return tx.Create(&req).Error
|
||||||
|
})
|
||||||
if err := h.db.Create(&req).Error; err != nil {
|
if err != nil {
|
||||||
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -148,13 +157,20 @@ func (h *StockInHandler) Update(c *gin.Context) {
|
|||||||
}
|
}
|
||||||
var total float64
|
var total float64
|
||||||
for i := range req.Items {
|
for i := range req.Items {
|
||||||
req.Items[i].ShopID = shopID
|
it := &req.Items[i]
|
||||||
req.Items[i].OrderID = order.ID
|
it.ShopID = shopID
|
||||||
req.Items[i].TotalPrice = req.Items[i].Quantity * req.Items[i].UnitPrice
|
it.OrderID = order.ID
|
||||||
total += req.Items[i].TotalPrice
|
if it.BatchNo == "" {
|
||||||
if req.Items[i].BatchNo == "" {
|
it.BatchNo = fmt.Sprintf("%s-%02d", order.OrderNo, i+1)
|
||||||
req.Items[i].BatchNo = fmt.Sprintf("%s-%02d", order.OrderNo, i+1)
|
|
||||||
}
|
}
|
||||||
|
// 编辑草稿:旧明细已删,每条按新模型重建独立产品(旧草稿 product 无库存,暂留待后续清理)
|
||||||
|
prod, e := createIndependentProduct(tx, shopID, it.ProductName, it.Series, it.Spec, it.BatchNo, it.ProductionDate, it.UnitPrice)
|
||||||
|
if e != nil {
|
||||||
|
return e
|
||||||
|
}
|
||||||
|
it.ProductID = prod.ID
|
||||||
|
it.ProductCode = prod.Code
|
||||||
|
it.TotalPrice = it.Quantity * it.UnitPrice
|
||||||
}
|
}
|
||||||
updates := map[string]interface{}{
|
updates := map[string]interface{}{
|
||||||
"warehouse_id": req.WarehouseID,
|
"warehouse_id": req.WarehouseID,
|
||||||
|
|||||||
@@ -28,9 +28,11 @@ func TestStockInHandler_FullFlow(t *testing.T) {
|
|||||||
"order_date": time.Now().Format(time.RFC3339),
|
"order_date": time.Now().Format(time.RFC3339),
|
||||||
"items": []map[string]interface{}{
|
"items": []map[string]interface{}{
|
||||||
{
|
{
|
||||||
"product_id": product.ID,
|
"product_name": "Test Beer",
|
||||||
"quantity": 10.0,
|
"series": "普通",
|
||||||
"unit_price": 5.0,
|
"spec": "500ml",
|
||||||
|
"quantity": 10.0,
|
||||||
|
"unit_price": 5.0,
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
})
|
})
|
||||||
@@ -57,15 +59,17 @@ func TestStockInHandler_FullFlow(t *testing.T) {
|
|||||||
w = makeRequest(r, "PUT", fmt.Sprintf("/api/v1/stock-in/orders/%d/approve", orderID), token, nil)
|
w = makeRequest(r, "PUT", fmt.Sprintf("/api/v1/stock-in/orders/%d/approve", orderID), token, nil)
|
||||||
require.Equal(t, http.StatusOK, w.Code)
|
require.Equal(t, http.StatusOK, w.Code)
|
||||||
|
|
||||||
// 5. 验证库存变化
|
// 5. 验证库存变化:入库为明细新建了独立产品,库存指向它(不是预设的 product)
|
||||||
var inv model.Inventory
|
var inv model.Inventory
|
||||||
db.Where("shop_id = ? AND warehouse_id = ? AND product_id = ?",
|
db.Where("shop_id = ? AND warehouse_id = ?",
|
||||||
shop.ID, warehouse.ID, product.ID).First(&inv)
|
shop.ID, warehouse.ID).First(&inv)
|
||||||
assert.Equal(t, float64(10), inv.Quantity)
|
assert.Equal(t, float64(10), inv.Quantity)
|
||||||
|
assert.NotZero(t, inv.ProductID)
|
||||||
|
assert.NotEqual(t, product.ID, inv.ProductID)
|
||||||
|
|
||||||
// 6. 验证库存流水
|
// 6. 验证库存流水
|
||||||
var logs []model.InventoryLog
|
var logs []model.InventoryLog
|
||||||
db.Where("shop_id = ? AND product_id = ?", shop.ID, product.ID).Find(&logs)
|
db.Where("shop_id = ? AND product_id = ?", shop.ID, inv.ProductID).Find(&logs)
|
||||||
require.Len(t, logs, 1)
|
require.Len(t, logs, 1)
|
||||||
assert.Equal(t, "in", logs[0].Direction)
|
assert.Equal(t, "in", logs[0].Direction)
|
||||||
assert.Equal(t, float64(10), logs[0].Quantity)
|
assert.Equal(t, float64(10), logs[0].Quantity)
|
||||||
|
|||||||
@@ -22,6 +22,9 @@ type Product struct {
|
|||||||
Brand string `gorm:"size:100" json:"brand"`
|
Brand string `gorm:"size:100" json:"brand"`
|
||||||
PurchasePrice float64 `gorm:"type:decimal(12,2)" json:"purchase_price"`
|
PurchasePrice float64 `gorm:"type:decimal(12,2)" json:"purchase_price"`
|
||||||
SalePrice float64 `gorm:"type:decimal(12,2)" json:"sale_price"`
|
SalePrice float64 `gorm:"type:decimal(12,2)" json:"sale_price"`
|
||||||
|
// 特有产品的批次属性:每个 product = 一个特有产品/序列号,生产日期/批次归此(单一来源)
|
||||||
|
ProductionDate *Date `gorm:"type:date" json:"production_date"`
|
||||||
|
BatchNo string `gorm:"size:50" json:"batch_no"`
|
||||||
MinStock int `gorm:"default:0" json:"min_stock"`
|
MinStock int `gorm:"default:0" json:"min_stock"`
|
||||||
Description string `gorm:"type:text" json:"description"`
|
Description string `gorm:"type:text" json:"description"`
|
||||||
CustomFields JSON `gorm:"type:json" json:"custom_fields,omitempty"`
|
CustomFields JSON `gorm:"type:json" json:"custom_fields,omitempty"`
|
||||||
|
|||||||
@@ -188,6 +188,8 @@ func SetupTestDB() *gorm.DB {
|
|||||||
brand TEXT,
|
brand TEXT,
|
||||||
purchase_price REAL,
|
purchase_price REAL,
|
||||||
sale_price REAL,
|
sale_price REAL,
|
||||||
|
production_date DATETIME,
|
||||||
|
batch_no TEXT,
|
||||||
min_stock INTEGER DEFAULT 0,
|
min_stock INTEGER DEFAULT 0,
|
||||||
description TEXT,
|
description TEXT,
|
||||||
custom_fields TEXT,
|
custom_fields TEXT,
|
||||||
@@ -239,6 +241,45 @@ func SetupTestDB() *gorm.DB {
|
|||||||
content TEXT,
|
content TEXT,
|
||||||
remark TEXT
|
remark TEXT
|
||||||
)`,
|
)`,
|
||||||
|
`CREATE TABLE IF NOT EXISTS product_images (
|
||||||
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
|
product_id INTEGER NOT NULL,
|
||||||
|
shop_id INTEGER NOT NULL,
|
||||||
|
url TEXT NOT NULL,
|
||||||
|
sort_order INTEGER DEFAULT 0,
|
||||||
|
created_at DATETIME
|
||||||
|
)`,
|
||||||
|
`CREATE TABLE IF NOT EXISTS product_name_options (
|
||||||
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
|
created_at DATETIME,
|
||||||
|
updated_at DATETIME,
|
||||||
|
deleted_at DATETIME,
|
||||||
|
shop_id INTEGER NOT NULL,
|
||||||
|
code TEXT,
|
||||||
|
name TEXT NOT NULL,
|
||||||
|
remark TEXT
|
||||||
|
)`,
|
||||||
|
`CREATE TABLE IF NOT EXISTS product_series_options (
|
||||||
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
|
created_at DATETIME,
|
||||||
|
updated_at DATETIME,
|
||||||
|
deleted_at DATETIME,
|
||||||
|
shop_id INTEGER NOT NULL,
|
||||||
|
code TEXT,
|
||||||
|
name TEXT NOT NULL,
|
||||||
|
remark TEXT
|
||||||
|
)`,
|
||||||
|
`CREATE TABLE IF NOT EXISTS product_spec_options (
|
||||||
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
|
created_at DATETIME,
|
||||||
|
updated_at DATETIME,
|
||||||
|
deleted_at DATETIME,
|
||||||
|
shop_id INTEGER NOT NULL,
|
||||||
|
code TEXT,
|
||||||
|
name TEXT NOT NULL,
|
||||||
|
quantity INTEGER DEFAULT 0,
|
||||||
|
remark TEXT
|
||||||
|
)`,
|
||||||
`CREATE TABLE IF NOT EXISTS warehouses (
|
`CREATE TABLE IF NOT EXISTS warehouses (
|
||||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||||
created_at DATETIME,
|
created_at DATETIME,
|
||||||
|
|||||||
@@ -11,7 +11,6 @@ import '../../models/stock_in.dart';
|
|||||||
import '../../core/config/app_constants.dart';
|
import '../../core/config/app_constants.dart';
|
||||||
import '../../providers/partner_provider.dart';
|
import '../../providers/partner_provider.dart';
|
||||||
import '../../providers/product_option_provider.dart';
|
import '../../providers/product_option_provider.dart';
|
||||||
import '../../providers/product_provider.dart';
|
|
||||||
import '../../providers/inventory_provider.dart';
|
import '../../providers/inventory_provider.dart';
|
||||||
import '../../providers/stock_in_provider.dart';
|
import '../../providers/stock_in_provider.dart';
|
||||||
import '../../providers/warehouse_provider.dart';
|
import '../../providers/warehouse_provider.dart';
|
||||||
@@ -306,58 +305,22 @@ class _StockInFormScreenState extends ConsumerState<StockInFormScreen> {
|
|||||||
|
|
||||||
setState(() => _submitting = true);
|
setState(() => _submitting = true);
|
||||||
|
|
||||||
// Resolve product IDs for items where productId is null
|
// 入库每行 = 一个特有产品:明细只带 名称/系列/规格(字典文本) + 批次/生产日期,
|
||||||
|
// 由后端为每行新建独立产品(序列号),前端不再 findOrCreate 复用。
|
||||||
final nameOpts = ref.read(productNameListProvider).valueOrNull ?? [];
|
final nameOpts = ref.read(productNameListProvider).valueOrNull ?? [];
|
||||||
final seriesOpts = ref.read(productSeriesListProvider).valueOrNull ?? [];
|
final seriesOpts = ref.read(productSeriesListProvider).valueOrNull ?? [];
|
||||||
final specOpts = ref.read(productSpecListProvider).valueOrNull ?? [];
|
final specOpts = ref.read(productSpecListProvider).valueOrNull ?? [];
|
||||||
|
String optName(List<dynamic> opts, int? id) =>
|
||||||
|
opts.where((o) => o.id == id).firstOrNull?.name as String? ?? '';
|
||||||
|
|
||||||
for (final item in _items) {
|
for (final item in _items) {
|
||||||
if (item.productId == null) {
|
if (optName(nameOpts, item.selectedNameId).isEmpty) {
|
||||||
final name = nameOpts
|
ScaffoldMessenger.of(context).showSnackBar(
|
||||||
.where((o) => o.id == item.selectedNameId)
|
const SnackBar(
|
||||||
.firstOrNull
|
content: Text('请选择商品名称'), backgroundColor: AppTheme.danger),
|
||||||
?.name ??
|
);
|
||||||
'';
|
setState(() => _submitting = false);
|
||||||
final series = seriesOpts
|
return;
|
||||||
.where((o) => o.id == item.selectedSeriesId)
|
|
||||||
.firstOrNull
|
|
||||||
?.name ??
|
|
||||||
'';
|
|
||||||
final spec = specOpts
|
|
||||||
.where((o) => o.id == item.selectedSpecId)
|
|
||||||
.firstOrNull
|
|
||||||
?.name ??
|
|
||||||
'';
|
|
||||||
if (name.isEmpty) {
|
|
||||||
ScaffoldMessenger.of(context).showSnackBar(
|
|
||||||
const SnackBar(
|
|
||||||
content: Text('请选择商品名称'), backgroundColor: AppTheme.danger),
|
|
||||||
);
|
|
||||||
setState(() => _submitting = false);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
try {
|
|
||||||
final product =
|
|
||||||
await ref.read(productRepositoryProvider).findOrCreate(
|
|
||||||
name: name,
|
|
||||||
series: series,
|
|
||||||
spec: spec,
|
|
||||||
originId: item.selectedOriginId,
|
|
||||||
shelfLifeId: item.selectedShelfLifeId,
|
|
||||||
storageId: item.selectedStorageId,
|
|
||||||
descriptionDocId: item.selectedDescriptionDocId,
|
|
||||||
);
|
|
||||||
item.productId = product.id;
|
|
||||||
} catch (e) {
|
|
||||||
if (mounted) {
|
|
||||||
ScaffoldMessenger.of(context).showSnackBar(
|
|
||||||
SnackBar(
|
|
||||||
content: Text('商品查找失败:$e'), backgroundColor: AppTheme.danger),
|
|
||||||
);
|
|
||||||
setState(() => _submitting = false);
|
|
||||||
}
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -367,7 +330,9 @@ class _StockInFormScreenState extends ConsumerState<StockInFormScreen> {
|
|||||||
final batchNo = item.batchNoCtrl.text.trim();
|
final batchNo = item.batchNoCtrl.text.trim();
|
||||||
final productionDate = item.productionDateCtrl.text.trim();
|
final productionDate = item.productionDateCtrl.text.trim();
|
||||||
return {
|
return {
|
||||||
'product_id': item.productId ?? 0,
|
'product_name': optName(nameOpts, item.selectedNameId),
|
||||||
|
'series': optName(seriesOpts, item.selectedSeriesId),
|
||||||
|
'spec': optName(specOpts, item.selectedSpecId),
|
||||||
'quantity': qty,
|
'quantity': qty,
|
||||||
'unit_price': price,
|
'unit_price': price,
|
||||||
'total_price': qty * price,
|
'total_price': qty * price,
|
||||||
@@ -639,6 +604,20 @@ class _StockInFormScreenState extends ConsumerState<StockInFormScreen> {
|
|||||||
hint: '请选择供应商',
|
hint: '请选择供应商',
|
||||||
dialogTitle: '选择供应商',
|
dialogTitle: '选择供应商',
|
||||||
isRequired: true,
|
isRequired: true,
|
||||||
|
onSearch: (kw) async {
|
||||||
|
final res = await ref
|
||||||
|
.read(partnerRepositoryProvider)
|
||||||
|
.list(
|
||||||
|
type: 'supplier',
|
||||||
|
keyword: kw,
|
||||||
|
pageSize: 50);
|
||||||
|
return res.data
|
||||||
|
.map((p) => OptionItem(
|
||||||
|
id: p.id,
|
||||||
|
name: p.name,
|
||||||
|
code: p.code))
|
||||||
|
.toList();
|
||||||
|
},
|
||||||
onChanged: (v) =>
|
onChanged: (v) =>
|
||||||
setState(() => _partnerId = v),
|
setState(() => _partnerId = v),
|
||||||
),
|
),
|
||||||
|
|||||||
@@ -49,8 +49,7 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
ColDef('warehouse', '仓库'),
|
ColDef('warehouse', '仓库'),
|
||||||
ColDef('amount', '金额', minWidth: 800),
|
ColDef('amount', '金额', minWidth: 800),
|
||||||
ColDef('status', '状态'),
|
ColDef('status', '状态'),
|
||||||
ColDef('date', '日期', minWidth: 900),
|
ColDef('date', '入库时间', minWidth: 900),
|
||||||
ColDef('reviewed_at', '入库时间', minWidth: 900),
|
|
||||||
ColDef('operator', '入库员', minWidth: 1100),
|
ColDef('operator', '入库员', minWidth: 1100),
|
||||||
ColDef('reviewer', '审核员', minWidth: 1100),
|
ColDef('reviewer', '审核员', minWidth: 1100),
|
||||||
ColDef('actions', '操作', required: true),
|
ColDef('actions', '操作', required: true),
|
||||||
@@ -270,12 +269,6 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
return DataCell(StatusBadge(_apiStatusToEnum(o.status)));
|
return DataCell(StatusBadge(_apiStatusToEnum(o.status)));
|
||||||
case 'date':
|
case 'date':
|
||||||
return DataCell(Text(o.orderDate?.substring(0, 10) ?? '-'));
|
return DataCell(Text(o.orderDate?.substring(0, 10) ?? '-'));
|
||||||
case 'reviewed_at':
|
|
||||||
return DataCell(Text(o.reviewedAt != null
|
|
||||||
? o.reviewedAt!.length >= 16
|
|
||||||
? o.reviewedAt!.substring(0, 16)
|
|
||||||
: o.reviewedAt!.substring(0, 10)
|
|
||||||
: '-'));
|
|
||||||
case 'operator':
|
case 'operator':
|
||||||
return DataCell(Text(o.operatorName ?? '-',
|
return DataCell(Text(o.operatorName ?? '-',
|
||||||
style: const TextStyle(fontSize: 13)));
|
style: const TextStyle(fontSize: 13)));
|
||||||
@@ -550,7 +543,7 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
o.totalAmount != null
|
o.totalAmount != null
|
||||||
? '¥${o.totalAmount!.toStringAsFixed(2)}'
|
? '¥${o.totalAmount!.toStringAsFixed(2)}'
|
||||||
: '-'),
|
: '-'),
|
||||||
MobileCardField('日期', o.orderDate?.substring(0, 10) ?? '-'),
|
MobileCardField('入库时间', o.orderDate?.substring(0, 10) ?? '-'),
|
||||||
],
|
],
|
||||||
actions: _orderActions(context, o),
|
actions: _orderActions(context, o),
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
import 'dart:async';
|
||||||
|
|
||||||
import 'package:flutter/material.dart';
|
import 'package:flutter/material.dart';
|
||||||
import 'package:flutter/services.dart';
|
import 'package:flutter/services.dart';
|
||||||
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
import 'package:flutter_riverpod/flutter_riverpod.dart';
|
||||||
@@ -7,6 +9,7 @@ import '../../core/theme/app_theme.dart';
|
|||||||
import '../../core/auth/auth_state.dart';
|
import '../../core/auth/auth_state.dart';
|
||||||
import '../../core/utils/print_util.dart';
|
import '../../core/utils/print_util.dart';
|
||||||
import '../../core/utils/date_util.dart';
|
import '../../core/utils/date_util.dart';
|
||||||
|
import '../../models/inventory.dart';
|
||||||
import '../../models/stock_out.dart';
|
import '../../models/stock_out.dart';
|
||||||
import '../../widgets/date_picker_field.dart';
|
import '../../widgets/date_picker_field.dart';
|
||||||
import '../../widgets/searchable_option_field.dart';
|
import '../../widgets/searchable_option_field.dart';
|
||||||
@@ -39,6 +42,39 @@ class _PickerItem {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// 把库存行按 product 聚合为选择器条目(同一 product 的多行数量相加)。
|
||||||
|
List<_PickerItem> _aggregatePickerItems(List<Inventory> rows) {
|
||||||
|
final Map<int, _PickerItem> map = {};
|
||||||
|
for (final inv in rows.where((inv) => inv.productId != null)) {
|
||||||
|
final pid = inv.productId!;
|
||||||
|
final existing = map[pid];
|
||||||
|
if (existing != null) {
|
||||||
|
map[pid] = _PickerItem(
|
||||||
|
productId: pid,
|
||||||
|
productCode: existing.productCode,
|
||||||
|
productName: existing.productName,
|
||||||
|
series: existing.series,
|
||||||
|
spec: existing.spec,
|
||||||
|
unit: existing.unit,
|
||||||
|
unitPrice: existing.unitPrice ?? inv.unitPrice,
|
||||||
|
availableQty: existing.availableQty + inv.quantity,
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
map[pid] = _PickerItem(
|
||||||
|
productId: pid,
|
||||||
|
productCode: inv.productCode,
|
||||||
|
productName: inv.productName,
|
||||||
|
series: inv.series,
|
||||||
|
spec: inv.spec,
|
||||||
|
unit: inv.unit,
|
||||||
|
unitPrice: inv.unitPrice,
|
||||||
|
availableQty: inv.quantity,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return map.values.toList();
|
||||||
|
}
|
||||||
|
|
||||||
class _ItemRow {
|
class _ItemRow {
|
||||||
int? productId;
|
int? productId;
|
||||||
final String productCode;
|
final String productCode;
|
||||||
@@ -158,36 +194,8 @@ class _StockOutFormScreenState extends ConsumerState<StockOutFormScreen> {
|
|||||||
.listInventory(
|
.listInventory(
|
||||||
warehouseId: warehouseId,
|
warehouseId: warehouseId,
|
||||||
pageSize: AppConstants.stockOutPickerPageSize);
|
pageSize: AppConstants.stockOutPickerPageSize);
|
||||||
final Map<int, _PickerItem> productMap = {};
|
|
||||||
for (final inv in result.data.where((inv) => inv.productId != null)) {
|
|
||||||
final pid = inv.productId!;
|
|
||||||
if (productMap.containsKey(pid)) {
|
|
||||||
final existing = productMap[pid]!;
|
|
||||||
productMap[pid] = _PickerItem(
|
|
||||||
productId: pid,
|
|
||||||
productCode: existing.productCode,
|
|
||||||
productName: existing.productName,
|
|
||||||
series: existing.series,
|
|
||||||
spec: existing.spec,
|
|
||||||
unit: existing.unit,
|
|
||||||
unitPrice: existing.unitPrice ?? inv.unitPrice,
|
|
||||||
availableQty: existing.availableQty + inv.quantity,
|
|
||||||
);
|
|
||||||
} else {
|
|
||||||
productMap[pid] = _PickerItem(
|
|
||||||
productId: pid,
|
|
||||||
productCode: inv.productCode,
|
|
||||||
productName: inv.productName,
|
|
||||||
series: inv.series,
|
|
||||||
spec: inv.spec,
|
|
||||||
unit: inv.unit,
|
|
||||||
unitPrice: inv.unitPrice,
|
|
||||||
availableQty: inv.quantity,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
setState(() {
|
setState(() {
|
||||||
_inventoryPickerItems = productMap.values.toList();
|
_inventoryPickerItems = _aggregatePickerItems(result.data);
|
||||||
_inventoryMap = {
|
_inventoryMap = {
|
||||||
for (final item in _inventoryPickerItems)
|
for (final item in _inventoryPickerItems)
|
||||||
item.productId: item.availableQty
|
item.productId: item.availableQty
|
||||||
@@ -206,7 +214,10 @@ class _StockOutFormScreenState extends ConsumerState<StockOutFormScreen> {
|
|||||||
}
|
}
|
||||||
final selected = await showDialog<List<_PickerItem>>(
|
final selected = await showDialog<List<_PickerItem>>(
|
||||||
context: context,
|
context: context,
|
||||||
builder: (_) => _InventoryPickerDialog(items: _inventoryPickerItems),
|
builder: (_) => _InventoryPickerDialog(
|
||||||
|
items: _inventoryPickerItems,
|
||||||
|
warehouseId: _warehouseId,
|
||||||
|
),
|
||||||
);
|
);
|
||||||
if (selected == null || selected.isEmpty) return;
|
if (selected == null || selected.isEmpty) return;
|
||||||
setState(() {
|
setState(() {
|
||||||
@@ -532,6 +543,20 @@ class _StockOutFormScreenState extends ConsumerState<StockOutFormScreen> {
|
|||||||
selectedId: _partnerId,
|
selectedId: _partnerId,
|
||||||
hint: '请选择客户',
|
hint: '请选择客户',
|
||||||
dialogTitle: '选择客户',
|
dialogTitle: '选择客户',
|
||||||
|
onSearch: (kw) async {
|
||||||
|
final res = await ref
|
||||||
|
.read(partnerRepositoryProvider)
|
||||||
|
.list(
|
||||||
|
type: 'customer',
|
||||||
|
keyword: kw,
|
||||||
|
pageSize: 50);
|
||||||
|
return res.data
|
||||||
|
.map((p) => OptionItem(
|
||||||
|
id: p.id,
|
||||||
|
name: p.name,
|
||||||
|
code: p.code))
|
||||||
|
.toList();
|
||||||
|
},
|
||||||
onChanged: (v) =>
|
onChanged: (v) =>
|
||||||
setState(() => _partnerId = v),
|
setState(() => _partnerId = v),
|
||||||
),
|
),
|
||||||
@@ -873,39 +898,67 @@ class _FormField extends StatelessWidget {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
class _InventoryPickerDialog extends StatefulWidget {
|
class _InventoryPickerDialog extends ConsumerStatefulWidget {
|
||||||
final List<_PickerItem> items;
|
final List<_PickerItem> items;
|
||||||
const _InventoryPickerDialog({required this.items});
|
final int? warehouseId;
|
||||||
|
const _InventoryPickerDialog({required this.items, this.warehouseId});
|
||||||
|
|
||||||
@override
|
@override
|
||||||
State<_InventoryPickerDialog> createState() => _InventoryPickerDialogState();
|
ConsumerState<_InventoryPickerDialog> createState() =>
|
||||||
|
_InventoryPickerDialogState();
|
||||||
}
|
}
|
||||||
|
|
||||||
class _InventoryPickerDialogState extends State<_InventoryPickerDialog> {
|
class _InventoryPickerDialogState
|
||||||
|
extends ConsumerState<_InventoryPickerDialog> {
|
||||||
final _searchCtrl = TextEditingController();
|
final _searchCtrl = TextEditingController();
|
||||||
String _search = '';
|
String _search = '';
|
||||||
final Set<int> _selected = {};
|
final Set<int> _selected = {};
|
||||||
|
// 服务端搜索结果(替代一次性拉全部本地过滤);初始用调用方已加载的首屏
|
||||||
|
late List<_PickerItem> _results = widget.items;
|
||||||
|
// 已见过的条目(跨多次搜索),用于确认时按 productId 还原所选
|
||||||
|
late final Map<int, _PickerItem> _known = {
|
||||||
|
for (final it in widget.items) it.productId: it
|
||||||
|
};
|
||||||
|
bool _loading = false;
|
||||||
|
Timer? _debounce;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void dispose() {
|
void dispose() {
|
||||||
|
_debounce?.cancel();
|
||||||
_searchCtrl.dispose();
|
_searchCtrl.dispose();
|
||||||
super.dispose();
|
super.dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
List<_PickerItem> get _filtered {
|
void _onSearchChanged(String v) {
|
||||||
if (_search.isEmpty) return widget.items;
|
setState(() => _search = v);
|
||||||
final q = _search.toLowerCase();
|
_debounce?.cancel();
|
||||||
return widget.items
|
_debounce = Timer(const Duration(milliseconds: 300), _fetch);
|
||||||
.where((item) =>
|
}
|
||||||
item.productName.toLowerCase().contains(q) ||
|
|
||||||
item.productCode.toLowerCase().contains(q) ||
|
Future<void> _fetch() async {
|
||||||
item.series.toLowerCase().contains(q))
|
setState(() => _loading = true);
|
||||||
.toList();
|
try {
|
||||||
|
final kw = _search.trim();
|
||||||
|
final result = await ref.read(inventoryRepositoryProvider).listInventory(
|
||||||
|
warehouseId: widget.warehouseId,
|
||||||
|
keyword: kw.isEmpty ? null : kw,
|
||||||
|
pageSize: AppConstants.stockOutPickerPageSize,
|
||||||
|
);
|
||||||
|
final items = _aggregatePickerItems(result.data);
|
||||||
|
for (final it in items) {
|
||||||
|
_known[it.productId] = it;
|
||||||
|
}
|
||||||
|
if (mounted) setState(() => _results = items);
|
||||||
|
} catch (_) {
|
||||||
|
// 忽略:保留上次结果
|
||||||
|
} finally {
|
||||||
|
if (mounted) setState(() => _loading = false);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Widget build(BuildContext context) {
|
Widget build(BuildContext context) {
|
||||||
final filtered = _filtered;
|
final filtered = _results;
|
||||||
final allSelected = filtered.isNotEmpty &&
|
final allSelected = filtered.isNotEmpty &&
|
||||||
filtered.every((e) => _selected.contains(e.productId));
|
filtered.every((e) => _selected.contains(e.productId));
|
||||||
|
|
||||||
@@ -945,14 +998,24 @@ class _InventoryPickerDialogState extends State<_InventoryPickerDialog> {
|
|||||||
padding: const EdgeInsets.symmetric(horizontal: 16, vertical: 10),
|
padding: const EdgeInsets.symmetric(horizontal: 16, vertical: 10),
|
||||||
child: TextField(
|
child: TextField(
|
||||||
controller: _searchCtrl,
|
controller: _searchCtrl,
|
||||||
decoration: const InputDecoration(
|
decoration: InputDecoration(
|
||||||
hintText: '搜索商品编码、名称或系列',
|
hintText: '搜索商品编码、名称或系列',
|
||||||
prefixIcon: Icon(Icons.search, size: 18),
|
prefixIcon: const Icon(Icons.search, size: 18),
|
||||||
|
suffixIcon: _loading
|
||||||
|
? const Padding(
|
||||||
|
padding: EdgeInsets.all(12),
|
||||||
|
child: SizedBox(
|
||||||
|
width: 16,
|
||||||
|
height: 16,
|
||||||
|
child: CircularProgressIndicator(strokeWidth: 2),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
: null,
|
||||||
isDense: true,
|
isDense: true,
|
||||||
contentPadding:
|
contentPadding:
|
||||||
EdgeInsets.symmetric(horizontal: 12, vertical: 10),
|
const EdgeInsets.symmetric(horizontal: 12, vertical: 10),
|
||||||
),
|
),
|
||||||
onChanged: (v) => setState(() => _search = v),
|
onChanged: _onSearchChanged,
|
||||||
),
|
),
|
||||||
),
|
),
|
||||||
// Table header
|
// Table header
|
||||||
@@ -1068,9 +1131,9 @@ class _InventoryPickerDialogState extends State<_InventoryPickerDialog> {
|
|||||||
onPressed: _selected.isEmpty
|
onPressed: _selected.isEmpty
|
||||||
? null
|
? null
|
||||||
: () {
|
: () {
|
||||||
final result = widget.items
|
final result = _selected
|
||||||
.where((item) =>
|
.map((id) => _known[id])
|
||||||
_selected.contains(item.productId))
|
.whereType<_PickerItem>()
|
||||||
.toList();
|
.toList();
|
||||||
Navigator.pop(context, result);
|
Navigator.pop(context, result);
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -64,8 +64,7 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
ColDef('warehouse', '仓库'),
|
ColDef('warehouse', '仓库'),
|
||||||
ColDef('amount', '金额', minWidth: 800),
|
ColDef('amount', '金额', minWidth: 800),
|
||||||
ColDef('status', '状态'),
|
ColDef('status', '状态'),
|
||||||
ColDef('date', '日期', minWidth: 900),
|
ColDef('date', '出库时间', minWidth: 900),
|
||||||
ColDef('reviewed_at', '出库时间', minWidth: 900),
|
|
||||||
ColDef('created_at', '创建时间', minWidth: 900),
|
ColDef('created_at', '创建时间', minWidth: 900),
|
||||||
ColDef('operator', '出库员', minWidth: 1100),
|
ColDef('operator', '出库员', minWidth: 1100),
|
||||||
ColDef('reviewer', '审核员', minWidth: 1100),
|
ColDef('reviewer', '审核员', minWidth: 1100),
|
||||||
@@ -271,12 +270,6 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
return DataCell(StatusBadge(_apiStatusToEnum(o.status)));
|
return DataCell(StatusBadge(_apiStatusToEnum(o.status)));
|
||||||
case 'date':
|
case 'date':
|
||||||
return DataCell(Text(o.orderDate?.substring(0, 10) ?? '-'));
|
return DataCell(Text(o.orderDate?.substring(0, 10) ?? '-'));
|
||||||
case 'reviewed_at':
|
|
||||||
return DataCell(Text(o.reviewedAt != null
|
|
||||||
? o.reviewedAt!.length >= 16
|
|
||||||
? o.reviewedAt!.substring(0, 16)
|
|
||||||
: o.reviewedAt!.substring(0, 10)
|
|
||||||
: '-'));
|
|
||||||
case 'created_at':
|
case 'created_at':
|
||||||
return DataCell(Text(o.createdAt != null
|
return DataCell(Text(o.createdAt != null
|
||||||
? o.createdAt!.length >= 16
|
? o.createdAt!.length >= 16
|
||||||
@@ -524,7 +517,7 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
o.totalAmount != null
|
o.totalAmount != null
|
||||||
? '¥${o.totalAmount!.toStringAsFixed(2)}'
|
? '¥${o.totalAmount!.toStringAsFixed(2)}'
|
||||||
: '-'),
|
: '-'),
|
||||||
MobileCardField('日期', o.orderDate?.substring(0, 10) ?? '-'),
|
MobileCardField('出库时间', o.orderDate?.substring(0, 10) ?? '-'),
|
||||||
],
|
],
|
||||||
actions: _orderActions(context, o),
|
actions: _orderActions(context, o),
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -2,12 +2,12 @@ import 'package:flutter/material.dart';
|
|||||||
import '../core/theme/app_theme.dart';
|
import '../core/theme/app_theme.dart';
|
||||||
import '../core/utils/date_util.dart';
|
import '../core/utils/date_util.dart';
|
||||||
|
|
||||||
/// 年/月/日 三个可编辑下拉框的日期选择组件,替代原生 showDatePicker。
|
/// 可键入日期框 + 日历图标(替代旧的「年/月/日」三下拉)。
|
||||||
///
|
///
|
||||||
/// - 每个下拉是 Material 3 `DropdownMenu`:点开可选,键入数字即过滤定位
|
/// - **直接键入**:支持「2024」「2024-5」「2024-5-12」「20240512」等,归一为 `yyyy-MM-dd`,
|
||||||
/// (年/月/日均为有界域,条目覆盖全范围,等价于「手动输入数字」)。
|
/// 缺的月/日补 `01`(老酒只知道年份,填 2024 即 2024-01-01)。失焦时把显示归一化。
|
||||||
/// - 改月/年时把超出当月的「日」自动 clamp 回当月最大值。
|
/// - **日历图标**:弹 Material `showDatePicker`(input 模式可直接键入年份,选老年份方便)。
|
||||||
/// - 值以 `yyyy-MM-dd` 字符串进出([value] / [onChanged]);三者未填齐时回调 null。
|
/// - 值以 `yyyy-MM-dd` 字符串进出([value] / [onChanged]);无有效年时回调 null。
|
||||||
class DatePickerField extends StatefulWidget {
|
class DatePickerField extends StatefulWidget {
|
||||||
final String? value; // yyyy-MM-dd
|
final String? value; // yyyy-MM-dd
|
||||||
final ValueChanged<String?> onChanged;
|
final ValueChanged<String?> onChanged;
|
||||||
@@ -27,151 +27,130 @@ class DatePickerField extends StatefulWidget {
|
|||||||
}
|
}
|
||||||
|
|
||||||
class _DatePickerFieldState extends State<DatePickerField> {
|
class _DatePickerFieldState extends State<DatePickerField> {
|
||||||
int? _year;
|
late final TextEditingController _ctrl;
|
||||||
int? _month;
|
final FocusNode _focus = FocusNode();
|
||||||
int? _day;
|
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void initState() {
|
void initState() {
|
||||||
super.initState();
|
super.initState();
|
||||||
_parse(widget.value);
|
_ctrl = TextEditingController(text: widget.value ?? '');
|
||||||
|
_focus.addListener(() {
|
||||||
|
// 失焦时把输入归一化显示(如 2024 → 2024-01-01)
|
||||||
|
if (!_focus.hasFocus) {
|
||||||
|
final n = _normalize(_ctrl.text);
|
||||||
|
if (n != null && n != _ctrl.text) {
|
||||||
|
_ctrl.text = n;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void didUpdateWidget(DatePickerField old) {
|
void didUpdateWidget(DatePickerField old) {
|
||||||
super.didUpdateWidget(old);
|
super.didUpdateWidget(old);
|
||||||
if (old.value != widget.value) {
|
// 仅在无焦点(非用户正在输入)时同步外部值,避免回流打断输入
|
||||||
_parse(widget.value);
|
if (!_focus.hasFocus &&
|
||||||
|
old.value != widget.value &&
|
||||||
|
(widget.value ?? '') != _ctrl.text) {
|
||||||
|
_ctrl.text = widget.value ?? '';
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void _parse(String? v) {
|
@override
|
||||||
final d = parseYmd(v);
|
void dispose() {
|
||||||
_year = d?.year;
|
_ctrl.dispose();
|
||||||
_month = d?.month;
|
_focus.dispose();
|
||||||
_day = d?.day;
|
super.dispose();
|
||||||
}
|
}
|
||||||
|
|
||||||
int get _daysInMonth {
|
/// 归一用户输入为 `yyyy-MM-dd`(缺月/日补 01);无有效年返回 null。
|
||||||
final y = _year ?? DateTime.now().year;
|
static String? _normalize(String raw) {
|
||||||
final m = _month ?? 1;
|
final s = raw.trim();
|
||||||
return DateTime(y, m + 1, 0).day; // 下月第 0 天 = 当月最后一天
|
if (s.isEmpty) return null;
|
||||||
}
|
int? y, mo, d;
|
||||||
|
if (RegExp(r'^[0-9]+$').hasMatch(s)) {
|
||||||
String? get _composed => composeYmd(_year, _month, _day);
|
// 纯数字串:yyyymmdd / yyyymm / yyyy
|
||||||
|
if (s.length >= 8) {
|
||||||
void _emit(FormFieldState<String> field) {
|
y = int.tryParse(s.substring(0, 4));
|
||||||
// 改月/年后把超界的日 clamp 回当月最大值(与 composeYmd 一致,State 同步显示)
|
mo = int.tryParse(s.substring(4, 6));
|
||||||
if (_day != null && _day! > _daysInMonth) {
|
d = int.tryParse(s.substring(6, 8));
|
||||||
_day = _daysInMonth;
|
} else if (s.length == 6) {
|
||||||
|
y = int.tryParse(s.substring(0, 4));
|
||||||
|
mo = int.tryParse(s.substring(4, 6));
|
||||||
|
} else {
|
||||||
|
y = int.tryParse(s);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
final parts =
|
||||||
|
s.split(RegExp(r'[^0-9]+')).where((e) => e.isNotEmpty).toList();
|
||||||
|
if (parts.isNotEmpty) y = int.tryParse(parts[0]);
|
||||||
|
if (parts.length >= 2) mo = int.tryParse(parts[1]);
|
||||||
|
if (parts.length >= 3) d = int.tryParse(parts[2]);
|
||||||
|
}
|
||||||
|
if (y == null || y < 1900 || y > 2200) return null;
|
||||||
|
mo ??= 1;
|
||||||
|
d ??= 1;
|
||||||
|
if (mo < 1 || mo > 12) return null;
|
||||||
|
final maxDay = DateTime(y, mo + 1, 0).day;
|
||||||
|
if (d < 1) d = 1;
|
||||||
|
if (d > maxDay) d = maxDay;
|
||||||
|
return '${y.toString().padLeft(4, '0')}-'
|
||||||
|
'${mo.toString().padLeft(2, '0')}-'
|
||||||
|
'${d.toString().padLeft(2, '0')}';
|
||||||
|
}
|
||||||
|
|
||||||
|
Future<void> _pickFromCalendar(FormFieldState<String> field) async {
|
||||||
|
final init =
|
||||||
|
parseYmd(_normalize(_ctrl.text) ?? widget.value) ?? DateTime.now();
|
||||||
|
final picked = await showDatePicker(
|
||||||
|
context: context,
|
||||||
|
initialDate: init,
|
||||||
|
firstDate: DateTime(1900),
|
||||||
|
lastDate: DateTime(2200),
|
||||||
|
initialEntryMode: DatePickerEntryMode.input,
|
||||||
|
);
|
||||||
|
if (picked != null) {
|
||||||
|
final v = formatYmd(picked);
|
||||||
|
_ctrl.text = v;
|
||||||
|
field.didChange(v);
|
||||||
|
widget.onChanged(v);
|
||||||
}
|
}
|
||||||
final v = _composed;
|
|
||||||
field.didChange(v);
|
|
||||||
widget.onChanged(v);
|
|
||||||
setState(() {});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
Widget build(BuildContext context) {
|
Widget build(BuildContext context) {
|
||||||
final now = DateTime.now();
|
|
||||||
final years = [for (var y = now.year - 20; y <= now.year + 5; y++) y];
|
|
||||||
final months = [for (var m = 1; m <= 12; m++) m];
|
|
||||||
final days = [for (var d = 1; d <= _daysInMonth; d++) d];
|
|
||||||
|
|
||||||
// 每个下拉用 Expanded 撑满分得的宽度(expandedInsets:zero 让 DropdownMenu 填满父级),
|
|
||||||
// trailingIcon 用紧凑小箭头,避免默认大图标按钮挤掉数字(曾导致「2026」被裁成「007」)。
|
|
||||||
Widget menu({
|
|
||||||
required String label,
|
|
||||||
required int? value,
|
|
||||||
required List<int> items,
|
|
||||||
required ValueChanged<int?> onSel,
|
|
||||||
required FormFieldState<String> field,
|
|
||||||
}) {
|
|
||||||
return DropdownMenu<int>(
|
|
||||||
initialSelection: value,
|
|
||||||
label: Text(label, style: const TextStyle(fontSize: 11)),
|
|
||||||
enableFilter: true,
|
|
||||||
requestFocusOnTap: true,
|
|
||||||
textStyle: const TextStyle(fontSize: 13),
|
|
||||||
menuHeight: 280,
|
|
||||||
expandedInsets: EdgeInsets.zero,
|
|
||||||
trailingIcon: const Icon(Icons.arrow_drop_down, size: 18),
|
|
||||||
selectedTrailingIcon: const Icon(Icons.arrow_drop_up, size: 18),
|
|
||||||
inputDecorationTheme: const InputDecorationTheme(
|
|
||||||
isDense: true,
|
|
||||||
contentPadding: EdgeInsets.symmetric(horizontal: 6, vertical: 8),
|
|
||||||
),
|
|
||||||
dropdownMenuEntries: [
|
|
||||||
for (final i in items) DropdownMenuEntry<int>(value: i, label: '$i'),
|
|
||||||
],
|
|
||||||
onSelected: onSel,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
return FormField<String>(
|
return FormField<String>(
|
||||||
initialValue: widget.value,
|
initialValue: widget.value,
|
||||||
validator: widget.isRequired
|
validator: widget.isRequired
|
||||||
? (v) => (_composed == null ? '请选择日期' : null)
|
? (_) => _normalize(_ctrl.text) == null ? '请输入日期' : null
|
||||||
: null,
|
: null,
|
||||||
builder: (field) {
|
builder: (field) {
|
||||||
return Column(
|
return TextField(
|
||||||
crossAxisAlignment: CrossAxisAlignment.start,
|
controller: _ctrl,
|
||||||
mainAxisSize: MainAxisSize.min,
|
focusNode: _focus,
|
||||||
children: [
|
keyboardType: TextInputType.datetime,
|
||||||
Row(
|
style: const TextStyle(fontSize: 13),
|
||||||
children: [
|
decoration: InputDecoration(
|
||||||
Expanded(
|
isDense: true,
|
||||||
flex: 5,
|
hintText: '年-月-日',
|
||||||
child: menu(
|
hintStyle: const TextStyle(fontSize: 12),
|
||||||
label: '年',
|
contentPadding:
|
||||||
value: _year,
|
const EdgeInsets.symmetric(horizontal: 8, vertical: 8),
|
||||||
items: years,
|
errorText: field.errorText,
|
||||||
field: field,
|
suffixIcon: IconButton(
|
||||||
onSel: (v) {
|
icon: const Icon(Icons.calendar_today,
|
||||||
_year = v;
|
size: 16, color: AppTheme.textSecondary),
|
||||||
_emit(field);
|
padding: EdgeInsets.zero,
|
||||||
},
|
constraints: const BoxConstraints(minWidth: 34, minHeight: 34),
|
||||||
),
|
tooltip: '选择日期',
|
||||||
),
|
onPressed: () => _pickFromCalendar(field),
|
||||||
const SizedBox(width: 6),
|
|
||||||
Expanded(
|
|
||||||
flex: 4,
|
|
||||||
child: menu(
|
|
||||||
label: '月',
|
|
||||||
value: _month,
|
|
||||||
items: months,
|
|
||||||
field: field,
|
|
||||||
onSel: (v) {
|
|
||||||
_month = v;
|
|
||||||
_emit(field);
|
|
||||||
},
|
|
||||||
),
|
|
||||||
),
|
|
||||||
const SizedBox(width: 6),
|
|
||||||
Expanded(
|
|
||||||
flex: 4,
|
|
||||||
child: menu(
|
|
||||||
label: '日',
|
|
||||||
value: _day,
|
|
||||||
items: days,
|
|
||||||
field: field,
|
|
||||||
onSel: (v) {
|
|
||||||
_day = v;
|
|
||||||
_emit(field);
|
|
||||||
},
|
|
||||||
),
|
|
||||||
),
|
|
||||||
],
|
|
||||||
),
|
),
|
||||||
if (field.errorText != null)
|
),
|
||||||
Padding(
|
onChanged: (v) {
|
||||||
padding: const EdgeInsets.only(left: 12, top: 4),
|
final n = _normalize(v);
|
||||||
child: Text(
|
field.didChange(n);
|
||||||
field.errorText!,
|
widget.onChanged(n);
|
||||||
style: const TextStyle(fontSize: 11, color: AppTheme.danger),
|
},
|
||||||
),
|
|
||||||
),
|
|
||||||
],
|
|
||||||
);
|
);
|
||||||
},
|
},
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
import 'dart:async';
|
||||||
|
|
||||||
import '../core/utils/dialog_util.dart';
|
import '../core/utils/dialog_util.dart';
|
||||||
import 'package:flutter/material.dart';
|
import 'package:flutter/material.dart';
|
||||||
import '../core/responsive/responsive.dart';
|
import '../core/responsive/responsive.dart';
|
||||||
@@ -41,6 +43,9 @@ class SearchableOptionField extends StatelessWidget {
|
|||||||
/// 创建成功返回新选项 id(自动选中),失败/取消返回 null。为空则不显示新增入口。
|
/// 创建成功返回新选项 id(自动选中),失败/取消返回 null。为空则不显示新增入口。
|
||||||
final Future<int?> Function(String keyword)? onCreate;
|
final Future<int?> Function(String keyword)? onCreate;
|
||||||
|
|
||||||
|
/// 可选:服务端搜索。提供时搜索框输入会 debounce 调它取结果(替代本地过滤)。
|
||||||
|
final Future<List<OptionItem>> Function(String keyword)? onSearch;
|
||||||
|
|
||||||
const SearchableOptionField({
|
const SearchableOptionField({
|
||||||
super.key,
|
super.key,
|
||||||
required this.options,
|
required this.options,
|
||||||
@@ -51,6 +56,7 @@ class SearchableOptionField extends StatelessWidget {
|
|||||||
this.isRequired = false,
|
this.isRequired = false,
|
||||||
this.isDense = true,
|
this.isDense = true,
|
||||||
this.onCreate,
|
this.onCreate,
|
||||||
|
this.onSearch,
|
||||||
});
|
});
|
||||||
|
|
||||||
String get _displayText {
|
String get _displayText {
|
||||||
@@ -66,6 +72,7 @@ class SearchableOptionField extends StatelessWidget {
|
|||||||
options: options,
|
options: options,
|
||||||
selectedId: selectedId,
|
selectedId: selectedId,
|
||||||
onCreate: onCreate,
|
onCreate: onCreate,
|
||||||
|
onSearch: onSearch,
|
||||||
),
|
),
|
||||||
);
|
);
|
||||||
// result == -1 means "clear selection"
|
// result == -1 means "clear selection"
|
||||||
@@ -120,11 +127,13 @@ class _SearchDialog extends StatefulWidget {
|
|||||||
final List<OptionItem> options;
|
final List<OptionItem> options;
|
||||||
final int? selectedId;
|
final int? selectedId;
|
||||||
final Future<int?> Function(String keyword)? onCreate;
|
final Future<int?> Function(String keyword)? onCreate;
|
||||||
|
final Future<List<OptionItem>> Function(String keyword)? onSearch;
|
||||||
const _SearchDialog({
|
const _SearchDialog({
|
||||||
required this.title,
|
required this.title,
|
||||||
required this.options,
|
required this.options,
|
||||||
this.selectedId,
|
this.selectedId,
|
||||||
this.onCreate,
|
this.onCreate,
|
||||||
|
this.onSearch,
|
||||||
});
|
});
|
||||||
|
|
||||||
@override
|
@override
|
||||||
@@ -135,9 +144,28 @@ class _SearchDialogState extends State<_SearchDialog> {
|
|||||||
final _ctrl = TextEditingController();
|
final _ctrl = TextEditingController();
|
||||||
String _keyword = '';
|
String _keyword = '';
|
||||||
bool _creating = false;
|
bool _creating = false;
|
||||||
|
List<OptionItem>? _serverItems; // 服务端搜索结果(null=尚未搜索,用 widget.options)
|
||||||
|
bool _searching = false;
|
||||||
|
Timer? _debounce;
|
||||||
|
|
||||||
|
void _onSearchChanged(String v) {
|
||||||
|
setState(() => _keyword = v);
|
||||||
|
if (widget.onSearch == null) return;
|
||||||
|
_debounce?.cancel();
|
||||||
|
_debounce = Timer(const Duration(milliseconds: 300), () async {
|
||||||
|
setState(() => _searching = true);
|
||||||
|
try {
|
||||||
|
final res = await widget.onSearch!(v.trim());
|
||||||
|
if (mounted) setState(() => _serverItems = res);
|
||||||
|
} finally {
|
||||||
|
if (mounted) setState(() => _searching = false);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
@override
|
@override
|
||||||
void dispose() {
|
void dispose() {
|
||||||
|
_debounce?.cancel();
|
||||||
_ctrl.dispose();
|
_ctrl.dispose();
|
||||||
super.dispose();
|
super.dispose();
|
||||||
}
|
}
|
||||||
@@ -197,12 +225,14 @@ class _SearchDialogState extends State<_SearchDialog> {
|
|||||||
|
|
||||||
@override
|
@override
|
||||||
Widget build(BuildContext context) {
|
Widget build(BuildContext context) {
|
||||||
final filtered = _keyword.isEmpty
|
final filtered = widget.onSearch != null
|
||||||
? widget.options
|
? (_serverItems ?? widget.options)
|
||||||
: widget.options.where((o) => o.matches(_keyword)).toList();
|
: (_keyword.isEmpty
|
||||||
|
? widget.options
|
||||||
|
: widget.options.where((o) => o.matches(_keyword)).toList());
|
||||||
final kw = _keyword.trim();
|
final kw = _keyword.trim();
|
||||||
final hasExact =
|
final hasExact =
|
||||||
widget.options.any((o) => o.name.toLowerCase() == kw.toLowerCase());
|
filtered.any((o) => o.name.toLowerCase() == kw.toLowerCase());
|
||||||
final canCreate = widget.onCreate != null && kw.isNotEmpty && !hasExact;
|
final canCreate = widget.onCreate != null && kw.isNotEmpty && !hasExact;
|
||||||
|
|
||||||
return AlertDialog(
|
return AlertDialog(
|
||||||
@@ -216,12 +246,22 @@ class _SearchDialogState extends State<_SearchDialog> {
|
|||||||
TextField(
|
TextField(
|
||||||
controller: _ctrl,
|
controller: _ctrl,
|
||||||
autofocus: true,
|
autofocus: true,
|
||||||
decoration: const InputDecoration(
|
decoration: InputDecoration(
|
||||||
hintText: '搜索...',
|
hintText: '搜索...',
|
||||||
prefixIcon: Icon(Icons.search, size: 18),
|
prefixIcon: const Icon(Icons.search, size: 18),
|
||||||
|
suffixIcon: _searching
|
||||||
|
? const Padding(
|
||||||
|
padding: EdgeInsets.all(10),
|
||||||
|
child: SizedBox(
|
||||||
|
width: 16,
|
||||||
|
height: 16,
|
||||||
|
child: CircularProgressIndicator(strokeWidth: 2),
|
||||||
|
),
|
||||||
|
)
|
||||||
|
: null,
|
||||||
isDense: true,
|
isDense: true,
|
||||||
),
|
),
|
||||||
onChanged: (v) => setState(() => _keyword = v),
|
onChanged: _onSearchChanged,
|
||||||
),
|
),
|
||||||
const SizedBox(height: 8),
|
const SizedBox(height: 8),
|
||||||
Expanded(
|
Expanded(
|
||||||
|
|||||||
@@ -31,26 +31,47 @@ void main() {
|
|||||||
});
|
});
|
||||||
|
|
||||||
group('DatePickerField', () {
|
group('DatePickerField', () {
|
||||||
testWidgets('渲染三个年/月/日下拉框', (tester) async {
|
testWidgets('渲染可键入框 + 日历图标', (tester) async {
|
||||||
await tester.pumpWidget(MaterialApp(
|
await tester.pumpWidget(MaterialApp(
|
||||||
home: Scaffold(
|
home: Scaffold(
|
||||||
body: DatePickerField(value: '2026-06-19', onChanged: (_) {}),
|
body: DatePickerField(value: '2026-06-19', onChanged: (_) {}),
|
||||||
),
|
),
|
||||||
));
|
));
|
||||||
await tester.pumpAndSettle();
|
await tester.pumpAndSettle();
|
||||||
expect(find.byType(DropdownMenu<int>), findsNWidgets(3));
|
expect(find.byType(TextField), findsOneWidget);
|
||||||
|
expect(find.byIcon(Icons.calendar_today), findsOneWidget);
|
||||||
});
|
});
|
||||||
|
|
||||||
testWidgets('初始值回显到三个下拉框', (tester) async {
|
testWidgets('初始值回显到输入框', (tester) async {
|
||||||
await tester.pumpWidget(MaterialApp(
|
await tester.pumpWidget(MaterialApp(
|
||||||
home: Scaffold(
|
home: Scaffold(
|
||||||
body: DatePickerField(value: '2026-06-19', onChanged: (_) {}),
|
body: DatePickerField(value: '2026-06-19', onChanged: (_) {}),
|
||||||
),
|
),
|
||||||
));
|
));
|
||||||
await tester.pumpAndSettle();
|
await tester.pumpAndSettle();
|
||||||
expect(find.widgetWithText(DropdownMenu<int>, '2026'), findsOneWidget);
|
expect(find.text('2026-06-19'), findsOneWidget);
|
||||||
expect(find.widgetWithText(DropdownMenu<int>, '6'), findsOneWidget);
|
});
|
||||||
expect(find.widgetWithText(DropdownMenu<int>, '19'), findsOneWidget);
|
|
||||||
|
testWidgets('只输年份归一为 yyyy-01-01', (tester) async {
|
||||||
|
String? out;
|
||||||
|
await tester.pumpWidget(MaterialApp(
|
||||||
|
home: Scaffold(
|
||||||
|
body: DatePickerField(onChanged: (v) => out = v),
|
||||||
|
),
|
||||||
|
));
|
||||||
|
await tester.enterText(find.byType(TextField), '2024');
|
||||||
|
expect(out, '2024-01-01');
|
||||||
|
});
|
||||||
|
|
||||||
|
testWidgets('年月归一为 yyyy-MM-01', (tester) async {
|
||||||
|
String? out;
|
||||||
|
await tester.pumpWidget(MaterialApp(
|
||||||
|
home: Scaffold(
|
||||||
|
body: DatePickerField(onChanged: (v) => out = v),
|
||||||
|
),
|
||||||
|
));
|
||||||
|
await tester.enterText(find.byType(TextField), '2024-5');
|
||||||
|
expect(out, '2024-05-01');
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,41 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
# backup-db.sh — dump the production MySQL (jiu_db) from EC2 and keep a gzip
|
||||||
|
# snapshot on the mac (host) runner's local disk (~/jiu-db-backups), retaining
|
||||||
|
# the last 30 days. The DB password is read on EC2 from production.env's
|
||||||
|
# DATABASE_DSN, so no DB-password secret is needed.
|
||||||
|
#
|
||||||
|
# Requires env (same as deploy-server): EC2_SSH_KEY, EC2_HOST, EC2_USER.
|
||||||
|
set -euo pipefail
|
||||||
|
|
||||||
|
# shellcheck source=scripts/ci/lib-forgejo.sh
|
||||||
|
. "$(dirname "$0")/lib-forgejo.sh"
|
||||||
|
|
||||||
|
BACKUP_DIR="${HOME}/jiu-db-backups"
|
||||||
|
mkdir -p "${BACKUP_DIR}"
|
||||||
|
FILENAME="jiu_db_$(date +%Y%m%d_%H%M%S).sql.gz"
|
||||||
|
DEST="${BACKUP_DIR}/${FILENAME}"
|
||||||
|
|
||||||
|
setup_ssh
|
||||||
|
trap teardown_ssh EXIT
|
||||||
|
|
||||||
|
echo "==> backup-db: dumping jiu_db from ${EC2_HOST}"
|
||||||
|
# On EC2: parse the DSN password from production.env, then mysqldump the
|
||||||
|
# container to stdout; stream back over ssh and gzip locally. The heredoc is
|
||||||
|
# single-quoted, so it runs verbatim on EC2 (no local expansion). ${SSH} carries
|
||||||
|
# no -t, keeping stdout a clean dump stream.
|
||||||
|
${SSH} "${EC2_USER}@${EC2_HOST}" 'bash -s' <<'ENDSSH' | gzip > "${DEST}"
|
||||||
|
set -euo pipefail
|
||||||
|
PW=$(python3 -c 'import re;e=open("/opt/jiu/config/production.env").read();d=re.search(r"DATABASE_DSN=(.*)",e).group(1).strip().strip(chr(34)).strip(chr(39));print(re.match(r"[^:]+:([^@]+)@",d).group(1))')
|
||||||
|
exec docker exec -e MYSQL_PWD="${PW}" jiu_mysql mysqldump -uroot --single-transaction --no-tablespaces jiu_db
|
||||||
|
ENDSSH
|
||||||
|
|
||||||
|
# Integrity + sanity + retention.
|
||||||
|
gzip -t "${DEST}"
|
||||||
|
SIZE=$(stat -f%z "${DEST}" 2>/dev/null || stat -c%s "${DEST}")
|
||||||
|
if [ "${SIZE}" -lt 100000 ]; then
|
||||||
|
echo "==> backup-db: dump suspiciously small (${SIZE} bytes), aborting" >&2
|
||||||
|
rm -f "${DEST}"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
find "${BACKUP_DIR}" -name '*.sql.gz' -mtime +30 -delete
|
||||||
|
echo "==> backup-db: saved ${DEST} (${SIZE} bytes)"
|
||||||
Reference in New Issue
Block a user