package tmpzcgf

import (
	"fmt"
	"strconv"
	"time"

	"dashoo.cn/backend/api/business/oilsupplier/goodsaptitudeclass"
	"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"
)

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(utils.DBE)
	err := svc.InsertSupplier()
	if err != nil {
		fmt.Println(err)
		// session.Rollback()
	}
	//err = session.Commit()

	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(utils.DBE)
	err := svc.InsertSupplierCert()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// err = session.Commit()
	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(utils.DBE)
	err := svc.UpdateSupplierTypeCodeAndInFlag()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// err = session.Commit()
	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(utils.DBE)
	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(utils.DBE)
	err := svc.InsterAnnual()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// err = session.Commit()
	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(utils.DBE)
	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()
	if err != nil {
		// session.Rollback()
		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(utils.DBE)

	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()
		fmt.Println(err)
	}
	// err = session.Commit()

	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(utils.DBE)
	err := svc.InsertOilPaymentInfo()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	err = svc.UpdateOilPaymentInfo()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// err = session.Commit()
	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(utils.DBE)
	err := svc.InsterBadRecord()

	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	err = svc.UpdateBadRecord()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// err = session.Commit()
	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(utils.DBE)
	err := svc.InsertCertSub()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// err = session.Commit()
	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(utils.DBE)
	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()
			fmt.Println(err)
		}
	}
	// err = session.Commit()
	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(utils.DBE)
	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 {
			fmt.Println(err)
			// session.Rollback()
			// return
		}
		err = svc.UpdateCertSub02classId(where)
		if err != nil {
			fmt.Println(err)
			//session.Rollback()
			//return
		}
		err = svc.UpdateCertSub03classId(where)
		if err != nil {
			fmt.Println(err)
			// 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(utils.DBE)
	err := svc.InsertOilSupplierCertAppend()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// 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(utils.DBE)
	err := svc.InsertOilInfoChange()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// 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(utils.DBE)
	err := svc.InsertOilSupplierCertSub()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// 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(utils.DBE)
	err := svc.UpdateOilInfoChange()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	// 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(utils.DBE)
	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()
			fmt.Println(err)
		}
		// err = session.Commit()
	}

	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()
	if err != nil {
		// session.Rollback()
		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("==========结束=========")
}

