api_topic_list.go 2.3 KB

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