Ordini

src/server/models/orderscart.js

@@ -0,0 +1,179 @@
+const mongoose = require('mongoose');
+const Schema = mongoose.Schema;
+
+const shared_consts = require('../tools/shared_nodejs');
+
+const Order = require('../models/order');
+
+const { ObjectID } = require('mongodb');
+
+const OrdersCartSchema = new Schema({
+  idapp: {
+    type: String
+  },
+  numorder: { type: Number },
+  userId: { type: Schema.Types.ObjectId, ref: 'User' },
+  totalQty: { type: Number, default: 0 },
+  totalPrice: { type: Number, default: 0 },
+  items: [
+    {
+      order:
+        { type: Schema.Types.ObjectId, ref: 'Order' }
+    }
+  ],
+  status: {
+    type: Number
+  },
+  note: {
+    type: String
+  },
+  modify_at: {
+    type: Date
+  },
+  created_at: {
+    type: Date
+  },
+});
+
+var OrdersCart = module.exports = mongoose.model('OrdersCart', OrdersCartSchema);
+
+module.exports.findAllIdApp = async function (idapp, userId) {
+  const myfind = { idapp, userId };
+
+  return await OrdersCart.findOne(myfind);
+};
+
+
+module.exports.getNewNumOrder = async function (uid, idapp) {
+  let query = { userId: uid, idapp }
+  let numorder = 1;
+  let numorderrec = await OrdersCart.find(query).sort({ numorder: -1 }).limit(1);
+  if (numorderrec.length <= 0)
+    numorder = 1;
+  else
+    numorder = numorderrec[0].numorder;
+
+  if (numorder) {
+    numorder++
+  } else {
+    numorder = 1;
+  }
+
+  return numorder;
+
+};
+
+module.exports.getOrdersCartByUserId = async function (uid, idapp) {
+  let query = { userId: uid, idapp, status: { $gte: shared_consts.OrderStatus.CHECKOUT_CONFIRMED } }
+  const myorderscart = await OrdersCart.find(query);
+
+  for (let ind = 0; ind < myorderscart.length; ind++) {
+    for (const idkey in myorderscart[ind].items) {
+      try {
+        idorder = myorderscart[ind].items[idkey]._id.toString();
+        const myorder = myorderscart[ind].items[idkey].order;
+        if (!!myorder) {
+          idorder = myorderscart[ind].items[idkey].order._id.toString();
+        }
+        const myord = await Order.getTotalOrderById(idorder);
+        if (myord.length > 0) {
+          myorderscart[ind].items[idkey]._doc.order = myord[0];
+        }
+      } catch (e) {
+        console.log('err', e);
+      }
+    }
+  }
+
+  /*  if (!!mycart) {
+      for (const idkey in mycart.items) {
+        try {
+          idorder = mycart.items[idkey]._id.toString();
+          const myorder = mycart.items[idkey].order;
+          if (!!myorder) {
+            idorder = mycart.items[idkey].order._id.toString();
+          }
+          const myord = await Order.getTotalOrderById(idorder);
+          if (myord.length > 0) {
+            mycart.items[idkey]._doc.order = myord[0];
+          }
+        } catch (e) {
+          console.log('err', e);
+        }
+      }
+      return mycart;
+    }*/
+  return myorderscart
+  // return null;
+}
+
+module.exports.updateOrdersCartById = function (id, newOrdersCart, callback) {
+  let query = { id: id }
+  OrdersCart.find(query, function (err, c) {
+    if (err) throw err
+
+    //exist cart in databse
+    if (c.length > 0) {
+      OrdersCart.findOneAndUpdate(
+        { _id: id },
+        {
+          $set: {
+            items: newOrdersCart.items,
+            totalQty: newOrdersCart.totalQty,
+            totalPrice: newOrdersCart.totalPrice,
+            userId: userId,
+            status: newOrdersCart.status,
+            numorder: newOrdersCart.numorder,
+            note: newOrdersCart.note,
+            modify_at: new Date(),
+          }
+        },
+        { new: true },
+        callback
+      )
+    } else {
+      //no cart in database
+      newOrdersCart.save(callback)
+    }
+  })
+}
+
+module.exports.createOrdersCart = async function (newOrdersCart) {
+  return await newOrdersCart.save()
+}
+
+OrdersCartSchema.pre('save', async function (next) {
+
+  try {
+    if (this.isNew) {
+      try {
+        const myrec = await User.findOne({ idapp: this.idapp }).limit(1).sort({ neworder: -1 });
+
+        if (!!myrec) {
+          this.neworder = myrec._doc.neworder + 1;
+        } else {
+          this.neworder = 1;
+        }
+      } catch (e) {
+        this.neworder = 2;
+      }
+    }
+
+    /*
+    if (user.isModified('password')) {
+      bcrypt.genSalt(10, (err, salt) => {
+        bcrypt.hash(user.password, salt, (err, hash) => {
+          user.password = hash;
+          next();
+        });
+      });
+    } else {
+      next();
+    }
+    */
+
+    next();
+  } catch (e) {
+    console.error(e.message);
+  }
+});