package api import ( "encoding/json" "github.com/kataras/iris/v12" "github.com/kataras/iris/v12/context" "go.uber.org/zap" "gorm.io/gorm" "gorm.io/gorm/clause" "io" "pet-house.com/business/models" "pet-house.com/business/utils" "pet-house.com/core/server/database" "pet-house.com/core/server/web/web_iris" "pet-house.com/core/server/zap_server" "strconv" "strings" "sync" "time" ) type PetGoodsInfo struct { PetId int64 GoodsIds []int64 } type OrderCreateRequest struct { PetGoodsInfos []PetGoodsInfo //宠物商品信息列表 ServiceTime string //预约时间 yyyy-MM-dd HH:mm ServiceAddrId int64 //预约服务地址 } type OrderCreateResponse struct { OrderDetail OrderDetail `json:"orderDetail"` } type OrderCreatePreCheckResponse struct { HasAlert bool `json:"hasAlert"` //是否弹窗提示 返回false直接下单,返回ture弹出确认框,确认框点击是之后调用下单接口 AlertMsg string `json:"alertMsg"` //弹窗消息 } func (p DefParty) orderCreatePreCheck() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderCreatePreCheck", func(ctx *context.Context) { headerBaseInfo := GetHeaderBaseInfo(ctx) body, _ := io.ReadAll(ctx.Request().Body) var orderCreateRequest OrderCreateRequest json.Unmarshal(body, &orderCreateRequest) if len(orderCreateRequest.PetGoodsInfos) == 0 { ParamError.Fail(ctx, orderCreateRequest) return } var userInfo *models.User database.Instance().Model(&models.User{}).Where("id = ?", headerBaseInfo.Uid).Find(&userInfo) var orderTotalAmount = 0 for _, value := range orderCreateRequest.PetGoodsInfos { for _, value := range value.GoodsIds { goods := GoodsMap[value] orderTotalAmount = orderTotalAmount + int(goods.Price) } } orderCreatePreCheckResponse := OrderCreatePreCheckResponse{ HasAlert: false, } var discountAmount = orderTotalAmount if userInfo.Discount > 0 { discount := float64(userInfo.Discount) discountAmount = int(utils.RoundToOneDecimalPlace(float64(orderTotalAmount)*(discount/100.0)) * 10) if userInfo.Amount < discountAmount { orderCreatePreCheckResponse.HasAlert = true orderCreatePreCheckResponse.AlertMsg = "您的会员余额不够,需要进行线下支付,当前订单将不享受会员折扣优惠价格" } } Success(ctx, orderCreateRequest, orderCreatePreCheckResponse) }) }} } var orderLock sync.Mutex // 创建 func (p DefParty) orderCreate() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderCreate", func(ctx *context.Context) { headerBaseInfo := GetHeaderBaseInfo(ctx) body, _ := io.ReadAll(ctx.Request().Body) var orderCreateRequest OrderCreateRequest json.Unmarshal(body, &orderCreateRequest) var userServiceAddr models.UserServiceAddr database.Instance().Model(&models.UserServiceAddr{}).Where("uid = ? and id = ?", headerBaseInfo.Uid, orderCreateRequest.ServiceAddrId).Find(&userServiceAddr) if userServiceAddr.Id == 0 { UserServiceAddrNotExistError.Fail(ctx, nil) return } //serviceAddr := ServiceAddrMap[orderCreateRequest.ServiceAreaId] //if serviceAddr.Id == 0 { // NotInServiceExistError.Fail(ctx, nil) // return //} /*if len(serviceAddr.ServiceArea) > 0 && serviceAddr.ServiceArea != userServiceAddr.AddrArea { ServiceAddrNotExistError.Fail(ctx, nil) return }*/ var projectionServiceTime = 0 for _, value := range orderCreateRequest.PetGoodsInfos { for _, value := range value.GoodsIds { goods := GoodsMap[value] if goods.Time != "/" && len(goods.Time) > 0 { goodsTime, _ := strconv.Atoi(goods.Time) projectionServiceTime += goodsTime } } } haveReserve := checkOrderServiceTime(orderCreateRequest.ServiceTime, projectionServiceTime) if haveReserve { OrderCreateError.DefFail(ctx, orderCreateRequest, "当前订单预估服务时长预计:"+strconv.Itoa(projectionServiceTime)+"分钟,服务时间过长,请更换时间段预约") return } for _, value := range orderCreateRequest.PetGoodsInfos { userPet := GetUserPet(headerBaseInfo.Uid, value.PetId) if userPet.PetInfo.Vaccine == 0 { OrderCreateError.DefFail(ctx, orderCreateRequest, "当前订单存在未接种疫苗的宠物,无法下单") return } } var orderTotalAmount = 0 orderLock.Lock() orderId := NextId.Generate().String() orderMain := models.OrderMain{ OrderId: orderId, Uid: headerBaseInfo.Uid, OrderStatus: 1, PayType: 1, ServiceTime: orderCreateRequest.ServiceTime, ServiceAddrId: orderCreateRequest.ServiceAddrId, ServiceRemark: "", } var projectionServiceTimeAll = 0 var orderSubList []models.OrderSub var orderSubDetailList []models.OrderDetail var mainGoods = 0 for _, value := range orderCreateRequest.PetGoodsInfos { subOrderId := NextId.Generate().String() var totalAmount int32 = 0 var projectionServiceTime = 0 var goodsName string for _, value := range value.GoodsIds { goods := GoodsMap[value] totalAmount = totalAmount + goods.Price orderSubDetailList = append(orderSubDetailList, models.OrderDetail{SubOrderId: subOrderId, GoodsId: value, Amount: goods.Price}) if goods.Time != "/" && len(goods.Time) > 0 { goodsTime, _ := strconv.Atoi(goods.Time) projectionServiceTime += goodsTime } if goods.GoodsType == 1 || goods.GoodsType == 2 { mainGoods++ } goodsName = goods.Name + "、" + goodsName } userPetInfo := GetUserPet(headerBaseInfo.Uid, value.PetId) var petInfo = "宠物名称:" + userPetInfo.PetInfo.NickName + "
品种:" + userPetInfo.PetBaseInfo.Assortment + "
服务项目:" + goodsName projectionServiceTimeAll += projectionServiceTime orderSub := models.OrderSub{ OrderId: subOrderId, MainOrderId: orderMain.OrderId, OrderStatus: 1, PetId: value.PetId, PayType: 1, Discount: 100, TotalAmount: totalAmount, PayAmount: totalAmount, PetInfo: petInfo, //PayTime: time.Now(), ProjectionServiceTime: projectionServiceTime, } orderTotalAmount = orderTotalAmount + int(totalAmount) orderSubList = append(orderSubList, orderSub) } if mainGoods == 0 { OrderCreateError.DefFail(ctx, orderCreateRequest, "订单未选择主商品,创建失败") return } orderMain.ProjectionServiceTime = projectionServiceTimeAll var userInfo *models.User database.Instance().Model(&models.User{}).Where("id = ?", headerBaseInfo.Uid).Find(&userInfo) var discountAmount = orderTotalAmount if userInfo.Discount > 0 { discount := float64(userInfo.Discount) discountAmount = int(utils.RoundToOneDecimalPlace(float64(orderTotalAmount)*(discount/100.0)) * 10) //discountAmount = int(math.Round(float64(orderTotalAmount)*(discount/100.0)) * 10) } orderMain.TotalAmount = orderTotalAmount tx := database.Instance().Begin() var db4 *gorm.DB if userInfo.Amount >= discountAmount { var currAmount = userInfo.Amount orderMain.PayStatus = 1 orderMain.PayTotalAmount = discountAmount userInfo.Amount = userInfo.Amount - discountAmount updateValues := map[string]interface{}{ "Amount": userInfo.Amount, } db4 = tx.Model(&userInfo).Updates(&updateValues) orderMain.PayDiscount = userInfo.Discount orderMain.PayType = 3 for index := range orderSubList { orderSubList[index].PayType = 3 } zap_server.ZAPLOG.Info("会员金额扣除", zap.Any("用户ID", userInfo.Id), zap.Any("订单号", orderMain.OrderId), zap.Any("当前余额", currAmount), zap.Any("扣除余额", discountAmount), zap.Any("剩余余额", userInfo.Amount), zap.Any("折扣", userInfo.Discount)) discount := float64(userInfo.Discount) for index, _ := range orderSubList { orderSubList[index].Discount = userInfo.Discount //orderSubList[index].PayAmount = int32(math.Round(float64(orderSubList[index].TotalAmount) * (discount / 100.0))) orderSubList[index].PayAmount = int32(utils.RoundToOneDecimalPlace(float64(orderSubList[index].TotalAmount)*(discount/100.0)) * 10) } } var findUserServiceAddr models.UserServiceAddr database.Instance().Model(&models.UserServiceAddr{}).Where("id = ? and uid = ?", orderCreateRequest.ServiceAddrId, headerBaseInfo.Uid).Find(&findUserServiceAddr) userInfo.Mobile = findUserServiceAddr.Mobile updateValues := map[string]interface{}{ "Mobile": userInfo.Mobile, } tx.Model(&userInfo).Updates(&updateValues) db := tx.Model(&models.OrderDetail{}).CreateInBatches(&orderSubDetailList, len(orderSubDetailList)) db1 := tx.Model(&models.OrderSub{}).CreateInBatches(&orderSubList, len(orderSubList)) db2 := tx.Model(&models.OrderMain{}).Create(&orderMain) if (db4 != nil && db4.Error != nil) || db.Error != nil || db1.Error != nil || db2.Error != nil { tx.Callback() orderLock.Unlock() zap_server.ZAPLOG.Error("订单插入失败", zap.Any("db", db.Error), zap.Any("db1", db1.Error), zap.Any("db2", db2.Error), zap.Any("db4", db4.Error)) OrderCreateError.Fail(ctx, orderCreateRequest) return } tx.Commit() orderLock.Unlock() Success(ctx, orderCreateRequest, OrderCreateResponse{GetOrderDetail(orderMain.OrderId)}) }) }} } func GetOrderDetail(orderId string) OrderDetail { var orderMain models.OrderMain database.Instance().Model(&models.OrderMain{}).Where("order_id = ?", orderId).Find(&orderMain) var findUserServiceAddr models.UserServiceAddr database.Instance().Model(&models.UserServiceAddr{}).Where("id = ?", orderMain.ServiceAddrId).Find(&findUserServiceAddr) orderDetail := OrderDetail{ OrderId: orderMain.OrderId, Status: orderMain.OrderStatus, ServiceTime: orderMain.ServiceTime, ServiceAddr: findUserServiceAddr, ServiceRemark: orderMain.ServiceRemark, CreateTime: orderMain.CreateTime.Format("2006-01-02 15:04:05"), PayStatus: orderMain.PayStatus, DispatchStatus: orderMain.DispatchStatus, TotalAmount: orderMain.TotalAmount, DiscountAmount: strconv.Itoa(orderMain.TotalAmount), Discount: float64(orderMain.PayDiscount) / 100, } if orderMain.PayDiscount > 0 { orderDetail.DiscountAmount = strconv.FormatFloat(float64(orderMain.PayTotalAmount)/10.0, 'f', 1, 64) } var subOrderList []SubOrder var orderSubList []models.OrderSub database.Instance().Model(&models.OrderSub{}).Where("main_order_id = ? ", orderMain.OrderId).Find(&orderSubList) for _, orderSub := range orderSubList { var orderDetailList []models.OrderDetail database.Instance().Model(&models.OrderDetail{}).Where("sub_order_id = ? ", orderSub.OrderId).Find(&orderDetailList) var goods []models.Goods for _, orderDetail := range orderDetailList { good := GoodsMap[orderDetail.GoodsId] goods = append(goods, good) } orderSubR1 := SubOrder{ OrderId: orderSub.OrderId, Status: orderSub.OrderStatus, UserPetInfo: GetUserPet(orderMain.Uid, orderSub.PetId), TotalAmount: orderSub.TotalAmount, PayAmount: strconv.Itoa(int(orderSub.PayAmount)), Discount: float64(orderSub.Discount), Goods: goods, } if orderSubR1.Discount < 100 { //orderSubR1.PayAmount = int32(math.Round(float64(orderSubR1.TotalAmount) * (orderSubR1.Discount / 100.0))) //x := float64(orderSubR1.TotalAmount) * (orderSubR1.Discount / 100.0) / 10 x := float64(orderSub.PayAmount) / 10 orderSubR1.PayAmount = strconv.FormatFloat(x, 'f', 1, 64) orderSubR1.DiscountAmount = orderSubR1.PayAmount } else { orderSubR1.DiscountAmount = strconv.Itoa(int(orderSubR1.TotalAmount)) } subOrderList = append(subOrderList, orderSubR1) } var carOrder models.CarOrder database.Instance().Model(&models.CarOrder{}).Where("order_id = ?", orderMain.OrderId).Find(&carOrder) if carOrder.Id > 0 { car := CarMap[carOrder.CarId] orderDetail.ServiceCar = &car } else { orderDetail.ServiceCar = &models.ServiceCar{} } orderDetail.SubOrderList = subOrderList return orderDetail } func checkOrderServiceTime(serviceTime string, projectionServiceTime int) bool { type orderMainTmp struct { ServiceTime string ProjectionServiceTime int } var orderMainTmpList []orderMainTmp //服务时间>=预约时间 and 服务时间<=预计结束时间 时间范围内无订单才可预约 database.Instance().Model(&models.OrderMain{}).Where("service_time >= ? and service_time <= DATE_FORMAT(DATE_ADD('"+serviceTime+"', INTERVAL "+strconv.Itoa(projectionServiceTime)+" MINUTE), '%Y-%m-%d %H:%i') and order_status != 3 and order_status != 4", serviceTime).Find(&orderMainTmpList) //时间点订单数量<服务车辆*车辆单次服务数量 才可接受预约 if len(orderMainTmpList) > 0 { return len(orderMainTmpList) >= len(CarMap)*CarServiceNum } return false } type OrderListRequest struct { Status int //订单状态 0所有 1待服务 2服务中 3已完成 4已取消 PageNo int //页码 PageSize int //数据数量 } type SubOrder struct { OrderId string `json:"orderId"` //子订单ID Status int `json:"status"` //子订单状态 0待派单 1待服务 2服务中 3已完成 4已取消 UserPetInfo UserPetInfo `json:"userPetInfo"` //用户宠物信息 TotalAmount int32 `json:"totalAmount"` //总金额 PayAmount string `json:"payAmount"` //实际支付金额 DiscountAmount string `json:"discountAmount"` //折扣金额 Discount float64 `json:"discount"` //用户折扣 Goods []models.Goods `json:"goods"` //商品信息 } type OrderDetail struct { OrderId string `json:"orderId"` //主订单号 Status int `json:"status"` //主订单状态 0待派单 1待服务 2服务中 3已完成 4已取消 ServiceTime string `json:"serviceTime"` //服务时间 ServiceAddr models.UserServiceAddr `json:"serviceAddr"` //服务地址信息 ServiceRemark string `json:"serviceRemark"` //服务备注 CreateTime string `json:"createTime"` //创建时间 SubOrderList []SubOrder `json:"subOrderList"` //子订单列表 ServiceCar *models.ServiceCar `json:"serviceCar"` //服务车辆 只有派单状态未1的时候才会存在 PayStatus int `json:"payStatus"` //支付状态 0未支付 1已支付 DispatchStatus int `json:"dispatchStatus"` //派单状态 0未派单 1已派单 Discount float64 `json:"discount"` //用户折扣 TotalAmount int `json:"totalAmount"` //总金额 DiscountAmount string `json:"discountAmount"` //折扣金额 } type OrderListResponse struct { OrderDetails []OrderDetail `json:"orderDetails"` //订单列表 PageNo int `json:"pageNo"` //页码 PageSize int `json:"pageSize"` //数据数量 } // 订单列表 func (p DefParty) orderList() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderList", func(ctx *context.Context) { headerBaseInfo := GetHeaderBaseInfo(ctx) body, _ := io.ReadAll(ctx.Request().Body) var orderListRequest OrderListRequest json.Unmarshal(body, &orderListRequest) if orderListRequest.PageNo == 0 { ParamError.DefFail(ctx, orderListRequest, "页码必须>0") return } var orderList []models.OrderMain if orderListRequest.Status == 0 { database.Instance().Model(&models.OrderMain{}).Where("uid = ?", headerBaseInfo.Uid).Offset((orderListRequest.PageNo - 1) * orderListRequest.PageSize).Limit(orderListRequest.PageSize).Order(clause.OrderByColumn{Column: clause.Column{Name: "create_time"}, Desc: true}).Find(&orderList) } else { database.Instance().Model(&models.OrderMain{}).Where("uid = ? and status = ?", headerBaseInfo.Uid, orderListRequest.Status).Offset((orderListRequest.PageNo - 1) * orderListRequest.PageSize).Limit(orderListRequest.PageSize).Order(clause.OrderByColumn{Column: clause.Column{Name: "create_time"}, Desc: true}).Find(&orderList) } var orderDetails []OrderDetail for _, value := range orderList { var findUserServiceAddr models.UserServiceAddr database.Instance().Model(&models.UserServiceAddr{}).Where("id = ? and uid = ?", value.ServiceAddrId, headerBaseInfo.Uid).Find(&findUserServiceAddr) orderDetail := OrderDetail{ OrderId: value.OrderId, Status: value.OrderStatus, ServiceTime: value.ServiceTime, ServiceAddr: findUserServiceAddr, ServiceRemark: value.ServiceRemark, CreateTime: value.CreateTime.Format("2006-01-02 15:04:05"), PayStatus: value.PayStatus, DispatchStatus: value.DispatchStatus, TotalAmount: value.TotalAmount, DiscountAmount: strconv.FormatFloat(float64(value.PayTotalAmount)/10.0, 'f', 1, 64), Discount: float64(value.PayDiscount / 100.0), } var subOrderList []SubOrder var orderSubList []models.OrderSub database.Instance().Model(&models.OrderSub{}).Where("main_order_id = ? ", value.OrderId).Find(&orderSubList) for _, orderSub := range orderSubList { var orderDetailList []models.OrderDetail database.Instance().Model(&models.OrderDetail{}).Where("sub_order_id = ? ", orderSub.OrderId).Find(&orderDetailList) var goods []models.Goods for _, orderDetail := range orderDetailList { good := GoodsMap[orderDetail.GoodsId] goods = append(goods, good) } orderSub := SubOrder{ OrderId: orderSub.OrderId, Status: orderSub.OrderStatus, UserPetInfo: GetUserPet(value.Uid, orderSub.PetId), TotalAmount: orderSub.TotalAmount, Discount: float64(orderSub.Discount / 100.0), Goods: goods, } if orderSub.Discount > 0 { //orderSub.PayAmount = int32(math.Round(float64(orderSub.TotalAmount) * (orderSub.Discount / 100.0))) //orderSub.DiscountAmount = orderSub.PayAmount x := float64(orderSub.TotalAmount) * (orderSub.Discount / 100.0) / 10 orderSub.PayAmount = strconv.FormatFloat(x, 'f', 1, 64) orderSub.DiscountAmount = orderSub.PayAmount } subOrderList = append(subOrderList, orderSub) } orderDetail.SubOrderList = subOrderList orderDetails = append(orderDetails, orderDetail) } var orderListResponse = OrderListResponse{ OrderDetails: orderDetails, PageNo: orderListRequest.PageNo + 1, PageSize: orderListRequest.PageSize, } Success(ctx, orderListRequest, orderListResponse) }) }} } type OrderCancelRequest struct { OrderId string } type OrderCancelResponse struct { OrderDetail OrderDetail `json:"orderDetail"` } func (p DefParty) orderCancel() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderCancel", func(ctx *context.Context) { headerBaseInfo := GetHeaderBaseInfo(ctx) body, _ := io.ReadAll(ctx.Request().Body) var orderCancelRequest OrderCancelRequest json.Unmarshal(body, &orderCancelRequest) var orderMain models.OrderMain database.Instance().Model(&models.OrderMain{}).Where("order_id = ?", orderCancelRequest.OrderId).Find(&orderMain) if orderMain.Uid != headerBaseInfo.Uid { OrderExistError.Fail(ctx, orderCancelRequest) return } if orderMain.OrderStatus != 1 { OrderError.Fail(ctx, orderCancelRequest) return } if orderMain.DispatchStatus == 1 { OrderError.Fail(ctx, orderCancelRequest) return } if orderMain.PayStatus == 1 { var userInfo models.User database.Instance().Model(&models.User{}).Where("id = ?", orderMain.Uid).Find(&userInfo) userInfo.Amount = userInfo.Amount + orderMain.PayTotalAmount updateValues := map[string]interface{}{ "Amount": userInfo.Amount, } database.Instance().Model(&userInfo).Updates(&updateValues) orderMain.PayTotalAmount = 0 orderMain.PayStatus = 0 } orderMain.OrderStatus = 4 updateValues := map[string]interface{}{ "OrderStatus": orderMain.OrderStatus, "PayStatus": orderMain.PayStatus, "PayTotalAmount": orderMain.PayTotalAmount, } database.Instance().Model(&orderMain).Updates(&updateValues) Success(ctx, orderCancelRequest, OrderCancelResponse{GetOrderDetail(orderMain.OrderId)}) }) }} } type TimeObject struct { Time string `json:"time"` Y bool `json:"y"` } type OrderServiceTimeRequest struct { ServiceAddrId int64 } type OrderServiceTimeResponse struct { Times map[string][]TimeObject `json:"times"` } // 获取订单可预约时间 func (p DefParty) orderServiceTime() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderServiceTime", func(ctx *context.Context) { headerBaseInfo := GetHeaderBaseInfo(ctx) body, _ := io.ReadAll(ctx.Request().Body) var orderServiceTimeRequest OrderServiceTimeRequest json.Unmarshal(body, &orderServiceTimeRequest) if orderServiceTimeRequest.ServiceAddrId == 0 { ParamError.Fail(ctx, orderServiceTimeRequest) return } type orderMainTmp struct { ServiceTime string ProjectionServiceTime int } var orderMainTmpList []orderMainTmp database.Instance().Model(&models.OrderMain{}).Where("service_time >= DATE_SUB(NOW(), INTERVAL 7 DAY) and order_status != 3 and order_status != 4").Find(&orderMainTmpList) var orderTimeMap = make(map[string]string) var orderTimeNum = make(map[string]int) for _, value := range orderMainTmpList { orderTimeMap[value.ServiceTime] = value.ServiceTime orderTimeNum[value.ServiceTime] = orderTimeNum[value.ServiceTime] + 1 if value.ProjectionServiceTime > 0 { //计算出服务时间点之后累计延长时间 date, _ := time.Parse("2006-01-02 15:04", value.ServiceTime) lastDate := date.Add(time.Minute * time.Duration(value.ProjectionServiceTime)) for t := date; t.Before(lastDate); t = t.Add(time.Hour) { timeStr := t.Format("2006-01-02 15:04") orderTimeMap[timeStr] = timeStr orderTimeNum[timeStr] = orderTimeNum[timeStr] + 1 } } } serviceTime := AddrServiceMap[orderServiceTimeRequest.ServiceAddrId] times := strings.Split(serviceTime.Times, ",") carNum := len(CarMap) daysMap := utils.GetStrDays(7, 60, ReserveMap, orderTimeMap, carNum, orderTimeNum, CarServiceNum, times) var dayHoursMap = make(map[string][]TimeObject) for day, values := range daysMap { key := day for _, value := range values { if _, ok := dayHoursMap[key]; ok { dayHoursMap[key] = append(dayHoursMap[key], TimeObject{ Time: value.Time, Y: value.Y, }) } else { dayHoursMap[key] = []TimeObject{{ Time: value.Time, Y: value.Y, }} } } } Success(ctx, headerBaseInfo, OrderServiceTimeResponse{dayHoursMap}) }) }} } type OrderEditRequest struct { OrderId string //订单ID Status int //订单状态 4取消 } // 修改订单 func (p DefParty) orderEdit() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderEdit", func(ctx *context.Context) { headerBaseInfo := GetHeaderBaseInfo(ctx) body, _ := io.ReadAll(ctx.Request().Body) var orderEditRequest OrderEditRequest json.Unmarshal(body, &orderEditRequest) var orderMain models.OrderMain var orderSub models.OrderSub database.Instance().Model(&models.OrderSub{}).Where("order_id = ?", orderEditRequest.OrderId).Find(&orderSub) database.Instance().Model(&models.OrderMain{}).Where("order_id = ?", orderSub.MainOrderId).Find(&orderMain) if orderMain.Uid != headerBaseInfo.Uid { OrderError.Fail(ctx, orderEditRequest) return } if orderSub.OrderStatus > 0 || orderEditRequest.Status == 0 { OrderError.Fail(ctx, orderEditRequest) return } orderSub.OrderStatus = orderEditRequest.Status updateValues := map[string]interface{}{ "OrderStatus": orderSub.OrderStatus, } database.Instance().Model(&orderSub).Updates(&updateValues) Success(ctx, orderEditRequest, GetOrderDetail(orderMain.OrderId)) }) }} } type OrderDetailRequest struct { OrderId string } type OrderDetailResponse struct { OrderDetail OrderDetail `json:"orderDetail"` } // 订单详情 func (p DefParty) orderDetail() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderDetail", func(ctx *context.Context) { body, _ := io.ReadAll(ctx.Request().Body) var orderDetailRequest OrderDetailRequest json.Unmarshal(body, &orderDetailRequest) orderDetail := GetOrderDetail(orderDetailRequest.OrderId) if len(orderDetail.OrderId) == 0 { OrderExistError.Fail(ctx, orderDetailRequest) return } Success(ctx, orderDetailRequest, OrderDetailResponse{GetOrderDetail(orderDetailRequest.OrderId)}) }) }} } type OrderGoodsUpdateRequest struct { OrderId string GoodsIds []int64 } // 修改订单商品 func (p DefParty) orderGoodsUpdate() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderGoodsUpdate", func(ctx *context.Context) { body, _ := io.ReadAll(ctx.Request().Body) var orderGoodsUpdateRequest OrderGoodsUpdateRequest json.Unmarshal(body, &orderGoodsUpdateRequest) var orderSub models.OrderSub database.Instance().Model(&models.OrderSub{}).Where("order_id = ?", orderGoodsUpdateRequest.OrderId).Find(&orderSub) if len(orderSub.OrderId) == 0 { OrderExistError.Fail(ctx, orderGoodsUpdateRequest) return } var orderMain models.OrderMain database.Instance().Model(&models.OrderMain{}).Where("order_id = ?", orderSub.MainOrderId).Find(&orderMain) var totalAmount = 0 var projectionServiceTime = 0 for _, value := range orderGoodsUpdateRequest.GoodsIds { goods := GoodsMap[value] totalAmount = totalAmount + int(goods.Price) if goods.Time != "/" && len(goods.Time) > 0 { goodsTime, _ := strconv.Atoi(goods.Time) projectionServiceTime += goodsTime } } //非当前订单 var orderSubList []models.OrderSub database.Instance().Model(&models.OrderSub{}).Where("main_order_id = ? and order_id != ", orderMain.OrderId, orderGoodsUpdateRequest.OrderId).Find(&orderSubList) //新价格 var newAmount = totalAmount var allProjectionServiceTime = projectionServiceTime for _, value := range orderSubList { newAmount = newAmount + int(value.TotalAmount) allProjectionServiceTime = allProjectionServiceTime + value.ProjectionServiceTime } //已支付 if orderMain.PayStatus == 1 { if orderMain.PayType == 3 { var userInfo *models.User database.Instance().Model(&models.User{}).Where("id = ?", orderMain.Uid).Find(&userInfo) //先退还 userInfo.Amount = userInfo.Amount + orderMain.PayTotalAmount if userInfo.Discount > 0 { discount := float64(userInfo.Discount) newAmount = int(utils.RoundToOneDecimalPlace(float64(newAmount)*(discount/100.0)) * 10) } //余额不足 if userInfo.Amount < newAmount { OrderUpdateBalanceNotEnough.DefFail(ctx, orderGoodsUpdateRequest, "原订单金额:"+strconv.FormatFloat(float64(orderMain.PayTotalAmount)/10, 'f', 1, 64)+" 修改后订单金额:"+strconv.FormatFloat(float64(newAmount)/10, 'f', 1, 64)+";修改服务项目后余额不足,请充值后再支付") return } var originAmount = userInfo.Amount var preAmount = orderMain.PayTotalAmount userInfo.Amount = userInfo.Amount - newAmount orderMain.PayTotalAmount = newAmount updateValues := map[string]interface{}{ "Amount": userInfo.Amount, } database.Instance().Model(&userInfo).Updates(&updateValues) orderMain.PayDiscount = userInfo.Discount zap_server.ZAPLOG.Info("会员金额扣除", zap.Any("用户ID", userInfo.Id), zap.Any("订单ID", orderMain.OrderId), zap.Any("用户修改之前余额", originAmount), zap.Any("当前余额", userInfo.Amount), zap.Any("商品修改之前金额", preAmount), zap.Any("商品修改之后金额", orderMain.PayTotalAmount), zap.Any("折扣", userInfo.Discount)) } } database.Instance().Where("sub_order_id = ?", orderGoodsUpdateRequest.OrderId).Delete(&models.OrderDetail{}) for _, value := range orderGoodsUpdateRequest.GoodsIds { goods := GoodsMap[value] orderDetail := models.OrderDetail{ SubOrderId: orderGoodsUpdateRequest.OrderId, GoodsId: goods.Id, Amount: goods.Price, } database.Instance().Model(&models.OrderDetail{}).Create(&orderDetail) } orderSub.TotalAmount = int32(totalAmount) orderSub.PayAmount = int32(newAmount) orderSub.ProjectionServiceTime = projectionServiceTime updateValues := map[string]interface{}{ "TotalAmount": orderSub.TotalAmount, "PayAmount": orderSub.PayAmount, "ProjectionServiceTime": orderSub.ProjectionServiceTime, } orderMain.ProjectionServiceTime = allProjectionServiceTime updateValues1 := map[string]interface{}{ "PayTotalAmount": orderMain.PayTotalAmount, "ProjectionServiceTime": orderMain.ProjectionServiceTime, } database.Instance().Model(&orderMain).Updates(&updateValues1) database.Instance().Model(&orderSub).Updates(&updateValues) Success(ctx, orderGoodsUpdateRequest, OrderDetailResponse{GetOrderDetail(orderSub.MainOrderId)}) }) }} } // 支付 func (p DefParty) orderPay() web_iris.Party { return web_iris.Party{Prefix: p.Prefix, PartyFunc: func(index iris.Party) { index.Post(OrderBase+"/orderPay", func(ctx *context.Context) { }) }} }