export default {
  async fetch(request, env, ctx) {
    const url = new URL(request.url);

    if (request.method === "OPTIONS") {
      return new Response(null, { headers: corsHeaders(request) });
    }

    try {
      // ===== 署名発行（FileMaker → Worker）=====
      if (url.pathname === "/auth/sign") {
        const issuerSecret = request.headers.get("X-Issuer-Secret") || "";
        if (!env.SIGN_ISSUER_SECRET || issuerSecret !== env.SIGN_ISSUER_SECRET) {
          return json({ error: "unauthorized" }, 401, request);
        }

        const uid = (url.searchParams.get("uid") || "").trim();
        if (!uid) return json({ error: "uid required" }, 400, request);

        const ttlSec = Number(env.SIGN_TTL_SEC || 1800);
        const now = Math.floor(Date.now() / 1000);

        const cacheKey = `sign:${uid}`;
        const cacheReq = new Request("https://cache.local/" + encodeURIComponent(cacheKey));
        const cached = await caches.default.match(cacheReq);
        if (cached) return withCors(cached, request);

        const exp = now + ttlSec;
        const nonce = randomNonce(24);

        const payload = `uid=${uid}&exp=${exp}&nonce=${nonce}`;
        const sig = await hmacHex(env.AUTH_HMAC_SECRET, payload);

        const out = {
          uid,
          exp,
          nonce,
          sig,
          token: `${payload}&sig=${sig}`,
          pagesUrl: env.PAGES_URL
            ? `${env.PAGES_URL}?uid=${encodeURIComponent(uid)}&exp=${exp}&nonce=${encodeURIComponent(nonce)}&sig=${sig}`
            : null
        };

        const body = JSON.stringify(out);
        const headers = new Headers({
          "Content-Type": "application/json; charset=utf-8",
          "Cache-Control": `public, max-age=${ttlSec}`
        });
        const ch = corsHeaders(request);
        for (const [k, v] of Object.entries(ch)) headers.set(k, v);

        const res = new Response(body, { status: 200, headers });
        ctx.waitUntil(caches.default.put(cacheReq, new Response(body, { status: 200, headers })));
        return res;
      }

      // ===== ここから下は署名トークン必須（Pages → Worker）=====
      const auth = await requireSignedAuth(request, env, url);

      if (url.pathname === "/health") return json({ ok: true }, 200, request);
      if (url.pathname === "/config") return json({ mapboxToken: env.MAPBOX_TOKEN || "" }, 200, request);

      // =========================================================
      // staff master (共通：案件/訪販)
      // GET /staff_list
      // =========================================================
      if (url.pathname === "/staff_list") {
        const ttl = Number(env.STAFF_LIST_CACHE_SEC || 3600);
        const cacheReq = new Request("https://cache.local/" + encodeURIComponent(`staff_list:v1`));
        const cached = await caches.default.match(cacheReq);
        if (cached) return withCors(cached, request);

        const token = await getFmsToken(env);

        const findBody = {
          query: [{
            [ACCOUNT_FIELDS.attr]: "正社員",
            [ACCOUNT_FIELDS.exit_date]: "="
          }],
          limit: Number(env.STAFF_LIST_LIMIT || 2000)
        };

        const records = await fmsFindAccounts(env, token, findBody);

        const names = [];
        for (const r of records) {
          const f = r.fieldData || {};
          const name = (f[ACCOUNT_FIELDS.name] || "").toString().trim();
          if (!name) continue;
          names.push(name);
        }

        const uniq = Array.from(new Set(names)).sort((a, b) => a.localeCompare(b, "ja"));
        const items = uniq.map(name => ({ name }));

        return cachedJson({ items }, 200, request, ctx, cacheReq, ttl);
      }

      // =========================================================
      // 訪販：報告（更新→script endpointで通知）
      // POST /prospect_report
      // body: { record_id, status, memo }
      // status: excluded|ordered|approach|posting
      // =========================================================
      if (url.pathname === "/prospect_report" && request.method === "POST") {
        const token = await getFmsToken(env);

        const raw = await request.text();
        let body;
        try { body = JSON.parse(raw || "{}"); }
        catch { return json({ error: "invalid json" }, 400, request); }

        const record_id = (body.record_id || "").toString().trim();
        const status = (body.status || "").toString().trim();
        const memo = (body.memo ?? "").toString();

        if (!record_id) return json({ error: "record_id required" }, 400, request);
        if (!["excluded","ordered","approach","posting"].includes(status)) {
          return json({ error: "invalid status" }, 400, request);
        }

        // 1) record_idで対象レコード特定（FM内部 recordId を得る）
        const findBody = { query: [{ [PROSPECT_FIELDS.record_id]: record_id }], limit: 1 };
        const records = await fmsFindProspects(env, token, findBody);
        const rec = records[0];
        if (!rec) return json({ error: "not found" }, 404, request);

        const f = rec.fieldData || {};
        const fmRecordId = String(rec.recordId || "");
        if (!fmRecordId) throw new Error("Missing FileMaker recordId");

        // 2) uid → アカウント管理(t_ID) → tc_氏名（見つからなければスキップ）
        let staffName = "";
        try {
          const uid = (auth.uid || "").toString().trim();
          if (uid) {
            const accFind = { query: [{ [ACCOUNT_FIELDS.id]: uid }], limit: 1 };
            const accRecs = await fmsFindAccounts(env, token, accFind);
            const accRec = accRecs[0];
            if (accRec?.fieldData) {
              staffName = (accRec.fieldData[ACCOUNT_FIELDS.name] || "").toString().trim();
            }
          }
        } catch (_e) {
          staffName = "";
        }

        const todayMdy = todayMDY_JST();

        // 3) 更新 fieldData
        const fieldData = {};

        if (status === "excluded") fieldData[PROSPECT_FIELDS.excluded_date] = todayMdy;
        if (status === "ordered")  fieldData[PROSPECT_FIELDS.ordered_date]  = todayMdy;
        if (status === "approach") fieldData[PROSPECT_FIELDS.approach_date] = todayMdy;
        if (status === "posting")  fieldData[PROSPECT_FIELDS.posted_date]   = todayMdy;

        if (staffName) fieldData[PROSPECT_FIELDS.staff] = staffName;

        const prevMemo = (f[PROSPECT_FIELDS.visit_memo] ?? "").toString();
        fieldData[PROSPECT_FIELDS.visit_memo] = appendProspectMemo({
          prev: prevMemo,
          todayMdy,
          staffName: staffName || (f[PROSPECT_FIELDS.staff] ?? "").toString().trim(),
          uid: auth.uid,
          status,
          memo
        });

        // 4) まず更新（scriptはここでは実行しない）
        const updateResult = await fmsUpdateProspectRecord(env, token, fmRecordId, { fieldData });

        // 5) script endpoint で通知（paramは record_id のみ）
        const scriptName = (env.FMS_SCRIPT_PROSPECT_NOTIFY || "").toString().trim();
        if (!scriptName) throw new Error("Missing FMS_SCRIPT_PROSPECT_NOTIFY");
        const scriptResult = await fmsRunProspectScript(env, token, scriptName, record_id);

        return json({
          ok: true,
          record_id,
          status,
          staff_updated: !!staffName,
          updateResult,
          scriptResult
        }, 200, request);
      }

      // ===== bboxで点取得（従来）=====
      if (url.pathname === "/projects") {
        const bboxStr = url.searchParams.get("bbox") || "";
        const parts = bboxStr.split(",").map(Number);
        if (parts.length !== 4 || parts.some((n) => Number.isNaN(n))) {
          return json({ error: "bbox required: minLng,minLat,maxLng,maxLat" }, 400, request);
        }
        const [minLng, minLat, maxLng, maxLat] = parts;

        const key = `projects:${auth.uid}:${round(minLng, 3)}:${round(minLat, 3)}:${round(maxLng, 3)}:${round(maxLat, 3)}`;
        const cacheReq = new Request("https://cache.local/" + encodeURIComponent(key));
        const cached = await caches.default.match(cacheReq);
        if (cached) return withCors(cached, request);

        const token = await getFmsToken(env);

        const findBody = {
          query: [{ [FIELDS.has_coord]: "1" }],
          limit: Number(env.PROJECTS_LIMIT || 3000)
        };

        const records = await fmsFind(env, token, findBody);

        const items = [];
        for (const r of records) {
          const f = r.fieldData || {};
          const lat = Number(f[FIELDS.lat]);
          const lng = Number(f[FIELDS.lng]);
          if (!Number.isFinite(lat) || !Number.isFinite(lng)) continue;
          if (lng < minLng || lng > maxLng || lat < minLat || lat > maxLat) continue;
          items.push(projectToItemMDY(f));
        }

        return cachedJson({ items }, 200, request, ctx, cacheReq, 15);
      }

      // ===== 全域：日付(MIX)で絞り込み（従来）=====
      if (url.pathname === "/projects_by_date") {
        const raw = (url.searchParams.get("date") || "").trim();
        if (!raw) return json({ error: "date required" }, 400, request);

        const mdy = normalizeMDY(raw);
        if (!mdy) return json({ error: "invalid date format" }, 400, request);

        const ttl = Number(env.PROJECTS_BY_DATE_CACHE_SEC || 60);
        const cacheReq = new Request("https://cache.local/" + encodeURIComponent(`projects_by_date:${auth.uid}:${mdy}`));
        const cached = await caches.default.match(cacheReq);
        if (cached) return withCors(cached, request);

        const token = await getFmsToken(env);

        const findBody = {
          query: [
            { [FIELDS.has_coord]: "1", [FIELDS.visit_date]: mdy },
            { [FIELDS.has_coord]: "1", [FIELDS.cvisit_date]: mdy }
          ],
          limit: Number(env.PROJECTS_LIMIT || 3000)
        };

        const records = await fmsFind(env, token, findBody);

        const items = [];
        for (const r of records) {
          const f = r.fieldData || {};
          const lat = Number(f[FIELDS.lat]);
          const lng = Number(f[FIELDS.lng]);
          if (!Number.isFinite(lat) || !Number.isFinite(lng)) continue;
          items.push(projectToItemMDY(f));
        }

        return cachedJson({ items }, 200, request, ctx, cacheReq, ttl);
      }

      // ===== ★軽量化の本命：bbox + filters + search（案件）=====
      if (url.pathname === "/projects_search") {
        const bboxStr = url.searchParams.get("bbox") || "";
        const parts = bboxStr.split(",").map(Number);
        if (parts.length !== 4 || parts.some((n) => Number.isNaN(n))) {
          return json({ error: "bbox required: minLng,minLat,maxLng,maxLat" }, 400, request);
        }
        const [minLng0, minLat0, maxLng0, maxLat0] = parts;

        const r6 = (n) => Math.round(n * 1e6) / 1e6;
        const minLng = r6(minLng0);
        const minLat = r6(minLat0);
        const maxLng = r6(maxLng0);
        const maxLat = r6(maxLat0);

        const status  = (url.searchParams.get("status")  || "").trim();
        const channel = (url.searchParams.get("channel") || "").trim();
        const staff   = (url.searchParams.get("staff")   || "").trim();
        const rawDate = (url.searchParams.get("date")    || "").trim();
        const qRaw    = (url.searchParams.get("q")       || "").trim();
        const year    = (url.searchParams.get("year")    || "").trim();

        const date = rawDate ? normalizeMDY(rawDate) : "";

        const ttl = Number(env.PROJECTS_SEARCH_CACHE_SEC || 10);
        const key =
          `projects_search:${auth.uid}:` +
          `${minLng}:${minLat}:${maxLng}:${maxLat}:` +
          `${status}:${channel}:${staff}:${date}:${qRaw}:${year}`;

        const cacheReq = new Request("https://cache.local/" + encodeURIComponent(key));
        const cached = await caches.default.match(cacheReq);
        if (cached) return withCors(cached, request);

        const token = await getFmsToken(env);

        const base = {
          [FIELDS.has_coord]: "1",
          [FIELDS.lat]: `${minLat}...${maxLat}`,
          [FIELDS.lng]: `${minLng}...${maxLng}`,
        };

        if (status) base[FIELDS.status] = status;
        if (channel && FIELDS.channel) base[FIELDS.channel] = channel;
        if (staff) base[FIELDS.staff] = staff;

        const baseClauses = [];
        if (date) {
          baseClauses.push({ ...base, [FIELDS.visit_date]: date });
          baseClauses.push({ ...base, [FIELDS.cvisit_date]: date });
        } else {
          baseClauses.push({ ...base });
        }

        const q = qRaw;
        const qDigits = q.replace(/[^\d]/g, "");
        const isNumericOnly = q && qDigits && qDigits.length === q.length;

        const query = [];

        if (!q) {
          query.push(...baseClauses);
        } else if (isNumericOnly) {
          for (const bc of baseClauses) {
            query.push({ ...bc, [FIELDS.id]: q });
            query.push({ ...bc, [FIELDS.phone]: `*${q}*` });
            query.push({ ...bc, [FIELDS.mobile]: `*${q}*` });
          }
        } else {
          for (const bc of baseClauses) {
            query.push({ ...bc, [FIELDS.customer_name]: `*${q}*` });
            query.push({ ...bc, [FIELDS.address]: `*${q}*` });
          }
        }

        const LIMIT = Number(env.PROJECTS_LIMIT || 3000);
        const MAX_PAGES = Number(env.PROJECTS_MAX_PAGES || 20);

        const items = [];
        let offset = 1;

        for (let page = 0; page < MAX_PAGES; page++) {
          const findBody = { query, limit: LIMIT, offset };
          const records = await fmsFind(env, token, findBody);
          if (!records.length) break;

          for (const r of records) {
            const f = r.fieldData || {};
            const lat = Number(f[FIELDS.lat]);
            const lng = Number(f[FIELDS.lng]);
            if (!Number.isFinite(lat) || !Number.isFinite(lng)) continue;
            if (lng < minLng || lng > maxLng || lat < minLat || lat > maxLat) continue;

            const it = projectToItemMDY(f);

            if (year) {
              const ed = normalizeMDY(it.end_date);
              const m = ed.match(/^(\d{2})\/(\d{2})\/(\d{4})$/);
              if (!m || m[3] !== year) continue;
            }

            items.push(it);
          }

          offset += records.length;
          if (records.length < LIMIT) break;
        }

        return cachedJson({ items }, 200, request, ctx, cacheReq, ttl);
      }

      // ===== 1件詳細（案件）=====
      if (url.pathname === "/project") {
        const id = url.searchParams.get("id");
        if (!id) return json({ error: "id required" }, 400, request);

        const token = await getFmsToken(env);

        const findBody = { query: [{ [FIELDS.id]: String(id) }], limit: 1 };
        const records = await fmsFind(env, token, findBody);
        const rec = records[0];
        if (!rec) return json({ error: "not found" }, 404, request);

        const f = rec.fieldData || {};
        return json({
          item: {
            id: String(f[FIELDS.id] ?? id),
            customer_name: f[FIELDS.customer_name] ?? "",
            lat: Number(f[FIELDS.lat]),
            lng: Number(f[FIELDS.lng]),
            status: f[FIELDS.status] ?? "",
            channel: f[FIELDS.channel] ?? "",
            address: f[FIELDS.address] ?? "",
            phone: f[FIELDS.phone] ?? "",
            mobile: f[FIELDS.mobile] ?? "",
            staff: f[FIELDS.staff] ?? "",

            cvisit_date: normalizeMDY(f[FIELDS.cvisit_date]),
            cvisit_time1: normalizeTime(f[FIELDS.cvisit_time1]),
            cvisit_time2: normalizeTime(f[FIELDS.cvisit_time2]),

            visit_date: normalizeMDY(f[FIELDS.visit_date]),
            visit_time1: normalizeTime(f[FIELDS.visit_time1]),
            visit_time2: normalizeTime(f[FIELDS.visit_time2]),

            start_date: normalizeMDY(f[FIELDS.start_date]),
            s_end_date: normalizeMDY(f[FIELDS.s_end_date]),
            end_date: normalizeMDY(f[FIELDS.end_date]),

            amount: f[FIELDS.amount] ?? "",
            accuracy: f[FIELDS.accuracy] ?? "",

            apo_memo: f[FIELDS.apo_memo] ?? "",
            closing_memo: f[FIELDS.closing_memo] ?? "",
            construction_memo: f[FIELDS.construction_memo] ?? ""
          }
        }, 200, request);
      }

      // =========================================================
      // 訪販：bbox + filters + search（最小返却）
      // ★ is_recent_1w を返す（今回追加）
      // =========================================================
      if (url.pathname === "/prospects_search") {
        const bboxStr = url.searchParams.get("bbox") || "";
        const parts = bboxStr.split(",").map(Number);
        if (parts.length !== 4 || parts.some((n) => Number.isNaN(n))) {
          return json({ error: "bbox required: minLng,minLat,maxLng,maxLat" }, 400, request);
        }
        const [minLng0, minLat0, maxLng0, maxLat0] = parts;

        const r6 = (n) => Math.round(n * 1e6) / 1e6;
        const minLng = r6(minLng0);
        const minLat = r6(minLat0);
        const maxLng = r6(maxLng0);
        const maxLat = r6(maxLat0);

        const qRaw = (url.searchParams.get("q") || "").trim();

        const posting  = (url.searchParams.get("posting") || "").trim() === "1";
        const approach = (url.searchParams.get("approach") || "").trim() === "1";
        const ordered  = (url.searchParams.get("ordered") || "").trim() === "1";
        const excluded = (url.searchParams.get("excluded") || "").trim() === "1";

        const dist  = (url.searchParams.get("dist")  || "").trim();
        const staff = (url.searchParams.get("staff") || "").trim();

        const ttl = Number(env.PROJECTS_SEARCH_CACHE_SEC || 10);
        const key =
          `prospects_search:${auth.uid}:` +
          `${minLng}:${minLat}:${maxLng}:${maxLat}:` +
          `${qRaw}:${posting?1:0}:${approach?1:0}:${ordered?1:0}:${excluded?1:0}:${dist}:${staff}`;

        const cacheReq = new Request("https://cache.local/" + encodeURIComponent(key));
        const cached = await caches.default.match(cacheReq);
        if (cached) return withCors(cached, request);

        const token = await getFmsToken(env);

        const base = {
          [PROSPECT_FIELDS.has_coord]: "1",
          [PROSPECT_FIELDS.lat]: `${minLat}...${maxLat}`,
          [PROSPECT_FIELDS.lng]: `${minLng}...${maxLng}`,
        };
        if (staff) base[PROSPECT_FIELDS.staff] = staff;

        const baseClauses = qRaw
          ? [{ ...base, [PROSPECT_FIELDS.address_join]: `*${qRaw}*` }]
          : [{ ...base }];

        const statusClauses = [];
        if (excluded) statusClauses.push({ [PROSPECT_FIELDS.excluded_date]: "*" });
        if (ordered)  statusClauses.push({ [PROSPECT_FIELDS.ordered_date]: "*" });
        if (approach) statusClauses.push({ [PROSPECT_FIELDS.approach_date]: "*" });
        if (posting)  statusClauses.push({ [PROSPECT_FIELDS.posted_date]: "*" });

        const distClause = buildProspectDistClause(dist);

        const query = [];
        if (!statusClauses.length && !distClause) {
          query.push(...baseClauses);
        } else {
          for (const bc of baseClauses) {
            if (statusClauses.length) {
              for (const sc of statusClauses) {
                const merged = { ...bc, ...sc };
                if (distClause) Object.assign(merged, distClause);
                query.push(merged);
              }
            } else {
              const merged = { ...bc };
              if (distClause) Object.assign(merged, distClause);
              query.push(merged);
            }
          }
        }

        const LIMIT = Number(env.PROJECTS_LIMIT || 3000);
        const MAX_PAGES = Number(env.PROJECTS_MAX_PAGES || 20);

        const items = [];
        let offset = 1;

        for (let page = 0; page < MAX_PAGES; page++) {
          const findBody = { query, limit: LIMIT, offset };
          const records = await fmsFindProspects(env, token, findBody);
          if (!records.length) break;

          for (const r of records) {
            const f = r.fieldData || {};
            const lat = Number(f[PROSPECT_FIELDS.lat]);
            const lng = Number(f[PROSPECT_FIELDS.lng]);
            if (!Number.isFinite(lat) || !Number.isFinite(lng)) continue;
            if (lng < minLng || lng > maxLng || lat < minLat || lat > maxLat) continue;

            items.push(prospectToMapItem(f)); // ★ここで is_recent_1w も返る
          }

          offset += records.length;
          if (records.length < LIMIT) break;
        }

        return cachedJson({ items }, 200, request, ctx, cacheReq, ttl);
      }

      // ===== 1件詳細（訪販）=====
      if (url.pathname === "/prospect") {
        const id = (url.searchParams.get("id") || "").trim();
        if (!id) return json({ error: "id required" }, 400, request);

        const token = await getFmsToken(env);

        const findBody = { query: [{ [PROSPECT_FIELDS.record_id]: String(id) }], limit: 1 };
        const records = await fmsFindProspects(env, token, findBody);
        const rec = records[0];
        if (!rec) return json({ error: "not found" }, 404, request);

        const f = rec.fieldData || {};
        return json({ item: prospectToDetailMDY(f) }, 200, request);
      }

      return json({ error: "not found" }, 404, request);
    } catch (e) {
      return json({ error: e?.message || String(e) }, 500, request);
    }
  }
};

