fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat:新增api

Browse Source
This commit is contained in:
momo
2023-09-14 18:43:10 +08:00
parent e0a851ba25
commit 6606173050
48 changed files with 1929 additions and 1114 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
server/home-user-auth/internal/logic/usercontactservicelogic.go
View File

@@ -1,10 +1,8 @@
package logic
import (
"fusenapi/model/gmodel"
"fusenapi/utils/auth"
"fusenapi/utils/basic"
"fusenapi/utils/collect"
"context"
@@ -12,7 +10,6 @@ import (
"fusenapi/server/home-user-auth/internal/types"
"github.com/zeromicro/go-zero/core/logx"
"gorm.io/gorm"
)
type UserContactServiceLogic struct {
@@ -33,36 +30,36 @@ func (l *UserContactServiceLogic) UserContactService(req *types.RequestContactSe
// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data)
// userinfo 传入值时, 一定不为null
if !userinfo.IsUser() {
return resp.SetStatus(basic.CodeUnAuth)
}
// if !userinfo.IsUser() {
// return resp.SetStatus(basic.CodeUnAuth)
// }
cs := gmodel.FsContactService{
UserId: &userinfo.UserId,
}
collect.LoadJsonTag(&cs, &req)
// cs := gmodel.FsContactService{
// UserId: &userinfo.UserId,
// }
// collect.LoadJsonTag(&cs, &req)
switch req.Type {
case "order":
_, err := l.svcCtx.AllModels.FsOrder.FindOneAndCreateServiceContact(l.ctx, userinfo.UserId, req.RelationID, &cs)
if err != nil {
if err == gorm.ErrRecordNotFound {
return resp.SetStatus(basic.CodeOrderNotFoundErr)
}
return resp.SetStatus(basic.CodeDbSqlErr)
}
case "cloud":
_, err := l.svcCtx.AllModels.FsCloudPickUp.GetCloudPickUpByIDAndUserID(l.ctx, userinfo.UserId, req.RelationID, &cs)
if err != nil {
if err == gorm.ErrRecordNotFound {
return resp.SetStatus(basic.CodeCloudOrderNotFoundErr)
}
return resp.SetStatus(basic.CodeDbSqlErr)
}
return
default:
return resp.SetStatusWithMessage(basic.CodeRequestParamsErr, "type is unknown")
}
// switch req.Type {
// case "order":
// _, err := l.svcCtx.AllModels.FsOrder.FindOneAndCreateServiceContact(l.ctx, userinfo.UserId, req.RelationID, &cs)
// if err != nil {
// if err == gorm.ErrRecordNotFound {
// return resp.SetStatus(basic.CodeOrderNotFoundErr)
// }
// return resp.SetStatus(basic.CodeDbSqlErr)
// }
// case "cloud":
// _, err := l.svcCtx.AllModels.FsCloudPickUp.GetCloudPickUpByIDAndUserID(l.ctx, userinfo.UserId, req.RelationID, &cs)
// if err != nil {
// if err == gorm.ErrRecordNotFound {
// return resp.SetStatus(basic.CodeCloudOrderNotFoundErr)
// }
// return resp.SetStatus(basic.CodeDbSqlErr)
// }
// return
// default:
// return resp.SetStatusWithMessage(basic.CodeRequestParamsErr, "type is unknown")
// }
return resp.SetStatus(basic.CodeOK, cs)
return resp.SetStatus(basic.CodeOK)
}

184
server/home-user-auth/internal/logic/useroderdeletelogic.go
View File

@@ -1,23 +1,15 @@
package logic
import (
"errors"
"fusenapi/constants"
"fusenapi/model/gmodel"
"fusenapi/utils/auth"
"fusenapi/utils/basic"
"time"
"context"
"fusenapi/server/home-user-auth/internal/svc"
"fusenapi/server/home-user-auth/internal/types"
"github.com/stripe/stripe-go/v74"
"github.com/stripe/stripe-go/v74/client"
"github.com/zeromicro/go-zero/core/logx"
"gorm.io/gorm"
)
type UserOderDeleteLogic struct {
@@ -38,109 +30,109 @@ func (l *UserOderDeleteLogic) UserOderDelete(req *types.RequestOrderId, userinfo
// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data)
// userinfo 传入值时, 一定不为null
if !userinfo.IsUser() {
return resp.SetStatus(basic.CodeUnAuth) // 如果不是用户信息, 返回未授权错误
}
// if !userinfo.IsUser() {
// return resp.SetStatus(basic.CodeUnAuth) // 如果不是用户信息, 返回未授权错误
// }
//订单id
orderId := req.OrderId
if orderId < 1 {
return resp.SetStatus(basic.CodeRequestParamsErr)
}
// //订单id
// orderId := req.OrderId
// if orderId < 1 {
// return resp.SetStatus(basic.CodeRequestParamsErr)
// }
m := l.svcCtx.AllModels.FsOrder
order, err := m.FindOne(l.ctx, userinfo.UserId, orderId)
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatus(basic.CodeOrderNotFoundErr)
}
logx.Error(err)
return resp.SetStatus(basic.CodeDbSqlErr)
}
// m := l.svcCtx.AllModels.FsOrder
// order, err := m.FindOne(l.ctx, userinfo.UserId, orderId)
// if err != nil {
// if errors.Is(err, gorm.ErrRecordNotFound) {
// return resp.SetStatus(basic.CodeOrderNotFoundErr)
// }
// logx.Error(err)
// return resp.SetStatus(basic.CodeDbSqlErr)
// }
if auth.CheckValueRange[constants.Order](
constants.Order(*order.Status),
constants.STATUS_NEW_NOT_PAY,
constants.STATUS_NEW_PAY_COMPLETED,
constants.STATUS_NEW_PART_PAY,
) {
return resp.SetStatus(basic.CodeOrderNotCancelledErr)
}
// if auth.CheckValueRange[constants.Order](
// constants.Order(*order.Status),
// constants.STATUS_NEW_NOT_PAY,
// constants.STATUS_NEW_PAY_COMPLETED,
// constants.STATUS_NEW_PART_PAY,
// ) {
// return resp.SetStatus(basic.CodeOrderNotCancelledErr)
// }
if *order.IsPayCompleted == 1 &&
time.Now().After(time.Unix(*order.Ctime, 0).Add(48*time.Hour)) {
return resp.SetStatus(basic.CodeOrderNotCancelledErr)
}
// if *order.IsPayCompleted == 1 &&
// time.Now().After(time.Unix(*order.Ctime, 0).Add(48*time.Hour)) {
// return resp.SetStatus(basic.CodeOrderNotCancelledErr)
// }
uOrder := &gmodel.FsOrder{
Id: orderId,
}
// uOrder := &gmodel.FsOrder{
// Id: orderId,
// }
var (
isCancel int64 = 1
ustatus int64 = int64(constants.STATUS_NEW_CANCEL)
)
// 修改取消状态和取消原因
uOrder.Status = &ustatus
uOrder.IsCancel = &isCancel
uOrder.RefundReasonId = &req.RefundReasonId
uOrder.RefundReason = &req.RefundReason
// var (
// isCancel int64 = 1
// ustatus int64 = int64(constants.STATUS_NEW_CANCEL)
// )
// // 修改取消状态和取消原因
// uOrder.Status = &ustatus
// uOrder.IsCancel = &isCancel
// uOrder.RefundReasonId = &req.RefundReasonId
// uOrder.RefundReason = &req.RefundReason
err = m.Update(l.ctx, uOrder)
if err != nil {
logx.Error(err)
return resp.SetStatus(basic.CodeDbUpdateErr)
}
// err = m.Update(l.ctx, uOrder)
// if err != nil {
// logx.Error(err)
// return resp.SetStatus(basic.CodeDbUpdateErr)
// }
var (
IsRefund int64 = 0
CreatedAt = time.Now().UTC().Unix()
)
// var (
// IsRefund int64 = 0
// CreatedAt = time.Now().UTC().Unix()
// )
refund := &gmodel.FsRefundReason{
IsRefund: &IsRefund,
RefundReasonId: &req.RefundReasonId,
RefundReason: &req.RefundReason,
OrderId: &order.Id,
CreatedAt: &CreatedAt,
}
// refund := &gmodel.FsRefundReason{
// IsRefund: &IsRefund,
// RefundReasonId: &req.RefundReasonId,
// RefundReason: &req.RefundReason,
// OrderId: &order.Id,
// CreatedAt: &CreatedAt,
// }
mFsRefundReason := gmodel.NewFsRefundReasonModel(l.svcCtx.MysqlConn)
err = mFsRefundReason.Create(l.ctx, refund)
if err != nil {
logx.Error(err)
return resp.SetStatus(basic.CodeDbSqlErr)
}
// mFsRefundReason := gmodel.NewFsRefundReasonModel(l.svcCtx.MysqlConn)
// err = mFsRefundReason.Create(l.ctx, refund)
// if err != nil {
// logx.Error(err)
// return resp.SetStatus(basic.CodeDbSqlErr)
// }
// 退款
// 调用第三方接口发起退款
// // 退款
// // 调用第三方接口发起退款
config := &stripe.BackendConfig{
MaxNetworkRetries: stripe.Int64(0), // Zero retries
}
// config := &stripe.BackendConfig{
// MaxNetworkRetries: stripe.Int64(0), // Zero retries
// }
sc := &client.API{}
sc.Init(l.svcCtx.Config.Stripe.SK, &stripe.Backends{
API: stripe.GetBackendWithConfig(stripe.APIBackend, config),
Uploads: stripe.GetBackendWithConfig(stripe.UploadsBackend, config),
})
// ['order_number' => $order->sn, 'is_refund' => 0, 'pay_status' => 1]
payM := l.svcCtx.AllModels.FsPay
// sc := &client.API{}
// sc.Init(l.svcCtx.Config.Stripe.SK, &stripe.Backends{
// API: stripe.GetBackendWithConfig(stripe.APIBackend, config),
// Uploads: stripe.GetBackendWithConfig(stripe.UploadsBackend, config),
// })
// // ['order_number' => $order->sn, 'is_refund' => 0, 'pay_status' => 1]
// payM := l.svcCtx.AllModels.FsPay
// 查询支付信息
pays, err := payM.GetOrderPayList(l.ctx, *order.Sn, 1, 0)
for _, pay := range pays {
sc.Refunds.New(&stripe.RefundParams{
PaymentIntent: pay.TradeNo,
})
}
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatus(basic.CodeApiErr)
}
}
// // 查询支付信息
// pays, err := payM.GetOrderPayList(l.ctx, *order.Sn, 1, 0)
// for _, pay := range pays {
// sc.Refunds.New(&stripe.RefundParams{
// PaymentIntent: pay.TradeNo,
// })
// }
// if err != nil {
// if errors.Is(err, gorm.ErrRecordNotFound) {
// return resp.SetStatus(basic.CodeApiErr)
// }
// }
return resp.SetStatus(basic.CodePayCancelOk, uOrder)
return resp.SetStatus(basic.CodePayCancelOk)
// return ResponseError(500, "Cancellation failure")

