|
@@ -135,9 +135,13 @@ func (this *TmpzcgfController) UpdateSupplierId(){
|
|
|
// @Success 200 {object}
|
|
// @Success 200 {object}
|
|
|
// @router /insterannualaudit [get]
|
|
// @router /insterannualaudit [get]
|
|
|
func (this *TmpzcgfController) InsterAnnualAudit(){
|
|
func (this *TmpzcgfController) InsterAnnualAudit(){
|
|
|
|
|
+ fmt.Println("=============开始导入年审表==========")
|
|
|
t := time.Now()
|
|
t := time.Now()
|
|
|
session := utils.DBE.NewSession()
|
|
session := utils.DBE.NewSession()
|
|
|
- defer session.Close()
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ fmt.Println("=============导入年审表结束==========")
|
|
|
|
|
+ session.Close()
|
|
|
|
|
+ }()
|
|
|
err := session.Begin()
|
|
err := session.Begin()
|
|
|
svc := tmpzcgf.GetTmpzcgtService(session)
|
|
svc := tmpzcgf.GetTmpzcgtService(session)
|
|
|
err = svc.InsterAnnual()
|
|
err = svc.InsterAnnual()
|
|
@@ -155,9 +159,13 @@ func (this *TmpzcgfController) InsterAnnualAudit(){
|
|
|
// @Success 200 {object}
|
|
// @Success 200 {object}
|
|
|
// @router /updateAnnualAudit [get]
|
|
// @router /updateAnnualAudit [get]
|
|
|
func (this *TmpzcgfController) UpdateAnnualAudit(){
|
|
func (this *TmpzcgfController) UpdateAnnualAudit(){
|
|
|
|
|
+ fmt.Println("=============开始更新年审表==========")
|
|
|
t := time.Now()
|
|
t := time.Now()
|
|
|
session := utils.DBE.NewSession()
|
|
session := utils.DBE.NewSession()
|
|
|
- defer session.Close()
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ fmt.Println("=============开始年审表结束==========")
|
|
|
|
|
+ session.Close()
|
|
|
|
|
+ }()
|
|
|
err := session.Begin()
|
|
err := session.Begin()
|
|
|
svc := tmpzcgf.GetTmpzcgtService(session)
|
|
svc := tmpzcgf.GetTmpzcgtService(session)
|
|
|
err = svc.UpdateOilAnnualAudit()
|
|
err = svc.UpdateOilAnnualAudit()
|
|
@@ -196,9 +204,13 @@ func (this *TmpzcgfController) UpdateAnnualAudit(){
|
|
|
// @Success 200 {object}
|
|
// @Success 200 {object}
|
|
|
// @router /updateOilSupplierCertAppend [get]
|
|
// @router /updateOilSupplierCertAppend [get]
|
|
|
func (this *TmpzcgfController) UpdateOilSupplierCertAppend(){
|
|
func (this *TmpzcgfController) UpdateOilSupplierCertAppend(){
|
|
|
|
|
+ fmt.Println("=============开始更新年审表==========")
|
|
|
t := time.Now()
|
|
t := time.Now()
|
|
|
session := utils.DBE.NewSession()
|
|
session := utils.DBE.NewSession()
|
|
|
- defer session.Close()
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ fmt.Println("=============开始年审表结束==========")
|
|
|
|
|
+ session.Close()
|
|
|
|
|
+ }()
|
|
|
err := session.Begin()
|
|
err := session.Begin()
|
|
|
svc := tmpzcgf.GetTmpzcgtService(session)
|
|
svc := tmpzcgf.GetTmpzcgtService(session)
|
|
|
var appendlist []suppliercertappend.OilSupplierCertAppend
|
|
var appendlist []suppliercertappend.OilSupplierCertAppend
|
|
@@ -238,10 +250,11 @@ func (this *TmpzcgfController) UpdateOilSupplierCertAppend(){
|
|
|
// @Success 200 {object}
|
|
// @Success 200 {object}
|
|
|
// @router /insterOilPaymentInfo [get]
|
|
// @router /insterOilPaymentInfo [get]
|
|
|
func (this *TmpzcgfController) InsterOilPaymentInfo(){
|
|
func (this *TmpzcgfController) InsterOilPaymentInfo(){
|
|
|
|
|
+ fmt.Println("=============导入缴费记录开始==========")
|
|
|
t := time.Now()
|
|
t := time.Now()
|
|
|
session := utils.DBE.NewSession()
|
|
session := utils.DBE.NewSession()
|
|
|
defer func() {
|
|
defer func() {
|
|
|
- fmt.Println("+++++++++++")
|
|
|
|
|
|
|
+ fmt.Println("=============导入缴费记录结束==========")
|
|
|
session.Close()
|
|
session.Close()
|
|
|
}()
|
|
}()
|
|
|
err := session.Begin()
|
|
err := session.Begin()
|
|
@@ -265,9 +278,11 @@ func (this *TmpzcgfController) InsterOilPaymentInfo(){
|
|
|
// @Success 200 {object}
|
|
// @Success 200 {object}
|
|
|
// @router /insterBadRecord [get]
|
|
// @router /insterBadRecord [get]
|
|
|
func (this *TmpzcgfController) InsterBadRecord(){
|
|
func (this *TmpzcgfController) InsterBadRecord(){
|
|
|
|
|
+ fmt.Println("=============导入不良记录开始==========")
|
|
|
t := time.Now()
|
|
t := time.Now()
|
|
|
session := utils.DBE.NewSession()
|
|
session := utils.DBE.NewSession()
|
|
|
defer func() {
|
|
defer func() {
|
|
|
|
|
+ fmt.Println("=============导入不良记录结束==========")
|
|
|
session.Close()
|
|
session.Close()
|
|
|
}()
|
|
}()
|
|
|
err := session.Begin()
|
|
err := session.Begin()
|
|
@@ -311,7 +326,7 @@ func (this *TmpzcgfController) InsterBadRecord(){
|
|
|
//
|
|
//
|
|
|
//}
|
|
//}
|
|
|
|
|
|
|
|
-// @Title 导入年审
|
|
|
|
|
|
|
+// @Title 导入准入范围
|
|
|
// @Description get user by token
|
|
// @Description get user by token
|
|
|
// @Success 200 {object}
|
|
// @Success 200 {object}
|
|
|
// @router /insertCertSub [get]
|
|
// @router /insertCertSub [get]
|
|
@@ -407,4 +422,101 @@ func (this *TmpzcgfController) UpdateCertSubclassID(){
|
|
|
fmt.Println(elapsed)
|
|
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)
|
|
|
}
|
|
}
|