785 lines
23 KiB
Go
785 lines
23 KiB
Go
// Code generated by ent, DO NOT EDIT.
|
|
|
|
package ent
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"mingyang-admin-pay/rpc/ent/paychannel"
|
|
"mingyang-admin-pay/rpc/ent/paynotifytask"
|
|
"mingyang-admin-pay/rpc/ent/payorder"
|
|
"mingyang-admin-pay/rpc/ent/payorderextension"
|
|
"mingyang-admin-pay/rpc/ent/payrefund"
|
|
"time"
|
|
|
|
"entgo.io/ent/dialect/sql/sqlgraph"
|
|
"entgo.io/ent/schema/field"
|
|
)
|
|
|
|
// PayOrderCreate is the builder for creating a PayOrder entity.
|
|
type PayOrderCreate struct {
|
|
config
|
|
mutation *PayOrderMutation
|
|
hooks []Hook
|
|
}
|
|
|
|
// SetCreatedAt sets the "created_at" field.
|
|
func (_c *PayOrderCreate) SetCreatedAt(v time.Time) *PayOrderCreate {
|
|
_c.mutation.SetCreatedAt(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableCreatedAt sets the "created_at" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableCreatedAt(v *time.Time) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetCreatedAt(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetUpdatedAt sets the "updated_at" field.
|
|
func (_c *PayOrderCreate) SetUpdatedAt(v time.Time) *PayOrderCreate {
|
|
_c.mutation.SetUpdatedAt(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableUpdatedAt sets the "updated_at" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableUpdatedAt(v *time.Time) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetUpdatedAt(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetStatus sets the "status" field.
|
|
func (_c *PayOrderCreate) SetStatus(v uint8) *PayOrderCreate {
|
|
_c.mutation.SetStatus(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableStatus sets the "status" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableStatus(v *uint8) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetStatus(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetTenantID sets the "tenant_id" field.
|
|
func (_c *PayOrderCreate) SetTenantID(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetTenantID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableTenantID sets the "tenant_id" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableTenantID(v *uint64) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetTenantID(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetDeletedAt sets the "deleted_at" field.
|
|
func (_c *PayOrderCreate) SetDeletedAt(v time.Time) *PayOrderCreate {
|
|
_c.mutation.SetDeletedAt(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableDeletedAt sets the "deleted_at" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableDeletedAt(v *time.Time) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetDeletedAt(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetChannelID sets the "channel_id" field.
|
|
func (_c *PayOrderCreate) SetChannelID(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetChannelID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetUserID sets the "user_id" field.
|
|
func (_c *PayOrderCreate) SetUserID(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetUserID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetSubject sets the "subject" field.
|
|
func (_c *PayOrderCreate) SetSubject(v string) *PayOrderCreate {
|
|
_c.mutation.SetSubject(v)
|
|
return _c
|
|
}
|
|
|
|
// SetBody sets the "body" field.
|
|
func (_c *PayOrderCreate) SetBody(v string) *PayOrderCreate {
|
|
_c.mutation.SetBody(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNotifyURL sets the "notify_url" field.
|
|
func (_c *PayOrderCreate) SetNotifyURL(v string) *PayOrderCreate {
|
|
_c.mutation.SetNotifyURL(v)
|
|
return _c
|
|
}
|
|
|
|
// SetAmount sets the "amount" field.
|
|
func (_c *PayOrderCreate) SetAmount(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetAmount(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableAmount sets the "amount" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableAmount(v *uint64) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetAmount(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetPaySource sets the "pay_source" field.
|
|
func (_c *PayOrderCreate) SetPaySource(v string) *PayOrderCreate {
|
|
_c.mutation.SetPaySource(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillablePaySource sets the "pay_source" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillablePaySource(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetPaySource(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetChannelFeeRate sets the "channel_fee_rate" field.
|
|
func (_c *PayOrderCreate) SetChannelFeeRate(v string) *PayOrderCreate {
|
|
_c.mutation.SetChannelFeeRate(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableChannelFeeRate sets the "channel_fee_rate" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableChannelFeeRate(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetChannelFeeRate(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetChannelFee sets the "channel_fee" field.
|
|
func (_c *PayOrderCreate) SetChannelFee(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetChannelFee(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableChannelFee sets the "channel_fee" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableChannelFee(v *uint64) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetChannelFee(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetOrderStatus sets the "order_status" field.
|
|
func (_c *PayOrderCreate) SetOrderStatus(v string) *PayOrderCreate {
|
|
_c.mutation.SetOrderStatus(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableOrderStatus sets the "order_status" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableOrderStatus(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetOrderStatus(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetUserIP sets the "user_ip" field.
|
|
func (_c *PayOrderCreate) SetUserIP(v string) *PayOrderCreate {
|
|
_c.mutation.SetUserIP(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableUserIP sets the "user_ip" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableUserIP(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetUserIP(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetExpireTime sets the "expire_time" field.
|
|
func (_c *PayOrderCreate) SetExpireTime(v time.Time) *PayOrderCreate {
|
|
_c.mutation.SetExpireTime(v)
|
|
return _c
|
|
}
|
|
|
|
// SetPayNo sets the "pay_no" field.
|
|
func (_c *PayOrderCreate) SetPayNo(v string) *PayOrderCreate {
|
|
_c.mutation.SetPayNo(v)
|
|
return _c
|
|
}
|
|
|
|
// SetSuccessTime sets the "success_time" field.
|
|
func (_c *PayOrderCreate) SetSuccessTime(v time.Time) *PayOrderCreate {
|
|
_c.mutation.SetSuccessTime(v)
|
|
return _c
|
|
}
|
|
|
|
// SetExtensionID sets the "extension_id" field.
|
|
func (_c *PayOrderCreate) SetExtensionID(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetExtensionID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableExtensionID sets the "extension_id" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableExtensionID(v *uint64) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetExtensionID(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetTransactionID sets the "transaction_id" field.
|
|
func (_c *PayOrderCreate) SetTransactionID(v string) *PayOrderCreate {
|
|
_c.mutation.SetTransactionID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableTransactionID sets the "transaction_id" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableTransactionID(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetTransactionID(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetCurrency sets the "currency" field.
|
|
func (_c *PayOrderCreate) SetCurrency(v string) *PayOrderCreate {
|
|
_c.mutation.SetCurrency(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableCurrency sets the "currency" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableCurrency(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetCurrency(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetRefundPrice sets the "refund_price" field.
|
|
func (_c *PayOrderCreate) SetRefundPrice(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetRefundPrice(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableRefundPrice sets the "refund_price" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableRefundPrice(v *uint64) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetRefundPrice(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetChannelOrderNo sets the "channel_order_no" field.
|
|
func (_c *PayOrderCreate) SetChannelOrderNo(v string) *PayOrderCreate {
|
|
_c.mutation.SetChannelOrderNo(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableChannelOrderNo sets the "channel_order_no" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableChannelOrderNo(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetChannelOrderNo(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetChannelUserID sets the "channel_user_id" field.
|
|
func (_c *PayOrderCreate) SetChannelUserID(v string) *PayOrderCreate {
|
|
_c.mutation.SetChannelUserID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetNillableChannelUserID sets the "channel_user_id" field if the given value is not nil.
|
|
func (_c *PayOrderCreate) SetNillableChannelUserID(v *string) *PayOrderCreate {
|
|
if v != nil {
|
|
_c.SetChannelUserID(*v)
|
|
}
|
|
return _c
|
|
}
|
|
|
|
// SetID sets the "id" field.
|
|
func (_c *PayOrderCreate) SetID(v uint64) *PayOrderCreate {
|
|
_c.mutation.SetID(v)
|
|
return _c
|
|
}
|
|
|
|
// SetChannel sets the "channel" edge to the PayChannel entity.
|
|
func (_c *PayOrderCreate) SetChannel(v *PayChannel) *PayOrderCreate {
|
|
return _c.SetChannelID(v.ID)
|
|
}
|
|
|
|
// AddOrdersExtensionIDs adds the "orders_extension" edge to the PayOrderExtension entity by IDs.
|
|
func (_c *PayOrderCreate) AddOrdersExtensionIDs(ids ...uint64) *PayOrderCreate {
|
|
_c.mutation.AddOrdersExtensionIDs(ids...)
|
|
return _c
|
|
}
|
|
|
|
// AddOrdersExtension adds the "orders_extension" edges to the PayOrderExtension entity.
|
|
func (_c *PayOrderCreate) AddOrdersExtension(v ...*PayOrderExtension) *PayOrderCreate {
|
|
ids := make([]uint64, len(v))
|
|
for i := range v {
|
|
ids[i] = v[i].ID
|
|
}
|
|
return _c.AddOrdersExtensionIDs(ids...)
|
|
}
|
|
|
|
// AddNotifyTaskIDs adds the "notify_task" edge to the PayNotifyTask entity by IDs.
|
|
func (_c *PayOrderCreate) AddNotifyTaskIDs(ids ...uint64) *PayOrderCreate {
|
|
_c.mutation.AddNotifyTaskIDs(ids...)
|
|
return _c
|
|
}
|
|
|
|
// AddNotifyTask adds the "notify_task" edges to the PayNotifyTask entity.
|
|
func (_c *PayOrderCreate) AddNotifyTask(v ...*PayNotifyTask) *PayOrderCreate {
|
|
ids := make([]uint64, len(v))
|
|
for i := range v {
|
|
ids[i] = v[i].ID
|
|
}
|
|
return _c.AddNotifyTaskIDs(ids...)
|
|
}
|
|
|
|
// AddRefundIDs adds the "refund" edge to the PayRefund entity by IDs.
|
|
func (_c *PayOrderCreate) AddRefundIDs(ids ...uint64) *PayOrderCreate {
|
|
_c.mutation.AddRefundIDs(ids...)
|
|
return _c
|
|
}
|
|
|
|
// AddRefund adds the "refund" edges to the PayRefund entity.
|
|
func (_c *PayOrderCreate) AddRefund(v ...*PayRefund) *PayOrderCreate {
|
|
ids := make([]uint64, len(v))
|
|
for i := range v {
|
|
ids[i] = v[i].ID
|
|
}
|
|
return _c.AddRefundIDs(ids...)
|
|
}
|
|
|
|
// Mutation returns the PayOrderMutation object of the builder.
|
|
func (_c *PayOrderCreate) Mutation() *PayOrderMutation {
|
|
return _c.mutation
|
|
}
|
|
|
|
// Save creates the PayOrder in the database.
|
|
func (_c *PayOrderCreate) Save(ctx context.Context) (*PayOrder, error) {
|
|
_c.defaults()
|
|
return withHooks(ctx, _c.sqlSave, _c.mutation, _c.hooks)
|
|
}
|
|
|
|
// SaveX calls Save and panics if Save returns an error.
|
|
func (_c *PayOrderCreate) SaveX(ctx context.Context) *PayOrder {
|
|
v, err := _c.Save(ctx)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
|
|
// Exec executes the query.
|
|
func (_c *PayOrderCreate) Exec(ctx context.Context) error {
|
|
_, err := _c.Save(ctx)
|
|
return err
|
|
}
|
|
|
|
// ExecX is like Exec, but panics if an error occurs.
|
|
func (_c *PayOrderCreate) ExecX(ctx context.Context) {
|
|
if err := _c.Exec(ctx); err != nil {
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
// defaults sets the default values of the builder before save.
|
|
func (_c *PayOrderCreate) defaults() {
|
|
if _, ok := _c.mutation.CreatedAt(); !ok {
|
|
v := payorder.DefaultCreatedAt()
|
|
_c.mutation.SetCreatedAt(v)
|
|
}
|
|
if _, ok := _c.mutation.UpdatedAt(); !ok {
|
|
v := payorder.DefaultUpdatedAt()
|
|
_c.mutation.SetUpdatedAt(v)
|
|
}
|
|
if _, ok := _c.mutation.Status(); !ok {
|
|
v := payorder.DefaultStatus
|
|
_c.mutation.SetStatus(v)
|
|
}
|
|
if _, ok := _c.mutation.TenantID(); !ok {
|
|
v := payorder.DefaultTenantID
|
|
_c.mutation.SetTenantID(v)
|
|
}
|
|
if _, ok := _c.mutation.Amount(); !ok {
|
|
v := payorder.DefaultAmount
|
|
_c.mutation.SetAmount(v)
|
|
}
|
|
if _, ok := _c.mutation.ChannelFeeRate(); !ok {
|
|
v := payorder.DefaultChannelFeeRate
|
|
_c.mutation.SetChannelFeeRate(v)
|
|
}
|
|
if _, ok := _c.mutation.ChannelFee(); !ok {
|
|
v := payorder.DefaultChannelFee
|
|
_c.mutation.SetChannelFee(v)
|
|
}
|
|
if _, ok := _c.mutation.OrderStatus(); !ok {
|
|
v := payorder.DefaultOrderStatus
|
|
_c.mutation.SetOrderStatus(v)
|
|
}
|
|
if _, ok := _c.mutation.Currency(); !ok {
|
|
v := payorder.DefaultCurrency
|
|
_c.mutation.SetCurrency(v)
|
|
}
|
|
if _, ok := _c.mutation.RefundPrice(); !ok {
|
|
v := payorder.DefaultRefundPrice
|
|
_c.mutation.SetRefundPrice(v)
|
|
}
|
|
}
|
|
|
|
// check runs all checks and user-defined validators on the builder.
|
|
func (_c *PayOrderCreate) check() error {
|
|
if _, ok := _c.mutation.CreatedAt(); !ok {
|
|
return &ValidationError{Name: "created_at", err: errors.New(`ent: missing required field "PayOrder.created_at"`)}
|
|
}
|
|
if _, ok := _c.mutation.UpdatedAt(); !ok {
|
|
return &ValidationError{Name: "updated_at", err: errors.New(`ent: missing required field "PayOrder.updated_at"`)}
|
|
}
|
|
if _, ok := _c.mutation.TenantID(); !ok {
|
|
return &ValidationError{Name: "tenant_id", err: errors.New(`ent: missing required field "PayOrder.tenant_id"`)}
|
|
}
|
|
if _, ok := _c.mutation.ChannelID(); !ok {
|
|
return &ValidationError{Name: "channel_id", err: errors.New(`ent: missing required field "PayOrder.channel_id"`)}
|
|
}
|
|
if _, ok := _c.mutation.UserID(); !ok {
|
|
return &ValidationError{Name: "user_id", err: errors.New(`ent: missing required field "PayOrder.user_id"`)}
|
|
}
|
|
if _, ok := _c.mutation.Subject(); !ok {
|
|
return &ValidationError{Name: "subject", err: errors.New(`ent: missing required field "PayOrder.subject"`)}
|
|
}
|
|
if _, ok := _c.mutation.Body(); !ok {
|
|
return &ValidationError{Name: "body", err: errors.New(`ent: missing required field "PayOrder.body"`)}
|
|
}
|
|
if _, ok := _c.mutation.NotifyURL(); !ok {
|
|
return &ValidationError{Name: "notify_url", err: errors.New(`ent: missing required field "PayOrder.notify_url"`)}
|
|
}
|
|
if _, ok := _c.mutation.Amount(); !ok {
|
|
return &ValidationError{Name: "amount", err: errors.New(`ent: missing required field "PayOrder.amount"`)}
|
|
}
|
|
if _, ok := _c.mutation.ChannelFeeRate(); !ok {
|
|
return &ValidationError{Name: "channel_fee_rate", err: errors.New(`ent: missing required field "PayOrder.channel_fee_rate"`)}
|
|
}
|
|
if _, ok := _c.mutation.ChannelFee(); !ok {
|
|
return &ValidationError{Name: "channel_fee", err: errors.New(`ent: missing required field "PayOrder.channel_fee"`)}
|
|
}
|
|
if _, ok := _c.mutation.OrderStatus(); !ok {
|
|
return &ValidationError{Name: "order_status", err: errors.New(`ent: missing required field "PayOrder.order_status"`)}
|
|
}
|
|
if _, ok := _c.mutation.ExpireTime(); !ok {
|
|
return &ValidationError{Name: "expire_time", err: errors.New(`ent: missing required field "PayOrder.expire_time"`)}
|
|
}
|
|
if _, ok := _c.mutation.PayNo(); !ok {
|
|
return &ValidationError{Name: "pay_no", err: errors.New(`ent: missing required field "PayOrder.pay_no"`)}
|
|
}
|
|
if _, ok := _c.mutation.SuccessTime(); !ok {
|
|
return &ValidationError{Name: "success_time", err: errors.New(`ent: missing required field "PayOrder.success_time"`)}
|
|
}
|
|
if _, ok := _c.mutation.Currency(); !ok {
|
|
return &ValidationError{Name: "currency", err: errors.New(`ent: missing required field "PayOrder.currency"`)}
|
|
}
|
|
if _, ok := _c.mutation.RefundPrice(); !ok {
|
|
return &ValidationError{Name: "refund_price", err: errors.New(`ent: missing required field "PayOrder.refund_price"`)}
|
|
}
|
|
if len(_c.mutation.ChannelIDs()) == 0 {
|
|
return &ValidationError{Name: "channel", err: errors.New(`ent: missing required edge "PayOrder.channel"`)}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (_c *PayOrderCreate) sqlSave(ctx context.Context) (*PayOrder, error) {
|
|
if err := _c.check(); err != nil {
|
|
return nil, err
|
|
}
|
|
_node, _spec := _c.createSpec()
|
|
if err := sqlgraph.CreateNode(ctx, _c.driver, _spec); err != nil {
|
|
if sqlgraph.IsConstraintError(err) {
|
|
err = &ConstraintError{msg: err.Error(), wrap: err}
|
|
}
|
|
return nil, err
|
|
}
|
|
if _spec.ID.Value != _node.ID {
|
|
id := _spec.ID.Value.(int64)
|
|
_node.ID = uint64(id)
|
|
}
|
|
_c.mutation.id = &_node.ID
|
|
_c.mutation.done = true
|
|
return _node, nil
|
|
}
|
|
|
|
func (_c *PayOrderCreate) createSpec() (*PayOrder, *sqlgraph.CreateSpec) {
|
|
var (
|
|
_node = &PayOrder{config: _c.config}
|
|
_spec = sqlgraph.NewCreateSpec(payorder.Table, sqlgraph.NewFieldSpec(payorder.FieldID, field.TypeUint64))
|
|
)
|
|
if id, ok := _c.mutation.ID(); ok {
|
|
_node.ID = id
|
|
_spec.ID.Value = id
|
|
}
|
|
if value, ok := _c.mutation.CreatedAt(); ok {
|
|
_spec.SetField(payorder.FieldCreatedAt, field.TypeTime, value)
|
|
_node.CreatedAt = value
|
|
}
|
|
if value, ok := _c.mutation.UpdatedAt(); ok {
|
|
_spec.SetField(payorder.FieldUpdatedAt, field.TypeTime, value)
|
|
_node.UpdatedAt = value
|
|
}
|
|
if value, ok := _c.mutation.Status(); ok {
|
|
_spec.SetField(payorder.FieldStatus, field.TypeUint8, value)
|
|
_node.Status = value
|
|
}
|
|
if value, ok := _c.mutation.TenantID(); ok {
|
|
_spec.SetField(payorder.FieldTenantID, field.TypeUint64, value)
|
|
_node.TenantID = value
|
|
}
|
|
if value, ok := _c.mutation.DeletedAt(); ok {
|
|
_spec.SetField(payorder.FieldDeletedAt, field.TypeTime, value)
|
|
_node.DeletedAt = value
|
|
}
|
|
if value, ok := _c.mutation.UserID(); ok {
|
|
_spec.SetField(payorder.FieldUserID, field.TypeUint64, value)
|
|
_node.UserID = value
|
|
}
|
|
if value, ok := _c.mutation.Subject(); ok {
|
|
_spec.SetField(payorder.FieldSubject, field.TypeString, value)
|
|
_node.Subject = value
|
|
}
|
|
if value, ok := _c.mutation.Body(); ok {
|
|
_spec.SetField(payorder.FieldBody, field.TypeString, value)
|
|
_node.Body = value
|
|
}
|
|
if value, ok := _c.mutation.NotifyURL(); ok {
|
|
_spec.SetField(payorder.FieldNotifyURL, field.TypeString, value)
|
|
_node.NotifyURL = value
|
|
}
|
|
if value, ok := _c.mutation.Amount(); ok {
|
|
_spec.SetField(payorder.FieldAmount, field.TypeUint64, value)
|
|
_node.Amount = value
|
|
}
|
|
if value, ok := _c.mutation.PaySource(); ok {
|
|
_spec.SetField(payorder.FieldPaySource, field.TypeString, value)
|
|
_node.PaySource = value
|
|
}
|
|
if value, ok := _c.mutation.ChannelFeeRate(); ok {
|
|
_spec.SetField(payorder.FieldChannelFeeRate, field.TypeString, value)
|
|
_node.ChannelFeeRate = value
|
|
}
|
|
if value, ok := _c.mutation.ChannelFee(); ok {
|
|
_spec.SetField(payorder.FieldChannelFee, field.TypeUint64, value)
|
|
_node.ChannelFee = value
|
|
}
|
|
if value, ok := _c.mutation.OrderStatus(); ok {
|
|
_spec.SetField(payorder.FieldOrderStatus, field.TypeString, value)
|
|
_node.OrderStatus = value
|
|
}
|
|
if value, ok := _c.mutation.UserIP(); ok {
|
|
_spec.SetField(payorder.FieldUserIP, field.TypeString, value)
|
|
_node.UserIP = value
|
|
}
|
|
if value, ok := _c.mutation.ExpireTime(); ok {
|
|
_spec.SetField(payorder.FieldExpireTime, field.TypeTime, value)
|
|
_node.ExpireTime = value
|
|
}
|
|
if value, ok := _c.mutation.PayNo(); ok {
|
|
_spec.SetField(payorder.FieldPayNo, field.TypeString, value)
|
|
_node.PayNo = value
|
|
}
|
|
if value, ok := _c.mutation.SuccessTime(); ok {
|
|
_spec.SetField(payorder.FieldSuccessTime, field.TypeTime, value)
|
|
_node.SuccessTime = value
|
|
}
|
|
if value, ok := _c.mutation.ExtensionID(); ok {
|
|
_spec.SetField(payorder.FieldExtensionID, field.TypeUint64, value)
|
|
_node.ExtensionID = value
|
|
}
|
|
if value, ok := _c.mutation.TransactionID(); ok {
|
|
_spec.SetField(payorder.FieldTransactionID, field.TypeString, value)
|
|
_node.TransactionID = value
|
|
}
|
|
if value, ok := _c.mutation.Currency(); ok {
|
|
_spec.SetField(payorder.FieldCurrency, field.TypeString, value)
|
|
_node.Currency = value
|
|
}
|
|
if value, ok := _c.mutation.RefundPrice(); ok {
|
|
_spec.SetField(payorder.FieldRefundPrice, field.TypeUint64, value)
|
|
_node.RefundPrice = value
|
|
}
|
|
if value, ok := _c.mutation.ChannelOrderNo(); ok {
|
|
_spec.SetField(payorder.FieldChannelOrderNo, field.TypeString, value)
|
|
_node.ChannelOrderNo = value
|
|
}
|
|
if value, ok := _c.mutation.ChannelUserID(); ok {
|
|
_spec.SetField(payorder.FieldChannelUserID, field.TypeString, value)
|
|
_node.ChannelUserID = value
|
|
}
|
|
if nodes := _c.mutation.ChannelIDs(); len(nodes) > 0 {
|
|
edge := &sqlgraph.EdgeSpec{
|
|
Rel: sqlgraph.M2O,
|
|
Inverse: false,
|
|
Table: payorder.ChannelTable,
|
|
Columns: []string{payorder.ChannelColumn},
|
|
Bidi: false,
|
|
Target: &sqlgraph.EdgeTarget{
|
|
IDSpec: sqlgraph.NewFieldSpec(paychannel.FieldID, field.TypeUint64),
|
|
},
|
|
}
|
|
for _, k := range nodes {
|
|
edge.Target.Nodes = append(edge.Target.Nodes, k)
|
|
}
|
|
_node.ChannelID = nodes[0]
|
|
_spec.Edges = append(_spec.Edges, edge)
|
|
}
|
|
if nodes := _c.mutation.OrdersExtensionIDs(); len(nodes) > 0 {
|
|
edge := &sqlgraph.EdgeSpec{
|
|
Rel: sqlgraph.O2M,
|
|
Inverse: true,
|
|
Table: payorder.OrdersExtensionTable,
|
|
Columns: []string{payorder.OrdersExtensionColumn},
|
|
Bidi: false,
|
|
Target: &sqlgraph.EdgeTarget{
|
|
IDSpec: sqlgraph.NewFieldSpec(payorderextension.FieldID, field.TypeUint64),
|
|
},
|
|
}
|
|
for _, k := range nodes {
|
|
edge.Target.Nodes = append(edge.Target.Nodes, k)
|
|
}
|
|
_spec.Edges = append(_spec.Edges, edge)
|
|
}
|
|
if nodes := _c.mutation.NotifyTaskIDs(); len(nodes) > 0 {
|
|
edge := &sqlgraph.EdgeSpec{
|
|
Rel: sqlgraph.O2M,
|
|
Inverse: true,
|
|
Table: payorder.NotifyTaskTable,
|
|
Columns: []string{payorder.NotifyTaskColumn},
|
|
Bidi: false,
|
|
Target: &sqlgraph.EdgeTarget{
|
|
IDSpec: sqlgraph.NewFieldSpec(paynotifytask.FieldID, field.TypeUint64),
|
|
},
|
|
}
|
|
for _, k := range nodes {
|
|
edge.Target.Nodes = append(edge.Target.Nodes, k)
|
|
}
|
|
_spec.Edges = append(_spec.Edges, edge)
|
|
}
|
|
if nodes := _c.mutation.RefundIDs(); len(nodes) > 0 {
|
|
edge := &sqlgraph.EdgeSpec{
|
|
Rel: sqlgraph.O2M,
|
|
Inverse: true,
|
|
Table: payorder.RefundTable,
|
|
Columns: []string{payorder.RefundColumn},
|
|
Bidi: false,
|
|
Target: &sqlgraph.EdgeTarget{
|
|
IDSpec: sqlgraph.NewFieldSpec(payrefund.FieldID, field.TypeUint64),
|
|
},
|
|
}
|
|
for _, k := range nodes {
|
|
edge.Target.Nodes = append(edge.Target.Nodes, k)
|
|
}
|
|
_spec.Edges = append(_spec.Edges, edge)
|
|
}
|
|
return _node, _spec
|
|
}
|
|
|
|
// PayOrderCreateBulk is the builder for creating many PayOrder entities in bulk.
|
|
type PayOrderCreateBulk struct {
|
|
config
|
|
err error
|
|
builders []*PayOrderCreate
|
|
}
|
|
|
|
// Save creates the PayOrder entities in the database.
|
|
func (_c *PayOrderCreateBulk) Save(ctx context.Context) ([]*PayOrder, error) {
|
|
if _c.err != nil {
|
|
return nil, _c.err
|
|
}
|
|
specs := make([]*sqlgraph.CreateSpec, len(_c.builders))
|
|
nodes := make([]*PayOrder, len(_c.builders))
|
|
mutators := make([]Mutator, len(_c.builders))
|
|
for i := range _c.builders {
|
|
func(i int, root context.Context) {
|
|
builder := _c.builders[i]
|
|
builder.defaults()
|
|
var mut Mutator = MutateFunc(func(ctx context.Context, m Mutation) (Value, error) {
|
|
mutation, ok := m.(*PayOrderMutation)
|
|
if !ok {
|
|
return nil, fmt.Errorf("unexpected mutation type %T", m)
|
|
}
|
|
if err := builder.check(); err != nil {
|
|
return nil, err
|
|
}
|
|
builder.mutation = mutation
|
|
var err error
|
|
nodes[i], specs[i] = builder.createSpec()
|
|
if i < len(mutators)-1 {
|
|
_, err = mutators[i+1].Mutate(root, _c.builders[i+1].mutation)
|
|
} else {
|
|
spec := &sqlgraph.BatchCreateSpec{Nodes: specs}
|
|
// Invoke the actual operation on the latest mutation in the chain.
|
|
if err = sqlgraph.BatchCreate(ctx, _c.driver, spec); err != nil {
|
|
if sqlgraph.IsConstraintError(err) {
|
|
err = &ConstraintError{msg: err.Error(), wrap: err}
|
|
}
|
|
}
|
|
}
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
mutation.id = &nodes[i].ID
|
|
if specs[i].ID.Value != nil && nodes[i].ID == 0 {
|
|
id := specs[i].ID.Value.(int64)
|
|
nodes[i].ID = uint64(id)
|
|
}
|
|
mutation.done = true
|
|
return nodes[i], nil
|
|
})
|
|
for i := len(builder.hooks) - 1; i >= 0; i-- {
|
|
mut = builder.hooks[i](mut)
|
|
}
|
|
mutators[i] = mut
|
|
}(i, ctx)
|
|
}
|
|
if len(mutators) > 0 {
|
|
if _, err := mutators[0].Mutate(ctx, _c.builders[0].mutation); err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
return nodes, nil
|
|
}
|
|
|
|
// SaveX is like Save, but panics if an error occurs.
|
|
func (_c *PayOrderCreateBulk) SaveX(ctx context.Context) []*PayOrder {
|
|
v, err := _c.Save(ctx)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
return v
|
|
}
|
|
|
|
// Exec executes the query.
|
|
func (_c *PayOrderCreateBulk) Exec(ctx context.Context) error {
|
|
_, err := _c.Save(ctx)
|
|
return err
|
|
}
|
|
|
|
// ExecX is like Exec, but panics if an error occurs.
|
|
func (_c *PayOrderCreateBulk) ExecX(ctx context.Context) {
|
|
if err := _c.Exec(ctx); err != nil {
|
|
panic(err)
|
|
}
|
|
}
|