同步数据到上海修改日志记录方式

models/db.go

@@ -87,5 +87,6 @@ func init() {
 		new(CygxUserSearchKeyWord),
 		new(CompanyReportPermission),
 		new(CygxShanghaiCompanyLog),
+		new(CygxShanghaiErrLog),
 	)
 }

models/shanghai_company_log.go

@@ -19,3 +19,18 @@ func AddCygxShanghaiCompanyLog(item *CygxShanghaiCompanyLog) (lastId int64, err
 	lastId, err = o.Insert(item)
 	return
 }
+
+type CygxShanghaiErrLog struct {
+	Id         int `orm:"column(id);pk"`
+	ErrVal     string
+	ErrMsg     string
+	ErrType    string
+	CreateTime time.Time
+}
+
+//添加日志记录
+func AddCygxShanghaiErrLog(item *CygxShanghaiErrLog) (lastId int64, err error) {
+	o := orm.NewOrm()
+	lastId, err = o.Insert(item)
+	return
+}

services/send_company_user.go

@@ -42,10 +42,10 @@ type ShangHaiResultApidateComPany struct {
 }
 
 //c
-func SendComapnyToShanghai(url, jsonCompany string) {
+func SendComapnyToShanghai(url, jsonCompany, postType string) {
 	method := "POST"
 	//fmt.Println(string(jsonCompany))
-	utils.FileLog.Info(string(jsonCompany))
+	//utils.FileLog.Info(string(jsonCompany))
 	payload := strings.NewReader(jsonCompany)
 	client := &http.Client{}
 	req, err := http.NewRequest(method, url, payload)
@@ -65,7 +65,7 @@ func SendComapnyToShanghai(url, jsonCompany string) {
 		fmt.Println(err)
 		return
 	}
-	var result GetShangHaiTokenResultApi
+	var result GetShangHaiTokenResultApiComPany
 	err = json.Unmarshal(body, &result)
 	if err != nil {
 		fmt.Println("Getres.pdfResult Err:", err.Error())
@@ -84,11 +84,19 @@ func SendComapnyToShanghai(url, jsonCompany string) {
 		go utils.SendEmail("同步策略平台信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), string(body), utils.EmailSendToExpert)
 	}
 	//var companyCode string
-	//for _, v := range result.Data.FailInfo {
-	//	if v.ErrMsg == "c" {
-	//		companyCode += "'" + v.ErrVal + "',"
-	//	}
-	//}
+	for _, v := range result.Data.FailInfo {
+		if v.ErrMsg != "" {
+			//companyCode += "'" + v.ErrVal + "',"
+			item := new(models.CygxShanghaiErrLog)
+			item.CreateTime = time.Now()
+			item.ErrMsg = v.ErrMsg
+			item.ErrVal = v.ErrVal
+			item.ErrType = postType
+			go models.AddCygxShanghaiErrLog(item)
+		}
+	}
+	//给产品导数据用，别删
+	//companyCode = postType + companyCode
 	////fmt.Println(result.Data.FailInfo)
 	//utils.FileLog.Info(string(companyCode))
 	//utils.FileLog.Info(string(body))
@@ -101,7 +109,6 @@ func DotongbuShangHai(cont context.Context) (err error) {
 		if err != nil {
 			go utils.SendEmail("同步策略平台获取数据信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
 		}
-		fmt.Println("line 21", err, msg)
 	}()
 	//获取token
 	url := "https://crm.hzinsights.com/openapi/v1/auth/getAccessToken?app_key=26945134&app_secret=b99cb2bdec70d20156000f664ec5ac30"
@@ -154,7 +161,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
 				}
 				jsonstr := string(data)
 				jsonstr = "{\"sync_data\": " + jsonstr + " }"
-				SendComapnyToShanghai(url, jsonstr)
+				SendComapnyToShanghai(url, jsonstr, "权益")
 				companyItems = make([]*models.CompanyJson, 0)
 			}
 		}
@@ -167,7 +174,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
 			}
 			jsonstr := string(data)
 			jsonstr = "{\"sync_data\": " + jsonstr + " }"
-			SendComapnyToShanghai(url, jsonstr)
+			SendComapnyToShanghai(url, jsonstr, "权益")
 			companyItems = make([]*models.CompanyJson, 0)
 		}
 	}
@@ -194,7 +201,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
 				}
 				jsonstr := string(data)
 				jsonstr = "{\"sync_data\": " + jsonstr + " }"
-				SendComapnyToShanghai(url, jsonstr)
+				SendComapnyToShanghai(url, jsonstr, "FICC")
 				companyFiccItems = make([]*models.CompanyJson, 0)
 			}
 		}
@@ -207,7 +214,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
 			}
 			jsonstr := string(data)
 			jsonstr = "{\"sync_data\": " + jsonstr + " }"
-			SendComapnyToShanghai(url, jsonstr)
+			SendComapnyToShanghai(url, jsonstr, "FICC")
 		}
 	}
 
@@ -248,7 +255,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
 				fmt.Println(k)
 				jsonstr := string(data)
 				jsonstr = "{\"sync_data\": " + jsonstr + " }"
-				SendComapnyToShanghai(url, jsonstr)
+				SendComapnyToShanghai(url, jsonstr, "user")
 				userItems = make([]*models.UserJson, 0)
 			}
 		}
@@ -262,7 +269,7 @@ func DotongbuShangHai(cont context.Context) (err error) {
 			}
 			jsonstr := string(data)
 			jsonstr = "{\"sync_data\": " + jsonstr + " }"
-			SendComapnyToShanghai(url, jsonstr)
+			SendComapnyToShanghai(url, jsonstr, "user")
 			companyItems = make([]*models.CompanyJson, 0)
 		}
 	}