package tmpzcgf

import (
	"dashoo.cn/backend/api/business/oilsupplier/infochange"
	"dashoo.cn/backend/api/business/oilsupplier/supplier"
	"dashoo.cn/backend/api/business/oilsupplier/suppliercert"
	"dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
	"dashoo.cn/backend/api/business/tmpzcgf"
	. "dashoo.cn/backend/api/controllers"
	"dashoo.cn/utils"
	"fmt"
	"time"
)

type TmpzcgfController struct {
	BaseController
}

// @Title 跟新OilSupplier
// @Description get user by token
// @Success 200 {object}
// @router /insertsupplier [get]
func (this *TmpzcgfController) InsertSupplier(){
	fmt.Println("======开始导入OilSupplier表======")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("======OilSupplier表结束======")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertSupplier()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新SupplierCert
// @Description get user by token
// @Success 200 {object}
// @router /insertsuppliercert [get]
func (this *TmpzcgfController) InsertSupplierCert(){
	fmt.Println("=============开始导入Cert表==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============导入Cert表结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertSupplierCert()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 更新CertTypeAndInflag
// @Description get user by token
// @Success 200 {object}
// @router /updatecerttypeandinflag [get]
func (this *TmpzcgfController) UpdateCertTypeAndInflag(){
	fmt.Println("=============开始更新Cert==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============开始更新Cert==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.UpdateSupplierTypeCodeAndInFlag()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新SupplierId
// @Description get user by token
// @Success 200 {object}
// @router /updatesupplierid [get]
func (this *TmpzcgfController) UpdateSupplierId(){
	fmt.Println("=============开始更新Cert的SupplierId==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============更新Cert的SupplierId结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.UpdateSupplierCert()
	//var supp []supplier.OilSupplier
	//var certs  []suppliercert.OilSupplierCert
	//var  c  suppliercert.OilSupplierCert

	//svc.GetEntitysByWhere("OilSupplier", "CreateBy='导入'" ,&supp )
	//svc.GetEntitysByWhere("OilSupplierCert", "1=1", &certs)
	//for _,cert := range certs {
	//	for _,sup := range supp {
	//		if cert.OutsideFlog == sup.SupplierName {
	//			fmt.Println(cert.OutsideFlog, sup.SupplierName)
	//			col := []string{"SupplierId"}
	//			c.SupplierId = sup.Id
	//			where := "Id=" + strconv.Itoa(cert.Id)
	//			err = svc.UpdateEntityBywheretbl("OilSupplierCert",c,col,where)
	//			if err != nil {
	//				session.Rollback()
	//			}
	//			break
	//		}
	//	}
	//}

	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 导入年审
// @Description get user by token
// @Success 200 {object}
// @router /insterannualaudit [get]
func (this *TmpzcgfController) InsterAnnualAudit(){
	fmt.Println("=============开始导入年审表==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============导入年审表结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsterAnnual()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新年审表的SupplierId CertId
// @Description get user by token
// @Success 200 {object}
// @router /updateAnnualAudit [get]
func (this *TmpzcgfController) UpdateAnnualAudit(){
	fmt.Println("=============开始更新年审表==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============开始年审表结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.UpdateOilAnnualAudit()
	//var annus []annualaudit.OilAnnualAudit
	//var certs  []suppliercert.OilSupplierCert
	//var  annual  annualaudit.OilAnnualAudit
	//
	//svc.GetEntitysByWhere("OilAnnualAudit", "1=1" ,&annus )
	//svc.GetEntitysByWhere("OilSupplierCert", "CreateBy='导入'", &certs)
	//var aff int64
	//for _,annu := range annus {
	//	for _,sup := range certs {
	//		if annu.OldId == sup.GfId {
	//			fmt.Println(annu.OldId, sup.GfId, sup.OutsideFlog)
	//			col := []string{"SupplierId", "CerId"}
	//			annual.SupplierId = sup.SupplierId
	//			annual.CerId = sup.Id
	//			//where := "Id=" + strconv.Itoa(annu.Id)
	//			aff,err = svc.UpdateEntityByIdCols(annu.Id, &annual, col)
	//			if err != nil {
	//				session.Rollback()
	//			}
	//			break
	//		}
	//	}
	//}

	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新 OilSupplierCertAppend 的 SupplierId  SupplierCertId
// @Description get user by token
// @Success 200 {object}
// @router /updateOilSupplierCertAppend [get]
func (this *TmpzcgfController) UpdateOilSupplierCertAppend(){
	fmt.Println("=============开始更新CertAppend==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============开始CertAppend结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)


	err = svc.UpOilSupplierCertAppend()

	//var appendlist []suppliercertappend.OilSupplierCertAppend
	//var certlist  []suppliercert.OilSupplierCert
	//var  append  suppliercertappend.OilSupplierCertAppend
	//svc.GetEntities(&appendlist, "")
	//svc.GetEntities(&certlist, "CreateBy='导入'")
	//
	//for _,annu := range appendlist {
	//	for _,cert := range certlist {
	//		if annu.OldId == cert.GfId && annu.AppendType == cert.SupplierTypeCode{
	//			fmt.Println(annu.OldId, cert.GfId, cert.OutsideFlog, annu.AppendType, cert.SupplierTypeCode)
	//			col := []string{"SupplierId", "SupplierCertId"}
	//			append.SupplierId = cert.SupplierId
	//			append.SupplierCertId = cert.Id
	//			//where := "Id=" + strconv.Itoa(annu.Id)
	//			_,err = svc.UpdateEntityByIdCols(annu.Id, &append, col)
	//			if err != nil {
	//				session.Rollback()
	//			}
	//			break
	//		}
	//	}
	//}

	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)



}

// @Title 导入缴费记录
// @Description get user by token
// @Success 200 {object}
// @router /insterOilPaymentInfo [get]
func (this *TmpzcgfController) InsterOilPaymentInfo(){
	fmt.Println("=============导入交费记录开始==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============导入交费记录结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertOilPaymentInfo()
	if err != nil {
		session.Rollback()
	}
	err = svc.UpdateOilPaymentInfo()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 导入不良记录
// @Description get user by token
// @Success 200 {object}
// @router /insterBadRecord [get]
func (this *TmpzcgfController) InsterBadRecord(){
	fmt.Println("=============导入不良记录开始==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============导入不良记录结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsterBadRecord()

	if err != nil {
		session.Rollback()
	}
	err = svc.UpdateBadRecord()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新tmp_zcgf
// @Description get user by token
// @Success 200 {object}
// @router /updatezcgf [get]
//func (this *TmpzcgfController) Updatezcgf(){
//
//	t := time.Now()
//	session := utils.DBE.NewSession()
//	defer func() {
//		session.Close()
//	}()
//	var zcgflist []tmpzcgf.Tmpzcgf
//	svc := tmpzcgf.GetTmpzcgtService(session)
//	err := session.Begin()
//	svc.GetEntitysByWhere("tmp_zcgf_l", "", &zcgflist)
//	for _,zcgf := range zcgflist{
//		t,err := time.Parse("2006-01-02", zcgf.成立时间)
//		if err != nil {
//			fmt.Println(err)
//		}
//	}
//
//}

// @Title 导入准入范围
// @Description get user by token
// @Success 200 {object}
// @router /insertCertSub [get]
func (this *TmpzcgfController) InsertCertSub(){
	fmt.Println("=============开始导入准入范围==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============导入准入范围结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertCertSub()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新OilSupplierCertSub表的SupplierId CertId
// @Description get user by token
// @Success 200 {object}
// @router /updateOilSupplierCertSub [get]
func (this *TmpzcgfController) UpdateOilSupplierCertSub(){
	fmt.Println("=============开始更新准入范围==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============更新范围结束==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	var supplierlist []supplier.OilSupplier
	where := "CreateBy='导入'"
	svc.GetEntities(&supplierlist, where)
	for _,item := range supplierlist {
		where := "where b.Type = '1' and b.CreateBy='导入1' and b.Remark = '" + item.SupplierName + "'"
		err = svc.UpdateCertSub(where)
		if err != nil {
			session.Rollback()
		}
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新OilSupplierCertSub表的SupplierId CertId
// @Description get user by token
// @Success 200 {object}
// @router /updateCertSubclassID [get]
func (this *TmpzcgfController) UpdateCertSubclassID(){
	fmt.Println("=============开始更新编码ID==========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("=============导入更新编码ID==========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	var supplierlist []supplier.OilSupplier
	where := "CreateBy='导入'"
	svc.GetEntities(&supplierlist, where)
	for _,item := range supplierlist {
		where := " and  b.Type = '1' and b.CreateBy='导入1' and b.Remark = '" + item.SupplierName + "'"
		err = svc.UpdateCertSub01classId(where)
		if err != nil {
			session.Rollback()
			return
		}
		err = svc.UpdateCertSub02classId(where)
		if err != nil {
			session.Rollback()
			return
		}
		err = svc.UpdateCertSub03classId(where)
		if err != nil {
			session.Rollback()
			return
		}
	}

	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)


}


// @Title 导入增项申请
// @Description get user by token
// @Success 200 {object}
// @router /insertOilSupplierCertAppend [get]
func (this *TmpzcgfController) InsertOilSupplierCertAppend(){
	fmt.Println("==========导入增项申请开始=========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("==========导入增项申请结束=========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertOilSupplierCertAppend()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 导入信息变更
// @Description get user by token
// @Success 200 {object}
// @router /insertOilInfoChange [get]
func (this *TmpzcgfController) InsertOilInfoChange(){
	fmt.Println("==========导入信息变更开始=========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("==========导入信息变更结束=========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertOilInfoChange()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 导入增项的准入范围
// @Description get user by token
// @Success 200 {object}
// @router /insertOilSupplierCertSub [get]
func (this *TmpzcgfController) InsertOilSupplierCertSub(){
	fmt.Println("==========导入增项的准入范围开始=========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("==========导入增项的准入范围结束=========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.InsertOilSupplierCertSub()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新
// @Description get user by token
// @Success 200 {object}
// @router /updateOilInfoChange [get]
func (this *TmpzcgfController) UpdateOilInfoChange(){
	fmt.Println("==========更新信息变更开始=========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("==========更新信息变更结束=========")
		session.Close()
	}()
	err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(session)
	err = svc.UpdateOilInfoChange()
	if err != nil {
		session.Rollback()
	}
	err = session.Commit()
	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title 跟新
// @Description get user by token
// @Success 200 {object}
// @router /updateCertSubIsType1 [get]
func (this *TmpzcgfController) UpdateCertSubIsType1(){
	fmt.Println("==========更新增项的准入范围=========")
	t := time.Now()
	session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("==========增项的准入范围结束=========")
		session.Close()
	}()
	err := session.Begin()


	var supplierlist []supplier.OilSupplier
	where := "CreateBy='导入'"
	svc := tmpzcgf.GetTmpzcgtService(session)
	svc.GetEntities(&supplierlist, where)
	for _,item := range supplierlist {
		fmt.Println(item.SupplierName)
		where := "where b.Type = '3' and b.ModifiedBy = '" + item.SupplierName + "'"
		err = svc.UpdateCertSubIsType2(where)
		if err != nil {
			session.Rollback()
		}
		err = session.Commit()
	}


	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
}

// @Title g更新
// @Description get user by token
// @Success 200 {object}
// @router /updateCertSubIsType3 [get]
func (this *TmpzcgfController) UpdateCertSubIsType3(){
	fmt.Println("==========更新增项的准入范围=========")
	t := time.Now()
	svc := tmpzcgf.GetTmpzcgfService1(utils.DBE)
	err := svc.UpdateCertSubIsType3()

	fmt.Println(err)
	elapsed := time.Since(t)
	fmt.Println(elapsed)
	fmt.Println("==========更新增项的准入范围结束=========")
}

// @Title 清空临时数据
// @Description get user by token
// @Success 200 {object}
// @router /cleattmpdata [get]
func (this *TmpzcgfController) ClearTmpData(){
	fmt.Println("==========清空临时数据=========")
	t := time.Now()
	svc := tmpzcgf.GetTmpzcgfService1(utils.DBE)
	var cert suppliercert.OilSupplierCert
	cert.OutsideFlog = ""
	cols := []string{
		"OutsideFlog",
	}
	svc.UpdateEntityBywheretbl("OilSupplierCert", cert, cols, "")

	var certsub suppliercertsub.OilSupplierCertSub
	certsub.Remark = ""
	certsub.ModifiedBy = ""
	colssub := []string{
		"Remark",
		"ModifiedBy",
	}
	svc.UpdateEntityBywheretbl("OilSupplierCertSub", certsub, colssub, "")

	var infoc infochange.OilInfoChange
	infoc.HouseNo = ""
	colinfo := []string{
		"HouseNo",
	}
	svc.UpdateEntityBywheretbl("OilInfoChange", colinfo, colinfo, "")
	elapsed := time.Since(t)
	fmt.Println(elapsed)
	fmt.Println("==========结束=========")
}