package RestaurantWeeklyRecipeMarge

import (
	"errors"
	"fmt"
	CoreCache "gitee.com/fotomxq/weeekj_core/v5/core/cache"
	CoreFilter "gitee.com/fotomxq/weeekj_core/v5/core/filter"
	CoreSQL2 "gitee.com/fotomxq/weeekj_core/v5/core/sql2"
	Router2SystemConfig "gitee.com/fotomxq/weeekj_core/v5/router2/system_config"
	"time"
)

// ArgsGetWeeklyRecipeList 获取周数据列表参数
type ArgsGetWeeklyRecipeList struct {
	//分页参数
	Pages CoreSQL2.ArgsPages `json:"pages"`
	//分公司ID
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//分公司ID组
	OrgIDs []int64 `db:"org_ids" json:"orgIDs" check:"ids" empty:"true"`
	//门店ID
	StoreID int64 `db:"store_id" json:"storeID" check:"id" empty:"true"`
	//门店ID列
	StoreIDs []int64 `db:"store_ids" json:"storeIDs" check:"ids" empty:"true"`
	//提交组织成员ID
	SubmitOrgBindID int64 `db:"submit_org_bind_id" json:"submitOrgBindID" check:"id" empty:"true"`
	//提交用户ID
	// 与组织ID二选一，如果组织成员ID为空，则使用用户ID；如果组织ID不为空，则使用组织成员ID+用户ID
	SubmitUserID int64 `db:"submit_user_id" json:"submitUserID" check:"id" empty:"true"`
	//审核状态
	// 0 未审核; 1 审核通过; 2 审核不通过
	AuditStatus int `db:"audit_status" json:"auditStatus" check:"intThan0" empty:"true"`
	//审核人ID
	AuditOrgBindID int64 `db:"audit_org_bind_id" json:"auditOrgBindID" check:"id" empty:"true"`
	//审核用户ID
	// 与组织ID二选一，如果组织成员ID为空，则使用用户ID；如果组织ID不为空，则使用组织成员ID+用户ID
	AuditUserID int64 `db:"audit_user_id" json:"auditUserID" check:"id" empty:"true"`
	//菜谱类型ID
	RecipeTypeID int64 `db:"recipe_type_id" json:"recipeTypeID" check:"id" index:"true"`
	//是否删除
	IsRemove bool `json:"isRemove" check:"bool"`
	//搜索
	Search string `json:"search" check:"search" empty:"true"`
}

// GetWeeklyRecipeList 获取周数据列表
func GetWeeklyRecipeList(args *ArgsGetWeeklyRecipeList) (dataList []FieldsWeeklyRecipe, dataCount int64, err error) {
	dataCount, err = weeklyRecipeDB.Select().SetDefaultKeyListFields().SetDefaultListFields().SetPages(args.Pages).SetDeleteQuery("delete_at", args.IsRemove).SetIDQuery("org_id", args.OrgID).SetIDsQuery("org_ids", args.OrgIDs).SetIDQuery("store_id", args.StoreID).SetIDsQuery("store_id", args.StoreIDs).SetIDQuery("submit_org_bind_id", args.SubmitOrgBindID).SetIDQuery("submit_user_id", args.SubmitUserID).SetIntQuery("audit_status", args.AuditStatus).SetIDQuery("audit_org_bind_id", args.AuditOrgBindID).SetIDQuery("audit_user_id", args.AuditUserID).SetIDQuery("recipe_type_id", args.SubmitUserID).SetSearchQuery([]string{"name", "remark"}, args.Search).SelectList("").ResultAndCount(&dataList)
	if err != nil || len(dataList) < 1 {
		return
	}
	for k, v := range dataList {
		vData := getWeeklyRecipeByID(v.ID)
		if vData.ID < 1 {
			continue
		}
		dataList[k] = vData
	}
	return
}

// ArgsGetWeeklyRecipeByID 获取周数据参数
type ArgsGetWeeklyRecipeByID struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//分公司ID
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//门店ID
	StoreID int64 `db:"store_id" json:"storeID" check:"id" empty:"true"`
}

// GetWeeklyRecipeByID 获取周数据
func GetWeeklyRecipeByID(args *ArgsGetWeeklyRecipeByID) (data FieldsWeeklyRecipe, err error) {
	data = getWeeklyRecipeByID(args.ID)
	if data.ID < 1 || !CoreFilter.EqID2(args.OrgID, data.OrgID) || !CoreFilter.EqID2(args.StoreID, data.StoreID) {
		err = errors.New("no data")
		return
	}
	return
}