// --- FileMaker field names (Projects) ---
const FIELDS = {
  has_coord: "map_has_coord",

  id: "n_管理番号",
  customer_name: "t_契約者名",
  lat: "開発_緯度",
  lng: "開発_経度",
  status: "t_エントリーステータス",
  channel: "ct_チャネル",

  address: "t_施工先住所",
  phone: "t_固定電話番号",
  mobile: "t_携帯電話番号",
  staff: "t_担当クローザー",

  cvisit_date: "d_現地調査予定日",
  cvisit_time1: "ti_現地調査時間1",
  cvisit_time2: "ti_現地調査時間2",

  visit_date: "d_訪問予定日",
  visit_time1: "ti_訪問時間1",
  visit_time2: "ti_訪問時間2",

  start_date: "d_工務店着工日",
  s_end_date: "d_工務店完工予定日",
  end_date: "d_工務店完工日",

  amount: "n_火災保険適用金額",
  accuracy: "開発_ジオコード精度",

  apo_memo: "t_アポイントmemo",
  closing_memo: "t_クロージング備考",
  construction_memo: "t_工事備考"
};

// --- FileMaker field names (Prospects: エコxエネリスト) ---
const PROSPECT_FIELDS = {
  has_coord: "map_has_coord",
  record_id: "record_id",
  lat: "n_緯度",
  lng: "n_経度",
  geo_precision: "t_GEO",

  address_join: "tc_連結住所",
  delivery_dt: "d_配信日時",
  posted_date: "d_チラシ投函日",
  approach_date: "d_対面アプローチ日",
  ordered_date: "d_受注日",
  excluded_date: "d_対象外確定日",
  staff: "t_担当者",

  // ★追加（FM計算フィールド）
  is_recent_1w: "is_recent_1w",

  name: "お名前",
  kana: "フリガナ",
  age: "年齢",
  phone: "電話番号",
  email: "メールアドレス",
  applicant: "お申込者",
  place: "設置場所",
  quote_method: "お見積もり方法",
  quote_status: "お見積もり状況",
  has_solar: "太陽光パネルは設置されていますか？",
  timing: "導入検討時期",
  purpose: "導入目的",
  choose_point: "設置会社を選ぶポイント",
  also_products: "あわせて見積もりを取りたい商品",
  ownership: "建物の所有区分",
  inquiry: "お問合せ内容",
  visit_memo: "t_訪問備考"
};

// --- FileMaker field names (Accounts: アカウント管理) ---
const ACCOUNT_FIELDS = {
  id: "t_ID",
  name: "tc_氏名",
  attr: "t_属性",
  exit_date: "d_退社日"
};

function projectToItemMDY(f) {
  return {
    id: String(f[FIELDS.id] ?? ""),
    lat: Number(f[FIELDS.lat]),
    lng: Number(f[FIELDS.lng]),
    status: f[FIELDS.status] ?? "",
    customer_name: f[FIELDS.customer_name] ?? "",

    channel: f[FIELDS.channel] ?? "",
    staff: f[FIELDS.staff] ?? "",

    visit_date: normalizeMDY(f[FIELDS.visit_date]),
    visit_time1: normalizeTime(f[FIELDS.visit_time1]),
    visit_time2: normalizeTime(f[FIELDS.visit_time2]),

    cvisit_date: normalizeMDY(f[FIELDS.cvisit_date]),
    cvisit_time1: normalizeTime(f[FIELDS.cvisit_time1]),
    cvisit_time2: normalizeTime(f[FIELDS.cvisit_time2]),

    end_date: normalizeMDY(f[FIELDS.end_date]),

    address: f[FIELDS.address] ?? "",
    phone: f[FIELDS.phone] ?? "",
    mobile: f[FIELDS.mobile] ?? ""
  };
}

function prospectStatusCodeFromFieldData(f){
  if (normalizeMDY(f[PROSPECT_FIELDS.excluded_date])) return "excluded";
  if (normalizeMDY(f[PROSPECT_FIELDS.ordered_date])) return "ordered";
  if (normalizeMDY(f[PROSPECT_FIELDS.approach_date])) return "approach";
  if (normalizeMDY(f[PROSPECT_FIELDS.posted_date])) return "posting";
  return "todo";
}

function prospectToMapItem(f){
  const code = prospectStatusCodeFromFieldData(f);
  return {
    record_id: String(f[PROSPECT_FIELDS.record_id] ?? ""),
    lat: Number(f[PROSPECT_FIELDS.lat]),
    lng: Number(f[PROSPECT_FIELDS.lng]),
    status_code: code,

    // ★追加：FM計算フィールドをそのまま返す（0/1）
    is_recent_1w: Number(f[PROSPECT_FIELDS.is_recent_1w] || 0),

    is_todo: code === "todo" ? 1 : 0,
    is_posted: code === "posting" ? 1 : 0,
    is_approached: code === "approach" ? 1 : 0,
    is_ordered: code === "ordered" ? 1 : 0,
    is_excluded: code === "excluded" ? 1 : 0
  };
}

function prospectToDetailMDY(f){
  return {
    record_id: String(f[PROSPECT_FIELDS.record_id] ?? ""),
    lat: Number(f[PROSPECT_FIELDS.lat]),
    lng: Number(f[PROSPECT_FIELDS.lng]),
    t_GEO: f[PROSPECT_FIELDS.geo_precision] ?? "",

    "お名前": f[PROSPECT_FIELDS.name] ?? "",
    "フリガナ": f[PROSPECT_FIELDS.kana] ?? "",
    "年齢": f[PROSPECT_FIELDS.age] ?? "",
    "電話番号": f[PROSPECT_FIELDS.phone] ?? "",
    "メールアドレス": f[PROSPECT_FIELDS.email] ?? "",
    "tc_連結住所": f[PROSPECT_FIELDS.address_join] ?? "",
    "t_担当者": f[PROSPECT_FIELDS.staff] ?? "",

    "お申込者": f[PROSPECT_FIELDS.applicant] ?? "",
    "設置場所": f[PROSPECT_FIELDS.place] ?? "",
    "お見積もり方法": f[PROSPECT_FIELDS.quote_method] ?? "",
    "お見積もり状況": f[PROSPECT_FIELDS.quote_status] ?? "",

    "太陽光パネルは設置されていますか？": f[PROSPECT_FIELDS.has_solar] ?? "",
    "導入検討時期": f[PROSPECT_FIELDS.timing] ?? "",
    "導入目的": f[PROSPECT_FIELDS.purpose] ?? "",
    "設置会社を選ぶポイント": f[PROSPECT_FIELDS.choose_point] ?? "",
    "あわせて見積もりを取りたい商品": f[PROSPECT_FIELDS.also_products] ?? "",
    "建物の所有区分": f[PROSPECT_FIELDS.ownership] ?? "",
    "お問合せ内容": f[PROSPECT_FIELDS.inquiry] ?? "",
    "t_訪問備考": f[PROSPECT_FIELDS.visit_memo] ?? "",

    "d_配信日時": normalizeMDY(f[PROSPECT_FIELDS.delivery_dt]),
    "d_チラシ投函日": normalizeMDY(f[PROSPECT_FIELDS.posted_date]),
    "d_対面アプローチ日": normalizeMDY(f[PROSPECT_FIELDS.approach_date]),
    "d_受注日": normalizeMDY(f[PROSPECT_FIELDS.ordered_date]),
    "d_対象外確定日": normalizeMDY(f[PROSPECT_FIELDS.excluded_date])
  };
}

function appendProspectMemo({ prev, todayMdy, staffName, uid, status, memo }){
  const cleanMemo = (memo ?? "").toString().replace(/\r\n/g,"\n").replace(/\r/g,"\n").trim();
  const who = (staffName || "").trim() || `uid:${uid}`;
  const head = `[${todayMdy}] (${who}) status=${status}`;
  const block = cleanMemo ? `${head}\n${cleanMemo}` : head;

  const p = (prev ?? "").toString().replace(/\r\n/g,"\n").replace(/\r/g,"\n").trim();
  if (!p) return block;
  return `${block}\n\n${p}`;
}

function todayMDY_JST(){
  const now = new Date();
  const jst = new Date(now.getTime() + 9*60*60*1000);
  const y = jst.getUTCFullYear();
  const m = String(jst.getUTCMonth()+1).padStart(2,"0");
  const d = String(jst.getUTCDate()).padStart(2,"0");
  return `${m}/${d}/${y}`;
}

// ---- dist clause builder ----
function buildProspectDistClause(dist){
  if (!dist) return null;

  const now = new Date();
  const jst = new Date(now.getTime() + 9*60*60*1000);
  const y = jst.getUTCFullYear();
  const m = jst.getUTCMonth();
  const d = jst.getUTCDate();
  const startOfToday = new Date(Date.UTC(y, m, d));

  const cutoff = (months, years) => {
    const dt = new Date(startOfToday);
    if (years) dt.setUTCFullYear(dt.getUTCFullYear() - years);
    if (months) dt.setUTCMonth(dt.getUTCMonth() - months);
    const yy = dt.getUTCFullYear();
    const mm = String(dt.getUTCMonth()+1).padStart(2,"0");
    const dd = String(dt.getUTCDate()).padStart(2,"0");
    return `${mm}/${dd}/${yy}`;
  };

  if (dist === "3m")   return { [PROSPECT_FIELDS.delivery_dt]: `>=${cutoff(3,0)}` };
  if (dist === "6m")   return { [PROSPECT_FIELDS.delivery_dt]: `>=${cutoff(6,0)}` };
  if (dist === "1y")   return { [PROSPECT_FIELDS.delivery_dt]: `>=${cutoff(0,1)}` };
  if (dist === "past") return { [PROSPECT_FIELDS.delivery_dt]: `<${cutoff(0,1)}` };
  return null;
}

// --- normalize date/time ---
function normalizeMDY(s) {
  s = (s ?? "").toString().trim();
  if (!s) return "";

  let m = s.match(/^(\d{1,2})\/(\d{1,2})\/(\d{4})$/);
  if (m) {
    const mm = String(m[1]).padStart(2, "0");
    const dd = String(m[2]).padStart(2, "0");
    const yy = m[3];
    return `${mm}/${dd}/${yy}`;
  }

  m = s.match(/^(\d{4})\/(\d{1,2})\/(\d{1,2})$/);
  if (m) {
    const yy = m[1];
    const mm = String(m[2]).padStart(2, "0");
    const dd = String(m[3]).padStart(2, "0");
    return `${mm}/${dd}/${yy}`;
  }

  m = s.match(/^(\d{4})-(\d{1,2})-(\d{1,2})$/);
  if (m) {
    const yy = m[1];
    const mm = String(m[2]).padStart(2, "0");
    const dd = String(m[3]).padStart(2, "0");
    return `${mm}/${dd}/${yy}`;
  }

  return "";
}

function normalizeTime(s) {
  s = (s ?? "").toString().trim();
  if (!s) return "";
  const m = s.match(/^(\d{1,2}):(\d{2})/);
  if (m) return `${String(m[1]).padStart(2, "0")}:${m[2]}`;
  const m2 = s.match(/^(\d{1,2})時(\d{1,2})?/);
  if (m2) return `${String(m2[1]).padStart(2, "0")}:${String(m2[2] ?? "00").padStart(2, "0")}`;
  return s;
}

// --- CORS/helpers ---
function corsHeaders(request) {
  const origin = request.headers.get("Origin") || "*";
  return {
    "Access-Control-Allow-Origin": origin,
    "Access-Control-Allow-Methods": "GET,POST,OPTIONS,PATCH",
    "Access-Control-Allow-Headers": "Content-Type, Authorization, X-Issuer-Secret",
    "Access-Control-Max-Age": "86400"
  };
}
function withCors(response, request) {
  const headers = new Headers(response.headers);
  const ch = corsHeaders(request);
  for (const [k, v] of Object.entries(ch)) headers.set(k, v);
  return new Response(response.body, { status: response.status, headers });
}
function json(obj, status, request) {
  const body = JSON.stringify(obj);
  const headers = new Headers({ "Content-Type": "application/json; charset=utf-8" });
  const ch = corsHeaders(request);
  for (const [k, v] of Object.entries(ch)) headers.set(k, v);
  return new Response(body, { status, headers });
}
function cachedJson(obj, status, request, ctx, cacheReq, ttlSec) {
  const body = JSON.stringify(obj);
  const headers = new Headers({
    "Content-Type": "application/json; charset=utf-8",
    "Cache-Control": `public, max-age=${ttlSec}`
  });
  const ch = corsHeaders(request);
  for (const [k, v] of Object.entries(ch)) headers.set(k, v);
  const res = new Response(body, { status, headers });
  ctx.waitUntil(caches.default.put(cacheReq, new Response(body, { status, headers })));
  return res;
}
function round(n, digits) {
  const p = 10 ** digits;
  return Math.round(n * p) / p;
}

// ===== Signed auth =====
async function requireSignedAuth(request, env, url) {
  const secret = env.AUTH_HMAC_SECRET;
  if (!secret) throw new Error("Missing AUTH_HMAC_SECRET");

  const authz = request.headers.get("Authorization") || "";
  let tokenStr = "";
  if (authz.toLowerCase().startsWith("bearer ")) tokenStr = authz.slice(7).trim();

  if (!tokenStr) {
    const uid = url.searchParams.get("uid") || "";
    const exp = url.searchParams.get("exp") || "";
    const nonce = url.searchParams.get("nonce") || "";
    const sig = url.searchParams.get("sig") || "";
    if (uid && exp && nonce && sig) tokenStr = `uid=${uid}&exp=${exp}&nonce=${nonce}&sig=${sig}`;
  }
  if (!tokenStr) throw new Error("Missing auth token");

  const p = new URLSearchParams(tokenStr);
  const uid = (p.get("uid") || "").trim();
  const expStr = (p.get("exp") || "").trim();
  const nonce = (p.get("nonce") || "").trim();
  const sigHex = (p.get("sig") || "").trim();
  if (!uid || !expStr || !nonce || !sigHex) throw new Error("Invalid token: missing fields");

  const exp = Number(expStr);
  if (!Number.isFinite(exp)) throw new Error("Invalid token: exp");

  const now = Math.floor(Date.now() / 1000);
  if (exp < now) throw new Error("Token expired");

  const payload = `uid=${uid}&exp=${expStr}&nonce=${nonce}`;
  const expected = await hmacHex(secret, payload);
  if (!timingSafeEqualHex(expected, sigHex)) throw new Error("Invalid signature");

  return { uid, exp, nonce };
}

async function hmacHex(secret, payload) {
  const key = await crypto.subtle.importKey(
    "raw",
    new TextEncoder().encode(secret),
    { name: "HMAC", hash: "SHA-256" },
    false,
    ["sign"]
  );
  const sig = await crypto.subtle.sign("HMAC", key, new TextEncoder().encode(payload));
  return bufToHex(new Uint8Array(sig));
}
function bufToHex(buf) {
  let s = "";
  for (const b of buf) s += b.toString(16).padStart(2, "0");
  return s;
}
function timingSafeEqualHex(a, b) {
  const aa = (a || "").toLowerCase();
  const bb = (b || "").toLowerCase();
  if (aa.length !== bb.length) return false;
  let r = 0;
  for (let i = 0; i < aa.length; i++) r |= aa.charCodeAt(i) ^ bb.charCodeAt(i);
  return r === 0;
}
function randomNonce(len) {
  const bytes = new Uint8Array(len);
  crypto.getRandomValues(bytes);
  return Array.from(bytes, b => (b % 36).toString(36)).join("");
}

// ===== FMS Data API =====
async function getFmsToken(env) {
  if (globalThis.__FMS_TOKEN && globalThis.__FMS_TOKEN_EXPIRES > Date.now()) {
    return globalThis.__FMS_TOKEN;
  }

  const host = env.FMS_HOST;
  const db = env.FMS_DB;
  const user = env.FMS_USER;
  const pass = env.FMS_PASS;
  if (!host || !db || !user || !pass) {
    throw new Error("Missing FMS_* secrets");
  }

  const loginUrl = `${host}/fmi/data/vLatest/databases/${encodeURIComponent(db)}/sessions`;
  const auth = btoa(`${user}:${pass}`);

  const resp = await fetch(loginUrl, {
    method: "POST",
    headers: { "Authorization": `Basic ${auth}`, "Content-Type": "application/json" },
    body: JSON.stringify({})
  });

  if (!resp.ok) throw new Error(`FMS login failed: ${resp.status} ${await resp.text()}`);

  const data = await resp.json();
  const token = data?.response?.token;
  if (!token) throw new Error("FMS login response missing token");

  globalThis.__FMS_TOKEN = token;
  globalThis.__FMS_TOKEN_EXPIRES = Date.now() + 13 * 60 * 1000;
  return token;
}

async function fmsFind(env, token, bodyObj) {
  const host = env.FMS_HOST;
  const db = env.FMS_DB;
  const layout = env.FMS_LAYOUT;
  if (!layout) throw new Error("Missing FMS_LAYOUT secret");

  const findUrl =
    `${host}/fmi/data/vLatest/databases/${encodeURIComponent(db)}` +
    `/layouts/${encodeURIComponent(layout)}/_find`;

  let resp = await fetch(findUrl, {
    method: "POST",
    headers: { "Authorization": `Bearer ${token}`, "Content-Type": "application/json" },
    body: JSON.stringify(bodyObj)
  });

  if (resp.status === 401) {
    globalThis.__FMS_TOKEN = null;
    globalThis.__FMS_TOKEN_EXPIRES = 0;
    const newToken = await getFmsToken(env);
    resp = await fetch(findUrl, {
      method: "POST",
      headers: { "Authorization": `Bearer ${newToken}`, "Content-Type": "application/json" },
      body: JSON.stringify(bodyObj)
    });
  }

  if (!resp.ok) throw new Error(`FMS find failed: ${resp.status} ${await resp.text()}`);

  const data = await resp.json();
  return data?.response?.data ?? [];
}

async function fmsFindProspects(env, token, bodyObj) {
  const host = env.FMS_HOST;
  const db = env.FMS_DB;
  const layout = env.FMS_LAYOUT_PROSPECTS;
  if (!layout) throw new Error("Missing FMS_LAYOUT_PROSPECTS secret");

  const findUrl =
    `${host}/fmi/data/vLatest/databases/${encodeURIComponent(db)}` +
    `/layouts/${encodeURIComponent(layout)}/_find`;

  let resp = await fetch(findUrl, {
    method: "POST",
    headers: { "Authorization": `Bearer ${token}`, "Content-Type": "application/json" },
    body: JSON.stringify(bodyObj)
  });

  if (resp.status === 401) {
    globalThis.__FMS_TOKEN = null;
    globalThis.__FMS_TOKEN_EXPIRES = 0;
    const newToken = await getFmsToken(env);
    resp = await fetch(findUrl, {
      method: "POST",
      headers: { "Authorization": `Bearer ${newToken}`, "Content-Type": "application/json" },
      body: JSON.stringify(bodyObj)
    });
  }

  if (!resp.ok) throw new Error(`FMS find (prospects) failed: ${resp.status} ${await resp.text()}`);

  const data = await resp.json();
  return data?.response?.data ?? [];
}

async function fmsFindAccounts(env, token, bodyObj) {
  const host = env.FMS_HOST;
  const db = env.FMS_DB;
  const layout = env.FMS_LAYOUT_ACCOUNTS;
  if (!layout) throw new Error("Missing FMS_LAYOUT_ACCOUNTS secret");

  const findUrl =
    `${host}/fmi/data/vLatest/databases/${encodeURIComponent(db)}` +
    `/layouts/${encodeURIComponent(layout)}/_find`;

  let resp = await fetch(findUrl, {
    method: "POST",
    headers: { "Authorization": `Bearer ${token}`, "Content-Type": "application/json" },
    body: JSON.stringify(bodyObj)
  });

  if (resp.status === 401) {
    globalThis.__FMS_TOKEN = null;
    globalThis.__FMS_TOKEN_EXPIRES = 0;
    const newToken = await getFmsToken(env);
    resp = await fetch(findUrl, {
      method: "POST",
      headers: { "Authorization": `Bearer ${newToken}`, "Content-Type": "application/json" },
      body: JSON.stringify(bodyObj)
    });
  }

  if (!resp.ok) throw new Error(`FMS find (accounts) failed: ${resp.status} ${await resp.text()}`);

  const data = await resp.json();
  return data?.response?.data ?? [];
}

async function fmsUpdateProspectRecord(env, token, fmRecordId, { fieldData }) {
  const host = env.FMS_HOST;
  const db = env.FMS_DB;
  const layout = env.FMS_LAYOUT_PROSPECTS;
  if (!layout) throw new Error("Missing FMS_LAYOUT_PROSPECTS secret");

  const updateUrl =
    `${host}/fmi/data/vLatest/databases/${encodeURIComponent(db)}` +
    `/layouts/${encodeURIComponent(layout)}/records/${encodeURIComponent(String(fmRecordId))}`;

  const bodyObj = { fieldData: fieldData || {} };

  let resp = await fetch(updateUrl, {
    method: "PATCH",
    headers: { "Authorization": `Bearer ${token}`, "Content-Type": "application/json" },
    body: JSON.stringify(bodyObj)
  });

  if (resp.status === 401) {
    globalThis.__FMS_TOKEN = null;
    globalThis.__FMS_TOKEN_EXPIRES = 0;
    const newToken = await getFmsToken(env);
    resp = await fetch(updateUrl, {
      method: "PATCH",
      headers: { "Authorization": `Bearer ${newToken}`, "Content-Type": "application/json" },
      body: JSON.stringify(bodyObj)
    });
  }

  if (!resp.ok) throw new Error(`FMS update (prospect) failed: ${resp.status} ${await resp.text()}`);
  return await resp.json();
}

// ★公式の script endpoint で実行（layoutコンテキスト：エコxエネリスト）
async function fmsRunProspectScript(env, token, scriptName, scriptParam) {
  const host = env.FMS_HOST;
  const db = env.FMS_DB;
  const layout = env.FMS_LAYOUT_PROSPECTS;
  if (!layout) throw new Error("Missing FMS_LAYOUT_PROSPECTS secret");

  const qs = new URLSearchParams();
  if (scriptParam != null) qs.set("script.param", String(scriptParam));

  const runUrl =
    `${host}/fmi/data/vLatest/databases/${encodeURIComponent(db)}` +
    `/layouts/${encodeURIComponent(layout)}/script/${encodeURIComponent(scriptName)}` +
    (qs.toString() ? `?${qs.toString()}` : "");

  let resp = await fetch(runUrl, {
    method: "GET",
    headers: { "Authorization": `Bearer ${token}` }
  });

  if (resp.status === 401) {
    globalThis.__FMS_TOKEN = null;
    globalThis.__FMS_TOKEN_EXPIRES = 0;
    const newToken = await getFmsToken(env);
    resp = await fetch(runUrl, {
      method: "GET",
      headers: { "Authorization": `Bearer ${newToken}` }
    });
  }

  if (!resp.ok) throw new Error(`FMS run script (prospect) failed: ${resp.status} ${await resp.text()}`);
  return await resp.json();
}
デプロイ後の確認
/prospects_search の items に is_recent_1w が出るか確認してください：

DevTools → Network → prospects_search → Response
items[0].is_recent_1w が 0/1 になっていればOK
次はHTML側で