170
server/home-user-auth/internal/logic/userordercancellogic.go
View File

@@ -1,13 +1,8 @@
package logic
import (
"errors"
"fusenapi/constants"
"fusenapi/model/gmodel"
"fusenapi/utils/auth"
"fusenapi/utils/basic"
"fusenapi/utils/handlers"
"time"
"context"
@@ -15,7 +10,6 @@ import (
"fusenapi/server/home-user-auth/internal/types"
"github.com/zeromicro/go-zero/core/logx"
"gorm.io/gorm"
)
type UserOrderCancelLogic struct {
@@ -36,93 +30,93 @@ func (l *UserOrderCancelLogic) UserOrderCancel(req *types.UserOrderCancelReq, us
// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data)
// userinfo 传入值时, 一定不为null
if userinfo == nil || userinfo.UserId == 0 {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
// if userinfo == nil || userinfo.UserId == 0 {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
//查询订单信息
orderModel := gmodel.NewFsOrderModel(l.svcCtx.MysqlConn)
orderInfo, err := orderModel.FindOne(l.ctx, userinfo.UserId, req.ID)
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "the order is not exists")
}
logx.Error(err)
return resp.SetStatus(basic.CodeServiceErr, "failed to get order info")
}
// //查询订单信息
// orderModel := gmodel.NewFsOrderModel(l.svcCtx.MysqlConn)
// orderInfo, err := orderModel.FindOne(l.ctx, userinfo.UserId, req.ID)
// if err != nil {
// if errors.Is(err, gorm.ErrRecordNotFound) {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "the order is not exists")
// }
// logx.Error(err)
// return resp.SetStatus(basic.CodeServiceErr, "failed to get order info")
// }
// 判断订单状态
var notCancelStatusMap = make(map[int64]struct{}, 3)
notCancelStatusMap[int64(constants.STATUS_NEW_NOT_PAY)] = struct{}{}
notCancelStatusMap[int64(constants.STATUS_NEW_PART_PAY)] = struct{}{}
notCancelStatusMap[int64(constants.STATUS_NEW_PAY_COMPLETED)] = struct{}{}
_, ok := notCancelStatusMap[int64(*orderInfo.Status)]
if !ok {
return resp.SetStatusWithMessage(basic.CodeOrderNotCancelledErr, "the order status not cancle")
}
// // 判断订单状态
// var notCancelStatusMap = make(map[int64]struct{}, 3)
// notCancelStatusMap[int64(constants.STATUS_NEW_NOT_PAY)] = struct{}{}
// notCancelStatusMap[int64(constants.STATUS_NEW_PART_PAY)] = struct{}{}
// notCancelStatusMap[int64(constants.STATUS_NEW_PAY_COMPLETED)] = struct{}{}
// _, ok := notCancelStatusMap[int64(*orderInfo.Status)]
// if !ok {
// return resp.SetStatusWithMessage(basic.CodeOrderNotCancelledErr, "the order status not cancle")
// }
var cancelTime int64 = time.Now().UTC().Unix() - (*orderInfo.Ctime + int64(constants.CANCLE_ORDER_EXPIRE))
// 第一次支付成功后48小时后不能进行取消操作
if *orderInfo.IsPayCompleted == 1 && cancelTime > 0 {
return resp.SetStatusWithMessage(basic.CodeOrderNotCancelledErr, "The current order cannot be cancelled")
}
// var cancelTime int64 = time.Now().UTC().Unix() - (*orderInfo.Ctime + int64(constants.CANCLE_ORDER_EXPIRE))
// // 第一次支付成功后48小时后不能进行取消操作
// if *orderInfo.IsPayCompleted == 1 && cancelTime > 0 {
// return resp.SetStatusWithMessage(basic.CodeOrderNotCancelledErr, "The current order cannot be cancelled")
// }
// 修改订单--取消状态和取消原因
*orderInfo.Status = int64(constants.STATUS_NEW_CANCEL)
*orderInfo.IsCancel = 1
orderInfo.RefundReasonId = &req.RefundReasonId
orderInfo.RefundReason = &req.RefundReason
// // 修改订单--取消状态和取消原因
// *orderInfo.Status = int64(constants.STATUS_NEW_CANCEL)
// *orderInfo.IsCancel = 1
// orderInfo.RefundReasonId = &req.RefundReasonId
// orderInfo.RefundReason = &req.RefundReason
var nowTime = time.Now().UTC().Unix()
var payList []handlers.PayInfo
// 事务处理
ctx := l.ctx
err = l.svcCtx.MysqlConn.Transaction(func(tx *gorm.DB) error {
// 修改订单信息
orderModelTS := gmodel.NewFsOrderModel(tx)
err = orderModelTS.RBUpdate(ctx, orderInfo)
if err != nil {
return err
}
// 新增退款记录
var isRefund int64 = 0
refundReasonModelTS := gmodel.NewFsRefundReasonModel(tx)
refundReasonModelTS.RBCreateOrUpdate(ctx, &gmodel.FsRefundReason{
IsRefund: &isRefund,
RefundReasonId: &req.RefundReasonId,
RefundReason: &req.RefundReason,
OrderId: &orderInfo.Id,
CreatedAt: &nowTime,
})
// 退款申请
// 退款申请--查询支付信息
fsPayModelTS := gmodel.NewFsPayModel(tx)
rbFsPay := fsPayModelTS.RowSelectBuilder(nil).Where("order_number = ?", orderInfo.Sn).Where("pay_status =?", constants.PAYSTATUS_SUCCESS).Where("is_refund =?", 0)
payInfoList, err := fsPayModelTS.FindAll(ctx, rbFsPay, nil, "")
if err != nil {
return err
}
for _, payInfo := range payInfoList {
var key string
if *payInfo.PaymentMethod == int64(constants.PAYMETHOD_STRIPE) {
key = l.svcCtx.Config.PayConfig.Stripe.Key
}
payList = append(payList, handlers.PayInfo{
TradeNo: *payInfo.TradeNo,
PaymentMethod: *payInfo.PaymentMethod,
Key: key,
})
}
return nil
})
// 退款申请--调取第三方接口发起退款
handlers.PayRefundHandler(&handlers.PayRefundHandlerReq{
PayInfoList: payList,
})
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeOrderCancelledNotOk, "the order cancle failed")
}
// var nowTime = time.Now().UTC().Unix()
// var payList []handlers.PayInfo
// // 事务处理
// ctx := l.ctx
// err = l.svcCtx.MysqlConn.Transaction(func(tx *gorm.DB) error {
// // 修改订单信息
// orderModelTS := gmodel.NewFsOrderModel(tx)
// err = orderModelTS.RBUpdate(ctx, orderInfo)
// if err != nil {
// return err
// }
// // 新增退款记录
// var isRefund int64 = 0
// refundReasonModelTS := gmodel.NewFsRefundReasonModel(tx)
// refundReasonModelTS.RBCreateOrUpdate(ctx, &gmodel.FsRefundReason{
// IsRefund: &isRefund,
// RefundReasonId: &req.RefundReasonId,
// RefundReason: &req.RefundReason,
// OrderId: &orderInfo.Id,
// CreatedAt: &nowTime,
// })
// // 退款申请
// // 退款申请--查询支付信息
// fsPayModelTS := gmodel.NewFsPayModel(tx)
// rbFsPay := fsPayModelTS.RowSelectBuilder(nil).Where("order_number = ?", orderInfo.Sn).Where("pay_status =?", constants.PAYSTATUS_SUCCESS).Where("is_refund =?", 0)
// payInfoList, err := fsPayModelTS.FindAll(ctx, rbFsPay, nil, "")
// if err != nil {
// return err
// }
// for _, payInfo := range payInfoList {
// var key string
// if *payInfo.PaymentMethod == int64(constants.PAYMETHOD_STRIPE) {
// key = l.svcCtx.Config.PayConfig.Stripe.Key
// }
// payList = append(payList, handlers.PayInfo{
// TradeNo: *payInfo.TradeNo,
// PaymentMethod: *payInfo.PaymentMethod,
// Key: key,
// })
// }
// return nil
// })
// // 退款申请--调取第三方接口发起退款
// handlers.PayRefundHandler(&handlers.PayRefundHandlerReq{
// PayInfoList: payList,
// })
// if err != nil {
// logx.Error(err)
// return resp.SetStatusWithMessage(basic.CodeOrderCancelledNotOk, "the order cancle failed")
// }
return resp.SetStatus(basic.CodeOK)
}