// ArgsGetWeeklyRecipeByLastData 获取上一次提交的记录参数
type ArgsGetWeeklyRecipeByLastData struct {
	//分公司ID
	OrgID int64 `db:"org_id" json:"orgID" check:"id"`
	//门店ID
	StoreID int64 `db:"store_id" json:"storeID" check:"id"`
	//菜谱类型ID
	RecipeTypeID int64 `db:"recipe_type_id" json:"recipeTypeID" check:"id" index:"true"`
}

// GetWeeklyRecipeByLastData 获取上一次提交的记录
// 只获取审批后的记录
func GetWeeklyRecipeByLastData(args *ArgsGetWeeklyRecipeByLastData) (data FieldsWeeklyRecipe, err error) {
	err = weeklyRecipeDB.Get().SetFieldsOne([]string{"id"}).SetIDQuery("org_id", args.OrgID).SetIDQuery("store_id", args.StoreID).SetIDQuery("recipe_type_id", args.RecipeTypeID).SetIntQuery("audit_status", 2).SetDeleteQuery("delete_at", false).NeedSort(true, "id", true).NeedLimit().Result(&data)
	if err != nil {
		return
	}
	return getWeeklyRecipeByID(data.ID), nil
}

// GetWeeklyRecipeNameByID 获取周数据名称
func GetWeeklyRecipeNameByID(id int64) (name string) {
	data := getWeeklyRecipeByID(id)
	if data.ID < 1 {
		return
	}
	return data.Name
}

// ArgsCreateWeeklyRecipe 创建周数据参数
type ArgsCreateWeeklyRecipe struct {
	//分公司ID
	OrgID int64 `db:"org_id" json:"orgID" check:"id"`
	//门店ID
	StoreID int64 `db:"store_id" json:"storeID" check:"id"`
	//提交组织成员ID
	SubmitOrgBindID int64 `db:"submit_org_bind_id" json:"submitOrgBindID" check:"id" empty:"true"`
	//提交用户ID
	// 与组织ID二选一，如果组织成员ID为空，则使用用户ID；如果组织ID不为空，则使用组织成员ID+用户ID
	SubmitUserID int64 `db:"submit_user_id" json:"submitUserID" check:"id" empty:"true"`
	//提交人姓名
	SubmitUserName string `db:"submit_user_name" json:"submitUserName" check:"des" min:"1" max:"300" empty:"true"`
	//名称
	Name string `db:"name" json:"name" check:"des" min:"1" max:"300" empty:"true"`
	//备注
	Remark string `db:"remark" json:"remark" check:"des" min:"1" max:"1000" empty:"true"`
	//菜谱类型ID
	RecipeTypeID int64 `db:"recipe_type_id" json:"recipeTypeID" check:"id" index:"true"`
}

// CreateWeeklyRecipe 创建周数据
func CreateWeeklyRecipe(args *ArgsCreateWeeklyRecipe) (id int64, err error) {
	//创建数据
	id, err = weeklyRecipeDB.Insert().SetFields([]string{"org_id", "store_id", "submit_org_bind_id", "submit_user_id", "submit_user_name", "audit_at", "audit_status", "audit_org_bind_id", "audit_user_id", "audit_user_name", "name", "remark", "recipe_type_id", "recipe_type_name"}).Add(map[string]any{
		"org_id":             args.OrgID,
		"store_id":           args.StoreID,
		"submit_org_bind_id": args.SubmitOrgBindID,
		"submit_user_id":     args.SubmitUserID,
		"submit_user_name":   args.SubmitUserName,
		"audit_at":           time.Time{},
		"audit_status":       0,
		"audit_org_bind_id":  0,
		"audit_user_id":      0,
		"audit_user_name":    "",
		"name":               args.Name,
		"remark":             args.Remark,
		"recipe_type_id":     args.RecipeTypeID,
		"recipe_type_name":   RecipeType.GetNameNoErr(args.RecipeTypeID),
	}).ExecAndResultID()
	if err != nil {
		return
	}
	//反馈
	return
}

// ArgsUpdateWeeklyRecipe 修改周数据参数
type ArgsUpdateWeeklyRecipe struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//分公司ID
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//门店ID
	StoreID int64 `db:"store_id" json:"storeID" check:"id" empty:"true"`
	//名称
	Name string `db:"name" json:"name" check:"des" min:"1" max:"300" empty:"true"`
	//备注
	Remark string `db:"remark" json:"remark" check:"des" min:"1" max:"1000" empty:"true"`
	//菜谱类型ID
	RecipeTypeID int64 `db:"recipe_type_id" json:"recipeTypeID" check:"id" index:"true"`
}

