package analysisuserlogic

import (
	"context"
	"strconv"

	"lone-services/pkg/modelbase"
	"lone-services/pkg/utils"
	"lone-services/pkg/validate"
	analysis "lone-services/rpc/analysis/pb"
	"lone-services/services/analysis/internal/dao"
	"lone-services/services/analysis/internal/logic/common"
	"lone-services/services/analysis/internal/model"
	"lone-services/services/analysis/internal/svc"
	"lone-services/services/analysis/validator"

	"github.com/zeromicro/go-zero/core/logx"
	"gorm.io/gorm"
)

type UserLogDeleteLogic struct {
	ctx    context.Context
	svcCtx *svc.ServiceContext
	logx.Logger
}

func NewUserLogDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UserLogDeleteLogic {
	return &UserLogDeleteLogic{
		ctx:    ctx,
		svcCtx: svcCtx,
		Logger: logx.WithContext(ctx),
	}
}

func (l *UserLogDeleteLogic) UserLogDelete(in *analysis.UserLogDeleteReq) (*analysis.Response, error) {
	var req validator.UserLogDeleteValidator
	if msg := validate.ValidateFromProto(in, &req); msg != utils.StringEmpty {
		return common.OutResponse(utils.ErrorParams, msg), nil
	}
	login, fail := common.RequireLogin(l.ctx)
	if fail != nil {
		return fail, nil
	}
	if login.Type != dao.TypeUser {
		return common.OkResponse(nil), nil
	}
	if login.BizId < utils.NumberOne {
		return common.OutResponse(utils.ErrorParams, "业务用户不存在"), nil
	}

	idStrs := make([]string, 0, len(req.Ids))
	for _, id := range req.Ids {
		idStrs = append(idStrs, strconv.FormatInt(id, utils.NumberTen))
	}
	where := modelbase.Params{
		In: map[string][]string{"id": idStrs},
		Eq: map[string]string{
			"user_id": strconv.FormatInt(login.BizId, utils.NumberTen),
			"status":  strconv.Itoa(utils.StatusOk),
		},
	}
	var images []dao.Image
	err := model.ImageModel{}.Init().Items(where, &images)
	if err != nil {
		l.Errorf("user log delete list: %v", err)
		return common.FailResponse(utils.Fail), nil
	}
	if len(images) == utils.NumberZero {
		return common.OkResponse(nil), nil
	}

	_, err = model.ImageModel{}.Init().Edit(where, map[string]interface{}{
		"status": utils.StatusFail,
	})
	if err != nil {
		l.Errorf("user log delete status: %v", err)
		return common.FailResponse(utils.Fail), nil
	}

	err = model.UserImageLogModel{}.Init().Session().
		Where("user_id = ?", login.BizId).
		Update("detection_number", gorm.Expr("detection_number - ?", len(images))).Error
	if err != nil {
		l.Errorf("user log delete decrement: %v", err)
		return common.FailResponse(utils.Fail), nil
	}
	return common.OkResponse(nil), nil
}