cf75462380
- 4단계 상태 플로우: pending → grouped → purchased → received - 한국어 스마트 검색: 초성 매칭(ㅁㅈㄱ→면장갑), 별칭 테이블, 인메모리 캐시 - 모바일 전용 신청 페이지: 바텀시트 UI, FAB, 카드 리스트, 스크롤 페이지네이션 - 인라인 품목 등록: 미등록 품목 검색→등록→신청 단일 트랜잭션 - 관리자 그룹화: 체크박스 다중 선택, 구매 그룹(batch) 생성/일괄 구매/입고 - 입고 처리: 사진+보관위치 등록, 부분 입고 허용, batch 자동 상태 전환 - 알림: notifyHelper에 target_user_ids 추가, 구매진행중/입고완료 시 신청자 ntfy+push Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
65 lines
2.0 KiB
JavaScript
65 lines
2.0 KiB
JavaScript
// shared/utils/notifyHelper.js — 공용 알림 헬퍼
|
|
// tkuser-api의 내부 알림 API를 통해 DB 저장 + Push 전송
|
|
const http = require('http');
|
|
|
|
const NOTIFY_URL = 'http://tkuser-api:3000/api/notifications/internal';
|
|
const SERVICE_KEY = process.env.INTERNAL_SERVICE_KEY || '';
|
|
|
|
const notifyHelper = {
|
|
/**
|
|
* 알림 전송
|
|
* @param {Object} opts
|
|
* @param {string} opts.type - 알림 유형 (safety, maintenance, repair, system, purchase)
|
|
* @param {string} opts.title - 알림 제목
|
|
* @param {string} [opts.message] - 알림 내용
|
|
* @param {string} [opts.link_url] - 클릭 시 이동 URL
|
|
* @param {string} [opts.reference_type] - 연관 테이블명
|
|
* @param {number} [opts.reference_id] - 연관 레코드 ID
|
|
* @param {number} [opts.created_by] - 생성자 user_id
|
|
* @param {number[]} [opts.target_user_ids] - 특정 사용자 직접 알림 (생략 시 type 기반 브로드캐스트)
|
|
*/
|
|
async send(opts) {
|
|
try {
|
|
const body = JSON.stringify(opts);
|
|
const url = new URL(NOTIFY_URL);
|
|
|
|
return new Promise((resolve) => {
|
|
const req = http.request({
|
|
hostname: url.hostname,
|
|
port: url.port,
|
|
path: url.pathname,
|
|
method: 'POST',
|
|
headers: {
|
|
'Content-Type': 'application/json',
|
|
'X-Internal-Service-Key': SERVICE_KEY,
|
|
'Content-Length': Buffer.byteLength(body)
|
|
},
|
|
timeout: 5000
|
|
}, (res) => {
|
|
res.resume(); // drain
|
|
resolve(true);
|
|
});
|
|
|
|
req.on('error', (err) => {
|
|
console.error('[notifyHelper] 알림 전송 실패:', err.message);
|
|
resolve(false);
|
|
});
|
|
|
|
req.on('timeout', () => {
|
|
req.destroy();
|
|
console.error('[notifyHelper] 알림 전송 타임아웃');
|
|
resolve(false);
|
|
});
|
|
|
|
req.write(body);
|
|
req.end();
|
|
});
|
|
} catch (err) {
|
|
console.error('[notifyHelper] 알림 전송 오류:', err.message);
|
|
return false;
|
|
}
|
|
}
|
|
};
|
|
|
|
module.exports = notifyHelper;
|