// UpdateWeeklyRecipe 修改周数据
func UpdateWeeklyRecipe(args *ArgsUpdateWeeklyRecipe) (err error) {
	//更新数据
	err = weeklyRecipeDB.Update().SetFields([]string{"name", "remark", "recipe_type_id"}).NeedUpdateTime().AddWhereID(args.ID).AddWhereOrgID(args.OrgID).SetWhereOrThan("store_id", args.StoreID).NamedExec(map[string]any{
		"name":           args.Name,
		"remark":         args.Remark,
		"recipe_type_id": args.RecipeTypeID,
	})
	if err != nil {
		return
	}
	//删除缓冲
	deleteWeeklyRecipeCache(args.ID)
	//反馈
	return
}

// ArgsAuditWeeklyRecipe 审核每周菜谱上报参数
type ArgsAuditWeeklyRecipe struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//当前组织ID
	// 用于验证数据是否属于当前组织
	RawOrgID int64 `db:"raw_org_id" json:"rawOrgID" check:"id" empty:"true"`
	//审核状态
	//0 草稿; 1 未审核; 2 审核通过; 3 审核不通过 ; 4 审核未通过，重新提交
	AuditStatus int `db:"audit_status" json:"auditStatus" check:"intThan0" empty:"true"`
	//审核人ID
	AuditOrgBindID int64 `db:"audit_org_bind_id" json:"auditOrgBindID" check:"id" empty:"true"`
	//审核用户ID
	// 与组织ID二选一，如果组织成员ID为空，则使用用户ID；如果组织ID不为空，则使用组织成员ID+用户ID
	AuditUserID int64 `db:"audit_user_id" json:"auditUserID" check:"id" empty:"true"`
	//审核人姓名
	AuditUserName string `db:"audit_user_name" json:"auditUserName" check:"des" min:"1" max:"300" empty:"true"`
	//审核备注
	AuditRemark string `db:"audit_remark" json:"auditRemark" check:"des" min:"1" max:"1000" default:"empty" empty:"true"`
}

// AuditWeeklyRecipe 审核每周菜谱上报
func AuditWeeklyRecipe(args *ArgsAuditWeeklyRecipe) (err error) {
	var auditAt time.Time
	if args.AuditStatus == 2 {
		auditAt = CoreFilter.GetNowTime()
	} else {
		auditAt = time.Time{}
	}

	err = weeklyRecipeDB.Update().SetFields([]string{"audit_at", "audit_status", "audit_remark", "audit_org_bind_id", "audit_user_id", "audit_user_name"}).NeedUpdateTime().AddWhereID(args.ID).NamedExec(map[string]any{
		"audit_at":          auditAt,
		"audit_status":      args.AuditStatus,
		"audit_org_bind_id": args.AuditOrgBindID,
		"audit_user_id":     args.AuditUserID,
		"audit_user_name":   args.AuditUserName,
		"audit_remark":      args.AuditRemark,
	})
	if err != nil {
		return
	}
	//删除缓冲
	deleteWeeklyRecipeCache(args.ID)
	//反馈
	return
}

// ArgsDeleteWeeklyRecipe 删除周数据参数
type ArgsDeleteWeeklyRecipe struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//分公司ID
	OrgID int64 `db:"org_id" json:"orgID" check:"id" empty:"true"`
	//门店ID
	StoreID int64 `db:"store_id" json:"storeID" check:"id" empty:"true"`
}

// DeleteWeeklyRecipe 删除周数据
func DeleteWeeklyRecipe(args *ArgsDeleteWeeklyRecipe) (err error) {
	//删除数据
	err = weeklyRecipeDB.Delete().NeedSoft(true).AddWhereID(args.ID).AddWhereOrgID(args.OrgID).SetWhereOrThan("store_id", args.StoreID).ExecNamed(nil)
	if err != nil {
		return
	}
	//删除缓冲
	deleteWeeklyRecipeCache(args.ID)
	//反馈
	return
}

// getWeeklyRecipeByID 通过ID获取周数据数据包
func getWeeklyRecipeByID(id int64) (data FieldsWeeklyRecipe) {
	cacheMark := getWeeklyRecipeCacheMark(id)
	if err := Router2SystemConfig.MainCache.GetStruct(cacheMark, &data); err == nil && data.ID > 0 {
		return
	}
	err := weeklyRecipeDB.Get().SetDefaultFields().GetByID(id).NeedLimit().Result(&data)
	if err != nil {
		return
	}
	Router2SystemConfig.MainCache.SetStruct(cacheMark, data, CoreCache.CacheTime1Hour)
	return
}

// 缓冲
func getWeeklyRecipeCacheMark(id int64) string {
	return fmt.Sprint("restaurant:weekly.recipe:id.", id)
}

func deleteWeeklyRecipeCache(id int64) {
	Router2SystemConfig.MainCache.DeleteMark(getWeeklyRecipeCacheMark(id))
}