api_bbs.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. package route
  2. import (
  3. "database/sql"
  4. "encoding/json"
  5. "fmt"
  6. "opennamu/route/tool"
  7. "strconv"
  8. )
  9. func Api_bbs(call_arg []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. if db == nil {
  16. return
  17. }
  18. defer db.Close()
  19. var rows *sql.Rows
  20. if other_set["bbs_num"] == "" {
  21. var err error
  22. 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"))
  23. if err != nil {
  24. return
  25. }
  26. } else {
  27. page, _ := strconv.Atoi(other_set["page"])
  28. num := 0
  29. if page*50 > 0 {
  30. num = page*50 - 50
  31. }
  32. 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"))
  33. if err != nil {
  34. return
  35. }
  36. defer stmt.Close()
  37. rows, err = stmt.Query(other_set["bbs_num"], num)
  38. if err != nil {
  39. return
  40. }
  41. }
  42. defer rows.Close()
  43. var data_list []map[string]string
  44. for rows.Next() {
  45. temp_data := make(map[string]string)
  46. var set_code string
  47. var set_id string
  48. err := rows.Scan(&set_code, &set_id)
  49. if err != nil {
  50. return
  51. }
  52. temp_data["set_code"] = set_code
  53. temp_data["set_id"] = set_id
  54. 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 = ?"))
  55. if err != nil {
  56. return
  57. }
  58. defer stmt.Close()
  59. rows, err := stmt.Query(set_code, set_id)
  60. if err != nil {
  61. return
  62. }
  63. defer rows.Close()
  64. for rows.Next() {
  65. var set_name string
  66. var set_data string
  67. err := rows.Scan(&set_name, &set_data, &set_code, &set_id)
  68. if err != nil {
  69. return
  70. }
  71. temp_data[set_name] = set_data
  72. }
  73. data_list = append(data_list, temp_data)
  74. }
  75. if len(data_list) == 0 {
  76. fmt.Print("{}")
  77. } else {
  78. json_data, _ := json.Marshal(data_list)
  79. fmt.Print(string(json_data))
  80. }
  81. }