Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 1a1d9aa15e | |||
| 71ed15b40b | |||
| fb1e637ce4 | |||
| 7f3261a4a9 |
@@ -5,6 +5,12 @@ 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.64] - 2026-06-20
|
||||||
|
|
||||||
|
### 新功能
|
||||||
|
- 入库单 / 出库单列表新增搜索框:输入单号或往来单位名称即可即时筛选,不用再翻页查找
|
||||||
|
- 入库 / 出库 / 库存三个列表均新增刷新按钮:多端并发录入后可一键同步最新数据
|
||||||
|
|
||||||
## [1.0.63] - 2026-06-20
|
## [1.0.63] - 2026-06-20
|
||||||
|
|
||||||
### 修复
|
### 修复
|
||||||
|
|||||||
@@ -5,6 +5,25 @@
|
|||||||
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.68] - 2026-06-21
|
||||||
|
|
||||||
|
### 修复
|
||||||
|
- 根治商品编码可能重复的问题:自动编码改为按现有最大序号递增生成(不再复用已删除商品占用过的编号、并发下也不会撞号),并在数据库层为「同门店 + 编码」加唯一约束,从此重复编码无法静默产生
|
||||||
|
|
||||||
|
## [1.0.67] - 2026-06-20
|
||||||
|
|
||||||
|
### 修复
|
||||||
|
- 历史导入单审核入库后,库存里商品显示为「历史导入占位」、按真实名搜不到的问题:审核生成库存时改用单据明细自带的真实商品名/编码/系列/规格,库存列表也不再显示已删除的占位商品名
|
||||||
|
- 库存列表按真实商品名/编码即可搜到这些历史商品
|
||||||
|
|
||||||
|
### 新功能
|
||||||
|
- 入库单 / 出库单列表支持关键词搜索:按单号或往来单位名称即时筛选
|
||||||
|
|
||||||
|
## [1.0.66] - 2026-06-20
|
||||||
|
|
||||||
|
### 修复
|
||||||
|
- 入库/出库单据列表改为按业务日期(入库/出库日期)倒序排列:从旧系统迁入的历史单据按真实日期归位到列表顶部,不再因录入时间晚、被排到末尾分页而在首页遗漏
|
||||||
|
|
||||||
## [1.0.65] - 2026-06-20
|
## [1.0.65] - 2026-06-20
|
||||||
|
|
||||||
### 修复
|
### 修复
|
||||||
|
|||||||
@@ -68,7 +68,7 @@ func (h *InventoryHandler) List(c *gin.Context) {
|
|||||||
specStr := c.Query("spec")
|
specStr := c.Query("spec")
|
||||||
|
|
||||||
if keyword != "" {
|
if keyword != "" {
|
||||||
baseWhere += " AND (COALESCE(NULLIF(p.name,''), inv.product_name) LIKE ? OR COALESCE(NULLIF(p.code,''), inv.product_code) LIKE ? OR p.name_pinyin LIKE ? OR p.name_initials LIKE ?)"
|
baseWhere += " AND (COALESCE(NULLIF(p.name,''), NULLIF(sii.product_name,''), inv.product_name) LIKE ? OR COALESCE(NULLIF(p.code,''), NULLIF(sii.product_code,''), inv.product_code) LIKE ? OR p.name_pinyin LIKE ? OR p.name_initials LIKE ?)"
|
||||||
like := "%" + keyword + "%"
|
like := "%" + keyword + "%"
|
||||||
args = append(args, like, like, like, like)
|
args = append(args, like, like, like, like)
|
||||||
}
|
}
|
||||||
@@ -101,7 +101,7 @@ func (h *InventoryHandler) List(c *gin.Context) {
|
|||||||
SELECT COUNT(*)
|
SELECT COUNT(*)
|
||||||
FROM inventories inv
|
FROM inventories inv
|
||||||
LEFT JOIN stock_in_items sii ON sii.id = inv.stock_in_item_id
|
LEFT JOIN stock_in_items sii ON sii.id = inv.stock_in_item_id
|
||||||
LEFT JOIN products p ON p.id = inv.product_id
|
LEFT JOIN products p ON p.id = inv.product_id AND p.deleted_at IS NULL
|
||||||
LEFT JOIN warehouses w ON w.id = inv.warehouse_id
|
LEFT JOIN warehouses w ON w.id = inv.warehouse_id
|
||||||
WHERE ` + baseWhere
|
WHERE ` + baseWhere
|
||||||
|
|
||||||
@@ -116,10 +116,10 @@ func (h *InventoryHandler) List(c *gin.Context) {
|
|||||||
SELECT
|
SELECT
|
||||||
inv.id, inv.shop_id, inv.warehouse_id, inv.product_id, inv.stock_in_item_id,
|
inv.id, inv.shop_id, inv.warehouse_id, inv.product_id, inv.stock_in_item_id,
|
||||||
inv.quantity,
|
inv.quantity,
|
||||||
COALESCE(NULLIF(p.code,''), inv.product_code, '') AS product_code,
|
COALESCE(NULLIF(p.code,''), NULLIF(sii.product_code,''), inv.product_code, '') AS product_code,
|
||||||
COALESCE(NULLIF(p.name,''), inv.product_name, '') AS product_name,
|
COALESCE(NULLIF(p.name,''), NULLIF(sii.product_name,''), inv.product_name, '') AS product_name,
|
||||||
COALESCE(NULLIF(p.series,''), inv.series, '') AS series,
|
COALESCE(NULLIF(p.series,''), NULLIF(sii.series,''), inv.series, '') AS series,
|
||||||
COALESCE(NULLIF(p.spec,''), inv.spec, '') AS spec,
|
COALESCE(NULLIF(p.spec,''), NULLIF(sii.spec,''), inv.spec, '') AS spec,
|
||||||
COALESCE(NULLIF(p.unit,''), inv.unit, '') AS unit,
|
COALESCE(NULLIF(p.unit,''), inv.unit, '') AS unit,
|
||||||
COALESCE(NULLIF(w.name,''), inv.warehouse_name, '') AS warehouse_name,
|
COALESCE(NULLIF(w.name,''), inv.warehouse_name, '') AS warehouse_name,
|
||||||
COALESCE(sii.unit_price, inv.unit_price) AS unit_price,
|
COALESCE(sii.unit_price, inv.unit_price) AS unit_price,
|
||||||
@@ -132,7 +132,7 @@ func (h *InventoryHandler) List(c *gin.Context) {
|
|||||||
inv.created_at
|
inv.created_at
|
||||||
FROM inventories inv
|
FROM inventories inv
|
||||||
LEFT JOIN stock_in_items sii ON sii.id = inv.stock_in_item_id
|
LEFT JOIN stock_in_items sii ON sii.id = inv.stock_in_item_id
|
||||||
LEFT JOIN products p ON p.id = inv.product_id
|
LEFT JOIN products p ON p.id = inv.product_id AND p.deleted_at IS NULL
|
||||||
LEFT JOIN warehouses w ON w.id = inv.warehouse_id
|
LEFT JOIN warehouses w ON w.id = inv.warehouse_id
|
||||||
WHERE ` + baseWhere + `
|
WHERE ` + baseWhere + `
|
||||||
ORDER BY inv.id DESC
|
ORDER BY inv.id DESC
|
||||||
|
|||||||
@@ -219,6 +219,52 @@ func TestInventoryHandler_List_HotelIsolation(t *testing.T) {
|
|||||||
assert.Equal(t, float64(0), respB["total"].(float64))
|
assert.Equal(t, float64(0), respB["total"].(float64))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 库存指向已软删的占位商品时,列表应回退到明细/库存快照真名,
|
||||||
|
// 而非占位商品名「历史导入占位」,且能按真名搜索到。
|
||||||
|
func TestInventoryHandler_List_DeletedProductFallsBackToSnapshot(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "INV009")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
warehouse := testutil.CreateTestWarehouse(db, shop.ID, "Warehouse")
|
||||||
|
placeholder := testutil.CreateTestProduct(db, shop.ID, "历史导入占位")
|
||||||
|
token := getAuthToken(user.ID, shop.ID, "admin")
|
||||||
|
r := setupProtectedRouter(db)
|
||||||
|
|
||||||
|
// 明细携带真实快照名
|
||||||
|
item := model.StockInItem{
|
||||||
|
ShopID: shop.ID,
|
||||||
|
ProductID: placeholder.ID,
|
||||||
|
ProductCode: "ZXZ029751",
|
||||||
|
ProductName: "贵州茅台酒2006",
|
||||||
|
Quantity: 10,
|
||||||
|
}
|
||||||
|
require.NoError(t, db.Create(&item).Error)
|
||||||
|
|
||||||
|
// 库存:product_id 指向占位商品,且 product_name 也是占位名(模拟旧脏数据)
|
||||||
|
require.NoError(t, db.Create(&model.Inventory{
|
||||||
|
ShopID: shop.ID,
|
||||||
|
WarehouseID: &warehouse.ID,
|
||||||
|
ProductID: &placeholder.ID,
|
||||||
|
StockInItemID: &item.ID,
|
||||||
|
ProductName: "历史导入占位",
|
||||||
|
Quantity: 10,
|
||||||
|
}).Error)
|
||||||
|
|
||||||
|
// 软删占位商品
|
||||||
|
require.NoError(t, db.Delete(&placeholder).Error)
|
||||||
|
|
||||||
|
// 列表:名称应回退到明细快照真名
|
||||||
|
w := makeRequest(r, "GET", "/api/v1/inventory", token, nil)
|
||||||
|
resp := parseResponse(w)
|
||||||
|
require.Equal(t, float64(1), resp["total"].(float64))
|
||||||
|
invItem := resp["data"].([]interface{})[0].(map[string]interface{})
|
||||||
|
assert.Equal(t, "贵州茅台酒2006", invItem["product_name"])
|
||||||
|
|
||||||
|
// 按真名可搜到
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/inventory?keyword=茅台", token, nil)
|
||||||
|
assert.Equal(t, float64(1), parseResponse(w)["total"].(float64))
|
||||||
|
}
|
||||||
|
|
||||||
func TestInventoryHandler_AfterStockInApprove(t *testing.T) {
|
func TestInventoryHandler_AfterStockInApprove(t *testing.T) {
|
||||||
db := testutil.SetupTestDB()
|
db := testutil.SetupTestDB()
|
||||||
shop := testutil.CreateTestShop(db, "INV008")
|
shop := testutil.CreateTestShop(db, "INV008")
|
||||||
|
|||||||
@@ -62,6 +62,29 @@ func (h *ProductHandler) List(c *gin.Context) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// nextProductCode 生成该门店下一个自动商品编码(P001、P002…)。
|
||||||
|
// 取现有 P 开头编码的最大数字序号 +1,**含软删行**(deleted_at 非空也计入,不复用已删商品占用过的号)。
|
||||||
|
// 不加行锁——并发下两请求可能算出同号,由 uk_shop_code 唯一约束 + 调用方 ErrDuplicatedKey 重试兜底。
|
||||||
|
// 用 GORM 表达式(非 MySQL 方言 SQL),sqlite 单测也能跑。
|
||||||
|
func nextProductCode(tx *gorm.DB, shopID uint64) (string, error) {
|
||||||
|
var codes []string
|
||||||
|
if err := tx.Model(&model.Product{}).
|
||||||
|
Where("shop_id = ? AND code LIKE 'P%'", shopID).
|
||||||
|
Pluck("code", &codes).Error; err != nil {
|
||||||
|
return "", err
|
||||||
|
}
|
||||||
|
maxN := 0
|
||||||
|
for _, c := range codes {
|
||||||
|
if len(c) < 2 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
if n, err := strconv.Atoi(c[1:]); err == nil && n > maxN {
|
||||||
|
maxN = n
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return fmt.Sprintf("P%03d", maxN+1), 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)
|
||||||
@@ -74,31 +97,24 @@ func (h *ProductHandler) Create(c *gin.Context) {
|
|||||||
product.PublicID = uuid.New().String()
|
product.PublicID = uuid.New().String()
|
||||||
product.NamePinyin, product.NameInitials = util.ToPinyin(product.Name)
|
product.NamePinyin, product.NameInitials = util.ToPinyin(product.Name)
|
||||||
|
|
||||||
// Auto-generate product code if not provided (e.g. P001, P002)
|
// 未显式指定编码时自动生成(事务内 max+1);撞 uk_shop_code 唯一约束则重算下一号重试(应对并发)。
|
||||||
// Retry up to 5 times on duplicate key to handle concurrent creates
|
autoCode := product.Code == ""
|
||||||
if product.Code == "" {
|
|
||||||
var count int64
|
|
||||||
h.db.Model(&model.Product{}).
|
|
||||||
Where("shop_id = ? AND deleted_at IS NULL", shopID).
|
|
||||||
Count(&count)
|
|
||||||
product.Code = fmt.Sprintf("P%03d", count+1)
|
|
||||||
}
|
|
||||||
|
|
||||||
var createErr error
|
var createErr error
|
||||||
for attempt := 0; attempt < 5; attempt++ {
|
for attempt := 0; attempt < 5; attempt++ {
|
||||||
if createErr = h.db.Create(&product).Error; createErr == nil {
|
createErr = h.db.Transaction(func(tx *gorm.DB) error {
|
||||||
|
if autoCode {
|
||||||
|
code, err := nextProductCode(tx, shopID)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
product.Code = code
|
||||||
|
}
|
||||||
|
product.ID = 0
|
||||||
|
return tx.Create(&product).Error
|
||||||
|
})
|
||||||
|
if createErr == nil || !autoCode || !errors.Is(createErr, gorm.ErrDuplicatedKey) {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
if !errors.Is(createErr, gorm.ErrDuplicatedKey) {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
// Duplicate code: try next slot
|
|
||||||
var count int64
|
|
||||||
h.db.Model(&model.Product{}).
|
|
||||||
Where("shop_id = ? AND deleted_at IS NULL", shopID).
|
|
||||||
Count(&count)
|
|
||||||
product.ID = 0
|
|
||||||
product.Code = fmt.Sprintf("P%03d", count+int64(attempt)+2)
|
|
||||||
}
|
}
|
||||||
if createErr != nil {
|
if createErr != nil {
|
||||||
c.JSON(http.StatusInternalServerError, gin.H{"error": createErr.Error()})
|
c.JSON(http.StatusInternalServerError, gin.H{"error": createErr.Error()})
|
||||||
@@ -256,25 +272,37 @@ func (h *ProductHandler) FindOrCreate(c *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
var count int64
|
|
||||||
h.db.Model(&model.Product{}).Where("shop_id = ? AND deleted_at IS NULL", shopID).Count(&count)
|
|
||||||
namePinyin, nameInitials := util.ToPinyin(req.Name)
|
namePinyin, nameInitials := util.ToPinyin(req.Name)
|
||||||
product = model.Product{
|
// 事务内 max+1 生成编码;撞 uk_shop_code 唯一约束则重算下一号重试(应对并发)。
|
||||||
TenantBase: model.TenantBase{ShopID: shopID},
|
var createErr error
|
||||||
PublicID: uuid.New().String(),
|
for attempt := 0; attempt < 5; attempt++ {
|
||||||
Name: req.Name,
|
createErr = h.db.Transaction(func(tx *gorm.DB) error {
|
||||||
Series: req.Series,
|
code, err := nextProductCode(tx, shopID)
|
||||||
Spec: req.Spec,
|
if err != nil {
|
||||||
Code: fmt.Sprintf("P%03d", count+1),
|
return err
|
||||||
NamePinyin: namePinyin,
|
}
|
||||||
NameInitials: nameInitials,
|
product = model.Product{
|
||||||
OriginID: req.OriginID,
|
TenantBase: model.TenantBase{ShopID: shopID},
|
||||||
ShelfLifeID: req.ShelfLifeID,
|
PublicID: uuid.New().String(),
|
||||||
StorageID: req.StorageID,
|
Name: req.Name,
|
||||||
DescriptionDocID: req.DescriptionDocID,
|
Series: req.Series,
|
||||||
|
Spec: req.Spec,
|
||||||
|
Code: code,
|
||||||
|
NamePinyin: namePinyin,
|
||||||
|
NameInitials: nameInitials,
|
||||||
|
OriginID: req.OriginID,
|
||||||
|
ShelfLifeID: req.ShelfLifeID,
|
||||||
|
StorageID: req.StorageID,
|
||||||
|
DescriptionDocID: req.DescriptionDocID,
|
||||||
|
}
|
||||||
|
return tx.Create(&product).Error
|
||||||
|
})
|
||||||
|
if createErr == nil || !errors.Is(createErr, gorm.ErrDuplicatedKey) {
|
||||||
|
break
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if createErr := h.db.Create(&product).Error; createErr != nil {
|
if createErr != nil {
|
||||||
// Race condition: try to find the record created by another request
|
// Race condition: 并发可能已按同 name/series/spec 建好,回查返回既有
|
||||||
if h.db.Where("shop_id = ? AND name = ? AND series = ? AND spec = ? AND deleted_at IS NULL",
|
if h.db.Where("shop_id = ? AND name = ? AND series = ? AND spec = ? AND deleted_at IS NULL",
|
||||||
shopID, req.Name, req.Series, req.Spec).First(&product).Error == nil {
|
shopID, req.Name, req.Series, req.Spec).First(&product).Error == nil {
|
||||||
util.RespondSuccess(c, product)
|
util.RespondSuccess(c, product)
|
||||||
|
|||||||
@@ -2,13 +2,16 @@ package handler
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"net/http"
|
"net/http"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/stretchr/testify/assert"
|
"github.com/stretchr/testify/assert"
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
|
||||||
|
"github.com/wangjia/jiu/backend/internal/model"
|
||||||
"github.com/wangjia/jiu/backend/testutil"
|
"github.com/wangjia/jiu/backend/testutil"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -199,3 +202,67 @@ func TestProductHandler_Create_ShopIDFromToken(t *testing.T) {
|
|||||||
dataBytes, _ := json.Marshal(data)
|
dataBytes, _ := json.Marshal(data)
|
||||||
_ = dataBytes
|
_ = dataBytes
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 自动编码按最大序号递增:P001 → P002 → P003。
|
||||||
|
func TestProductHandler_AutoCode_Increment(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "AC001")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
token := getAuthToken(user.ID, shop.ID, "admin")
|
||||||
|
r := setupProtectedRouter(db)
|
||||||
|
|
||||||
|
var codes []string
|
||||||
|
for i := 0; i < 3; i++ {
|
||||||
|
w := makeRequest(r, "POST", "/api/v1/products", token, map[string]interface{}{
|
||||||
|
"name": fmt.Sprintf("AutoP %d", i), "unit": "个",
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
data := parseResponse(w)["data"].(map[string]interface{})
|
||||||
|
codes = append(codes, data["code"].(string))
|
||||||
|
}
|
||||||
|
assert.Equal(t, []string{"P001", "P002", "P003"}, codes)
|
||||||
|
}
|
||||||
|
|
||||||
|
// 软删商品后,新建不复用被删的号(旧 count+1 逻辑会复用 → 重复,此为根因修复回归测试)。
|
||||||
|
func TestProductHandler_AutoCode_NoReuseAfterSoftDelete(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "AC002")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
token := getAuthToken(user.ID, shop.ID, "admin")
|
||||||
|
r := setupProtectedRouter(db)
|
||||||
|
|
||||||
|
var lastID uint64
|
||||||
|
for i := 0; i < 3; i++ { // P001 P002 P003
|
||||||
|
w := makeRequest(r, "POST", "/api/v1/products", token, map[string]interface{}{
|
||||||
|
"name": fmt.Sprintf("NR %d", i), "unit": "个",
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
lastID = extractID(w)
|
||||||
|
}
|
||||||
|
// 软删 P003
|
||||||
|
w := makeRequest(r, "DELETE", fmt.Sprintf("/api/v1/products/%d", lastID), token, nil)
|
||||||
|
require.Equal(t, http.StatusOK, w.Code)
|
||||||
|
|
||||||
|
// 再建 → 必须是 P004,不能复用已软删的 P003
|
||||||
|
w = makeRequest(r, "POST", "/api/v1/products", token, map[string]interface{}{
|
||||||
|
"name": "NR new", "unit": "个",
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
data := parseResponse(w)["data"].(map[string]interface{})
|
||||||
|
assert.Equal(t, "P004", data["code"])
|
||||||
|
}
|
||||||
|
|
||||||
|
// (shop_id, code) 唯一约束生效,且重复被翻译成 gorm.ErrDuplicatedKey(Create/FindOrCreate 重试的前提)。
|
||||||
|
func TestProductHandler_UniqueShopCode(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "UQ001")
|
||||||
|
require.NoError(t, db.Exec("CREATE UNIQUE INDEX uk_shop_code ON products(shop_id, code)").Error)
|
||||||
|
|
||||||
|
p1 := model.Product{TenantBase: model.TenantBase{ShopID: shop.ID}, Name: "A", Code: "P001"}
|
||||||
|
require.NoError(t, db.Create(&p1).Error)
|
||||||
|
|
||||||
|
p2 := model.Product{TenantBase: model.TenantBase{ShopID: shop.ID}, Name: "B", Code: "P001"}
|
||||||
|
err := db.Create(&p2).Error
|
||||||
|
require.Error(t, err)
|
||||||
|
assert.True(t, errors.Is(err, gorm.ErrDuplicatedKey))
|
||||||
|
}
|
||||||
|
|||||||
@@ -49,6 +49,13 @@ func (h *StockInHandler) List(c *gin.Context) {
|
|||||||
if endDate := c.Query("end_date"); endDate != "" {
|
if endDate := c.Query("end_date"); endDate != "" {
|
||||||
query = query.Where("order_date <= ?", endDate)
|
query = query.Where("order_date <= ?", endDate)
|
||||||
}
|
}
|
||||||
|
if kw := strings.TrimSpace(c.Query("keyword")); kw != "" {
|
||||||
|
like := "%" + kw + "%"
|
||||||
|
query = query.Where(
|
||||||
|
"order_no LIKE ? OR partner_id IN (SELECT id FROM partners WHERE shop_id = ? AND name LIKE ?)",
|
||||||
|
like, shopID, like,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
var total int64
|
var total int64
|
||||||
query.Count(&total)
|
query.Count(&total)
|
||||||
@@ -56,7 +63,7 @@ func (h *StockInHandler) List(c *gin.Context) {
|
|||||||
orders := make([]model.StockInOrder, 0)
|
orders := make([]model.StockInOrder, 0)
|
||||||
query.Preload("Warehouse").Preload("Partner").Preload("Operator").Preload("Reviewer").
|
query.Preload("Warehouse").Preload("Partner").Preload("Operator").Preload("Reviewer").
|
||||||
Offset((page - 1) * pageSize).Limit(pageSize).
|
Offset((page - 1) * pageSize).Limit(pageSize).
|
||||||
Order("id DESC").Find(&orders)
|
Order("order_date DESC, id DESC").Find(&orders)
|
||||||
|
|
||||||
c.JSON(http.StatusOK, gin.H{"data": orders, "total": total, "page": page, "page_size": pageSize})
|
c.JSON(http.StatusOK, gin.H{"data": orders, "total": total, "page": page, "page_size": pageSize})
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -308,6 +308,51 @@ func TestStockInHandler_Reject_NotPending(t *testing.T) {
|
|||||||
assert.Equal(t, http.StatusBadRequest, w.Code)
|
assert.Equal(t, http.StatusBadRequest, w.Code)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestStockInHandler_List_FilterByKeyword(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "SI011")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
warehouse := testutil.CreateTestWarehouse(db, shop.ID, "Warehouse")
|
||||||
|
product := testutil.CreateTestProduct(db, shop.ID, "Brandy")
|
||||||
|
token := getAuthToken(user.ID, shop.ID, "admin")
|
||||||
|
r := setupProtectedRouter(db)
|
||||||
|
|
||||||
|
// 往来单位:茅台供应商
|
||||||
|
partner := &model.Partner{Code: "P001", Name: "茅台供应商", Type: "supplier"}
|
||||||
|
partner.ShopID = shop.ID
|
||||||
|
require.NoError(t, db.Create(partner).Error)
|
||||||
|
|
||||||
|
// 单据1:挂往来单位
|
||||||
|
w := makeRequest(r, "POST", "/api/v1/stock-in/orders", token, map[string]interface{}{
|
||||||
|
"warehouse_id": warehouse.ID,
|
||||||
|
"partner_id": partner.ID,
|
||||||
|
"order_date": time.Now().Format(time.RFC3339),
|
||||||
|
"items": []map[string]interface{}{{"product_id": product.ID, "quantity": 5.0}},
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
order1No := parseResponse(w)["data"].(map[string]interface{})["order_no"].(string)
|
||||||
|
|
||||||
|
// 单据2:无往来单位
|
||||||
|
w = makeRequest(r, "POST", "/api/v1/stock-in/orders", token, map[string]interface{}{
|
||||||
|
"warehouse_id": warehouse.ID,
|
||||||
|
"order_date": time.Now().Format(time.RFC3339),
|
||||||
|
"items": []map[string]interface{}{{"product_id": product.ID, "quantity": 3.0}},
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
|
||||||
|
// 按往来单位名搜索 → 只命中单据1
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/stock-in/orders?keyword=茅台", token, nil)
|
||||||
|
assert.Equal(t, float64(1), parseResponse(w)["total"].(float64))
|
||||||
|
|
||||||
|
// 按单号搜索 → 只命中单据1
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/stock-in/orders?keyword="+order1No, token, nil)
|
||||||
|
assert.Equal(t, float64(1), parseResponse(w)["total"].(float64))
|
||||||
|
|
||||||
|
// 无关键词 → 两条都在
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/stock-in/orders", token, nil)
|
||||||
|
assert.Equal(t, float64(2), parseResponse(w)["total"].(float64))
|
||||||
|
}
|
||||||
|
|
||||||
func TestStockInHandler_List_FilterByStatus(t *testing.T) {
|
func TestStockInHandler_List_FilterByStatus(t *testing.T) {
|
||||||
db := testutil.SetupTestDB()
|
db := testutil.SetupTestDB()
|
||||||
shop := testutil.CreateTestShop(db, "SI010")
|
shop := testutil.CreateTestShop(db, "SI010")
|
||||||
|
|||||||
@@ -42,6 +42,13 @@ func (h *StockOutHandler) List(c *gin.Context) {
|
|||||||
if endDate := c.Query("end_date"); endDate != "" {
|
if endDate := c.Query("end_date"); endDate != "" {
|
||||||
query = query.Where("order_date <= ?", endDate)
|
query = query.Where("order_date <= ?", endDate)
|
||||||
}
|
}
|
||||||
|
if kw := strings.TrimSpace(c.Query("keyword")); kw != "" {
|
||||||
|
like := "%" + kw + "%"
|
||||||
|
query = query.Where(
|
||||||
|
"order_no LIKE ? OR partner_id IN (SELECT id FROM partners WHERE shop_id = ? AND name LIKE ?)",
|
||||||
|
like, shopID, like,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
var total int64
|
var total int64
|
||||||
query.Count(&total)
|
query.Count(&total)
|
||||||
@@ -49,7 +56,7 @@ func (h *StockOutHandler) List(c *gin.Context) {
|
|||||||
orders := make([]model.StockOutOrder, 0)
|
orders := make([]model.StockOutOrder, 0)
|
||||||
query.Preload("Warehouse").Preload("Partner").Preload("Operator").Preload("Reviewer").
|
query.Preload("Warehouse").Preload("Partner").Preload("Operator").Preload("Reviewer").
|
||||||
Offset((page - 1) * pageSize).Limit(pageSize).
|
Offset((page - 1) * pageSize).Limit(pageSize).
|
||||||
Order("id DESC").Find(&orders)
|
Order("order_date DESC, id DESC").Find(&orders)
|
||||||
|
|
||||||
c.JSON(http.StatusOK, gin.H{"data": orders, "total": total, "page": page, "page_size": pageSize})
|
c.JSON(http.StatusOK, gin.H{"data": orders, "total": total, "page": page, "page_size": pageSize})
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -133,6 +133,51 @@ func TestStockOutHandler_List(t *testing.T) {
|
|||||||
assert.Equal(t, float64(2), resp["total"].(float64))
|
assert.Equal(t, float64(2), resp["total"].(float64))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestStockOutHandler_List_FilterByKeyword(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "SO011")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
warehouse := testutil.CreateTestWarehouse(db, shop.ID, "Warehouse")
|
||||||
|
product := testutil.CreateTestProduct(db, shop.ID, "Beer")
|
||||||
|
token := getAuthToken(user.ID, shop.ID, "admin")
|
||||||
|
r := setupProtectedRouter(db)
|
||||||
|
|
||||||
|
// 往来单位:海底捞客户
|
||||||
|
partner := &model.Partner{Code: "C001", Name: "海底捞客户", Type: "customer"}
|
||||||
|
partner.ShopID = shop.ID
|
||||||
|
require.NoError(t, db.Create(partner).Error)
|
||||||
|
|
||||||
|
// 单据1:挂往来单位
|
||||||
|
w := makeRequest(r, "POST", "/api/v1/stock-out/orders", token, map[string]interface{}{
|
||||||
|
"warehouse_id": warehouse.ID,
|
||||||
|
"partner_id": partner.ID,
|
||||||
|
"order_date": time.Now().Format(time.RFC3339),
|
||||||
|
"items": []map[string]interface{}{{"product_id": product.ID, "quantity": 1.0}},
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
order1No := parseResponse(w)["data"].(map[string]interface{})["order_no"].(string)
|
||||||
|
|
||||||
|
// 单据2:无往来单位
|
||||||
|
w = makeRequest(r, "POST", "/api/v1/stock-out/orders", token, map[string]interface{}{
|
||||||
|
"warehouse_id": warehouse.ID,
|
||||||
|
"order_date": time.Now().Format(time.RFC3339),
|
||||||
|
"items": []map[string]interface{}{{"product_id": product.ID, "quantity": 1.0}},
|
||||||
|
})
|
||||||
|
require.Equal(t, http.StatusCreated, w.Code)
|
||||||
|
|
||||||
|
// 按往来单位名搜索
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/stock-out/orders?keyword=海底捞", token, nil)
|
||||||
|
assert.Equal(t, float64(1), parseResponse(w)["total"].(float64))
|
||||||
|
|
||||||
|
// 按单号搜索
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/stock-out/orders?keyword="+order1No, token, nil)
|
||||||
|
assert.Equal(t, float64(1), parseResponse(w)["total"].(float64))
|
||||||
|
|
||||||
|
// 无关键词
|
||||||
|
w = makeRequest(r, "GET", "/api/v1/stock-out/orders", token, nil)
|
||||||
|
assert.Equal(t, float64(2), parseResponse(w)["total"].(float64))
|
||||||
|
}
|
||||||
|
|
||||||
func TestStockOutHandler_Reject(t *testing.T) {
|
func TestStockOutHandler_Reject(t *testing.T) {
|
||||||
db := testutil.SetupTestDB()
|
db := testutil.SetupTestDB()
|
||||||
shop := testutil.CreateTestShop(db, "SO004")
|
shop := testutil.CreateTestShop(db, "SO004")
|
||||||
|
|||||||
@@ -10,6 +10,8 @@ type ProductCategory struct {
|
|||||||
type Product struct {
|
type Product struct {
|
||||||
TenantBase
|
TenantBase
|
||||||
PublicID string `gorm:"size:36;uniqueIndex" json:"public_id"`
|
PublicID string `gorm:"size:36;uniqueIndex" json:"public_id"`
|
||||||
|
// Code 商品编码:同店内唯一。(shop_id, code) 联合唯一索引 uk_shop_code 由 autoMigrate 显式建(见 main.go),
|
||||||
|
// 不在此用 tag 声明——ShopID 在共用 TenantBase 上,tag 只能建单列索引会破坏多租户隔离。
|
||||||
Code string `gorm:"size:50" json:"code"`
|
Code string `gorm:"size:50" json:"code"`
|
||||||
Barcode string `gorm:"size:100" json:"barcode"`
|
Barcode string `gorm:"size:100" json:"barcode"`
|
||||||
Name string `gorm:"size:200;not null" json:"name"`
|
Name string `gorm:"size:200;not null" json:"name"`
|
||||||
|
|||||||
@@ -64,16 +64,26 @@ func (s *StockService) ApproveStockIn(shopID, orderID, reviewerID uint64) error
|
|||||||
unitPricePtr = &itemCopy.UnitPrice
|
unitPricePtr = &itemCopy.UnitPrice
|
||||||
}
|
}
|
||||||
|
|
||||||
productCode := ""
|
// 优先使用明细自带快照列(历史导入单的真实商品信息在此),
|
||||||
productName := ""
|
// Product 关联仅作兜底(普通 UI 录入单的明细快照为空)。
|
||||||
series := ""
|
productCode := itemCopy.ProductCode
|
||||||
spec := ""
|
productName := itemCopy.ProductName
|
||||||
|
series := itemCopy.Series
|
||||||
|
spec := itemCopy.Spec
|
||||||
unit := ""
|
unit := ""
|
||||||
if itemCopy.Product != nil {
|
if itemCopy.Product != nil {
|
||||||
productCode = itemCopy.Product.Code
|
if productCode == "" {
|
||||||
productName = itemCopy.Product.Name
|
productCode = itemCopy.Product.Code
|
||||||
series = itemCopy.Product.Series
|
}
|
||||||
spec = itemCopy.Product.Spec
|
if productName == "" {
|
||||||
|
productName = itemCopy.Product.Name
|
||||||
|
}
|
||||||
|
if series == "" {
|
||||||
|
series = itemCopy.Product.Series
|
||||||
|
}
|
||||||
|
if spec == "" {
|
||||||
|
spec = itemCopy.Product.Spec
|
||||||
|
}
|
||||||
unit = itemCopy.Product.Unit
|
unit = itemCopy.Product.Unit
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -65,6 +65,47 @@ func TestStockService_ApproveStockIn_Success(t *testing.T) {
|
|||||||
assert.Equal(t, float64(10), logs[0].QtyAfter)
|
assert.Equal(t, float64(10), logs[0].QtyAfter)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 历史导入单:明细自带真实快照名,product_id 指向占位商品(名「历史导入占位」)。
|
||||||
|
// 审核生成的库存应使用明细快照真名,而非占位商品名。
|
||||||
|
func TestStockService_ApproveStockIn_PrefersItemSnapshot(t *testing.T) {
|
||||||
|
db := testutil.SetupTestDB()
|
||||||
|
shop := testutil.CreateTestShop(db, "STOCK009")
|
||||||
|
warehouse := testutil.CreateTestWarehouse(db, shop.ID, "Warehouse")
|
||||||
|
placeholder := testutil.CreateTestProduct(db, shop.ID, "历史导入占位")
|
||||||
|
user := testutil.CreateTestUser(db, shop.ID, "admin", "pass", "admin")
|
||||||
|
|
||||||
|
order := model.StockInOrder{
|
||||||
|
TenantBase: model.TenantBase{ShopID: shop.ID},
|
||||||
|
OrderNo: "IN20240101000009",
|
||||||
|
WarehouseID: warehouse.ID,
|
||||||
|
OperatorID: user.ID,
|
||||||
|
Status: "pending",
|
||||||
|
OrderDate: model.Date{Time: time.Now()},
|
||||||
|
Items: []model.StockInItem{
|
||||||
|
{
|
||||||
|
ShopID: shop.ID,
|
||||||
|
ProductID: placeholder.ID,
|
||||||
|
ProductCode: "ZXZ029751",
|
||||||
|
ProductName: "贵州茅台酒2006",
|
||||||
|
Series: "茅台",
|
||||||
|
Spec: "500ml",
|
||||||
|
Quantity: 10,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
require.NoError(t, db.Create(&order).Error)
|
||||||
|
|
||||||
|
svc := NewStockService(db)
|
||||||
|
require.NoError(t, svc.ApproveStockIn(shop.ID, order.ID, user.ID))
|
||||||
|
|
||||||
|
var inv model.Inventory
|
||||||
|
require.NoError(t, db.Where("shop_id = ? AND product_id = ?", shop.ID, placeholder.ID).First(&inv).Error)
|
||||||
|
assert.Equal(t, "贵州茅台酒2006", inv.ProductName)
|
||||||
|
assert.Equal(t, "ZXZ029751", inv.ProductCode)
|
||||||
|
assert.Equal(t, "茅台", inv.Series)
|
||||||
|
assert.Equal(t, "500ml", inv.Spec)
|
||||||
|
}
|
||||||
|
|
||||||
func TestStockService_ApproveStockIn_NotPending(t *testing.T) {
|
func TestStockService_ApproveStockIn_NotPending(t *testing.T) {
|
||||||
db := testutil.SetupTestDB()
|
db := testutil.SetupTestDB()
|
||||||
shop := testutil.CreateTestShop(db, "STOCK002")
|
shop := testutil.CreateTestShop(db, "STOCK002")
|
||||||
|
|||||||
+9
-1
@@ -87,7 +87,8 @@ func initDB() *gorm.DB {
|
|||||||
}
|
}
|
||||||
|
|
||||||
db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{
|
db, err := gorm.Open(mysql.Open(dsn), &gorm.Config{
|
||||||
Logger: logger.Default.LogMode(logLevel),
|
Logger: logger.Default.LogMode(logLevel),
|
||||||
|
TranslateError: true, // 把 MySQL 1062 翻译成 gorm.ErrDuplicatedKey,供编码撞唯一约束时重试
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("failed to connect database: %v", err)
|
log.Fatalf("failed to connect database: %v", err)
|
||||||
@@ -136,5 +137,12 @@ func autoMigrate(db *gorm.DB) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("auto migrate failed: %v", err)
|
log.Fatalf("auto migrate failed: %v", err)
|
||||||
}
|
}
|
||||||
|
// products(shop_id, code) 联合唯一索引:ShopID 在共用 TenantBase 上无法用 struct tag 表达,
|
||||||
|
// 故在此幂等显式建(保证同店内商品编码唯一,DB 层兜底防止重复编码静默落库)。
|
||||||
|
if !db.Migrator().HasIndex(&model.Product{}, "uk_shop_code") {
|
||||||
|
if err := db.Exec("CREATE UNIQUE INDEX uk_shop_code ON products (shop_id, code)").Error; err != nil {
|
||||||
|
log.Fatalf("create unique index uk_shop_code failed: %v", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
log.Println("AutoMigrate completed")
|
log.Println("AutoMigrate completed")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -46,7 +46,8 @@ func SetupTestDB() *gorm.DB {
|
|||||||
InitConfig()
|
InitConfig()
|
||||||
|
|
||||||
db, err := gorm.Open(sqlite.Open(":memory:"), &gorm.Config{
|
db, err := gorm.Open(sqlite.Open(":memory:"), &gorm.Config{
|
||||||
Logger: logger.Default.LogMode(logger.Silent),
|
Logger: logger.Default.LogMode(logger.Silent),
|
||||||
|
TranslateError: true,
|
||||||
})
|
})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(fmt.Sprintf("failed to open sqlite: %v", err))
|
panic(fmt.Sprintf("failed to open sqlite: %v", err))
|
||||||
|
|||||||
@@ -23,6 +23,7 @@ class StockInListNotifier extends AsyncNotifier<PageResult<StockInOrder>> {
|
|||||||
String _status = '';
|
String _status = '';
|
||||||
String? _startDate;
|
String? _startDate;
|
||||||
String? _endDate;
|
String? _endDate;
|
||||||
|
String _keyword = '';
|
||||||
PageResult<StockInOrder>? _cache;
|
PageResult<StockInOrder>? _cache;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
@@ -44,6 +45,7 @@ class StockInListNotifier extends AsyncNotifier<PageResult<StockInOrder>> {
|
|||||||
status: _status.isEmpty ? null : _status,
|
status: _status.isEmpty ? null : _status,
|
||||||
startDate: _startDate,
|
startDate: _startDate,
|
||||||
endDate: _endDate,
|
endDate: _endDate,
|
||||||
|
keyword: _keyword.isEmpty ? null : _keyword,
|
||||||
page: _page,
|
page: _page,
|
||||||
pageSize: _pageSize,
|
pageSize: _pageSize,
|
||||||
);
|
);
|
||||||
@@ -76,6 +78,12 @@ class StockInListNotifier extends AsyncNotifier<PageResult<StockInOrder>> {
|
|||||||
reload();
|
reload();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void setKeyword(String keyword) {
|
||||||
|
_keyword = keyword;
|
||||||
|
_page = 1;
|
||||||
|
reload();
|
||||||
|
}
|
||||||
|
|
||||||
void reload() {
|
void reload() {
|
||||||
state = const AsyncValue.loading();
|
state = const AsyncValue.loading();
|
||||||
_fetch().then((result) {
|
_fetch().then((result) {
|
||||||
|
|||||||
@@ -23,6 +23,7 @@ class StockOutListNotifier extends AsyncNotifier<PageResult<StockOutOrder>> {
|
|||||||
String _status = '';
|
String _status = '';
|
||||||
String? _startDate;
|
String? _startDate;
|
||||||
String? _endDate;
|
String? _endDate;
|
||||||
|
String _keyword = '';
|
||||||
PageResult<StockOutOrder>? _cache;
|
PageResult<StockOutOrder>? _cache;
|
||||||
|
|
||||||
@override
|
@override
|
||||||
@@ -44,6 +45,7 @@ class StockOutListNotifier extends AsyncNotifier<PageResult<StockOutOrder>> {
|
|||||||
status: _status.isEmpty ? null : _status,
|
status: _status.isEmpty ? null : _status,
|
||||||
startDate: _startDate,
|
startDate: _startDate,
|
||||||
endDate: _endDate,
|
endDate: _endDate,
|
||||||
|
keyword: _keyword.isEmpty ? null : _keyword,
|
||||||
page: _page,
|
page: _page,
|
||||||
pageSize: _pageSize,
|
pageSize: _pageSize,
|
||||||
);
|
);
|
||||||
@@ -76,6 +78,12 @@ class StockOutListNotifier extends AsyncNotifier<PageResult<StockOutOrder>> {
|
|||||||
reload();
|
reload();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void setKeyword(String keyword) {
|
||||||
|
_keyword = keyword;
|
||||||
|
_page = 1;
|
||||||
|
reload();
|
||||||
|
}
|
||||||
|
|
||||||
void reload() {
|
void reload() {
|
||||||
state = const AsyncValue.loading();
|
state = const AsyncValue.loading();
|
||||||
_fetch().then((result) {
|
_fetch().then((result) {
|
||||||
|
|||||||
@@ -13,6 +13,7 @@ class StockInRepository {
|
|||||||
String? status,
|
String? status,
|
||||||
String? startDate,
|
String? startDate,
|
||||||
String? endDate,
|
String? endDate,
|
||||||
|
String? keyword,
|
||||||
int page = 1,
|
int page = 1,
|
||||||
int pageSize = 20,
|
int pageSize = 20,
|
||||||
}) async {
|
}) async {
|
||||||
@@ -23,6 +24,7 @@ class StockInRepository {
|
|||||||
if (status != null && status.isNotEmpty) 'status': status,
|
if (status != null && status.isNotEmpty) 'status': status,
|
||||||
if (startDate != null) 'start_date': startDate,
|
if (startDate != null) 'start_date': startDate,
|
||||||
if (endDate != null) 'end_date': endDate,
|
if (endDate != null) 'end_date': endDate,
|
||||||
|
if (keyword != null && keyword.isNotEmpty) 'keyword': keyword,
|
||||||
};
|
};
|
||||||
final resp = await _client.get('/stock-in/orders', params: params);
|
final resp = await _client.get('/stock-in/orders', params: params);
|
||||||
return PageResult.fromJson(
|
return PageResult.fromJson(
|
||||||
|
|||||||
@@ -13,6 +13,7 @@ class StockOutRepository {
|
|||||||
String? status,
|
String? status,
|
||||||
String? startDate,
|
String? startDate,
|
||||||
String? endDate,
|
String? endDate,
|
||||||
|
String? keyword,
|
||||||
int page = 1,
|
int page = 1,
|
||||||
int pageSize = 20,
|
int pageSize = 20,
|
||||||
}) async {
|
}) async {
|
||||||
@@ -23,6 +24,7 @@ class StockOutRepository {
|
|||||||
if (status != null && status.isNotEmpty) 'status': status,
|
if (status != null && status.isNotEmpty) 'status': status,
|
||||||
if (startDate != null) 'start_date': startDate,
|
if (startDate != null) 'start_date': startDate,
|
||||||
if (endDate != null) 'end_date': endDate,
|
if (endDate != null) 'end_date': endDate,
|
||||||
|
if (keyword != null && keyword.isNotEmpty) 'keyword': keyword,
|
||||||
};
|
};
|
||||||
final resp = await _client.get('/stock-out/orders', params: params);
|
final resp = await _client.get('/stock-out/orders', params: params);
|
||||||
return PageResult.fromJson(
|
return PageResult.fromJson(
|
||||||
|
|||||||
@@ -677,6 +677,13 @@ class _InventoryListScreenState extends ConsumerState<InventoryListScreen> {
|
|||||||
ColumnPrefs.save(_screenId, v);
|
ColumnPrefs.save(_screenId, v);
|
||||||
},
|
},
|
||||||
),
|
),
|
||||||
|
IconButton(
|
||||||
|
tooltip: '刷新',
|
||||||
|
icon: const Icon(Icons.refresh, size: 20),
|
||||||
|
onPressed: () => ref
|
||||||
|
.read(inventoryListProvider.notifier)
|
||||||
|
.reload(),
|
||||||
|
),
|
||||||
],
|
],
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
@@ -712,6 +719,13 @@ class _InventoryListScreenState extends ConsumerState<InventoryListScreen> {
|
|||||||
ColumnPrefs.save(_screenId, v);
|
ColumnPrefs.save(_screenId, v);
|
||||||
},
|
},
|
||||||
),
|
),
|
||||||
|
const SizedBox(width: 8),
|
||||||
|
OutlinedButton.icon(
|
||||||
|
onPressed: () =>
|
||||||
|
ref.read(inventoryListProvider.notifier).reload(),
|
||||||
|
icon: const Icon(Icons.refresh, size: 16),
|
||||||
|
label: const Text('刷新'),
|
||||||
|
),
|
||||||
const Spacer(),
|
const Spacer(),
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -39,6 +39,7 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
Set<String> _filterWarehouse = {};
|
Set<String> _filterWarehouse = {};
|
||||||
Set<String> _filterSupplier = {};
|
Set<String> _filterSupplier = {};
|
||||||
Set<String>? _hiddenCols; // null = 尚未载入本地存档(回退到 minWidth 首次默认)
|
Set<String>? _hiddenCols; // null = 尚未载入本地存档(回退到 minWidth 首次默认)
|
||||||
|
final _searchCtrl = TextEditingController();
|
||||||
|
|
||||||
static const _screenId = 'stock_in_list';
|
static const _screenId = 'stock_in_list';
|
||||||
|
|
||||||
@@ -71,6 +72,15 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@override
|
||||||
|
void dispose() {
|
||||||
|
_searchCtrl.dispose();
|
||||||
|
super.dispose();
|
||||||
|
}
|
||||||
|
|
||||||
|
void _triggerSearch() =>
|
||||||
|
ref.read(stockInListProvider.notifier).setKeyword(_searchCtrl.text.trim());
|
||||||
|
|
||||||
String? get _startDate => _dateRange != null
|
String? get _startDate => _dateRange != null
|
||||||
? '${_dateRange!.start.year}-${_dateRange!.start.month.toString().padLeft(2, '0')}-${_dateRange!.start.day.toString().padLeft(2, '0')}'
|
? '${_dateRange!.start.year}-${_dateRange!.start.month.toString().padLeft(2, '0')}-${_dateRange!.start.day.toString().padLeft(2, '0')}'
|
||||||
: null;
|
: null;
|
||||||
@@ -352,6 +362,27 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
)
|
)
|
||||||
: null;
|
: null;
|
||||||
|
|
||||||
|
final searchField = TextField(
|
||||||
|
controller: _searchCtrl,
|
||||||
|
decoration: InputDecoration(
|
||||||
|
hintText: '单号/往来单位,回车搜索',
|
||||||
|
prefixIcon: const Icon(Icons.search, size: 16),
|
||||||
|
hintStyle: const TextStyle(fontSize: 12),
|
||||||
|
suffixIcon: IconButton(
|
||||||
|
icon: const Icon(Icons.search, size: 16),
|
||||||
|
tooltip: '搜索',
|
||||||
|
onPressed: _triggerSearch,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
onSubmitted: (_) => _triggerSearch(),
|
||||||
|
);
|
||||||
|
|
||||||
|
final refreshBtn = IconButton(
|
||||||
|
tooltip: '刷新',
|
||||||
|
icon: const Icon(Icons.refresh, size: 20),
|
||||||
|
onPressed: () => ref.read(stockInListProvider.notifier).reload(),
|
||||||
|
);
|
||||||
|
|
||||||
final dateBtn = OutlinedButton.icon(
|
final dateBtn = OutlinedButton.icon(
|
||||||
onPressed: _pickDateRange,
|
onPressed: _pickDateRange,
|
||||||
icon: const Icon(Icons.date_range, size: 16),
|
icon: const Icon(Icons.date_range, size: 16),
|
||||||
@@ -374,28 +405,36 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
: null;
|
: null;
|
||||||
|
|
||||||
if (isMobile) {
|
if (isMobile) {
|
||||||
return Wrap(
|
return Column(
|
||||||
spacing: 8,
|
mainAxisSize: MainAxisSize.min,
|
||||||
runSpacing: 4,
|
|
||||||
crossAxisAlignment: WrapCrossAlignment.center,
|
|
||||||
children: [
|
children: [
|
||||||
if (newBtn != null) newBtn,
|
searchField,
|
||||||
if (statusFilter != null) statusFilter,
|
const SizedBox(height: 8),
|
||||||
dateBtn,
|
Wrap(
|
||||||
if (clearDate != null) clearDate,
|
spacing: 8,
|
||||||
IconButton(
|
runSpacing: 4,
|
||||||
tooltip: '导出',
|
crossAxisAlignment: WrapCrossAlignment.center,
|
||||||
icon: const Icon(Icons.download, size: 20),
|
children: [
|
||||||
onPressed: doExport,
|
if (newBtn != null) newBtn,
|
||||||
),
|
if (statusFilter != null) statusFilter,
|
||||||
ColumnToggleButton(
|
dateBtn,
|
||||||
columns: _colDefs,
|
if (clearDate != null) clearDate,
|
||||||
hidden: hidden,
|
IconButton(
|
||||||
compact: true,
|
tooltip: '导出',
|
||||||
onChanged: (v) {
|
icon: const Icon(Icons.download, size: 20),
|
||||||
setState(() => _hiddenCols = v);
|
onPressed: doExport,
|
||||||
ColumnPrefs.save(_screenId, v);
|
),
|
||||||
},
|
ColumnToggleButton(
|
||||||
|
columns: _colDefs,
|
||||||
|
hidden: hidden,
|
||||||
|
compact: true,
|
||||||
|
onChanged: (v) {
|
||||||
|
setState(() => _hiddenCols = v);
|
||||||
|
ColumnPrefs.save(_screenId, v);
|
||||||
|
},
|
||||||
|
),
|
||||||
|
refreshBtn,
|
||||||
|
],
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
@@ -403,6 +442,8 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
|
|
||||||
return Row(
|
return Row(
|
||||||
children: [
|
children: [
|
||||||
|
SizedBox(width: 220, child: searchField),
|
||||||
|
const SizedBox(width: 12),
|
||||||
if (newBtn != null) newBtn,
|
if (newBtn != null) newBtn,
|
||||||
const Spacer(),
|
const Spacer(),
|
||||||
if (statusFilter != null) ...[
|
if (statusFilter != null) ...[
|
||||||
@@ -429,6 +470,7 @@ class _StockInListScreenState extends ConsumerState<StockInListScreen> {
|
|||||||
ColumnPrefs.save(_screenId, v);
|
ColumnPrefs.save(_screenId, v);
|
||||||
},
|
},
|
||||||
),
|
),
|
||||||
|
refreshBtn,
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
}),
|
}),
|
||||||
|
|||||||
@@ -38,6 +38,7 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
Set<String> _filterWarehouse = {};
|
Set<String> _filterWarehouse = {};
|
||||||
Set<String> _filterCustomer = {};
|
Set<String> _filterCustomer = {};
|
||||||
Set<String>? _hiddenCols; // null = 尚未载入本地存档(回退到 minWidth 首次默认)
|
Set<String>? _hiddenCols; // null = 尚未载入本地存档(回退到 minWidth 首次默认)
|
||||||
|
final _searchCtrl = TextEditingController();
|
||||||
|
|
||||||
static const _screenId = 'stock_out_list';
|
static const _screenId = 'stock_out_list';
|
||||||
|
|
||||||
@@ -71,6 +72,16 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
ColDef('actions', '操作', required: true),
|
ColDef('actions', '操作', required: true),
|
||||||
];
|
];
|
||||||
|
|
||||||
|
@override
|
||||||
|
void dispose() {
|
||||||
|
_searchCtrl.dispose();
|
||||||
|
super.dispose();
|
||||||
|
}
|
||||||
|
|
||||||
|
void _triggerSearch() => ref
|
||||||
|
.read(stockOutListProvider.notifier)
|
||||||
|
.setKeyword(_searchCtrl.text.trim());
|
||||||
|
|
||||||
String? get _startDate => _dateRange != null
|
String? get _startDate => _dateRange != null
|
||||||
? '${_dateRange!.start.year}-${_dateRange!.start.month.toString().padLeft(2, '0')}-${_dateRange!.start.day.toString().padLeft(2, '0')}'
|
? '${_dateRange!.start.year}-${_dateRange!.start.month.toString().padLeft(2, '0')}-${_dateRange!.start.day.toString().padLeft(2, '0')}'
|
||||||
: null;
|
: null;
|
||||||
@@ -358,6 +369,27 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
)
|
)
|
||||||
: null;
|
: null;
|
||||||
|
|
||||||
|
final searchField = TextField(
|
||||||
|
controller: _searchCtrl,
|
||||||
|
decoration: InputDecoration(
|
||||||
|
hintText: '单号/往来单位,回车搜索',
|
||||||
|
prefixIcon: const Icon(Icons.search, size: 16),
|
||||||
|
hintStyle: const TextStyle(fontSize: 12),
|
||||||
|
suffixIcon: IconButton(
|
||||||
|
icon: const Icon(Icons.search, size: 16),
|
||||||
|
tooltip: '搜索',
|
||||||
|
onPressed: _triggerSearch,
|
||||||
|
),
|
||||||
|
),
|
||||||
|
onSubmitted: (_) => _triggerSearch(),
|
||||||
|
);
|
||||||
|
|
||||||
|
final refreshBtn = IconButton(
|
||||||
|
tooltip: '刷新',
|
||||||
|
icon: const Icon(Icons.refresh, size: 20),
|
||||||
|
onPressed: () => ref.read(stockOutListProvider.notifier).reload(),
|
||||||
|
);
|
||||||
|
|
||||||
final dateBtn = OutlinedButton.icon(
|
final dateBtn = OutlinedButton.icon(
|
||||||
onPressed: _pickDateRange,
|
onPressed: _pickDateRange,
|
||||||
icon: const Icon(Icons.date_range, size: 16),
|
icon: const Icon(Icons.date_range, size: 16),
|
||||||
@@ -380,28 +412,36 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
: null;
|
: null;
|
||||||
|
|
||||||
if (isMobile) {
|
if (isMobile) {
|
||||||
return Wrap(
|
return Column(
|
||||||
spacing: 8,
|
mainAxisSize: MainAxisSize.min,
|
||||||
runSpacing: 4,
|
|
||||||
crossAxisAlignment: WrapCrossAlignment.center,
|
|
||||||
children: [
|
children: [
|
||||||
if (newBtn != null) newBtn,
|
searchField,
|
||||||
if (statusFilter != null) statusFilter,
|
const SizedBox(height: 8),
|
||||||
dateBtn,
|
Wrap(
|
||||||
if (clearDate != null) clearDate,
|
spacing: 8,
|
||||||
IconButton(
|
runSpacing: 4,
|
||||||
tooltip: '导出',
|
crossAxisAlignment: WrapCrossAlignment.center,
|
||||||
icon: const Icon(Icons.download, size: 20),
|
children: [
|
||||||
onPressed: doExport,
|
if (newBtn != null) newBtn,
|
||||||
),
|
if (statusFilter != null) statusFilter,
|
||||||
ColumnToggleButton(
|
dateBtn,
|
||||||
columns: _colDefs,
|
if (clearDate != null) clearDate,
|
||||||
hidden: hidden,
|
IconButton(
|
||||||
compact: true,
|
tooltip: '导出',
|
||||||
onChanged: (v) {
|
icon: const Icon(Icons.download, size: 20),
|
||||||
setState(() => _hiddenCols = v);
|
onPressed: doExport,
|
||||||
ColumnPrefs.save(_screenId, v);
|
),
|
||||||
},
|
ColumnToggleButton(
|
||||||
|
columns: _colDefs,
|
||||||
|
hidden: hidden,
|
||||||
|
compact: true,
|
||||||
|
onChanged: (v) {
|
||||||
|
setState(() => _hiddenCols = v);
|
||||||
|
ColumnPrefs.save(_screenId, v);
|
||||||
|
},
|
||||||
|
),
|
||||||
|
refreshBtn,
|
||||||
|
],
|
||||||
),
|
),
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
@@ -409,6 +449,8 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
|
|
||||||
return Row(
|
return Row(
|
||||||
children: [
|
children: [
|
||||||
|
SizedBox(width: 220, child: searchField),
|
||||||
|
const SizedBox(width: 12),
|
||||||
if (newBtn != null) newBtn,
|
if (newBtn != null) newBtn,
|
||||||
const Spacer(),
|
const Spacer(),
|
||||||
if (statusFilter != null) ...[
|
if (statusFilter != null) ...[
|
||||||
@@ -435,6 +477,7 @@ class _StockOutListScreenState extends ConsumerState<StockOutListScreen> {
|
|||||||
ColumnPrefs.save(_screenId, v);
|
ColumnPrefs.save(_screenId, v);
|
||||||
},
|
},
|
||||||
),
|
),
|
||||||
|
refreshBtn,
|
||||||
],
|
],
|
||||||
);
|
);
|
||||||
}),
|
}),
|
||||||
|
|||||||
Reference in New Issue
Block a user