Merge pull request #9 from purwadhikafullstack/development

Development

Author: jordansmrd

apps/api/package.json

@@ -21,6 +21,7 @@
     "bcrypt": "^5.1.1",
     "cors": "^2.8.5",
     "cross-env": "^7.0.3",
+    "date-fns": "^3.6.0",
     "dotenv": "^16.4.5",
     "express": "^4.18.2",
     "googleapis": "^140.0.0",
@@ -38,6 +39,7 @@
   "devDependencies": {
     "@types/bcrypt": "^5.0.2",
     "@types/cors": "^2.8.17",
+    "@types/date-fns": "^2.6.0",
     "@types/express": "^4.17.21",
     "@types/haversine": "^1.1.8",
     "@types/jsonwebtoken": "^9.0.6",
@@ -53,4 +55,4 @@
   "prisma": {
     "seed": "ts-node --compiler-options {\"module\":\"CommonJS\"} prisma/seed.ts"
   }
-}
+}

apps/api/prisma/migrations/20240713093953_add_is_default_store/migration.sql

@@ -0,0 +1,16 @@
+/*
+  Warnings:
+
+  - You are about to drop the column `updated_by` on the `stock_histories` table. All the data in the column will be lost.
+  - You are about to drop the column `updated_date` on the `stock_histories` table. All the data in the column will be lost.
+
+*/
+-- DropForeignKey
+ALTER TABLE `stock_histories` DROP FOREIGN KEY `stock_histories_updated_by_fkey`;
+
+-- AlterTable
+ALTER TABLE `stock_histories` DROP COLUMN `updated_by`,
+    DROP COLUMN `updated_date`;
+
+-- AlterTable
+ALTER TABLE `stores` ADD COLUMN `is_default` BOOLEAN NOT NULL DEFAULT false;

apps/api/prisma/schema.prisma

