HasuraNodeComponent/asessorScheduler.js at main · UPHRH-platform/HasuraNodeComponent · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
import cron from "node-cron";
import axios from "axios";

// Replace 'YOUR_API_ENDPOINT' with the actual API endpoint for updating status
const GET_THRESHOLD_DAYS = '/api/rest/config/search';
const GET_FORM_SUBMISSIONS_BY_STATUS = '/api/rest/getFormSubmissionsByStatus';
const UPDATE_ENDPOINT = "/api/rest/UpdateFormSubmissionStatus";
const UPDATE_ASSESSMENT_ENDPOINT = "/rest/assessorUpdateForm"
const SCHEDULES_ENDPOINT = "/rest/getAssessmentSchedule";
const TARGET_URL = process.env.TARGET_URL || "https://hasura.upsmfac.org";
const REACT_APP_NODE_URL = process.env.REACT_APP_API_URL || "https://uphrh.in/api/api";
const AUTH_TOKEN = process.env.REACT_APP_AUTH_TOKEN;

// Creating an Axios instance with custom headers
const axiosInstance = axios.create({
    baseURL: TARGET_URL,
    headers: {
      "x-hasura-admin-secret": "myadminsecretkey",
      "Hasura-Client-Name": "hasura-console"
      // Add any other headers you need
    },
  });

//Get threshold days from DB
const fetchThreshold = () => {
    return new Promise(async(resolve) => {
            try {
                const reqData = {"searchString" : {"status": {"_eq": true}, "type": {"_eq": "scheduler"}},"offSet":0,"limit": 100};
                const response = await axiosInstance.post(TARGET_URL+GET_THRESHOLD_DAYS,reqData);
                resolve( response.data.config);
            } catch (error) {
                console.error('Error fetching threshold days:', error.message);
                throw error;
            }
      });

};

//Get submitted date and reviewed date from DB
const fetchData = (arr) => {
    return new Promise(async(resolve) => {
            try {
                const reqData = {"params": arr};
                const response = await axiosInstance.post(TARGET_URL+GET_FORM_SUBMISSIONS_BY_STATUS, reqData);
                resolve(response.data.form_submissions);
            } catch (error) {
                console.error('Error fetching application data:', error.message);
                throw error;
            }
    });
};

// Update status using the API
const updateStatus = (updateStr) => {
    return new Promise(async(resolve) => {
            try {
                console.log(updateStr);
                const response = await axiosInstance.post(TARGET_URL+UPDATE_ENDPOINT, updateStr);
                resolve(response.data.update_form_submissions.returning);
            } catch (error) {
                console.error('Error updating status:', error.message);
                throw error;
            }
    });
  };

  const sendEmailNotification = async (postData) => {
    const res = await axiosInstance.post(
      REACT_APP_NODE_URL + "/email/notify",
      postData,
      {
        headers: {
          "Content-Type": "application/json",
          Authorization: AUTH_TOKEN,
        },
      }
    );
    return res;
  };

