api_topic_list.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115
  1. package route
  2. import (
  3. "database/sql"
  4. "encoding/json"
  5. "log"
  6. "opennamu/route/tool"
  7. "strconv"
  8. )
  9. func Api_topic_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_int, err := strconv.Atoi(other_set["num"])
  15. if err != nil {
  16. log.Fatal(err)
  17. }
  18. if page_int > 0 {
  19. page_int = (page_int * 50) - 50
  20. } else {
  21. page_int = 0
  22. }
  23. stmt, err := db.Prepare(tool.DB_change("select code, sub, stop, agree, date from rd where title = ? order by sub asc limit ?, 50"))
  24. if err != nil {
  25. log.Fatal(err)
  26. }
  27. defer stmt.Close()
  28. rows, err := stmt.Query(other_set["name"], page_int)
  29. if err != nil {
  30. log.Fatal(err)
  31. }
  32. defer rows.Close()
  33. var data_list [][]string
  34. ip_parser_temp := map[string][]string{}
  35. for rows.Next() {
  36. var code string
  37. var sub string
  38. var stop string
  39. var agree string
  40. var date string
  41. err := rows.Scan(&code, &sub, &stop, &agree, &date)
  42. if err != nil {
  43. log.Fatal(err)
  44. }
  45. stmt, err := db.Prepare(tool.DB_change("select ip, id from topic where code = ? order by id + 0 desc limit 1"))
  46. if err != nil {
  47. log.Fatal(err)
  48. }
  49. defer stmt.Close()
  50. var ip string
  51. var id string
  52. err = stmt.QueryRow(code).Scan(&ip, &id)
  53. if err != nil {
  54. if err == sql.ErrNoRows {
  55. ip = ""
  56. } else {
  57. log.Fatal(err)
  58. }
  59. }
  60. var ip_pre string
  61. var ip_render string
  62. if _, ok := ip_parser_temp[ip]; ok {
  63. ip_pre = ip_parser_temp[ip][0]
  64. ip_render = ip_parser_temp[ip][1]
  65. } else {
  66. ip_pre = tool.IP_preprocess(db, ip, other_set["ip"])[0]
  67. ip_render = tool.IP_parser(db, ip, other_set["ip"])
  68. ip_parser_temp[ip] = []string{ip_pre, ip_render}
  69. }
  70. data_list = append(data_list, []string{
  71. code,
  72. sub,
  73. stop,
  74. agree,
  75. ip_pre,
  76. ip_render,
  77. date,
  78. id,
  79. })
  80. }
  81. return_data := make(map[string]interface{})
  82. return_data["language"] = map[string]string{
  83. "closed": tool.Get_language(db, "closed", false),
  84. "agreed_discussion": tool.Get_language(db, "agreed_discussion", false),
  85. "make_new_topic": tool.Get_language(db, "make_new_topic", false),
  86. "stop": tool.Get_language(db, "stop", false),
  87. }
  88. if len(data_list) == 0 {
  89. return_data["data"] = map[string]string{}
  90. } else {
  91. return_data["data"] = data_list
  92. }
  93. json_data, _ := json.Marshal(return_data)
  94. return string(json_data)
  95. }