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

modified connections

Browse Source
master
varun 1 year ago
parent 627286e52b
commit cee726aa9a
3 changed files with 104 additions and 6 deletions
Show Stats Download Patch File Download Diff File

90
src/controllers/createConnectionController.js
Unescape View File

@ -451,7 +451,6 @@ const fastify = require("fastify")({
// }
// };
exports.createConnections = async (req, body) => {
try {
const customerId = req.params.customerId;
@ -468,6 +467,8 @@ exports.createConnections = async (req, body) => {
input_type: connection.input_type,
motor_status: connection.motor_status || "0",
inputismotor: connection.hasOwnProperty("inputismotor") ? connection.inputismotor : false,
motor_id: connection.motor_id || null,
motor_stop_status: connection.motor_stop_status || "1"
};
});
}
@ -478,6 +479,8 @@ exports.createConnections = async (req, body) => {
outputConnections: connection.outputConnections,
output_type: connection.output_type,
outputismotor: connection.hasOwnProperty("outputismotor") ? connection.outputismotor : false,
motor_id: connection.motor_id || null,
motor_stop_status: connection.motor_stop_status || "1"
};
});
}
@ -504,9 +507,9 @@ exports.createConnections = async (req, body) => {
'connections.inputConnections': {
$each: [{ inputConnections: tankname, input_type: 'sump', inputismotor: data.outputismotor || false }],
},
// 'connections.outputConnections': {
// $each: [{ outputConnections: tankname, output_type: 'overhead'}],
// },
'connections.outputConnections': {
$each: [{ outputConnections: tankname, output_type: 'overhead', motor_id: data.motor_id || null, motor_stop_status: "1"}],
},
},
},
{ new: true }
@ -525,6 +528,85 @@ exports.createConnections = async (req, body) => {
exports.createConnections = async (req, body) => {
try {
const customerId = req.params.customerId;
const tankname = req.body.tankname;
const tankInfo = await Tank.findOne({ customerId: customerId.toString(), tankName: tankname });
const usertobeInserted = req.body;
tankInfo.connections.source = tankInfo.tankName;
if (usertobeInserted.inputConnections) {
tankInfo.connections.inputConnections = usertobeInserted.inputConnections.map(connection => {
return {
inputConnections: connection.inputConnections,
input_type: connection.input_type,
motor_status: connection.motor_status || "1",
inputismotor: connection.hasOwnProperty("inputismotor") ? connection.inputismotor : false,
motor_id: connection.motor_id || null,
motor_stop_status: connection.motor_stop_status || "1"
};
});
}
if (usertobeInserted.outputConnections) {
tankInfo.connections.outputConnections = usertobeInserted.outputConnections.map(connection => {
return {
outputConnections: connection.outputConnections,
output_type: connection.output_type,
outputismotor: connection.hasOwnProperty("outputismotor") ? connection.outputismotor : false,
motor_id: connection.motor_id || null,
motor_status: connection.motor_status || "1",
motor_stop_status: connection.motor_stop_status || "1"
};
});
}
const tank_connections = await tankInfo.save();
const connection_data_check = tank_connections.connections.inputConnections;
const sump_names = connection_data_check.map(d => d.inputConnections);
console.log(sump_names);
const connection_data = usertobeInserted.outputConnections;
console.log(connection_data, "connection_data");
for (const data of connection_data) {
if (data['output_type'] === "overhead") {
const tankName = data['outputConnections'];
if (sump_names.includes(tankname)) {
console.log(`${tankname} exists in ${sump_names}`);
} else {
const tankConnections = await Tank.findOneAndUpdate(
{ customerId: customerId.toString(), tankName: tankName },
{
$addToSet: {
'connections.inputConnections': {
$each: [{ inputConnections: tankname, input_type: 'sump', inputismotor: data.outputismotor || false }],
},
'connections.outputConnections': {
$each: [{ outputConnections: tankname, output_type: 'overhead', motor_id: data.motor_id || null, motor_stop_status: "1"}],
},
},
},
{ new: true }
);
console.log("tankConnections", tankConnections.connections.inputConnections);
console.log("tankConnections", tankConnections.connections.outputConnections);
}
}
}
return tank_connections;
} catch (err) {
throw boom.boomify(err);
}
};
// exports.createConnections = async (req, body) => {
// try {
// const customerId = req.params.customerId;

8
src/models/tanks.js
Unescape View File

@ -60,7 +60,9 @@ const tanksSchema = new mongoose.Schema({
inputConnections: { type: String },
input_type: { type: String },
inputismotor: { type: Boolean, },
motor_status: { type: String, default: "0" }
motor_id:{ type: String ,default: null},
motor_status: { type: String, default: "0" },
motor_stop_status: { type: String, default: "1" },
}
],
outputConnections: [
@ -68,7 +70,9 @@ const tanksSchema = new mongoose.Schema({
outputConnections: { type: String },
output_type: { type: String },
outputismotor: { type: Boolean, },
motor_status: { type: String, default: "0" }
motor_id:{ type: String ,default: null},
motor_status: { type: String, default: "0" },
motor_stop_status: { type: String, default: "1" },
}
]
}

12
src/routes/createConnectionsRoute.js
Unescape View File

@ -124,6 +124,9 @@ module.exports = function (fastify, opts, next) {
inputConnections: { type: "string", default: null },
input_type: { type: "string", default: null },
inputismotor: { type: "boolean"},
motor_id:{ type: "string" ,default: null},
motor_status: { type: "string", default: "1" },
motor_stop_status: { type: "string", default: "1" },
},
},
},
@ -136,6 +139,9 @@ module.exports = function (fastify, opts, next) {
outputConnections: { type: "string", default: null },
output_type: { type: "string", default: null },
outputismotor: { type: "boolean" },
motor_id:{ type: "string" ,default: null},
motor_status: { type: "string", default: "1" },
motor_stop_status: { type: "string", default: "1" },
},
},
},
@ -183,6 +189,9 @@ module.exports = function (fastify, opts, next) {
inputConnections: { type: "string", default: null },
input_type: { type: "string", default: null },
inputismotor: { type: "boolean"},
motor_id:{ type: "string" ,default: null},
motor_status: { type: "string", default: "1" },
motor_stop_status: { type: "string", default: "1" },
},
},
},
@ -195,6 +204,9 @@ module.exports = function (fastify, opts, next) {
outputConnections: { type: "string", default: null },
output_type: { type: "string", default: null },
outputismotor: { type: "boolean" },
motor_id:{ type: "string" ,default: null},
motor_status: { type: "string", default: "1" },
motor_stop_status: { type: "string", default: "1" },
},
},
},

Write Preview
Loading…
Cancel
Save