初始化管理员账号数据

main.go

@@ -10,6 +10,6 @@ func main() {
 		beego.BConfig.WebConfig.DirectoryIndex = true
 		beego.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
 	}
-
+	//services.InitEtaForumAdminId() // 初始化账号
 	beego.Run()
 }

models/system/admin.go

@@ -270,3 +270,104 @@ func GetGroupSysUserList(groupId int) (items []*Admin, err error) {
 	_, err = o.Raw(sql, groupId).QueryRows(&items)
 	return
 }
+
+type DifferentAdmin struct {
+	AdminId     int    `description:"系统用户id"`
+	RealName    string `description:"用户真实名称"`
+	Mobile      string `description:"用户手机号"`
+	CrmAdminId  int    `description:"crm系统用户id"`
+	CrmRealName string `description:"crm用户真实名称"`
+	CrmMobile   string `description:"crm用户手机号"`
+}
+
+// GetDifferentAdmin 获取系统用户和crm系统用户不同的用户
+func GetDifferentAdmin() (items []*DifferentAdmin, err error) {
+	sql := `SELECT a.admin_id, a.real_name,  a.mobile, c.admin_id as crm_admin_id, c.real_name as crm_real_name, c.mobile as crm_mobile FROM admin as a LEFT JOIN admin_crm c on a.admin_name= c.admin_name WHERE a.admin_id != c.admin_id `
+	o := orm.NewOrm()
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+// 初始化，把原先crm中的adminId改成社区里的adminId
+func SetDifferentAdmin(adminId int, adminRealName string, crmAdminId int, crmAdminRealName string, now time.Time, beforeTime string) (err error) {
+	// 事务更新
+	fmt.Println("开始替换 adminId:", adminId, "adminRealName:", adminRealName, "crmAdminId:", crmAdminId, "crmAdminRealName:", crmAdminRealName, "now:", now, "beforeTime:", beforeTime)
+	o := orm.NewOrm()
+	to, err := o.Begin()
+	if err != nil {
+		return
+	}
+	defer func() {
+		if err != nil {
+			_ = to.Rollback()
+		} else {
+			_ = to.Commit()
+		}
+	}()
+	sql := "UPDATE eta_business SET seller_id = ?, seller_name=?, modify_time=? WHERE seller_id = ? and seller_name = ? and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+	sql = "UPDATE eta_business_operation_record SET seller_id = ? WHERE seller_id = ?  and create_time<?"
+	_, err = to.Raw(sql, adminId, crmAdminId, beforeTime).Exec()
+
+	if err != nil {
+		return
+	}
+	sql = "UPDATE eta_business_operation_record SET sys_user_id = ?, sys_real_name=? WHERE sys_user_id = ? and	sys_real_name =?  and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE eta_business_remind_record SET seller_id = ?, seller_name=? WHERE seller_id = ? and seller_name = ? and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE eta_training_video_classify SET sys_user_id = ?, sys_real_name=?, modify_time=? WHERE sys_user_id = ? and	sys_real_name =? and create_time<? "
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE eta_training_video_op_log SET sys_user_id = ?, sys_real_name=? WHERE sys_user_id = ? and	sys_real_name =?  and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE eta_training_video_tag SET sys_user_id = ?, sys_real_name=?, modify_time=? WHERE sys_user_id = ? and	sys_real_name =?  and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE eta_trial SET seller_id = ?, seller=?, modify_time=? WHERE seller_id = ? and seller = ? and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE eta_trial_approval SET seller_id = ?, seller=?, modify_time=? WHERE seller_id = ? and seller = ? and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE help_doc SET admin_id = ?, admin_real_name=?, modify_time=? WHERE admin_id = ? and admin_real_name = ? and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	sql = "UPDATE help_doc_classify SET sys_user_id = ?, sys_user_real_name=?, modify_time=? WHERE sys_user_id = ? and	sys_user_real_name =?  and create_time<?"
+	_, err = to.Raw(sql, adminId, adminRealName, now, crmAdminId, crmAdminRealName, beforeTime).Exec()
+	if err != nil {
+		return
+	}
+
+	return
+}

services/eta_trial.go

@@ -3,6 +3,7 @@ package services
 import (
 	"eta/eta_forum_admin/models/company"
 	"eta/eta_forum_admin/models/eta_trial"
+	"eta/eta_forum_admin/models/system"
 	"eta/eta_forum_admin/services/alarm_msg"
 	"eta/eta_forum_admin/services/eta_forum_hub"
 	"eta/eta_forum_admin/utils"
@@ -228,3 +229,26 @@ func ApprovalApply(approvalId int) (err error) {
 	//}()
 	return
 }
+
+// 把crm中的销售ID转成成新的销售ID
+func InitEtaForumAdminId() (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println("InitEtaForumAdminId err: %s", err.Error())
+		}
+	}()
+	now := time.Now()
+	beforeTime := "2025-01-03" // 改成当前执行的时间，，修改这个时间之前的所有数据，避免替换后续新产生的数据
+	adminList, err := system.GetDifferentAdmin()
+	if err != nil {
+		return
+	}
+	for _, item := range adminList {
+		err = system.SetDifferentAdmin(item.AdminId, item.RealName, item.CrmAdminId, item.CrmRealName, now, beforeTime)
+		if err != nil {
+			return
+		}
+	}
+	fmt.Println("InitEtaForumAdminId Success 替换账号：", len(adminList), "个")
+	return
+}