GtDataStore/app/cmd/events/internal/logic/handler/multi.go

package handler

import (
	"GtDataStore/app/cmd/events/internal/logic/job"
	"GtDataStore/app/cmd/events/internal/svc"
	"GtDataStore/app/model"
	"context"
	"github.com/zeromicro/go-zero/core/logx"
)

func EventMulti(ctx context.Context, task *job.Task, technologyName string) error {
	// 1. 查询所有的设备
	_, err := findMultiRecord(task.Job.SvcCtx, int64(task.Id))
	if err != nil {
		return err
	}

	return nil
}

func findMultiRecord(svcCtx *svc.ServiceContext, projectId int64) ([]model.DcEventBind, error) {
	if records, err := svcCtx.DcEventBind.FindByProjectIdRuleFlag(context.Background(), projectId, EVENT_MULTI_ITEM); err != nil {
		logx.Infof("findMultiRecord not found record")
		return nil, err
	} else {
		return records, nil
	}
}