package oilsupplier

import (
	"dashoo.cn/backend/api/business/invoiceinfo"
	"dashoo.cn/backend/api/business/paymentinfo"
	"dashoo.cn/backend/api/business/workflow"
	. "dashoo.cn/backend/api/controllers"
	"dashoo.cn/utils"
	"fmt"
	"time"
)

type OilInvoiceController struct {
	BaseController
}

// @Title 获取信息
// @Description get user by token
// @Success 200 {object} map[string]interface{}
// @router /getinvoicedata [get]
func (this *OilInvoiceController) GetInvoiceData() {

	id := this.GetString("Id")
	dictList := make(map[string]interface{})

	svc := invoiceinfo.GetInvoiceService(utils.DBE)
	var entity invoiceinfo.OilInvoiceInfo
	where := "Id=" + id
	svc.GetEntity(&entity, where)

	var paylist []paymentinfo.PaymentinfoList
	svcp := paymentinfo.GetPaymentService(utils.DBE)
	where = "p.Id in (" + entity.SrcIds + ")"
	svcp.GetPaymentinfoList1(where, &paylist)

	dictList["invoiceinfo"] = entity
	dictList["paymentinfos"] = paylist

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

}

// @Title 更新发票状态
// @Description 更新发票状态
// @Success	200	{object} controllers.Request
// @router /updateisinvoice [get]
func (this *OilInvoiceController) UpdateIsInvoice() {

	id := this.GetString("Id")
	srcIds := this.GetString("SrcIds")
	session := utils.DBE.NewSession()
	defer session.Close()
	err := session.Begin()

	cols := []string{"IsInvoice", "InvoiceOn"}
	svc := invoiceinfo.GetOilInvoiceInfoSession(session)
	var info invoiceinfo.OilInvoiceInfo
	info.IsInvoice = "1"
	info.InvoiceOn = time.Now()
	_, err = svc.UpdateEntityByIdCols(id, &info, cols)

	var errinfo ErrorInfo
	if err != nil {
		session.Rollback()
		errinfo.Code = -1
		errinfo.Message = "操作失败！"
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}

	var payinfo paymentinfo.OilPaymentInfo
	payinfo.IsInvoice = "1"
	paycols := []string{"IsInvoice"}
	where := "Id in (" + srcIds + ")"
	err = svc.UpdateEntityBywheretbl(OilPaymentInfoName, &payinfo, paycols, where)

	if err != nil {
		session.Rollback()
		errinfo.Code = -1
		errinfo.Message = "操作失败！"
		this.Data["json"] = &errinfo
		this.ServeJSON()
		return
	}

	svcActiviti := workflow.GetActivitiService(utils.DBE)
	var ActiComplete workflow.ActiCompleteVM
	ActiComplete.ProcessKey = workflow.OIL_SUPPLIER_VERIFY
	ActiComplete.BusinessKey = id
	ActiComplete.UserId = this.User.Id
	ActiComplete.Remarks = ""
	ActiComplete.Result = "1"

	receiveVal := svcActiviti.TaskComplete(ActiComplete)
	fmt.Println(receiveVal)
	if receiveVal == "true" {
		session.Commit()
		errinfo.Code = 0
		errinfo.Message = "操作成功！"
		this.Data["json"] = &errinfo
		this.ServeJSON()
	} else {
		session.Rollback()
		errinfo.Code = -1
		errinfo.Message = "操作失败！"
		this.Data["json"] = &errinfo
		this.ServeJSON()
	}
}