直近1週間 フィルター追加（フロントで is_recent_1w==1 で絞る）
どのdistでも is_recent_1w==1 を リング/グローで爆目立ちさせる の差分を出せます。どれくらい派手にしたい？（白リング＋黄色グロー、みたいな方向でOK？）
Notionに保存
とりあえず爆目立ちすればおｋｗ
完全版ＨＴＭＬでちょうだい
Copy<!doctype html>
<html lang="ja">
<head>
  <meta charset="utf-8" />
  <meta name="viewport" content="width=device-width,initial-scale=1,viewport-fit=cover" />
  <title>案件地図</title>

  <link href="https://api.mapbox.com/mapbox-gl-js/v2.15.0/mapbox-gl.css" rel="stylesheet">
  <script src="https://api.mapbox.com/mapbox-gl-js/v2.15.0/mapbox-gl.js"></script>

  <style>
    :root{
      --bg:#0b1220;
      --panel:rgba(255,255,255,.92);
      --line:rgba(0,0,0,.08);
      --shadow:0 10px 30px rgba(0,0,0,.18);
      --r:16px;
      --txt:#111827;
      --muted:#6b7280;
      --primary:#2563eb;
      --panelW:320px;
    }
    html,body{height:100%;margin:0;background:var(--bg);font-family:system-ui,-apple-system,"Segoe UI","Hiragino Sans","Yu Gothic UI",sans-serif}
    #map{position:absolute;inset:0}

    /* Top status bar (fixed) */
    .topStat{
      position:fixed;
      top:10px;
      left:50%;
      transform:translateX(-50%);
      z-index:20;
      display:flex;
      align-items:center;
      gap:10px;
      padding:8px 12px;
      border-radius:999px;
      border:1px solid rgba(0,0,0,.10);
      background: rgba(255,255,255,.92);
      backdrop-filter: blur(10px);
      box-shadow: 0 10px 26px rgba(0,0,0,.18);
      color:#111827;
      font-size:12px;
      font-weight:900;
      max-width: min(92vw, 840px);
      pointer-events:none;
      user-select:none;
    }
    .topStat #topStatText{
      white-space:nowrap;
      overflow:hidden;
      text-overflow:ellipsis;
    }
    .topStat .dot{
      width:10px;height:10px;border-radius:50%;
      background:#9ca3af;
      flex:0 0 auto;
    }
    .topStat.is-loading .dot{ background:#2563eb; }
    .topStat.is-ok .dot{ background:#22c55e; }
    .topStat.is-warn .dot{ background:#f59e0b; }
    .topStat.is-error .dot{ background:#ef4444; }

    /* generic panel */
    .panel{
      position:fixed; z-index:10;
      background:var(--panel);
      border:1px solid var(--line);
      border-radius:var(--r);
      box-shadow:var(--shadow);
      backdrop-filter: blur(10px);
      overflow:hidden;
    }
    .panel .hd{
      display:flex;align-items:center;justify-content:space-between;
      padding:8px 10px;border-bottom:1px solid rgba(0,0,0,.06);user-select:none;
      background: rgba(255,255,255,.75);
    }
    .panel .ttl{font-weight:900;color:var(--txt);font-size:12px;letter-spacing:.06em}
    .panel .tg{
      border:none;background:transparent;color:var(--muted);
      font-weight:900;cursor:pointer;padding:6px 8px;border-radius:10px;
    }
    .panel .tg:hover{background:rgba(0,0,0,.04)}
    .panel .bd{padding:10px 12px;overflow:auto}

    .row{display:flex;gap:8px;margin:8px 0}
    .col{flex:1}
    label{font-size:12px;color:var(--muted);display:block;margin:0 0 4px}
    input,select,button,textarea{
      width:100%;box-sizing:border-box;
      padding:9px 10px;border-radius:12px;
      border:1px solid rgba(0,0,0,.10);
      background:rgba(255,255,255,.92);
      font-size:13px;outline:none;
    }
    textarea{min-height:88px;resize:vertical}
    input:focus,select:focus,textarea:focus{border-color: rgba(37,99,235,.55); box-shadow:0 0 0 3px rgba(37,99,235,.12)}
    button{cursor:pointer;border:none;font-weight:900}
    .btn-primary{background:var(--primary);color:#fff}
    .btn-secondary{
      background: rgba(255,255,255,.92);
      border:1px solid rgba(0,0,0,.10);
      color:#111827;
    }
    .badge{display:inline-flex;align-items:center;gap:6px;padding:4px 10px;border-radius:999px;background:rgba(0,0,0,.06);font-size:12px;color:var(--txt)}
    .small{font-size:12px;color:var(--muted)}

    /* main panel */
    #mainPanel{
      top:12px; left:12px;
      width:var(--panelW);
      max-height: calc(100vh - 24px);
    }
    #mainPanel .bd{max-height: calc(100vh - 24px - 44px)}
    .collapsed .bd{display:none}
    .collapsed{width:auto}
    .collapsed .ttl{display:none}

    /* route list */
    .list{
      border:1px solid var(--line);
      border-radius:12px;
      background: rgba(255,255,255,.6);
      padding:8px;
    }
    .item{
      display:flex;justify-content:space-between;align-items:center;gap:10px;
      background:#fff;border-radius:12px;padding:10px;margin:8px 0;border:1px solid rgba(0,0,0,.06);
    }
    .x{width:auto;padding:8px 10px;border-radius:10px;background:#ef4444;color:#fff;font-weight:900}

    /* compact top-right settings */
    #labelPanel{
      right:12px; top:12px;
      width:200px;
      max-height:none;
    }
    #labelPanel .bd{padding:10px 12px}
    #labelPanel .hd{padding:8px 10px}

    .miniRow{display:flex; align-items:center; gap:10px;}
    .miniRow label{
      margin:0;
      display:flex; align-items:center; gap:10px;
      font-size:12px; color:var(--muted);
    }
    .miniRow input[type="checkbox"]{ width:18px; height:18px; accent-color: var(--primary); }

    /* Legend mini */
    #legendMini{
      position:fixed;
      left:12px;
      bottom:12px;
      z-index:1;
      pointer-events:none;
      background: rgba(255,255,255,.72);
      border:1px solid rgba(0,0,0,.08);
      border-radius: 12px;
      padding:8px 10px;
      backdrop-filter: blur(8px);
      display:grid;
      grid-template-columns: 1fr 1fr;
      gap:6px 10px;
      font-size:11px;
      color: var(--txt);
    }
    #legendMini .lg{ display:flex; align-items:center; gap:6px; }
    .dot{ width:9px; height:9px; border-radius:50% }
    .dot.done{background:#2196F3}
    .dot.plan{background:#f59e0b}
    .dot.contract{background:#4CAF50}
    .dot.deposit{background:#ff9800}
    .dot.meet{background:#9c27b0}
    .dot.quote{background:#00bcd4}
    .dot.survey{background:#ff5722}
    .dot.other{background:#9ca3af}

    /* Memo modal */
    #memoModal{
      position:fixed; inset:0; z-index:9999;
      display:none;
      background: rgba(0,0,0,.55);
      backdrop-filter: blur(6px);
    }
    #memoCard{
      position:absolute; inset: 12px;
      background: rgba(255,255,255,.96);
      border:1px solid var(--line);
      border-radius: 18px;
      box-shadow: var(--shadow);
      display:flex; flex-direction:column;
      overflow:hidden;
    }
    #memoCard .mh{
      display:flex; align-items:center; justify-content:space-between;
      padding:12px; border-bottom:1px solid var(--line);
    }
    #memoTitle{font-weight:900;color:var(--txt)}
    #memoClose{
      width:auto; padding:8px 10px; border-radius:10px;
      background:#111827; color:#fff;
    }
    #memoBody{
      padding:12px;
      overflow:auto;
      white-space:pre-wrap;
      word-break:break-word;
      line-height:1.55;
      color: var(--txt);
      font-size:13px;
    }

    /* Center fixed popup modal */
    #centerPopup{
      position:fixed; inset:0; z-index:9998;
      display:none;
      background: rgba(0,0,0,.55);
      backdrop-filter: blur(6px);
    }
    #centerPopupCard{
      position:absolute;
      left:50%;
      top:50%;
      transform: translate(-50%,-50%);
      width: min(560px, calc(100vw - 24px));
      max-height: min(82vh, calc(100vh - 24px));
      background: rgba(255,255,255,.98);
      border:1px solid var(--line);
      border-radius: 18px;
      box-shadow: 0 14px 50px rgba(0,0,0,.30);
      overflow:hidden;
      display:flex;
      flex-direction:column;
    }
    #centerPopupClose{
      position:absolute;
      right:10px; top:10px;
      width:auto;
      padding:8px 10px;
      border-radius:10px;
      background: rgba(17,24,39,.92);
      color:#fff;
      border:none;
      font-weight:900;
      cursor:pointer;
      z-index:2;
    }

    /* ===== Scrollable popup inner (body scroll + sticky actions) ===== */
    #centerPopupContent{
      display:flex;
      flex-direction:column;
      min-height:0;
      height:100%;
    }
    .cp-head{
      padding:12px 12px;
      background: linear-gradient(135deg, rgba(37,99,235,.95), rgba(99,102,241,.95));
      color:#fff;
      flex:0 0 auto;
    }
    .cp-head .name{font-weight:900;font-size:14px}
    .cp-head .id{opacity:.9;font-size:12px;margin-top:2px}

    .cp-body{
      padding:12px;
      overflow:auto;
      background:#fff;
      color: var(--txt);
      font-size:13px;
      line-height:1.45;
      min-height:0;
      flex:1 1 auto;
      -webkit-overflow-scrolling: touch;
    }

    .cp-kv{
      display:grid;
      grid-template-columns: 128px 1fr;
      gap:6px 10px;
      align-items:start;
      margin:10px 0;
    }
    .cp-kv .k{
      font-size:12px;
      font-weight:900;
      color: rgba(17,24,39,.82);
      letter-spacing:.02em;
      line-height:1.2;
    }
    .cp-kv .v{
      color: var(--txt);
      line-height:1.45;
      word-break: break-word;
      white-space: pre-wrap; /* ★改行反映 */
    }

    .cp-actions{
      display:flex;gap:10px;flex-wrap:wrap;
      padding:12px;
      background: rgba(255,255,255,.90);
      border-top:1px solid rgba(0,0,0,.06);
      position: sticky;
      bottom: 0;
      z-index: 1;
      flex:0 0 auto;
      backdrop-filter: blur(10px);
    }

    /* Link button base */
    .a{
      flex:1; min-width: 140px;
      display:block;text-align:center;
      text-decoration:none;
      padding:10px 12px;border-radius:12px;
      font-weight:900;
      border:1px solid rgba(0,0,0,.08);
      background:#fff;
      color:var(--primary);
    }
    .a.primary{background: var(--primary); color:#fff; border:none}

    .cp-actions .a.primary{
      display:flex;
      align-items:center;
      justify-content:center;
      gap:10px;
      padding:12px 14px;
      border-radius:14px;
      background: linear-gradient(135deg, #2563eb, #6366f1);
      box-shadow: 0 10px 22px rgba(37,99,235,.28);
      transform: translateY(0);
    }
    .cp-actions .a.primary:active{
      transform: translateY(1px);
      box-shadow: 0 6px 14px rgba(37,99,235,.22);
    }

    .sep{
      margin:10px 0 6px;
      padding-top:10px;
      border-top:1px solid rgba(0,0,0,.08);
      font-size:12px;
      font-weight:900;
      color:#111827;
      letter-spacing:.06em;
    }

    /* Mobile layout */
    @media (max-width: 900px){
      #mainPanel{
        left:10px; right:10px; top:auto; bottom:10px;
        width:auto; max-height: 72vh;
      }
      #mainPanel .bd{max-height: calc(72vh - 44px)}
      #labelPanel{right:10px; top:10px; width:200px}
      #legendMini{ left:10px; top:10px; bottom:auto; }
    }
    @media (max-width: 430px){
      .topStat{ top:8px; }
      #mainPanel{ left:8px; right:8px; bottom:8px; max-height: 58vh; }
      #mainPanel .bd{max-height: calc(58vh - 44px)}
      #labelPanel{ right:8px; top:8px; width:190px; }
      #labelPanel .bd{ padding:8px 10px }
      #legendMini{ left:8px; top:8px; bottom:auto; padding:6px 8px; gap:5px 8px; font-size:10px; }
      .mapboxgl-ctrl-top-right{ top: 8px; right: 8px; }
      .cp-kv{ grid-template-columns: 1fr; }
      .cp-kv .k{ color: rgba(17,24,39,.75); }
    }

    /* GPS pulse overlay */
    @keyframes pulseRing {
      0%   { transform: scale(0.70); opacity: 0.70; }
      65%  { transform: scale(1.55); opacity: 0.18; }
      100% { transform: scale(1.85); opacity: 0.00; }
    }
    .gps-overlay{
      position:fixed;
      z-index:2;
      pointer-events:none;
      left:-9999px; top:-9999px;
    }
    .pulse-ring{
      position:absolute;
      width:72px;height:72px;
      border-radius:50%;
      border:3px solid rgba(37,99,235,0.70);
      background: rgba(37,99,235,0.14);
      transform-origin:center;
      animation: pulseRing 2.2s ease-out infinite;
      pointer-events:none;
      box-shadow: 0 0 22px rgba(37,99,235,0.35);
    }
    #gpsPulse::after{
      content:"";
      position:absolute;
      left:50%; top:50%;
      width:44px; height:44px;
      transform: translate(-50%,-50%);
      border-radius:50%;
      border:2px solid rgba(255,255,255,0.75);
      background: rgba(37,99,235,0.10);
      opacity: 0.65;
      filter: drop-shadow(0 0 10px rgba(37,99,235,0.35));
    }
  </style>
</head>

<body>
  <div id="map"></div>

  <div id="topStat" class="topStat" aria-live="polite">
    <span class="dot"></span>
    <span id="topStatText">-</span>
  </div>

  <div id="legendMini" aria-hidden="true">
    <div class="lg"><span class="dot done"></span>完了</div>
    <div class="lg"><span class="dot plan"></span>予定</div>
    <div class="lg"><span class="dot contract"></span>契約</div>
    <div class="lg"><span class="dot deposit"></span>半金</div>
    <div class="lg"><span class="dot meet"></span>商談</div>
    <div class="lg"><span class="dot quote"></span>見積</div>
    <div class="lg"><span class="dot survey"></span>現調</div>
    <div class="lg"><span class="dot other"></span>他</div>
  </div>

  <div id="gpsPulse" class="gps-overlay"><div class="pulse-ring"></div></div>

  <div id="centerPopup" role="dialog" aria-modal="true">
    <div id="centerPopupCard">
      <button id="centerPopupClose" type="button">×</button>
      <div id="centerPopupContent"></div>
    </div>
  </div>

  <div class="panel" id="mainPanel">
    <div class="hd">
      <div class="ttl">案件地図</div>
      <button class="tg" id="mainToggle">◀</button>
    </div>
    <div class="bd">
      <div class="row">
        <div class="col">
          <label>検索（表示範囲内）</label>
          <input id="search" placeholder="顧客名 / 住所 / 電話 / 管理番号 /（訪販：住所）">
          <div class="small">※検索は案件/訪販どちらにも効きます（訪販は住所部分一致）</div>
        </div>
      </div>

      <div class="row" style="align-items:center;gap:10px">
        <label style="display:flex;align-items:center;gap:10px;margin:0" class="col">
          <input type="checkbox" id="prospects-on" checked style="width:auto">
          訪販を表示
        </label>
      </div>

      <div class="sep">案件フィルター</div>

      <div class="row">
        <div class="col">
          <label>ステータス</label>
          <select id="status-filter">
            <option value="">すべて</option>
            <option value="現調日調整中">現調日調整中</option>
            <option value="現調予定">現調予定</option>
            <option value="見積作成中">見積作成中</option>
            <option value="商談予定">商談予定</option>
            <option value="工事予定">工事予定</option>
            <option value="半金予定">半金予定</option>
            <option value="工事完了">工事完了</option>
            <option value="契約完了">契約完了</option>
            <option value="キャンセル">キャンセル</option>
          </select>
        </div>
      </div>

      <div class="row" id="completion-year-row" style="display:none">
        <div class="col">
          <label>完工年度（工事完了のとき）</label>
          <select id="completion-year-filter">
            <option value="">すべて</option>
          </select>
        </div>
      </div>

      <div class="row">
        <div class="col">
          <label>チャネル</label>
          <select id="channel-filter">
            <option value="">すべて</option>
            <option value="テレアポ">テレアポ</option>
            <option value="アイドマ">アイドマ</option>
            <option value="オノデン">オノデン</option>
            <option value="コジマ">コジマ</option>
            <option value="直販">直販</option>
            <option value="紹介">紹介</option>
            <option value="追加">追加</option>
            <option value="アスレスHP">アスレスHP</option>
            <option value="RenoviaHP">RenoviaHP</option>
            <option value="コジマLP">コジマLP</option>
            <option value="雨漏りLP">雨漏りLP</option>
            <option value="比較ビズ">比較ビズ</option>
            <option value="ゼヒトモ">ゼヒトモ</option>
            <option value="タイナビ">タイナビ</option>
            <option value="エコエネ">エコエネ</option>
            <option value="リショップナビ">リショップナビ</option>
            <option value="GoogleLP">GoogleLP</option>
            <option value="シェアテク">シェアテク</option>
            <option value="リフォームパーク">リフォームパーク</option>
            <option value="ミツモア">ミツモア</option>
          </select>
        </div>
      </div>

      <div class="row">
        <div class="col">
          <label>担当（クローザー）</label>
          <select id="staff-filter"><option value="">すべて</option></select>
          <div class="small">※担当者候補はマスタ（在籍正社員）優先</div>
        </div>
      </div>

      <div class="row">
        <div class="col">
          <label>現調予定日 / 訪問予定日（MIX：当日〜1週間）</label>
          <select id="visit-date-filter"><option value="">すべて</option></select>
        </div>
      </div>

      <div class="sep">訪販フィルター</div>

      <div class="row">
        <div class="col">
          <label>状態</label>
          <select id="prospect-status-filter">
            <option value="">すべて</option>
            <option value="excluded">対象外</option>
            <option value="posting">ポスティング済</option>
            <option value="approach">対面済</option>
            <option value="ordered">受注済</option>
          </select>
          <div class="small">※訪販は8000件想定のため常にクラスタ表示</div>
        </div>
      </div>

      <div class="row">
        <div class="col">
          <label>配信年月</label>
          <select id="prospect-dist-filter">
            <option value="">すべて</option>
            <option value="1w">直近1週間</option>
            <option value="3m">直近3ヶ月</option>
            <option value="6m">直近半年</option>
            <option value="1y">直近1年</option>
            <option value="past">過去（1年より前）</option>
          </select>
          <div class="small">※「直近1週間」は is_recent_1w=1 で絞り込みます</div>
        </div>
      </div>

      <div class="row">
        <div class="col">
          <label>担当者（訪販）</label>
          <select id="prospect-staff-filter">
            <option value="">すべて</option>
          </select>
          <div class="small">※担当者候補はマスタ（在籍正社員）優先</div>
        </div>
      </div>

      <div class="row" id="clusterRow" style="align-items:center;gap:10px;display:none">
        <label style="display:flex;align-items:center;gap:10px;margin:0" class="col">
          <input type="checkbox" id="cluster" checked style="width:auto">
          クラスター表示（案件）
        </label>
        <span class="badge" id="stat">-</span>
      </div>

      <div class="row" style="align-items:center;gap:10px;margin-top:-2px">
        <span class="badge" id="stat2">-</span>
      </div>

      <div class="row">
        <button id="routeMode" class="btn-secondary">ルート作成モード</button>
      </div>

      <div id="routeBox" style="display:none">
        <div class="small" style="margin-top:6px">地図上の点をタップして追加/解除（推奨7件）</div>
        <div class="list" id="routeList"></div>
        <div class="row">
          <button id="showRoute" class="btn-primary">ルート表示</button>
        </div>
        <div class="row">
          <button id="clearRoute" class="btn-secondary">ルート線を消す</button>
        </div>
      </div>

      <div class="row">
        <button id="reset" class="btn-secondary">リセット</button>
      </div>
    </div>
  </div>

  <div class="panel" id="labelPanel">
    <div class="hd">
      <div class="ttl">表示</div>
    </div>
    <div class="bd">
      <div class="row" style="margin-top:6px">
        <div class="col">
          <div class="miniRow">
            <label>
              <input type="checkbox" id="label-on">
              ピン横情報
            </label>
          </div>
          <div class="small">ID/契約者名＋担当＋直近予定</div>
        </div>
      </div>

      <div class="row" style="margin-top:10px">
        <div class="col">
          <div class="miniRow">
            <label>
              <input type="checkbox" id="gps-on">
              GPS
            </label>
            <span class="small" id="gpsStat" style="margin-left:auto;color:var(--muted)">OFF</span>
          </div>
          <div class="small">追従なし（矢印＋点滅表示）</div>
        </div>
      </div>
    </div>
  </div>

  <div id="memoModal" role="dialog" aria-modal="true">
    <div id="memoCard">
      <div class="mh">
        <div id="memoTitle">備考</div>
        <button id="memoClose">閉じる</button>
      </div>
      <div id="memoBody"></div>
    </div>
  </div>

<script>
(async () => {
  const WORKER_BASE_URL = "https://fm-map-api.backoffice-2d5.workers.dev";

  // tileset
  const TILESET_URL = "mapbox://renovia.1hjvigj3";
  const TILESET_SOURCE_LAYER = "MAP-2bnbeh";
  const TILESET_ID_PROP = "id";

  // base opacity control
  const BASE_OPACITY = { NO_FILTER: 0.85, FILTERED: 0.06 };

  // fixed completion year
  const COMPLETION_YEAR_START = 2018;

  // auto rules
  const AUTO = { LABEL_OFF_OVER: 800, CLUSTER_FORCE_OVER: 1200 };

  // prospects tuning (8000想定)
  const PROSPECTS = { CLUSTER_RADIUS: 62, CLUSTER_MAX_ZOOM: 15 };

  // colors
  const PROSPECT_TODO_COLOR = "#ef4444";     // 未実施（fallback）
  const PROSPECT_EXCLUDED_COLOR = "#334155"; // 対象外

  // ===== 爆目立ち（直近1週間） =====
  // 白太リング + ネオン（黄色→水色）グロー
  const RECENT_RING_COLOR = "rgba(255,255,255,0.98)";
  const RECENT_GLOW_COLOR = "rgba(255, 230, 0, 0.35)"; // イエロー
  const RECENT_GLOW2_COLOR = "rgba(0, 255, 255, 0.22)"; // シアン

  function getAuthTokenFromUrl() {
    const u = new URL(location.href);
    const uid = u.searchParams.get("uid") || "";
    const exp = u.searchParams.get("exp") || "";
    const nonce = u.searchParams.get("nonce") || "";
    const sig = u.searchParams.get("sig") || "";
    if (!uid || !exp || !nonce || !sig) return "";
    return `uid=${uid}&exp=${exp}&nonce=${nonce}&sig=${sig}`;
  }
  const AUTH_TOKEN = getAuthTokenFromUrl();
  if (!AUTH_TOKEN) throw new Error("Missing auth token");
  const headers = { "Authorization": "Bearer " + AUTH_TOKEN };

  // ===== Expiry banner (always show until + remaining) =====
  const authParams = new URLSearchParams(AUTH_TOKEN);
  const AUTH_EXP_SEC = Number(authParams.get("exp") || "0");
  const AUTH_UID = authParams.get("uid") || "";

  function two(n){ return String(n).padStart(2,"0"); }
  function formatJstHmFromUnixSec(sec){
    if (!Number.isFinite(sec) || sec <= 0) return "";
    const dt = new Date(sec * 1000);
    const jst = new Date(dt.getTime() + 9*60*60*1000);
    return `${two(jst.getUTCHours())}:${two(jst.getUTCMinutes())}`;
  }
  function remainingSec(){
    if (!Number.isFinite(AUTH_EXP_SEC) || AUTH_EXP_SEC <= 0) return null;
    return AUTH_EXP_SEC - Math.floor(Date.now()/1000);
  }
  function humanRemain(remSec){
    if (remSec == null) return "";
    const s = Math.max(0, remSec);
    const h = Math.floor(s / 3600);
    const m = Math.floor((s % 3600) / 60);
    if (h > 0) return `${h}時間${m}分`;
    return `${m}分`;
  }

  function setStat(text, mode="ok"){
    const bar = document.getElementById("topStat");
    const txt = document.getElementById("topStatText");
    if (txt) txt.textContent = text;

    if (bar){
      bar.classList.remove("is-loading","is-ok","is-warn","is-error");
      if (mode === "loading") bar.classList.add("is-loading");
      else if (mode === "error") bar.classList.add("is-error");
      else if (mode === "warn") bar.classList.add("is-warn");
      else bar.classList.add("is-ok");
    }

    const s1 = document.getElementById("stat");
    const s2 = document.getElementById("stat2");
    if (s1) s1.textContent = text;
    if (s2) s2.textContent = text;
  }

  let baseStatText = "検索してください（範囲内検索）";
  let baseStatMode = "warn";
  let expiredLocked = false;

  function setBaseStat(text, mode){
    baseStatText = text;
    baseStatMode = mode || "ok";
    if (!expiredLocked) renderStat();
  }

  function renderStat(){
    const until = formatJstHmFromUnixSec(AUTH_EXP_SEC);
    const rem = remainingSec();

    if (rem != null && rem <= 0){
      expiredLocked = true;
      setStat(`期限切れ：FileMakerからもう一度開いてください（uid:${AUTH_UID} / 有効期限:${until}）`, "error");
      return;
    }

    const warn = (rem != null && rem <= 5*60);
    const expLabel = (until && rem != null)
      ? `｜有効期限:${until}（残り${humanRemain(rem)}）`
      : (until ? `｜有効期限:${until}` : "");

    if (warn){
      setStat(`${baseStatText}${expLabel}｜まもなく期限切れ`, "warn");
    } else {
      setStat(`${baseStatText}${expLabel}`, baseStatMode);
    }
  }
  setInterval(renderStat, 10 * 1000);
  renderStat();

  function isExpiredNow(){
    const rem = remainingSec();
    return (rem != null && rem <= 0);
  }

  async function fetchJsonGuard(url, opt){
    if (isExpiredNow()){
      renderStat();
      throw new Error("AUTH_EXPIRED");
    }
    const r = await fetch(url, opt);
    const txt = await r.text();
    if (!r.ok){
      if (txt.includes("Token expired") || txt.includes("Missing auth token") || txt.includes("Invalid signature")){
        expiredLocked = true;
        renderStat();
        throw new Error("AUTH_EXPIRED");
      }
      throw new Error(`HTTP ${r.status}: ${txt}`);
    }
    return JSON.parse(txt);
  }

  const conf = await fetchJsonGuard(`${WORKER_BASE_URL}/config`, { headers });
  mapboxgl.accessToken = conf.mapboxToken;

  const map = new mapboxgl.Map({
    container: "map",
    style: "mapbox://styles/mapbox/streets-v12",
    center: [138.252924, 36.204824],
    zoom: 5
  });
  map.addControl(new mapboxgl.NavigationControl(), "top-right");

  // state
  let routeMode = false;
  const selected = [];
  const selectedSet = new Set();

  // projects state
  let lastItems = [];
  let loadTimer = null;
  let loadAbort = null;
  let lastKey = "";

  // prospects state
  let lastProspects = [];
  let prospectsTimer = null;
  let prospectsAbort = null;
  let lastProspectsKey = "";

  // staff master
  let staffMasterLoaded = false;

  // memo modal
  const memoModal = document.getElementById("memoModal");
  const memoTitle = document.getElementById("memoTitle");
  const memoBody  = document.getElementById("memoBody");
  document.getElementById("memoClose").onclick = () => memoModal.style.display = "none";
  memoModal.addEventListener("click", (e) => { if (e.target === memoModal) memoModal.style.display = "none"; });

  // center popup
  const centerPopup = document.getElementById("centerPopup");
  const centerPopupContent = document.getElementById("centerPopupContent");
  const centerPopupClose = document.getElementById("centerPopupClose");
  function closeCenterPopup(){
    centerPopup.style.display = "none";
    centerPopupContent.innerHTML = "";
  }
  centerPopupClose.onclick = closeCenterPopup;
  centerPopup.addEventListener("click", (e) => { if (e.target === centerPopup) closeCenterPopup(); });

  document.addEventListener("keydown", (e) => {
    if (e.key === "Escape") {
      memoModal.style.display = "none";
      closeCenterPopup();
    }
  });

  function openMemo(title, text){
    memoTitle.textContent = title;
    const s = (text ?? "").toString().replace(/\r\n/g, "\n").replace(/\r/g, "\n").trim();
    memoBody.textContent = s || "（空）";
    memoModal.style.display = "block";
    memoBody.scrollTop = 0;
  }

  window.__LAST_MEMO__ = { apo:"", closing:"", construction:"" };
  window.openMemoFromPopup = (kind) => {
    const m = window.__LAST_MEMO__ || {};
    if (kind === "apo") openMemo("アポ情報", m.apo);
    if (kind === "closing") openMemo("クローザー備考", m.closing);
    if (kind === "construction") openMemo("工事備考", m.construction);
  };

  // helpers
  function escapeHtml(s){
    return (s ?? "").toString()
      .replaceAll("&","&amp;").replaceAll("<","&lt;")
      .replaceAll(">","&gt;")
      .replaceAll('"',"&quot;")
      .replaceAll("'","&#039;");
  }
  function normStr(s){ return (s ?? "").toString().trim(); }
  function lower(s){ return normStr(s).toLowerCase(); }
  function normDigits(s){ return normStr(s).replace(/[^\d]/g, ""); }
  function normNewlines(s){
    return (s ?? "").toString().replace(/\r\n/g, "\n").replace(/\r/g, "\n").trim();
  }

  function statusColor(status){
    switch(status){
      case "工事完了": return "#2196F3";
      case "工事予定": return "#f59e0b";
      case "契約完了": return "#4CAF50";
      case "半金予定": return "#ff9800";
      case "商談予定": return "#9c27b0";
      case "見積作成中": return "#00bcd4";
      case "現調予定": return "#ff5722";
      case "現調日調整中": return "#e11d48";
      case "キャンセル": return "#6b7280";
      default: return "#9ca3af";
    }
  }

  function bboxStrRounded6() {
    const b = map.getBounds();
    const r6 = (n)=> Math.round(n*1e6)/1e6;
    return `${r6(b.getWest())},${r6(b.getSouth())},${r6(b.getEast())},${r6(b.getNorth())}`;
  }

  // MDY helpers
  function normalizeMDY(s){
    s = (s ?? "").toString().trim();
    if (!s) return "";
    let m = s.match(/^(\d{1,2})\/(\d{1,2})\/(\d{4})$/);
    if (m) return `${String(m[1]).padStart(2,"0")}/${String(m[2]).padStart(2,"0")}/${m[3]}`;
    m = s.match(/^(\d{4})\/(\d{1,2})\/(\d{1,2})$/);
    if (m) return `${String(m[2]).padStart(2,"0")}/${String(m[3]).padStart(2,"0")}/${m[1]}`;
    m = s.match(/^(\d{4})-(\d{1,2})-(\d{1,2})$/);
    if (m) return `${String(m[2]).padStart(2,"0")}/${String(m[3]).padStart(2,"0")}/${m[1]}`;
    return "";
  }
  function mdyToNum(mdy){
    const s = normalizeMDY(mdy);
    const m = s.match(/^(\d{2})\/(\d{2})\/(\d{4})$/);
    if (!m) return Infinity;
    return Number(`${m[3]}${m[1]}${m[2]}`);
  }
  function todayNumJST(){
    const now = new Date();
    const jst = new Date(now.getTime() + 9*60*60*1000);
    const y = jst.getUTCFullYear();
    const m = String(jst.getUTCMonth()+1).padStart(2,"0");
    const d = String(jst.getUTCDate()).padStart(2,"0");
    return Number(`${y}${m}${d}`);
  }
  function todayMdyJSTPlus(days){
    const dt = new Date();
    dt.setDate(dt.getDate() + days);
    const jst = new Date(dt.getTime() + 9*60*60*1000);
    const y = jst.getUTCFullYear();
    const m = String(jst.getUTCMonth()+1).padStart(2,"0");
    const d = String(jst.getUTCDate()).padStart(2,"0");
    return `${m}/${d}/${y}`;
  }

  function presetVisitDateOptions(defaultDaysFromToday = null){
    const sel = document.getElementById("visit-date-filter");
    const cur = sel.value;

    sel.innerHTML = `<option value="">すべて</option>`;
    for (let i = 0; i <= 7; i++){
      const v = todayMdyJSTPlus(i);
      const o = document.createElement("option");
      o.value = v;
      o.textContent = v;
      sel.appendChild(o);
    }

    if (cur && [...sel.options].some(o => o.value === cur)) sel.value = cur;
    else if (defaultDaysFromToday != null) sel.value = todayMdyJSTPlus(defaultDaysFromToday);
    else sel.value = "";
  }

  function presetCompletionYears(defaultYear = ""){
    const sel = document.getElementById("completion-year-filter");
    const cur = sel.value;
    const now = new Date();
    const jst = new Date(now.getTime() + 9*60*60*1000);
    const thisYear = jst.getUTCFullYear();

    sel.innerHTML = `<option value="">すべて</option>`;
    for (let y = thisYear; y >= COMPLETION_YEAR_START; y--){
      const o = document.createElement("option");
      o.value = String(y);
      o.textContent = `${y}年`;
      sel.appendChild(o);
    }

    if (cur && [...sel.options].some(o => o.value === cur)) sel.value = cur;
    else sel.value = defaultYear || "";
  }

  function formatTimeRange(t1, t2){
    const a = normStr(t1), b = normStr(t2);
    if (a && b) return `${a}〜${b}`;
    return a || b || "";
  }
  function mmddFromMdy(mdy){
    const s = normalizeMDY(mdy);
    if (!s) return "";
    return s.slice(0,5);
  }

  function buildAllLabel(p){
    const id = normStr(p.id);
    const name = normStr(p.customer_name);
    const staff = normStr(p.staff);

    const today = todayNumJST();
    const vNum = mdyToNum(p.visit_date);
    const cNum = mdyToNum(p.cvisit_date);

    const cand = [];
    if (vNum >= today) cand.push({ num:vNum, date:p.visit_date, t:formatTimeRange(p.visit_time1,p.visit_time2) });
    if (cNum >= today) cand.push({ num:cNum, date:p.cvisit_date, t:formatTimeRange(p.cvisit_time1,p.cvisit_time2) });

    cand.sort((a,b)=> a.num-b.num);
    const best = cand[0];

    const near = best ? `${mmddFromMdy(best.date)}${best.t ? " " + best.t : ""}` : "";
    const line1 = [id, name].filter(Boolean).join("　");
    const line2 = [ staff ? `担当：${staff}` : "担当：-", near || "-" ].join("　");
    return `${line1}\n${line2}`;
  }

  function toGeoJSON(items) {
    return {
      type: "FeatureCollection",
      features: items.map(p => ({
        type: "Feature",
        geometry: { type: "Point", coordinates: [p.lng, p.lat] },
        properties: {
          id: String(p.id ?? ""),
          customer_name: p.customer_name ?? "",
          status: p.status ?? "",
          channel: p.channel ?? "",
          staff: p.staff ?? "",
          visit_date: p.visit_date ?? "",
          visit_time1: p.visit_time1 ?? "",
          visit_time2: p.visit_time2 ?? "",
          cvisit_date: p.cvisit_date ?? "",
          cvisit_time1: p.cvisit_time1 ?? "",
          cvisit_time2: p.cvisit_time2 ?? "",
          end_date: p.end_date ?? "",
          label_all: buildAllLabel(p)
        }
      }))
    };
  }

  function prospectsToGeoJSON(items){
    return {
      type:"FeatureCollection",
      features: items.map(p => ({
        type:"Feature",
        geometry:{ type:"Point", coordinates:[p.lng, p.lat] },
        properties:{
          record_id: String(p.record_id ?? ""),
          status_code: p.status_code ?? "",

          // ★直近1週間フラグ（FM計算フィールド）
          is_recent_1w: Number(p.is_recent_1w || 0),

          // backward compat
          is_posted: Number(p.is_posted || 0),
          is_approached: Number(p.is_approached || 0),
          is_ordered: Number(p.is_ordered || 0),
          is_todo: Number(p.is_todo || 0),
          is_excluded: Number(p.is_excluded || 0)
        }
      }))
    };
  }

  function updateCompletionYearVisibility(){
    const st = document.getElementById("status-filter").value;
    const row = document.getElementById("completion-year-row");
    const yearSel = document.getElementById("completion-year-filter");
    const on = (st === "工事完了");
    row.style.display = on ? "block" : "none";
    if (!on) yearSel.value = "";
  }

  // ★マスタ優先：検索結果でstaff候補を上書きしない
  function rebuildFilterOptions(_items){ return; }

  function filterItems(items){
    const q = lower(document.getElementById("search").value);
    const st = document.getElementById("status-filter").value;
    const ch = document.getElementById("channel-filter").value;
    const sf = document.getElementById("staff-filter").value;
    const vd = document.getElementById("visit-date-filter").value;
    const y  = document.getElementById("completion-year-filter").value;
    const qDigits = normDigits(q);

    return items.filter(p=>{
      if (st && p.status !== st) return false;
      if (ch && p.channel !== ch) return false;
      if (sf && p.staff !== sf) return false;

      if (vd) {
        if (normalizeMDY(p.visit_date) !== vd && normalizeMDY(p.cvisit_date) !== vd) return false;
      }

      if (st === "工事完了" && y) {
        const ed = normalizeMDY(p.end_date);
        const m = ed.match(/^(\d{2})\/(\d{2})\/(\d{4})$/);
        if (!m || m[3] !== y) return false;
      }

      if (q) {
        const idHit   = String(p.id ?? "").includes(q);
        const nameHit = lower(p.customer_name).includes(q);
        const phoneHit = (qDigits && false);
        if (!idHit && !nameHit && !phoneHit) return false;
      }

      return true;
    });
  }

  function setClusterEnabled(on) {
    document.getElementById("cluster").checked = on;
    map.setLayoutProperty("clusters", "visibility", on ? "visible" : "none");
    map.setLayoutProperty("cluster-count", "visibility", on ? "visible" : "none");
  }

  function updateClusterUiVisibility() {
    const vd = document.getElementById("visit-date-filter").value;
    const row = document.getElementById("clusterRow");
    row.style.display = vd ? "flex" : "none";
  }

  function applyLabel(on){
    map.setLayoutProperty("point-labels", "visibility", on ? "visible" : "none");
  }

  function applyAutoVisibilityRules(hitCount){
    const labelChk = document.getElementById("label-on");
    const clusterChk = document.getElementById("cluster");

    if (hitCount >= AUTO.CLUSTER_FORCE_OVER) {
      if (!clusterChk.checked) clusterChk.checked = true;
      setClusterEnabled(true);
    }

    if (hitCount >= AUTO.LABEL_OFF_OVER) {
      if (labelChk.checked) labelChk.checked = false;
      applyLabel(false);
    } else {
      applyLabel(labelChk.checked);
    }

    if (map.getLayer("points-halo")) {
      const op = (hitCount >= AUTO.CLUSTER_FORCE_OVER) ? 0.45 : 0.90;
      map.setPaintProperty("points-halo", "circle-opacity", op);
    }
  }

  function prospectsEnabled(){
    return document.getElementById("prospects-on").checked;
  }

  function hasAnyProjectCondition(){
    const q  = document.getElementById("search").value.trim();
    const st = document.getElementById("status-filter").value;
    const ch = document.getElementById("channel-filter").value;
    const sf = document.getElementById("staff-filter").value;
    const vd = document.getElementById("visit-date-filter").value;
    const y  = document.getElementById("completion-year-filter").value;
    return !!(q || st || ch || sf || vd || y);
  }

  function hasAnyProspectCondition(){
    const q = document.getElementById("search").value.trim();
    const ps = document.getElementById("prospect-status-filter").value;
    const dist = document.getElementById("prospect-dist-filter").value;
    const staff = document.getElementById("prospect-staff-filter").value;
    return !!(q || ps || dist || staff);
  }

  function applyBaseOpacity(){
    const shouldFadeBase =
      hasAnyProjectCondition() ||
      (prospectsEnabled() && hasAnyProspectCondition()) ||
      (prospectsEnabled() && document.getElementById("prospects-on").checked);

    const op = shouldFadeBase ? BASE_OPACITY.FILTERED : BASE_OPACITY.NO_FILTER;
    if (map.getLayer("base-points")) {
      map.setPaintProperty("base-points", "circle-opacity", op);
    }
  }

  function applyProspectVisibility(){
    const show = prospectsEnabled();
    const vis = show ? "visible" : "none";
    ["p-clusters","p-cluster-count","p-points-halo","p-points","p-recent-glow2","p-recent-glow","p-recent-ring"].forEach(id=>{
      if (map.getLayer(id)) map.setLayoutProperty(id, "visibility", vis);
    });
    applyBaseOpacity();
  }

  function clearProjectHits(){
    lastItems = [];
    const src = map.getSource("projects");
    if (src) src.setData({ type:"FeatureCollection", features: [] });
  }
  function clearProspects(){
    lastProspects = [];
    const src = map.getSource("prospects");
    if (src) src.setData({ type:"FeatureCollection", features: [] });
  }

  function clearAll(){
    clearProjectHits();
    clearProspects();
    setBaseStat("検索してください（範囲内検索）", "warn");
    applyBaseOpacity();
  }

  function scheduleLoadProjects(delay=250){
    if (loadTimer) clearTimeout(loadTimer);
    loadTimer = setTimeout(() => loadProjects(), delay);
  }
  function scheduleLoadProspects(delay=250){
    if (prospectsTimer) clearTimeout(prospectsTimer);
    prospectsTimer = setTimeout(() => loadProspects(), delay);
  }

  function kv(label, value){
    const v = normStr(value);
    if (!v) return "";
    return `<div class="cp-kv"><div class="k">${escapeHtml(label)}</div><div class="v">${escapeHtml(normNewlines(v))}</div></div>`;
  }

  async function loadStaffMasterOnce(){
    if (staffMasterLoaded) return;
    staffMasterLoaded = true;

    try {
      const data = await fetchJsonGuard(`${WORKER_BASE_URL}/staff_list`, { headers });
      const names = (data.items || []).map(x => normStr(x?.name)).filter(Boolean);

      const staffSel = document.getElementById("staff-filter");
      const pStaffSel = document.getElementById("prospect-staff-filter");

      const cur1 = staffSel.value;
      const cur2 = pStaffSel.value;

      staffSel.innerHTML = `<option value="">すべて</option>`;
      pStaffSel.innerHTML = `<option value="">すべて</option>`;

      for (const n of names){
        const o1 = document.createElement("option");
        o1.value = n; o1.textContent = n;
        staffSel.appendChild(o1);

        const o2 = document.createElement("option");
        o2.value = n; o2.textContent = n;
        pStaffSel.appendChild(o2);
      }

      if (cur1 && [...staffSel.options].some(o => o.value === cur1)) staffSel.value = cur1;
      if (cur2 && [...pStaffSel.options].some(o => o.value === cur2)) pStaffSel.value = cur2;

    } catch (e) {
      console.error("staff master load failed", e);
    }
  }

  async function showProjectPopupById(id){
    setBaseStat("詳細取得中…", "loading");
    const data = await fetchJsonGuard(`${WORKER_BASE_URL}/project?id=${encodeURIComponent(String(id))}`, { headers });
    const p = data.item;

    window.__LAST_MEMO__ = {
      apo: p.apo_memo || "",
      closing: p.closing_memo || "",
      construction: p.construction_memo || ""
    };

    const visitLine = (p.visit_date ? `${p.visit_date} ${[p.visit_time1,p.visit_time2].filter(Boolean).join("〜")}` : "");
    const cvisitLine = (p.cvisit_date ? `${p.cvisit_date} ${[p.cvisit_time1,p.cvisit_time2].filter(Boolean).join("〜")}` : "");
    const amount = (p.amount !== "" && p.amount != null && String(p.amount).trim() !== "")
      ? `¥${Number(p.amount).toLocaleString()}`
      : "";

    const fmpUrl =
      `fmp://app.nexus-fms.com/ASLESx?script=${encodeURIComponent("MAP連動")}` +
      `&param=${encodeURIComponent(String(p.id || ""))}`;

    const bodyHtml =
      kv("ステータス", p.status || "-") +
      kv("住所", p.address || "-") +
      kv("電話", `${p.phone || "-"} / ${p.mobile || "-"}`) +
      kv("クローザー / チャネル", `${p.staff || "-"} / ${p.channel || "-"}`) +
      (cvisitLine ? kv("現調予定", cvisitLine) : "") +
      (visitLine ? kv("訪問予定", visitLine) : "") +
      kv("着工 / 完工予定 / 完工日", `${p.start_date || "-"} / ${p.s_end_date || "-"} / ${p.end_date || "-"}`) +
      (amount ? kv("適用金額", amount) : "");

    const html = `
      <div class="cp-head">
        <div class="name">${escapeHtml(p.customer_name || "")}</div>
        <div class="id">ID: ${escapeHtml(String(p.id || ""))}</div>
      </div>
      <div class="cp-body">
        ${bodyHtml || `<div class="small">（データなし）</div>`}
        <div class="row" style="display:flex;gap:10px;flex-wrap:wrap;margin-top:12px">
          <button class="btn-secondary" style="flex:1;min-width:140px" onclick="window.openMemoFromPopup('apo')">アポ情報</button>
          <button class="btn-secondary" style="flex:1;min-width:140px" onclick="window.openMemoFromPopup('closing')">クローザー備考</button>
          <button class="btn-secondary" style="flex:1;min-width:140px" onclick="window.openMemoFromPopup('construction')">工事備考</button>
        </div>
      </div>
      <div class="cp-actions">
        <a class="a primary" href="${fmpUrl}">FileMakerを開く</a>
      </div>
    `;

    centerPopupContent.innerHTML = html;
    centerPopup.style.display = "block";
    setBaseStat("詳細表示中", "ok");
  }

  async function submitProspectReport(recordId){
    const status = document.getElementById("reportStatus").value;
    const memo = document.getElementById("reportMemo").value || "";

    if (!status) {
      alert("ステータスを選択してください");
      return;
    }

    const btn = document.getElementById("reportSubmit");
    btn.disabled = true;
    btn.textContent = "送信中…";

    try {
      setBaseStat("報告送信中…", "loading");

      await fetchJsonGuard(`${WORKER_BASE_URL}/prospect_report`, {
        method: "POST",
        headers: { ...headers, "Content-Type": "application/json" },
        body: JSON.stringify({
          record_id: String(recordId),
          status,
          memo
        })
      });

      // 再検索して反映（B方式）
      lastProspectsKey = "";
      await loadProspects();

      setBaseStat("報告しました（通知送信）", "ok");
      btn.textContent = "報告済み";
      setTimeout(() => { btn.textContent = "報告する"; btn.disabled = false; }, 1200);

    } catch (e) {
      if (String(e.message || "") === "AUTH_EXPIRED") return;
      console.error("submitProspectReport failed", e);
      alert("報告に失敗しました（通信/権限/期限切れ）");
      setBaseStat("報告失敗", "error");
      btn.textContent = "報告する";
      btn.disabled = false;
    }
  }

  async function showProspectPopupById(recordId){
    setBaseStat("詳細取得中…", "loading");
    const data = await fetchJsonGuard(`${WORKER_BASE_URL}/prospect?id=${encodeURIComponent(String(recordId))}`, { headers });
    const p = data.item || {};
    const rid = String(p.record_id || recordId);

    const name = normStr(p["お名前"]) || "（名称なし）";
    const headId = `record_id: ${rid}${p["t_担当者"] ? `　/　担当: ${p["t_担当者"]}` : ""}`;

    // ★フル表示（前の設定）
    const bodyHtml =
      kv("フリガナ", p["フリガナ"]) +
      kv("年齢", p["年齢"]) +
      kv("電話番号", p["電話番号"]) +
      kv("メールアドレス", p["メールアドレス"]) +
      kv("住所", p["tc_連結住所"]) +

      kv("お申込者", p["お申込者"]) +
      kv("設置場所", p["設置場所"]) +
      kv("お見積もり方法", p["お見積もり方法"]) +
      kv("お見積もり状況", p["お見積もり状況"]) +

      kv("太陽光パネルは設置されていますか？", p["太陽光パネルは設置されていますか？"]) +
      kv("導入検討時期", p["導入検討時期"]) +
      kv("導入目的", p["導入目的"]) +
      kv("設置会社を選ぶポイント", p["設置会社を選ぶポイント"]) +
      kv("あわせて見積もりを取りたい商品", p["あわせて見積もりを取りたい商品"]) +
      kv("建物の所有区分", p["建物の所有区分"]) +

      kv("お問合せ内容", p["お問合せ内容"]) +
      kv("訪問備考", p["t_訪問備考"]) +

      kv("配信日時", p["d_配信日時"]) +
      kv("チラシ投函日", p["d_チラシ投函日"]) +
      kv("対面アプローチ日", p["d_対面アプローチ日"]) +
      kv("受注日", p["d_受注日"]) +
      kv("対象外確定日", p["d_対象外確定日"]);

    const reportUi = `
      <div class="sep">報告</div>
      <div class="row">
        <div class="col">
          <label>ステータス</label>
          <select id="reportStatus">
            <option value="">選択してください</option>
            <option value="posting">ポスティング済</option>
            <option value="approach">対面済</option>
            <option value="ordered">受注済</option>
            <option value="excluded">対象外</option>
          </select>
        </div>
      </div>
      <div class="row">
        <div class="col">
          <label>備考</label>
          <textarea id="reportMemo" placeholder="内容（任意）"></textarea>
          <div class="small">※担当者はログインUID→アカウント管理(t_ID)から自動設定（見つからない場合は更新スキップ）</div>
        </div>
      </div>
      <div class="row">
        <button id="reportSubmit" class="btn-primary" type="button">報告する</button>
      </div>
    `;

    const html = `
      <div class="cp-head">
        <div class="name">${escapeHtml(name)}</div>
        <div class="id">${escapeHtml(headId)}</div>
      </div>
      <div class="cp-body">
        ${bodyHtml || `<div class="small">（データなし）</div>`}
        ${reportUi}
      </div>
      <div class="cp-actions">
        <a class="a" href="#" onclick="return false;">更新後は自動で通知されます</a>
      </div>
    `;

    centerPopupContent.innerHTML = html;
    centerPopup.style.display = "block";
    document.getElementById("reportSubmit").onclick = () => submitProspectReport(rid);

    setBaseStat("詳細表示中", "ok");
  }

  async function loadProjects() {
    applyBaseOpacity();

    if (!hasAnyProjectCondition()){
      clearProjectHits();
      setBaseStat("検索してください（範囲内検索）", "warn");
      return;
    }

    if (loadAbort) loadAbort.abort();
    loadAbort = new AbortController();

    const bbox = bboxStrRounded6();
    const status  = document.getElementById("status-filter").value;
    const channel = document.getElementById("channel-filter").value;
    const staff   = document.getElementById("staff-filter").value;
    const date    = document.getElementById("visit-date-filter").value;
    const year    = document.getElementById("completion-year-filter").value;
    const q       = document.getElementById("search").value.trim();

    const key = ["P",bbox,status,channel,staff,date,year,q].join("|");
    if (key === lastKey) return;
    lastKey = key;

    const params = new URLSearchParams();
    params.set("bbox", bbox);
    if (status)  params.set("status", status);
    if (channel) params.set("channel", channel);
    if (staff)   params.set("staff", staff);
    if (date)    params.set("date", date);
    if (year)    params.set("year", year);
    if (q)       params.set("q", q);

    const apiUrl = `${WORKER_BASE_URL}/projects_search?${params.toString()}`;

    try {
      setBaseStat("検索中…", "loading");
      const data = await fetchJsonGuard(apiUrl, { headers, signal: loadAbort.signal });

      lastItems = (data.items || []).map(p => ({
        ...p,
        id: String(p.id ?? ""),
        lat: Number(p.lat),
        lng: Number(p.lng)
      })).filter(p => Number.isFinite(p.lat) && Number.isFinite(p.lng));

      rebuildFilterOptions(lastItems);
      updateCompletionYearVisibility();

      const filtered = filterItems(lastItems);
      const src = map.getSource("projects");
      if (src) src.setData(toGeoJSON(filtered));

      setBaseStat(`表示: 案件 ${filtered.length}件${prospectsEnabled() ? ` / 訪販 ${lastProspects.length}件` : ""}`, "ok");
      updateClusterUiVisibility();
      applyAutoVisibilityRules(filtered.length);
      applyBaseOpacity();

    } catch (e) {
      if (e && (e.name === "AbortError" || String(e.message || "").includes("aborted"))) return;
      if (String(e.message || "") === "AUTH_EXPIRED") return;
      console.error("loadProjects failed", e, apiUrl);
      setBaseStat("通信エラー（案件）", "error");
    }
  }

  async function loadProspects(){
    if (!prospectsEnabled()){
      clearProspects();
      applyProspectVisibility();
      return;
    }

    if (prospectsAbort) prospectsAbort.abort();
    prospectsAbort = new AbortController();

    const bbox = bboxStrRounded6();
    const q = document.getElementById("search").value.trim();

    const ps = document.getElementById("prospect-status-filter").value;
    const dist = document.getElementById("prospect-dist-filter").value; // ★ 1w 追加
    const staff = document.getElementById("prospect-staff-filter").value;

    // 運用安全：訪販ONで完全無条件は止める
    if (!q && !ps && !dist && !staff) {
      clearProspects();
      setBaseStat("（訪販）配信年月などで絞ってください", "warn");
      applyProspectVisibility();
      return;
    }

    // ★ dist=1w の場合は「直近3ヶ月で取得してからフロントで絞る」でも良いが、
    // 今回はHTML完結を優先して、取得はそのまま（distは送らない）
    // ただし無条件取得は重いので「1w」選択時は dist を送らない代わりに、
    // 「q か staff か status が必須」になる可能性がある点に注意。
    // → 現実運用として、1w選択時も dist=3m を送って取得→1wで絞る、が安全。
    const fetchDistForApi = (dist === "1w") ? "3m" : dist;

    const key = ["R",bbox,q,ps,fetchDistForApi,staff].join("|");
    if (key === lastProspectsKey) return;
    lastProspectsKey = key;

    const params = new URLSearchParams();
    params.set("bbox", bbox);
    if (q) params.set("q", q);
    if (fetchDistForApi) params.set("dist", fetchDistForApi);
    if (staff) params.set("staff", staff);

    if (ps === "posting") params.set("posting", "1");
    if (ps === "approach") params.set("approach", "1");
    if (ps === "ordered") params.set("ordered", "1");
    if (ps === "excluded") params.set("excluded", "1");

    const apiUrl = `${WORKER_BASE_URL}/prospects_search?${params.toString()}`;

    try {
      setBaseStat("検索中…", "loading");
      const data = await fetchJsonGuard(apiUrl, { headers, signal: prospectsAbort.signal });

      let items = (data.items || []).map(p => ({
        ...p,
        record_id: String(p.record_id ?? ""),
        lat: Number(p.lat),
        lng: Number(p.lng),
        is_recent_1w: Number(p.is_recent_1w || 0)
      })).filter(p => Number.isFinite(p.lat) && Number.isFinite(p.lng));

      // ★ dist=1w はフロントで絞る
      if (dist === "1w") {
        items = items.filter(p => Number(p.is_recent_1w) === 1);
      }

      lastProspects = items;

      const src = map.getSource("prospects");
      if (src) src.setData(prospectsToGeoJSON(lastProspects));

      setBaseStat(`表示: 案件 ${filterItems(lastItems).length}件 / 訪販 ${lastProspects.length}件`, "ok");
      applyProspectVisibility();

    } catch (e) {
      if (e && (e.name === "AbortError" || String(e.message || "").includes("aborted"))) return;
      if (String(e.message || "") === "AUTH_EXPIRED") return;
      console.error("loadProspects failed", e, apiUrl);
      setBaseStat("通信エラー（訪販）", "error");
    }
  }

  // GPS
  let gpsWatchId = null;
  let lastGpsAt = 0;
  let lastHeading = null;
  let lastLngLat = null;

  function setGpsStat(s){
    const el = document.getElementById("gpsStat");
    if (el) el.textContent = s;
  }

  function computeHeading(prev, next){
    const [lng1, lat1] = prev.map(d => d * Math.PI/180);
    const [lng2, lat2] = next.map(d => d * Math.PI/180);
    const y = Math.sin(lng2-lng1) * Math.cos(lat2);
    const x = Math.cos(lat1)*Math.sin(lat2) - Math.sin(lat1)*Math.cos(lat2)*Math.cos(lng2-lng1);
    let brng = Math.atan2(y, x) * 180/Math.PI;
    brng = (brng + 360) % 360;
    return brng;
  }

  function setGpsGeo(lng, lat, headingDeg){
    const src = map.getSource("me");
    if (!src) return;
    src.setData({
      type:"FeatureCollection",
      features:[{
        type:"Feature",
        geometry:{ type:"Point", coordinates:[lng, lat] },
        properties:{ heading: Number.isFinite(headingDeg) ? headingDeg : 0 }
      }]
    });
  }

  function clearGps(){
    const src = map.getSource("me");
    if (src) src.setData({ type:"FeatureCollection", features: [] });
    lastLngLat = null;
    lastHeading = null;

    const pulse = document.getElementById("gpsPulse");
    pulse.style.left = "-9999px";
    pulse.style.top = "-9999px";
  }

  function updatePulseOverlay(lng, lat){
    const p = map.project([lng, lat]);
    const pulse = document.getElementById("gpsPulse");
    pulse.style.left = (p.x - 36) + "px";
    pulse.style.top  = (p.y - 36) + "px";
  }

  function startGps(){
    if (!("geolocation" in navigator)) {
      setGpsStat("非対応");
      document.getElementById("gps-on").checked = false;
      return;
    }
    if (gpsWatchId != null) return;

    setGpsStat("ON");
    gpsWatchId = navigator.geolocation.watchPosition(
      (pos) => {
        const now = Date.now();
        if (now - lastGpsAt < 500) return;
        lastGpsAt = now;

        const lng = pos.coords.longitude;
        const lat = pos.coords.latitude;

        let heading = Number(pos.coords.heading);
        if (!Number.isFinite(heading)) heading = null;

        if (heading == null && lastLngLat) {
          const moved = computeHeading([lastLngLat.lng, lastLngLat.lat], [lng, lat]);
          if (lastHeading == null) heading = moved;
          else {
            const diff = ((moved - lastHeading + 540) % 360) - 180;
            heading = (lastHeading + diff * 0.35 + 360) % 360;
          }
        }
        if (heading == null && lastHeading != null) heading = lastHeading;
        if (heading == null) heading = 0;

        lastLngLat = { lng, lat };
        lastHeading = heading;

        setGpsGeo(lng, lat, heading);
        updatePulseOverlay(lng, lat);
      },
      () => setGpsStat("エラー"),
      { enableHighAccuracy: true, maximumAge: 0, timeout: 10000 }
    );
  }

  function stopGps(){
    if (gpsWatchId != null) {
      navigator.geolocation.clearWatch(gpsWatchId);
      gpsWatchId = null;
    }
    setGpsStat("OFF");
    clearGps();
  }

  function syncPulseToMap(){
    if (!lastLngLat) return;
    updatePulseOverlay(lastLngLat.lng, lastLngLat.lat);
  }

  // route + UI
  function renderRouteList() {
    const box = document.getElementById("routeList");
    if (selected.length === 0) {
      box.innerHTML = `<div class="small" style="text-align:center;padding:10px">未選択</div>`;
      return;
    }
    box.innerHTML = selected.map((p, i) => `
      <div class="item">
        <div style="min-width:0">
          <div style="font-weight:900;white-space:nowrap;overflow:hidden;text-overflow:ellipsis">${i+1}. ${escapeHtml(p.customer_name || "(no name)")}</div>
          <div class="small">ID: ${escapeHtml(p.id)}</div>
        </div>
        <button class="x" data-id="${escapeHtml(p.id)}">✕</button>
      </div>
    `).join("");

    box.querySelectorAll("button.x").forEach(btn => {
      btn.onclick = () => {
        const id = btn.getAttribute("data-id");
        const idx = selected.findIndex(x => String(x.id) === String(id));
        if (idx >= 0) {
          selectedSet.delete(String(id));
          selected.splice(idx, 1);
          map.setFilter("selected", ["in", ["get","id"], ["literal", Array.from(selectedSet)]]);
          renderRouteList();
        }
      };
    });
  }

  function clearRouteLine() {
    if (map.getLayer("route")) map.removeLayer("route");
    if (map.getLayer("route-border")) map.removeLayer("route-border");
    if (map.getSource("route")) map.removeSource("route");
  }

  async function createRoute() {
    if (selected.length < 2) return;
    if (selected.length > 25) return;

    clearRouteLine();

    const coords = selected.map(p => `${p.lng},${p.lat}`).join(";");
    const url = `https://api.mapbox.com/directions/v5/mapbox/driving/${coords}?geometries=geojson&overview=full&access_token=${mapboxgl.accessToken}`;
    const data = await fetch(url).then(r => r.json());
    const route = data?.routes?.[0];
    if (!route) return;

    map.addSource("route", { type:"geojson", data:{ type:"Feature", geometry: route.geometry } });
    map.addLayer({ id:"route-border", type:"line", source:"route", paint:{ "line-color":"#fff", "line-width":10 } });
    map.addLayer({ id:"route", type:"line", source:"route", paint:{ "line-color":"#2563eb", "line-width":6 } });

    const b = new mapboxgl.LngLatBounds();
    route.geometry.coordinates.forEach(c => b.extend(c));
    map.fitBounds(b, { padding: 80, duration: 700, maxZoom: 14 });
  }

  function bindToggle(panelId, btnId){
    const p = document.getElementById(panelId);
    const b = document.getElementById(btnId);
    b.onclick = () => {
      p.classList.toggle("collapsed");
      b.textContent = p.classList.contains("collapsed") ? "▶" : "◀";
    };
  }
  function collapsePanel(panelId, btnId){
    const p = document.getElementById(panelId);
    const b = document.getElementById(btnId);
    if (!p.classList.contains("collapsed")) p.classList.add("collapsed");
    if (b) b.textContent = "▶";
  }

  // init layers
  map.on("load", async () => {
    // base tileset (clickable)
    map.addSource("baseVT", { type: "vector", url: TILESET_URL });
    map.addLayer({
      id: "base-points",
      type: "circle",
      source: "baseVT",
      "source-layer": TILESET_SOURCE_LAYER,
      paint: {
        "circle-color": "#111827",
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 5, 2.4, 10, 3.6, 14, 4.6],
        "circle-stroke-width": ["interpolate", ["linear"], ["zoom"], 5, 0.8, 10, 1.2, 14, 1.4],
        "circle-stroke-color": "rgba(255,255,255,0.92)",
        "circle-opacity": BASE_OPACITY.NO_FILTER
      }
    });

    // projects hits geojson (search results)
    map.addSource("projects", {
      type: "geojson",
      data: { type:"FeatureCollection", features: [] },
      cluster: true,
      clusterRadius: 60,
      clusterMaxZoom: 14
    });

    // prospects geojson (always cluster)
    map.addSource("prospects", {
      type:"geojson",
      data:{ type:"FeatureCollection", features: [] },
      cluster: true,
      clusterRadius: PROSPECTS.CLUSTER_RADIUS,
      clusterMaxZoom: PROSPECTS.CLUSTER_MAX_ZOOM
    });

    // gps
    map.addSource("me", { type:"geojson", data:{ type:"FeatureCollection", features: [] } });

    // ===== projects layers =====
    map.addLayer({
      id: "clusters",
      type: "circle",
      source: "projects",
      filter: ["has","point_count"],
      paint: {
        "circle-color": ["step", ["get","point_count"], "#22c55e", 10, "#f59e0b", 50, "#ef4444"],
        "circle-radius": ["step", ["get","point_count"], 18, 10, 24, 50, 30],
        "circle-stroke-width": 2,
        "circle-stroke-color": "#fff"
      }
    });

    map.addLayer({
      id: "cluster-count",
      type: "symbol",
      source: "projects",
      filter: ["has","point_count"],
      layout: { "text-field":"{point_count_abbreviated}", "text-size": 12 },
      paint: { "text-color":"#fff" }
    });

    map.addLayer({
      id: "points-halo",
      type: "circle",
      source: "projects",
      filter: ["!", ["has", "point_count"]],
      paint: {
        "circle-color": "rgba(0,0,0,0.35)",
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 5, 6.5, 10, 10, 14, 12],
        "circle-blur": 0.2,
        "circle-opacity": 0.9
      }
    });

    map.addLayer({
      id: "points",
      type: "circle",
      source: "projects",
      filter: ["!", ["has","point_count"]],
      paint: {
        "circle-color": ["match", ["get","status"],
          "工事完了", "#2196F3",
          "工事予定", "#f59e0b",
          "契約完了", "#4CAF50",
          "半金予定", "#ff9800",
          "商談予定", "#9c27b0",
          "見積作成中", "#00bcd4",
          "現調予定", "#ff5722",
          "現調日調整中", "#e11d48",
          "キャンセル", "#6b7280",
          "#9ca3af"
        ],
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 5, 5.5, 10, 8.5, 14, 10.5],
        "circle-stroke-width": ["interpolate", ["linear"], ["zoom"], 5, 2.0, 10, 3.0, 14, 3.5],
        "circle-stroke-color": "#ffffff",
        "circle-opacity": 0.98
      }
    });

    map.addLayer({
      id: "point-labels",
      type: "symbol",
      source: "projects",
      filter: ["all", ["!", ["has","point_count"]], ["!=", ["get","label_all"], ""]],
      layout: {
        "text-field": ["get", "label_all"],
        "text-size": 12,
        "text-offset": [1.2, 0],
        "text-anchor": "left",
        "text-allow-overlap": true,
        "text-ignore-placement": true,
        "text-max-width": 18,
        "text-line-height": 1.2
      },
      paint: {
        "text-color": "#111827",
        "text-halo-color": "rgba(255,255,255,0.95)",
        "text-halo-width": 2,
        "text-halo-blur": 0.2
      }
    });

    map.addLayer({
      id: "selected",
      type: "circle",
      source: "projects",
      filter: ["in", ["get","id"], ["literal", []]],
      paint: { "circle-color": "#ef4444", "circle-radius": 11, "circle-stroke-width": 3, "circle-stroke-color": "#fff" }
    });

    // ===== prospects layers =====
    map.addLayer({
      id: "p-clusters",
      type: "circle",
      source: "prospects",
      filter: ["has","point_count"],
      paint: {
        "circle-color": ["step", ["get","point_count"], "#60a5fa", 20, "#38bdf8", 80, "#0ea5e9"],
        "circle-radius": ["step", ["get","point_count"], 17, 20, 23, 80, 29],
        "circle-stroke-width": 2,
        "circle-stroke-color": "#fff",
        "circle-opacity": 0.92
      }
    });

    map.addLayer({
      id: "p-cluster-count",
      type: "symbol",
      source: "prospects",
      filter: ["has","point_count"],
      layout: { "text-field":"{point_count_abbreviated}", "text-size": 12 },
      paint: { "text-color":"#fff" }
    });

    map.addLayer({
      id: "p-points-halo",
      type: "circle",
      source: "prospects",
      filter: ["!", ["has", "point_count"]],
      paint: {
        "circle-color": "rgba(0,0,0,0.28)",
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 6, 6.2, 12, 8.6, 15, 10.2],
        "circle-blur": 0.2,
        "circle-opacity": 0.85
      }
    });

    // 直近1週間の “爆目立ち” グロー（下から順に重ねる）
    map.addLayer({
      id: "p-recent-glow2",
      type: "circle",
      source: "prospects",
      filter: ["all",
        ["!", ["has","point_count"]],
        ["==", ["get","is_recent_1w"], 1]
      ],
      paint: {
        "circle-color": RECENT_GLOW2_COLOR,
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 5, 18, 10, 26, 14, 34, 16, 42],
        "circle-blur": 0.9,
        "circle-opacity": 0.95
      }
    });

    map.addLayer({
      id: "p-recent-glow",
      type: "circle",
      source: "prospects",
      filter: ["all",
        ["!", ["has","point_count"]],
        ["==", ["get","is_recent_1w"], 1]
      ],
      paint: {
        "circle-color": RECENT_GLOW_COLOR,
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 5, 14, 10, 21, 14, 28, 16, 34],
        "circle-blur": 0.75,
        "circle-opacity": 0.95
      }
    });

    map.addLayer({
      id: "p-recent-ring",
      type: "circle",
      source: "prospects",
      filter: ["all",
        ["!", ["has","point_count"]],
        ["==", ["get","is_recent_1w"], 1]
      ],
      paint: {
        "circle-color": "rgba(0,0,0,0)", /* fillなし */
        "circle-stroke-color": RECENT_RING_COLOR,
        "circle-stroke-width": ["interpolate", ["linear"], ["zoom"], 5, 3.0, 10, 4.0, 14, 5.2, 16, 6.0],
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 5, 9.5, 10, 13.5, 14, 17.5, 16, 21.5],
        "circle-opacity": 0.98
      }
    });

    // 訪販の色分け（通常）
    map.addLayer({
      id: "p-points",
      type: "circle",
      source: "prospects",
      filter: ["!", ["has","point_count"]],
      paint: {
        "circle-color": [
          "case",
          ["==", ["get","status_code"], "excluded"], PROSPECT_EXCLUDED_COLOR,
          ["==", ["get","status_code"], "ordered"], "rgba(59,130,246,0.28)",
          ["==", ["get","status_code"], "approach"], "#a855f7",
          ["==", ["get","status_code"], "posting"], "#f59e0b",
          ["==", ["get","status_code"], "todo"], PROSPECT_TODO_COLOR,

          ["==", ["get","is_excluded"], 1], PROSPECT_EXCLUDED_COLOR,
          ["==", ["get","is_ordered"], 1], "rgba(59,130,246,0.28)",
          ["==", ["get","is_approached"], 1], "#a855f7",
          ["==", ["get","is_posted"], 1], "#f59e0b",
          ["==", ["get","is_todo"], 1], PROSPECT_TODO_COLOR,

          "#60a5fa"
        ],
        "circle-radius": ["interpolate", ["linear"], ["zoom"], 6, 5.6, 12, 7.8, 15, 9.2],
        "circle-stroke-width": ["interpolate", ["linear"], ["zoom"], 6, 1.8, 12, 2.4, 15, 2.8],
        "circle-stroke-color": "#ffffff",
        "circle-opacity": 0.98
      }
    });

    // interactions: projects clusters
    map.on("click", "clusters", (e) => {
      const f = map.queryRenderedFeatures(e.point, { layers:["clusters"] })[0];
      if (!f) return;
      const clusterId = f.properties.cluster_id;
      map.getSource("projects").getClusterExpansionZoom(clusterId, (err, zoom) => {
        if (err) return;
        map.easeTo({ center: f.geometry.coordinates, zoom });
      });
    });

    // interactions: prospects clusters
    map.on("click", "p-clusters", (e) => {
      if (!prospectsEnabled()) return;
      const f = map.queryRenderedFeatures(e.point, { layers:["p-clusters"] })[0];
      if (!f) return;
      const clusterId = f.properties.cluster_id;
      map.getSource("prospects").getClusterExpansionZoom(clusterId, (err, zoom) => {
        if (err) return;
        map.easeTo({ center: f.geometry.coordinates, zoom });
      });
    });

    // click project point
    map.on("click", "points", async (e) => {
      const f = e.features?.[0];
      if (!f) return;

      if (routeMode) {
        const p = f.properties;
        const id = String(p.id);
        if (selectedSet.has(id)) {
          selectedSet.delete(id);
          const idx = selected.findIndex(x => String(x.id) === id);
          if (idx >= 0) selected.splice(idx, 1);
        } else {
          selectedSet.add(id);
          selected.push({
            id,
            customer_name: p.customer_name || "",
            lat: Number(f.geometry.coordinates[1]),
            lng: Number(f.geometry.coordinates[0])
          });
        }
        map.setFilter("selected", ["in", ["get","id"], ["literal", Array.from(selectedSet)]]);
        renderRouteList();
        return;
      }
      await showProjectPopupById(f.properties.id);
    });

    // click prospect point
    map.on("click", "p-points", async (e) => {
      if (!prospectsEnabled()) return;
      const f = e.features?.[0];
      if (!f) return;
      const rid = f.properties?.record_id;
      if (!rid) return;
      await showProspectPopupById(rid);
    });

    // tileset click (only when no project condition)
    map.on("click", "base-points", async (e) => {
      if (hasAnyProjectCondition()) return;
      const f = e.features?.[0];
      if (!f) return;
      const id = f.properties?.[TILESET_ID_PROP];
      if (!id) return;
      await showProjectPopupById(id);
    });

    // cursors
    map.on("mouseenter", "clusters", () => map.getCanvas().style.cursor="pointer");
    map.on("mouseleave", "clusters", () => map.getCanvas().style.cursor="");
    map.on("mouseenter", "points", () => map.getCanvas().style.cursor="pointer");
    map.on("mouseleave", "points", () => map.getCanvas().style.cursor="");

    map.on("mouseenter", "p-clusters", () => map.getCanvas().style.cursor= prospectsEnabled() ? "pointer" : "");
    map.on("mouseleave", "p-clusters", () => map.getCanvas().style.cursor="");
    map.on("mouseenter", "p-points", () => map.getCanvas().style.cursor= prospectsEnabled() ? "pointer" : "");
    map.on("mouseleave", "p-points", () => map.getCanvas().style.cursor="");

    map.on("mouseenter", "base-points", () => {
      map.getCanvas().style.cursor = hasAnyProjectCondition() ? "" : "pointer";
    });
    map.on("mouseleave", "base-points", () => map.getCanvas().style.cursor="");

    map.on("move", syncPulseToMap);
    map.on("zoom", syncPulseToMap);

    // initial UI state
    bindToggle("mainPanel","mainToggle");
    collapsePanel("mainPanel","mainToggle");

    document.getElementById("label-on").checked = false;
    applyLabel(false);

    document.getElementById("gps-on").checked = false;
    setGpsStat("OFF");
    stopGps();

    presetVisitDateOptions(null);
    presetCompletionYears("");

    setClusterEnabled(true);
    updateClusterUiVisibility();

    await loadStaffMasterOnce();

    clearAll();
    applyProspectVisibility();
    applyBaseOpacity();

    let t;
    map.on("moveend", () => {
      clearTimeout(t);
      t = setTimeout(() => {
        if (hasAnyProjectCondition()) scheduleLoadProjects(0);
        if (prospectsEnabled()) scheduleLoadProspects(0);
      }, 350);
    });
  });

  // UI events
  document.getElementById("search").addEventListener("input", () => {
    scheduleLoadProjects(350);
    if (prospectsEnabled()) scheduleLoadProspects(350);
  });

  document.getElementById("prospects-on").addEventListener("change", () => {
    applyProspectVisibility();
    if (prospectsEnabled()) scheduleLoadProspects(0);
    else clearProspects();
  });

  document.getElementById("status-filter").addEventListener("change", () => {
    updateCompletionYearVisibility();
    applyBaseOpacity();
    scheduleLoadProjects(120);
  });
  document.getElementById("completion-year-filter").addEventListener("change", () => { applyBaseOpacity(); scheduleLoadProjects(120); });
  document.getElementById("channel-filter").addEventListener("change", () => { applyBaseOpacity(); scheduleLoadProjects(120); });
  document.getElementById("staff-filter").addEventListener("change", () => { applyBaseOpacity(); scheduleLoadProjects(120); });

  document.getElementById("visit-date-filter").addEventListener("change", () => {
    const vd = document.getElementById("visit-date-filter").value;
    if (!vd) setClusterEnabled(true);
    updateClusterUiVisibility();
    applyBaseOpacity();
    scheduleLoadProjects(120);
  });

  document.getElementById("cluster").addEventListener("change", (e) => setClusterEnabled(e.target.checked));

  document.getElementById("prospect-status-filter").addEventListener("change", () => { applyBaseOpacity(); if (prospectsEnabled()) scheduleLoadProspects(120); });
  document.getElementById("prospect-dist-filter").addEventListener("change", () => { applyBaseOpacity(); if (prospectsEnabled()) scheduleLoadProspects(120); });
  document.getElementById("prospect-staff-filter").addEventListener("change", () => { applyBaseOpacity(); if (prospectsEnabled()) scheduleLoadProspects(120); });

  document.getElementById("label-on").addEventListener("change", (e) => applyLabel(e.target.checked));
  document.getElementById("gps-on").addEventListener("change", (e) => e.target.checked ? startGps() : stopGps());

  document.getElementById("routeMode").addEventListener("click", () => {
    routeMode = !routeMode;
    document.getElementById("routeMode").textContent = routeMode ? "ルート作成中" : "ルート作成モード";
    document.getElementById("routeMode").className = routeMode ? "btn-primary" : "btn-secondary";
    document.getElementById("routeBox").style.display = routeMode ? "block" : "none";

    if (!routeMode) {
      selectedSet.clear();
      selected.length = 0;
      map.setFilter("selected", ["in", ["get","id"], ["literal", []]]);
      renderRouteList();
      clearRouteLine();
    } else {
      renderRouteList();
    }
  });

  document.getElementById("showRoute").addEventListener("click", createRoute);
  document.getElementById("clearRoute").addEventListener("click", clearRouteLine);

  document.getElementById("reset").addEventListener("click", () => {
    document.getElementById("search").value = "";

    // projects
    document.getElementById("status-filter").value = "";
    document.getElementById("completion-year-filter").value = "";
    document.getElementById("channel-filter").value = "";
    document.getElementById("staff-filter").value = "";
    document.getElementById("visit-date-filter").value = "";

    // prospects
    document.getElementById("prospects-on").checked = true;
    document.getElementById("prospect-status-filter").value = "";
    document.getElementById("prospect-dist-filter").value = "";
    document.getElementById("prospect-staff-filter").value = "";

    updateCompletionYearVisibility();

    setClusterEnabled(true);
    updateClusterUiVisibility();

    document.getElementById("label-on").checked = false;
    applyLabel(false);

    document.getElementById("gps-on").checked = false;
    stopGps();

    lastKey = "";
    if (loadAbort) loadAbort.abort();

    lastProspectsKey = "";
    if (prospectsAbort) prospectsAbort.abort();

    presetVisitDateOptions(null);
    presetCompletionYears("");

    map.flyTo({ center:[138.252924,36.204824], zoom:5, duration:700 });

    closeCenterPopup();
    clearAll();
    applyProspectVisibility();
    applyBaseOpacity();
  });

})();
</script>
</body>
</html>