api_user_watch_list.go 1.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. package route
  2. import (
  3. "database/sql"
  4. "encoding/json"
  5. "log"
  6. "opennamu/route/tool"
  7. "strconv"
  8. )
  9. func Api_user_watch_list(call_arg []string) string {
  10. other_set := map[string]string{}
  11. json.Unmarshal([]byte(call_arg[0]), &other_set)
  12. db := tool.DB_connect()
  13. defer db.Close()
  14. page, _ := strconv.Atoi(other_set["num"])
  15. num := 0
  16. if page*50 > 0 {
  17. num = page*50 - 50
  18. }
  19. ip := other_set["ip"]
  20. name := other_set["name"]
  21. if ip != name && tool.Get_user_auth(db, 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("select data from user_set where name = 'star_doc' and id = ? limit ?, 50"))
  28. } else {
  29. stmt, err = db.Prepare(tool.DB_change("select data from user_set where name = 'watchlist' and id = ? limit ?, 50"))
  30. }
  31. if err != nil {
  32. log.Fatal(err)
  33. }
  34. defer stmt.Close()
  35. rows, err := stmt.Query(name, num)
  36. if err != nil {
  37. log.Fatal(err)
  38. }
  39. defer rows.Close()
  40. var data_list []string
  41. for rows.Next() {
  42. var title_data string
  43. err := rows.Scan(&title_data)
  44. if err != nil {
  45. log.Fatal(err)
  46. }
  47. data_list = append(data_list, title_data)
  48. }
  49. return_data := make(map[string]interface{})
  50. return_data["language"] = map[string]string{
  51. "watchlist": tool.Get_language(db, "watchlist", false),
  52. "star_doc": tool.Get_language(db, "star_doc", false),
  53. }
  54. if len(data_list) == 0 {
  55. return_data["data"] = map[string]string{}
  56. } else {
  57. return_data["data"] = data_list
  58. }
  59. json_data, _ := json.Marshal(return_data)
  60. return string(json_data)
  61. }