58
server/home-user-auth/internal/logic/userorderdeletelogic.go
View File

@@ -1,9 +1,6 @@
package logic
import (
"errors"
"fusenapi/constants"
"fusenapi/model/gmodel"
"fusenapi/utils/auth"
"fusenapi/utils/basic"
@@ -13,7 +10,6 @@ import (
"fusenapi/server/home-user-auth/internal/types"
"github.com/zeromicro/go-zero/core/logx"
"gorm.io/gorm"
)
type UserOrderDeleteLogic struct {
@@ -43,36 +39,36 @@ func (l *UserOrderDeleteLogic) UserOrderDelete(req *types.UserOrderDeleteReq, us
// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data)
// userinfo 传入值时, 一定不为null
if userinfo == nil || userinfo.UserId == 0 {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
// if userinfo == nil || userinfo.UserId == 0 {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
orderModel := gmodel.NewFsOrderModel(l.svcCtx.MysqlConn)
orderInfo, err := orderModel.FindOne(l.ctx, userinfo.UserId, req.ID)
// orderModel := gmodel.NewFsOrderModel(l.svcCtx.MysqlConn)
// orderInfo, err := orderModel.FindOne(l.ctx, userinfo.UserId, req.ID)
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get order info")
}
// if err != nil {
// if errors.Is(err, gorm.ErrRecordNotFound) {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
// logx.Error(err)
// return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get order info")
// }
updateStatusMap := make(map[constants.Order]struct{}, 4)
updateStatusMap[constants.STATUS_NEW_COMPLETED] = struct{}{}
updateStatusMap[constants.STATUS_NEW_CANCEL] = struct{}{}
updateStatusMap[constants.STATUS_NEW_REFUNDED] = struct{}{}
updateStatusMap[constants.STATUS_NEW_CLOSE] = struct{}{}
if _, ok := updateStatusMap[constants.Order(*orderInfo.Status)]; !ok {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
*orderInfo.Status = int64(constants.STATUS_NEW_DELETE)
*orderInfo.IsDeleted = 1
err = orderModel.Update(l.ctx, orderInfo)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "fail to delete")
}
// updateStatusMap := make(map[constants.Order]struct{}, 4)
// updateStatusMap[constants.STATUS_NEW_COMPLETED] = struct{}{}
// updateStatusMap[constants.STATUS_NEW_CANCEL] = struct{}{}
// updateStatusMap[constants.STATUS_NEW_REFUNDED] = struct{}{}
// updateStatusMap[constants.STATUS_NEW_CLOSE] = struct{}{}
// if _, ok := updateStatusMap[constants.Order(*orderInfo.Status)]; !ok {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
// *orderInfo.Status = int64(constants.STATUS_NEW_DELETE)
// *orderInfo.IsDeleted = 1
// err = orderModel.Update(l.ctx, orderInfo)
// if err != nil {
// logx.Error(err)
// return resp.SetStatusWithMessage(basic.CodeServiceErr, "fail to delete")
// }
return resp.SetStatus(basic.CodeOK)
}

474
server/home-user-auth/internal/logic/userorderlistlogic.go
View File

@@ -1,20 +1,8 @@
package logic
import (
"errors"
"fmt"
"fusenapi/constants"
"fusenapi/model/gmodel"
"fusenapi/utils/auth"
"fusenapi/utils/basic"
"fusenapi/utils/configs"
"fusenapi/utils/image"
"strings"
"fusenapi/utils/format"
"fusenapi/utils/order"
"math"
"time"
"context"
@@ -22,7 +10,6 @@ import (
"fusenapi/server/home-user-auth/internal/types"
"github.com/zeromicro/go-zero/core/logx"
"gorm.io/gorm"
)
type UserOrderListLogic struct {
@@ -43,263 +30,264 @@ func (l *UserOrderListLogic) UserOrderList(req *types.UserOrderListReq, userinfo
// 返回值必须调用Set重新返回, resp可以空指针调用 resp.SetStatus(basic.CodeOK, data)
// userinfo 传入值时, 一定不为null
size := req.Size
// size := req.Size
if size > 0 {
size = int64(image.GetCurrentSize(uint32(size)))
}
// if size > 0 {
// size = int64(image.GetCurrentSize(uint32(size)))
// }
orderDetailModel := gmodel.NewFsOrderDetailModel(l.svcCtx.MysqlConn)
orderDetailTemplateModel := gmodel.NewFsOrderDetailTemplateModel(l.svcCtx.MysqlConn)
fsProductDesignModel := gmodel.NewFsProductDesignModel(l.svcCtx.MysqlConn)
orderModel := gmodel.NewFsOrderModel(l.svcCtx.MysqlConn)
rowBuilder := orderModel.RowSelectBuilder(nil)
if userinfo == nil || userinfo.UserId == 0 {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
// orderDetailModel := gmodel.NewFsOrderDetailModel(l.svcCtx.MysqlConn)
// orderDetailTemplateModel := gmodel.NewFsOrderDetailTemplateModel(l.svcCtx.MysqlConn)
// fsProductDesignModel := gmodel.NewFsProductDesignModel(l.svcCtx.MysqlConn)
// orderModel := gmodel.NewFsOrderModel(l.svcCtx.MysqlConn)
// rowBuilder := orderModel.RowSelectBuilder(nil)
// if userinfo == nil || userinfo.UserId == 0 {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
// 查询条件
var page = req.Page
var pageSize = req.PageSize
var listRes []*gmodel.FsOrderRel
rowBuilder = rowBuilder.Where("user_id =?", userinfo.UserId).Where("status <> ?", constants.STATUS_NEW_NOT_PAY).Where("status <>?", constants.STATUS_NEW_DELETE)
// // 查询条件
// var page = req.Page
// var pageSize = req.PageSize
// var listRes []*gmodel.FsOrderRel
// rowBuilder = rowBuilder.Where("user_id =?", userinfo.UserId).Where("status <> ?", constants.STATUS_NEW_NOT_PAY).Where("status <>?", constants.STATUS_NEW_DELETE)
// 根据时间来查询不同范围的订单
switch req.Time {
case 1:
rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(0, -1, 0).Unix())
case 2:
rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(0, -3, 0).Unix())
case 3:
rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(0, -6, 0).Unix())
case 4:
rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(-1, 0, 0).Unix())
default:
}
// // 根据时间来查询不同范围的订单
// switch req.Time {
// case 1:
// rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(0, -1, 0).Unix())
// case 2:
// rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(0, -3, 0).Unix())
// case 3:
// rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(0, -6, 0).Unix())
// case 4:
// rowBuilder = rowBuilder.Where("ctime >?", time.Now().UTC().AddDate(-1, 0, 0).Unix())
// default:
// }
//按照订单状态查询不同的订单
if req.Status != -1 {
switch req.Status {
case 1:
rowBuilder = rowBuilder.Where("status in ?", [3]constants.Order{constants.STATUS_NEW_PART_PAY, constants.STATUS_NEW_PAY_COMPLETED, constants.STATUS_NEW_SURE})
case 2:
rowBuilder = rowBuilder.Where("status in ?", [2]constants.Order{constants.STATUS_NEW_PRODUTING, constants.STATUS_NEW_PRODUT_COMPLETED})
case 3:
rowBuilder = rowBuilder.Where("status in ?", [2]constants.Order{constants.STATUS_NEW_DELIVER, constants.STATUS_NEW_UPS})
case 4:
rowBuilder = rowBuilder.Where("status =?", constants.STATUS_NEW_ARRIVAL)
case 5:
rowBuilder = rowBuilder.Where("status =?", constants.STATUS_NEW_COMPLETED).Where("delivery_method =?", constants.DELIVERY_METHOD_ADDRESS)
case 7:
rowBuilder = rowBuilder.Where("status in ?", [3]constants.Order{constants.STATUS_NEW_CANCEL, constants.STATUS_NEW_REFUNDED, constants.STATUS_NEW_REFUNDING})
case 8:
rowBuilder = rowBuilder.Where("status =?", constants.STATUS_NEW_COMPLETED).Where("delivery_method =?", constants.DELIVERY_METHOD_CLOUD)
}
}
// //按照订单状态查询不同的订单
// if req.Status != -1 {
// switch req.Status {
// case 1:
// rowBuilder = rowBuilder.Where("status in ?", [3]constants.Order{constants.STATUS_NEW_PART_PAY, constants.STATUS_NEW_PAY_COMPLETED, constants.STATUS_NEW_SURE})
// case 2:
// rowBuilder = rowBuilder.Where("status in ?", [2]constants.Order{constants.STATUS_NEW_PRODUTING, constants.STATUS_NEW_PRODUT_COMPLETED})
// case 3:
// rowBuilder = rowBuilder.Where("status in ?", [2]constants.Order{constants.STATUS_NEW_DELIVER, constants.STATUS_NEW_UPS})
// case 4:
// rowBuilder = rowBuilder.Where("status =?", constants.STATUS_NEW_ARRIVAL)
// case 5:
// rowBuilder = rowBuilder.Where("status =?", constants.STATUS_NEW_COMPLETED).Where("delivery_method =?", constants.DELIVERY_METHOD_ADDRESS)
// case 7:
// rowBuilder = rowBuilder.Where("status in ?", [3]constants.Order{constants.STATUS_NEW_CANCEL, constants.STATUS_NEW_REFUNDED, constants.STATUS_NEW_REFUNDING})
// case 8:
// rowBuilder = rowBuilder.Where("status =?", constants.STATUS_NEW_COMPLETED).Where("delivery_method =?", constants.DELIVERY_METHOD_CLOUD)
// }
// }
// 查询总数
total, err := orderModel.FindCount(l.ctx, rowBuilder, nil)
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get order info")
}
// // 查询总数
// total, err := orderModel.FindCount(l.ctx, rowBuilder, nil)
// if err != nil {
// if errors.Is(err, gorm.ErrRecordNotFound) {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
// logx.Error(err)
// return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get order info")
// }
// 查询数据
if total > 0 {
rowBuilder = rowBuilder.Preload("FsOrderAffiliateInfo").Preload("FsOrderDetails", func(dbPreload *gorm.DB) *gorm.DB {
return dbPreload.Table(orderDetailModel.TableName()).Preload("FsOrderDetailTemplateInfo", func(dbPreload *gorm.DB) *gorm.DB {
return dbPreload.Table(orderDetailTemplateModel.TableName()).Preload("FsProductDesignInfo", func(dbPreload *gorm.DB) *gorm.DB {
return dbPreload.Table(fsProductDesignModel.TableName()).Preload("OptionData").Preload("TemplateData")
}).Preload("FsProductSizeInfo")
}).Preload("FsProductInfo")
})
listRes, err = orderModel.FindPageListByPage(l.ctx, rowBuilder, &page, &pageSize, nil, "")
}
// // 查询数据
// if total > 0 {
// rowBuilder = rowBuilder.Preload("FsOrderAffiliateInfo").Preload("FsOrderDetails", func(dbPreload *gorm.DB) *gorm.DB {
// return dbPreload.Table(orderDetailModel.TableName()).Preload("FsOrderDetailTemplateInfo", func(dbPreload *gorm.DB) *gorm.DB {
// return dbPreload.Table(orderDetailTemplateModel.TableName()).Preload("FsProductDesignInfo", func(dbPreload *gorm.DB) *gorm.DB {
// return dbPreload.Table(fsProductDesignModel.TableName()).Preload("OptionData").Preload("TemplateData")
// }).Preload("FsProductSizeInfo")
// }).Preload("FsProductInfo")
// })
// listRes, err = orderModel.FindPageListByPage(l.ctx, rowBuilder, &page, &pageSize, nil, "")
// }
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
}
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get order info")
}
listResLen := len(listRes)
// if err != nil {
// if errors.Is(err, gorm.ErrRecordNotFound) {
// return resp.SetStatusWithMessage(basic.CodeDbRecordNotFoundErr, "order not found")
// }
// logx.Error(err)
// return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get order info")
// }
// listResLen := len(listRes)
var respList []types.Items
if listResLen > 0 {
// 获取订单时间配置
orderTimeConfig, err := configs.GetOrderTimeConfig(l.ctx, l.svcCtx.MysqlConn)
if err != nil {
return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get config time info")
}
// var respList []types.Items
// if listResLen > 0 {
// // 获取订单时间配置
// orderTimeConfig, err := configs.GetOrderTimeConfig(l.ctx, l.svcCtx.MysqlConn)
// if err != nil {
// return resp.SetStatusWithMessage(basic.CodeServiceErr, "failed to get config time info")
// }
// 数据处理
for _, item := range listRes {
var pbData types.Items
pbData.ID = item.Id
pbData.Sn = *item.Sn
pbData.UserID = *item.UserId
pbData.TotalAmount = *item.TotalAmount
pbData.Ctime = format.TimeIntToFormat(*item.Ctime)
pbData.Status = *item.Status
pbData.DeliveryMethod = *item.DeliveryMethod
pbData.TsTime = format.TimeToFormat(*item.TsTime)
pbData.IsPayCompleted = *item.IsPayCompleted
pbData.DeliverSn = *item.DeliverSn
// // 数据处理
// for _, item := range listRes {
// var pbData types.Items
// pbData.ID = item.Id
// pbData.Sn = *item.Sn
// pbData.UserID = *item.UserId
// pbData.TotalAmount = *item.TotalAmount
// pbData.Ctime = format.TimeIntToFormat(*item.Ctime)
// pbData.Status = *item.Status
// pbData.DeliveryMethod = *item.DeliveryMethod
// pbData.TsTime = format.TimeToFormat(*item.TsTime)
// pbData.IsPayCompleted = *item.IsPayCompleted
// pbData.DeliverSn = *item.DeliverSn
var pcsBox int64
var pcs int64
var productList []types.Product
// var pcsBox int64
// var pcs int64
// var productList []types.Product
var surplusAt int64
// var surplusAt int64
//如果是部分支付状态，那么取消订单倒计时2天
if *item.Status == int64(constants.STATUS_NEW_PART_PAY) {
surplusAt = (*item.Ctime + int64(constants.CANCLE_ORDER_EXPIRE)) - time.Now().UTC().Unix()
if surplusAt < 0 {
surplusAt = 0
}
}
// //如果是部分支付状态，那么取消订单倒计时2天
// if *item.Status == int64(constants.STATUS_NEW_PART_PAY) {
// surplusAt = (*item.Ctime + int64(constants.CANCLE_ORDER_EXPIRE)) - time.Now().UTC().Unix()
// if surplusAt < 0 {
// surplusAt = 0
// }
// }
fsOrderAffiliateInfo := item.FsOrderAffiliateInfo
// fsOrderAffiliateInfo := item.FsOrderAffiliateInfo
var sureTime int64
var productTime int64
var ProductEndtime int64
var deliverTime int64
var upsDeliverTime int64
var upsTime int64
var arrivalTime int64
var recevieTime int64
if fsOrderAffiliateInfo.Id > 0 {
sureTime = *fsOrderAffiliateInfo.SureTime
productTime = *fsOrderAffiliateInfo.ProductTime
ProductEndtime = *fsOrderAffiliateInfo.ProductEndtime
deliverTime = *fsOrderAffiliateInfo.DeliverTime
upsDeliverTime = *fsOrderAffiliateInfo.UpsDeliverTime
upsTime = *fsOrderAffiliateInfo.UpsTime
arrivalTime = *fsOrderAffiliateInfo.ArrivalTime
recevieTime = *fsOrderAffiliateInfo.RecevieTime
}
// var sureTime int64
// var productTime int64
// var ProductEndtime int64
// var deliverTime int64
// var upsDeliverTime int64
// var upsTime int64
// var arrivalTime int64
// var recevieTime int64
// if fsOrderAffiliateInfo.Id > 0 {
// sureTime = *fsOrderAffiliateInfo.SureTime
// productTime = *fsOrderAffiliateInfo.ProductTime
// ProductEndtime = *fsOrderAffiliateInfo.ProductEndtime
// deliverTime = *fsOrderAffiliateInfo.DeliverTime
// upsDeliverTime = *fsOrderAffiliateInfo.UpsDeliverTime
// upsTime = *fsOrderAffiliateInfo.UpsTime
// arrivalTime = *fsOrderAffiliateInfo.ArrivalTime
// recevieTime = *fsOrderAffiliateInfo.RecevieTime
// }
var getOrderStatusAndLogisticsReq = order.GetOrderStatusAndLogisticsReq{
OrderStatus: constants.Order(*item.Status),
DeliveryMethod: constants.DeliveryMethod(*item.DeliveryMethod),
IsPayCompleted: *item.IsAllProductCompleted,
OrderCtime: *item.Ctime,
// var getOrderStatusAndLogisticsReq = order.GetOrderStatusAndLogisticsReq{
// OrderStatus: constants.Order(*item.Status),
// DeliveryMethod: constants.DeliveryMethod(*item.DeliveryMethod),
// IsPayCompleted: *item.IsAllProductCompleted,
// OrderCtime: *item.Ctime,
SureTime: sureTime,
ProductTime: productTime,
ProductEndtime: ProductEndtime,
DeliverTime: deliverTime,
UpsDeliverTime: upsDeliverTime,
UpsTime: upsTime,
ArrivalTime: arrivalTime,
RecevieTime: recevieTime,
// SureTime: sureTime,
// ProductTime: productTime,
// ProductEndtime: ProductEndtime,
// DeliverTime: deliverTime,
// UpsDeliverTime: upsDeliverTime,
// UpsTime: upsTime,
// ArrivalTime: arrivalTime,
// RecevieTime: recevieTime,
WebSetTimeInfo: orderTimeConfig,
}
// WebSetTimeInfo: orderTimeConfig,
// }
statusAndLogisticsRes := order.GetOrderStatusAndLogistics(getOrderStatusAndLogisticsReq)
// statusAndLogisticsRes := order.GetOrderStatusAndLogistics(getOrderStatusAndLogisticsReq)
// 流程控制
var statusTime []types.StatusTime
for _, itemTimes := range statusAndLogisticsRes.Times {
statusTime = append(statusTime, types.StatusTime{
Key: itemTimes.Key,
Time: itemTimes.Time,
})
}
pbData.StatusTimes = statusTime
pbData.LogisticsStatus = int64(statusAndLogisticsRes.LogisticsStatus)
pbData.Status = int64(statusAndLogisticsRes.OrderStatus)
// // 流程控制
// var statusTime []types.StatusTime
// for _, itemTimes := range statusAndLogisticsRes.Times {
// statusTime = append(statusTime, types.StatusTime{
// Key: itemTimes.Key,
// Time: itemTimes.Time,
// })
// }
// pbData.StatusTimes = statusTime
// pbData.LogisticsStatus = int64(statusAndLogisticsRes.LogisticsStatus)
// pbData.Status = int64(statusAndLogisticsRes.OrderStatus)
var isStopMax int64
if len(item.FsOrderDetails) > 0 {
for _, fsOrderDetailItem := range item.FsOrderDetails {
// var isStopMax int64
// if len(item.FsOrderDetails) > 0 {
// for _, fsOrderDetailItem := range item.FsOrderDetails {
fsOrderDetailBuyNum := *fsOrderDetailItem.FsOrderDetail.BuyNum
fsOrderDetailEachBoxNum := *fsOrderDetailItem.FsOrderDetailTemplateInfo.EachBoxNum
pcs = pcs + fsOrderDetailBuyNum
pcsBoxNum := fsOrderDetailBuyNum / fsOrderDetailEachBoxNum
var csBoxNumF int64
if (fsOrderDetailBuyNum % fsOrderDetailEachBoxNum) > 0 {
csBoxNumF = 1
}
pcsBox = pcsBox + pcsBoxNum + csBoxNumF
// fsOrderDetailBuyNum := *fsOrderDetailItem.FsOrderDetail.BuyNum
// fsOrderDetailEachBoxNum := *fsOrderDetailItem.FsOrderDetailTemplateInfo.EachBoxNum
// pcs = pcs + fsOrderDetailBuyNum
// pcsBoxNum := fsOrderDetailBuyNum / fsOrderDetailEachBoxNum
// var csBoxNumF int64
// if (fsOrderDetailBuyNum % fsOrderDetailEachBoxNum) > 0 {
// csBoxNumF = 1
// }
// pcsBox = pcsBox + pcsBoxNum + csBoxNumF
productCover := *fsOrderDetailItem.Cover
// 尺寸
if size >= 200 {
coverArr := strings.Split(*fsOrderDetailItem.Cover, ".")
if len(coverArr) < 2 {
return resp.SetStatusWithMessage(basic.CodeServiceErr, "cover split slice item count is less than 2")
}
productCover = fmt.Sprintf("%s_%d.%s", coverArr[0], req.Size, coverArr[1])
}
// productCover := *fsOrderDetailItem.Cover
// // 尺寸
// if size >= 200 {
// coverArr := strings.Split(*fsOrderDetailItem.Cover, ".")
// if len(coverArr) < 2 {
// return resp.SetStatusWithMessage(basic.CodeServiceErr, "cover split slice item count is less than 2")
// }
// productCover = fmt.Sprintf("%s_%d.%s", coverArr[0], req.Size, coverArr[1])
// }
// 判断stop
var isStop int64
if fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductDesignInfo.OptionData.Id != 0 {
// 尺寸或者模板下架
if fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductDesignInfo.Id != 0 {
isStop = 1
} else {
isStop = 3
}
} else {
if fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductDesignInfo.Id != 0 {
isStop = 1
}
}
// // 判断stop
// var isStop int64
// if fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductDesignInfo.OptionData.Id != 0 {
// // 尺寸或者模板下架
// if fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductDesignInfo.Id != 0 {
// isStop = 1
// } else {
// isStop = 3
// }
// } else {
// if fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductDesignInfo.Id != 0 {
// isStop = 1
// }
// }
// 判断产品是否下架
if *fsOrderDetailItem.FsProductInfo.IsShelf == 0 || *fsOrderDetailItem.FsProductInfo.IsDel == 1 {
isStop = 2
}
if isStop > isStopMax {
isStopMax = isStop
}
// // 判断产品是否下架
// if *fsOrderDetailItem.FsProductInfo.IsShelf == 0 || *fsOrderDetailItem.FsProductInfo.IsDel == 1 {
// isStop = 2
// }
// if isStop > isStopMax {
// isStopMax = isStop
// }
productList = append(productList, types.Product{
Cover: productCover,
Fitting: *fsOrderDetailItem.OptionalTitle,
OptionPrice: *fsOrderDetailItem.OptionPrice,
OrderDetailTemplateId: *fsOrderDetailItem.OrderDetailTemplateId,
OrderId: *fsOrderDetailItem.OrderId,
Pcs: fsOrderDetailBuyNum,
PcsBox: pcsBox,
Price: *fsOrderDetailItem.FsOrderDetail.Amount,
ProductId: *fsOrderDetailItem.OptionPrice,
Title: *fsOrderDetailItem.FsProductInfo.Title,
Size: *fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductSizeInfo.Capacity,
IsStop: isStop,
})
}
pbData.ProductList = productList
}
// productList = append(productList, types.Product{
// Cover: productCover,
// Fitting: *fsOrderDetailItem.OptionalTitle,
// OptionPrice: *fsOrderDetailItem.OptionPrice,
// OrderDetailTemplateId: *fsOrderDetailItem.OrderDetailTemplateId,
// OrderId: *fsOrderDetailItem.OrderId,
// Pcs: fsOrderDetailBuyNum,
// PcsBox: pcsBox,
// Price: *fsOrderDetailItem.FsOrderDetail.Amount,
// ProductId: *fsOrderDetailItem.OptionPrice,
// Title: *fsOrderDetailItem.FsProductInfo.Title,
// Size: *fsOrderDetailItem.FsOrderDetailTemplateInfo.FsProductSizeInfo.Capacity,
// IsStop: isStop,
// })
// }
// pbData.ProductList = productList
// }
pbData.IsStop = isStopMax
pbData.PcsBox = pcsBox
pbData.Pcs = pcs
pbData.SurplusAt = surplusAt
pbData.Deposit = *item.TotalAmount / 2
pbData.Remaining = pbData.Deposit
respList = append(respList, pbData)
}
// pbData.IsStop = isStopMax
// pbData.PcsBox = pcsBox
// pbData.Pcs = pcs
// pbData.SurplusAt = surplusAt
// pbData.Deposit = *item.TotalAmount / 2
// pbData.Remaining = pbData.Deposit
// respList = append(respList, pbData)
// }
}
// }
return resp.SetStatusWithMessage(basic.CodeOK, "success", types.UserOrderListRsp{
Items: respList,
Meta: types.Meta{
TotalCount: total,
PageCount: int64(math.Ceil(float64(total) / float64(pageSize))),
CurrentPage: int(page),
PerPage: int(pageSize),
},
})
// return resp.SetStatusWithMessage(basic.CodeOK, "success", types.UserOrderListRsp{
// Items: respList,
// Meta: types.Meta{
// TotalCount: total,
// PageCount: int64(math.Ceil(float64(total) / float64(pageSize))),
// CurrentPage: int(page),
// PerPage: int(pageSize),
// },
// })
return resp.SetStatusWithMessage(basic.CodeOK, "success")
}