dps-sdk/client/client.go

package client

import (
	"strings"
	"time"
)

const (
	columnCreateUserID     = "create_user_id"
	columnLastUpdateUserID = "last_update_user_id"
	columnCreatedTime      = "created_time"
	columnLastEventTime    = "last_event_time"
)

func GetCreateUserID(dataMap map[string]any) string {
	return dataMap[columnCreateUserID].(string)
}

func GetLastUpdateUserID(dataMap map[string]any) string {
	return dataMap[columnLastUpdateUserID].(string)
}

func FormatCreatedTime(dataMap map[string]any, format string) string {
	return dataMap[columnCreatedTime].(time.Time).Format(format)
}

func FormatLastEventTime(dataMap map[string]any, format string) string {
	return dataMap[columnLastEventTime].(time.Time).Format(format)
}

func IsErrorDBRecordHasExist(err error) bool {
	return strings.Contains(err.Error(), "记录已存在")
}

func IsErrorDBRecordNotExist(err error) bool {
	return strings.Contains(err.Error(), "记录不存在")
}

type Client interface {
	AutoMigrate(request *AutoMigrateRequest) error
	Transaction(txFunc TransactionFunc) error
	Insert(request *InsertRequest) (string, error)
	InsertBatch(request *InsertBatchRequest) (string, error)
	Delete(request *DeleteRequest) (string, error)
	DeleteBatch(request *DeleteBatchRequest) (string, error)
	Update(request *UpdateRequest) (string, error)
	Replay(request *ReplayRequest) (string, error)
	QueryByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []map[string]any, int64, error)
	CommonQuery(request *CommonQueryRequest) (string, []map[string]any, int64, error)
	QueryOnlyByWhereAndOrderBy(request *QueryByWhereAndOrderByRequest) (string, []map[string]any, error)
	CommonQueryOnly(request *CommonQueryRequest) (string, []map[string]any, error)
	QueryByKeys(request *QueryByKeysRequest) (string, map[string]any, error)
	CountWhere(request *CountWhereRequest) (string, int64, error)
	CommonCount(request *CommonCountRequest) (string, int64, error)
	EventQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error)
	CommonEventQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, error)
	EventQueryOnlyByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, error)
	CommonEventQueryOnly(request *CommonEventQueryRequest) (string, []EventInfo, error)
	CountEventByKeys(request *CountEventByKeysRequest) (string, int64, error)
	CommonCountEvent(request *CommonCountEventRequest) (string, int64, error)
	EventHistoryQueryByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, int64, error)
	CommonEventHistoryQuery(request *CommonEventQueryRequest) (string, []EventInfo, int64, error)
	EventHistoryQueryOnlyByKeys(request *EventQueryByKeysRequest) (string, []EventInfo, error)
	CommonEventHistoryQueryOnly(request *CommonEventQueryRequest) (string, []EventInfo, error)
	CountEventHistoryByKeys(request *CountEventByKeysRequest) (string, int64, error)
	CommonCountEventHistory(request *CommonCountEventRequest) (string, int64, error)
}