|
|
|
@@ -59,14 +59,17 @@ func syncTopicStruct(x *xorm.Engine) error { |
|
|
|
|
|
|
|
func deleteNotDisplayUser(x *xorm.Engine, static *xorm.Engine) error { |
|
|
|
|
|
|
|
sess := x.NewSession() |
|
|
|
defer sess.Close() |
|
|
|
sess.Select("`user`.*").Table("user").Where("type=1") |
|
|
|
userList := make([]*User, 0) |
|
|
|
log.Info("delete zuzi user size=" + fmt.Sprint(len(userList))) |
|
|
|
for i, userRecord := range userList { |
|
|
|
log.Info("delete zuzi user, i=" + fmt.Sprint(i) + " userName=" + userRecord.Name) |
|
|
|
deleteSql := "delete from user_business_analysis where id=" + fmt.Sprint(userRecord.ID) + " and name='" + userRecord.Name + "'" |
|
|
|
querySQL := "select id,name from user where type=1" |
|
|
|
|
|
|
|
rows, err := x.Query(querySQL) |
|
|
|
if err != nil { |
|
|
|
log.Info("select db failed,err:", err) |
|
|
|
return err |
|
|
|
} |
|
|
|
|
|
|
|
for i, userRow := range rows { |
|
|
|
log.Info("delete zuzi user, i=" + fmt.Sprint(i) + " userName=" + string(userRow["id"])) |
|
|
|
deleteSql := "delete from user_business_analysis where id=" + string(userRow["id"]) + " and name='" + string(userRow["name"]) + "'" |
|
|
|
static.Exec(deleteSql) |
|
|
|
} |
|
|
|
|
|
|
|
|