diff --git a/app/controllers/salespd.controller.js b/app/controllers/salespd.controller.js index f59d80c..19affa5 100644 --- a/app/controllers/salespd.controller.js +++ b/app/controllers/salespd.controller.js @@ -114,7 +114,7 @@ exports.PullSalesPdData = async (req, res) => { if(storeId) { Object.assign(values, { pd_id: storeId.pd_id }); - await ProductInformation.create( values).then((successData)=>{logMsg.info("ProductInformation insert success ,PdId= "+storeId.pd_id);}).catch((err)=>{ logMsg.info("BreifOfBusiness insert failed ,PdId= "+storeId.pd_id+" Error = "+err);}); + await ProductInformation.create( values).then((successData)=>{logMsg.info("ProductInformation insert success ,PdId= "+storeId.pd_id);}).catch((err)=>{ logMsg.info("ProductInformation insert failed ,PdId= "+storeId.pd_id+" Error = "+err);}); }else{resolve(false)} } else if (keys == 'section5') { @@ -915,3 +915,103 @@ exports.PropertyInformationList = async (req, res) => + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +exports.PullSalesPdshareholderData = async (req, res) => +{ + try + { + + + IfGeneralSectionDataExist = await GeneralSection.findOne({ where : { ref_no : req.body.pdid ,product:req.body.product,case_no :req.body.caseno, is_active : 1 }}); + if(IfGeneralSectionDataExist) + { + + + + var salesPD = new Promise(async(resolve, reject) => { + const tempData =JSON.parse(JSON.stringify(req.body.data)); + logMsg.info("Insertion started for PdId(ref_no)= "+req.body.pdid); + var count = 0; + var storeId = IfGeneralSectionDataExist; + const len = Object.keys(tempData).length - 1; + for (const [keys, values] of Object.entries(tempData)) { + count++; + + if (Array.isArray(values) == true ) + { + + values.forEach(async(values) => { + + if (keys == 'section3') { + if(storeId) { + Object.assign(values, { pd_id: storeId.pd_id }); await DetailsOfKeyShareHolder.create( values).then((successData)=>{logMsg.info("DetailsOfKeyShareHolder insert success ,PdId= "+storeId.pd_id);}).catch((err)=>{ logMsg.info("DetailsOfKeyShareHolder insert failed ,PdId= "+storeId.pd_id+" Error = "+err);}); + }else{resolve(false)} + }; + + }); + } + else + { + + if (keys == 'section3') { if(storeId) { Object.assign(values, { pd_id: storeId.pd_id }); await DetailsOfKeyShareHolder.create( values).then((successData)=>{logMsg.info("DetailsOfKeyShareHolder insert success ,PdId= "+storeId.pd_id);}).catch((err)=>{ logMsg.info("DetailsOfKeyShareHolder insert failed ,PdId= "+storeId.pd_id+" Error = "+err);}); }else{resolve(false)} }; + + + } + if (len == count - 1 ) + { + resolve(); + + } + } // end of for loop + + }); // end of promise + salesPD.then(async(result) => { + setTimeout(() => { + if(result == false) + { + res.send({'status':404,'message':"failed",'data':"No Data"}); + }else{ + logMsg.info("Insertion completed for PdId(ref_no)= "+req.body.pdid); + res.send({'status':200,'message':"success",'data':"No Data"}); + } + }, 1000); + }); + + }// end of if else condition + + + + } catch(err) { + res.send({'status':404,message: err.message || "Some error occurred while retrieving data." ,'data': "No data" }); + } //end of try catch + +}; \ No newline at end of file diff --git a/app/routes/routes.js b/app/routes/routes.js index 9e5da23..e6845b0 100644 --- a/app/routes/routes.js +++ b/app/routes/routes.js @@ -5,7 +5,7 @@ module.exports = app => { const SalesPdController = require("../controllers/salespd.controller.js"); const { logMsg } = require('../services/logger.js'); var router = require("express").Router(); - + router.post('/PullSalesPdshareholderData',SalesPdController.PullSalesPdshareholderData); /** * @swagger * /api/demo: