diff --git a/controller/getInvestmentSumarry.js b/controller/getInvestmentSumarry.js index 9a4922f..3ed6af1 100644 --- a/controller/getInvestmentSumarry.js +++ b/controller/getInvestmentSumarry.js @@ -22,44 +22,71 @@ function getHashCode(req) { } - -const createLiquiloanInvestor = async (req, res) => { - - var promiseArray = []; - +const createLiquiloanInvestor = () => { for (let i = 0; i < arrayGetList.length; i++) { - promiseArray.push(new Promise((resolve, reject) => { - var options = { - method: 'POST', - url: 'https://supply-integration.liquiloans.com/api/v2/GetInvestmentSummary', - headers: { - 'Content-Type': 'application/json', - 'Cookie': 'AWSALB=9yK+sr19KPz9dgL+OcWl2hZ9MOhLlvF9PtNolmRnkviHh01CvjlIWH44NtfjIziyJFwnhrn3+JNhztFLJis+Ijq971nXr5QQVJBxId1uvjZyqKSl/6oFuidGkloW; AWSALBCORS=9yK+sr19KPz9dgL+OcWl2hZ9MOhLlvF9PtNolmRnkviHh01CvjlIWH44NtfjIziyJFwnhrn3+JNhztFLJis+Ijq971nXr5QQVJBxId1uvjZyqKSl/6oFuidGkloW' - }, - body: JSON.stringify({ - "investor_id": arrayGetList[i], - "timestamp": getCurrentDateTime(), - "checksum": getHashCode(arrayGetList[i]), - "mid": "M00201" - }) - }; - request(options, function (error, response, body) { - if (error) reject(error); - else resolve(body) + var options = { + method: 'POST', + url: 'https://supply-integration.liquiloans.com/api/v2/GetInvestmentSummary', + headers: { + 'Content-Type': 'application/json', + 'Cookie': 'AWSALB=9yK+sr19KPz9dgL+OcWl2hZ9MOhLlvF9PtNolmRnkviHh01CvjlIWH44NtfjIziyJFwnhrn3+JNhztFLJis+Ijq971nXr5QQVJBxId1uvjZyqKSl/6oFuidGkloW; AWSALBCORS=9yK+sr19KPz9dgL+OcWl2hZ9MOhLlvF9PtNolmRnkviHh01CvjlIWH44NtfjIziyJFwnhrn3+JNhztFLJis+Ijq971nXr5QQVJBxId1uvjZyqKSl/6oFuidGkloW' + }, + body: JSON.stringify({ + "investor_id": arrayGetList[i], + "timestamp": getCurrentDateTime(), + "checksum": getHashCode(arrayGetList[i]), + "mid": "M00201" }) - })) + + }; + request(options, function (error, response) { + if (error) throw new Error(error); + getUrlAndStore(response.body) + }); } - console.log(await Promise.all(promiseArray)); } +const getUrlAndStore = async (body) => { + try { + const data = JSON.parse(body) + console.log(data, "KDDODKOKODODKDKO"); + let callsData = data.data; + let calls = []; + // if (callsData.length) { + // for (let i = 0; i < callsData.length; i++) { + // let record = {}; + // record.sid = callsData[i].Sid; + // record.date_created = callsData[i].DateCreated; + // record.date_updated = callsData[i].DateUpdated; + // record.account_sid = callsData[i].AccountSid; + // record.to = callsData[i].To; + // record.from = callsData[i].From; + // record.phone_number = callsData[i].PhoneNumber; + // record.phone_number_sid = callsData[i].PhoneNumberSid; + // record.status = callsData[i].Status; + // record.start_time = callsData[i].StartTime; + // record.end_time = callsData[i].EndTime; + // record.duration = callsData[i].Duration; + // record.price = callsData[i].Price; + // record.direction = callsData[i].Direction; + // record.recording_url = callsData[i].RecordingUrl; + + // record.conversation_duration = callsData[i].Details.ConversationDuration; + // record.leg1_status = callsData[i].Details.Leg1Status; + // record.leg2_status = callsData[i].Details.Leg2Status; + // record.created_at = new Date(); -// const createLiquiloanInvestor = (req, res) => { -// for (let i = 0; i < arrayGetList.length; i++) { -// const element = arrayGetList[i]; -// main(element, element.length) -// } -// res.se -// } + + // calls.push(record); + // console.log('calls---->', calls.length); + // await db.exotelCalls.bulkCreate(calls); + // } + } + catch (err) { + console.log(err); + winstonLogger.error('getUrlAndStore() error is : ' + err); + } +} module.exports = { createLiquiloanInvestor