insatller fee

server/controllers/GPS.InstalledDevice.js

@@ -4,64 +4,63 @@ const User = require('../models/GPS.User')
 const InstalledDevice = require('../models/GPS.InstalledDevice')
 const Device = require('../models/GPS.Device')
 const userGPS = require('../models/GPS.User')
+const Fee = require('../models/GPS.Fee')
 const Score = require('../models/GPS.Score')
 const { _sr } = require('../plugins/serverResponses')
 const { notifyAdmin } = require('../WebSocket/controllers/admin_EventsController')
-const { isDeviceRegisteredOnKoja } = require('../kojaWebService')
+const { findDeviceByImeiOnKoja } = require('../kojaWebService')
 
 module.exports.deviceRegistration = [
   [body('IMEI').notEmpty().isString().withMessage('لطفا IMEI را وارد یا تصحیح کنید')],
   checkValidations(validationResult),
   async (req, res) => {
     const IMEI = req.body.IMEI
-
+    console.log('IMEI ******************', IMEI)
     try {
-      const device = await Device.findOne({ IMEI })
-      if (!device) {
-        return res.status(404).json({ msg: 'این IMEI وجود ندارد' })
-      }
-      if (device.status === 1) {
+      const installedDevice = await InstalledDevice.findOne({ IMEI })
+      // // const installedDevice = false
+      if (installedDevice) {
         return res.status(400).json({ msg: 'این IMEI قبلا ثبت شده ' })
       }
-      const isRegistered = await isDeviceRegisteredOnKoja(IMEI)
-
-      if (isRegistered) {
-        let installedDeviceId = null
-        try {
-          const data = {
-            deviceId: device.id,
-            status: 0,
-            registerDate: new Date(),
-            userId: req.user_id,
-            IMEI: req.body.IMEI
-          }
-          // 1.add to installed device
-          const installedDevice = await InstalledDevice.create(data)
-          installedDeviceId = installedDevice._id
-          // 2. change status
-          await Device.findOneAndUpdate({ IMEI }, { status: 1 })
-
-          // 3. add to wallet
-          await userGPS.findByIdAndUpdate(req.user_id, { $inc: { walletBalance: 100_000 } })
-
-          notifyAdmin('newInstallDeviceRequest')
-          res.status(201).json({ msg: 'مبلغ صد هزار تومان به کیف پول شما اضافه شد' })
-        } catch (err) {
-          console.log('Error in Db Transactions', err?.message)
-          if (installedDeviceId) {
-            try {
-              await InstalledDevice.deleteOne({ _id: installedDeviceId })
-              console.log('Rollback 1/2: InstalledDevice deleted.')
-              await Device.findOneAndUpdate({ IMEI }, { status: 0 })
-              console.log('Rollback 2/2: Device status reset to 0.')
-            } catch (error) {
-              console.error('CRITICAL: Rollback failed for some changes. MANUAL INTERVENTION REQUIRED.', error)
-            }
-          }
-          return res.status(err?.status || 500).json({ msg: err?.msg || 'خطا در تراکنش های دیتابیس ' })
+      // const isRegisteredOnKoja = true
+      const RegisteredDevice = await findDeviceByImeiOnKoja(IMEI)
+      if (!RegisteredDevice) {
+        return res.status(400).json({ msg: 'هنوز در سامانه ردیاب ثبت نشده است.' })
+      }
+       let installedDeviceId = null
+      try {
+        const fee = await Fee.findOne({ title: 'install_fee' })
+        if (!fee) {
+          return res.status(400).json({ msg: 'هزینه نصب یافت نشد' })
         }
-      } else {
-        res.status(400).json({ msg: 'هنوز در سامانه ردیاب ثبت نشده است.' })
+         const data = {
+          // deviceId: RegisteredDevice.deviceId,
+          deviceType: RegisteredDevice.device_type.name,
+          status: 1,
+          registerDate: new Date(),
+          userId: req.user_id,
+          IMEI: req.body.IMEI
+        }
+        // 1.add to installed device
+        const installedDevice = await InstalledDevice.create(data)
+        installedDeviceId = installedDevice._id
+
+        // 2. add to wallet
+        await userGPS.findByIdAndUpdate(req.user_id, { $inc: { walletBalance:fee.amount } })
+
+        notifyAdmin('newInstallDeviceRequest')
+        res.status(201).json({ msg: 'مبلغ صد هزار تومان به کیف پول شما اضافه شد' })
+      } catch (err) {
+        console.log('Error in Db Transactions', err?.message)
+        if (installedDeviceId) {
+          try {
+            await InstalledDevice.deleteOne({ _id: installedDeviceId })
+            console.log('Rollback: InstalledDevice deleted.')
+          } catch (error) {
+            console.error('CRITICAL: Rollback failed for some changes. MANUAL INTERVENTION REQUIRED.', error)
+          }
+        }
+        return res.status(err?.status || 500).json({ msg: err?.msg || 'خطا در تراکنش های دیتابیس ' })
       }
     } catch (err) {
       console.log('deviceRegistration Error: ', err?.message)
@@ -147,7 +146,7 @@ module.exports.getAllForAdmin = async (req, res) => {
     // }
 
     const data = await InstalledDevice.find()
-      //   .sort({ [sortField]: sortOrder })
+        .sort({ created_at: -1 })
       .populate('deviceId')
       .populate('userId', 'shopName national_code first_name last_name mobile_number city_name province_name')
     //   .skip(skip)