package oilcontract

import (
	"encoding/json"
	"strconv"
	"time"

	"dashoo.cn/backend/api/business/baseUser"
	//	"dashoo.cn/backend/api/business/items"
	"dashoo.cn/backend/api/business/oilcontract/contractEvaluationItems"
	. "dashoo.cn/backend/api/controllers"
	"dashoo.cn/business2/userRole"
	"dashoo.cn/utils"
)

type OilContractEvaluationItemsController struct {
	BaseController
}

// @Title 获取列表
// @Description get user by token
// @Success 200 {object} []contractEvaluationItems.OilContractEvaluationItems
// @router /list [get]
func (this *OilContractEvaluationItemsController) GetEntityList() {

	//获取分页信息
	page := this.GetPageInfoForm()
	where := " 1=1 "
	orderby := "Id"
	asc := false
	Order := this.GetString("Order")
	Prop := this.GetString("Prop")
	if Order != "" && Prop != "" {
		orderby = Prop
		if Order == "asc" {
			asc = true
		}
	}
	Id := this.GetString("Id")
	ContractId := this.GetString("ContractId")
	ParentId := this.GetString("ParentId")
	SequenceNo := this.GetString("SequenceNo")
	Content := this.GetString("Content")
	NormalScore := this.GetString("NormalScore")
	Score := this.GetString("Score")
	LevelCode := this.GetString("LevelCode")
	Remark := this.GetString("Remark")
	ModifiedOn := this.GetString("ModifiedOn")
	ModifiedUserId := this.GetString("ModifiedUserId")
	ModifiedBy := this.GetString("ModifiedBy")

	if Id != "" {
		where = where + " and Id like '%" + Id + "%'"
	}

	if ContractId != "" {
		where = where + " and ContractId like '%" + ContractId + "%'"
	}

	if ParentId != "" {
		where = where + " and ParentId like '%" + ParentId + "%'"
	}

	if SequenceNo != "" {
		where = where + " and SequenceNo like '%" + SequenceNo + "%'"
	}

	if Content != "" {
		where = where + " and Content like '%" + Content + "%'"
	}

	if NormalScore != "" {
		where = where + " and NormalScore like '%" + NormalScore + "%'"
	}

	if Score != "" {
		where = where + " and Score like '%" + Score + "%'"
	}

	if LevelCode != "" {
		where = where + " and LevelCode like '%" + LevelCode + "%'"
	}

	if Remark != "" {
		where = where + " and Remark like '%" + Remark + "%'"
	}

	if ModifiedOn != "" {
		where = where + " and ModifiedOn like '%" + ModifiedOn + "%'"
	}

	if ModifiedUserId != "" {
		where = where + " and ModifiedUserId like '%" + ModifiedUserId + "%'"
	}

	if ModifiedBy != "" {
		where = where + " and ModifiedBy like '%" + ModifiedBy + "%'"
	}

	svc := contractEvaluationItems.GetOilContractEvaluationItemsService(utils.DBE)
	var list []contractEvaluationItems.OilContractEvaluationItems
	total := svc.GetPagingEntitiesWithOrderBytbl("", page.CurrentPage, page.Size, orderby, asc, &list, where)
	var datainfo DataInfo
	datainfo.Items = list
	datainfo.CurrentItemCount = total
	datainfo.PageIndex = page.CurrentPage
	datainfo.ItemsPerPage = page.Size
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 获取列表树
// @Description get user by token
// @Success 200 {object} []contractEvaluationItems.OilContractEvaluationItems
// @router /tree [get]
func (this *OilContractEvaluationItemsController) GetTreeList() {
	//获取分页信息
	page := this.GetPageInfoForm()
	orderby := "Id"
	where := " ParentId = 0 "
	Id      := this.GetString("ContentReviewId")      // 评价主表ID
	Category:= this.GetString("Category","0")   // 类型  0 二级部门创建  1 专业处创建
	if Id != "" {
		where = where + " and ContentReviewId = '" + Id + "'"
	}
	if Category != "" {
		where = where + " and Category = '" + Category + "'"
	}
	svc := contractEvaluationItems.GetOilContractEvaluationItemsService(utils.DBE)
	var list []contractEvaluationItems.OilContractEvaluationItems
	var result []contractEvaluationItems.EvaluationItems
	total := svc.GetPagingEntitiesWithOrderBytbl("", page.CurrentPage, page.Size, orderby, true, &list, where)
	for _, value := range list {
		var firstTmp contractEvaluationItems.EvaluationItems
		firstTmp.Content = value.Content
		firstTmp.ParentId = value.ParentId
		firstTmp.Id = value.Id
		firstTmp.SequenceNo = value.SequenceNo
		firstTmp.NormalScore = value.NormalScore
		firstTmp.Remark = value.Remark
		firstTmp.LevelCode = value.LevelCode

		var list1 []contractEvaluationItems.EvaluationItems
		where1 := " ParentId = " + strconv.Itoa(value.Id)
		svc.GetPagingEntitiesWithOrderBytbl("", page.CurrentPage, page.Size, orderby, true, &list1, where1)
		for _, v := range list1 {
			var secTmp contractEvaluationItems.EvaluationItems
			secTmp.Content = v.Content
			secTmp.Content = v.Content
			secTmp.ParentId = v.ParentId
			secTmp.Id = v.Id
			secTmp.SequenceNo = v.SequenceNo
			secTmp.NormalScore = v.NormalScore
			secTmp.Remark = v.Remark
			secTmp.LevelCode = v.LevelCode
			firstTmp.Child = append(firstTmp.Child, secTmp)
		}
		result = append(result, firstTmp)
	}
	var datainfo DataInfo
	datainfo.Items = result
	datainfo.CurrentItemCount = total
	//datainfo.PageIndex = page.CurrentPage
	//datainfo.ItemsPerPage = page.Size
	this.Data["json"] = &datainfo
	this.ServeJSON()
}


// @Title 获取字典列表
// @Description get user by token
// @Success 200 {object} map[string]interface{}
// @router /dictlist [get]
func (this *OilContractEvaluationItemsController) GetDictList() {
	dictList := make(map[string]interface{})
	//dictSvc := items.GetItemsService(utils.DBE)
	userSvc := baseUser.GetBaseUserService(utils.DBE)
	//customerSvc := svccustomer.GetCustomerService(utils.DBE)
	//dictList["WellNo"] = dictSvc.GetKeyValueItems("WellNo", "")
	var userEntity userRole.Base_User
	userSvc.GetEntityById(this.User.Id, &userEntity)
	dictList["Supervisers"] = userSvc.GetUserListByDepartmentId("", userEntity.Departmentid)

	//var dictCustomer []svccustomer.Customer
	//customerSvc.GetEntitysByWhere("" + CustomerName, "", &dictCustomer)
	//dictList["EntrustCorp"] = &dictCustomer

	var datainfo DataInfo
	datainfo.Items = dictList
	this.Data["json"] = &datainfo
	this.ServeJSON()
}

// @Title 获取实体
// @Description 获取实体
// @Success 200 {object} contractEvaluationItems.OilContractEvaluationItems
// @router /get/:id [get]
func (this *OilContractEvaluationItemsController) GetEntity() {
	Id := this.Ctx.Input.Param(":id")

	var model contractEvaluationItems.OilContractEvaluationItems
	svc := contractEvaluationItems.GetOilContractEvaluationItemsService(utils.DBE)
	svc.GetEntityByIdBytbl(OilContractEvaluationItemsName, Id, &model)

	this.Data["json"] = &model
	this.ServeJSON()
}

// @Title 添加
// @Description 新增
// @Param 	body body contractEvaluationItems.OilContractEvaluationItems
// @Success	200	{object} controllers.Request
// @router /add [post]
func (this *OilContractEvaluationItemsController) AddEntity() {
	var model contractEvaluationItems.OilContractEvaluationItems
	var jsonBlob = this.Ctx.Input.RequestBody
	svc := contractEvaluationItems.GetOilContractEvaluationItemsService(utils.DBE)

	json.Unmarshal(jsonBlob, &model)

	_, err := svc.InsertEntityBytbl(OilContractEvaluationItemsName, &model)

	var errinfo ErrorDataInfo
	if err == nil {
		//新增
		errinfo.Message = "添加成功！"
		errinfo.Code = 0
		errinfo.Item = model.Id
		this.Data["json"] = &errinfo
		this.ServeJSON()
	} else {
		errinfo.Message = "添加失败！" + utils.AlertProcess(err.Error())
		errinfo.Code = -1
		this.Data["json"] = &errinfo
		this.ServeJSON()
	}
}

// @Title 修改实体
// @Description 修改实体
// @Param 	body body contractEvaluationItems.OilContractEvaluationItems
// @Success	200	{object} controllers.Request
// @router /update/:id [post]
func (this *OilContractEvaluationItemsController) UpdateEntity() {
	id := this.Ctx.Input.Param(":id")
	var errinfo ErrorInfo
	if id == "" {
		errinfo.Message = "操作失败！请求信息不完整"
		errinfo.Code = -2
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}

	var model contractEvaluationItems.OilContractEvaluationItems
	svc := contractEvaluationItems.GetOilContractEvaluationItemsService(utils.DBE)

	var jsonBlob = this.Ctx.Input.RequestBody
	json.Unmarshal(jsonBlob, &model)
	model.ModifiedOn = time.Now()
	model.ModifiedBy = this.User.Realname
	model.ModifiedUserId, _ = utils.StrTo(this.User.Id).Int()

	cols := []string{

		"Id",

		"ContractId",

		"ContractWorkId",

		"ParentId",

		"SequenceNo",

		"Content",

		"NormalScore",

		"Score",

		"LevelCode",

		"Remark",

		"ModifiedOn",

		"ModifiedUserId",

		"ModifiedBy",
	}
	err := svc.UpdateEntityBytbl(OilContractEvaluationItemsName, id, &model, cols)
	if err == nil {
		errinfo.Message = "修改成功！"
		errinfo.Code = 0
		this.Data["json"] = &errinfo
		this.ServeJSON()
	} else {
		errinfo.Message = "修改失败！" + utils.AlertProcess(err.Error())
		errinfo.Code = -1
		this.Data["json"] = &errinfo
		this.ServeJSON()
	}
}

// @Title 删除单条信息
// @Description
// @Success 200 {object} ErrorInfo
// @Failure 403 :id 为空
// @router /delete/:Id [delete]
func (this *OilContractEvaluationItemsController) DeleteEntity() {
	Id := this.Ctx.Input.Param(":Id")
	var errinfo ErrorInfo
	if Id == "" {
		errinfo.Message = "操作失败！请求信息不完整"
		errinfo.Code = -2
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}
	var model contractEvaluationItems.OilContractEvaluationItems
	var entityempty contractEvaluationItems.OilContractEvaluationItems
	svc := contractEvaluationItems.GetOilContractEvaluationItemsService(utils.DBE)
	opdesc := "删除-" + Id
	err := svc.DeleteOperationAndWriteLogBytbl(OilContractEvaluationItemsName, BaseOperationLogName, Id, &model, &entityempty, utils.ToStr(this.User.Id), this.User.Username, opdesc, "", "钻井日报")
	if err == nil {
		errinfo.Message = "删除成功"
		errinfo.Code = 0
		this.Data["json"] = &errinfo
		this.ServeJSON()
	} else {
		errinfo.Message = "删除失败！" + utils.AlertProcess(err.Error())
		errinfo.Code = -1
		this.Data["json"] = &errinfo
		this.ServeJSON()
	}
}