no message

models/send_company_user.go

@@ -6,24 +6,35 @@ import (
 )
 
 type CompanyJson struct {
-	CompanyName  string `json:"name"`        //公司名称
-	ShortName    string `json:"short_name"`  //公司简称
-	CreditCode   string `json:"social"`      //社会信用代码
-	City         string `json:"city"`        //所在地级市或直辖市
-	SignType     string `json:"sign_type"`   //客户重要度（A类、B类、C类、D类）
-	Fe           string `json:"f_e"`         //客户类型（FICC、权益、策略）
-	IndustryName string `json:"industry"`    //所属行业（公募、私募、券商资管、保险、海外、其他类型）
-	Mobile       string `json:"sale_phone"`  //所属销售（销售手机号）
-	Status       string `json:"status"`      //客户状态（正式、试用）
-	Permission   string `json:"permissions"` //客户权限（医药,科技,智造,消费,策略,专家,路演服务,研选）
-	StartDate    string `json:"start_time"`  //服务期限开始时间
-	EndDate      string `json:"end_time"`    //服务期限结束时间
-	Info         string `json:"info"`        //简介
-	CreatedTime  string `json:"create_time"` //创建时间
+	CompanyName    string `json:"name"`            //公司名称
+	ShortName      string `json:"short_name"`      //公司简称
+	CreditCode     string `json:"social"`          //社会信用代码
+	City           string `json:"city"`            //所在地级市或直辖市
+	SignType       string `json:"sign_type"`       //客户重要度（A类、B类、C类、D类）
+	Fe             string `json:"f_e"`             //客户类型（FICC、权益、策略）
+	IndustryName   string `json:"industry"`        //所属行业（公募、私募、券商资管、保险、海外、其他类型）
+	Mobile         string `json:"sale_phone"`      //所属销售（销售手机号）
+	Status         string `json:"status"`          //客户状态（正式、试用）
+	Permission     string `json:"permissions"`     //客户权限（医药,科技,智造,消费,策略,专家,路演服务,研选）
+	StartDate      string `json:"start_time"`      //服务期限开始时间
+	EndDate        string `json:"end_time"`        //服务期限结束时间
+	Info           string `json:"info"`            //简介
+	CreatedTime    string `json:"create_time"`     //创建时间
+	PermissionData string `json:"permission_data"` //创建时间
 	//CreatedTimes string //创建时间
 	EndDateTime time.Time //创建时间
 }
 
+type PermissionDataList struct {
+	PermissionData []*PermissionData
+}
+type PermissionData struct {
+	CreatedTime string `json:"permission_name"` //权限名称
+	StartTime   string `json:"start_time"`      //权限开始时间
+	EndTime     string `json:"end_time"`        //权限结束时间
+	IsTryOut    string `json:"is_try_out"`      //权限是否试用：0=否，1=是
+}
+
 type UserJson struct {
 	CreditCode          string `json:"social"`            //社会信用代码
 	RealName            string `json:"name"`              //昵称

services/send_company_user.go

@@ -106,8 +106,8 @@ func SendComapnyToShanghai(url, jsonCompany, postType string) (err error) {
 	return
 }
 
-func DotongbuShangHai(cont context.Context) (err error) {
-	//func DotongbuShangHai() (err error) {
+//func DotongbuShangHai(cont context.Context) (err error) {
+func DotongbuShangHai() (err error) {
 	//先删除被禁用的用户
 	DeleteUserDotongbuShangHaiApi()
 	var condition string
@@ -168,20 +168,20 @@ func DotongbuShangHai(cont context.Context) (err error) {
 	}
 
 	//偶尔需要单独同步某一个公司的人员
-	//condition = ` AND c.company_id  =  5676  `
+	condition = ` AND c.company_id  =  6901  `
 
 	//同30小时有变更的公司
 	DotongbuShangHaApi(condition)
 
 	//原有的公司如果新增了也同步
-	companyIds = strings.TrimRight(companyIds, ",")
-	if companyIds != "" {
-		condition = ` AND p.is_suspend = 0  AND c.company_id  IN (` + companyIds + ")"
-		DotongbuShangHaApi(condition)
-	}
-
-	//处理被禁用的用户，将禁用用户的状态同步
-	CompanySuspend()
+	//companyIds = strings.TrimRight(companyIds, ",")
+	//if companyIds != "" {
+	//	condition = ` AND p.is_suspend = 0  AND c.company_id  IN (` + companyIds + ")"
+	//	DotongbuShangHaApi(condition)
+	//}
+	//
+	////处理被禁用的用户，将禁用用户的状态同步
+	//CompanySuspend()
 	return
 }
 

services/task.go

@@ -87,8 +87,8 @@ func Task() {
 		updateCygxActivitySpecialSignupNum := task.NewTask("updateCygxActivitySpecialSignupNum", "0 25 0 * * *", UpdateCygxActivitySpecialSignupNum) //修改专项调研，用户与公司的参与数量
 		task.AddTask("updateCygxActivitySpecialSignupNum", updateCygxActivitySpecialSignupNum)
 
-		dotongbuShangHai := task.NewTask("dotongbuShangHai", "0 */20 * * * *", DotongbuShangHai) //把信息同步到上海策略品台
-		task.AddTask("同步用户到上海", dotongbuShangHai)
+		//dotongbuShangHai := task.NewTask("dotongbuShangHai", "0 */20 * * * *", DotongbuShangHai) //把信息同步到上海策略品台
+		//task.AddTask("同步用户到上海", dotongbuShangHai)
 
 		updateDailyMonthReadBillboard := task.NewTask("updateDailyMonthReadBillboard", "0 0 3 * * *", UpdateDailyMonthReadBillboard) // 每日3:00更新阅读飙升榜单
 		task.AddTask("updateDailyMonthReadBillboard", updateDailyMonthReadBillboard)
@@ -107,6 +107,7 @@ func Task() {
 		getArticleListByApi := task.NewTask("getArticleListByApi", "0 */60 * * * *", GetArticleListByApi) //通过三方接口获取策略平台上的文章
 		task.AddTask("getArticleListByApi", getArticleListByApi)
 	}
+	DotongbuShangHai()
 	//GetCygxActivityAttendanceDetail()
 	//CreateIndexNameArticleHistory()
 	//AddAllArticleHistory()