All files / controllers projectController.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
/**
 * 프로젝트 관리 컨트롤러
 *
 * 프로젝트 CRUD API 엔드포인트 핸들러
 *
 * @author TK-FB-Project
 * @since 2025-12-11
 */
 
const projectModel = require('../models/projectModel');
const { ValidationError, NotFoundError, DatabaseError } = require('../utils/errors');
const { asyncHandler } = require('../middlewares/errorHandler');
const logger = require('../utils/logger');
 
/**
 * 프로젝트 생성
 */
exports.createProject = asyncHandler(async (req, res) => {
  const projectData = req.body;
 
  logger.info('프로젝트 생성 요청', { name: projectData.name });
 
  const id = await new Promise((resolve, reject) => {
    projectModel.create(projectData, (err, lastID) => {
      if (err) reject(new DatabaseError('프로젝트 생성 중 오류가 발생했습니다'));
      else resolve(lastID);
    });
  });
 
  logger.info('프로젝트 생성 성공', { project_id: id });
 
  res.status(201).json({
    success: true,
    data: { project_id: id },
    message: '프로젝트가 성공적으로 생성되었습니다'
  });
});
 
/**
 * 전체 프로젝트 조회
 */
exports.getAllProjects = asyncHandler(async (req, res) => {
  const rows = await new Promise((resolve, reject) => {
    projectModel.getAll((err, data) => {
      if (err) reject(new DatabaseError('프로젝트 목록 조회 중 오류가 발생했습니다'));
      else resolve(data);
    });
  });
 
  res.json({
    success: true,
    data: rows,
    message: '프로젝트 목록 조회 성공'
  });
});
 
/**
 * 활성 프로젝트만 조회 (작업보고서용)
 */
exports.getActiveProjects = asyncHandler(async (req, res) => {
  const rows = await new Promise((resolve, reject) => {
    projectModel.getActiveProjects((err, data) => {
      if (err) reject(new DatabaseError('활성 프로젝트 목록 조회 중 오류가 발생했습니다'));
      else resolve(data);
    });
  });
 
  res.json({
    success: true,
    data: rows,
    message: '활성 프로젝트 목록 조회 성공'
  });
});
 
/**
 * 단일 프로젝트 조회
 */
exports.getProjectById = asyncHandler(async (req, res) => {
  const id = parseInt(req.params.project_id, 10);
 
  if (isNaN(id)) {
    throw new ValidationError('유효하지 않은 프로젝트 ID입니다');
  }
 
  const row = await new Promise((resolve, reject) => {
    projectModel.getById(id, (err, data) => {
      if (err) reject(new DatabaseError('프로젝트 조회 중 오류가 발생했습니다'));
      else resolve(data);
    });
  });
 
  if (!row) {
    throw new NotFoundError('프로젝트를 찾을 수 없습니다');
  }
 
  res.json({
    success: true,
    data: row,
    message: '프로젝트 조회 성공'
  });
});
 
/**
 * 프로젝트 수정
 */
exports.updateProject = asyncHandler(async (req, res) => {
  const id = parseInt(req.params.project_id, 10);
 
  if (isNaN(id)) {
    throw new ValidationError('유효하지 않은 프로젝트 ID입니다');
  }
 
  const data = { ...req.body, project_id: id };
 
  const changes = await new Promise((resolve, reject) => {
    projectModel.update(data, (err, ch) => {
      if (err) reject(new DatabaseError('프로젝트 수정 중 오류가 발생했습니다'));
      else resolve(ch);
    });
  });
 
  if (changes === 0) {
    throw new NotFoundError('프로젝트를 찾을 수 없습니다');
  }
 
  logger.info('프로젝트 수정 성공', { project_id: id });
 
  res.json({
    success: true,
    data: { changes },
    message: '프로젝트 정보가 성공적으로 수정되었습니다'
  });
});
 
/**
 * 프로젝트 삭제
 */
exports.removeProject = asyncHandler(async (req, res) => {
  const id = parseInt(req.params.project_id, 10);
 
  if (isNaN(id)) {
    throw new ValidationError('유효하지 않은 프로젝트 ID입니다');
  }
 
  const changes = await new Promise((resolve, reject) => {
    projectModel.remove(id, (err, ch) => {
      if (err) reject(new DatabaseError('프로젝트 삭제 중 오류가 발생했습니다'));
      else resolve(ch);
    });
  });
 
  if (changes === 0) {
    throw new NotFoundError('프로젝트를 찾을 수 없습니다');
  }
 
  logger.info('프로젝트 삭제 성공', { project_id: id });
 
  res.json({
    success: true,
    message: '프로젝트가 성공적으로 삭제되었습니다'
  });
});