bom修改匹配

cmd/queue/bom.go

@@ -35,7 +35,6 @@ func (t *RecvPro) Consumer(dataByte []byte) (err error) {
 	if err != nil {
 	if err != nil {
 		log.Error(err)
 		log.Error(err)
 	}
 	}
-
 	err = logic.MatchGoods(message)
 	err = logic.MatchGoods(message)
 	if err != nil {
 	if err != nil {
 		log.Error(err)
 		log.Error(err)

internal/logic/bom_item.go

@@ -14,7 +14,8 @@ import (
 func GetBomItems(bomId int) (bomItems []model.BomItem) {
 func GetBomItems(bomId int) (bomItems []model.BomItem) {
 	bomIdStr := strconv.FormatInt(int64(bomId), 10)
 	bomIdStr := strconv.FormatInt(int64(bomId), 10)
 	tableEnd := string(bomIdStr[len(bomIdStr)-1])
 	tableEnd := string(bomIdStr[len(bomIdStr)-1])
-	model.Db.Table("lie_bom_item_"+tableEnd).Where("del_status = ?", 1).Where("bom_id = ?", bomId).Find(&bomItems)
+	model.Db.Table("lie_bom_item_"+tableEnd).Where("del_status = ?", 1).
+		Where("bom_id = ?", bomId).Find(&bomItems)
 	return bomItems
 	return bomItems
 }
 }
 
 

internal/logic/match.go

@@ -6,7 +6,6 @@ import (
 	"bom_server/internal/model"
 	"bom_server/internal/model"
 	"context"
 	"context"
 	"encoding/json"
 	"encoding/json"
-	"errors"
 	"math"
 	"math"
 	"regexp"
 	"regexp"
 	"strings"
 	"strings"
@@ -28,7 +27,7 @@ func MatchGoods(message model.BomMessage) (err error) {
 	bomId := message.BomId
 	bomId := message.BomId
 	bom := GetBomInfoWithItems(bomId)
 	bom := GetBomInfoWithItems(bomId)
 	if len(bom.BomItems) == 0 {
 	if len(bom.BomItems) == 0 {
-		return errors.New("没有商品的bom单")
+		return nil
 	}
 	}
 	bomItems := bom.BomItems
 	bomItems := bom.BomItems
 	var perGoDealNumber int
 	var perGoDealNumber int
@@ -251,7 +250,6 @@ func search(index string, bomId int, bomItems []model.BomItem, deliveryType, sor
 		searchFlag = true
 		searchFlag = true
 		search.Add(searchRequest)
 		search.Add(searchRequest)
 	}
 	}
-
 	//没有搜索条件的话,直接返回空值即可
 	//没有搜索条件的话,直接返回空值即可
 	if !searchFlag {
 	if !searchFlag {
 		return nil, err
 		return nil, err