[FEAT]#9 #52 유저 알림 신청 API 및 알림 로직 완성

Author: de-novo

prisma/schema.prisma

@@ -202,6 +202,13 @@ model TyphoonPredictionCircleWithAroundWeatherPrediction {
   @@map("typhoon_predictions_circle_with_around_weather_prediction")
 }
 
+model User {
+  phone_number String   @id @db.VarChar(100)
+  city        String
+  @@map("users")
+}
+
+
 enum GRADE_TYPE {
   TD
   TS

src/app/sms/provider/sms.service.ts

@@ -1,13 +1,21 @@
-import { Injectable } from '@nestjs/common';
+import { WeatherService } from '@app/weather/provider/weather.service';
+import { BadRequestException, Injectable } from '@nestjs/common';
 
+import { PrismaService } from '@src/prisma/prisma.service';
 import axios from 'axios';
 import * as crypto from 'crypto';
+import { SMSApplyDto } from '../sms-apply.dto';
 
 @Injectable()
 export class SmsService {
   private ACCESS_KEY_ID = process.env.SENS_ACCESS_KEY;
   private SECRET_KEY = process.env.SENS_SECRET_KEY;
   private SERVICE_ID = process.env.SENS_SERVICE_ID;
+
+  constructor(
+    private readonly weatherService: WeatherService,
+    private readonly prisma: PrismaService,
+  ) {}
   // private headers = {
   //   'Content-Type': 'application/json;charset=UTF-8',
   //   'x-ncp-apigw-timestamp': Date.now().toString(),
@@ -74,4 +82,32 @@ export class SmsService {
       //this.logger.error(`Error occurred: ${error.message}`, error.stack);
     }
   }
+
+  async applyNotice(smsApplyDto: SMSApplyDto) {
+    const { phone_number, longitude, latitude } = smsApplyDto;
+    const { city } = await this.weatherService.getCity(latitude, longitude);
+    if (city === 'non-city')
+      throw new BadRequestException('존재하지 않는 지역입니다.');
+
+    return await this.prisma.user.upsert({
+      where: {
+        phone_number,
+      },
+      update: {
+        city,
+      },
+      create: {
+        phone_number,
+        city,
+      },
+    });
+  }
+
+  async getUserListByCity(city: string) {
+    return await this.prisma.user.findMany({
+      where: {
+        city,
+      },
+    });
+  }
 }

src/app/sms/sms-apply.dto.ts

@@ -0,0 +1,16 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { IsNumber, IsString } from 'class-validator';
+
+export class SMSApplyDto {
+  @ApiProperty({ description: '전화번호' })
+  @IsString()
+  phone_number: string;
+
+  @ApiProperty({ description: 'longitude' })
+  @IsNumber()
+  longitude: number;
+
+  @ApiProperty({ description: 'latitude' })
+  @IsNumber()
+  latitude: number;
+}

src/app/sms/sms.controller.ts

@@ -1,10 +1,14 @@
-import { Controller, Param, Post } from '@nestjs/common';
+import { Body, Controller, Param, Post } from '@nestjs/common';
 import { SmsService } from './provider/sms.service';
+import { SMSApplyDto } from './sms-apply.dto';
 
 @Controller('sms')
 export class SmsController {
   constructor(private readonly SmsService: SmsService) {}
-
+  @Post('/notice')
+  async appllyNotice(@Body() smsApplyDto: SMSApplyDto) {
+    return await this.SmsService.applyNotice(smsApplyDto);
+  }
   @Post('/:phone_number')
   async sendSms(@Param('phone_number') phone_number: string) {
     return await this.SmsService.sendSms(phone_number, 'test');

src/app/sms/sms.event-listener.ts

@@ -44,8 +44,7 @@ export class SmsListener {
           overpassCoords,
         );
         cities.forEach(async (city) => {
-          const users = [{ phone: '01073616616', city }];
-          // const users = await this.smsService.getUsersByCity(city);
+          const users = await this.smsService.getUserListByCity(city);
           users.forEach(async (user) => {
             //     await this.smsService.sendSms(
             //       user.phone,
@@ -61,7 +60,8 @@ export class SmsListener {
             //     );
 
             //테스트용
-            console.log(`
+            if (user)
+              console.log(`
         [SRT] 태풍 경보 알림
         ${typhoonPrediction1.prediction_date}~${typhoonPrediction2.prediction_date}에
         ${user.city}에 태풍(${name})위험이 예측되었습니다.(기준 일자 : ${typhoonPrediction1.observation_date})