package controllers

import (
	"encoding/json"
	"fmt"
	"oppmg/common/log"
	"oppmg/models"
	"oppmg/protocol"
	serverank "oppmg/services/rank"
	"strings"
	"time"
)

type RankController struct {
	BaseController
}

//GetRankType  榜单类型列表
//@router /rank/list
func (c RankController) GetRankType() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	companyid := c.GetCompanyId()
	rspData := serverank.GetRankList(companyid)
	msg = protocol.NewReturnResponse(rspData, nil)
	return
}

//EditRankType 榜单类型列表添加
//@router /rank/edit
func (c RankController) EditRankType() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		Id   int64  `json:"id"`
		Name string `json:"name"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	err := serverank.UpdateRankType(param.Id, param.Name, companyid)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//EditRankType ...
//@router /rank/forbid_allow
func (c RankController) RankTypeForbidAllow() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		Id     int64 `json:"id"`
		Status int   `json:"status"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	var err error
	companyid := c.GetCompanyId()
	switch param.Status {
	case 1:
		err = serverank.ForbidRank(param.Id, companyid)
	case 2:
		err = serverank.AllowRank(param.Id, companyid)
	default:
		err = protocol.NewErrWithMessage("1")
	}
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankSeasonList 赛季列表
//@router /rank/season/list
func (c RankController) RankSeasonList() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		protocol.RequestPageInfo
		RankTypeId int64 `json:"rank_type_id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	rspData, err := serverank.RankSeasonList(param.PageIndex, param.PageSize, param.RankTypeId, companyid)
	msg = protocol.NewPageDataResponse(rspData, err)
	return
}

//RankSeasonAdd 赛季列表添加
//@router /rank/season/add
func (c RankController) RankSeasonAdd() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		RankTypeId int64  `json:"rank_type_id"`
		Name       string `json:"name"`
		BeginTime  string `json:"begin_time"`
		EndTime    string `json:"end_time"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	param.Name = strings.TrimSpace(param.Name)
	if len(param.Name) == 0 {
		msg = protocol.BadRequestParam("1")
		return
	}
	var (
		beginTime int64
		endTime   int64
	)
	t1, err := time.ParseInLocation("2006-01-02", param.BeginTime, time.Local)
	if err != nil {
		msg = protocol.BadRequestParam("1")
		return
	}
	beginTime = t1.Unix()
	t2, err := time.ParseInLocation("2006-01-02", param.EndTime, time.Local)
	if err != nil {
		msg = protocol.BadRequestParam("1")
		return
	}
	endTime = t2.Unix() + 86399 //60*60*24-1
	if beginTime > endTime {
		msg = protocol.BadRequestParam("1")
		return
	}
	ok := serverank.RankPeriodCheckTime(param.RankTypeId, beginTime, endTime, 0)
	if !ok {
		msg = protocol.BadRequestParam("10101")
		return
	}
	companyid := c.GetCompanyId()
	err = serverank.AddRankPeriod(param.RankTypeId, beginTime, endTime, param.Name, companyid)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankSeasonEdit ...
//@router /rank/season/edit
func (c RankController) RankSeasonEdit() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		Id         int64  `json:"id"`
		Name       string `json:"name"`
		RankTypeId int64  `json:"rank_type_id"`
		BeginTime  string `json:"begin_time"`
		EndTime    string `json:"end_time"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	param.Name = strings.TrimSpace(param.Name)
	if len(param.Name) == 0 {
		msg = protocol.BadRequestParam("1")
		return
	}
	var (
		beginTime int64
		endTime   int64
	)
	t1, err := time.ParseInLocation("2006-01-02", param.BeginTime, time.Local)
	if err != nil {
		msg = protocol.BadRequestParam("1")
		return
	}
	beginTime = t1.Unix()
	t2, err := time.ParseInLocation("2006-01-02", param.EndTime, time.Local)
	if err != nil {
		msg = protocol.BadRequestParam("1")
		return
	}

	endTime = t2.Unix() + 86399 //60*60*24-1
	if beginTime > endTime {
		msg = protocol.BadRequestParam("1")
		return
	}
	ok := serverank.RankPeriodCheckTime(param.RankTypeId, beginTime, endTime, param.Id)
	if !ok {
		msg = protocol.BadRequestParam("10101")
		return
	}
	companyid := c.GetCompanyId()
	fmt.Println(beginTime, endTime)
	err = serverank.EditRankPeriod(param.Id, beginTime, endTime, param.Name, companyid)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankRangeList 赛季榜单参与人列表
//@router /rank/range/list
func (c RankController) RankRangeList() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()

	companyid := c.GetCompanyId()
	rspData := serverank.GetRankRangeList(companyid)
	msg = protocol.NewReturnResponse(rspData, nil)
	return
}

//RankRangeAdd 赛季榜单参与人列表添加
//@router /rank/range/add
func (c RankController) RankRangeAdd() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		RankTypeId int64   `json:"rank_type_id"`
		Name       string  `json:"name"`
		RangeType  int8    `json:"range_type"`
		RelationId []int64 `json:"relation_id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	switch param.RangeType {
	case 1:
		//员工
		if len(param.RelationId) == 0 {
			param.RangeType = models.RANK_RANGE_TYPE_EMPLAYEEALL
		} else {
			param.RangeType = models.RANK_RANGE_TYPE_EMPLAYEE
		}
	case 2:
		//部门
		if len(param.RelationId) == 0 {
			param.RangeType = models.RANK_RANGE_TYPE_DEPARTMENTALL
		} else {
			param.RangeType = models.RANK_RANGE_TYPE_DEPARTMENT
		}
	default:
		log.Error("param.RangeType err")
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	err := serverank.AddRankRange(param.RankTypeId, param.Name, param.RangeType, param.RelationId, companyid)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankRangeEdit 赛季榜单参与人编辑
//@router /rank/range/edit
func (c RankController) RankRangeEdit() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		Id         int64   `json:"id"`
		Name       string  `json:"name"`
		RangeType  int8    `json:"range_type"`
		RelationId []int64 `json:"relation_id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	switch param.RangeType {
	case 1:
		//员工
		if len(param.RelationId) == 0 {
			param.RangeType = models.RANK_RANGE_TYPE_EMPLAYEEALL
		} else {
			param.RangeType = models.RANK_RANGE_TYPE_EMPLAYEE
		}
	case 2:
		//部门
		if len(param.RelationId) == 0 {
			param.RangeType = models.RANK_RANGE_TYPE_DEPARTMENTALL
		} else {
			param.RangeType = models.RANK_RANGE_TYPE_DEPARTMENT
		}
	default:
		log.Error("param.RangeType err")
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	err := serverank.EditRankRange(param.Id, param.Name, param.RangeType, param.RelationId, companyid)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankRangeForbidAllow ...
//@router /rank/range/forbid_allow
func (c RankController) RankRangeForbidAllow() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		Id     int64 `json:"id"`
		Status int   `json:"status"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	var err error
	companyid := c.GetCompanyId()
	switch param.Status {
	case 1:
		err = serverank.ForbidRankRange(param.Id, companyid)
	case 2:
		err = serverank.AllowRankRange(param.Id, companyid)
	default:
		err = protocol.NewErrWithMessage("1")
	}
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankRangeInfo 赛季榜单参与人详情
//@router /rank/range/info
func (c RankController) RankRangeInfo() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		Id int64 `json:"id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	// companyid := c.GetCompanyId()
	rspData := serverank.GetRankRangeInfo(param.Id)
	switch rspData.RangeType {
	case models.RANK_RANGE_TYPE_DEPARTMENT, models.RANK_RANGE_TYPE_DEPARTMENTALL:
		//部门
		rspData.RangeType = 2
	case models.RANK_RANGE_TYPE_EMPLAYEE, models.RANK_RANGE_TYPE_EMPLAYEEALL:
		//员工
		rspData.RangeType = 1

	}
	msg = protocol.NewReturnResponse(rspData, nil)
	return
}

//RankRangeSort ...
//@router /rank/range/sort
func (c RankController) RankRangeSort() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		RankTypeId int64   `json:"rank_type_id"`
		Id         []int64 `json:"id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	err := serverank.RankRangeSort(param.Id)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankItemList 评比项列表
//@router /rank/item/list
func (c RankController) RankItemList() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		RankTypeId int64 `json:"rank_type_id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	items := serverank.GetRankItemList(companyid, param.RankTypeId)
	rspdata := map[string][]protocol.RankItemInfo{
		"all":     serverank.AllRankItem,
		"checked": items,
	}
	msg = protocol.NewReturnResponse(rspdata, nil)
	return
}

//RankItemEdit ...
//@router /rank/item/edit
func (c RankController) RankItemEdit() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		RankTypeId int64    `json:"rank_type_id"`
		ItemKey    []string `json:"item_key"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	err := serverank.GetRankItemEdit(companyid, param.RankTypeId, param.ItemKey)
	msg = protocol.NewReturnResponse(nil, err)
	return
}

//RankRangeMove 赛季榜单参与人分组 批量移动
//@router /rank/range/move
func (c RankController) RankRangeMove() {
	var msg *protocol.ResponseMessage
	defer func() {
		c.ResposeJson(msg)
	}()
	type Parameter struct {
		FromId     int64   `json:"from_id"`
		ToId       int64   `json:"to_id"`
		RelationId []int64 `json:"relation_id"`
	}
	var param Parameter
	if err := json.Unmarshal(c.Ctx.Input.RequestBody, &param); err != nil {
		log.Error("json 解析失败 err:%s", err)
		msg = protocol.BadRequestParam("1")
		return
	}
	companyid := c.GetCompanyId()
	err := serverank.RankRangeMove(param.FromId, param.ToId, param.RelationId, companyid)
	msg = protocol.NewReturnResponse(nil, err)
	return
}