Compare commits
No commits in common. "1a62986a5d7b028ce2746ce62a241f815f0c8437" and "d150e95f196ad2fac23307f17b2498243b57f89f" have entirely different histories.
1a62986a5d
...
d150e95f19
1052
api/cast/cast.pb.go
1052
api/cast/cast.pb.go
File diff suppressed because it is too large
Load Diff
@ -2447,22 +2447,6 @@ func (m *WorkListReq) validate(all bool) error {
|
|||||||
|
|
||||||
// no validation rules for DmStatus
|
// no validation rules for DmStatus
|
||||||
|
|
||||||
// no validation rules for StartTime1
|
|
||||||
|
|
||||||
// no validation rules for EndTime1
|
|
||||||
|
|
||||||
// no validation rules for StartTime4
|
|
||||||
|
|
||||||
// no validation rules for EndTime4
|
|
||||||
|
|
||||||
// no validation rules for StartTime9
|
|
||||||
|
|
||||||
// no validation rules for EndTime9
|
|
||||||
|
|
||||||
// no validation rules for StartTime6
|
|
||||||
|
|
||||||
// no validation rules for EndTime6
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
if len(errors) > 0 {
|
||||||
return WorkListReqMultiError(errors)
|
return WorkListReqMultiError(errors)
|
||||||
}
|
}
|
||||||
@ -18755,926 +18739,6 @@ var _ interface {
|
|||||||
ErrorName() string
|
ErrorName() string
|
||||||
} = ListWorkMetricsDailyRespValidationError{}
|
} = ListWorkMetricsDailyRespValidationError{}
|
||||||
|
|
||||||
// Validate checks the field values on UpsertTaskListReq with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// first error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *UpsertTaskListReq) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on UpsertTaskListReq with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the result is a list of violation errors wrapped in
|
|
||||||
// UpsertTaskListReqMultiError, or nil if none found.
|
|
||||||
func (m *UpsertTaskListReq) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *UpsertTaskListReq) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
// no validation rules for Uuid
|
|
||||||
|
|
||||||
// no validation rules for Action
|
|
||||||
|
|
||||||
// no validation rules for Url
|
|
||||||
|
|
||||||
// no validation rules for Status
|
|
||||||
|
|
||||||
// no validation rules for OperatorID
|
|
||||||
|
|
||||||
// no validation rules for OperatorName
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return UpsertTaskListReqMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// UpsertTaskListReqMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by UpsertTaskListReq.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type UpsertTaskListReqMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m UpsertTaskListReqMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m UpsertTaskListReqMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// UpsertTaskListReqValidationError is the validation error returned by
|
|
||||||
// UpsertTaskListReq.Validate if the designated constraints aren't met.
|
|
||||||
type UpsertTaskListReqValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e UpsertTaskListReqValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e UpsertTaskListReqValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e UpsertTaskListReqValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e UpsertTaskListReqValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e UpsertTaskListReqValidationError) ErrorName() string {
|
|
||||||
return "UpsertTaskListReqValidationError"
|
|
||||||
}
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e UpsertTaskListReqValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sUpsertTaskListReq.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = UpsertTaskListReqValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = UpsertTaskListReqValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on UpsertTaskListResp with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the first error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *UpsertTaskListResp) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on UpsertTaskListResp with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the result is a list of violation errors wrapped in
|
|
||||||
// UpsertTaskListRespMultiError, or nil if none found.
|
|
||||||
func (m *UpsertTaskListResp) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *UpsertTaskListResp) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
// no validation rules for Uuid
|
|
||||||
|
|
||||||
// no validation rules for Msg
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return UpsertTaskListRespMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// UpsertTaskListRespMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by UpsertTaskListResp.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type UpsertTaskListRespMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m UpsertTaskListRespMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m UpsertTaskListRespMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// UpsertTaskListRespValidationError is the validation error returned by
|
|
||||||
// UpsertTaskListResp.Validate if the designated constraints aren't met.
|
|
||||||
type UpsertTaskListRespValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e UpsertTaskListRespValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e UpsertTaskListRespValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e UpsertTaskListRespValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e UpsertTaskListRespValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e UpsertTaskListRespValidationError) ErrorName() string {
|
|
||||||
return "UpsertTaskListRespValidationError"
|
|
||||||
}
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e UpsertTaskListRespValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sUpsertTaskListResp.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = UpsertTaskListRespValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = UpsertTaskListRespValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on GetTaskListReq with the rules defined in
|
|
||||||
// the proto definition for this message. If any rules are violated, the first
|
|
||||||
// error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *GetTaskListReq) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on GetTaskListReq with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// result is a list of violation errors wrapped in GetTaskListReqMultiError,
|
|
||||||
// or nil if none found.
|
|
||||||
func (m *GetTaskListReq) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *GetTaskListReq) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
// no validation rules for Uuid
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return GetTaskListReqMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetTaskListReqMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by GetTaskListReq.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type GetTaskListReqMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m GetTaskListReqMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m GetTaskListReqMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// GetTaskListReqValidationError is the validation error returned by
|
|
||||||
// GetTaskListReq.Validate if the designated constraints aren't met.
|
|
||||||
type GetTaskListReqValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e GetTaskListReqValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e GetTaskListReqValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e GetTaskListReqValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e GetTaskListReqValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e GetTaskListReqValidationError) ErrorName() string { return "GetTaskListReqValidationError" }
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e GetTaskListReqValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sGetTaskListReq.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = GetTaskListReqValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = GetTaskListReqValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on TaskListInfo with the rules defined in
|
|
||||||
// the proto definition for this message. If any rules are violated, the first
|
|
||||||
// error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *TaskListInfo) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on TaskListInfo with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// result is a list of violation errors wrapped in TaskListInfoMultiError, or
|
|
||||||
// nil if none found.
|
|
||||||
func (m *TaskListInfo) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *TaskListInfo) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
// no validation rules for Uuid
|
|
||||||
|
|
||||||
// no validation rules for Action
|
|
||||||
|
|
||||||
// no validation rules for Url
|
|
||||||
|
|
||||||
// no validation rules for Status
|
|
||||||
|
|
||||||
// no validation rules for OperatorID
|
|
||||||
|
|
||||||
// no validation rules for OperatorName
|
|
||||||
|
|
||||||
// no validation rules for CreatedAt
|
|
||||||
|
|
||||||
// no validation rules for UpdatedAt
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return TaskListInfoMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// TaskListInfoMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by TaskListInfo.ValidateAll() if the designated constraints aren't met.
|
|
||||||
type TaskListInfoMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m TaskListInfoMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m TaskListInfoMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// TaskListInfoValidationError is the validation error returned by
|
|
||||||
// TaskListInfo.Validate if the designated constraints aren't met.
|
|
||||||
type TaskListInfoValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e TaskListInfoValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e TaskListInfoValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e TaskListInfoValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e TaskListInfoValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e TaskListInfoValidationError) ErrorName() string { return "TaskListInfoValidationError" }
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e TaskListInfoValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sTaskListInfo.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = TaskListInfoValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = TaskListInfoValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on GetTaskListResp with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// first error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *GetTaskListResp) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on GetTaskListResp with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the result is a list of violation errors wrapped in
|
|
||||||
// GetTaskListRespMultiError, or nil if none found.
|
|
||||||
func (m *GetTaskListResp) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *GetTaskListResp) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
if all {
|
|
||||||
switch v := interface{}(m.GetData()).(type) {
|
|
||||||
case interface{ ValidateAll() error }:
|
|
||||||
if err := v.ValidateAll(); err != nil {
|
|
||||||
errors = append(errors, GetTaskListRespValidationError{
|
|
||||||
field: "Data",
|
|
||||||
reason: "embedded message failed validation",
|
|
||||||
cause: err,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
case interface{ Validate() error }:
|
|
||||||
if err := v.Validate(); err != nil {
|
|
||||||
errors = append(errors, GetTaskListRespValidationError{
|
|
||||||
field: "Data",
|
|
||||||
reason: "embedded message failed validation",
|
|
||||||
cause: err,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else if v, ok := interface{}(m.GetData()).(interface{ Validate() error }); ok {
|
|
||||||
if err := v.Validate(); err != nil {
|
|
||||||
return GetTaskListRespValidationError{
|
|
||||||
field: "Data",
|
|
||||||
reason: "embedded message failed validation",
|
|
||||||
cause: err,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// no validation rules for Msg
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return GetTaskListRespMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// GetTaskListRespMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by GetTaskListResp.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type GetTaskListRespMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m GetTaskListRespMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m GetTaskListRespMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// GetTaskListRespValidationError is the validation error returned by
|
|
||||||
// GetTaskListResp.Validate if the designated constraints aren't met.
|
|
||||||
type GetTaskListRespValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e GetTaskListRespValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e GetTaskListRespValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e GetTaskListRespValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e GetTaskListRespValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e GetTaskListRespValidationError) ErrorName() string { return "GetTaskListRespValidationError" }
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e GetTaskListRespValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sGetTaskListResp.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = GetTaskListRespValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = GetTaskListRespValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on ListTaskListReq with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// first error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *ListTaskListReq) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on ListTaskListReq with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the result is a list of violation errors wrapped in
|
|
||||||
// ListTaskListReqMultiError, or nil if none found.
|
|
||||||
func (m *ListTaskListReq) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *ListTaskListReq) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
// no validation rules for Action
|
|
||||||
|
|
||||||
// no validation rules for Status
|
|
||||||
|
|
||||||
// no validation rules for OperatorID
|
|
||||||
|
|
||||||
// no validation rules for Page
|
|
||||||
|
|
||||||
// no validation rules for PageSize
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return ListTaskListReqMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// ListTaskListReqMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by ListTaskListReq.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type ListTaskListReqMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m ListTaskListReqMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m ListTaskListReqMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// ListTaskListReqValidationError is the validation error returned by
|
|
||||||
// ListTaskListReq.Validate if the designated constraints aren't met.
|
|
||||||
type ListTaskListReqValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e ListTaskListReqValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e ListTaskListReqValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e ListTaskListReqValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e ListTaskListReqValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e ListTaskListReqValidationError) ErrorName() string { return "ListTaskListReqValidationError" }
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e ListTaskListReqValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sListTaskListReq.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = ListTaskListReqValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = ListTaskListReqValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on ListTaskListResp with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// first error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *ListTaskListResp) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on ListTaskListResp with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the result is a list of violation errors wrapped in
|
|
||||||
// ListTaskListRespMultiError, or nil if none found.
|
|
||||||
func (m *ListTaskListResp) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *ListTaskListResp) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
for idx, item := range m.GetData() {
|
|
||||||
_, _ = idx, item
|
|
||||||
|
|
||||||
if all {
|
|
||||||
switch v := interface{}(item).(type) {
|
|
||||||
case interface{ ValidateAll() error }:
|
|
||||||
if err := v.ValidateAll(); err != nil {
|
|
||||||
errors = append(errors, ListTaskListRespValidationError{
|
|
||||||
field: fmt.Sprintf("Data[%v]", idx),
|
|
||||||
reason: "embedded message failed validation",
|
|
||||||
cause: err,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
case interface{ Validate() error }:
|
|
||||||
if err := v.Validate(); err != nil {
|
|
||||||
errors = append(errors, ListTaskListRespValidationError{
|
|
||||||
field: fmt.Sprintf("Data[%v]", idx),
|
|
||||||
reason: "embedded message failed validation",
|
|
||||||
cause: err,
|
|
||||||
})
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else if v, ok := interface{}(item).(interface{ Validate() error }); ok {
|
|
||||||
if err := v.Validate(); err != nil {
|
|
||||||
return ListTaskListRespValidationError{
|
|
||||||
field: fmt.Sprintf("Data[%v]", idx),
|
|
||||||
reason: "embedded message failed validation",
|
|
||||||
cause: err,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// no validation rules for Count
|
|
||||||
|
|
||||||
// no validation rules for Msg
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return ListTaskListRespMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// ListTaskListRespMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by ListTaskListResp.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type ListTaskListRespMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m ListTaskListRespMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m ListTaskListRespMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// ListTaskListRespValidationError is the validation error returned by
|
|
||||||
// ListTaskListResp.Validate if the designated constraints aren't met.
|
|
||||||
type ListTaskListRespValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e ListTaskListRespValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e ListTaskListRespValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e ListTaskListRespValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e ListTaskListRespValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e ListTaskListRespValidationError) ErrorName() string { return "ListTaskListRespValidationError" }
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e ListTaskListRespValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sListTaskListResp.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = ListTaskListRespValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = ListTaskListRespValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on DeleteTaskListReq with the rules defined
|
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
|
||||||
// first error encountered is returned, or nil if there are no violations.
|
|
||||||
func (m *DeleteTaskListReq) Validate() error {
|
|
||||||
return m.validate(false)
|
|
||||||
}
|
|
||||||
|
|
||||||
// ValidateAll checks the field values on DeleteTaskListReq with the rules
|
|
||||||
// defined in the proto definition for this message. If any rules are
|
|
||||||
// violated, the result is a list of violation errors wrapped in
|
|
||||||
// DeleteTaskListReqMultiError, or nil if none found.
|
|
||||||
func (m *DeleteTaskListReq) ValidateAll() error {
|
|
||||||
return m.validate(true)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *DeleteTaskListReq) validate(all bool) error {
|
|
||||||
if m == nil {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
var errors []error
|
|
||||||
|
|
||||||
// no validation rules for Uuid
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
|
||||||
return DeleteTaskListReqMultiError(errors)
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// DeleteTaskListReqMultiError is an error wrapping multiple validation errors
|
|
||||||
// returned by DeleteTaskListReq.ValidateAll() if the designated constraints
|
|
||||||
// aren't met.
|
|
||||||
type DeleteTaskListReqMultiError []error
|
|
||||||
|
|
||||||
// Error returns a concatenation of all the error messages it wraps.
|
|
||||||
func (m DeleteTaskListReqMultiError) Error() string {
|
|
||||||
msgs := make([]string, 0, len(m))
|
|
||||||
for _, err := range m {
|
|
||||||
msgs = append(msgs, err.Error())
|
|
||||||
}
|
|
||||||
return strings.Join(msgs, "; ")
|
|
||||||
}
|
|
||||||
|
|
||||||
// AllErrors returns a list of validation violation errors.
|
|
||||||
func (m DeleteTaskListReqMultiError) AllErrors() []error { return m }
|
|
||||||
|
|
||||||
// DeleteTaskListReqValidationError is the validation error returned by
|
|
||||||
// DeleteTaskListReq.Validate if the designated constraints aren't met.
|
|
||||||
type DeleteTaskListReqValidationError struct {
|
|
||||||
field string
|
|
||||||
reason string
|
|
||||||
cause error
|
|
||||||
key bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// Field function returns field value.
|
|
||||||
func (e DeleteTaskListReqValidationError) Field() string { return e.field }
|
|
||||||
|
|
||||||
// Reason function returns reason value.
|
|
||||||
func (e DeleteTaskListReqValidationError) Reason() string { return e.reason }
|
|
||||||
|
|
||||||
// Cause function returns cause value.
|
|
||||||
func (e DeleteTaskListReqValidationError) Cause() error { return e.cause }
|
|
||||||
|
|
||||||
// Key function returns key value.
|
|
||||||
func (e DeleteTaskListReqValidationError) Key() bool { return e.key }
|
|
||||||
|
|
||||||
// ErrorName returns error name.
|
|
||||||
func (e DeleteTaskListReqValidationError) ErrorName() string {
|
|
||||||
return "DeleteTaskListReqValidationError"
|
|
||||||
}
|
|
||||||
|
|
||||||
// Error satisfies the builtin error interface
|
|
||||||
func (e DeleteTaskListReqValidationError) Error() string {
|
|
||||||
cause := ""
|
|
||||||
if e.cause != nil {
|
|
||||||
cause = fmt.Sprintf(" | caused by: %v", e.cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
key := ""
|
|
||||||
if e.key {
|
|
||||||
key = "key for "
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf(
|
|
||||||
"invalid %sDeleteTaskListReq.%s: %s%s",
|
|
||||||
key,
|
|
||||||
e.field,
|
|
||||||
e.reason,
|
|
||||||
cause)
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ error = DeleteTaskListReqValidationError{}
|
|
||||||
|
|
||||||
var _ interface {
|
|
||||||
Field() string
|
|
||||||
Reason() string
|
|
||||||
Key() bool
|
|
||||||
Cause() error
|
|
||||||
ErrorName() string
|
|
||||||
} = DeleteTaskListReqValidationError{}
|
|
||||||
|
|
||||||
// Validate checks the field values on WorkListResp_Info with the rules defined
|
// Validate checks the field values on WorkListResp_Info with the rules defined
|
||||||
// in the proto definition for this message. If any rules are violated, the
|
// in the proto definition for this message. If any rules are violated, the
|
||||||
// first error encountered is returned, or nil if there are no violations.
|
// first error encountered is returned, or nil if there are no violations.
|
||||||
@ -19733,14 +18797,6 @@ func (m *WorkListResp_Info) validate(all bool) error {
|
|||||||
|
|
||||||
// no validation rules for Remark
|
// no validation rules for Remark
|
||||||
|
|
||||||
// no validation rules for Status1Time
|
|
||||||
|
|
||||||
// no validation rules for Status4Time
|
|
||||||
|
|
||||||
// no validation rules for Status9Time
|
|
||||||
|
|
||||||
// no validation rules for Status6Time
|
|
||||||
|
|
||||||
if len(errors) > 0 {
|
if len(errors) > 0 {
|
||||||
return WorkListResp_InfoMultiError(errors)
|
return WorkListResp_InfoMultiError(errors)
|
||||||
}
|
}
|
||||||
|
|||||||
@ -104,11 +104,6 @@ type CastClient interface {
|
|||||||
GetArtistAyrShareInfo(ctx context.Context, in *GetArtistAyrShareInfoReq, opts ...grpc_go.CallOption) (*GetArtistAyrShareInfoResp, common.ErrorWithAttachment)
|
GetArtistAyrShareInfo(ctx context.Context, in *GetArtistAyrShareInfoReq, opts ...grpc_go.CallOption) (*GetArtistAyrShareInfoResp, common.ErrorWithAttachment)
|
||||||
// 作品平台信息相关接口
|
// 作品平台信息相关接口
|
||||||
ListWorkPlatformInfo(ctx context.Context, in *ListWorkPlatformInfoReq, opts ...grpc_go.CallOption) (*ListWorkPlatformInfoResp, common.ErrorWithAttachment)
|
ListWorkPlatformInfo(ctx context.Context, in *ListWorkPlatformInfoReq, opts ...grpc_go.CallOption) (*ListWorkPlatformInfoResp, common.ErrorWithAttachment)
|
||||||
// 任务列表相关接口
|
|
||||||
UpsertTaskList(ctx context.Context, in *UpsertTaskListReq, opts ...grpc_go.CallOption) (*UpsertTaskListResp, common.ErrorWithAttachment)
|
|
||||||
GetTaskList(ctx context.Context, in *GetTaskListReq, opts ...grpc_go.CallOption) (*GetTaskListResp, common.ErrorWithAttachment)
|
|
||||||
ListTaskList(ctx context.Context, in *ListTaskListReq, opts ...grpc_go.CallOption) (*ListTaskListResp, common.ErrorWithAttachment)
|
|
||||||
DeleteTaskList(ctx context.Context, in *DeleteTaskListReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
type castClient struct {
|
type castClient struct {
|
||||||
@ -180,10 +175,6 @@ type CastClientImpl struct {
|
|||||||
ListWorkMetricsDaily func(ctx context.Context, in *ListWorkMetricsDailyReq) (*ListWorkMetricsDailyResp, error)
|
ListWorkMetricsDaily func(ctx context.Context, in *ListWorkMetricsDailyReq) (*ListWorkMetricsDailyResp, error)
|
||||||
GetArtistAyrShareInfo func(ctx context.Context, in *GetArtistAyrShareInfoReq) (*GetArtistAyrShareInfoResp, error)
|
GetArtistAyrShareInfo func(ctx context.Context, in *GetArtistAyrShareInfoReq) (*GetArtistAyrShareInfoResp, error)
|
||||||
ListWorkPlatformInfo func(ctx context.Context, in *ListWorkPlatformInfoReq) (*ListWorkPlatformInfoResp, error)
|
ListWorkPlatformInfo func(ctx context.Context, in *ListWorkPlatformInfoReq) (*ListWorkPlatformInfoResp, error)
|
||||||
UpsertTaskList func(ctx context.Context, in *UpsertTaskListReq) (*UpsertTaskListResp, error)
|
|
||||||
GetTaskList func(ctx context.Context, in *GetTaskListReq) (*GetTaskListResp, error)
|
|
||||||
ListTaskList func(ctx context.Context, in *ListTaskListReq) (*ListTaskListResp, error)
|
|
||||||
DeleteTaskList func(ctx context.Context, in *DeleteTaskListReq) (*emptypb.Empty, error)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *CastClientImpl) GetDubboStub(cc *triple.TripleConn) CastClient {
|
func (c *CastClientImpl) GetDubboStub(cc *triple.TripleConn) CastClient {
|
||||||
@ -582,30 +573,6 @@ func (c *castClient) ListWorkPlatformInfo(ctx context.Context, in *ListWorkPlatf
|
|||||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ListWorkPlatformInfo", in, out)
|
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ListWorkPlatformInfo", in, out)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *castClient) UpsertTaskList(ctx context.Context, in *UpsertTaskListReq, opts ...grpc_go.CallOption) (*UpsertTaskListResp, common.ErrorWithAttachment) {
|
|
||||||
out := new(UpsertTaskListResp)
|
|
||||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
|
||||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/UpsertTaskList", in, out)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *castClient) GetTaskList(ctx context.Context, in *GetTaskListReq, opts ...grpc_go.CallOption) (*GetTaskListResp, common.ErrorWithAttachment) {
|
|
||||||
out := new(GetTaskListResp)
|
|
||||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
|
||||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/GetTaskList", in, out)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *castClient) ListTaskList(ctx context.Context, in *ListTaskListReq, opts ...grpc_go.CallOption) (*ListTaskListResp, common.ErrorWithAttachment) {
|
|
||||||
out := new(ListTaskListResp)
|
|
||||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
|
||||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/ListTaskList", in, out)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (c *castClient) DeleteTaskList(ctx context.Context, in *DeleteTaskListReq, opts ...grpc_go.CallOption) (*emptypb.Empty, common.ErrorWithAttachment) {
|
|
||||||
out := new(emptypb.Empty)
|
|
||||||
interfaceKey := ctx.Value(constant.InterfaceKey).(string)
|
|
||||||
return out, c.cc.Invoke(ctx, "/"+interfaceKey+"/DeleteTaskList", in, out)
|
|
||||||
}
|
|
||||||
|
|
||||||
// CastServer is the server API for Cast service.
|
// CastServer is the server API for Cast service.
|
||||||
// All implementations must embed UnimplementedCastServer
|
// All implementations must embed UnimplementedCastServer
|
||||||
// for forward compatibility
|
// for forward compatibility
|
||||||
@ -685,11 +652,6 @@ type CastServer interface {
|
|||||||
GetArtistAyrShareInfo(context.Context, *GetArtistAyrShareInfoReq) (*GetArtistAyrShareInfoResp, error)
|
GetArtistAyrShareInfo(context.Context, *GetArtistAyrShareInfoReq) (*GetArtistAyrShareInfoResp, error)
|
||||||
// 作品平台信息相关接口
|
// 作品平台信息相关接口
|
||||||
ListWorkPlatformInfo(context.Context, *ListWorkPlatformInfoReq) (*ListWorkPlatformInfoResp, error)
|
ListWorkPlatformInfo(context.Context, *ListWorkPlatformInfoReq) (*ListWorkPlatformInfoResp, error)
|
||||||
// 任务列表相关接口
|
|
||||||
UpsertTaskList(context.Context, *UpsertTaskListReq) (*UpsertTaskListResp, error)
|
|
||||||
GetTaskList(context.Context, *GetTaskListReq) (*GetTaskListResp, error)
|
|
||||||
ListTaskList(context.Context, *ListTaskListReq) (*ListTaskListResp, error)
|
|
||||||
DeleteTaskList(context.Context, *DeleteTaskListReq) (*emptypb.Empty, error)
|
|
||||||
mustEmbedUnimplementedCastServer()
|
mustEmbedUnimplementedCastServer()
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -890,18 +852,6 @@ func (UnimplementedCastServer) GetArtistAyrShareInfo(context.Context, *GetArtist
|
|||||||
func (UnimplementedCastServer) ListWorkPlatformInfo(context.Context, *ListWorkPlatformInfoReq) (*ListWorkPlatformInfoResp, error) {
|
func (UnimplementedCastServer) ListWorkPlatformInfo(context.Context, *ListWorkPlatformInfoReq) (*ListWorkPlatformInfoResp, error) {
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method ListWorkPlatformInfo not implemented")
|
return nil, status.Errorf(codes.Unimplemented, "method ListWorkPlatformInfo not implemented")
|
||||||
}
|
}
|
||||||
func (UnimplementedCastServer) UpsertTaskList(context.Context, *UpsertTaskListReq) (*UpsertTaskListResp, error) {
|
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method UpsertTaskList not implemented")
|
|
||||||
}
|
|
||||||
func (UnimplementedCastServer) GetTaskList(context.Context, *GetTaskListReq) (*GetTaskListResp, error) {
|
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method GetTaskList not implemented")
|
|
||||||
}
|
|
||||||
func (UnimplementedCastServer) ListTaskList(context.Context, *ListTaskListReq) (*ListTaskListResp, error) {
|
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method ListTaskList not implemented")
|
|
||||||
}
|
|
||||||
func (UnimplementedCastServer) DeleteTaskList(context.Context, *DeleteTaskListReq) (*emptypb.Empty, error) {
|
|
||||||
return nil, status.Errorf(codes.Unimplemented, "method DeleteTaskList not implemented")
|
|
||||||
}
|
|
||||||
func (s *UnimplementedCastServer) XXX_SetProxyImpl(impl protocol.Invoker) {
|
func (s *UnimplementedCastServer) XXX_SetProxyImpl(impl protocol.Invoker) {
|
||||||
s.proxyImpl = impl
|
s.proxyImpl = impl
|
||||||
}
|
}
|
||||||
@ -2786,122 +2736,6 @@ func _Cast_ListWorkPlatformInfo_Handler(srv interface{}, ctx context.Context, de
|
|||||||
return interceptor(ctx, in, info, handler)
|
return interceptor(ctx, in, info, handler)
|
||||||
}
|
}
|
||||||
|
|
||||||
func _Cast_UpsertTaskList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
|
||||||
in := new(UpsertTaskListReq)
|
|
||||||
if err := dec(in); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
base := srv.(dubbo3.Dubbo3GrpcService)
|
|
||||||
args := []interface{}{}
|
|
||||||
args = append(args, in)
|
|
||||||
md, _ := metadata.FromIncomingContext(ctx)
|
|
||||||
invAttachment := make(map[string]interface{}, len(md))
|
|
||||||
for k, v := range md {
|
|
||||||
invAttachment[k] = v
|
|
||||||
}
|
|
||||||
invo := invocation.NewRPCInvocation("UpsertTaskList", args, invAttachment)
|
|
||||||
if interceptor == nil {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
info := &grpc_go.UnaryServerInfo{
|
|
||||||
Server: srv,
|
|
||||||
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
|
|
||||||
}
|
|
||||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
return interceptor(ctx, in, info, handler)
|
|
||||||
}
|
|
||||||
|
|
||||||
func _Cast_GetTaskList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
|
||||||
in := new(GetTaskListReq)
|
|
||||||
if err := dec(in); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
base := srv.(dubbo3.Dubbo3GrpcService)
|
|
||||||
args := []interface{}{}
|
|
||||||
args = append(args, in)
|
|
||||||
md, _ := metadata.FromIncomingContext(ctx)
|
|
||||||
invAttachment := make(map[string]interface{}, len(md))
|
|
||||||
for k, v := range md {
|
|
||||||
invAttachment[k] = v
|
|
||||||
}
|
|
||||||
invo := invocation.NewRPCInvocation("GetTaskList", args, invAttachment)
|
|
||||||
if interceptor == nil {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
info := &grpc_go.UnaryServerInfo{
|
|
||||||
Server: srv,
|
|
||||||
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
|
|
||||||
}
|
|
||||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
return interceptor(ctx, in, info, handler)
|
|
||||||
}
|
|
||||||
|
|
||||||
func _Cast_ListTaskList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
|
||||||
in := new(ListTaskListReq)
|
|
||||||
if err := dec(in); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
base := srv.(dubbo3.Dubbo3GrpcService)
|
|
||||||
args := []interface{}{}
|
|
||||||
args = append(args, in)
|
|
||||||
md, _ := metadata.FromIncomingContext(ctx)
|
|
||||||
invAttachment := make(map[string]interface{}, len(md))
|
|
||||||
for k, v := range md {
|
|
||||||
invAttachment[k] = v
|
|
||||||
}
|
|
||||||
invo := invocation.NewRPCInvocation("ListTaskList", args, invAttachment)
|
|
||||||
if interceptor == nil {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
info := &grpc_go.UnaryServerInfo{
|
|
||||||
Server: srv,
|
|
||||||
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
|
|
||||||
}
|
|
||||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
return interceptor(ctx, in, info, handler)
|
|
||||||
}
|
|
||||||
|
|
||||||
func _Cast_DeleteTaskList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc_go.UnaryServerInterceptor) (interface{}, error) {
|
|
||||||
in := new(DeleteTaskListReq)
|
|
||||||
if err := dec(in); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
base := srv.(dubbo3.Dubbo3GrpcService)
|
|
||||||
args := []interface{}{}
|
|
||||||
args = append(args, in)
|
|
||||||
md, _ := metadata.FromIncomingContext(ctx)
|
|
||||||
invAttachment := make(map[string]interface{}, len(md))
|
|
||||||
for k, v := range md {
|
|
||||||
invAttachment[k] = v
|
|
||||||
}
|
|
||||||
invo := invocation.NewRPCInvocation("DeleteTaskList", args, invAttachment)
|
|
||||||
if interceptor == nil {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
info := &grpc_go.UnaryServerInfo{
|
|
||||||
Server: srv,
|
|
||||||
FullMethod: ctx.Value("XXX_TRIPLE_GO_INTERFACE_NAME").(string),
|
|
||||||
}
|
|
||||||
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
||||||
result := base.XXX_GetProxyImpl().Invoke(ctx, invo)
|
|
||||||
return result, result.Error()
|
|
||||||
}
|
|
||||||
return interceptor(ctx, in, info, handler)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Cast_ServiceDesc is the grpc_go.ServiceDesc for Cast service.
|
// Cast_ServiceDesc is the grpc_go.ServiceDesc for Cast service.
|
||||||
// It's only intended for direct use with grpc_go.RegisterService,
|
// It's only intended for direct use with grpc_go.RegisterService,
|
||||||
// and not to be introspected or modified (even as a copy)
|
// and not to be introspected or modified (even as a copy)
|
||||||
@ -3165,22 +2999,6 @@ var Cast_ServiceDesc = grpc_go.ServiceDesc{
|
|||||||
MethodName: "ListWorkPlatformInfo",
|
MethodName: "ListWorkPlatformInfo",
|
||||||
Handler: _Cast_ListWorkPlatformInfo_Handler,
|
Handler: _Cast_ListWorkPlatformInfo_Handler,
|
||||||
},
|
},
|
||||||
{
|
|
||||||
MethodName: "UpsertTaskList",
|
|
||||||
Handler: _Cast_UpsertTaskList_Handler,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
MethodName: "GetTaskList",
|
|
||||||
Handler: _Cast_GetTaskList_Handler,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
MethodName: "ListTaskList",
|
|
||||||
Handler: _Cast_ListTaskList_Handler,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
MethodName: "DeleteTaskList",
|
|
||||||
Handler: _Cast_DeleteTaskList_Handler,
|
|
||||||
},
|
|
||||||
},
|
},
|
||||||
Streams: []grpc_go.StreamDesc{},
|
Streams: []grpc_go.StreamDesc{},
|
||||||
Metadata: "pb/fiee/cast.proto",
|
Metadata: "pb/fiee/cast.proto",
|
||||||
|
|||||||
@ -1050,21 +1050,6 @@ func ImportWorkBatch(ctx *gin.Context) {
|
|||||||
req := cast.ImportWorkBatchReq{
|
req := cast.ImportWorkBatchReq{
|
||||||
ImageWorks: make([]*cast.UpdateWorkImageReq, 0),
|
ImageWorks: make([]*cast.UpdateWorkImageReq, 0),
|
||||||
}
|
}
|
||||||
urlHost := config.AppConfig.System.FieeHost
|
|
||||||
var urlResult string
|
|
||||||
urlResult = fmt.Sprintf("%s/api/fiee/static/work/%s", urlHost, fileName)
|
|
||||||
taskResp, err := service.CastProvider.UpsertTaskList(context.Background(), &cast.UpsertTaskListReq{
|
|
||||||
Uuid: "",
|
|
||||||
Action: "importWorkBatch",
|
|
||||||
Url: urlResult,
|
|
||||||
Status: 2,
|
|
||||||
OperatorID: fmt.Sprint(loginInfo.ID),
|
|
||||||
OperatorName: loginInfo.Name,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
service.Error(ctx, err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
for line, row := range rows {
|
for line, row := range rows {
|
||||||
if line == 0 {
|
if line == 0 {
|
||||||
continue
|
continue
|
||||||
@ -1291,6 +1276,7 @@ func ImportWorkBatch(ctx *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
// 打开模板文件,如果有失败的数据,生成结果文件
|
// 打开模板文件,如果有失败的数据,生成结果文件
|
||||||
|
var urlResult string
|
||||||
if resp.FailCount > 0 {
|
if resp.FailCount > 0 {
|
||||||
hasValueRows := make(map[int]bool, resp.FailCount)
|
hasValueRows := make(map[int]bool, resp.FailCount)
|
||||||
for _, v := range resp.ImageWorks {
|
for _, v := range resp.ImageWorks {
|
||||||
@ -1312,11 +1298,9 @@ func ImportWorkBatch(ctx *gin.Context) {
|
|||||||
service.Error(ctx, err)
|
service.Error(ctx, err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
urlHost := config.AppConfig.System.FieeHost
|
||||||
|
urlResult = fmt.Sprintf("%s/api/fiee/static/work/%s", urlHost, fileName)
|
||||||
}
|
}
|
||||||
service.CastProvider.UpsertTaskList(context.Background(), &cast.UpsertTaskListReq{
|
|
||||||
Uuid: taskResp.Uuid,
|
|
||||||
Status: 3,
|
|
||||||
})
|
|
||||||
service.Success(ctx, map[string]interface{}{
|
service.Success(ctx, map[string]interface{}{
|
||||||
"successCount": resp.SuccessCount,
|
"successCount": resp.SuccessCount,
|
||||||
"failCount": resp.FailCount,
|
"failCount": resp.FailCount,
|
||||||
|
|||||||
@ -55,8 +55,6 @@ func ImageCheckByte(file *multipart.FileHeader) (bool, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func SecurityFile(textVal string) (bool, error) {
|
func SecurityFile(textVal string) (bool, error) {
|
||||||
//FIXME
|
|
||||||
return true, nil
|
|
||||||
if textVal == "" {
|
if textVal == "" {
|
||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
@ -80,8 +78,6 @@ func SecurityFile(textVal string) (bool, error) {
|
|||||||
return true, nil
|
return true, nil
|
||||||
}
|
}
|
||||||
func SecurityText(textVal string) (bool, error) {
|
func SecurityText(textVal string) (bool, error) {
|
||||||
//FIXME
|
|
||||||
return true, nil
|
|
||||||
aliConfig, err := pkgSecurity.GetGlobalConfig("./data/alibabacloud.env")
|
aliConfig, err := pkgSecurity.GetGlobalConfig("./data/alibabacloud.env")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return false, err
|
return false, err
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user