router.js 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145
  1. var express = require('express');
  2. var router = express.Router();
  3. var mysql = require('../model/mysql');
  4. const _mysqluser = ["172.16.12.5", "registration"]; //用戶數據庫信息
  5. // const _mysqluser = ["183.36.25.93", "registration"]; //本地测试用戶數據庫信息
  6. const crypto = require('crypto');
  7. const XLSX = require('xlsx');
  8. router.route('/user').post(async function (req, res) {
  9. const reqData = req.body;
  10. const uuid = crypto.randomUUID();
  11. let userData = JSON.parse(reqData.user);
  12. await mysql.usselect([_mysqluser[0], _mysqluser[1], "select_registration_user", reqData.idCard], async function (r) {
  13. console.log(r[0] && r[0], r[0].some(item => item['type'] == Number(reqData.type)));
  14. if (r[0] && r[0].some(item => item['type'] == Number(reqData.type))) {
  15. res.send({ status: 'error', message: '选手报名失败,选手身份证号已存在' });
  16. } else {
  17. // const insertUserPromises = userData.map(item => {
  18. // return new Promise((resolve, reject) => {
  19. // const userList = [];
  20. // userList.unshift(_mysqluser[0], _mysqluser[1], "insert_registration_users", item.name, item.gender, item.ethnicity, item.birthdate, item.email, item.id_number, item.group, item.grade, item.school, item.schoolRegion, item.phone, uuid);
  21. // mysql.usselect(userList, function (data) {
  22. // // 可以根据 data 判断是否插入成功
  23. // console.log("insert_registration_users", data);
  24. // if (data != 0) {
  25. // resolve(data);
  26. // } else {
  27. // reject(data);
  28. // }
  29. // });
  30. // });
  31. // });
  32. // signUpData.unshift(_mysqluser[0], _mysqluser[1], "insert_registrations", reqData.uploadUrl, "", reqData.type, reqData.idCard);
  33. // Promise.all(insertUserPromises).then(() => {
  34. // // 所有用户插入完成后再插入报名数据
  35. // mysql.usselect(signUpData, function (data) {
  36. // if (data != 0) {
  37. // res.send({ status: 'ok', message: '选手报名成功' });
  38. // } else {
  39. // res.send({ status: 'error', message: '选手报名失败' });
  40. // }
  41. // });
  42. // }).catch(error => {
  43. // console.error("error", error);
  44. // res.send({ status: 'error', message: '选手报名失败,选手身份证号已存在' });
  45. // });
  46. for (const item of userData) {
  47. const userList = [_mysqluser[0], _mysqluser[1], "insert_registration_users", item.name, item.gender, item.ethnicity, item.birthdate, item.email, item.id_number, item.group, item.grade, item.school, item.schoolRegion, item.phone, uuid,reqData.type,reqData.area]
  48. await new Promise((resolve, reject) => {
  49. mysql.usselect(userList, function (data) {
  50. // 可以根据 data 判断是否插入成功
  51. console.log("insert_registration_users", data);
  52. if (data != 0) {
  53. resolve(data);
  54. } else {
  55. res.send({ status: 'error', message: '选手报名失败' });
  56. reject(data);
  57. }
  58. });
  59. });
  60. }
  61. const signUpData = [_mysqluser[0], _mysqluser[1], "insert_registrations", reqData.uploadUrl, "", reqData.type, reqData.idCard]
  62. mysql.usselect(signUpData, function (data) {
  63. if (data != 0) {
  64. res.send({ status: 'ok', message: '选手报名成功' });
  65. } else {
  66. res.send({ status: 'error', message: '选手报名失败' });
  67. }
  68. });
  69. }
  70. })
  71. });
  72. router.route('/update').post(async function (req, res) {
  73. const { url, id_number,type } = req.body;
  74. const queryList = [_mysqluser[0], _mysqluser[1], "update_registration", url, id_number,type];
  75. mysql.usselect(queryList, function (data) {
  76. console.log(data);
  77. if (data == 1) {
  78. res.send({ status: 'ok', message: '报名信息更新成功' });
  79. } else {
  80. res.send({ status: 'error', message: '未找到报名信息' });
  81. }
  82. });
  83. });
  84. router.route('/exportData').get(async function (req, res) {
  85. const { start, end } = req.query;
  86. const queryList = [_mysqluser[0], _mysqluser[1], "sp_export_registration_data", start, end];
  87. let dataList = [];
  88. await mysql.usselect(queryList, function (data) {
  89. if (data[0] && data[0][0]) {
  90. dataList = data[0];
  91. dataList = dataList.map(item => {
  92. let user_group = ""
  93. if (item.type == 1) {
  94. user_group = item.user_group == 1 ? "小学低龄" : item.user_group == 2 ? "小学高龄" : item.user_group == 3 ? "中学" : "高校"
  95. } else {
  96. user_group = item.user_group == 1 ? "小学组(4-6年级)" : item.user_group == 2 ? "初中组(7-9年级)" : item.user_group == 3 ? "高中组(10-12年级,含中职)" : "高校组(含高职)"
  97. }
  98. return {
  99. 小组id: item.user_groupid,
  100. 小组人数: item.id_card.split(",").length,
  101. 指导老师: item.upload_url,
  102. 比赛类型: item.type == 1 ? "桌游挑战赛" : "智能体应用",
  103. 姓名: item.user_name,
  104. 邮箱: item.user_email,
  105. 身份证号: item.user_id_number,
  106. 组别: user_group,
  107. 年级: item.user_grade,
  108. 学校: item.user_school,
  109. 学校地区: item.user_school_region,
  110. 电话: item.user_phone,
  111. 上传文件: item.registration_form_url.split(",")[0],
  112. 上传视频: item.registration_form_url.split(",")[1],
  113. 报名时间: new Date(item.created_at).toLocaleString()
  114. }
  115. });
  116. const workbook = XLSX.utils.book_new();
  117. const worksheet = XLSX.utils.json_to_sheet(dataList);
  118. XLSX.utils.book_append_sheet(workbook, worksheet, '报名数据');
  119. const buffer = XLSX.write(workbook, { type: 'buffer', bookType: 'xlsx' });
  120. res.setHeader('Content-Disposition', 'attachment; filename="' + start + ':' + end + '.xlsx"');
  121. res.setHeader('Content-Type', 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
  122. res.send(buffer);
  123. return;
  124. }
  125. });
  126. });
  127. module.exports = router;