api_topic_list.go 2.5 KB

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