新增系统商品

api/dao/product.go

@@ -4,6 +4,7 @@ import (
 	"gorm.io/gorm"
 	"gorm.io/gorm/clause"
 	"hospital-admin-api/api/model"
+	"hospital-admin-api/api/requests"
 	"hospital-admin-api/global"
 )
 
@@ -71,3 +72,80 @@ func (r *ProductDao) AddProduct(tx *gorm.DB, model *model.Product) (*model.Produ
 	}
 	return model, nil
 }
+
+// GetProductPageSearch 获取商品列表-分页
+func (r *ProductDao) GetProductPageSearch(req requests.GetProductPage, page, pageSize int) (m []*model.Product, total int64, err error) {
+	var totalRecords int64
+
+	// 构建查询条件
+	query := global.Db.Model(&model.Product{})
+
+	// 库存表
+	query = query.Preload("ProductPlatformAmount", func(db *gorm.DB) *gorm.DB {
+		return db.Select("amount_id", "product_platform_id", "product_platform_code", "stock")
+	})
+
+	// 商品名称
+	if req.ProductName != "" {
+		query = query.Where("product_name LIKE ?", "%"+req.ProductName+"%")
+	}
+
+	// 商品通用名
+	if req.CommonName != "" {
+		query = query.Where("common_name LIKE ?", "%"+req.CommonName+"%")
+	}
+
+	// 商品助记码
+	if req.MnemonicCode != "" {
+		query = query.Where("mnemonic_code LIKE ?", "%"+req.MnemonicCode+"%")
+	}
+
+	// 药品类型
+	if req.ProductType != nil {
+		query = query.Where("product_type = ?", req.ProductType)
+	}
+
+	// 平台商品id
+	if req.ProductPlatformId != "" {
+		query = query.Where("product_platform_id = ?", req.ProductPlatformId)
+	}
+
+	// 处方平台编码
+	if req.ProductPlatformCode != "" {
+		query = query.Where("product_platform_code LIKE ?", "%"+req.ProductPlatformCode+"%")
+	}
+
+	// 药店编码
+	if req.ProductPharmacyCode != "" {
+		query = query.Where("product_pharmacy_code LIKE ?", "%"+req.ProductPharmacyCode+"%")
+	}
+
+	// 批准文号
+	if req.LicenseNumber != "" {
+		query = query.Where("license_number LIKE ?", "%"+req.LicenseNumber+"%")
+	}
+
+	// 生产厂家
+	if req.Manufacturer != "" {
+		query = query.Where("manufacturer LIKE ?", "%"+req.Manufacturer+"%")
+	}
+
+	// 商品备注
+	if req.ProductRemarks != "" {
+		query = query.Where("product_remarks LIKE ?", "%"+req.ProductRemarks+"%")
+	}
+
+	// 排序
+	query = query.Order("created_at desc")
+
+	// 查询总数量
+	if err := query.Count(&totalRecords).Error; err != nil {
+		return nil, 0, err
+	}
+
+	err = query.Scopes(model.Paginate(page, pageSize)).Find(&m).Error
+	if err != nil {
+		return nil, 0, err
+	}
+	return m, totalRecords, nil
+}

api/dao/productPlatformAmount.go

@@ -0,0 +1,72 @@
+package dao
+
+import (
+	"gorm.io/gorm"
+	"hospital-admin-api/api/model"
+	"hospital-admin-api/global"
+)
+
+type ProductPlatformAmountDao struct {
+}
+
+// GetProductPlatformAmountById 获取商品库存数据-商品库存id
+func (r *ProductPlatformAmountDao) GetProductPlatformAmountById(amountId int64) (m *model.ProductPlatformAmount, err error) {
+	err = global.Db.First(&m, amountId).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// GetProductPlatformAmountByProductPlatformId 获取商品库存数据-平台商品id
+func (r *ProductPlatformAmountDao) GetProductPlatformAmountByProductPlatformId(productPlatformId int64) (m *model.ProductPlatformAmount, err error) {
+	err = global.Db.Where("product_platform_id = ?", productPlatformId).First(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// DeleteProductPlatformAmount 删除商品库存
+func (r *ProductPlatformAmountDao) DeleteProductPlatformAmount(tx *gorm.DB, maps interface{}) error {
+	err := tx.Where(maps).Delete(&model.ProductPlatformAmount{}).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// EditProductPlatformAmount 修改商品库存
+func (r *ProductPlatformAmountDao) EditProductPlatformAmount(tx *gorm.DB, maps interface{}, data interface{}) error {
+	err := tx.Model(&model.ProductPlatformAmount{}).Where(maps).Updates(data).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// EditProductPlatformAmountByUserId 修改商品库存-商品库存id
+func (r *ProductPlatformAmountDao) EditProductPlatformAmountByUserId(tx *gorm.DB, amountId int64, data interface{}) error {
+	err := tx.Model(&model.ProductPlatformAmount{}).Where("amount_id = ?", amountId).Updates(data).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// GetProductPlatformAmountList 获取商品库存列表
+func (r *ProductPlatformAmountDao) GetProductPlatformAmountList(maps interface{}) (m []*model.ProductPlatformAmount, err error) {
+	err = global.Db.Where(maps).Find(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// AddProductPlatformAmount 新增商品K库存
+func (r *ProductPlatformAmountDao) AddProductPlatformAmount(tx *gorm.DB, model *model.ProductPlatformAmount) (*model.ProductPlatformAmount, error) {
+	if err := tx.Create(model).Error; err != nil {
+		return nil, err
+	}
+	return model, nil
+}