增加药房管理

api/controller/base.go

@@ -41,6 +41,7 @@ type userDoctorManage struct {
 type basic struct {
 	Department            // 科室管理
 	Hospital              // 医院管理
+	Pharmacy              // 药房管理
 	DiseaseClassExpertise // 专长管理
 	Bank                  // 银行管理
 }

api/controller/pharmacy.go

@@ -0,0 +1,234 @@
+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 Pharmacy struct{}
+
+// GetPharmacyPage 获取药房列表-分页
+func (r *Pharmacy) GetPharmacyPage(c *gin.Context) {
+	pharmacyRequest := requests.PharmacyRequest{}
+	req := pharmacyRequest.GetPharmacyPage
+	if err := c.ShouldBindJSON(&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
+	}
+
+	pharmacyDao := dao.PharmacyDao{}
+	pharmacies, total, err := pharmacyDao.GetPharmacyPageSearch(req, req.Page, req.PageSize)
+	if err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	resList := dto.GetPharmacyListDto(pharmacies)
+
+	result := make(map[string]interface{})
+	result["page"] = req.Page
+	result["page_size"] = req.PageSize
+	result["total"] = total
+	result["data"] = resList
+	responses.OkWithData(result, c)
+}
+
+// GetPharmacyList 获取药房列表（下拉/限制条件）
+func (r *Pharmacy) GetPharmacyList(c *gin.Context) {
+	pharmacyRequest := requests.PharmacyRequest{}
+	req := pharmacyRequest.GetPharmacyList
+	if err := c.ShouldBind(&req); err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	maps := make(map[string]interface{})
+	if req.PharmacyName != "" {
+		maps["pharmacy_name"] = req.PharmacyName
+	}
+	if req.PharmacyCode != "" {
+		maps["pharmacy_code"] = req.PharmacyCode
+	}
+	if req.Status != nil {
+		maps["status"] = *req.Status
+	} else {
+		maps["status"] = 1 // 默认只查正常启用的
+	}
+	if req.IsPickup != nil {
+		maps["is_pickup"] = *req.IsPickup
+	}
+
+	pharmacyDao := dao.PharmacyDao{}
+	pharmacies, err := pharmacyDao.GetPharmacyList(maps)
+	if err != nil {
+		responses.Ok(c)
+		return
+	}
+
+	resList := dto.GetPharmacyListDto(pharmacies)
+	responses.OkWithData(resList, c)
+}
+
+// GetPharmacy 获取药房详情
+func (r *Pharmacy) GetPharmacy(c *gin.Context) {
+	id := c.Param("pharmacy_id")
+	if id == "" {
+		responses.FailWithMessage("缺少参数", c)
+		return
+	}
+
+	pharmacyId, err := strconv.ParseInt(id, 10, 64)
+	if err != nil {
+		responses.Fail(c)
+		return
+	}
+
+	pharmacyService := service.PharmacyService{}
+	pharmacyDto, err := pharmacyService.GetPharmacy(pharmacyId)
+	if err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	responses.OkWithData(pharmacyDto, c)
+}
+
+// AddPharmacy 新增药房
+func (r *Pharmacy) AddPharmacy(c *gin.Context) {
+	pharmacyRequest := requests.PharmacyRequest{}
+	req := pharmacyRequest.AddPharmacy
+	if err := c.ShouldBindJSON(&req); err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	if err := global.Validate.Struct(req); err != nil {
+		responses.FailWithMessage(utils.Translate(err), c)
+		return
+	}
+
+	pharmacyService := service.PharmacyService{}
+	_, err := pharmacyService.AddPharmacy(req)
+	if err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	responses.Ok(c)
+}
+
+// PutPharmacy 修改药房
+func (r *Pharmacy) PutPharmacy(c *gin.Context) {
+	pharmacyRequest := requests.PharmacyRequest{}
+	req := pharmacyRequest.PutPharmacy
+	if err := c.ShouldBindJSON(&req); err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	if err := global.Validate.Struct(req); err != nil {
+		responses.FailWithMessage(utils.Translate(err), c)
+		return
+	}
+
+	id := c.Param("pharmacy_id")
+	if id == "" {
+		responses.FailWithMessage("缺少参数", c)
+		return
+	}
+
+	pharmacyId, err := strconv.ParseInt(id, 10, 64)
+	if err != nil {
+		responses.Fail(c)
+		return
+	}
+
+	pharmacyService := service.PharmacyService{}
+	_, err = pharmacyService.PutPharmacy(pharmacyId, req)
+	if err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	responses.Ok(c)
+}
+
+// PutPharmacyStatus 修改药房状态
+func (r *Pharmacy) PutPharmacyStatus(c *gin.Context) {
+	pharmacyRequest := requests.PharmacyRequest{}
+	req := pharmacyRequest.PutPharmacyStatus
+	if err := c.ShouldBindJSON(&req); err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	if err := global.Validate.Struct(req); err != nil {
+		responses.FailWithMessage(utils.Translate(err), c)
+		return
+	}
+
+	id := c.Param("pharmacy_id")
+	if id == "" {
+		responses.FailWithMessage("缺少参数", c)
+		return
+	}
+
+	pharmacyId, err := strconv.ParseInt(id, 10, 64)
+	if err != nil {
+		responses.Fail(c)
+		return
+	}
+
+	pharmacyService := service.PharmacyService{}
+	_, err = pharmacyService.PutPharmacyStatus(pharmacyId, req)
+	if err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	responses.Ok(c)
+}
+
+// DeletePharmacy 删除药房
+func (r *Pharmacy) DeletePharmacy(c *gin.Context) {
+	id := c.Param("pharmacy_id")
+	if id == "" {
+		responses.FailWithMessage("缺少参数", c)
+		return
+	}
+
+	pharmacyId, err := strconv.ParseInt(id, 10, 64)
+	if err != nil {
+		responses.Fail(c)
+		return
+	}
+
+	pharmacyService := service.PharmacyService{}
+	_, err = pharmacyService.DeletePharmacy(pharmacyId)
+	if err != nil {
+		responses.FailWithMessage(err.Error(), c)
+		return
+	}
+
+	responses.Ok(c)
+}

api/dao/pharmacy.go

@@ -0,0 +1,111 @@
+package dao
+
+import (
+	"gorm.io/gorm"
+	"hospital-admin-api/api/model"
+	"hospital-admin-api/api/requests"
+	"hospital-admin-api/global"
+)
+
+type PharmacyDao struct{}
+
+// GetPharmacyById 获取药房数据-药房id
+func (r *PharmacyDao) GetPharmacyById(pharmacyId int64) (m *model.Pharmacy, err error) {
+	err = global.Db.Where("pharmacy_id = ? AND status != ?", pharmacyId, 2).First(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// GetPharmacyByCode 获取药房数据-药房代码
+func (r *PharmacyDao) GetPharmacyByCode(code string) (m *model.Pharmacy, err error) {
+	err = global.Db.Where("pharmacy_code = ? AND status != ?", code, 2).First(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// AddPharmacy 新增药房
+func (r *PharmacyDao) AddPharmacy(tx *gorm.DB, m *model.Pharmacy) (*model.Pharmacy, error) {
+	if err := tx.Create(m).Error; err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// EditPharmacyById 修改药房-药房id
+func (r *PharmacyDao) EditPharmacyById(tx *gorm.DB, pharmacyId int64, data interface{}) error {
+	err := tx.Model(&model.Pharmacy{}).Where("pharmacy_id = ?", pharmacyId).Updates(data).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// DeletePharmacyById 软删除药房-药房id
+func (r *PharmacyDao) DeletePharmacyById(tx *gorm.DB, pharmacyId int64) error {
+	err := tx.Model(&model.Pharmacy{}).Where("pharmacy_id = ?", pharmacyId).Update("status", 2).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// GetPharmacyList 获取药房列表
+func (r *PharmacyDao) GetPharmacyList(maps interface{}) (m []*model.Pharmacy, err error) {
+	err = global.Db.Where(maps).Where("status != ?", 2).Order("created_at desc").Find(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// GetPharmacyPageSearch 获取药房列表-分页
+func (r *PharmacyDao) GetPharmacyPageSearch(req requests.GetPharmacyPage, page, pageSize int) (m []*model.Pharmacy, total int64, err error) {
+	var totalRecords int64
+
+	query := global.Db.Model(&model.Pharmacy{}).Where("status != ?", 2)
+
+	if req.PharmacyName != "" {
+		query = query.Where("pharmacy_name LIKE ?", "%"+req.PharmacyName+"%")
+	}
+
+	if req.PharmacyCode != "" {
+		query = query.Where("pharmacy_code LIKE ?", "%"+req.PharmacyCode+"%")
+	}
+
+	if req.Status != nil {
+		query = query.Where("status = ?", *req.Status)
+	}
+
+	if req.IsPickup != nil {
+		query = query.Where("is_pickup = ?", *req.IsPickup)
+	}
+
+	if req.ProvinceId != 0 {
+		query = query.Where("province_id = ?", req.ProvinceId)
+	}
+
+	if req.CityId != nil {
+		query = query.Where("city_id = ?", req.CityId)
+	}
+
+	if req.CountyId != nil {
+		query = query.Where("county_id = ?", req.CountyId)
+	}
+
+	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/dto/Pharmacy.go

@@ -0,0 +1,62 @@
+package dto
+
+import (
+	"fmt"
+	"hospital-admin-api/api/model"
+)
+
+type PharmacyDto struct {
+	PharmacyId            string          `json:"pharmacy_id"`             // 主键id
+	PharmacyName          string          `json:"pharmacy_name"`           // 药房名称
+	PharmacyCode          string          `json:"pharmacy_code"`           // 药房代码
+	Postage               float64         `json:"postage"`                 // 基础邮费
+	FreeShippingThreshold float64         `json:"free_shipping_threshold"` // 满XX包邮门槛金额
+	IsPickup              int             `json:"is_pickup"`               // 是否支持自提（0:否 1:是）
+	Telephone             string          `json:"telephone"`               // 电话
+	ProvinceId            int             `json:"province_id"`             // 省份id
+	Province              string          `json:"province"`                // 省份
+	CityId                int             `json:"city_id"`                 // 城市id
+	City                  string          `json:"city"`                    // 城市
+	CountyId              int             `json:"county_id"`               // 区县id
+	County                string          `json:"county"`                  // 区县
+	Address               string          `json:"address"`                 // 详细地址
+	FullAddress           string          `json:"full_address"`            // 完整地址（省市区+详细地址）
+	Status                int             `json:"status"`                  // 状态（0:禁用 1:正常 2:删除）
+	CreatedAt             model.LocalTime `json:"created_at"`              // 创建时间
+	UpdatedAt             model.LocalTime `json:"updated_at"`              // 修改时间
+}
+
+func GetPharmacyDto(m *model.Pharmacy) *PharmacyDto {
+	if m == nil {
+		return nil
+	}
+	fullAddress := fmt.Sprintf("%s%s%s%s", m.Province, m.City, m.County, m.Address)
+	return &PharmacyDto{
+		PharmacyId:            fmt.Sprintf("%d", m.PharmacyId),
+		PharmacyName:          m.PharmacyName,
+		PharmacyCode:          m.PharmacyCode,
+		Postage:               m.Postage,
+		FreeShippingThreshold: m.FreeShippingThreshold,
+		IsPickup:              m.IsPickup,
+		Telephone:             m.Telephone,
+		ProvinceId:            m.ProvinceId,
+		Province:              m.Province,
+		CityId:                m.CityId,
+		City:                  m.City,
+		CountyId:              m.CountyId,
+		County:                m.County,
+		Address:               m.Address,
+		FullAddress:           fullAddress,
+		Status:                m.Status,
+		CreatedAt:             m.CreatedAt,
+		UpdatedAt:             m.UpdatedAt,
+	}
+}
+
+func GetPharmacyListDto(m []*model.Pharmacy) []PharmacyDto {
+	responses := make([]PharmacyDto, len(m))
+	for i, v := range m {
+		responses[i] = *GetPharmacyDto(v)
+	}
+	return responses
+}

api/model/pharmacy.go

@@ -0,0 +1,45 @@
+package model
+
+import (
+	"gorm.io/gorm"
+	"hospital-admin-api/global"
+	"time"
+)
+
+// Pharmacy 药房信息表
+type Pharmacy struct {
+	PharmacyId            int64   `gorm:"column:pharmacy_id;type:bigint(20);primary_key;comment:主键id" json:"pharmacy_id"`
+	PharmacyName          string  `gorm:"column:pharmacy_name;type:varchar(100);comment:药房名称;NOT NULL" json:"pharmacy_name"`
+	PharmacyCode          string  `gorm:"column:pharmacy_code;type:varchar(64);comment:药房代码;NOT NULL" json:"pharmacy_code"`
+	Postage               float64 `gorm:"column:postage;type:decimal(10,2);default:0.00;comment:基础邮费" json:"postage"`
+	FreeShippingThreshold float64 `gorm:"column:free_shipping_threshold;type:decimal(10,2);default:0.00;comment:满XX包邮门槛金额" json:"free_shipping_threshold"`
+	IsPickup              int     `gorm:"column:is_pickup;type:tinyint(1);default:0;comment:是否支持自提（0:否 1:是）" json:"is_pickup"`
+	Telephone             string  `gorm:"column:telephone;type:varchar(30);comment:电话" json:"telephone"`
+	ProvinceId            int     `gorm:"column:province_id;type:int(11);default:0;comment:省份id" json:"province_id"`
+	Province              string  `gorm:"column:province;type:varchar(50);comment:省份" json:"province"`
+	CityId                int     `gorm:"column:city_id;type:int(11);default:0;comment:城市id" json:"city_id"`
+	City                  string  `gorm:"column:city;type:varchar(50);comment:城市" json:"city"`
+	CountyId              int     `gorm:"column:county_id;type:int(11);default:0;comment:区县id" json:"county_id"`
+	County                string  `gorm:"column:county;type:varchar(50);comment:区县" json:"county"`
+	Address               string  `gorm:"column:address;type:varchar(255);comment:地址" json:"address"`
+	Status                int     `gorm:"column:status;type:tinyint(1);default:1;comment:状态（0:禁用 1:正常 2:删除）" json:"status"`
+	Model
+}
+
+func (m *Pharmacy) TableName() string {
+	return "gdxz_pharmacy"
+}
+
+func (m *Pharmacy) BeforeCreate(tx *gorm.DB) error {
+	if m.PharmacyId == 0 {
+		m.PharmacyId = 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
+}

api/requests/pharmacy.go

@@ -0,0 +1,65 @@
+package requests
+
+type PharmacyRequest struct {
+	GetPharmacyList   // 获取药房列表
+	GetPharmacyPage   // 获取药房列表-分页
+	AddPharmacy       // 新增药房
+	PutPharmacy       // 修改药房
+	PutPharmacyStatus // 修改药房状态
+}
+
+// GetPharmacyList 获取药房列表
+type GetPharmacyList struct {
+	PharmacyName string `json:"pharmacy_name" form:"pharmacy_name" label:"药房名称"`
+	PharmacyCode string `json:"pharmacy_code" form:"pharmacy_code" label:"药房代码"`
+	Status       *int   `json:"status" form:"status" label:"状态"`
+	IsPickup     *int   `json:"is_pickup" form:"is_pickup" label:"是否支持自提"`
+}
+
+// GetPharmacyPage 获取药房列表-分页
+type GetPharmacyPage struct {
+	Page         int    `json:"page" form:"page" label:"页码"`
+	PageSize     int    `json:"page_size" form:"page_size" label:"每页个数"`
+	PharmacyName string `json:"pharmacy_name" form:"pharmacy_name" label:"药房名称"`
+	PharmacyCode string `json:"pharmacy_code" form:"pharmacy_code" label:"药房代码"`
+	Status       *int   `json:"status" form:"status" label:"状态"`
+	IsPickup     *int   `json:"is_pickup" form:"is_pickup" label:"是否支持自提"`
+	ProvinceId   int    `json:"province_id" form:"province_id" label:"省份id"`
+	CityId       *int   `json:"city_id" form:"city_id" label:"城市id"`
+	CountyId     *int   `json:"county_id" form:"county_id" label:"区县id"`
+}
+
+// AddPharmacy 新增药房
+type AddPharmacy struct {
+	PharmacyName          string   `json:"pharmacy_name" form:"pharmacy_name" label:"药房名称" validate:"required"`
+	PharmacyCode          string   `json:"pharmacy_code" form:"pharmacy_code" label:"药房代码" validate:"required"`
+	Postage               *float64 `json:"postage" form:"postage" label:"邮费" validate:"required,gte=0"`
+	FreeShippingThreshold *float64 `json:"free_shipping_threshold" form:"free_shipping_threshold" label:"满XX包邮" validate:"required,gte=0"`
+	IsPickup              *int     `json:"is_pickup" form:"is_pickup" label:"是否支持自提" validate:"required,oneof=0 1"`
+	Telephone             string   `json:"telephone" form:"telephone" label:"电话"`
+	ProvinceId            int      `json:"province_id" form:"province_id" label:"省份id"`
+	CityId                int      `json:"city_id" form:"city_id" label:"城市id"`
+	CountyId              int      `json:"county_id" form:"county_id" label:"区县id"`
+	Address               string   `json:"address" form:"address" label:"地址" validate:"required"`
+	Status                *int     `json:"status" form:"status" label:"状态" validate:"omitempty,oneof=0 1"`
+}
+
+// PutPharmacy 修改药房
+type PutPharmacy struct {
+	PharmacyName          string   `json:"pharmacy_name" form:"pharmacy_name" label:"药房名称" validate:"required"`
+	PharmacyCode          string   `json:"pharmacy_code" form:"pharmacy_code" label:"药房代码" validate:"required"`
+	Postage               *float64 `json:"postage" form:"postage" label:"邮费" validate:"required,gte=0"`
+	FreeShippingThreshold *float64 `json:"free_shipping_threshold" form:"free_shipping_threshold" label:"满XX包邮" validate:"required,gte=0"`
+	IsPickup              *int     `json:"is_pickup" form:"is_pickup" label:"是否支持自提" validate:"required,oneof=0 1"`
+	Telephone             string   `json:"telephone" form:"telephone" label:"电话"`
+	ProvinceId            int      `json:"province_id" form:"province_id" label:"省份id"`
+	CityId                int      `json:"city_id" form:"city_id" label:"城市id"`
+	CountyId              int      `json:"county_id" form:"county_id" label:"区县id"`
+	Address               string   `json:"address" form:"address" label:"地址" validate:"required"`
+	Status                *int     `json:"status" form:"status" label:"状态" validate:"omitempty,oneof=0 1"`
+}
+
+// PutPharmacyStatus 修改药房状态
+type PutPharmacyStatus struct {
+	Status *int `json:"status" form:"status" label:"状态" validate:"required,oneof=0 1"`
+}

api/router/router.go

@@ -161,6 +161,13 @@ func basicRouter(r *gin.Engine, api controller.Api) {
 			hospitalGroup.GET("/list", api.Hospital.GetHospitalList)
 		}
 
+		// 药房管理-基础数据
+		pharmacyGroup := basicGroup.Group("/pharmacy")
+		{
+			// 获取药房列表
+			pharmacyGroup.GET("/list", api.Pharmacy.GetPharmacyList)
+		}
+
 		// 医生专长管理-基础数据
 		expertiseGroup := basicGroup.Group("/expertise")
 		{
@@ -885,6 +892,31 @@ func privateRouter(r *gin.Engine, api controller.Api) {
 			hospitalGroup.PUT("/:hospital_id", api.Hospital.PutHospital)
 		}
 
+		// 药房管理
+		pharmacyGroup := basicGroup.Group("/pharmacy")
+		{
+			// 获取药房列表-分页
+			pharmacyGroup.POST("/page", api.Pharmacy.GetPharmacyPage)
+
+			// 获取药房列表
+			pharmacyGroup.GET("/list", api.Pharmacy.GetPharmacyList)
+
+			// 获取药房详情
+			pharmacyGroup.GET("/:pharmacy_id", api.Pharmacy.GetPharmacy)
+
+			// 新增药房
+			pharmacyGroup.POST("", api.Pharmacy.AddPharmacy)
+
+			// 修改药房
+			pharmacyGroup.PUT("/:pharmacy_id", api.Pharmacy.PutPharmacy)
+
+			// 修改药房状态
+			pharmacyGroup.PUT("/status/:pharmacy_id", api.Pharmacy.PutPharmacyStatus)
+
+			// 删除药房
+			pharmacyGroup.DELETE("/:pharmacy_id", api.Pharmacy.DeletePharmacy)
+		}
+
 		// 科普分类管理
 		articleClassGroup := basicGroup.Group("/article/class")
 		{

api/service/pharmacy.go

@@ -0,0 +1,261 @@
+package service
+
+import (
+	"errors"
+	"fmt"
+	"gorm.io/gorm"
+	"hospital-admin-api/api/dao"
+	"hospital-admin-api/api/dto"
+	"hospital-admin-api/api/model"
+	"hospital-admin-api/api/requests"
+	"hospital-admin-api/global"
+)
+
+type PharmacyService struct{}
+
+// AddPharmacy 新增药房
+func (r *PharmacyService) AddPharmacy(req requests.AddPharmacy) (bool, error) {
+	pharmacyDao := dao.PharmacyDao{}
+
+	// 检测药房代码是否已存在
+	existPharmacy, err := pharmacyDao.GetPharmacyByCode(req.PharmacyCode)
+	if err == nil && existPharmacy != nil {
+		return false, errors.New("药房代码已存在，请勿重复添加")
+	}
+
+	var province string
+	var city string
+	var county string
+
+	areaDao := dao.AreaDao{}
+	if req.ProvinceId != 0 {
+		area, err := areaDao.GetAreaById(req.ProvinceId)
+		if err != nil || area == nil {
+			return false, errors.New("省份数据错误")
+		}
+		province = area.AreaName
+	}
+
+	if req.CityId != 0 {
+		area, err := areaDao.GetAreaById(req.CityId)
+		if err != nil || area == nil {
+			return false, errors.New("城市数据错误")
+		}
+		city = area.AreaName
+	}
+
+	if req.CountyId != 0 {
+		area, err := areaDao.GetAreaById(req.CountyId)
+		if err != nil || area == nil {
+			return false, errors.New("区县数据错误")
+		}
+		county = area.AreaName
+	}
+
+	status := 1
+	if req.Status != nil {
+		status = *req.Status
+	}
+
+	// 开启事务
+	tx := global.Db.Begin()
+	defer func() {
+		if rec := recover(); rec != nil {
+			tx.Rollback()
+		}
+	}()
+
+	pharmacy := &model.Pharmacy{
+		PharmacyName:          req.PharmacyName,
+		PharmacyCode:          req.PharmacyCode,
+		Postage:               *req.Postage,
+		FreeShippingThreshold: *req.FreeShippingThreshold,
+		IsPickup:              *req.IsPickup,
+		Telephone:             req.Telephone,
+		ProvinceId:            req.ProvinceId,
+		Province:              province,
+		CityId:                req.CityId,
+		City:                  city,
+		CountyId:              req.CountyId,
+		County:                county,
+		Address:               req.Address,
+		Status:                status,
+	}
+
+	pharmacy, err = pharmacyDao.AddPharmacy(tx, pharmacy)
+	if err != nil || pharmacy == nil {
+		tx.Rollback()
+		return false, errors.New(err.Error())
+	}
+
+	tx.Commit()
+	return true, nil
+}
+
+// PutPharmacy 修改药房
+func (r *PharmacyService) PutPharmacy(pharmacyId int64, req requests.PutPharmacy) (bool, error) {
+	pharmacyDao := dao.PharmacyDao{}
+	pharmacy, err := pharmacyDao.GetPharmacyById(pharmacyId)
+	if err != nil || pharmacy == nil {
+		return false, errors.New("药房不存在或已删除")
+	}
+
+	// 如果修改了代码，需检查新代码是否被其他药房占用
+	if req.PharmacyCode != pharmacy.PharmacyCode {
+		exist, err := pharmacyDao.GetPharmacyByCode(req.PharmacyCode)
+		if err == nil && exist != nil && exist.PharmacyId != pharmacyId {
+			return false, errors.New("药房代码已被占用")
+		}
+	}
+
+	tx := global.Db.Begin()
+	defer func() {
+		if rec := recover(); rec != nil {
+			tx.Rollback()
+			fmt.Println(rec)
+		}
+	}()
+
+	pharmacyData := make(map[string]interface{})
+
+	if req.PharmacyName != pharmacy.PharmacyName {
+		pharmacyData["pharmacy_name"] = req.PharmacyName
+	}
+
+	if req.PharmacyCode != pharmacy.PharmacyCode {
+		pharmacyData["pharmacy_code"] = req.PharmacyCode
+	}
+
+	if *req.Postage != pharmacy.Postage {
+		pharmacyData["postage"] = *req.Postage
+	}
+
+	if *req.FreeShippingThreshold != pharmacy.FreeShippingThreshold {
+		pharmacyData["free_shipping_threshold"] = *req.FreeShippingThreshold
+	}
+
+	if *req.IsPickup != pharmacy.IsPickup {
+		pharmacyData["is_pickup"] = *req.IsPickup
+	}
+
+	if req.Telephone != pharmacy.Telephone {
+		pharmacyData["telephone"] = req.Telephone
+	}
+
+	if req.ProvinceId != 0 && req.ProvinceId != pharmacy.ProvinceId {
+		areaDao := dao.AreaDao{}
+		area, err := areaDao.GetAreaById(req.ProvinceId)
+		if err != nil || area == nil {
+			return false, errors.New("省份数据错误")
+		}
+		pharmacyData["province_id"] = req.ProvinceId
+		pharmacyData["province"] = area.AreaName
+	}
+
+	if req.CityId != 0 && req.CityId != pharmacy.CityId {
+		areaDao := dao.AreaDao{}
+		area, err := areaDao.GetAreaById(req.CityId)
+		if err != nil || area == nil {
+			return false, errors.New("城市数据错误")
+		}
+		pharmacyData["city_id"] = req.CityId
+		pharmacyData["city"] = area.AreaName
+	}
+
+	if req.CountyId != 0 && req.CountyId != pharmacy.CountyId {
+		areaDao := dao.AreaDao{}
+		area, err := areaDao.GetAreaById(req.CountyId)
+		if err != nil || area == nil {
+			return false, errors.New("区县数据错误")
+		}
+		pharmacyData["county_id"] = req.CountyId
+		pharmacyData["county"] = area.AreaName
+	}
+
+	if req.Address != pharmacy.Address {
+		pharmacyData["address"] = req.Address
+	}
+
+	if req.Status != nil && *req.Status != pharmacy.Status {
+		pharmacyData["status"] = *req.Status
+	}
+
+	if len(pharmacyData) > 0 {
+		err = pharmacyDao.EditPharmacyById(tx, pharmacyId, pharmacyData)
+		if err != nil {
+			tx.Rollback()
+			return false, errors.New(err.Error())
+		}
+	}
+
+	tx.Commit()
+	return true, nil
+}
+
+// PutPharmacyStatus 修改药房状态
+func (r *PharmacyService) PutPharmacyStatus(pharmacyId int64, req requests.PutPharmacyStatus) (bool, error) {
+	pharmacyDao := dao.PharmacyDao{}
+	pharmacy, err := pharmacyDao.GetPharmacyById(pharmacyId)
+	if err != nil || pharmacy == nil {
+		return false, errors.New("药房不存在或已删除")
+	}
+
+	data := map[string]interface{}{
+		"status": *req.Status,
+	}
+
+	tx := global.Db.Begin()
+	defer func() {
+		if rec := recover(); rec != nil {
+			tx.Rollback()
+		}
+	}()
+
+	err = pharmacyDao.EditPharmacyById(tx, pharmacyId, data)
+	if err != nil {
+		tx.Rollback()
+		return false, errors.New(err.Error())
+	}
+
+	tx.Commit()
+	return true, nil
+}
+
+// DeletePharmacy 软删除药房
+func (r *PharmacyService) DeletePharmacy(pharmacyId int64) (bool, error) {
+	pharmacyDao := dao.PharmacyDao{}
+	pharmacy, err := pharmacyDao.GetPharmacyById(pharmacyId)
+	if err != nil || pharmacy == nil {
+		return false, errors.New("药房不存在或已删除")
+	}
+
+	tx := global.Db.Begin()
+	defer func() {
+		if rec := recover(); rec != nil {
+			tx.Rollback()
+		}
+	}()
+
+	err = pharmacyDao.DeletePharmacyById(tx, pharmacyId)
+	if err != nil {
+		tx.Rollback()
+		return false, errors.New(err.Error())
+	}
+
+	tx.Commit()
+	return true, nil
+}
+
+// GetPharmacy 药房详情
+func (r *PharmacyService) GetPharmacy(pharmacyId int64) (*dto.PharmacyDto, error) {
+	pharmacyDao := dao.PharmacyDao{}
+	pharmacy, err := pharmacyDao.GetPharmacyById(pharmacyId)
+	if err != nil || pharmacy == nil {
+		if errors.Is(err, gorm.ErrRecordNotFound) || pharmacy == nil {
+			return nil, errors.New("未找到相关药房信息")
+		}
+		return nil, err
+	}
+
+	return dto.GetPharmacyDto(pharmacy), nil
+}