api_w_watch_list.go 2.1 KB

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