294 lines
8.5 KiB
Go
294 lines
8.5 KiB
Go
package service
|
||
|
||
import (
|
||
"database/sql"
|
||
"fmt"
|
||
"math"
|
||
"strings"
|
||
|
||
"cmautobuy/admin/model"
|
||
"cmautobuy/admin/repository"
|
||
)
|
||
|
||
// PddOptionChoice 是采集结果中的一个可购买规格组合。
|
||
type PddOptionChoice struct {
|
||
Key string
|
||
OptionsJSON string
|
||
Label string
|
||
PriceText string
|
||
PriceCent int64
|
||
HasPrice bool
|
||
Selected bool
|
||
}
|
||
|
||
func pddOptionChoices(raw string) ([]PddOptionChoice, []string, error) {
|
||
collected, err := parseCollected(raw)
|
||
if err != nil {
|
||
return nil, nil, err
|
||
}
|
||
keys, names := dimensionOrder(collected)
|
||
choices := make([]PddOptionChoice, 0, len(collected.SKUs))
|
||
seen := map[string]bool{}
|
||
for _, sku := range collected.SKUs {
|
||
if !sku.Available || len(sku.Options) == 0 {
|
||
continue
|
||
}
|
||
key, err := OptionKey(sku.Options)
|
||
if err != nil {
|
||
return nil, nil, err
|
||
}
|
||
if seen[key] {
|
||
continue
|
||
}
|
||
seen[key] = true
|
||
parts := make([]string, 0, len(keys))
|
||
for i, dimensionKey := range keys {
|
||
name := dimensionKey
|
||
if i < len(names) && names[i] != "" {
|
||
name = names[i]
|
||
}
|
||
parts = append(parts, name+"："+sku.Options[dimensionKey])
|
||
}
|
||
choice := PddOptionChoice{
|
||
Key: key, OptionsJSON: key, Label: strings.Join(parts, " / "),
|
||
PriceText: formatPriceCent(sku.PriceCent),
|
||
}
|
||
if sku.PriceCent != nil && *sku.PriceCent > 0 {
|
||
choice.PriceCent, choice.HasPrice = *sku.PriceCent, true
|
||
}
|
||
choices = append(choices, choice)
|
||
}
|
||
return choices, names, nil
|
||
}
|
||
|
||
func findPddChoice(raw, key string) (*PddOptionChoice, error) {
|
||
choices, _, err := pddOptionChoices(raw)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
for _, choice := range choices {
|
||
if choice.Key == key {
|
||
copy := choice
|
||
return ©, nil
|
||
}
|
||
}
|
||
return nil, nil
|
||
}
|
||
|
||
// SaveSybMapping 保存顺运宝明细对应蝦皮 SKU 到当前 PDD 商品的可复用映射。
|
||
func SaveSybMapping(db *sql.DB, sybID, optionKey, operator string) error {
|
||
tx, err := db.Begin()
|
||
if err != nil {
|
||
return fmt.Errorf("开始保存规格映射事务失败: %w", err)
|
||
}
|
||
defer tx.Rollback()
|
||
context, err := repository.GetSybOrderContext(tx, strings.TrimSpace(sybID))
|
||
if err != nil {
|
||
return err
|
||
}
|
||
if context == nil {
|
||
return fmt.Errorf("顺运宝明细不存在")
|
||
}
|
||
if context.Order.ShopeeSKUID == "" {
|
||
return fmt.Errorf("请先确认蝦皮规格")
|
||
}
|
||
if context.PddGoodsID == "" || context.PddCollectStatus != string(model.CollectCollected) ||
|
||
strings.TrimSpace(context.PddSkusJSON) == "" {
|
||
return fmt.Errorf("当前 PDD 商品尚未完成采集")
|
||
}
|
||
choice, err := findPddChoice(context.PddSkusJSON, strings.TrimSpace(optionKey))
|
||
if err != nil {
|
||
return fmt.Errorf("读取 PDD 规格失败: %w", err)
|
||
}
|
||
if choice == nil {
|
||
return fmt.Errorf("所选 PDD 规格已不存在或不可购买，请刷新后重试")
|
||
}
|
||
if err := repository.UpsertSKUMapping(tx, model.SKUMapping{
|
||
ShopeeSKUID: context.Order.ShopeeSKUID, PddGoodsID: context.PddGoodsID,
|
||
PddOptionKey: choice.Key, PddOptions: choice.OptionsJSON,
|
||
GoodsID: context.Order.ShopeeGoodsID, MappedAt: model.NowISO(),
|
||
MappedBy: strings.TrimSpace(operator),
|
||
}); err != nil {
|
||
return err
|
||
}
|
||
return tx.Commit()
|
||
}
|
||
|
||
func mappingIsValid(context repository.SybOrderContext) bool {
|
||
if context.MappingOptionKey == "" || context.PddSkusJSON == "" {
|
||
return false
|
||
}
|
||
choice, err := findPddChoice(context.PddSkusJSON, context.MappingOptionKey)
|
||
return err == nil && choice != nil
|
||
}
|
||
|
||
// PurchaseTaskRequest 是一条采购任务的人工确认输入。价格单位固定为人民币分。
|
||
type PurchaseTaskRequest struct {
|
||
SybID string
|
||
MaxPriceCent int64
|
||
}
|
||
|
||
// PurchaseTaskResult 同时返回已创建数量和每条无法创建的原因。
|
||
type PurchaseTaskResult struct {
|
||
Created int
|
||
Failures []TaskCreateError
|
||
}
|
||
|
||
// CreatePurchaseTasks 校验并创建采购任务。业务校验失败按明细返回，数据库错误整体回滚。
|
||
func CreatePurchaseTasks(db *sql.DB, actor *model.User, requests []PurchaseTaskRequest, clientID string) (PurchaseTaskResult, error) {
|
||
var result PurchaseTaskResult
|
||
visibleUserID, err := visibleClientUserID(actor)
|
||
if err != nil {
|
||
return result, err
|
||
}
|
||
clientID = strings.TrimSpace(clientID)
|
||
if clientID == "" {
|
||
return result, fmt.Errorf("请选择执行采购任务的客户端")
|
||
}
|
||
tx, err := db.Begin()
|
||
if err != nil {
|
||
return result, fmt.Errorf("开始创建采购任务事务失败: %w", err)
|
||
}
|
||
defer tx.Rollback()
|
||
visible, err := repository.ClientVisibleToUser(tx, clientID, visibleUserID)
|
||
if err != nil {
|
||
return result, err
|
||
}
|
||
if !visible {
|
||
return result, fmt.Errorf("所选客户端不存在或不在当前账号可见范围")
|
||
}
|
||
|
||
seen := map[string]bool{}
|
||
for _, request := range requests {
|
||
request.SybID = strings.TrimSpace(request.SybID)
|
||
if request.SybID == "" || seen[request.SybID] {
|
||
if request.SybID != "" {
|
||
result.Failures = append(result.Failures, TaskCreateError{SybID: request.SybID, Reason: "重复选择"})
|
||
}
|
||
continue
|
||
}
|
||
seen[request.SybID] = true
|
||
reason, context, optionsJSON, err := validatePurchaseRequest(tx, request)
|
||
if err != nil {
|
||
return PurchaseTaskResult{}, err
|
||
}
|
||
if reason != "" {
|
||
result.Failures = append(result.Failures, TaskCreateError{SybID: request.SybID, Reason: reason})
|
||
continue
|
||
}
|
||
if err := repository.InsertPurchaseTask(tx, model.Task{
|
||
TaskID: newPurchaseTaskID(), AssignedClient: clientID,
|
||
SybID: context.Order.SybID, OrderNo: context.Order.OrderNo,
|
||
GoodsID: context.Order.ShopeeGoodsID, ShopeeSKUID: context.Order.ShopeeSKUID,
|
||
PddGoodsURL: context.PddGoodsURL, PddGoodsID: context.PddGoodsID,
|
||
PddOptions: optionsJSON, Quantity: context.Order.Quantity,
|
||
MaxPriceCent: request.MaxPriceCent,
|
||
}); err != nil {
|
||
return PurchaseTaskResult{}, err
|
||
}
|
||
result.Created++
|
||
}
|
||
if err := tx.Commit(); err != nil {
|
||
return PurchaseTaskResult{}, fmt.Errorf("提交采购任务失败: %w", err)
|
||
}
|
||
return result, nil
|
||
}
|
||
|
||
func validatePurchaseRequest(q repository.Execer, request PurchaseTaskRequest) (string, *repository.SybOrderContext, string, error) {
|
||
context, err := repository.GetSybOrderContext(q, request.SybID)
|
||
if err != nil {
|
||
return "", nil, "", err
|
||
}
|
||
if context == nil {
|
||
return "顺运宝明细不存在", nil, "", nil
|
||
}
|
||
if context.Order.ShopeeSKUID == "" {
|
||
return "蝦皮规格未确认", context, "", nil
|
||
}
|
||
if context.PddGoodsID == "" || context.PddGoodsURL == "" {
|
||
return "未关联 PDD 商品", context, "", nil
|
||
}
|
||
if context.PddCollectStatus != string(model.CollectCollected) || context.PddSkusJSON == "" {
|
||
return "PDD 商品尚未采集完成", context, "", nil
|
||
}
|
||
if context.MappingOptionKey == "" {
|
||
return "PDD 规格尚未匹配", context, "", nil
|
||
}
|
||
choice, err := findPddChoice(context.PddSkusJSON, context.MappingOptionKey)
|
||
if err != nil {
|
||
return "", nil, "", err
|
||
}
|
||
if choice == nil {
|
||
return "已保存的 PDD 规格已失效，请重新匹配", context, "", nil
|
||
}
|
||
if context.Order.Quantity <= 0 {
|
||
return "采购数量必须大于 0", context, "", nil
|
||
}
|
||
if request.MaxPriceCent <= 0 {
|
||
return "人民币价格上限必须大于 0", context, "", nil
|
||
}
|
||
active, err := repository.HasActivePurchaseTask(q, request.SybID)
|
||
if err != nil {
|
||
return "", nil, "", err
|
||
}
|
||
if active {
|
||
return "已有未结束的采购任务", context, "", nil
|
||
}
|
||
return "", context, choice.OptionsJSON, nil
|
||
}
|
||
|
||
func newPurchaseTaskID() string {
|
||
id := newID()
|
||
if len(id) > 16 {
|
||
id = id[:16]
|
||
}
|
||
return "PUR-" + id
|
||
}
|
||
|
||
// parsePriceYuanToCent 把网页输入的人民币元精确转成分，不使用浮点数。
|
||
func ParsePriceYuanToCent(raw string) (int64, error) {
|
||
raw = strings.TrimSpace(raw)
|
||
if raw == "" {
|
||
return 0, fmt.Errorf("价格上限不能为空")
|
||
}
|
||
var whole, fraction string
|
||
parts := strings.Split(raw, ".")
|
||
if len(parts) > 2 {
|
||
return 0, fmt.Errorf("价格格式不正确")
|
||
}
|
||
whole = parts[0]
|
||
if len(parts) == 2 {
|
||
fraction = parts[1]
|
||
}
|
||
if whole == "" || len(fraction) > 2 {
|
||
return 0, fmt.Errorf("价格最多保留两位小数")
|
||
}
|
||
for _, value := range []string{whole, fraction} {
|
||
for _, r := range value {
|
||
if r < '0' || r > '9' {
|
||
return 0, fmt.Errorf("价格只能填写数字")
|
||
}
|
||
}
|
||
}
|
||
if len(fraction) == 0 {
|
||
fraction = "00"
|
||
} else if len(fraction) == 1 {
|
||
fraction += "0"
|
||
}
|
||
var yuan, cent int64
|
||
if _, err := fmt.Sscan(whole, &yuan); err != nil {
|
||
return 0, fmt.Errorf("价格格式不正确")
|
||
}
|
||
if _, err := fmt.Sscan(fraction, ¢); err != nil {
|
||
return 0, fmt.Errorf("价格格式不正确")
|
||
}
|
||
if yuan > (math.MaxInt64-cent)/100 {
|
||
return 0, fmt.Errorf("价格上限过大")
|
||
}
|
||
total := yuan*100 + cent
|
||
if total <= 0 {
|
||
return 0, fmt.Errorf("价格上限必须大于 0")
|
||
}
|
||
return total, nil
|
||
}
|