新增药品订单列表

2023-09-07 14:37:01 +08:00
parent 654c0fed05
commit e82932ab53
8 changed files with 595 additions and 8 deletions
@@ -0,0 +1,231 @@
+package dao
+
+import (
+	"gorm.io/gorm"
+	"gorm.io/gorm/clause"
+	"hospital-admin-api/api/model"
+	"hospital-admin-api/api/requests"
+	"hospital-admin-api/global"
+	"strings"
+	"time"
+)
+
+type OrderProductDao struct {
+}
+
+// GetOrderProductById 获取药品订单数据-药品订单id
+func (r *OrderProductDao) GetOrderProductById(orderProductId int64) (m *model.OrderProduct, err error) {
+	err = global.Db.First(&m, orderProductId).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// GetOrderProductPreloadById 获取药品订单数据-加载全部关联-药品订单id
+func (r *OrderProductDao) GetOrderProductPreloadById(orderProductId int64) (m *model.OrderProduct, err error) {
+	err = global.Db.Preload(clause.Associations).First(&m, orderProductId).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// DeleteOrderProduct 删除药品订单
+func (r *OrderProductDao) DeleteOrderProduct(tx *gorm.DB, maps interface{}) error {
+	err := tx.Where(maps).Delete(&model.OrderProduct{}).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// EditOrderProduct 修改药品订单
+func (r *OrderProductDao) EditOrderProduct(tx *gorm.DB, maps interface{}, data interface{}) error {
+	err := tx.Model(&model.OrderProduct{}).Where(maps).Updates(data).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// EditOrderProductById 修改药品订单-药品订单id
+func (r *OrderProductDao) EditOrderProductById(tx *gorm.DB, orderProductId int64, data interface{}) error {
+	err := tx.Model(&model.OrderProduct{}).Where("order_product_id = ?", orderProductId).Updates(data).Error
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+// GetOrderProductList 获取药品订单列表
+func (r *OrderProductDao) GetOrderProductList(maps interface{}) (m []*model.OrderProduct, err error) {
+	err = global.Db.Where(maps).Find(&m).Error
+	if err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+// AddOrderProduct 新增药品订单
+func (r *OrderProductDao) AddOrderProduct(tx *gorm.DB, model *model.OrderProduct) (*model.OrderProduct, error) {
+	if err := tx.Create(model).Error; err != nil {
+		return nil, err
+	}
+	return model, nil
+}
+
+// GetOrderProductPageSearch 获取药品订单列表-分页
+func (r *OrderProductDao) GetOrderProductPageSearch(req requests.GetOrderProductPage, page, pageSize int) (m []*model.OrderProduct, total int64, err error) {
+	var totalRecords int64
+
+	// 构建查询条件
+	query := global.Db.Model(&model.OrderProduct{})
+
+	// 医生
+	query = query.Preload("UserDoctor", func(db *gorm.DB) *gorm.DB {
+		return db.Omit("open_id", "union_id", "wx_session_key")
+	})
+
+	// 问诊订单
+	query = query.Preload("OrderInquiry", func(db *gorm.DB) *gorm.DB {
+		return db.Select("order_inquiry_id", "patient_name_mask", "patient_sex", "patient_age")
+	})
+
+	// 医生姓名
+	if req.DoctorName != "" {
+		subQuery := global.Db.Model(&model.UserDoctor{}).
+			Select("doctor_id").
+			Where("user_name LIKE ?", "%"+req.DoctorName+"%")
+
+		query = query.Where(gorm.Expr("doctor_id IN (?)", subQuery))
+	}
+
+	// 患者姓名-就诊人
+	if req.PatientName != "" {
+		subQuery := global.Db.Model(&model.OrderInquiry{}).
+			Select("order_inquiry_id").
+			Where("patient_name LIKE ?", "%"+req.PatientName+"%")
+
+		query = query.Where(gorm.Expr("order_inquiry_id IN (?)", subQuery))
+	}
+
+	// 订单编号
+	if req.OrderProductNo != "" {
+		query = query.Where("order_product_no = ?", req.OrderProductNo)
+	}
+
+	// 第三方支付流水号
+	if req.EscrowTradeNo != "" {
+		query = query.Where("escrow_trade_no = ?", req.EscrowTradeNo)
+	}
+
+	// 订单状态
+	if req.OrderProductStatus != nil {
+		query = query.Where("order_product_status = ?", req.OrderProductStatus)
+	}
+
+	// 支付渠道
+	if req.PayChannel != nil {
+		query = query.Where("pay_channel = ?", req.PayChannel)
+	}
+
+	// 支付状态
+	if req.PayStatus != nil {
+		query = query.Where("pay_status = ?", req.PayStatus)
+	}
+
+	// 订单取消原因
+	if req.CancelReason != nil {
+		query = query.Where("cancel_reason = ?", req.CancelReason)
+	}
+
+	// 物流编号
+	if req.LogisticsNo != "" {
+		query = query.Where("logistics_no = ?", req.LogisticsNo)
+	}
+
+	// 快递公司编码
+	if req.LogisticsCompanyCode != "" {
+		query = query.Where("logistics_company_code = ?", req.LogisticsCompanyCode)
+	}
+
+	// 订单备注
+	if req.Remarks != "" {
+		query = query.Where("remarks like ?", "%"+req.Remarks+"%")
+	}
+
+	// 退款状态
+	if req.RefundStatus != nil {
+		query = query.Where("refund_status = ?", req.RefundStatus)
+	}
+
+	// 上报处方平台状态
+	if req.ReportPreStatus != nil {
+		query = query.Where("report_pre_status = ?", req.ReportPreStatus)
+	}
+
+	// 发货时间
+	if req.DeliveryTime != "" {
+		deliveryTime := strings.Split(req.DeliveryTime, "&")
+		if len(deliveryTime) == 2 {
+			startTime, _ := time.Parse("2006-01-02", deliveryTime[0])
+			endTime, _ := time.Parse("2006-01-02", deliveryTime[1])
+			query = query.Where("delivery_time BETWEEN ? AND ?", startTime, endTime)
+		}
+	}
+
+	// 订单取消时间
+	if req.CancelTime != "" {
+		cancelTime := strings.Split(req.CancelTime, "&")
+		if len(cancelTime) == 2 {
+			startTime, _ := time.Parse("2006-01-02", cancelTime[0])
+			endTime, _ := time.Parse("2006-01-02", cancelTime[1])
+			query = query.Where("cancel_time BETWEEN ? AND ?", startTime, endTime)
+		}
+	}
+
+	// 支付时间
+	if req.PayTime != "" {
+		payTime := strings.Split(req.PayTime, "&")
+		if len(payTime) == 2 {
+			startTime, _ := time.Parse("2006-01-02", payTime[0])
+			endTime, _ := time.Parse("2006-01-02", payTime[1])
+			query = query.Where("complete_time BETWEEN ? AND ?", startTime, endTime)
+		}
+	}
+
+	// 上报处方平台时间
+	if req.ReportPreTime != "" {
+		reportPreTime := strings.Split(req.ReportPreTime, "&")
+		if len(reportPreTime) == 2 {
+			startTime, _ := time.Parse("2006-01-02", reportPreTime[0])
+			endTime, _ := time.Parse("2006-01-02", reportPreTime[1])
+			query = query.Where("report_pre_time BETWEEN ? AND ?", startTime, endTime)
+		}
+	}
+
+	// 收货人姓名
+	if req.ConsigneeName != "" {
+		query = query.Where("consignee_name LIKE ?", "%"+req.ConsigneeName+"%")
+	}
+
+	// 收货人电话
+	if req.ConsigneeTel != "" {
+		query = query.Where("consignee_tel LIKE ?", "%"+req.ConsigneeTel+"%")
+	}
+
+	// 排序
+	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
+}