614 lines
22 KiB
JavaScript
614 lines
22 KiB
JavaScript
const db = require("../models");
|
|
const API = require('../helper/API_Response');
|
|
const db_helper = require("../helper/db_helper");
|
|
const helper = require("../helper/helper");
|
|
const { User, Version, Navigation, Onbording, Cohort,
|
|
SelfPacedSubscription, KnowledgeAsses, MindMap,
|
|
Video, Practicetest, SelfPacedOneTime, ShortUrl } = require("../models");
|
|
|
|
exports.getUserById = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const all = await User.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: input.id
|
|
}
|
|
})
|
|
res.status(200).send(API._200(all));
|
|
};
|
|
exports.getUserByEmail = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const all = await User.findAll({
|
|
where: {
|
|
status: 0,
|
|
email: input.email
|
|
}
|
|
})
|
|
res.status(200).send(API._200(await all));
|
|
};
|
|
exports.by_certy = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
// const input = req.body
|
|
const all = await Version.findAll({
|
|
where: {
|
|
certy_id: input.certy_id
|
|
}
|
|
})
|
|
res.status(200).send(API._200(all));
|
|
};
|
|
exports.addreview = async (req, res) => {
|
|
// const input = req.body
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const data = await db_helper.selectByWhere("FlashcardReviews", { 'user_id': input.user_id, 'device_type': input.device_type, 'app_type': input.app_type })
|
|
if (data.length > 0) {
|
|
input["id"] = data[0].id;
|
|
res.status(200).send(API._200(await db_helper.update("FlashcardReviews", input)));
|
|
} else {
|
|
res.status(200).send(API._200(await db_helper.addData("FlashcardReviews", input)));
|
|
}
|
|
};
|
|
exports.getreview = async (req, res) => {
|
|
// const input = req.body
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const data = await db_helper.selectByWhere("FlashcardReviews", { 'user_id': input.user_id, 'device_type': input.device_type, 'app_type': input.app_type })
|
|
res.status(200).send(API._200(await data));
|
|
};
|
|
exports.getsetting = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const setting = await Navigation.findAll({
|
|
where: {
|
|
user_id: input.user_id,
|
|
status: 0
|
|
}
|
|
})
|
|
if (setting.length <= 0) {
|
|
await db_helper.addData("Navigation", input);
|
|
const sett = await Navigation.findAll({
|
|
where: {
|
|
user_id: input.user_id,
|
|
status: 0
|
|
}
|
|
});
|
|
res.status(200).send(API._200(await sett));
|
|
} else {
|
|
res.status(200).send(API._200(await setting));
|
|
}
|
|
};
|
|
exports.setsetting = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const data = await db_helper.selectByWhere("Navigation", { 'user_id': input.user_id })
|
|
if (data.length <= 0) {
|
|
res.status(200).send(API._200(await db_helper.addData("Navigation", input)));
|
|
|
|
} else {
|
|
let sql = "update app_nav_settings set card_know= :card_know, need_review= :need_review, card_not_seen= :card_not_seen, terms_def= :terms_def, shuffle= :shuffle where user_id= :user_id";
|
|
let que = await db.sequelize.query(sql, { replacements: { card_know: input.card_know, need_review: input.need_review, card_not_seen: input.card_not_seen, terms_def: input.terms_def, shuffle: input.shuffle, user_id: input.user_id } });
|
|
const sett = await Navigation.findAll({
|
|
where: {
|
|
user_id: input.user_id,
|
|
status: 0
|
|
}
|
|
});
|
|
res.status(200).send(API._200(await sett));
|
|
|
|
}
|
|
};
|
|
exports.addsupport = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.addData("AppSupport", input)));
|
|
|
|
};
|
|
exports.update_student_welcome_flow = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
if (input.email) {
|
|
const user = await User.findOne({
|
|
where: { email: input.email }
|
|
});
|
|
if (input.welcome_flow) user.welcome_flow = input.welcome_flow;
|
|
if (input.welcome_flow == 0) {
|
|
user.welcome_flow = 0;
|
|
user.onbording_date = new Date().toISOString()
|
|
}
|
|
if (input.cohort_id != "") {
|
|
let myuId = await user.id;
|
|
const onbording = await Onbording.findOne({
|
|
where: {
|
|
user_id: myuId,
|
|
cohort_id: input.cohort_id,
|
|
status: 0
|
|
}
|
|
});
|
|
if (onbording) {
|
|
if (input.welcome_flow) onbording.welcome_flow = input.welcome_flow;
|
|
if (input.welcome_flow == 0) {
|
|
onbording.welcome_flow = 0;
|
|
onbording.onbording_date = new Date().toISOString()
|
|
}
|
|
await onbording.save()
|
|
}
|
|
}
|
|
let result = await user.save();
|
|
res.status(200).send(API._200(await result));
|
|
|
|
} else {
|
|
const user = await User.findOne({
|
|
where: { id: input.id }
|
|
});
|
|
if (input.welcome_flow) user.welcome_flow = input.welcome_flow;
|
|
if (input.welcome_flow == 0) {
|
|
user.welcome_flow = 0;
|
|
user.onbording_date = new Date().toISOString()
|
|
}
|
|
if (input.cohort_id != "") {
|
|
let myuId = await user.id;
|
|
const onbording = await Onbording.findOne({
|
|
where: {
|
|
user_id: myuId,
|
|
cohort_id: input.cohort_id,
|
|
status: 0
|
|
}
|
|
});
|
|
if (onbording) {
|
|
if (input.welcome_flow) onbording.welcome_flow = input.welcome_flow;
|
|
if (input.welcome_flow == 0) {
|
|
onbording.welcome_flow = 0;
|
|
onbording.onbording_date = new Date().toISOString()
|
|
|
|
}
|
|
await onbording.save()
|
|
}
|
|
}
|
|
let result = await user.save();
|
|
res.status(200).send(API._200(await result));
|
|
|
|
}
|
|
};
|
|
exports.getallalias = async (req, res) => {
|
|
let all = await db_helper.query("SELECT aliasname FROM users WHERE status=0 AND aliasname IS NOT NULL");
|
|
res.status(200).send(API._200(await all[0]));
|
|
};
|
|
exports.updateuserbyemail = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const user = await User.findOne({
|
|
where: { email: input.email }
|
|
});
|
|
if (!user) {
|
|
res.status(404).send(API._404({ message: `User with email: ${input.email} was not found` }));
|
|
}
|
|
if (input.name) user.name = input.name;
|
|
if (input.email) user.email = input.email;
|
|
if (input.roll_id) user.roll_id = input.roll_id;
|
|
if (input.permissions) user.permissions = input.permissions;
|
|
if (input.email_verified_at) user.email_verified_at = input.email_verified_at;
|
|
if (input.email_verified) user.email_verified = input.email_verified;
|
|
if (input.free_flashcard) user.free_flashcard = input.free_flashcard;
|
|
if (input.free_practque) user.free_practque = input.free_practque;
|
|
if (input.free_flashccsp) user.free_flashccsp = input.free_flashccsp;
|
|
if (input.pass_rest_code) user.pass_rest_code = input.pass_rest_code;
|
|
if (input.calling_code) user.calling_code = input.calling_code;
|
|
if (input.avatar_url) user.avatar_url = input.avatar_url;
|
|
if (input.is_first) user.is_first = input.is_first;
|
|
if (input.aliasname) user.aliasname = input.aliasname;
|
|
if (input.is_temp) user.is_temp = input.is_temp;
|
|
if (input.authy_id) user.authy_id = input.authy_id;
|
|
if (input.is_live) user.is_live = input.is_live;
|
|
if (input.stripe_customer_id) user.stripe_customer_id = input.stripe_customer_id;
|
|
if (input.course_id) user.course_id = input.course_id;
|
|
if (input.user_time_zone) user.user_time_zone = input.user_time_zone;
|
|
if (input.allow_access) user.allow_access = input.allow_access;
|
|
if (input.onboard_cohort) user.onboard_cohort = input.onboard_cohort;
|
|
if (input.is_selfpaced) user.is_selfpaced = input.is_selfpaced;
|
|
if (input.welcome_flow) user.welcome_flow = input.welcome_flow;
|
|
if (input.expire_password) user.expire_password = input.expire_password;
|
|
|
|
user.remember_token = helper.generateAuthToken();
|
|
if (input.password) user.password = helper.getHashedPassword(input.password);
|
|
res.status(200).send(API._200(await user.save()));
|
|
|
|
};
|
|
exports.shortvideo = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
var data = {
|
|
qr_code: input.qr_code,
|
|
status: 0
|
|
}
|
|
if (input.type == 'video')
|
|
res.status(200).send(API._200(await db_helper.selectByWhere("Video", data)));
|
|
else if (input.type == 'mind') {
|
|
if (data.qr_code.startsWith("/")) {
|
|
data.qr_code = data.qr_code.replace("/", "")
|
|
}
|
|
res.status(200).send(API._200(await db_helper.selectByWhere("MindMap", data)));
|
|
}
|
|
else {
|
|
var shorturldata = {
|
|
shorturl: input.qr_code,
|
|
status: 0
|
|
}
|
|
res.status(200).send(API._200(await db_helper.selectByWhere("ShortUrl", shorturldata)));
|
|
}
|
|
|
|
};
|
|
exports.update_onbording = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const onbording = await Onbording.findOne({
|
|
where: {
|
|
user_id: input.user_id,
|
|
cohort_id: input.cohort_id,
|
|
status: 0
|
|
}
|
|
});
|
|
if (!onbording) {
|
|
res.status(404).send(API._404({ message: `Onbording with user_id: ${input.user_id} was not found` }));
|
|
}
|
|
if (input.user_id) onbording.user_id = input.user_id;
|
|
if (input.cohort_id) onbording.cohort_id = input.cohort_id;
|
|
if (input.is_expire) onbording.is_expire = input.is_expire;
|
|
if (input.link_expire_on) onbording.link_expire_on = input.link_expire_on;
|
|
if (input.completed_on) onbording.completed_on = input.completed_on;
|
|
if (input.welcome_flow) onbording.welcome_flow = input.welcome_flow;
|
|
if (input.is_selfpaced) onbording.is_selfpaced = input.is_selfpaced;
|
|
if (input.opt_in) onbording.opt_in = input.opt_in;
|
|
res.status(200).send(API._200(await onbording.save()));
|
|
|
|
|
|
};
|
|
exports.add_onbording = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
if (input.cohort_id != 0 && input.user_id != 0) {
|
|
let usr = {
|
|
"user_id": input.user_id,
|
|
"cohort_id": input.cohort_id,
|
|
}
|
|
const cc = await db_helper.selectByWhere("Onbording", usr);
|
|
if (cc.length > 0) {
|
|
res.status(200).send(API._200(await cc[0]));
|
|
|
|
} else {
|
|
let req = {
|
|
"user_id": input.user_id,
|
|
"is_main": 1,
|
|
"is_expire": 1
|
|
}
|
|
const main = await db_helper.selectByWhere("Onbording", req);
|
|
if (main.length > 0) {
|
|
input["is_main"] = 0;
|
|
} else {
|
|
input["is_main"] = 1;
|
|
}
|
|
res.status(200).send(API._200(await db_helper.addData("Onbording", input)));
|
|
}
|
|
}
|
|
else {
|
|
res.status(400).send(API._400({ message: "All params required" }));
|
|
}
|
|
};
|
|
exports.add_activity_tracker = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.addData("ActivityTracker", input)));
|
|
};
|
|
exports.add_authy = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
input["qr_code"] = req.body.qr_code;
|
|
res.status(200).send(API._200(await db_helper.addData("AuthyMaster", input)));
|
|
};
|
|
exports.update_two_fact_tab = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.update("User", input)));
|
|
};
|
|
exports.get_welcome_links = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
if (input.cohort_id == null || input.cohort_id == undefined) {
|
|
const cohorts = await db.sequelize.query("select id from cohorts where find_in_set((select id from users where email='" + input.email + "'),userslist) limit 1")
|
|
.then(function (data) {
|
|
return Array.from(new Set(data[0]));
|
|
})
|
|
input.cohort_id = cohorts[0].id;
|
|
}
|
|
const result = await db.sequelize.query("select c.id cohort_id,c.cohort_name,course_type,c.certi_id,cert.hybrid_welcome_video,cert.hybrid_welcome_thumbnail,cert.hybrid_course_thumbnail,cert.self_welcome_video,cert.self_welcome_thumbnail,cert.self_course_thumbnail,cert.live_welcome_video,cert.live_welcome_thumbnail,cert.live_course_thumbnail from cohorts as c left join certificates as cert on cert.id=c.certi_id where c.id= :cohort_id", { replacements: { cohort_id: input.cohort_id } }).then((res) => {
|
|
return Array.from(new Set(res));
|
|
})
|
|
res.status(200).send(API._200(await result));
|
|
|
|
};
|
|
exports.get_expirydate_onboarding = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const time = await db.sequelize.query("select DATE_ADD(createdAt, INTERVAL access_duration DAY) expiry_date,createdAt from payment_transactions where user_id=:user_id and payment_type in(select course_type from cohorts where id= :cohort_id) and cohort_id= :cohort_id and plan_id in(select method_id from cohorts where id= :cohort_id) order by id desc limit 1", { replacements: { user_id: input.user_id, cohort_id: input.cohort_id } })
|
|
.then(function (data) {
|
|
return Array.from(new Set(data[0]));
|
|
})
|
|
res.status(200).send(API._200(await time));
|
|
|
|
};
|
|
exports.add_failed_emails = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.addData("FailedEmail", input)));
|
|
};
|
|
exports.add_payment_transaction = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.addData("PaymentTransaction", input)));
|
|
};
|
|
exports.add_selfcohort_student = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
|
|
const cohort = await Cohort.findByPk(input.cohortIds);
|
|
let uid = cohort.userslist;
|
|
let newUsers = "";
|
|
if (uid.length > 0) {
|
|
newUsers = uid + "," + input.user_id;
|
|
}
|
|
else {
|
|
newUsers = input.user_id;
|
|
}
|
|
if (newUsers.endsWith(",")) {
|
|
newUsers = newUsers.substring(0, newUsers.length - 1);
|
|
}
|
|
if (newUsers.startsWith(",")) {
|
|
newUsers = newUsers.substring(1, newUsers.length);
|
|
}
|
|
cohort.userslist = newUsers;
|
|
res.status(200).send(API._200(await cohort.save()));
|
|
|
|
};
|
|
exports.fetch_user_payment = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const time = await db.sequelize.query("select * from payment_transactions where user_id in(select id from users where email='" + input.email + "') order by id desc limit 1")
|
|
.then(function (data) {
|
|
return Array.from(new Set(data[0]));
|
|
})
|
|
let response = {
|
|
link: "",
|
|
pay: false
|
|
}
|
|
if (time.length > 0) {
|
|
const monthNames = ["January", "February", "March", "April", "May", "June",
|
|
"July", "August", "September", "October", "November", "December"
|
|
];
|
|
|
|
let links = {
|
|
"user_id": time[0].user_id,
|
|
"cohort": time[0].cohort_id,
|
|
"date": monthNames[new Date(time[0].createdAt).getMonth()] + " " + await getOrdinal(new Date(time[0].createdAt).getDate())
|
|
}
|
|
let my_link = "http://64.23.254.43/welcomertemp/" + Buffer.from(JSON.stringify(links)).toString('base64');
|
|
response.link = my_link;
|
|
response.pay = true;
|
|
}
|
|
res.status(200).send(API._200(await response));
|
|
};
|
|
exports.get_membership = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const sub = await SelfPacedSubscription.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: input.sub_id
|
|
}
|
|
});
|
|
const mat = await db.sequelize.query("select * from self_paced_materials where status=0 and method_id= :sub_id and method_type='subscription' and is_checked=1", { replacements: { sub_id: input.sub_id } })
|
|
.then(function (data) {
|
|
return Array.from(new Set(data[0]));
|
|
})
|
|
for (let i = 0; i < mat.length; i++) {
|
|
if (mat[i].material_type == 'KA') {
|
|
const ka = await KnowledgeAsses.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['knowass_name']
|
|
});
|
|
mat[i]['material_name'] = await ka[0].knowass_name + " - Knowledge Assessment";
|
|
}
|
|
else if (mat[i].material_type == 'Mindmap') {
|
|
const mind = await MindMap.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['name']
|
|
});
|
|
mat[i]['material_name'] = await mind[0].name + " - Mindmap";
|
|
}
|
|
else if (mat[i].material_type == 'Video') {
|
|
const video = await Video.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['video_title']
|
|
});
|
|
mat[i]['material_name'] = await video[0].video_title + " - Video Lesson";
|
|
}
|
|
else if (mat[i].material_type == 'Test') {
|
|
const pt = await Practicetest.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['practice_name']
|
|
});
|
|
mat[i]['material_name'] = await pt[0].practice_name + " - Practice Test";
|
|
}
|
|
|
|
}
|
|
|
|
let response = { "Materials": mat, "Subscription": sub };
|
|
res.status(200).send(API._200(await response));
|
|
};
|
|
|
|
exports.get_onbording = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
let result = await db.sequelize.query("SELECT * FROM onbordings where user_id=:user_id and cohort_id=:cohort_id", { replacements: { cohort_id: input.cohort_id, user_id: input.user_id } }).then((res) => {
|
|
return Array.from(new Set(res));
|
|
})
|
|
res.status(200).send(API._200(await result));
|
|
};
|
|
exports.get_onetime_membership = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const sub = await SelfPacedOneTime.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: input.sub_id
|
|
}
|
|
});
|
|
const mat = await db.sequelize.query("select * from self_paced_materials where status=0 and method_id= :sub_id and method_type='onetime' and is_checked=1", { replacements: { sub_id: input.sub_id } })
|
|
.then(function (data) {
|
|
return Array.from(new Set(data[0]));
|
|
})
|
|
for (let i = 0; i < mat.length; i++) {
|
|
if (mat[i].material_type == 'KA') {
|
|
const ka = await KnowledgeAsses.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['knowass_name']
|
|
});
|
|
mat[i]['material_name'] = await ka[0].knowass_name + " - Knowledge Assessment";
|
|
}
|
|
else if (mat[i].material_type == 'Mindmap') {
|
|
const mind = await MindMap.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['name']
|
|
});
|
|
mat[i]['material_name'] = await mind[0].name + " - Mindmap";
|
|
}
|
|
else if (mat[i].material_type == 'Video') {
|
|
const video = await Video.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['video_title']
|
|
});
|
|
mat[i]['material_name'] = await video[0].video_title + " - Video Lesson";
|
|
}
|
|
else if (mat[i].material_type == 'Test') {
|
|
const pt = await Practicetest.findAll({
|
|
where: {
|
|
status: 0,
|
|
id: mat[i].material_id
|
|
},
|
|
attributes: ['practice_name']
|
|
});
|
|
mat[i]['material_name'] = await pt[0].practice_name + " - Practice Test";
|
|
}
|
|
|
|
}
|
|
|
|
let response = { "Materials": mat, "OneTime": sub };
|
|
res.status(200).send(API._200(await response));
|
|
};
|
|
exports.overdue_notification_stop = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
const data = await db_helper.selectByWhere("NotificationSetting", { 'user_id': input.user_id })
|
|
input["oberdue"] = input.overdue_notification;
|
|
if (data.length > 0) {
|
|
input["id"] = data[0].id;
|
|
await db_helper.update("NotificationSetting", input);
|
|
} else {
|
|
await db_helper.addData("NotificationSetting", input);
|
|
}
|
|
|
|
res.status(200).send(API._200(await db_helper.query("update users set overdue_notification=" + input.overdue_notification + " where id =" + input.user_id)));
|
|
};
|
|
exports.save_access_duration = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
let usr = {
|
|
"user_id": input.user_id,
|
|
"cohort_id": input.cohort_id,
|
|
}
|
|
const cc = await db_helper.selectByWhere("AccessDuration", usr);
|
|
if (cc.length > 0) {
|
|
input['id'] = cc[0].id;
|
|
res.status(200).send(API._200(await db_helper.update("AccessDuration", input)));
|
|
} else {
|
|
res.status(200).send(API._200(await db_helper.addData("AccessDuration", input)));
|
|
}
|
|
};
|
|
exports.save_self_schedule = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
let usr = {
|
|
"user_id": input.user_id,
|
|
"certi_id": input.certi_id
|
|
}
|
|
const cc = await db_helper.selectByWhere("SelfPacedSchedule", usr);
|
|
if (cc.length > 0) {
|
|
res.status(200).send(API._200(await db_helper.update("SelfPacedSchedule", input)));
|
|
} else {
|
|
res.status(200).send(API._200(await db_helper.addData("SelfPacedSchedule", input)));
|
|
}
|
|
};
|
|
exports.shortvideo = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
var data = {
|
|
qr_code: input.qr_code,
|
|
status: 0
|
|
}
|
|
if (input.type == 'video')
|
|
return API._200(await db_helper.selectByWhere("Video", data));
|
|
else if (input.type == 'mind') {
|
|
if (data.qr_code.startsWith("/")) {
|
|
data.qr_code = data.qr_code.replace("/", "")
|
|
}
|
|
res.status(200).send(API._200(await db_helper.selectByWhere("MindMap", data)));
|
|
}
|
|
else {
|
|
var shorturldata = {
|
|
shorturl: input.qr_code,
|
|
status: 0
|
|
}
|
|
res.status(200).send(API._200(await db_helper.selectByWhere("ShortUrl", shorturldata)));
|
|
}
|
|
};
|
|
exports.sendOtp = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
let number = Math.floor(100000 + Math.random() * 900000);
|
|
const user = await User.findOne({
|
|
where: { email: input.email }
|
|
});
|
|
user.email_otp = number;
|
|
let html = `<h1>Activation Code</h1><p>Here is your activation code to be entered at E-Learn:</p><h2>${number}</h2>`;
|
|
let data = {
|
|
to: input.email,
|
|
subject: "Email Activation",
|
|
text: html
|
|
}
|
|
helper.sendMail(data)
|
|
user.save()
|
|
res.status(200).send(API._200({}));
|
|
|
|
};
|
|
exports.addshorturl = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.addData('ShortUrl', input)));
|
|
};
|
|
exports.delete_meeting = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
let data = await db_helper.query("update live_events set is_live=0 where meeting_id='" + input.MeetingId + "'");
|
|
res.status(200).send(API._200(await data));
|
|
};
|
|
exports.getallShortUrl = async (req, res) => {
|
|
const all = await ShortUrl.findAll({
|
|
where: {
|
|
status: 0
|
|
}
|
|
})
|
|
res.status(200).send(API._200(await all));
|
|
};
|
|
exports.ShortUrldelete = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.statusChange('ShortUrl', input.id)));
|
|
};
|
|
exports.ShortUrlupdate = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.update('ShortUrl', input)));
|
|
};
|
|
exports.update_payment_transaction = async (req, res) => {
|
|
const input = await helper.decryptRequest(req.body.data);
|
|
res.status(200).send(API._200(await db_helper.update("PaymentTransaction", input)));
|
|
};
|