| Name | +GOO | +Department | +|
|---|---|---|---|
| + | + | + | + + | +
\\s*", "
", s)''' + return s.strip() + + +def db_dump_day(): + day = parse_day(input("Enter day (e.g., 1/22/26): ")) + fname = json_filename(day) + conn = get_conn() + try: + with conn.cursor() as cur: + cur.execute( + "SELECT * FROM conf_sessions WHERE DATE(starttime) = %s ORDER BY starttime, id", + (day.strftime("%Y-%m-%d"),), + ) + rows = cur.fetchall() + finally: + conn.close() + with open(fname, "w", encoding="utf-8") as fh: + json.dump(rows, fh, indent=2, sort_keys=True, default=str) + print(f"Wrote {len(rows)} session(s) to {fname}") + + +def db_reload_day_json(): + day = parse_day(input("Enter day (e.g., 1/22/26): ")) + fname = json_filename(day) + if not os.path.exists(fname): + raise FileNotFoundError(f"Missing {fname}") + with open(fname, "r", encoding="utf-8") as fh: + rows = json.load(fh) + if not isinstance(rows, list): + raise ValueError("JSON file must be a list of session rows") + conn = get_conn() + updated = 0 + try: + with conn.cursor() as cur: + for row in rows: + if "id" not in row: + continue + ses_id = row["id"] + cur.execute("SELECT * FROM conf_sessions WHERE id = %s", (ses_id,)) + current = cur.fetchone() + if not current: + print(f"Skipping missing id {ses_id}") + continue + changes = {} + for key, new_val in row.items(): + if key == "id" or key not in current: + continue + cur_val = current[key] + norm_new = normalize_value(new_val) + norm_cur = normalize_value(cur_val) + if norm_new != norm_cur: + changes[key] = new_val + if changes: + set_sql = ", ".join([f"`{k}`=%s" for k in changes.keys()]) + params = list(changes.values()) + [ses_id] + cur.execute(f"UPDATE conf_sessions SET {set_sql} WHERE id=%s", params) + updated += 1 + conn.commit() + finally: + conn.close() + print(f"Updated {updated} session(s) from {fname}") + + +def db_export_sessions_sql(): + if pymysql is None: + raise RuntimeError("pymysql is not installed. Install it with: pip install pymysql") + conn = get_conn() + try: + with conn.cursor() as cur: + cur.execute("SELECT * FROM conf_sessions WHERE id > 1462 ORDER BY id") + rows = cur.fetchall() + columns = [col[0] for col in cur.description] + finally: + conn.close() + if not rows: + print("No sessions found with id > 1462") + return + if "id" in columns: + columns = [c for c in columns if c != "id"] + os.makedirs("data", exist_ok=True) + out_path = os.path.join("data", "sessions.sql") + with open(out_path, "w", encoding="utf-8") as fh: + for row in rows: + values = [] + for col in columns: + val = row.get(col) + if col == "desc": + val = clean_desc_for_export(val) + values.append(sql_literal(val)) + col_sql = ", ".join([f"`{c}`" for c in columns]) + val_sql = ", ".join(values) + fh.write(f"INSERT INTO conf_sessions ({col_sql}) VALUES ({val_sql});\n") + print(f"Wrote {len(rows)} INSERT statements to {out_path}") + + +def main(): + actions = [ + ("Dump day's sessions from db", db_dump_day), + ("Reload day's session from json", db_reload_day_json), + ("Export sessions id>1462 to SQL inserts", db_export_sessions_sql), + ("Reload ops.py", "__RELOAD__"), + ("Quit", None), + ] + while True: + print("\nOps Menu") + for i, (label, _) in enumerate(actions, 1): + print(f"{i}. {label}") + choice = input("Choose an option: ").strip() + if not choice.isdigit(): + print("Please enter a number.") + continue + idx = int(choice) - 1 + if idx < 0 or idx >= len(actions): + print("Invalid choice.") + continue + label, action = actions[idx] + if action is None: + return + if action == "__RELOAD__": + os.execv(sys.executable, [sys.executable] + sys.argv) + try: + action() + except Exception as exc: + print(f"Error: {exc}") + + +if __name__ == "__main__": + main() diff --git a/user.php b/user.php new file mode 100644 index 0000000..1fa2dde --- /dev/null +++ b/user.php @@ -0,0 +1,115 @@ +getConnection(); +mysqli_set_charset($c, 'utf8'); + +$user_id = isset($_REQUEST['id']) ? intval($_REQUEST['id']) : 0; +$message = ''; + +// Fetch department options +$dept_opts = []; +$dept_q = "SELECT id, parent, name FROM gavi_departments ORDER BY name"; +$dept_r = mysqli_query($c, $dept_q); +while ($row = mysqli_fetch_assoc($dept_r)) { $dept_opts[] = $row; } + +// Helper: fetch user record +function fetch_user($c, $uid) { + $sql = "SELECT id, goo, email, name FROM conf_users WHERE id = ?"; + $stmt = mysqli_prepare($c, $sql); + mysqli_stmt_bind_param($stmt, "i", $uid); + mysqli_stmt_execute($stmt); + $res = mysqli_stmt_get_result($stmt); + return mysqli_fetch_assoc($res); +} + +// Helper: fetch mapping +function fetch_dept($c, $uid) { + $sql = "SELECT department_id FROM conf_user_departments WHERE user_id = ?"; + $stmt = mysqli_prepare($c, $sql); + mysqli_stmt_bind_param($stmt, "i", $uid); + mysqli_stmt_execute($stmt); + $res = mysqli_stmt_get_result($stmt); + $row = mysqli_fetch_assoc($res); + return $row ? intval($row['department_id']) : null; +} + +// Process save +if ($_SERVER['REQUEST_METHOD'] === 'POST' && $user_id > 0) { + $name = isset($_POST['name']) ? trim($_POST['name']) : ''; + $email = isset($_POST['email']) ? trim($_POST['email']) : ''; + $goo = isset($_POST['goo']) ? trim($_POST['goo']) : ''; + $dept = isset($_POST['department_id']) ? intval($_POST['department_id']) : 0; + + // Update conf_users + $upd = mysqli_prepare($c, "UPDATE conf_users SET name = ?, email = ?, goo = ? WHERE id = ?"); + mysqli_stmt_bind_param($upd, "sssi", $name, $email, $goo, $user_id); + mysqli_stmt_execute($upd); + + // Upsert department mapping + if ($dept > 0) { + $ins = mysqli_prepare($c, "INSERT INTO conf_user_departments (user_id, department_id) VALUES (?, ?) ON DUPLICATE KEY UPDATE department_id = VALUES(department_id)"); + mysqli_stmt_bind_param($ins, "ii", $user_id, $dept); + mysqli_stmt_execute($ins); + } else { + $del = mysqli_prepare($c, "DELETE FROM conf_user_departments WHERE user_id = ?"); + mysqli_stmt_bind_param($del, "i", $user_id); + mysqli_stmt_execute($del); + } + + $message = "Saved changes."; +} + +$user = $user_id ? fetch_user($c, $user_id) : null; +$user_dept = $user_id ? fetch_dept($c, $user_id) : null; + +$MY_TITLE = "Edit User"; +$MY_CRUMB = "Edit User"; + +if (!$user) { + $CONTENT = "
No user found. Provide ?id=USER_ID in the query string.
"; + include 'layout.php'; + exit(); +} + +ob_start(); +?> + + + + +