api_w_watch_list.go 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. package route
  2. import (
  3. "database/sql"
  4. "encoding/json"
  5. "log"
  6. "opennamu/route/tool"
  7. "strconv"
  8. )
  9. func Api_w_watch_list(call_arg []string) string {
  10. db_set := map[string]string{}
  11. json.Unmarshal([]byte(call_arg[0]), &db_set)
  12. other_set := map[string]string{}
  13. json.Unmarshal([]byte(call_arg[1]), &other_set)
  14. page, _ := strconv.Atoi(other_set["num"])
  15. num := 0
  16. if page*50 > 0 {
  17. num = page*50 - 50
  18. }
  19. db := tool.DB_connect(db_set)
  20. defer db.Close()
  21. if tool.Get_user_auth(db, db_set, other_set["ip"]) == "" {
  22. return "{}"
  23. }
  24. var stmt *sql.Stmt
  25. var err error
  26. if other_set["do_type"] == "star_doc" {
  27. stmt, err = db.Prepare(tool.DB_change(db_set, "select id from user_set where name = 'star_doc' and data = ? limit ?, 50"))
  28. } else {
  29. stmt, err = db.Prepare(tool.DB_change(db_set, "select id from user_set where name = 'watchlist' and data = ? limit ?, 50"))
  30. }
  31. if err != nil {
  32. log.Fatal(err)
  33. }
  34. defer stmt.Close()
  35. rows, err := stmt.Query(other_set["name"], num)
  36. if err != nil {
  37. log.Fatal(err)
  38. }
  39. defer rows.Close()
  40. var data_list [][]string
  41. ip_parser_temp := map[string][]string{}
  42. for rows.Next() {
  43. var user_name string
  44. err := rows.Scan(&user_name)
  45. if err != nil {
  46. log.Fatal(err)
  47. }
  48. var ip_pre string
  49. var ip_render string
  50. if _, ok := ip_parser_temp[user_name]; ok {
  51. ip_pre = ip_parser_temp[user_name][0]
  52. ip_render = ip_parser_temp[user_name][1]
  53. } else {
  54. ip_pre = tool.IP_preprocess(db, db_set, user_name, other_set["ip"])[0]
  55. ip_render = tool.IP_parser(db, db_set, user_name, other_set["ip"])
  56. ip_parser_temp[user_name] = []string{ip_pre, ip_render}
  57. }
  58. data_list = append(data_list, []string{ip_pre, ip_render})
  59. }
  60. return_data := make(map[string]interface{})
  61. return_data["language"] = map[string]string{
  62. "watchlist": tool.Get_language(db, db_set, "watchlist", false),
  63. "star_doc": tool.Get_language(db, db_set, "star_doc", false),
  64. }
  65. if len(data_list) == 0 {
  66. return_data["data"] = map[string]string{}
  67. } else {
  68. return_data["data"] = data_list
  69. }
  70. json_data, _ := json.Marshal(return_data)
  71. return string(json_data)
  72. }