基于Go + Golang + Uniapp + Vue + ElementUi + Goframe框架的新零售社交电商系统（除...

// +---------------------------------------------------------------------- // | ShopSuite商城系统 [ 赋能开发者，助力企业发展 ] // +---------------------------------------------------------------------- // | 版权所有 随商信息技术（上海）有限公司 // +---------------------------------------------------------------------- // | 未获商业授权前，不得将本软件用于商业用途。禁止整体或任何部分基础上以发展任何派生版本、 // | 修改版本或第三方版本用于重新分发。 // +---------------------------------------------------------------------- // | 官方网站: https://www.shopsuite.cn https://www.golershop.cn // +---------------------------------------------------------------------- // | 版权和免责声明: // | 本公司对该软件产品拥有知识产权（包括但不限于商标权、专利权、著作权、商业秘密等） // | 均受到相关法律法规的保护，任何个人、组织和单位不得在未经本团队书面授权的情况下对所授权 // | 软件框架产品本身申请相关的知识产权，禁止用于任何违法、侵害他人合法权益等恶意的行为，禁 // | 止用于任何违反我国法律法规的一切项目研发，任何个人、组织和单位用于项目研发而产生的任何 // | 意外、疏忽、合约毁坏、诽谤、版权或知识产权侵犯及其造成的损失 (包括但不限于直接、间接、 // | 附带或衍生的损失等)，本团队不承担任何法律责任，本软件框架只能用于公司和个人内部的 // | 法律所允许的合法合规的软件产品研发，详细见https://www.golershop.cn/policy // +---------------------------------------------------------------------- package trade import ( "context" "errors" "fmt" "github.com/gogf/gf/v2/database/gdb" "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/os/grpool" "github.com/gogf/gf/v2/os/gtime" "github.com/gogf/gf/v2/text/gstr" gconv "github.com/gogf/gf/v2/util/gconv" "github.com/mallsuite/gocore/core/ml" "github.com/shopspring/decimal" "golershop.cn/internal/consts" "golershop.cn/internal/dao" "golershop.cn/internal/dao/global" "golershop.cn/internal/model" "golershop.cn/internal/model/do" "golershop.cn/internal/model/entity" "golershop.cn/internal/service" "golershop.cn/utility/array" "math" "sync" "time" ) type sOrder struct{} func init() { service.RegisterOrder(NewOrder()) } func NewOrder() *sOrder { return &sOrder{} } // Detail 读取订单 func (s *sOrder) Detail(ctx context.Context, orderId any) (detail *model.OrderVo, err error) { detail = &model.OrderVo{} //信息表 orderInfo, err := dao.OrderInfo.Get(ctx, orderId) if err != nil { return nil, err } if err := gconv.Scan(orderInfo, detail); err != nil { return nil, err } //详情表 orderData, err := dao.OrderData.Get(ctx, orderId) if err != nil { return nil, err } if err := gconv.Scan(orderData, &detail.OrderData); err != nil { return nil, err } //基础表 orderBase, err := dao.OrderBase.Get(ctx, orderId) if err != nil { return nil, err } detail.OrderNumber = orderBase.OrderNumber detail.OrderTime = orderBase.OrderTime detail.OrderProductAmount = orderBase.OrderProductAmount detail.OrderPaymentAmount = orderBase.OrderPaymentAmount detail.CurrencyId = orderBase.CurrencyId detail.CurrencySymbolLeft = orderBase.CurrencySymbolLeft detail.StoreName = orderBase.StoreName detail.UserNickname = orderBase.UserNickname //读取订单商品 orderItems, err := dao.OrderItem.Find(ctx, &do.OrderItemListInput{Where: do.OrderItem{OrderId: orderId}}) if err != nil { return nil, err } gconv.Scan(orderItems, &detail.Items) if !g.IsEmpty(detail.Items) { for i := range detail.Items { detail.Items[i].ProductItemName = fmt.Sprintf("%s %s", detail.Items[i].ProductName, gstr.Replace(detail.Items[i].ItemName, ",", " "), ) } } //售后服务 returnItemList, err := dao.OrderReturnItem.Find(ctx, &do.OrderReturnItemListInput{Where: do.OrderReturnItem{OrderId: orderId, ReturnStateId: consts.RETURN_PROCESS_CANCEL}}) if err != nil { return nil, err } // 处理为map orderReturnItemMap := make(map[uint64][]string) for _, item := range returnItemList { if _, ok := orderReturnItemMap[item.OrderItemId]; !ok { orderReturnItemMap[item.OrderItemId] = []string{} } orderReturnItemMap[item.OrderItemId] = append(orderReturnItemMap[item.OrderItemId], item.ReturnId) } for i := range detail.Items { // 是否可以退货 detail.Items[i].IfReturn = detail.Items[i].OrderItemQuantity > detail.Items[i].OrderItemReturnNum && s.ifReturn(orderInfo.OrderStateId, orderInfo.OrderIsPaid) returnIds := orderReturnItemMap[detail.Items[i].OrderItemId] if g.IsEmpty(returnIds) { returnIds = []string{} } detail.Items[i].ReturnIds = returnIds } //商品库存 itemIds := array.Column(orderItems, "item_id") productItems, err := service.ProductItem().Gets(ctx, itemIds) if err != nil { return nil, err } for _, it := range productItems { i := &entity.WarehouseItem{} gconv.Scan(it, i) i.WarehouseId = 0 i.ItemId = it.ItemId i.WarehouseItemQuantity = it.ItemQuantity detail.WarehouseItems = append(detail.WarehouseItems, i) } //配送地址 orderDeliveryAddress, err := dao.OrderDeliveryAddress.Get(ctx, orderId) if err != nil { return nil, err } detail.Delivery = orderDeliveryAddress //订单日志 //orderStateLogItems, err := dao.OrderStateLog.Find(ctx, &do.OrderStateLogListInput{Where: do.OrderStateLog{OrderId: orderId}}) //if err != nil { // return nil, err //} // //detail.LogItems = orderStateLogItems //物流记录 orderLogistics, err := dao.OrderLogistics.Find(ctx, &do.OrderLogisticsListInput{Where: do.OrderLogistics{OrderId: orderId}}) if err != nil { return nil, err } detail.Logistics = orderLogistics //StockBill stockBill, err := service.StockBill().FindDetail(ctx, &do.StockBillListInput{Where: do.StockBill{OrderId: orderId}}) if err != nil { return nil, err } detail.StockBill = stockBill //consumeRecord consumeRecord, err := dao.ConsumeRecord.Find(ctx, &do.ConsumeRecordListInput{Where: do.ConsumeRecord{OrderId: orderId, TradeTypeId: consts.TRADE_TYPE_SALES}}) if err != nil { return nil, err } detail.ConsumeRecord = consumeRecord //ConsumeTrade consumeTrades, err := dao.ConsumeTrade.Find(ctx, &do.ConsumeTradeListInput{Where: do.ConsumeTrade{OrderId: orderId}}) if err != nil { return nil, err } if len(consumeTrades) > 0 { detail.ConsumeTrade = consumeTrades[0] } // 订单倒计时 showCancelTime := service.ConfigBase().GetBool(ctx, "show_cancel_time", false) orderAutocancelTime := service.ConfigBase().GetFloat(ctx, "order_autocancel_time", 0.0) if showCancelTime && orderAutocancelTime > 0 && detail.OrderStateId == consts.ORDER_STATE_WAIT_PAY { orderTime := detail.OrderTime orderTime = orderTime.Add(time.Duration(int(orderAutocancelTime*60*60)) * time.Second) remainPayTime := (orderTime.Unix() - time.Now().Unix()) detail.RemainPayTime = remainPayTime } return detail, nil } // List 订单搜索查询列表 func (s *sOrder) List(ctx context.Context, in *do.OrderInfoListInput) (out *model.OrderListOutput, err error) { //修正 待配货和代发货 为同一种状态查询 if len(in.BaseList.WhereExt) > 0 { if !g.IsEmpty(in.Where.OrderStateId) { if in.Where.OrderStateId == consts.ORDER_STATE_WAIT_SHIPPING || in.Where.OrderStateId == consts.ORDER_STATE_PICKING { in.Where.OrderStateId = []uint{consts.ORDER_STATE_PICKING, consts.ORDER_STATE_WAIT_SHIPPING} } } for _, c := range in.BaseList.WhereExt { if c.Column == "OrderStateId" && c.Symbol == ml.EQ { if gconv.Uint(c.Val) == consts.ORDER_STATE_WAIT_SHIPPING || gconv.Uint(c.Val) == consts.ORDER_STATE_PICKING { c.Symbol = ml.IN c.Val = []uint{consts.ORDER_STATE_PICKING, consts.ORDER_STATE_WAIT_SHIPPING} } } } }