no message

models/company_report_permission.go

@@ -33,3 +33,14 @@ func GetCompanyReportPermissionDetailByCondition(condition string, pars []interf
 	err = o.Raw(sql, pars).QueryRow(&item)
 	return
 }
+
+// 列表
+func GetCompanyReportPermissionList(condition string, pars []interface{}) (items []*CompanyReportPermission, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM company_report_permission  WHERE 1= 1 `
+	if condition != "" {
+		sql += condition
+	}
+	_, err = o.Raw(sql, pars).QueryRows(&items)
+	return
+}

services/activity_points.go

@@ -880,6 +880,7 @@ func YanXuanActivityPointsBillSubmitMeetingReduce(log models.YanXuanActivityPoin
 
 // 6:研选审批通过的时候研选扣点更新
 func YanXuanCompanyApprovalReduce(log models.YanXuanActivityPointsRedis) (err error) {
+	time.Sleep(5 * time.Second) // 延迟5秒处理
 	defer func() {
 		if err != nil {
 			fmt.Println(err)

services/send_company_user.go

@@ -108,15 +108,20 @@ func SendComapnyToShanghai(url, jsonCompany, postType string) (err error) {
 }
 
 func DotongbuShangHai(cont context.Context) (err error) {
-	//func DotongbuShangHai() (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go utils.SendAlarmMsg("把权限信息同步到上海策略品台失败，DotongbuShangHai："+err.Error(), 2)
+		}
+	}()
 	//先删除被禁用的用户
 	DeleteUserDotongbuShangHaiApi()
 	var condition string
 	updateTime := time.Now().Add(-time.Minute * 22).Format("2006-01-02 15:04:05")
-	listUpdateUser, err := models.GetWxUserOpLog(updateTime)
-	if err != nil && err.Error() != utils.ErrNoRow() {
-		fmt.Println(err)
-		return err
+	listUpdateUser, e := models.GetWxUserOpLog(updateTime)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetWxUserOpLog, Err: " + e.Error())
+		return
 	}
 	var companyIds string
 	if len(listUpdateUser) > 0 {
@@ -125,9 +130,10 @@ func DotongbuShangHai(cont context.Context) (err error) {
 		}
 	}
 	////获取冻结跟流失的客户
-	listFreezeAndLoss, err := models.GetCompanyFreezeAndLoss(updateTime)
-	if err != nil && err.Error() != utils.ErrNoRow() {
-		return err
+	listFreezeAndLoss, e := models.GetCompanyFreezeAndLoss(updateTime)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetCompanyFreezeAndLoss, Err: " + e.Error())
+		return
 	}
 	if len(listFreezeAndLoss) > 0 {
 		for _, v := range listFreezeAndLoss {
@@ -135,9 +141,10 @@ func DotongbuShangHai(cont context.Context) (err error) {
 		}
 	}
 
-	listDeleteUser, err := models.GetWxUserOpLogDelete(updateTime)
-	if err != nil && err.Error() != utils.ErrNoRow() {
-		return err
+	listDeleteUser, e := models.GetWxUserOpLogDelete(updateTime)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetWxUserOpLogDelete, Err: " + e.Error())
+		return
 	}
 
 	////获取删除客户
@@ -148,9 +155,10 @@ func DotongbuShangHai(cont context.Context) (err error) {
 	}
 
 	//获取指定时间内被移动的客户
-	listOperationRecord, err := models.GetCompanyOperationRecord(updateTime)
-	if err != nil && err.Error() != utils.ErrNoRow() {
-		return err
+	listOperationRecord, e := models.GetCompanyOperationRecord(updateTime)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetCompanyOperationRecord, Err: " + e.Error())
+		return
 	}
 	if len(listOperationRecord) > 0 {
 		for _, v := range listOperationRecord {
@@ -158,6 +166,22 @@ func DotongbuShangHai(cont context.Context) (err error) {
 		}
 	}
 
+	//获取正式转试用的客户ID
+	var conditionPer string
+	var parsPer []interface{}
+	conditionPer += "  AND product_id = 2  AND modify_time > ?  GROUP BY company_id   "
+	parsPer = append(parsPer, updateTime)
+	companyReportPermissionList, e := models.GetCompanyReportPermissionList(conditionPer, parsPer)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetCompanyReportPermissionList, Err: " + e.Error())
+		return
+	}
+	if len(companyReportPermissionList) > 0 {
+		for _, v := range companyReportPermissionList {
+			companyIds += strconv.Itoa(v.CompanyId) + ","
+		}
+	}
+
 	condition = ` AND p.is_suspend = 0  AND a.modify_time > ` + "'" + updateTime + "'"
 	companyIds = strings.TrimRight(companyIds, ",")