Merge pull request #446 from topcoder-platform/migrate-jobcandidates-scripts

Add migrate jobcandidates scripts and commands

Author: LieutenantRoger

.gitignore

@@ -40,6 +40,7 @@ build/Release
 # Dependency directories
 node_modules/
 jspm_packages/
+scripts/withdrawn-migration/temp/
 
 # Snowpack dependency directory (https://snowpack.dev/)
 web_modules/

data/demo-data.json

@@ -54,7 +54,7 @@
             "isApplicationPageActive": false,
             "minSalary": 100,
             "maxSalary": 200,
-            "hoursPerWeek": 20,
+            "hoursPerWeek": 80,
             "jobLocation": "Any location",
             "jobTimezone": "GMT",
             "currency": "USD",
@@ -765,7 +765,7 @@
             "id": "b0fc417b-3f41-4c06-9f2b-8e680c3a03c6",
             "jobId": "728ff056-63f6-4730-8a9f-3074acad8479",
             "userId": "a55fe1bc-1754-45fa-9adc-cf3d6d7c377a",
-            "status": "open",
+            "status": "placed",
             "externalId": "300234321",
             "resume": "http://example.com",
             "remark": "excellent",
@@ -793,7 +793,7 @@
             "id": "02a622f4-7894-4ac0-a823-a952ffa1b3f3",
             "jobId": "728ff056-63f6-4730-8a9f-3074acad8479",
             "userId": "a55fe1bc-1754-45fa-9adc-cf3d6d7c377a",
-            "status": "open",
+            "status": "selected",
             "externalId": "300234321",
             "resume": "http://example.com",
             "remark": "excellent",
@@ -807,7 +807,7 @@
             "id": "b32b4819-7bfa-49a8-851e-69cdddff8149",
             "jobId": "728ff056-63f6-4730-8a9f-3074acad8479",
             "userId": "a55fe1bc-1754-45fa-9adc-cf3d6d7c377a",
-            "status": "open",
+            "status": "skills-test",
             "externalId": "300234321",
             "resume": "http://example.com",
             "remark": "excellent",
@@ -1359,11 +1359,11 @@
         {
             "id": "d6103727-6615-4168-8169-0485577bfb3f",
             "projectId": 111,
-            "userId": "bef43122-426b-4b2b-acdd-9b5b3bd1c0bf",
-            "jobId": "a8adb1f8-a6ee-48b1-8661-33bd851b726e",
+            "userId": "a55fe1bc-1754-45fa-9adc-cf3d6d7c377a",
+            "jobId": "728ff056-63f6-4730-8a9f-3074acad8479",
             "status": "placed",
             "startDate": "2021-03-27",
-            "endDate": "2021-04-27",
+            "endDate": "2021-08-23",
             "memberRate": 13.23,
             "customerRate": 13,
             "rateType": "hourly",

package.json

@@ -30,7 +30,10 @@
     "local:reset": "npm run delete-index -- --force || true && npm run create-index -- --force && npm run init-db force",
     "cov": "nyc --reporter=html --reporter=text npm run test",
     "demo-payment-scheduler": "node scripts/demo-payment-scheduler/index.js && npm run index:all -- --force",
-    "demo-payment": "node scripts/demo-payment"
+    "demo-payment": "node scripts/demo-payment",
+    "migrate:backup-withdrawn": "node scripts/withdrawn-migration/backup.js",
+    "migrate:migration-withdrawn": "node scripts/withdrawn-migration/migration.js",
+    "migrate:restore-withdrawn": "node scripts/withdrawn-migration/restore.js"
   },
   "keywords": [],
   "author": "",

scripts/withdrawn-migration/backup.js

