supplier_system/src/dashoo.cn/backend/api/controllers/tmpzcgf/tmpzcgf.go

package tmpzcgf

import (
	"dashoo.cn/backend/api/business/oilsupplier/basisbuild"
	"dashoo.cn/backend/api/business/oilsupplier/goodsaptitudeclass"
	"dashoo.cn/backend/api/business/oilsupplier/suppliercertappend"
	"dashoo.cn/backend/api/business/oilsupplier/technologyserviceclass"
	"fmt"
	"strconv"
	"time"

	"dashoo.cn/backend/api/business/oilsupplier/infochange"
	"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() {
		elapsed := time.Since(t)
		fmt.Println("=============开始CertAppend结束==========", t, elapsed)
		// 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()

}

// @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() {
		elapsed := time.Since(t)
		fmt.Println("=============更新范围结束==========", t, elapsed)
		// session.Close()
	}()
	// err := session.Begin()
	svc := tmpzcgf.GetTmpzcgtService(utils.DBE)
	///////////////////
	//err := svc.UpdateCertSub()
	err := svc.UpdateCertSubCaseWhen()
	if err != nil {
		// session.Rollback()
		fmt.Println(err)
	}
	///////////////////
	/**
	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()
}

// @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 goodsAptitudeClassList []goodsaptitudeclass.OilGoodsAptitudeClass
	where := "1=1"
	svc.GetEntities(&goodsAptitudeClassList, where)
	for _, item := range goodsAptitudeClassList {
		sql := "UPDATE OilSupplierCertSub SET SubClassId = " + strconv.Itoa(item.Id)  + " WHERE SupplierTypeCode = '01' and Code = '" + item.Code + "'"
		svc.DBE.Query(sql)
	}

	var basisBuildList []basisbuild.OilBasisBuild
	where1 := "1=1"
	svc.GetEntities(&basisBuildList, where1)
	for _, item := range basisBuildList {
		sql := "UPDATE OilSupplierCertSub SET SubClassId = " + strconv.Itoa(item.Id)  + " WHERE SupplierTypeCode = '02' and Code = '" + item.Code + "'"
		svc.DBE.Query(sql)
	}

	var technologyServiceClassList []technologyserviceclass.OilTechnologyServiceClass
	where2 := "1=1"
	svc.GetEntities(&technologyServiceClassList, where2)
	for _, item := range technologyServiceClassList {
		sql := "UPDATE OilSupplierCertSub SET SubClassId = " + strconv.Itoa(item.Id)  + " WHERE SupplierTypeCode = '03' and Code = '" + item.Code + "'"
		svc.DBE.Query(sql)
	}

	// 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() {
		elapsed := time.Since(t)
		fmt.Println("==========导入增项申请结束=========", t, elapsed)
		// 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)
}

// @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 /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 /updateOilSupplierCertAppendSub [get]
func (this *TmpzcgfController) UpdateOilSupplierCertAppendSub() {
	fmt.Println("==========更新增项的准入范围=========")
	t := time.Now()
	// session := utils.DBE.NewSession()
	defer func() {
		elapsed := time.Since(t)
		fmt.Println("==========增项的准入范围结束=========", t, elapsed)
		// session.Close()
	}()
	// err := session.Begin()

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

// @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 append suppliercertappend.OilSupplierCertAppend
	append.Remark = ""
	append.ModifiedBy = ""
	colsAppend := []string{
		"Remark",
		"ModifiedBy",
	}
	svc.UpdateEntityBywheretbl("OilSupplierCertAppend", append, colsAppend, "")

	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 := suppliercertsub.GetOilSupplierCertSubService(utils.DBE)
	// 供应商
	var supplierCertSubList []suppliercertsub.OilSupplierCertSub
	wheresup := " SupplierTypeCode='01' and LENGTH(CODE) < 8 "
	svc.GetEntities(&supplierCertSubList, wheresup)
	// 准入项
	totalLen := len(supplierCertSubList)
	for certSubIdx, supplierCertSub := range supplierCertSubList {

		var goodsAptitudeClassList []goodsaptitudeclass.OilGoodsAptitudeClass
		whereclass := "Code like '" + supplierCertSub.Code + "%' and LENGTH(CODE) = 8"
		svc.GetEntities(&goodsAptitudeClassList, whereclass)

		totalClassLen := len(goodsAptitudeClassList)
		elapsed1 := time.Since(t)
		fmt.Sprintf("编码扩充总条数：%d, 当前序号：%d, 编码条数：%d,  总计时间：%s \n",
			totalLen, certSubIdx, totalClassLen, elapsed1)

		// 扩充的编码
		var entityList []suppliercertsub.OilSupplierCertSub
		for classIdx, 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 = "编码扩充"
			// 按最多200行insert一次
			if (classIdx + 1) % 200 == 0 || (classIdx + 1) == len(goodsAptitudeClassList) {
				// 加入本行数据
				entityList = append(entityList, entity)
				//执行insert操作
				svc.InsertEntityBytbl(OilSupplierCertSubName, &entityList)
				// 清空数组
				entityList = entityList[0:0]
			} else {
				entityList = append(entityList, entity)
			}
		}
	}
	// wheredel := "Id = " + strconv.Itoa(supplierCertSub.Id)
	svc.DeleteEntityBytbl(OilSupplierCertSubName, wheresup)

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

}

// @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.Query(sql)

	//sql = "truncate table OilCorporateInfo"
	//svc.DBE.Query(sql)

	sql = "truncate table OilEnterpriseMajorEquipment"
	svc.DBE.Query(sql)

	sql = "truncate table OilInfoChange"
	svc.DBE.Query(sql)

	sql = "truncate table OilInfoChangeItem"
	svc.DBE.Query(sql)

	sql = "truncate table OilPatentStatistical"
	svc.DBE.Query(sql)

	sql = "truncate table OilPaymentInfo"
	svc.DBE.Query(sql)

	sql = "truncate table OilQualChangeDetail"
	svc.DBE.Query(sql)

	sql = "truncate table OilQualChangeMain"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplier"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierCert"
	svc.DBE.Query(sql)

	// TODO: 删除准入范围和资质对应关系表
	/*sql = "truncate table OilSupplierCert2File"
	svc.DBE.Query(sql)*/

	sql = "truncate table OilSupplierCertAppend"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierCertAppendSub"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierCertSub"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierFile"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierOldInfo"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierOpinion"
	svc.DBE.Query(sql)

	sql = "truncate table OilThreeYearsPerformance"
	svc.DBE.Query(sql)

	sql = "truncate table OilWinningProject"
	svc.DBE.Query(sql)

	sql = "truncate table s5OVEDocumentHistory"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilAnnualAudit"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilInfoChange"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilPaymentInfo"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilSupplier"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilSupplierCert"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilSupplierCertAppend"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilSupplierCertSub"
	svc.DBE.Query(sql)

	sql = "truncate table Del_OilSupplierFile"
	svc.DBE.Query(sql)

	sql = "truncate table Manufacturer"
	svc.DBE.Query(sql)

	sql = "truncate table BadRecord"
	svc.DBE.Query(sql)

	sql = "truncate table BadRecordHistory"
	svc.DBE.Query(sql)

	sql = "truncate table Base_AuditHistory"
	svc.DBE.Query(sql)

	sql = "truncate table OilSupplierSceneFile"
	svc.DBE.Query(sql)

	// 设置环境变量
	svc.DBE.Query("set session bulk_insert_buffer_size = 120 * 1024 * 1024;")

	fmt.Println("==========truncate table结束=========")

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

		this.InsertSupplier()
		this.InsertSupplierCert()
		this.UpdateCertTypeAndInflag()
		this.UpdateSupplierId()
		this.InsertFileName()
		this.InsertCertSub() // 准入
		this.UpdateOilSupplierCertSub()
		this.InsertOilSupplierCertAppend()
		this.UpdateOilSupplierCertAppend()
		this.UpdateOilSupplierCertAppendSub() // 更新增项的准入范围
		this.UpdateCertSubclassID()
		//this.CapacityExpansion() // 编码扩充 --弃用
		//历史数据导入-由于运行到此处中断，上面的代码临时注释
		this.InsterAnnualAudit()
		this.UpdateAnnualAudit()
		this.InsterOilPaymentInfo()
		this.InsterBadRecord()
		this.InsertOilInfoChange()
		this.UpdateOilInfoChange()
		this.DelBadRecord()

		this.ClearTmpData()
	}()

	var errinfo ErrorInfo
	errinfo.Message = "导入命令下达成功，详情请看后台运行日志，注意不要重复点击！"
	errinfo.Code = 0
	this.Data["json"] = &errinfo
	this.ServeJSON()
}