api_bbs.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. package route
  2. import (
  3. "database/sql"
  4. "encoding/json"
  5. "fmt"
  6. "log"
  7. "opennamu/route/tool"
  8. "strconv"
  9. )
  10. func Api_bbs(call_arg []string) {
  11. db_set := map[string]string{}
  12. json.Unmarshal([]byte(call_arg[0]), &db_set)
  13. other_set := map[string]string{}
  14. json.Unmarshal([]byte(call_arg[1]), &other_set)
  15. db := tool.DB_connect(db_set)
  16. if db == nil {
  17. return
  18. }
  19. defer db.Close()
  20. var rows *sql.Rows
  21. if other_set["bbs_num"] == "" {
  22. var err error
  23. rows, err = db.Query(tool.DB_change(db_set, "select set_code, set_id from bbs_data where set_name = 'date' order by set_data desc limit 50"))
  24. if err != nil {
  25. log.Fatal(err)
  26. }
  27. } else {
  28. page, _ := strconv.Atoi(other_set["page"])
  29. num := 0
  30. if page*50 > 0 {
  31. num = page*50 - 50
  32. }
  33. stmt, err := db.Prepare(tool.DB_change(db_set, "select set_code, set_id from bbs_data where set_name = 'title' and set_id like ? order by set_code + 0 desc limit ?, 50"))
  34. if err != nil {
  35. log.Fatal(err)
  36. }
  37. defer stmt.Close()
  38. rows, err = stmt.Query(other_set["bbs_num"], num)
  39. if err != nil {
  40. log.Fatal(err)
  41. }
  42. }
  43. defer rows.Close()
  44. var data_list []map[string]string
  45. ip_parser_temp := map[string][]string{}
  46. for rows.Next() {
  47. temp_data := make(map[string]string)
  48. var set_code string
  49. var set_id string
  50. err := rows.Scan(&set_code, &set_id)
  51. if err != nil {
  52. log.Fatal(err)
  53. }
  54. temp_data["set_code"] = set_code
  55. temp_data["set_id"] = set_id
  56. stmt, err := db.Prepare(tool.DB_change(db_set, "select set_name, set_data, set_code, set_id from bbs_data where set_code = ? and set_id = ?"))
  57. if err != nil {
  58. log.Fatal(err)
  59. }
  60. defer stmt.Close()
  61. rows, err := stmt.Query(set_code, set_id)
  62. if err != nil {
  63. log.Fatal(err)
  64. }
  65. defer rows.Close()
  66. for rows.Next() {
  67. var set_name string
  68. var set_data string
  69. err := rows.Scan(&set_name, &set_data, &set_code, &set_id)
  70. if err != nil {
  71. log.Fatal(err)
  72. }
  73. if set_name == "user_id" {
  74. var ip_pre string
  75. var ip_render string
  76. if _, ok := ip_parser_temp[set_data]; ok {
  77. ip_pre = ip_parser_temp[set_data][0]
  78. ip_render = ip_parser_temp[set_data][1]
  79. } else {
  80. ip_pre = tool.IP_preprocess(db, db_set, set_data, other_set["ip"])[0]
  81. ip_render = tool.IP_parser(db, db_set, set_data, other_set["ip"])
  82. ip_parser_temp[set_data] = []string{ip_pre, ip_render}
  83. }
  84. set_data = ip_pre
  85. temp_data["user_id_render"] = ip_render
  86. }
  87. if set_name != "data" {
  88. temp_data[set_name] = set_data
  89. }
  90. }
  91. data_list = append(data_list, temp_data)
  92. }
  93. if len(data_list) == 0 {
  94. fmt.Print("{}")
  95. } else {
  96. json_data, _ := json.Marshal(data_list)
  97. fmt.Print(string(json_data))
  98. }
  99. }