api_bbs.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  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. for rows.Next() {
  46. temp_data := make(map[string]string)
  47. var set_code string
  48. var set_id string
  49. err := rows.Scan(&set_code, &set_id)
  50. if err != nil {
  51. log.Fatal(err)
  52. }
  53. temp_data["set_code"] = set_code
  54. temp_data["set_id"] = set_id
  55. 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 = ?"))
  56. if err != nil {
  57. log.Fatal(err)
  58. }
  59. defer stmt.Close()
  60. rows, err := stmt.Query(set_code, set_id)
  61. if err != nil {
  62. log.Fatal(err)
  63. }
  64. defer rows.Close()
  65. for rows.Next() {
  66. var set_name string
  67. var set_data string
  68. err := rows.Scan(&set_name, &set_data, &set_code, &set_id)
  69. if err != nil {
  70. log.Fatal(err)
  71. }
  72. temp_data[set_name] = set_data
  73. }
  74. data_list = append(data_list, temp_data)
  75. }
  76. if len(data_list) == 0 {
  77. fmt.Print("{}")
  78. } else {
  79. json_data, _ := json.Marshal(data_list)
  80. fmt.Print(string(json_data))
  81. }
  82. }