import { MySql } from "../helper/mysql";

export default class UserOrderRepository {
  async read(param: Record<string, any>): Promise<Record<string, any>> {
    const sortingField = ["updated"];
    const filterField = ["userId", "storeId"];

    let query = `
      SELECT * FROM order
      WHERE 1=1
    `;
    const values: any[] = [];

    if (param.hasOwnProperty("orderStatus")) {
      query += " AND statusOrder = ?";
      values.push(param.orderStatus);
    }

    if (param.hasOwnProperty("invoice")) {
      query += " AND invoice = ?";
      values.push(param.invoice);
    }

    if (param.hasOwnProperty("filter") && param.hasOwnProperty("value")) {
      const index = filterField.indexOf(param.filter);
      if (index >= 0) {
        query += ` AND ${filterField[index]} = ?`;
        values.push(param.value);
      }
    }

    if (param.hasOwnProperty("sort") && param.hasOwnProperty("direction")) {
      const index = sortingField.indexOf(param.sort);
      if (index >= 0) {
        query += ` ORDER BY ${sortingField[index]} ${param.direction}`;
      }
    }

    if (param.hasOwnProperty("page") && param.hasOwnProperty("limit")) {
      const skip = (Number(param.page) - 1) * Number(param.limit);
      query += " LIMIT ? OFFSET ?";
      values.push(Number(param.limit), skip);
    }

    const result = await MySql.query(query, values);

    const data = {
      paginate: {
        page: param.page,
        total: result.length,
      },
      data: result,
    };

    return data;
  }
}

// export default class UserOrderRepository {
//   async read(param: Record<string, any>): Promise<Record<string, any>> {
//     const result = await prisma.$transaction(async (tx) => {
//       const sortingField = ["updated"];
//       const filterField = ["userId", "storeId"];

//       let condition: any = {
//         where: {},
//       };

//       if (param.hasOwnProperty("orderStatus")) {
//         condition["where"] = {
//           ...condition.where,
//           statusOrder: param.orderStatus,
//         };
//       }

//       if (param.hasOwnProperty("invoice")) {
//         condition["where"] = {
//           ...condition.where,
//           invoice: param.invoice,
//         };
//       }

//       if (param.hasOwnProperty("filter") || param.hasOwnProperty("value")) {
//         const index = filterField.indexOf(param.filter);

//         if (index < 0) {
//           throw new BadRequest();
//         }

//         condition["where"] = {
//           ...condition.where,
//           [filterField[index]]: param.value,
//         };
//       }

//       if (param.hasOwnProperty("sort") && param.hasOwnProperty("direction")) {
//         const index = sortingField.indexOf(param.sort);

//         if (index < 0) {
//           throw new BadRequest();
//         }

//         if (index >= 0) {
//           condition = {
//             ...condition,
//             orderBy: {
//               [sortingField[index]]: param.direction,
//             },
//           };
//         }
//       }

//       if (param.hasOwnProperty("page") && param.hasOwnProperty("limit")) {
//         const skip = (Number(param.page) - 1) * Number(param.limit);

//         condition = {
//           ...condition,
//           skip: skip,
//           take: parseInt(param.limit),
//         };
//       }

//       const records = await tx.order.count({
//         ...condition,
//         skip: undefined,
//         take: undefined,
//       });

//       const query = await tx.order.findMany({
//         ...condition,
//         include: {
//           orderItem: true,
//           orderStatus: {
//             orderBy: {
//               created: "desc",
//             },
//           },
//         },
//       });

//       const data: Record<string, any> = {
//         paginate: {
//           page: param.page,
//           total: records,
//         },
//         data: query,
//       };

//       return data;
//     });

//     return result;
//   }

//   async show(param: Record<string, any>): Promise<Record<string, any>> {
//     const order = await prisma.order.findFirst({ where: { id: param.id } });

//     const data = {
//       data: order,
//     };

//     return data;
//   }

//   async create(param: Record<string, any>): Promise<Result<OrderModel>> {
//     const result = await prisma.$transaction(async (tx) => {
//       await Promise.all(
//         await param.stores.map(async (store: any) => {
//           const order = await tx.order.create({
//             data: {
//               invoice: invoice(),
//               userId: param.userId,
//               userName: param.userName,
//               userPhone: param.userPhone,
//               storeId: store.storeId,
//               storeUserId: store.storeUserId,
//               storeName: store.storeName,
//               storePhone: store.storePhone,
//               paymentId: param.paymentId,
//               paymentName: param.paymentName,
//               paymentPicture: param.paymentPicture,
//               paymentFee: param.paymentFee,
//               paymentFixed: param.paymentFixed,
//               receiverName: param.receiverName,
//               receiverAddress: param.receiverAddress,
//               receiverPhone: param.receiverPhone,
//               receiverLat: param.receiverLat,
//               receiverLng: param.receiverLng,
//               adminFee: param.adminFee,
//               payTotal: store.total,
//               productQty: store.qty,
//               productTotal: store.total,
//               shippingFee: param.shippingFee,
//               statusOrder: "PENDING",
//               statusPayment: "PENDING",
//               statusShipping: "PENDING",
//               orderItem: {
//                 create: store.items,
//               },
//               orderStatus: {
//                 create: {
//                   status: "PENDING",
//                 },
//               },
//               paymentStatus: {
//                 create: {
//                   status: "PENDING",
//                 },
//               },
//               shippingStatus: {
//                 create: {
//                   status: "PENDING",
//                 },
//               },
//             },
//           });
//         })
//       );

//       const data = {
//         data: null,
//       };

//       return data;
//     });

//     return result;
//   }

//   async update(param: Record<string, any>): Promise<void> {
//     await prisma.$transaction(async (tx) => {
//       await tx.order.update({
//         where: {
//           id: param.id,
//         },
//         data: {
//           statusOrder: param.statusOrder,
//           statusPayment: param.statusOrder,
//           statusShipping: param.statusOrder,
//           updated: new Date(),
//         },
//       });

//       await tx.orderStatus.create({
//         data: {
//           orderId: param.id,
//           status: param.statusOrder,
//         },
//       });
//     });
//   }
// }