@@ -81,7 +81,6 @@ model User {
   updatedProducts       Product[]      @relation("UpdatedProducts")
   userAddress           UserAddress[]
   createdStockHistories StockHistory[] @relation("CreatedStockHistories")
-  updatedStockHistories StockHistory[] @relation("UpdatedStockHistories")
   carts                 Cart[]
   orders                Order[]
   accounts              Account[]
@@ -124,6 +123,7 @@ model Store {
   postalCode      String?     @map(name: "postal_code")
   longitude       Float?
   latitude        Float?
+  isDefault       Boolean     @default(false) @map(name: "is_default")
   createdDate     DateTime    @default(now()) @map(name: "created_date")
   updatedDate     DateTime    @updatedAt @map(name: "updated_date")
   stocks          Stock[]
@@ -212,9 +212,6 @@ model StockHistory {
   createdByUser User?    @relation("CreatedStockHistories", fields: [createdBy], references: [id])
   createdBy     String?  @map(name: "created_by")
   createdDate   DateTime @default(now()) @map(name: "created_date")
-  updatedByUser User?    @relation("UpdatedStockHistories", fields: [updatedBy], references: [id])
-  updatedBy     String?  @map(name: "updated_by")
-  updatedDate   DateTime @updatedAt @map(name: "updated_date")
 
   @@map(name: "stock_histories")
 }

apps/api/src/actions/auth.action.ts

@@ -13,7 +13,7 @@ import { API_KEY } from '../config';
 import { sign } from 'jsonwebtoken';
 import { createCartQuery, getCartByUserIDQuery } from '@/queries/cart.query';
 import { getStoresQuery } from '@/queries/store.query';
-import { getNearestStores } from '@/utils/store.util';
+import { getNearestStore } from '@/utils/store.util';
 
 const registerAction = async (data: RegisterAuth): Promise<User> => {
   try {
@@ -49,7 +49,7 @@ const loginAction = async (data: Auth) => {
 
     if (!cart?.id) {
       const { stores } = await getStoresQuery({});
-      const store = getNearestStores({ stores, userLocation });
+      const store = getNearestStore({ stores, userLocation });
 
       await createCartQuery({
         userId: user.id,

apps/api/src/actions/discount.action.ts

@@ -8,9 +8,10 @@ import {
   createDiscountQuery,
   getDiscountByIDQuery,
   getDiscountByProductIdAndStoreIdQuery,
-  getDiscountQuery,
+  getDiscountsQuery,
   getDiscountsByStoreIDQuery,
   updateDiscountQuery,
+  deleteDiscountQuery,
 } from '@/queries/discount.query';
 import { Discount } from '@prisma/client';
 
@@ -25,11 +26,11 @@ const createDiscountAction = async (
   }
 };
 
-const getDiscountAction = async (
+const getDiscountsAction = async (
   filters: IFilterDiscount,
 ): Promise<IResultDiscount> => {
   try {
-    const data = await getDiscountQuery(filters);
+    const data = await getDiscountsQuery(filters);
     return data;
   } catch (err) {
     throw err;
@@ -62,11 +63,18 @@ const getDiscountByIDAction = async (id: string): Promise<Discount | null> => {
   }
 };
 
-const getDiscountByProductIdAndStoreIdAction = async (productId: string, storeId: string): Promise<Discount | null> => {
+const getDiscountByProductIdAndStoreIdAction = async (
+  productId: string,
+  storeId: string,
+): Promise<Discount | null> => {
   try {
-    if (!productId || !storeId) throw new Error("Please fill product ID and store ID");
+    if (!productId || !storeId)
+      throw new Error('Please fill product ID and store ID');
 
-    const discount = await getDiscountByProductIdAndStoreIdQuery(productId, storeId);
+    const discount = await getDiscountByProductIdAndStoreIdQuery(
+      productId,
+      storeId,
+    );
     if (!discount) throw new HttpException(404, 'Data not found');
 
     return discount;
@@ -87,11 +95,21 @@ const updateDiscountAction = async (
   }
 };
 
+const deleteDiscountAction = async (id: string): Promise<Discount> => {
+  try {
+    const discount = await deleteDiscountQuery(id);
+    return discount;
+  } catch (err) {
+    throw err;
+  }
+};
+
 export {
+  deleteDiscountAction,
   updateDiscountAction,
   getDiscountByIDAction,
   createDiscountAction,
-  getDiscountAction,
+  getDiscountsAction,
   getDiscountsByStoreIDAction,
   getDiscountByProductIdAndStoreIdAction,
 };

apps/api/src/actions/order.action.ts

@@ -5,7 +5,8 @@ import {
   IResultOrder,
 } from '@/interfaces/order.interface';
 import {
-  confirmShippingOrderQuery,
+  cancelUnconfirmedOrdersQuery,
+  confirmShippingOrdersQuery,
   createOrderQuery,
   getOrderByIDQuery,
   getOrdersQuery,
@@ -43,17 +44,27 @@ const createOrderAction = async (data: IOrder): Promise<Order | null> => {
   }
 };
 
-const confirmShippingOrderAction = async () => {
+const confirmShippingOrdersAction = async () => {
   try {
-    const orders = await confirmShippingOrderQuery();
+    const orders = await confirmShippingOrdersQuery();
+    return orders;
+  } catch (err) {
+    throw err;
+  }
+};
+
+const cancelUnconfirmedOrdersAction = async () => {
+  try {
+    const orders = await cancelUnconfirmedOrdersQuery();
     return orders;
   } catch (err) {
     throw err;
   }
 };
 
 export {
-  confirmShippingOrderAction,
+  confirmShippingOrdersAction,
+  cancelUnconfirmedOrdersAction,
   getOrdersAction,
   getOrderByIDAction,
   createOrderAction,

apps/api/src/actions/payment.action.ts

@@ -10,6 +10,7 @@ import path from 'path';
 import fs from 'fs';
 import * as handlebars from 'handlebars';
 import { transporter } from '../helpers/nodemailer';
+import { ORDER_STATUS } from '@/constants/order.constant';
 
 const prisma = new PrismaClient();
 
@@ -36,7 +37,7 @@ const createPaymentAction = async (orderId: string) => {
           'paymentReminder.hbs',
         );
 
-        const url = `http://localhost:3000/users/orders/confirmation/${order.id}`;
+        const url = `${process.env.FRONTEND_URL}/users/orders/confirmation/${order.id}`;
 
         const templateSource = fs.readFileSync(templatePath, 'utf-8');
 
@@ -77,6 +78,77 @@ const updatePaymentStatusAction = async (
 ): Promise<Order> => {
   try {
     const order = await updatePaymentStatusQuery(orderId, orderStatus);
+    if (
+      order.paymentMethod === 'BANK' &&
+      orderStatus === ORDER_STATUS.menungguPembayaran
+    ) {
+      try {
+        const user = await prisma.user.findUnique({
+          where: {
+            id: order.userId,
+          },
+        });
+
+        const templatePath = path.join(
+          __dirname,
+          '../templates',
+          'paymentFailed.hbs',
+        );
+
+        const templateSource = fs.readFileSync(templatePath, 'utf-8');
+
+        const compiledTemplate = handlebars.compile(templateSource);
+
+        const html = compiledTemplate({
+          email: user?.email,
+        });
+
+        await transporter.sendMail({
+          from: 'sender address',
+          to: user?.email || '',
+          subject: 'Payment Failed',
+          html,
+        });
+      } catch (err) {
+        throw err;
+      }
+    }
+
+    if (
+      order.paymentMethod === 'BANK' &&
+      orderStatus === ORDER_STATUS.diproses
+    ) {
+      try {
+        const user = await prisma.user.findUnique({
+          where: {
+            id: order.userId,
+          },
+        });
+
+        const templatePath = path.join(
+          __dirname,
+          '../templates',
+          'paymentSuccess.hbs',
+        );
+
+        const templateSource = fs.readFileSync(templatePath, 'utf-8');
+
+        const compiledTemplate = handlebars.compile(templateSource);
+
+        const html = compiledTemplate({
+          email: user?.email,
+        });
+
+        await transporter.sendMail({
+          from: 'sender address',
+          to: user?.email || '',
+          subject: 'Payment Success',
+          html,
+        });
+      } catch (err) {
+        throw err;
+      }
+    }
     return order;
   } catch (err) {
     throw err;

apps/api/src/actions/product.action.ts

@@ -4,6 +4,7 @@ import {
   createProductQuery,
   deleteProductImageQuery,
   deleteProductQuery,
+  getAvailableProductsByStoreIDQuery,
   getProductByIDQuery,
   getProductBySlugOrNameQuery,
   getProductsQuery,
@@ -28,6 +29,16 @@ const getProductsAction = async (
   }
 };
 
+const getAvailableProductsByStoreIDAction = async (
+  filters: IFilterProduct,
+): Promise<IResultProduct> => {
+  try {
+    const products = await getAvailableProductsByStoreIDQuery(filters);
+    return products;
+  } catch (err) {
+    throw err;
+  }
+};
 const getProductByIDAction = async (id: string): Promise<Product | null> => {
   try {
     const product = await getProductByIDQuery(id);
@@ -120,4 +131,5 @@ export {
   getProductBySlugAction,
   createProductImageAction,
   deleteProductImageAction,
+  getAvailableProductsByStoreIDAction,
 };

apps/api/src/actions/report.action.ts

@@ -2,8 +2,12 @@ import {
   getSalesReportPerCategoryQuery,
   getSalesReportPerMonthQuery,
   getSalesReportPerProductQuery,
+  getSalesReportTotalCategoryQuery,
+  getSalesReportTotalProductQuery,
+  getStockReportDetailQuery,
+  getStockReportPerMonthQuery,
 } from '@/queries/report.query';
-import { IFilterReport } from '@/interfaces/report.interface';
+import { IFilterReport, IFilterReportTable } from '@/interfaces/report.interface';
 
 const getSalesReportPerMonthAction = async (filters: IFilterReport) => {
   try {
@@ -32,8 +36,48 @@ const getSalesReportPerCategoryAction = async (filters: IFilterReport) => {
   }
 };
 
+const getSalesReportTotalProductAction = async (filters: IFilterReport) => {
+  try {
+    const data = await getSalesReportTotalProductQuery(filters);
+    return data;
+  } catch (err) {
+    throw err;
+  }
+};
+
+const getSalesReportTotalCategoryAction = async (filters: IFilterReport) => {
+  try {
+    const data = await getSalesReportTotalCategoryQuery(filters);
+    return data;
+  } catch (err) {
+    throw err;
+  }
+};
+
+const getStockReportPerMonthAction = async (filters: IFilterReport) => {
+  try {
+    const data = await getStockReportPerMonthQuery(filters);
+    return data;
+  } catch (err) {
+    throw err;
+  }
+};
+
+const getStockReportDetailAction = async (filters: IFilterReportTable) => {
+  try {
+    const data = await getStockReportDetailQuery(filters);
+    return data;
+  } catch (err) {
+    throw err;
+  }
+};
+
 export {
   getSalesReportPerMonthAction,
   getSalesReportPerProductAction,
   getSalesReportPerCategoryAction,
+  getSalesReportTotalProductAction,
+  getSalesReportTotalCategoryAction,
+  getStockReportPerMonthAction,
+  getStockReportDetailAction,
 };