import { TimeTable, Theater } from "../db/index.js"; import moment from 'moment'; import sequelize from 'sequelize' const { Op } = sequelize const getAll = async (req, res) => { try { const { when } = req.query const selectDate = new Date(when) const theaterArr = [] // const timeTableArr = [] const findAll = await TimeTable.findAll({ where: { date: selectDate }, attributes: { exclude: ['createdAt', 'updatedAt'] }, order: [["theater", "ASC"], ["start_time", "ASC"]] }) findAll.forEach(element => { if (!theaterArr.includes(element.theater)) theaterArr.push(element.theater) }) const findTheater = await Theater.findAll({ where: { id: theaterArr }, attributes: { exclude: ['createdAt', 'updatedAt'] }, order: [['theaterName']] }) findTheater.forEach(el => { const arr = findAll.filter(timetable => { if (el.id === timetable.theater) return timetable.dataValues }) el.dataValues.timetable = arr // timeTableArr.push({ id: el.id, info: arr }) }) return res.json(findTheater) // return res.json({findTheater, timeTableArr}) } catch (error) { return res.status(500).send(error.message || "상영시간표 정보 가져오는 중 에러 발생") } } const submit = async (req, res) => { try { const { movieId, title, theater, runtime, release_date, date } = req.body const result = await Promise.all( theater.map(async (theater) => { const startTime = getTime(theater.start) const endTime = getTime(theater.start, runtime) const isTimeTable = await TimeTable.findAll({ where: { [Op.and]: [ { theater: theater.theater }, { [Op.or]: [ { [Op.and]: [{ start_time: { [Op.gt]: startTime } }, { end_time: { [Op.lte]: endTime } }] }, { start_time: { [Op.between]: [startTime, endTime] } } ] } ] } }) if (isTimeTable.length !== 0) return "unvalid" else return "valid" }) ) result.map(el => { if (el !== "valid") throw new Error("유효하지 않은 데이터입니다. 다시 등록해주시길 바랍니다.") }) let curDate = new Date(release_date) const endDate = new Date(date) do { let day = curDate.getDay() await Promise.all( theater.map(async (theater) => { let partTime = "" if ('06:00' <= theater.start < '10:00') partTime = "morning" else if ('00:00' <= theater.start < '06:00') partTime = "night" else partTime = "day" await TimeTable.create({ theater: theater.theater, movieId, title, release_date, date: curDate, start_time: getTime(theater.start), end_time: getTime(theater.start, runtime), partTime: partTime, week: (day === 0 || day === 6) ? "weekend" : "weekdays" }) }) ) curDate.setDate(curDate.getDate() + 1) } while (curDate <= endDate) res.send("success!") } catch (error) { return res.status(500).send(error.message || "상영시간표 저장 중 에러 발생") } } const getTime = (string, runtime = 0) => { const arr = string.split(':') const date = new Date(0, 0, 0, Number(arr[0]), Number(arr[1]) + runtime) return date } const remove = async (req, res) => { try { const { timeId } = req.params const delNum = await TimeTable.destroy({ where: {} }) if (delNum) res.json(delNum) else throw new Error("해당 정보를 서버에서 삭제하는데 실패했습니다.") } catch (error) { return res.status(500).send(error.message || "상영시간표 삭제 중 에러 발생") } } export default { getAll, submit, remove }