mingyang-admin-pay/rpc/ent/payorder_create.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)
}
}