Arminta
/
watermanagement-backend-prod
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

previous motoraction code

Browse Source
master^2
Varun 7 months ago
parent ad0cf229b9
commit b01a3afe71
1 changed files with 33 additions and 33 deletions
Show Stats Download Patch File Download Diff File

62
src/controllers/tanksController.js
Unescape View File

@ -2838,7 +2838,6 @@ async function calculateTotalPumpedWater(customerId, motorId, start_instance_id)
exports.motorAction = async (req, reply) => { exports.motorAction = async (req, reply) => {
try { try {
const customerId = req.params.customerId; const customerId = req.params.customerId;
@ -3331,41 +3330,42 @@ exports.motorAction = async (req, reply) => {
}; };
async function stopMotor(motorId, customerId, start_instance_id) {
const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm');
await Tank.updateOne(
{ customerId, "connections.inputConnections.motor_id": motorId },
{ $set: {
"connections.inputConnections.$.motor_stop_status": "1",
"connections.inputConnections.$.stopTime": currentTime,
"connections.inputConnections.$.threshold_type": null,
"connections.inputConnections.$.manual_threshold_time": null,
"connections.inputConnections.$.manual_threshold_percentage": null
}}
);
if (motorIntervals[motorId]) { // async function stopMotor(motorId, customerId, start_instance_id) {
clearInterval(motorIntervals[motorId]); // const currentTime = moment().tz('Asia/Kolkata').format('DD-MMM-YYYY - HH:mm');
delete motorIntervals[motorId]; // await Tank.updateOne(
} // { customerId, "connections.inputConnections.motor_id": motorId },
// { $set: {
// "connections.inputConnections.$.motor_stop_status": "1",
// "connections.inputConnections.$.stopTime": currentTime,
// "connections.inputConnections.$.threshold_type": null,
// "connections.inputConnections.$.manual_threshold_time": null,
// "connections.inputConnections.$.manual_threshold_percentage": null
// }}
// );
eventEmitter.emit("motorStop", customerId, [], "", "", currentTime, "Mobile APP", 0, "", motorId, ""); // if (motorIntervals[motorId]) {
// clearInterval(motorIntervals[motorId]);
// delete motorIntervals[motorId];
// }
const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id }); // eventEmitter.emit("motorStop", customerId, [], "", "", currentTime, "Mobile APP", 0, "", motorId, "");
if (motorData) {
const startTime = moment(motorData.startTime, 'DD-MMM-YYYY - HH:mm');
const runtime = moment.duration(moment(currentTime, 'DD-MMM-YYYY - HH:mm').diff(startTime)).asSeconds();
const receiverTank = await Tank.findOne({ customerId, tankName: motorData.receiverTank, tankLocation: motorData.receiver_type.toLowerCase() }); // const motorData = await MotorData.findOne({ customerId, motor_id: motorId, start_instance_id });
const receiverFinalWaterLevel = parseInt(receiverTank.waterlevel.replace(/,/g, ''), 10); // if (motorData) {
const quantityDelivered = receiverFinalWaterLevel - parseInt(motorData.receiverInitialwaterlevel.replace(/,/g, ''), 10); // const startTime = moment(motorData.startTime, 'DD-MMM-YYYY - HH:mm');
// const runtime = moment.duration(moment(currentTime, 'DD-MMM-YYYY - HH:mm').diff(startTime)).asSeconds();
await MotorData.updateOne( // const receiverTank = await Tank.findOne({ customerId, tankName: motorData.receiverTank, tankLocation: motorData.receiver_type.toLowerCase() });
{ customerId, motor_id: motorId, start_instance_id }, // const receiverFinalWaterLevel = parseInt(receiverTank.waterlevel.replace(/,/g, ''), 10);
{ $set: { stopTime: currentTime, receiverfinalwaterlevel: receiverFinalWaterLevel.toString(), quantity_delivered: quantityDelivered.toString(), runtime: runtime } } // const quantityDelivered = receiverFinalWaterLevel - parseInt(motorData.receiverInitialwaterlevel.replace(/,/g, ''), 10);
);
} // await MotorData.updateOne(
} // { customerId, motor_id: motorId, start_instance_id },
// { $set: { stopTime: currentTime, receiverfinalwaterlevel: receiverFinalWaterLevel.toString(), quantity_delivered: quantityDelivered.toString(), runtime: runtime } }
// );
// }
// }

Write Preview
Loading…
Cancel
Save