fix: 更新数据库表名引用及配置

service/stock/inventory_count_detail_service.go

@@ -114,7 +114,7 @@ func (s *inventoryCountDetail) fillListItemNames(ctx context.Context, details []
 			Id   *bson.ObjectID `bson:"_id"`
 			Name string         `bson:"assetName"`
 		}
-		if _, e := mongo.DB().Find(ctx, bson.M{"_id": bson.M{"$in": ids}}, &assets, public.AssetCollection, nil, nil); e == nil {
+		if _, e := mongo.DB().Find(ctx, bson.M{"_id": bson.M{"$in": ids}}, &assets, public.TableNameAsset, nil, nil); e == nil {
 			for _, a := range assets {
 				assetNameMap[a.Id.Hex()] = a.Name
 			}

service/stock/stock_manage_service.go

@@ -89,6 +89,7 @@ func (s *stockManage) GetStockFormFields(ctx context.Context, req *stockDto.GetS
 // StockOperation 库存操作入口（入库/出库）
 // 根据SKU的StockMode区分明细模式和批次模式，计算差值后发布消息到NATS
 func (s *stockManage) StockOperation(ctx context.Context, req *stockDto.StockOperationReq) (err error) {
+	// TODO 后续需要排一下查询应该不走缓存，否则会导致库存不准确
 	assetSku, err := assetDao.AssetSku.GetOne(ctx, &assetDto.GetAssetSkuReq{Id: req.AssetSkuId})
 	if err != nil {
 		return
@@ -179,7 +180,8 @@ func (s *stockManage) stockPublishMessage(ctx context.Context, assetSku *assetEn
 // 使用Redis分布式锁防止并发冲突，支持明细模式和批次模式
 func (s *stockManage) AddStock(ctx context.Context, msg any) error {
 	var req = new(stockDto.StockPublishMessage)
-	if err := gconv.Struct(msg, &req); err != nil {
+	msgMap := gconv.Map(msg)
+	if err := gconv.Struct(msgMap["data"], &req); err != nil {
 		return err
 	}
 	// 设置 userId 和 tenantId 到 ctx