后:目录导入

src/dashoo.cn/backend/api/business/tmpzcgf/tmpzcgfSession.go

@@ -668,3 +668,9 @@ func (s *TmpzcgtSession) UpdateOilCatalog() error {
 	return err
 }
 
+func (s *TmpzcgtSession) UpdateOilCatalog2() error {
+	sql := "UPDATE `OilCatalog` a,( SELECT  b.`LegalPerson`,  b.`Address`,  b.`CommercialNo`,  b.`RegCapital`,  a.`CompanyName` FROM OilCatalog a  LEFT JOIN `OilSupplier` b ON b.`SupplierName` = a.`CompanyName` ) c SET a.`LegalPerson` = c.`LegalPerson`, a.`Address` = c.`Address`, a.`USCCode` = c.`CommercialNo`, a.`RegCapital` = c.`RegCapital` where c.CompanyName=a.CompanyName"
+	_, err := s.DBE.Query(sql)
+	return err
+}
+

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

@@ -773,6 +773,12 @@ func (this *TmpzcgfController) InsertUpdateOilCatalog() {
 		// session.Rollback()
 		fmt.Println(err)
 	}
+
+	err = svc.UpdateOilCatalog2()
+	if err != nil {
+		// session.Rollback()
+		fmt.Println(err)
+	}
 	// err = session.Commit()
 	// fmt.Println(err)
 	elapsed := time.Since(t)