kasperj/turftracker
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sdgsdgf

Browse Source
This commit is contained in:
Jake Kasper
2025-09-05 10:45:01 -04:00
parent e691172a9c
commit e5946157f0
4 changed files with 195 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

65
backend/src/routes/watering.js
View File

@@ -102,6 +102,15 @@ router.post('/plans/:id/points', async (req,res,next)=>{
const seqrs = await pool.query('SELECT COALESCE(MAX(sequence),0)+1 as next FROM watering_plan_points WHERE plan_id=$1',[planId]);
const sequence = seqrs.rows[0].next;
const payload = req.body || {};
let equipment_id = null, equipment_name = null;
if (payload.equipmentId) {
// verify ownership, otherwise ignore silently
const eq = await pool.query('SELECT id, custom_name, manufacturer, model FROM user_equipment WHERE id=$1 AND user_id=$2', [payload.equipmentId, req.user.id]);
if (eq.rows.length) {
equipment_id = eq.rows[0].id;
equipment_name = payload.equipmentName || eq.rows[0].custom_name || `${eq.rows[0].manufacturer||''} ${eq.rows[0].model||''}`.trim() || null;
}
}
const point = {
sprinkler_head_type: payload.sprinklerHeadType,
sprinkler_throw_feet: payload.throwFeet,
@@ -113,11 +122,13 @@ router.post('/plans/:id/points', async (req,res,next)=>{
const ins = await pool.query(
`INSERT INTO watering_plan_points
(plan_id, sequence, lat, lng, duration_minutes, sprinkler_mount, sprinkler_head_type,
sprinkler_gpm, sprinkler_throw_feet, sprinkler_degrees, sprinkler_length_feet, sprinkler_width_feet, coverage_sqft, sprinkler_heading_degrees)
VALUES ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14) RETURNING *`,
sprinkler_gpm, sprinkler_throw_feet, sprinkler_degrees, sprinkler_length_feet, sprinkler_width_feet, coverage_sqft, sprinkler_heading_degrees,
equipment_id, equipment_name)
VALUES ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11,$12,$13,$14,$15,$16) RETURNING *`,
[planId, sequence, payload.lat, payload.lng, payload.durationMinutes||0, payload.mountType||null,
payload.sprinklerHeadType||null, payload.gpm||null, payload.throwFeet||null, payload.degrees||null,
payload.lengthFeet||null, payload.widthFeet||null, coverage, payload.headingDegrees||null]
payload.lengthFeet||null, payload.widthFeet||null, coverage, payload.headingDegrees||null,
equipment_id, equipment_name]
);
res.status(201).json({ success:true, data:{ point: ins.rows[0] }});
} catch (e) { next(e); }
@@ -158,10 +169,12 @@ router.put('/points/:id', async (req, res, next) => {
sprinkler_length_feet = COALESCE($9, sprinkler_length_feet),
sprinkler_width_feet = COALESCE($10, sprinkler_width_feet),
sprinkler_heading_degrees = COALESCE($11, sprinkler_heading_degrees),
coverage_sqft = COALESCE($12, coverage_sqft)
WHERE id=$13 RETURNING *`,
coverage_sqft = COALESCE($12, coverage_sqft),
equipment_id = COALESCE($13, equipment_id),
equipment_name = COALESCE($14, equipment_name)
WHERE id=$15 RETURNING *`,
[p.lat, p.lng, p.durationMinutes, p.mountType, p.sprinklerHeadType, p.gpm,
p.throwFeet, p.degrees, p.lengthFeet, p.widthFeet, p.headingDegrees, coverage || null, pointId]
p.throwFeet, p.degrees, p.lengthFeet, p.widthFeet, p.headingDegrees, coverage || null, p.equipmentId || null, p.equipmentName || null, pointId]
);
res.json({ success:true, data:{ point: rs.rows[0] }});
} catch (e) { next(e); }
@@ -182,4 +195,44 @@ router.delete('/points/:id', async (req,res,next)=>{
} catch (e) { next(e); }
});
// DELETE /api/watering/plans/:id
router.delete('/plans/:id', async (req, res, next) => {
try {
const planId = req.params.id;
const own = await pool.query('SELECT id FROM watering_plans WHERE id=$1 AND user_id=$2', [planId, req.user.id]);
if (own.rows.length === 0) throw new AppError('Plan not found', 404);
await pool.query('DELETE FROM watering_plans WHERE id=$1', [planId]);
res.json({ success: true });
} catch (e) { next(e); }
});
module.exports = router;
// Duplicate a watering plan with all points
router.post('/plans/:id/duplicate', async (req, res, next) => {
try {
const planId = req.params.id;
const own = await pool.query('SELECT * FROM watering_plans WHERE id=$1 AND user_id=$2', [planId, req.user.id]);
if (own.rows.length === 0) throw new AppError('Plan not found', 404);
const src = own.rows[0];
const newName = (req.body && req.body.name) || `${src.name} (Copy ${new Date().toLocaleDateString()})`;
const ins = await pool.query(
`INSERT INTO watering_plans(user_id, property_id, name, notes)
VALUES ($1,$2,$3,$4) RETURNING *`,
[req.user.id, src.property_id, newName, src.notes]
);
const newPlan = ins.rows[0];
// Copy points
await pool.query(
`INSERT INTO watering_plan_points
(plan_id, sequence, lat, lng, duration_minutes, sprinkler_mount, sprinkler_head_type,
sprinkler_gpm, sprinkler_throw_feet, sprinkler_degrees, sprinkler_length_feet, sprinkler_width_feet,
coverage_sqft, sprinkler_heading_degrees, equipment_id, equipment_name)
SELECT $1, sequence, lat, lng, duration_minutes, sprinkler_mount, sprinkler_head_type,
sprinkler_gpm, sprinkler_throw_feet, sprinkler_degrees, sprinkler_length_feet, sprinkler_width_feet,
coverage_sqft, sprinkler_heading_degrees, equipment_id, equipment_name
FROM watering_plan_points WHERE plan_id=$2`,
[newPlan.id, planId]
);
res.status(201).json({ success: true, data: { plan: newPlan } });
} catch (e) { next(e); }
});