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

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,7 +42,7 @@ 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))
@@ -83,14 +83,22 @@ func SendComapnyToShanghai(url, jsonCompany string) {
 	if strings.Index(string(body), "必填") > 0 || strings.Index(string(body), "失败") > 0 || strings.Index(string(body), "社会信用代码格式错误") > 0 {
 		go utils.SendEmail("同步策略平台信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), string(body), utils.EmailSendToExpert)
 	}
-	var companyCode string
+	//var companyCode string
 	for _, v := range result.Data.FailInfo {
-		if v.ErrMsg == "社会信用代码权益CRM已存在对应客户" {
-			companyCode += "'" + v.ErrVal + "',"
+		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(companyCode))
 	//utils.FileLog.Info(string(body))
 	//fmt.Println(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)
 		}
 	}