原有的公司如果新增了也同步到上海策略平台

models/send_company_user.go

@@ -225,7 +225,13 @@ type WxUserOpLogResp struct {
 //获取指定时间内更新的用户
 func GetWxUserOpLog(createTime string) (items []*WxUserOpLogResp, err error) {
 	o := orm.NewOrm()
-	sql := ` SELECT company_id FROM wx_user_op_log WHERE  log_type IN ('add','edit','import','move') AND create_time >=  '` + createTime + `' AND company_id > 1 GROUP BY company_id `
+	sql := ` SELECT
+			u.company_id 
+		FROM
+			wx_user_op_log AS l
+			INNER JOIN wx_user AS u ON u.mobile = l.mobile 
+		WHERE
+			l.log_type IN ( 'add', 'edit', 'import', 'move' )  AND create_time >=  '` + createTime + `'  GROUP BY u.company_id `
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }