dps-sdk/instance_event_query.go

package dps

import (
	"git.sxidc.com/service-supports/dps-sdk/client"
	"git.sxidc.com/service-supports/fslog"
)

func EventQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return make([]client.EventInfo, 0), 0, nil
	}

	statement, infos, totalCount, err := dpsClient.EventQueryByKeys(req)
	if err != nil {
		return nil, 0, err
	}

	fslog.Info(statement)

	return infos, totalCount, nil
}

func CommonEventQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return make([]client.EventInfo, 0), 0, nil
	}

	statement, infos, totalCount, err := dpsClient.CommonEventQuery(req)
	if err != nil {
		return nil, 0, err
	}

	fslog.Info(statement)

	return infos, totalCount, nil
}

func CountEventByKeys(req *client.CountEventByKeysRequest) (int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return 0, nil
	}

	statement, count, err := dpsClient.CountEventByKeys(req)
	if err != nil {
		return 0, err
	}

	fslog.Info(statement)

	return count, nil
}

func CommonCountEvent(req *client.CommonCountEventRequest) (int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return 0, nil
	}

	statement, count, err := dpsClient.CommonCountEvent(req)
	if err != nil {
		return 0, err
	}

	fslog.Info(statement)

	return count, nil
}

func CheckEventExistByKeys(req *client.CountEventByKeysRequest) (bool, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return false, nil
	}

	statement, count, err := dpsClient.CountEventByKeys(req)
	if err != nil {
		return false, err
	}

	fslog.Info(statement)

	if count <= 0 {
		return false, nil
	}

	return true, nil
}

func CommonCheckEventExist(req *client.CommonCountEventRequest) (bool, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return false, nil
	}

	statement, count, err := dpsClient.CommonCountEvent(req)
	if err != nil {
		return false, err
	}

	fslog.Info(statement)

	if count <= 0 {
		return false, nil
	}

	return true, nil
}

func EventHistoryQueryByKeys(req *client.EventQueryByKeysRequest) ([]client.EventInfo, int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return make([]client.EventInfo, 0), 0, nil
	}

	statement, infos, totalCount, err := dpsClient.EventHistoryQueryByKeys(req)
	if err != nil {
		return nil, 0, err
	}

	fslog.Info(statement)

	return infos, totalCount, nil
}

func CommonEventHistoryQuery(req *client.CommonEventQueryRequest) ([]client.EventInfo, int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return make([]client.EventInfo, 0), 0, nil
	}

	statement, infos, totalCount, err := dpsClient.CommonEventHistoryQuery(req)
	if err != nil {
		return nil, 0, err
	}

	fslog.Info(statement)

	return infos, totalCount, nil
}

func CountEventHistoryByKeys(req *client.CountEventByKeysRequest) (int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return 0, nil
	}

	statement, count, err := dpsClient.CountEventHistoryByKeys(req)
	if err != nil {
		return 0, err
	}

	fslog.Info(statement)

	return count, nil
}

func CommonCountEventHistory(req *client.CommonCountEventRequest) (int64, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return 0, nil
	}

	statement, count, err := dpsClient.CommonCountEventHistory(req)
	if err != nil {
		return 0, err
	}

	fslog.Info(statement)

	return count, nil
}

func CheckEventHistoryExistByKeys(req *client.CountEventByKeysRequest) (bool, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return false, nil
	}

	statement, count, err := dpsClient.CountEventHistoryByKeys(req)
	if err != nil {
		return false, err
	}

	fslog.Info(statement)

	if count <= 0 {
		return false, nil
	}

	return true, nil
}

func CommonCheckEventHistoryExist(req *client.CommonCountEventRequest) (bool, error) {
	dpsClientMutex.Lock()
	defer dpsClientMutex.Unlock()

	if dpsClient == nil {
		return false, nil
	}

	statement, count, err := dpsClient.CommonCountEventHistory(req)
	if err != nil {
		return false, err
	}

	fslog.Info(statement)

	if count <= 0 {
		return false, nil
	}

	return true, nil
}