@@ -0,0 +1,67 @@
+/**
+ * Back up the jobCandidates that we will update it's status
+ */
+const config = require('config')
+const Sequelize = require('sequelize')
+const fs = require('fs')
+const path = require('path')
+const { JobCandidate, ResourceBooking, Job } = require('../../src/models')
+const logger = require('../../src/common/logger')
+
+const currentStep = 'Backup'
+
+async function backup () {
+  logger.info({ component: currentStep, message: '*************************** Backup process started ***************************' })
+  const filePath = path.join(__dirname, '/temp/')
+  const Op = Sequelize.Op
+  const jobCandidates = await JobCandidate.findAll({
+    where: {
+      status: 'placed'
+    }
+  })
+
+  for (let i = 0; i < jobCandidates.length; i++) {
+    const jc = jobCandidates[i]
+    const job = await Job.findById(jc.jobId)
+    const rb = await ResourceBooking.findOne({
+      where: {
+        userId: jc.userId,
+        jobId: jc.jobId
+      }
+    })
+    let completed = false
+    if (rb && rb.endDate) {
+      completed = new Date(rb.endDate) < new Date() && new Date(rb.endDate).toDateString() !== new Date().toDateString()
+    }
+    if (job.hoursPerWeek > config.JOBS_HOUR_PER_WEEK && !completed) {
+      const statuses = ['applied', 'skills-test', 'phone-screen', 'open', 'interview', 'selected', 'offered']
+      const filter = { [Op.and]: [] }
+      filter[Op.and].push({ status: statuses })
+      filter[Op.and].push({ userId: jc.userId })
+      const candidates = await JobCandidate.findAll({
+        where: filter
+      })
+      if (candidates && candidates.length > 0) {
+        fs.writeFile(filePath + `jobcandidate-backup.json`, JSON.stringify(
+          candidates
+        ), (err) => {
+          if (!err) {
+            logger.info({ component: `${currentStep} Summary`, message: `Backup up finished. There are ${candidates.length} jobCandidates that need to be updated` })
+            logger.info({ component: currentStep, message: '*************************** Backup process finished ***************************' })
+            return
+          }
+          logger.error({ component: currentStep, message: err.message })
+          process.exit(1)
+        })
+      }
+    }
+  }
+}
+
+backup().then(() => {
+  logger.info({ component: currentStep, message: 'Execution Finished!' })
+  process.exit()
+}).catch(err => {
+  logger.error(err.message)
+  process.exit(1)
+})

scripts/withdrawn-migration/migration.js

@@ -0,0 +1,37 @@
+/**
+ * Migration the jobCandidate status into expected status
+ */
+const config = require('config')
+const fs = require('fs')
+const path = require('path')
+const { JobCandidate } = require('../../src/models')
+const logger = require('../../src/common/logger')
+
+const currentStep = 'Migration'
+
+async function migration () {
+  logger.info({ component: currentStep, message: '*************************** Migration process started ***************************' })
+  const filePath = path.join(__dirname, '/temp/')
+  const data = fs.readFileSync(filePath + 'jobCandidate-backup.json', 'utf-8')
+  const jobCandidates = JSON.parse(data)
+  let summary = 0
+  for (var i = 0; i < jobCandidates.length; i++) {
+    const jc = await JobCandidate.findById(jobCandidates[i].id)
+    if (jc) {
+      const oldStatus = jc.status
+      const updated = await jc.update({ status: config.WITHDRAWN_STATUS_CHANGE_MAPPING[jobCandidates[i].status] })
+      summary++
+      logger.info({ component: currentStep, message: `jobCandidate with ${jc.id} status changed from ${oldStatus} to ${updated.status}` })
+    }
+  };
+  logger.info({ component: currentStep, message: `Totally updated ${summary} jobCandidates` })
+  logger.info({ component: currentStep, message: '*************************** Migration process finished ***************************' })
+}
+
+migration().then(() => {
+  logger.info({ component: currentStep, message: 'Execution Finished!' })
+  process.exit()
+}).catch(err => {
+  logger.error(err.message)
+  process.exit(1)
+})

scripts/withdrawn-migration/restore.js

@@ -0,0 +1,36 @@
+/**
+ * Resotre the changed jobCandidates into its original state.
+ */
+const fs = require('fs')
+const path = require('path')
+const { JobCandidate } = require('../../src/models')
+const logger = require('../../src/common/logger')
+
+const currentStep = 'Restore'
+
+async function restore () {
+  logger.info({ component: currentStep, message: '*************************** Restore process started ***************************' })
+  const filePath = path.join(__dirname, '/temp/')
+  const data = fs.readFileSync(filePath + 'jobCandidate-backup.json', 'utf-8')
+  const jobCandidates = JSON.parse(data)
+  let summary = 0
+  for (var i = 0; i < jobCandidates.length; i++) {
+    const jc = await JobCandidate.findById(jobCandidates[i].id)
+    if (jc) {
+      const oldStatus = jc.status
+      const updated = await jc.update({ status: jobCandidates[i].status })
+      summary++
+      logger.info({ component: currentStep, message: `jobCandidate with ${jc.id} status restored from ${oldStatus} to ${updated.status}` })
+    }
+  };
+  logger.info({ component: currentStep, message: `Totally restored ${summary} jobCandidates` })
+  logger.info({ component: currentStep, message: '*************************** Restore process finished ***************************' })
+}
+
+restore().then(() => {
+  logger.info({ component: currentStep, message: 'Execution Finished!' })
+  process.exit()
+}).catch(err => {
+  logger.error(err.message)
+  process.exit(1)
+})