add score page + update score after regiter imei

2025-12-01 20:18:15 +03:30
parent 7b501107cf
commit 176998476d
7 changed files with 234 additions and 104 deletions
@@ -4,7 +4,7 @@ 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 Settings = require('../models/GPS.Settings')
 const Score = require('../models/GPS.Score')
 const { _sr } = require('../plugins/serverResponses')
 const { notifyAdmin } = require('../WebSocket/controllers/admin_EventsController')
@@ -16,60 +16,108 @@ module.exports.deviceRegistration = [
  async (req, res) => {
    const IMEI = req.body.IMEI
    console.log('IMEI ******************', IMEI)
-    try {
-      const installedDevice = await InstalledDevice.findOne({ IMEI })
-      // // const installedDevice = false
-      if (installedDevice) {
-        return res.status(400).json({ msg: 'این IMEI قبلا ثبت شده ' })
-      }
-      // 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: 'هزینه نصب یافت نشد' })
-        }
-         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)
-      if (err.response) {
-        const { status } = err.response
-        return res.status(status || 500).json({ msg: err.message || 'خطا!' })
-      }
-      return res.status(err.status || 500).json({ msg: err.msg || 'خطا در ثبت دستگاه' })
+    const existingInstalledDevice = await InstalledDevice.findOne({ IMEI }).catch(err => {
+      console.log('err in findOne InstalledDevice', err?.message)
+      return res.status(500).json({ msg: 'خطا در دریافت اطلاعات از دیتابیس ثبت دستگاه' })
+    })
+    if (existingInstalledDevice) {
+      return res.status(400).json({ msg: 'این IMEI قبلا ثبت شده ' })
    }
+    // const isRegisteredOnKoja = true
+    let registeredDevice
+    try {
+      registeredDevice = await findDeviceByImeiOnKoja(IMEI)
+    } catch (err) {
+      return res.status(err.status || 500).json({ msg: err.message })
+    }
+    if (!registeredDevice) {
+      return res.status(400).json({ msg: 'هنوز در سامانه ردیاب ثبت نشده است.' })
+    }
+    if (!registeredDevice.device_type || !registeredDevice.device_type.name) {
+      return res.status(400).json({ msg: 'اطلاعات دستگاه ناقص است' })
+    }
+    let installedDeviceId = null
+    let scoreData = null
+    let walletUpdated = false
+    try {
+      const fee = await Settings.findOne({ title: 'install_fee' })
+      if (!fee) {
+        return res.status(400).json({ msg: 'هزینه نصب یافت نشد' })
+      }
+      const score = await Settings.findOne({ title: 'install_score' })
+      if (!score) {
+        return res.status(400).json({ msg: 'امتیاز نصب یافت نشد' })
+      }
+      const data = {
+        // deviceId: RegisteredDevice.deviceId,
+        installationDate: new Date(registeredDevice.activated_at),
+        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 score
+      scoreData = await Score.create({
+        title: 'ثبت دستگاه',
+        deviceId: installedDevice.id,
+        score: score.amount,
+        userId: req.user_id
+      })
+
+      // 3. add to wallet
+      await userGPS.findByIdAndUpdate(req.user_id, {
+        $inc: { walletBalance: fee.amount, score: score.amount, totalScore: score.amount }
+      })
+      walletUpdated = true
+
+      notifyAdmin('newInstallDeviceRequest')
+      res.status(201).json({
+        msg:
+          'مبلغ ' + fee.amount + ' تومان به کیف پول شما اضافه شد و ' + score.amount + ' امتیاز به امتیاز شما اضافه شد'
+      })
+    } 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)
+        }
+      }
+      if (scoreData) {
+        try {
+          await Score.deleteOne({ _id: scoreData._id })
+          console.log('Rollback: Score deleted.')
+        } catch (error) {
+          console.error('CRITICAL: Rollback failed for some changes. MANUAL INTERVENTION REQUIRED.', error)
+        }
+      }
+      if (walletUpdated) {
+        try {
+          const fee = await Settings.findOne({ title: 'install_fee' })
+          const score = await Settings.findOne({ title: 'install_score' })
+          if (fee && score) {
+            await userGPS.findByIdAndUpdate(req.user_id, { $inc: { walletBalance: -fee.amount, score: -score.amount } })
+            console.log('Rollback: Wallet balance and score reverted.')
+          }
+        } catch (error) {
+          console.error('CRITICAL: Rollback failed for wallet update. MANUAL INTERVENTION REQUIRED.', error)
+        }
+      }
+      return res.status(err?.status || 500).json({ msg: err?.msg || 'خطا در تراکنش های دیتابیس ' })
+    }
+
+    // console.log('deviceRegistration Error: ', err?.message)
+    // if (err.response) {
+    //   const { status } = err.response
+    //   return res.status(status || 500).json({ msg: err.message || 'خطا!' })
+    // }
  }
 ]

@@ -146,7 +194,7 @@ module.exports.getAllForAdmin = async (req, res) => {
    // }

    const data = await InstalledDevice.find()
-        .sort({ created_at: -1 })
+      .sort({ created_at: -1 })
      .populate('deviceId')
      .populate('userId', 'shopName national_code first_name last_name mobile_number city_name province_name')
    //   .skip(skip)