From b38c3f17cd23a8c29c7aceb3fda6307e9f0c4609 Mon Sep 17 00:00:00 2001 From: wucongxing <815046773@qq.com> Date: Thu, 21 Dec 2023 15:16:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=B9=B3=E5=8F=B0=E5=95=86?= =?UTF-8?q?=E5=93=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/controller/base.go | 6 ++ api/controller/product.go | 131 +++++++++++++++++++++++++++++ api/dao/productPlatform.go | 116 +++++++++++++++++++++++++ api/dto/PlatformProduct.go | 78 +++++++++++++++++ api/model/productPlatform.go | 43 ++++++++++ api/model/productPlatformAmount.go | 34 ++++++++ api/requests/product.go | 17 ++++ api/router/router.go | 33 ++++++++ api/service/product.go | 25 ++++++ 9 files changed, 483 insertions(+) create mode 100644 api/controller/product.go create mode 100644 api/dao/productPlatform.go create mode 100644 api/dto/PlatformProduct.go create mode 100644 api/model/productPlatform.go create mode 100644 api/model/productPlatformAmount.go create mode 100644 api/requests/product.go create mode 100644 api/service/product.go diff --git a/api/controller/base.go b/api/controller/base.go index 87588bb..43c0228 100644 --- a/api/controller/base.go +++ b/api/controller/base.go @@ -15,6 +15,7 @@ type Api struct { caManage // ca管理 financeManage // 财务管理 exportManage // 导出管理 + productManage // 商品管理 } // SysSetting 系统设置 @@ -84,3 +85,8 @@ type financeManage struct { type exportManage struct { Export } + +// 商品管理 +type productManage struct { + Product +} diff --git a/api/controller/product.go b/api/controller/product.go new file mode 100644 index 0000000..5713c4f --- /dev/null +++ b/api/controller/product.go @@ -0,0 +1,131 @@ +package controller + +import ( + "github.com/gin-gonic/gin" + "hospital-admin-api/api/dao" + "hospital-admin-api/api/dto" + "hospital-admin-api/api/requests" + "hospital-admin-api/api/responses" + "hospital-admin-api/api/service" + "hospital-admin-api/global" + "hospital-admin-api/utils" + "strconv" +) + +type Product struct{} + +// GetPlatformProductPage 获取平台商品列表-分页 +func (r *Product) GetPlatformProductPage(c *gin.Context) { + productRequest := requests.ProductRequest{} + req := productRequest.GetPlatformProductPage + if err := c.ShouldBind(&req); err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + // 参数验证 + if err := global.Validate.Struct(req); err != nil { + responses.FailWithMessage(utils.Translate(err), c) + return + } + + if req.Page == 0 { + req.Page = 1 + } + + if req.PageSize == 0 { + req.PageSize = 20 + } + + productPlatformDao := dao.ProductPlatformDao{} + productPlatform, total, err := productPlatformDao.GetPlatformProductPageSearch(req, req.Page, req.PageSize) + if err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + // 处理返回值 + GetProductPlatformPageResponses := dto.GetProductPlatformListDto(productPlatform) + if err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + result := make(map[string]interface{}) + result["page"] = req.Page + result["page_size"] = req.PageSize + result["total"] = total + result["data"] = GetProductPlatformPageResponses + responses.OkWithData(result, c) +} + +// GetPlatformProduct 平台商品详情 +func (r *Product) GetPlatformProduct(c *gin.Context) { + id := c.Param("product_platform_id") + if id == "" { + responses.FailWithMessage("缺少参数", c) + return + } + + // 将 id 转换为 int64 类型 + productPlatformId, err := strconv.ParseInt(id, 10, 64) + if err != nil { + responses.Fail(c) + return + } + + // 业务处理 + productService := service.ProductService{} + getPlatformProductResponses, err := productService.GetPlatformProduct(productPlatformId) + if err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + responses.OkWithData(getPlatformProductResponses, c) +} + +// GetSystemProductPage 获取系统商品列表-分页 +func (r *Product) GetSystemProductPage(c *gin.Context) { + productRequest := requests.ProductRequest{} + req := productRequest.GetPlatformProductPage + if err := c.ShouldBind(&req); err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + // 参数验证 + if err := global.Validate.Struct(req); err != nil { + responses.FailWithMessage(utils.Translate(err), c) + return + } + + if req.Page == 0 { + req.Page = 1 + } + + if req.PageSize == 0 { + req.PageSize = 20 + } + + productPlatformDao := dao.ProductPlatformDao{} + productPlatform, total, err := productPlatformDao.GetPlatformProductPageSearch(req, req.Page, req.PageSize) + if err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + // 处理返回值 + GetProductPlatformPageResponses := dto.GetProductPlatformListDto(productPlatform) + if err != nil { + responses.FailWithMessage(err.Error(), c) + return + } + + result := make(map[string]interface{}) + result["page"] = req.Page + result["page_size"] = req.PageSize + result["total"] = total + result["data"] = GetProductPlatformPageResponses + responses.OkWithData(result, c) +} diff --git a/api/dao/productPlatform.go b/api/dao/productPlatform.go new file mode 100644 index 0000000..3d72640 --- /dev/null +++ b/api/dao/productPlatform.go @@ -0,0 +1,116 @@ +package dao + +import ( + "gorm.io/gorm" + "hospital-admin-api/api/model" + "hospital-admin-api/api/requests" + "hospital-admin-api/global" +) + +type ProductPlatformDao struct { +} + +// GetProductPlatformById 获取平台商品数据-平台商品id +func (r *ProductPlatformDao) GetProductPlatformById(productPlatformId int64) (m *model.ProductPlatform, err error) { + err = global.Db.First(&m, productPlatformId).Error + if err != nil { + return nil, err + } + return m, nil +} + +// GetProductPlatformList 获取平台商品列表 +func (r *ProductPlatformDao) GetProductPlatformList(maps interface{}) (m []*model.ProductPlatform, err error) { + err = global.Db.Where(maps).Find(&m).Error + if err != nil { + return nil, err + } + return m, nil +} + +// DeleteProductPlatform 删除平台商品 +func (r *ProductPlatformDao) DeleteProductPlatform(tx *gorm.DB, maps interface{}) error { + err := tx.Where(maps).Delete(&model.ProductPlatform{}).Error + if err != nil { + return err + } + return nil +} + +// EditProductPlatform 修改平台商品 +func (r *ProductPlatformDao) EditProductPlatform(tx *gorm.DB, maps interface{}, data interface{}) error { + err := tx.Model(&model.ProductPlatform{}).Where(maps).Updates(data).Error + if err != nil { + return err + } + return nil +} + +// EditProductPlatformByUserId 修改平台商品-平台商品id +func (r *ProductPlatformDao) EditProductPlatformByUserId(tx *gorm.DB, productPlatformId int64, data interface{}) error { + err := tx.Model(&model.ProductPlatform{}).Where("product_platform_id = ?", productPlatformId).Updates(data).Error + if err != nil { + return err + } + return nil +} + +// AddProductPlatform 新增平台商品 +func (r *ProductPlatformDao) AddProductPlatform(tx *gorm.DB, model *model.ProductPlatform) (*model.ProductPlatform, error) { + if err := tx.Create(model).Error; err != nil { + return nil, err + } + return model, nil +} + +// GetPlatformProductPageSearch 获取平台商品列表-分页 +func (r *ProductPlatformDao) GetPlatformProductPageSearch(req requests.GetPlatformProductPage, page, pageSize int) (m []*model.ProductPlatform, total int64, err error) { + var totalRecords int64 + + // 构建查询条件 + query := global.Db.Model(&model.ProductPlatform{}) + + // 商品名称 + if req.ProductName != "" { + query = query.Where("product_name LIKE ?", "%"+req.ProductName+"%") + } + + // 药品类型 + if req.ProductType != nil { + query = query.Where("product_type = ?", req.ProductType) + } + + // 处方平台编码 + 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+"%") + } + + // 排序 + 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 +} diff --git a/api/dto/PlatformProduct.go b/api/dto/PlatformProduct.go new file mode 100644 index 0000000..ffe34e5 --- /dev/null +++ b/api/dto/PlatformProduct.go @@ -0,0 +1,78 @@ +package dto + +import ( + "fmt" + "hospital-admin-api/api/model" +) + +type ProductPlatformDto struct { + ProductPlatformId string `json:"product_platform_id"` // 主键id + ProductName string `json:"product_name"` // 商品名称 + ProductPrice float64 `json:"product_price"` // 商品价格 + ProductType int `json:"product_type"` // 药品类型（0:未知 1:中成药 2:西药） + ProductPlatformCode string `json:"product_platform_code"` // 处方平台商品编码 + ProductPharmacyCode string `json:"product_pharmacy_code"` // 第三方药店商品编码 + ProductSpec string `json:"product_spec"` // 商品规格 + LicenseNumber string `json:"license_number"` // 批准文号 + Manufacturer string `json:"manufacturer"` // 生产厂家 + SingleUnit string `json:"single_unit"` // 单次剂量单位 + PackagingUnit string `json:"packaging_unit"` // 基本包装单位 + PackagingCount string `json:"packaging_count"` // 基本包装数量 + RetailUnit string `json:"retail_unit"` // 零售单位 + CreatedAt model.LocalTime `json:"created_at"` // 创建时间 + UpdatedAt model.LocalTime `json:"updated_at"` // 更新时间 +} + +// GetProductPlatformDto 平台商品详情 +func GetProductPlatformDto(m *model.ProductPlatform) *ProductPlatformDto { + return &ProductPlatformDto{ + ProductPlatformId: fmt.Sprintf("%d", m.ProductPlatformId), + ProductName: m.ProductName, + ProductPrice: m.ProductPrice, + ProductType: m.ProductType, + ProductPlatformCode: m.ProductPlatformCode, + ProductPharmacyCode: m.ProductPharmacyCode, + ProductSpec: m.ProductSpec, + LicenseNumber: m.LicenseNumber, + Manufacturer: m.Manufacturer, + SingleUnit: m.SingleUnit, + PackagingUnit: m.PackagingUnit, + PackagingCount: m.PackagingCount, + RetailUnit: m.RetailUnit, + CreatedAt: m.CreatedAt, + UpdatedAt: m.UpdatedAt, + } +} + +// GetProductPlatformListDto 平台商品列表 +func GetProductPlatformListDto(m []*model.ProductPlatform) []*ProductPlatformDto { + // 处理返回值 + responses := make([]*ProductPlatformDto, len(m)) + + if len(m) > 0 { + for i, v := range m { + response := &ProductPlatformDto{ + ProductPlatformId: fmt.Sprintf("%d", v.ProductPlatformId), + ProductName: v.ProductName, + ProductPrice: v.ProductPrice, + ProductType: v.ProductType, + ProductPlatformCode: v.ProductPlatformCode, + ProductPharmacyCode: v.ProductPharmacyCode, + ProductSpec: v.ProductSpec, + LicenseNumber: v.LicenseNumber, + Manufacturer: v.Manufacturer, + SingleUnit: v.SingleUnit, + PackagingUnit: v.PackagingUnit, + PackagingCount: v.PackagingCount, + RetailUnit: v.RetailUnit, + CreatedAt: v.CreatedAt, + UpdatedAt: v.UpdatedAt, + } + + // 将转换后的结构体添加到新切片中 + responses[i] = response + } + } + + return responses +} diff --git a/api/model/productPlatform.go b/api/model/productPlatform.go new file mode 100644 index 0000000..acaa3c6 --- /dev/null +++ b/api/model/productPlatform.go @@ -0,0 +1,43 @@ +package model + +import ( + "gorm.io/gorm" + "hospital-admin-api/global" + "time" +) + +// ProductPlatform 商品表-处方平台 +type ProductPlatform struct { + ProductPlatformId int64 `gorm:"column:product_platform_id;type:bigint(19);primary_key;comment:主键id" json:"product_platform_id"` + ProductName string `gorm:"column:product_name;type:varchar(255);comment:商品名称" json:"product_name"` + ProductPrice float64 `gorm:"column:product_price;type:decimal(10,2);comment:商品价格" json:"product_price"` + ProductType int `gorm:"column:product_type;type:tinyint(4);default:1;comment:药品类型（0:未知 1:中成药 2:西药）" json:"product_type"` + ProductPlatformCode string `gorm:"column:product_platform_code;type:varchar(100);comment:处方平台商品编码" json:"product_platform_code"` + ProductPharmacyCode string `gorm:"column:product_pharmacy_code;type:varchar(100);comment:第三方药店商品编码" json:"product_pharmacy_code"` + ProductSpec string `gorm:"column:product_spec;type:varchar(255);comment:商品规格" json:"product_spec"` + LicenseNumber string `gorm:"column:license_number;type:varchar(255);comment:批准文号" json:"license_number"` + Manufacturer string `gorm:"column:manufacturer;type:varchar(255);comment:生产厂家" json:"manufacturer"` + SingleUnit string `gorm:"column:single_unit;type:varchar(50);comment:单次剂量单位" json:"single_unit"` + PackagingUnit string `gorm:"column:packaging_unit;type:varchar(20);comment:基本包装单位" json:"packaging_unit"` + PackagingCount string `gorm:"column:packaging_count;type:varchar(20);comment:基本包装数量" json:"packaging_count"` + RetailUnit string `gorm:"column:retail_unit;type:varchar(20);comment:零售单位" json:"retail_unit"` + Model +} + +func (m *ProductPlatform) TableName() string { + return "gdxz_product_platform" +} + +func (m *ProductPlatform) BeforeCreate(tx *gorm.DB) error { + if m.ProductPlatformId == 0 { + m.ProductPlatformId = global.Snowflake.Generate().Int64() + } + + m.CreatedAt = LocalTime(time.Now()) + tx.Statement.SetColumn("CreatedAt", m.CreatedAt) + + m.UpdatedAt = LocalTime(time.Now()) + tx.Statement.SetColumn("UpdatedAt", m.UpdatedAt) + + return nil +} diff --git a/api/model/productPlatformAmount.go b/api/model/productPlatformAmount.go new file mode 100644 index 0000000..6e2ee78 --- /dev/null +++ b/api/model/productPlatformAmount.go @@ -0,0 +1,34 @@ +package model + +import ( + "gorm.io/gorm" + "hospital-admin-api/global" + "time" +) + +// ProductPlatformAmount 商品-库存表-处方平台 +type ProductPlatformAmount struct { + AmountId int64 `gorm:"column:amount_id;type:bigint(19);primary_key;comment:主键id" json:"amount_id"` + ProductPlatformId int64 `gorm:"column:product_platform_id;type:bigint(19);comment:处方平台商品id" json:"product_platform_id"` + ProductPlatformCode string `gorm:"column:product_platform_code;type:varchar(100);comment:处方平台商品编码" json:"product_platform_code"` + Stock uint `gorm:"column:stock;type:int(11) unsigned;default:0;comment:现有库存" json:"stock"` + Model +} + +func (m *ProductPlatformAmount) TableName() string { + return "gdxz_product_platform_amount" +} + +func (m *ProductPlatformAmount) BeforeCreate(tx *gorm.DB) error { + if m.AmountId == 0 { + m.AmountId = global.Snowflake.Generate().Int64() + } + + m.CreatedAt = LocalTime(time.Now()) + tx.Statement.SetColumn("CreatedAt", m.CreatedAt) + + m.UpdatedAt = LocalTime(time.Now()) + tx.Statement.SetColumn("UpdatedAt", m.UpdatedAt) + + return nil +} diff --git a/api/requests/product.go b/api/requests/product.go new file mode 100644 index 0000000..f84287b --- /dev/null +++ b/api/requests/product.go @@ -0,0 +1,17 @@ +package requests + +type ProductRequest struct { + GetPlatformProductPage // 获取平台商品列表-分页 +} + +// GetPlatformProductPage 获取平台商品列表-分页 +type GetPlatformProductPage struct { + Page int `json:"page" form:"page" label:"页码"` + PageSize int `json:"page_size" form:"page_size" label:"每页个数"` + ProductName string `json:"product_name" form:"product_name" label:"商品名称"` // 商品名称 + ProductType *int `json:"product_type" form:"product_type" label:"药品类型"` // 药品类型（0:未知 1:中成药 2:西药） + ProductPlatformCode string `json:"product_platform_code" form:"product_platform_code" label:"处方平台编码"` // 处方平台商品编码 + ProductPharmacyCode string `json:"product_pharmacy_code" form:"product_pharmacy_code" label:"药店编码"` // 第三方药店商品编码 + LicenseNumber string `json:"license_number" form:"license_number" label:"批准文号"` // 批准文号 + Manufacturer string `json:"manufacturer" form:"manufacturer" label:"生产厂家"` // 生产厂家 +} diff --git a/api/router/router.go b/api/router/router.go index dcccc87..11ff77e 100644 --- a/api/router/router.go +++ b/api/router/router.go @@ -651,4 +651,37 @@ func privateRouter(r *gin.Engine, api controller.Api) { prescriptionGroup.POST("", api.Export.OrderPrescription) } } + + // 商品管理 + productGroup := adminGroup.Group("/product") + { + // 平台商品 + platformGroup := productGroup.Group("/platform") + { + // 获取平台商品列表-分页 + platformGroup.GET("", api.Product.GetPlatformProductPage) + + // 平台商品详情 + platformGroup.GET("/:product_platform_id", api.Product.GetPlatformProduct) + } + + // 系统商品 + systemGroup := productGroup.Group("/system") + { + // 获取系统商品列表-分页 + systemGroup.GET("", api.Product.GetSystemProductPage) + + // 系统商品详情 + systemGroup.GET("/:product_id", api.OrderProduct.GetOrderProduct) + + // 新增系统商品 + systemGroup.POST("", api.Dept.AddDept) + + // 删除系统商品 + systemGroup.DELETE("", api.Dept.DeleteDept) + + // 修改系统商品 + systemGroup.PUT("/:product_id", api.Dept.PutDept) + } + } } diff --git a/api/service/product.go b/api/service/product.go new file mode 100644 index 0000000..10775d8 --- /dev/null +++ b/api/service/product.go @@ -0,0 +1,25 @@ +package service + +import ( + "errors" + "hospital-admin-api/api/dao" + "hospital-admin-api/api/dto" +) + +type ProductService struct { +} + +// GetPlatformProduct 平台商品详情 +func (r *ProductService) GetPlatformProduct(productPlatformId int64) (g *dto.ProductPlatformDto, err error) { + // 获取平台商品数据 + productPlatformDao := dao.ProductPlatformDao{} + productPlatform, err := productPlatformDao.GetProductPlatformById(productPlatformId) + if err != nil || productPlatform == nil { + return nil, errors.New(err.Error()) + } + + // 处理返回值 + g = dto.GetProductPlatformDto(productPlatform) + + return g, nil +}