// Schedule the task to run every day at midnight
const scheduledJob = cron.schedule('0 0 * * *', async () => {
  console.log('Cron job running at 12 AM');
  try {
    const currentDate = new Date();
    const thresholdDaysMap = await fetchThreshold();
    const statusArr = thresholdDaysMap.filter(obj => obj.hasOwnProperty("name")).map(obj => obj["name"]);
    const applicationData = await fetchData(statusArr);
    const emailSub = "Application rejected!";
    const emailTemplate = "<!DOCTYPE html><html><head><meta charset='utf-8'><title>Your Email Title</title><link href='https://fonts.googleapis.com/css2?family=Mulish:wght@400;600&display=swap' rel='stylesheet'></head><body style='font-family: Arial, sans-serif; background-color: #f4f4f4; margin: 0; padding: 0;'><table width='100%' bgcolor='#ffffff' cellpadding='0' cellspacing='0' border='0'><tr><td style='padding: 20px; text-align: center; background-color: #F5F5F5;'><img src='https://regulator.upsmfac.org/images/upsmf.png' alt='Logo' style='max-width: 360px;'></td></tr></table><table width='100%' bgcolor='#ffffff' cellpadding='0' cellspacing='0' border='0'><tr><td style='padding: 36px;'><p style='color: #555555; font-size: 18px; font-family: 'Mulish', Arial, sans-serif;'>Dear ${applicantName},</p><p style='color: #555555; font-size: 18px; line-height: 1.6; font-family: 'Mulish', Arial, sans-serif;'>We hope this email finds you well. We are writing to kindly request the resubmission of your application for the affiliation process. We apologize for any inconvenience caused, but it appears that there was an issue with the initial submission. Following is the reason for rejection ${rejectedRemarks}</p></td></tr></table></body></html>";

    applicationData.forEach(async (item) => {
        var form_status_updated_at = new Date(item.updated_at);

        const updatedDateDifference = Math.abs(form_status_updated_at.getDate() - currentDate.getDate());

        const filteredObject = thresholdDaysMap.find(obj => obj.name === item.form_status);
        // Update application only for those status which has a threshold by admin
        if(filteredObject){
            if (updatedDateDifference > filteredObject.value) {
                // Update the status for this item
                const remarksStr = "Application Rejected as there was no updates from more than "+filteredObject.value+" days";
                const updateStr = { form_id: item.applicant_form_id, form_status: "Rejected", remarks: remarksStr, updated_at: new Date().toLocaleString()};
                const updatedRec = await updateStatus(updateStr);
                updatedRec.forEach( async (item1) => {
                    console.log('Status updated for item with ID: '+ item1.form_id);

                    var email = emailTemplate.replace("${rejectedRemarks}",remarksStr);
                    email = email.replace("${applicantName}",item.institute.name);
                    const emailData = {
                      recipientEmail: [item.institute.email],
                      emailSubject: emailSub,
                      emailBody: email,
                    };

                    await sendEmailNotification(emailData);
                    console.log('Notification sent..');
                });
            }
        }
    });

    updateInspectionScheduleStatus();

  } catch (error) {
    console.error('Error updating status:', error.message);
  }
}, {
  //scheduled: true,
  timezone: 'Asia/Kolkata',
});

const updateInspectionScheduleStatus = async() => {
  console.log('updating Inspection Schedule Status...');
  const res = await getAssessmentSchedule();
  const today = new Date();
  res.forEach( async (item) => {

    const assessment_date = new Date(item.date);
    const updatedDateDifference = assessment_date.getDate() - today.getDate();

    if(updatedDateDifference < 0 && item.status === "Upcoming"){
      //console.log('item: '+item.Applicant_form.form_id);
      // update Assessor Status in form_submission to Delayed
      await updateStatus(
       { form_id: item.Applicant_form.form_id,
        form_status: "Inspection Delayed",
        remarks: "Inspection Delayed because the inspection was not undertaken on the scheduled date",
        updated_at: new Date().toLocaleString()
       }
      )
      await updateAssessmentStatus({
        form_id: item.Applicant_form.form_id,
        form_status: "Inspection Delayed"
      });
    }

});
};

// update Assessor Status in assessment_schedule to Delayed
const updateAssessmentStatus = (reqBody) => {
  console.log('updating Assessment Status in assessment_schedule table to Delayed...');
  return new Promise(async(resolve) => {
          try {
              const response = await axiosInstance.put(REACT_APP_NODE_URL+UPDATE_ASSESSMENT_ENDPOINT, reqBody,
                {
                  headers: {
                    "Content-Type": "application/json",
                    Authorization: AUTH_TOKEN,
                  },
                });
              resolve(response);
          } catch (error) {
              console.error('Error updating status:', error.message);
              throw error;
          }
  });
};

const getAssessmentSchedule = () => {
  console.log('getting Assessment Schedule...');
  return new Promise(async(resolve) => {
          try {
              const reqData = {};
              const response = await axiosInstance.post(REACT_APP_NODE_URL+SCHEDULES_ENDPOINT, reqData,
                {
                  headers: {
                    "Content-Type": "application/json",
                    Authorization: AUTH_TOKEN,
                  },
                });

              resolve(response.data.assessment_schedule);
          } catch (error) {
              console.error('Error fetching application data:', error.message);
              throw error;
          }
  });
};
console.log('Scheduler started. Waiting for scheduled tasks...');
export default {
  scheduledJob
};