增加日志几率

http/internal/server/http/erp/company.go

@@ -55,13 +55,13 @@ func GetCompanyInfo(c *bm.Context)  {
 	companyName,_ := c.Params.Get("company_name")
 	db,closedb,err := dao.NewDB()
 	if err != nil {
-		fmt.Println(err)
+		log.Error(err.Error())
 	}
 	err = db.QueryRow(c,SELECTERPCOMBASIC,companyName).Scan(&erpCompanyInfo.ComName,&erpCompanyInfo.ComOrganization,&erpCompanyInfo.EstanlishmentTime,
 	&erpCompanyInfo.CustomerProperty,&erpCompanyInfo.RegisteredCapital,&erpCompanyInfo.LegalRepresentative,&erpCompanyInfo.TianyanchaJson,&erpCompanyInfo.ComAddress)
 
 	if err != nil {
-		fmt.Println(err)
+		log.Error(err.Error())
 	}
 
 	jsonArr := strings.Split(erpCompanyInfo.TianyanchaJson,"||||")
@@ -98,14 +98,14 @@ func PushCompanyMq(c *bm.Context,companyName string)  {
 
 	currentTime := time.Now().Unix()
 	sqlResult,err := db.Exec(c,member.INSERTCOMPANY,companyName,currentTime,currentTime)
-	lastid,_ := sqlResult.LastInsertId()
+	lastid,err := sqlResult.LastInsertId()
 	//如果添加没问题，就继续添加
 	if err != nil {
-		fmt.Println(err)
+		log.Error(err.Error())
 	}else{
 		_,err  = db.Exec(c,member.INSERTCOMPANYBASICINFO,lastid,companyName,currentTime)
 		if err != nil {
-			fmt.Println(err)
+			log.Error(err.Error())
 		}
 	}