lims_adapter/handler/results.go

package handler

import (
	"context"
	resultSrv "lims_adapter/service/result"

	"dashoo.cn/common_definition/admin/result_def"
	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/micro_libary/micro_srv"
	"dashoo.cn/micro_libary/myerrors"
	"github.com/gogf/gf/frame/g"
)

// 成果
type Result struct{}

func (r Result) BatchInsertPapers(ctx context.Context, req []result_def.BatchInsertPapersReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	userinfo, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}

	g.Log().Info("Received Result.BatchInsertPapers request @ " + tenant)
	failCount, successCount, duplicatedCount, failList, err := resultSrv.NewSrv(tenant).BatchInsertPapers(req, userinfo)

	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	rsp.Data = g.Map{"fail_count": failCount, "success_count": successCount, "fail_list": failList, "duplicated_count": duplicatedCount}
	return nil
}

func (r Result) GetResultList(ctx context.Context, req result_def.ResultListReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}

	g.Log().Info("Received Result.GetResultList request @ " + tenant)
	data, total, err := resultSrv.NewSrv(tenant).GetResultList(req)

	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	rsp.Data = g.Map{"Total": total, "Data": data}
	return nil
}

func (r Result) DeleteResult(ctx context.Context, req comm_def.IdOnlyReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}

	g.Log().Info("Received Result.DeleteResult request @ " + tenant)
	err = resultSrv.NewSrv(tenant).DeleteResult(req)

	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	return nil
}