no message

models/send_company_user.go

@@ -81,7 +81,6 @@ func GetSendCompanyList() (items []*CompanyJson, err error) {
 			AND a.STATUS IN ( '正式', '试用' )
 			AND( c.credit_code LIKE '91%'  OR  c.credit_code LIKE 'HZ%' ) 
 			AND p.product_id = 2
-			AND c.credit_code IN ('91469027MA5TW2803X','91330104MA27W2L868','913101133986714446','9144030059070789XY')
 		GROUP BY
 			c.company_id  `
 	_, err = o.Raw(sql).QueryRows(&items)
@@ -99,7 +98,7 @@ func GetSendCompanyFiccList() (items []*CompanyJson, err error) {
 			p.industry_name,
 			am.real_name,
 			am.mobile,
-			a.STATUS,
+			a.status,
 			UNIX_TIMESTAMP( p.start_date ) AS start_date,
 			UNIX_TIMESTAMP( p.end_date ) AS end_date,
 			UNIX_TIMESTAMP( a.created_time ) AS created_time,
@@ -131,8 +130,7 @@ func GetSendCompanyFiccList() (items []*CompanyJson, err error) {
 			AND p.STATUS IN ( '正式', '试用' ) 
 			AND a.STATUS IN ( '正式', '试用' ) 
 			AND ( c.credit_code LIKE '91%' OR c.credit_code LIKE 'HZ%' ) 
-			AND p.product_id = 1 
-AND c.credit_code IN ('91469027MA5TW2803X','91330104MA27W2L868','913101133986714446','9144030059070789XY')
+			AND p.product_id = 1
 			AND c.company_id NOT IN (
 			SELECT
 				c.company_id 
@@ -150,8 +148,7 @@ AND c.credit_code IN ('91469027MA5TW2803X','91330104MA27W2L868','913101133986714
 				AND p.STATUS IN ( '正式', '试用' ) 
 				AND a.STATUS IN ( '正式', '试用' ) 
 				AND ( c.credit_code LIKE '91%' OR c.credit_code LIKE 'HZ%' ) 
-				AND p.product_id = 2 
-				AND c.credit_code IN ('91469027MA5TW2803X','91330104MA27W2L868','913101133986714446','9144030059070789XY')
+				AND p.product_id = 2
 			GROUP BY
 				c.company_id 
 			) 
@@ -200,13 +197,12 @@ func GetSendUserList() (items []*UserJson, err error) {
 				AND p.STATUS IN ( '正式', '试用' ) 
 				AND a.STATUS IN ( '正式', '试用' )
 				AND us.create_time  != ''
-				AND c.credit_code IN ('9144030059070789XY')
-
 			GROUP BY
 				c.company_id 
-			) 
-			AND c.credit_code != '' `
-	//AND c.credit_code IN ('91469027MA5TW2803X','91330104MA27W2L868','913101133986714446','9144030059070789XY')
+			)
+AND 	c.credit_code  IN ('91310000625910522N')
+			AND us.create_time != '' 
+			AND ( c.credit_code LIKE '91%' OR c.credit_code LIKE 'HZ%' ) GROUP BY u.user_id   ORDER BY  c.company_id  DESC `
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }

services/send_company_user.go

@@ -22,10 +22,26 @@ type ShangHaiResultApidate struct {
 	ExpireIn    int    `json:"expire_in"`
 }
 
+type GetShangHaiTokenResultApiComPany struct {
+	Code int       `json:"code"`
+	Msg  string    `json:"msg"`
+	Time int       `json:"time"`
+	Data FailInfos `json:"data"`
+}
+type FailInfos struct {
+	TotalCount int                            `json:"total_count"`
+	FailInfo   []ShangHaiResultApidateComPany `json:"fail_info"`
+}
+
+type ShangHaiResultApidateComPany struct {
+	ErrVal string `json:"errVal"`
+	ErrMsg string `json:"errMsg"`
+}
+
 //把信息同步到上海策略品台
 func SendComapnyToShanghai(url, jsonCompany string) {
 	method := "POST"
-	fmt.Println(string(jsonCompany))
+	//fmt.Println(string(jsonCompany))
 	utils.FileLog.Info(string(jsonCompany))
 	payload := strings.NewReader(jsonCompany)
 	client := &http.Client{}
@@ -46,8 +62,21 @@ func SendComapnyToShanghai(url, jsonCompany string) {
 		fmt.Println(err)
 		return
 	}
+	var result GetShangHaiTokenResultApiComPany
+	err = json.Unmarshal(body, &result)
+	if err != nil {
+		fmt.Println("Getres.pdfResult Err:", err.Error())
+	}
+	var companyCode string
+	for _, v := range result.Data.FailInfo {
+		if v.ErrMsg == "公司名称权益CRM已存在对应客户" {
+			companyCode += "'" + v.ErrVal + "',"
+		}
+	}
+	//fmt.Println(result.Data.FailInfo)
+	utils.FileLog.Info(string(companyCode))
 	utils.FileLog.Info(string(body))
-	fmt.Println(string(body))
+	//fmt.Println(string(body))
 }
 
 func Dotognbu() {
@@ -124,7 +153,7 @@ func Dotognbu() {
 	if len(companyFiccList) > 0 {
 		url = "https://crm.hzinsights.com/openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
 		for k, _ := range companyFiccList {
-			companyList[k].Fe = "权益"
+			companyFiccList[k].Fe = "FICC"
 			//一次同步一百条
 			companyFiccItems = append(companyFiccItems, companyFiccList[k])
 			if (k+1)%100 == 0 {