// @Title 跟新
// @Description get user by token
// @Success 200 {object}
// @router /delBadRecord [get]
func (this *TmpzcgfController) DelBadRecord() {
	fmt.Println("==========删除多余的不良记录=========")
	t := time.Now()
	// session := utils.DBE.NewSession()
	defer func() {
		fmt.Println("==========删除多余的不良记录=========")
		// session.Close()
	}()
	// err := session.Begin()

	svc := tmpzcgf.GetTmpzcgtService(utils.DBE)
	where := "CompanyName is null"
	err := svc.DeleteEntityBytbl(BaseBadRecord, where)

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

// @Title OilSupplierCertSub表编码扩容 6位==》8位
// @Description get user by token
// @Success 200 {object}
// @router /capacityexpansion [get]
func (this *TmpzcgfController) CapacityExpansion() {
	fmt.Println("==========编码扩充开始=========")
	t := time.Now()

	svc := supplier.GetOilSupplierService(utils.DBE)
	var suppliercertList []suppliercert.OilSupplierCert
	where := "SupplierTypeCode='01' and InFlag != '3' "
	svc.GetEntities(&suppliercertList, where)

	// 供应商
	for _, suppliercert := range suppliercertList {
		var supplierCertSubList []suppliercertsub.OilSupplierCertSub
		wheresup := "SupplierId = " + strconv.Itoa(suppliercert.SupplierId) + " and SupplierTypeCode='01' and LENGTH(CODE) != 8 "
		svc.GetEntities(&supplierCertSubList, wheresup)
		// 准入项
		for _, supplierCertSub := range supplierCertSubList {
			var goodsAptitudeClassList []goodsaptitudeclass.OilGoodsAptitudeClass
			whereclass := "Code like '" + supplierCertSub.Code + "%' and LENGTH(CODE) = 8"
			svc.GetEntities(&goodsAptitudeClassList, whereclass)

			// 扩充的编码
			/** var entitys = make([]suppliercertsub.OilSupplierCertSub, len(goodsAptitudeClassList))
			for idx, goodsAptitudeClass := range goodsAptitudeClassList {
				entitys[idx].SupplierId = supplierCertSub.SupplierId
				entitys[idx].SupplierCertId = supplierCertSub.SupplierCertId
				entitys[idx].SupplierTypeCode = supplierCertSub.SupplierTypeCode
				entitys[idx].AppendStatus = supplierCertSub.AppendStatus
				entitys[idx].Type = supplierCertSub.Type
				entitys[idx].Name = goodsAptitudeClass.Name
				entitys[idx].Code = goodsAptitudeClass.Code
				entitys[idx].CertSubStatus = supplierCertSub.CertSubStatus
				entitys[idx].Remark = "编码扩充"
			}
			svc.InsertEntityBytbl(OilSupplierCertSubName, &entitys) */
			// fmt.Println("编码扩充:")
			// fmt.Println(entitys)

			for _, goodsAptitudeClass := range goodsAptitudeClassList {
				var entity suppliercertsub.OilSupplierCertSub
				entity.SupplierId = supplierCertSub.SupplierId
				entity.SupplierCertId = supplierCertSub.SupplierCertId
				entity.SupplierTypeCode = supplierCertSub.SupplierTypeCode
				entity.AppendStatus = supplierCertSub.AppendStatus
				entity.Type = supplierCertSub.Type
				entity.Name = goodsAptitudeClass.Name
				entity.Code = goodsAptitudeClass.Code
				entity.CertSubStatus = supplierCertSub.CertSubStatus
				entity.Remark = "编码扩充"
				svc.InsertEntityBytbl(OilSupplierCertSubName, &entity)
			}

			wheredel := "Id = " + strconv.Itoa(supplierCertSub.Id)
			svc.DeleteEntityBytbl(OilSupplierCertSubName, wheredel)

		}

	}

	elapsed := time.Since(t)
	fmt.Println(elapsed)
	fmt.Println("==========编码扩充完成=========")

}

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

// @Title 清空所有资质
// @Description get user by token
// @Success 200 {object}
// @router /clearAll [get]
func (this *TmpzcgfController) ClearAll() {
	fmt.Println("==========truncate table开始=========")
	svc := tmpzcgf.GetTmpzcgtService(utils.DBE)
	sql := "truncate table OilAnnualAudit"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilCorporateInfo"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilEnterpriseMajorEquipment"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilInfoChange"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilInfoChangeItem"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilPatentStatistical"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilPaymentInfo"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilQualChangeDetail"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilQualChangeMain"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplier"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierCert"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierCert2File"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierCertAppend"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierCertAppendSub"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierCertSub"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierFile"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierOldInfo"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilSupplierOpinion"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilThreeYearsPerformance"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table OilWinningProject"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table s5OVEDocumentHistory"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table s5OVEDocumentInfo"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilAnnualAudit"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilInfoChange"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilPaymentInfo"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilSupplier"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilSupplierCert"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilSupplierCertAppend"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilSupplierCertSub"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Del_OilSupplierFile"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Manufacturer"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table BadRecord"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table BadRecordHistory"
	svc.DBE.SQL(sql).Exec()

	sql = "truncate table Base_AuditHistory"
	svc.DBE.SQL(sql).Exec()
	fmt.Println("==========truncate table结束=========")

}
// @Title 一键执行所有导入
// @Description get user by token
// @Success 200 {object}
// @router /insertAll [get]
func (this *TmpzcgfController) InsertAll() {
	//清空所有资质
	this.ClearAll()

	this.InsertSupplier()
	this.InsertSupplierCert()
	this.UpdateCertTypeAndInflag()
	this.UpdateSupplierId()
	this.InsertFileName()
	this.InsertCertSub()
	this.UpdateOilSupplierCertSub()
	this.InsertOilSupplierCertAppend()
	this.UpdateOilSupplierCertAppend()
	this.InsertOilSupplierCertSub()
	this.UpdateCertSubIsType1()

	this.CapacityExpansion()
	this.UpdateCertSubIsType3()
	this.InsterAnnualAudit()
	this.UpdateAnnualAudit()
	this.InsterOilPaymentInfo()
	this.InsterBadRecord()
	this.InsertOilInfoChange()
	this.UpdateOilInfoChange()
	this.DelBadRecord()

	this.ClearTmpData()
}