คู่มืออธิบายโค้ด JobMatch

8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

void main() async {
  WidgetsFlutterBinding.ensureInitialized();
  SystemChrome.setPreferredOrientations([DeviceOrientation.portraitUp]);
  SystemChrome.setSystemUIOverlayStyle(
    const SystemUiOverlayStyle(
      statusBarColor: Colors.transparent,
      statusBarIconBrightness: Brightness.light,
    ),
  );
  await SessionService.instance.init();
  // เซสชันหมดอายุ (API ตอบ 401) -> ล้างข้อมูลเข้าสู่ระบบแล้วกลับไปหน้าเริ่มต้นให้ล็อกอินใหม่
  ApiService.onUnauthorized = () async {
    if (!SessionService.instance.isLoggedIn) return;
    await SessionService.instance.clearSession();
    AppRouter.router.go('/welcome');
  };
  runApp(const JobMatchEmployerApp());
}

class JobMatchEmployerApp extends StatelessWidget {
  const JobMatchEmployerApp({super.key});

  @override
  Widget build(BuildContext context) {
    return MaterialApp.router(
      title: 'JobMatch',
      theme: AppTheme.theme,
      routerConfig: AppRouter.router,
      debugShowCheckedModeBanner: false,
    );
  }
}

6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

static const String baseUrl = String.fromEnvironment(
  'API_URL',
  defaultValue: 'http://192.168.100.99/jobmatch_api',
);

/// แปลง path ไฟล์จาก API ให้เป็น URL เต็มที่ชี้ไปยังเซิร์ฟเวอร์ปัจจุบัน
/// - path สัมพัทธ์ (uploads/x.jpg) -> ต่อ baseUrl ให้
/// - URL เต็มของ jobmatch_api ที่มี IP เก่าติดมา -> เปลี่ยนเป็น baseUrl ปัจจุบัน
/// - URL ภายนอกอื่นๆ -> คืนค่าเดิม
static String? resolveUrl(String? path) {
  if (path == null || path.isEmpty) return path;
  if (path.startsWith('http://') || path.startsWith('https://')) {
    const marker = '/jobmatch_api/';
    final i = path.indexOf(marker);
    if (i == -1) return path;
    return _absolute('$baseUrl/${path.substring(i + marker.length)}');
  }
  return _absolute('$baseUrl/${path.startsWith('/') ? path.substring(1) : path}');
}

/// เวอร์ชันเว็บที่ baseUrl เป็น path สัมพัทธ์: เติมโดเมนของหน้าเว็บให้เป็น URL เต็ม (ใช้กับรูป/PDF)
static String _absolute(String url) =>
    url.startsWith('/') ? Uri.base.resolve(url).toString() : url;

26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

class AppRouter {
  static final router = GoRouter(
    initialLocation: '/splash',
    // ลิงก์ผิด/หน้าที่ไม่มีอยู่ (เจอได้บนเว็บ) -> หน้าภาษาไทยพร้อมปุ่มกลับหน้าแรก แทนข้อความ error ภาษาอังกฤษ
    errorBuilder: (context, state) => const NotFoundPage(),
    redirect: (context, state) {
      final isLoggedIn = SessionService.instance.isLoggedIn;
      final role = SessionService.instance.userRole;
      final loc = state.uri.path;

      final isUnauthRoute =
          loc == '/login' ||
          loc == '/register' ||
          loc == '/welcome' ||
          loc == '/seeker-login' ||
          loc == '/seeker-register' ||
          loc == '/forgot-password';

      if (loc == '/splash') return null;

      if (!isLoggedIn && !isUnauthRoute) {
        return '/welcome';
      }

      if (isLoggedIn && isUnauthRoute) {
        return role == 'seeker' ? '/seeker-home' : '/home';
      }

      return null;
    },

109
110
111
112
113
114
115
116
117
118
119
120
121
122

GoRoute(
  path: '/home',
  builder: (_, s) => MainShell(initialTab: int.tryParse(s.uri.queryParameters['tab'] ?? '') ?? 0),
  routes: [
    GoRoute(
      path: 'post-job',
      // ถ้ามีการส่ง JobPostingModel มาผ่าน context.push('/home/post-job', extra: job)
      // จะได้ค่าตรงนี้ผ่าน state.extra แล้วส่งต่อเป็นโหมดแก้ไข ถ้าไม่ได้ส่งมา (กดปุ่ม
      // "สร้างงานใหม่" ปกติ) extra จะเป็น null และหน้าจะเป็นโหมดโพสต์ใหม่ตามเดิม
      builder: (_, state) {
        final job = state.extra as JobPostingModel?;
        return PostJobPage(editJob: job);
      },
    ),

5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

class AppTheme {
  // ---- Color Palette ----
  static const Color primary = Color(0xFF1287B5); // ฟ้าเข้ม: แถบหัว ปุ่ม ไอคอน หัวข้อ
  static const Color primaryLight = Color(0xFF45CBF3); // ฟ้าสด (สีอ้างอิง): ไฮไลต์ ไล่เฉดสี
  static const Color primaryDark = Color(0xFF0B6A90); // ฟ้าเข้มกว่า: ปลายไล่เฉดสีของแถบหัว
  static const Color primaryDarker = Color(0xFF0E5577);
  static const Color primarySoft = Color(0xFFDFF5FD); // ฟ้าอ่อน: พื้นหลังป้าย/ชิป/ไอคอน
  static const Color primaryTint = Color(0xFFEFFAFE); // ฟ้าอ่อนมาก: พื้นการ์ดไฮไลต์
  static const Color primaryBorder = Color(0xFFB9E9FA); // เส้นขอบโทนฟ้า
  static const Color accent = Color(0xFF45CBF3);
  static const Color accentLight = Color(0xFFA6E6FA);
  static const Color ink = Color(0xFF231F20); // หมึกเข้ม: ตัวอักษรหลัก ของเด่นโทนเข้ม
  static const Color inkLight = Color(0xFF4A4340); // ปลายไล่เฉดสีของการ์ดสีหมึก
  static const Color cream = Color(0xFFFEF6F1); // ครีม (สีอ้างอิง): พื้นหลังหน้าจอ
  static const Color creamDark = Color(0xFFF3E9E2); // ครีมเข้ม: โครงตอนโหลดข้อมูล พื้นไอคอน
  static const Color creamLight = Color(0xFFFBF4EF);
  static const Color success = Color(0xFF2E9E6A);
  static const Color warning = Color(0xFFF29A2E);
  static const Color error = Color(0xFFE5484D);
  static const Color background = cream;
  static const Color surface = Color(0xFFFFFFFF);
  static const Color textPrimary = ink;
  static const Color textSecondary = Color(0xFF6B625C); // เทาอมน้ำตาล เข้ากับพื้นครีม
  static const Color divider = Color(0xFFEFE2D8);

  static ThemeData get theme => ThemeData(
    useMaterial3: true,
    fontFamily: 'Kanit',
    colorScheme: ColorScheme.fromSeed(
      seedColor: primary,
      primary: primary,
      secondary: primaryLight,
      surface: surface,
      error: error,
      onSurface: textPrimary,
    ),
    scaffoldBackgroundColor: background,
    appBarTheme: const AppBarTheme(
      backgroundColor: primary,
      foregroundColor: Colors.white,
      elevation: 0,

3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

const _thaiMonths = ['ม.ค.', 'ก.พ.', 'มี.ค.', 'เม.ย.', 'พ.ค.', 'มิ.ย.', 'ก.ค.', 'ส.ค.', 'ก.ย.', 'ต.ค.', 'พ.ย.', 'ธ.ค.'];
final _number = NumberFormat('#,##0');

/// แปลง "2026-10-15" (หรือ "2026-10-15 08:30:00") เป็น "15 ต.ค. 2569"
String formatThaiDate(String? isoDate) {
  final d = DateTime.tryParse(isoDate ?? '');
  if (d == null) return isoDate ?? '';
  return '${d.day} ${_thaiMonths[d.month - 1]} ${d.year + 543}';
}

/// เวลาแบบสัมพัทธ์สำหรับแจ้งเตือน: "เมื่อสักครู่", "5 นาทีที่แล้ว", "3 ชม.ที่แล้ว", "เมื่อวาน", เกินนั้นแสดงวันที่
String formatRelativeThai(String? dateTime) {
  final d = DateTime.tryParse(dateTime ?? '');
  if (d == null) return dateTime ?? '';
  final diff = DateTime.now().difference(d);
  if (diff.inMinutes < 1) return 'เมื่อสักครู่';
  if (diff.inMinutes < 60) return '${diff.inMinutes} นาทีที่แล้ว';
  if (diff.inHours < 24) return '${diff.inHours} ชม.ที่แล้ว';
  if (diff.inDays == 1) return 'เมื่อวาน';
  return formatThaiDate(dateTime);
}

/// จัดรูปแบบค่าจ้าง: "15000-24000 บาท" -> "15,000 – 24,000 บาท", "350-500 บาท/วัน" -> "350 – 500 บาท/วัน"
/// ข้อความที่ไม่มีตัวเลข (เช่น "ตามตกลง") คืนค่าเดิม
String formatSalary(String? raw) {
  final text = (raw ?? '').trim();
  if (text.isEmpty) return '';
  final numbers = RegExp(r'\d[\d,]*(?:\.\d+)?')
      .allMatches(text)
      .map((m) => double.tryParse(m.group(0)!.replaceAll(',', '')))
      .whereType<double>()
      .toList();
  if (numbers.isEmpty) return text;
  final unit = RegExp(r'/\s*\S+').firstMatch(text)?.group(0)?.replaceAll(' ', '') ?? '';
  final amount = numbers.length >= 2
      ? '${_number.format(numbers[0])} – ${_number.format(numbers[1])}'
      : _number.format(numbers[0]);
  return '$amount บาท$unit';
}

1
2
3
4
5
6
7
8
9
10

import 'package:flutter/foundation.dart' show kIsWeb;

/// ใช้ GPS ได้หรือไม่
/// เบราว์เซอร์ (โดยเฉพาะ Safari บน iPhone) ไม่ให้ใช้ตำแหน่งปัจจุบันบนเว็บแบบ http
/// และบางครั้งไม่ตอบกลับเลย ทำให้หน้าที่รอ GPS ค้าง จึงข้ามไปใช้พิกัดจากที่อยู่ในโปรไฟล์แทน
bool get canUseGps {
  if (!kIsWeb) return true;
  final uri = Uri.base;
  return uri.scheme == 'https' || uri.host == 'localhost' || uri.host == '127.0.0.1';
}

86
87
88
89
90
91
92
93

factory JobPostingModel.fromJson(Map<String, dynamic> json) {
  List<String> skills = [];
  final rawSkills = json['required_skills'] ?? json['tags'];
  if (rawSkills is List) {
    skills = rawSkills.map((e) => e.toString()).toList();
  } else if (rawSkills is String && rawSkills.isNotEmpty) {
    skills = rawSkills.split(',').map((s) => s.trim()).where((s) => s.isNotEmpty).toList();
  }

105
106
107
108
109
110

return JobPostingModel(
  jobId:          json['job_id'] as int? ?? json['id'] as int? ?? 0,
  employerId:     json['employer_id'] as int? ?? 0,
  employerUserId: json['employer_user_id'] as int? ?? 0,
  jobTitle:       json['job_title'] as String? ?? json['title'] as String? ?? '',
  jobDescription: json['job_description'] as String? ?? '',

67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

/// ค่าจ้างเป็นตัวเลข (ดึงเฉพาะตัวเลขจากข้อความ เช่น "15,000" -> 15000) ใช้กรอง/เรียงตามค่าจ้าง
double? get salaryValue {
  final digits = (salary ?? '').replaceAll(RegExp(r'[^0-9.]'), '');
  final value = double.tryParse(digits);
  return (value == null || value <= 0) ? null : value;
}

/// งานที่ผู้หางานมองเห็นได้ ('open' = ข้อมูลเดิมก่อนมีระบบอนุมัติ)
bool get isApproved => status == 'open' || status == 'approved';

/// จำนวนที่ยังรับได้อยู่ตอนนี้ (ไม่ต่ำกว่า 0 แม้ hiredCount จะเกิน vacancy มาจาก backend)
int get remainingVacancy {
  final remaining = vacancy - hiredCount;
  return remaining < 0 ? 0 : remaining;
}

/// รับครบตามจำนวนที่ต้องการแล้วหรือยัง
bool get isFull => remainingVacancy <= 0;

5
6
7
8
9
10
11
12
13
14
15
16

class SessionService {
  static SessionService? _instance;
  static SessionService get instance => _instance ??= SessionService._();
  SessionService._();

  SharedPreferences? _prefs;
  static const String prefProfileImage = 'profile_image';
  static const String prefCompanyName = 'company_name';

  Future<void> init() async {
    _prefs = await SharedPreferences.getInstance();
  }

63
64
65
66
67
68
69
70
71
72
73

int get userId => _prefs?.getInt(AppConstants.prefUserId) ?? 0;
int get employerId => _prefs?.getInt(AppConstants.prefEmployerId) ?? 0;
int get seekerId => _prefs?.getInt(AppConstants.prefSeekerId) ?? 0;
String get userName => _prefs?.getString(AppConstants.prefUserName) ?? '';
String get userRole => _prefs?.getString(AppConstants.prefUserRole) ?? '';
String get userEmail => _prefs?.getString(AppConstants.prefUserEmail) ?? '';
/// ชื่อบริษัท (ผู้ว่าจ้าง) ไม่มีให้ใช้ชื่อผู้ใช้แทน
String get companyName => _prefs?.getString(prefCompanyName) ?? userName;
String get profileImage =>
    AppConstants.resolveUrl(_prefs?.getString(prefProfileImage)) ?? '';
bool get isLoggedIn => _prefs?.getBool(AppConstants.prefIsLoggedIn) ?? false;

12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

class ApiService {
  static final ApiService _instance = ApiService._internal();
  factory ApiService() => _instance;
  ApiService._internal() {
    _dio.interceptors.add(
      InterceptorsWrapper(
        onRequest: (options, handler) {
          // แนบ user_id ของผู้ที่ล็อกอินอยู่ทุกคำขอ (backend ใช้ตรวจสิทธิ์ความเป็นเจ้าของข้อมูล)
          final userId = SessionService.instance.userId;
          if (userId > 0) {
            options.headers['X-User-Id'] = '$userId';
          }
          handler.next(options);
        },
        onResponse: (response, handler) {
          // token หมดอายุ / ไม่มี token (เช่น แอปเวอร์ชันเก่าที่ยังไม่เคยได้ token) -> ออกจากระบบให้ล็อกอินใหม่
          if (response.statusCode == 401 && !response.requestOptions.path.endsWith('login.php')) {
            _notifyUnauthorized();
          }
          handler.next(response);
        },
      ),
    );
  }

  /// เรียกเมื่อ backend ตอบ 401 (ตั้งค่าใน main.dart ให้ล้าง session แล้วกลับไปหน้าเริ่มต้น)
  static Future<void> Function()? onUnauthorized;
  static bool _handlingUnauthorized = false;

  static Future<void> _notifyUnauthorized() async {
    if (_handlingUnauthorized || onUnauthorized == null) return;
    _handlingUnauthorized = true;
    try {
      await onUnauthorized!();
    } finally {
      _handlingUnauthorized = false;
    }
  }

50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

final Dio _dio = Dio(
  BaseOptions(
    connectTimeout: const Duration(seconds: 10),
    receiveTimeout: const Duration(seconds: 10),
    headers: {'Content-Type': 'application/json'},
    validateStatus: (status) => true, // ยอมรับทุก status code ไม่ throw exception
  ),
);

Map<String, dynamic> _noCache(Map<String, dynamic> params) {
  params['_t'] = DateTime.now().millisecondsSinceEpoch;
  return params;
}

void _logError(String method, Object error) {
  if (kDebugMode) {
    debugPrint('[ApiService] $method failed: $error');
  }
}

// แปลง response data ให้เป็น Map อย่างปลอดภัย
// รองรับทั้งกรณีที่ Dio parse ให้แล้ว (Map) และกรณีที่ยังเป็น String อยู่
// (เช่น PHP backend ส่ง BOM, Content-Type ไม่ตรง หรือ Dio ไม่ auto-parse)
Map<String, dynamic> _parseMap(dynamic data) {
  if (data is Map<String, dynamic>) return data;
  if (data is String) {
    final raw = data.trim();
    final clean = raw.startsWith('\uFEFF') ? raw.substring(1) : raw;
    if (clean.isNotEmpty) {
      try {
        final decoded = jsonDecode(clean);
        if (decoded is Map<String, dynamic>) return decoded;
      } catch (e) {
        if (kDebugMode) debugPrint('[ApiService] jsonDecode error: $e\nData: $clean');
      }
    }
  }
  return {'success': false, 'message': 'ไม่สามารถอ่านข้อมูลจากเซิร์ฟเวอร์ได้'};
}

450
451
452
453
454
455
456
457
458
459
460
461
462
463
464

Future<Map<String, dynamic>> applyJob({
  required int jobId,
  required int seekerId,
}) async {
  try {
    final res = await _dio.post(
      AppConstants.applyJob,
      data: {'job_id': jobId, 'seeker_id': seekerId},
    );
    return _parseMap(res.data);
  } on DioException catch (e) {
    _logError('applyJob', e);
    return _handleError(e);
  }
}

336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353

Future<List<JobPostingModel>> getEmployerJobs(int employerId) async {
  try {
    final res = await _dio.get(
      AppConstants.getEmployerJobs,
      queryParameters: _noCache({'employer_id': employerId}),
    );
    final body = _parseMap(res.data);
    if (body['success'] == true) {
      return (body['data'] as List)
          .map((j) => JobPostingModel.fromJson(j))
          .toList();
    }
    return [];
  } catch (e) {
    _logError('getEmployerJobs', e);
    return [];
  }
}

771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798

Future<Map<String, dynamic>> uploadProfileImage({
  required int userId,
  required String role,
  // ส่งเป็น bytes เพื่อให้ใช้ได้ทั้งแอปมือถือและเว็บ (บนเว็บอ่านไฟล์จาก path ไม่ได้)
  required List<int> bytes,
  required String fileName,
  // 'cover' = ภาพปกบริษัท, null = รูปโปรไฟล์/โลโก้
  String? kind,
}) async {
  try {
    final formData = FormData.fromMap({
      'user_id': userId,
      'role': role,
      if (kind != null) 'kind': kind,
      'file': MultipartFile.fromBytes(bytes, filename: fileName),
    });
    final res = await _dio.post(
      AppConstants.uploadProfileImage,
      data: formData,
    );
    return _parseMap(res.data);
  } on DioException catch (e) {
    _logError('uploadProfileImage', e);
    return _handleError(e);
  } catch (e) {
    return {'success': false, 'message': e.toString()};
  }
}

20
21
22
23
24
25
26
27
28
29
30
31
32

Future<void> _checkSession() async {
  await Future.delayed(const Duration(seconds: 2));
  if (!mounted) return;
  if (SessionService.instance.isLoggedIn) {
    if (SessionService.instance.userRole == 'seeker') {
      context.go('/seeker-home');
    } else {
      context.go('/home');
    }
  } else {
    context.go('/welcome');
  }
}

22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

Future<void> _handleLogin() async {
  if (!_formKey.currentState!.validate()) return;
  setState(() => _isLoading = true);

  final res = await ApiService().login(
    _emailController.text.trim(),
    _passwordController.text,
  );

  setState(() => _isLoading = false);

  if (!mounted) return;

  if (res['success'] == true) {
    final userData = res['data'];
    final role = userData['role'] ?? 'employer';

    if (role != 'employer') {
      ScaffoldMessenger.of(context).showSnackBar(
        const SnackBar(
          content: Text('บัญชีนี้ไม่ใช่บัญชีสำหรับนายจ้าง'),
          backgroundColor: AppTheme.error,
        ),
      );
      return;
    }

    final member = MemberModel.fromJson(userData);

    final fullMember = await ApiService().getMember(member.userId);
    await SessionService.instance.saveSession(fullMember ?? member);

    if (!mounted) return;
    context.go('/home');
  } else {
    ScaffoldMessenger.of(context).showSnackBar(
      SnackBar(
        content: Text(res['message'] ?? 'เข้าสู่ระบบไม่สำเร็จ'),
        backgroundColor: AppTheme.error,
      ),
    );
  }
}

81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

final isCompany = _employerType == EmployerType.company;
final subdistrict = _thaiAddressController.subdistrict?.nameTh ?? '';
final district = _thaiAddressController.district?.nameTh ?? '';
final province = _thaiAddressController.province?.nameTh ?? '';
final zipCodeText =
    _thaiAddressController.subdistrict?.postcode.toString() ?? '';
final fullAddress = _addressDetailController.text.trim();

final completeAddress =
    '$fullAddress ต.$subdistrict อ.$district จ.$province $zipCodeText';

final res = await ApiService().registerEmployer(
  name: _nameController.text.trim(),
  email: _emailController.text.trim(),
  password: _passwordController.text,
  contactPhone: _contactPhoneController.text.trim(),
  companyAddress: completeAddress.trim(),
  companyName: isCompany
      ? _companyNameController.text.trim()
      : _nameController.text.trim(),
  companyDetail: isCompany
      ? _companyDetailController.text.trim()
      : 'บุคคลทั่วไป',
  latitude: _latitude,
  longitude: _longitude,
);

if (!mounted) return;

if (res['success'] == true) {
  final loginRes = await ApiService().login(
    _emailController.text.trim(),
    _passwordController.text,
  );
  if (!mounted) return;

  if (loginRes['success'] == true) {
    final userData = loginRes['data'];
    final member = MemberModel.fromJson(userData);
    final fullMember = await ApiService().getMember(member.userId);

    await SessionService.instance.saveSession(fullMember ?? member);
    if (!mounted) return;
    context.go('/home');

153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170

void _nextStep() {
  bool isStepValid = false;
  if (_currentStep == 0) {
    isStepValid = _step1FormKey.currentState!.validate();
  } else if (_currentStep == 1) {
    isStepValid = _step2FormKey.currentState!.validate();
  } else if (_currentStep == 2) {
    isStepValid = _step3FormKey.currentState!.validate();
  }

  if (isStepValid) {
    if (_currentStep < 2) {
      setState(() => _currentStep += 1);
    } else {
      _handleRegister();
    }
  }
}

211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236

if (res['success'] == true) {
  final loginRes = await ApiService().login(
    _emailController.text.trim(),
    _passwordController.text,
  );

  if (!mounted) return;

  if (loginRes['success'] == true) {
    final userData = loginRes['data'];
    final member = MemberModel.fromJson(userData);
    final fullMember = await ApiService().getMember(member.userId);

    await SessionService.instance.saveSession(
      fullMember ?? member,
      seekerId: userData['seeker_id'] as int?,
    );

    if (!mounted) return;
    ScaffoldMessenger.of(context).showSnackBar(
      const SnackBar(
        content: Text('สมัครสมาชิกและเข้าสู่ระบบสำเร็จ!'),
        backgroundColor: AppTheme.success,
      ),
    );
    context.go('/seeker-home');

33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

Future<void> _submit() async {
  if (!_formKey.currentState!.validate()) return;
  setState(() => _isLoading = true);

  final res = await ApiService().resetPassword(
    email: _emailController.text.trim(),
    phone: _phoneController.text.trim(),
    newPassword: _passwordController.text,
  );

  if (!mounted) return;
  setState(() => _isLoading = false);

  final ok = res['success'] == true;
  ScaffoldMessenger.of(context).showSnackBar(
    SnackBar(
      content: Text(res['message'] ?? (ok ? 'ตั้งรหัสผ่านใหม่สำเร็จ' : 'ตั้งรหัสผ่านใหม่ไม่สำเร็จ')),
      backgroundColor: ok ? AppTheme.success : AppTheme.error,
    ),
  );
  if (ok) context.pop();
}

21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

class _MainShellState extends State<MainShell> {
  int _currentIndex = 0;
  int _unreadChatCount = 0;
  int _unreadNotiCount = 0;
  Timer? _unreadTimer;

  final List<Widget> _tabs = const [
    DashboardTab(),
    ManageJobsTab(),
    ChatTab(),
    NotificationsTab(),
    ProfileTab(),
  ];

  @override
  void initState() {
    super.initState();
    _currentIndex = widget.initialTab.clamp(0, _tabs.length - 1);
    _fetchUnreadCount();
    _unreadTimer = Timer.periodic(const Duration(seconds: 5), (_) => _fetchUnreadCount());
  }

  @override
  void dispose() {
    _unreadTimer?.cancel();
    super.dispose();
  }

66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

void _onPageChanged(int index) {
  setState(() => _currentIndex = index);
}

void switchTab(int index) {
  _pageController.jumpToPage(index);
  if (index == 3) _fetchUnreadCount();
}

void _onBottomNavTapped(int index) {
  _pageController.jumpToPage(index);
  if (index == 3) _fetchUnreadCount();
}

@override
Widget build(BuildContext context) {
  return Scaffold(
    body: PageView(
      controller: _pageController,
      onPageChanged: _onPageChanged,
      physics: const NeverScrollableScrollPhysics(),
      children: _tabs,
    ),
    bottomNavigationBar: BottomNavigationBar(
      currentIndex: _currentIndex,
      onTap: _onBottomNavTapped,

160
161
162
163
164
165
166
167

onPressed: () {
  context.push<String>('/seeker-home/notifications').then((result) {
    _fetchUnreadNotifications();
    // แตะแจ้งเตือนเรื่องใบสมัคร -> สลับไปแท็บ "งานของฉัน"
    if (result == kOpenApplicationsTab && context.mounted) {
      context.findAncestorStateOfType<SeekerMainShellState>()?.switchTab(1);
    }
  });

58
59
60
61
62
63
64
65
66
67
68
69
70
71

Future<void> _loadDashboardData() async {
  if (!mounted) return;
  setState(() => _isLoading = true);
  final employerId = SessionService.instance.employerId;
  final jobs = await ApiService().getEmployerJobs(employerId);
  final apps = await ApiService().getApplicationsByEmployer(employerId);
  if (!mounted) return;
  setState(() {
    _jobs = jobs;
    _recentApplications = apps;
    _isLoading = false;
  });
  _fadeController.forward(from: 0);
}

6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

// กำหนด State
abstract class ManageJobsState {}

class ManageJobsInitial extends ManageJobsState {}

class ManageJobsLoading extends ManageJobsState {}

class ManageJobsLoaded extends ManageJobsState {
  final List<JobPostingModel> jobs;
  ManageJobsLoaded(this.jobs);
}

class ManageJobsError extends ManageJobsState {
  final String message;
  ManageJobsError(this.message);
}

// สร้าง Cubit
class ManageJobsCubit extends Cubit<ManageJobsState> {
  final ApiService _apiService;

  ManageJobsCubit(this._apiService) : super(ManageJobsInitial());

  Future<void> fetchJobs() async {
    emit(ManageJobsLoading());
    try {
      final employerId = SessionService.instance.employerId;
      final jobs = await _apiService.getEmployerJobs(employerId);
      emit(ManageJobsLoaded(jobs));
    } catch (e) {
      emit(ManageJobsError("ไม่สามารถดึงข้อมูลได้: ${e.toString()}"));
    }
  }

160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192

return BlocProvider.value(
  value: _manageJobsCubit,
  child: Scaffold(
    appBar: AppBar(
      title: const Text('จัดการประกาศงาน'),

    ),
    body: BlocBuilder<ManageJobsCubit, ManageJobsState>(
      builder: (context, state) {
        if (state is ManageJobsLoading || state is ManageJobsInitial) {
          return const Center(child: CircularProgressIndicator());
        }

        if (state is ManageJobsError) {
          return Center(
            child: Column(
              mainAxisAlignment: MainAxisAlignment.center,
              children: [
                const Icon(Icons.error_outline, size: 48, color: AppTheme.error),
                const SizedBox(height: 12),
                Text(state.message, style: const TextStyle(color: AppTheme.error)),
                const SizedBox(height: 16),
                ElevatedButton.icon(
                  onPressed: () => _manageJobsCubit.fetchJobs(),
                  icon: const Icon(Icons.refresh),
                  label: const Text('ลองใหม่'),
                ),
              ],
            ),
          );
        }

        if (state is ManageJobsLoaded) {

203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242

try {
  Position position = await Geolocator.getCurrentPosition(
    locationSettings: const LocationSettings(
      accuracy: LocationAccuracy.high,
    ),
  );
  double realLat = position.latitude;
  double realLng = position.longitude;
  String locationName = '';

  try {
    List<Placemark> placemarks = await placemarkFromCoordinates(
      realLat,
      realLng,
    );
    if (placemarks.isNotEmpty) {
      Placemark place = placemarks[0];
      locationName =
          place.street ??
          place.subLocality ??
          place.locality ??
          place.subAdministrativeArea ??
          place.administrativeArea ??
          '';
    }
  } catch (e) {
    debugPrint('ไม่สามารถแปลงพิกัดเป็นชื่อเมืองได้: $e');
  }

  if (locationName.isEmpty) {
    locationName =
        'พิกัด ${realLat.toStringAsFixed(6)}, ${realLng.toStringAsFixed(6)}';
  }

  if (!mounted) return;
  setState(() {
    _latitude = realLat.toString();
    _longitude = realLng.toString();
    _jobLocationController.text = locationName;
  });

261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297

Future<void> _handlePostJob() async {
  if (!_formKey.currentState!.validate()) return;
  setState(() => _isLoading = true);

  final employerId = SessionService.instance.employerId;
  final vacancy = int.tryParse(_vacancyController.text.trim()) ?? 1;

  final Map<String, dynamic> res;
  if (_isEditMode) {
    res = await ApiService().updateJob(
      jobId: widget.editJob!.jobId,
      jobTitle: _jobTitleController.text.trim(),
      jobDescription: _jobDescriptionController.text.trim(),
      qualifications: _qualificationsController.text.trim(),
      jobLocation: _jobLocationController.text.trim(),
      requiredSkills: _requiredSkillsController.text.trim(),
      jobType: _selectedJobType,
      salary: _salaryController.text.trim().replaceAll(',', ''),
      vacancy: vacancy,
      latitude: _latitude,
      longitude: _longitude,
    );
  } else {
    res = await ApiService().postJob(
      employerId: employerId,
      jobTitle: _jobTitleController.text.trim(),
      jobDescription: _jobDescriptionController.text.trim(),
      qualifications: _qualificationsController.text.trim(),
      jobLocation: _jobLocationController.text.trim(),
      requiredSkills: _requiredSkillsController.text.trim(),
      jobType: _selectedJobType,
      salary: _salaryController.text.trim().replaceAll(',', ''),
      vacancy: vacancy,
      latitude: _latitude,
      longitude: _longitude,
    );
  }

57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

Future<void> _fetchAll() async {
  setState(() => _isLoading = true);

  final employerId = SessionService.instance.employerId;
  final results = await Future.wait([
    ApiService().getApplicationsByJob(widget.jobId),
    ApiService().getEmployerJobs(employerId),
  ]);

  if (!mounted) return;

  final candidates = results[0] as List<ApplicationModel>;
  final jobs = results[1] as List<JobPostingModel>;
  JobPostingModel? job;
  for (final j in jobs) {
    if (j.jobId == widget.jobId) {
      job = j;
      break;
    }
  }

  setState(() {
    _candidates = candidates;
    _job = job;
    _isLoading = false;
  });
}

85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106

Future<void> _updateStatus(ApplicationModel cand, String newStatus) async {
  if (newStatus == kAcceptedStatus && (_job?.isFull ?? false)) {
    ScaffoldMessenger.of(context).showSnackBar(
      const SnackBar(content: Text('รับครบตามจำนวนที่กำหนดแล้ว'), backgroundColor: AppTheme.error),
    );
    return;
  }

  // รับเข้าทำงาน -> ให้เลือกวันเริ่มงานก่อน (กดยกเลิก = ไม่เปลี่ยนสถานะ)
  HireDetails? hire;
  if (newStatus == kAcceptedStatus) {
    hire = await showHireDialog(context, candidateName: cand.fullname);
    if (hire == null || !mounted) return;
  }

  setState(() => _isUpdatingStatus = true);
  final res = await ApiService().updateApplicationStatus(
    cand.applicationId,
    newStatus,
    startDate: hire?.startDate,
    message: hire?.message,
  );

53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

Future<void> _updateStatus(String newStatus) async {
  // รับเข้าทำงาน -> ให้เลือกวันเริ่มงานก่อน (กดยกเลิก = ไม่เปลี่ยนสถานะ)
  HireDetails? hire;
  if (newStatus == AppConstants.statusPassed) {
    hire = await showHireDialog(context, candidateName: _application?.fullname);
    if (hire == null || !mounted) return;
  }
  final res = await ApiService().updateApplicationStatus(
    widget.applicationId,
    newStatus,
    startDate: hire?.startDate,
    message: hire?.message,
  );
  if (!mounted) return;
  if (res['success'] == true) {
    ScaffoldMessenger.of(context).showSnackBar(
      SnackBar(content: Text('อัปเดตสถานะเป็น "$newStatus" สำเร็จ'), backgroundColor: AppTheme.success),
    );
    _loadCandidateDetail();
  } else {
    ScaffoldMessenger.of(context).showSnackBar(
      SnackBar(content: Text(res['message'] ?? 'อัปเดตสถานะไม่สำเร็จ'), backgroundColor: AppTheme.error),
    );
  }
}

47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

Future<void> _selectDate() async {
  final picked = await showDatePicker(
    context: context,
    initialDate: DateTime.now().add(const Duration(days: 1)),
    firstDate: DateTime.now(),
    lastDate: DateTime.now().add(const Duration(days: 90)),
  );
  if (picked != null) {
    setState(() {
      _dateValue = "${picked.year}-${picked.month.toString().padLeft(2, '0')}-${picked.day.toString().padLeft(2, '0')}";
      _dateController.text = formatThaiDate(_dateValue);
    });
  }
}

Future<void> _selectTime() async {
  final picked = await showTimePicker(
    context: context,
    initialTime: const TimeOfDay(hour: 10, minute: 0),
  );
  if (picked != null) {
    final hhmm = "${picked.hour.toString().padLeft(2, '0')}:${picked.minute.toString().padLeft(2, '0')}";
    setState(() {
      _timeValue = '$hhmm:00';
      _timeController.text = '$hhmm น.';
    });
  }
}

87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

onTap: () async {
  if (!noti.isRead) {
    await ApiService().markNotificationAsRead(noti.notiId);
    _loadNotifications();
  }

  if (noti.type.startsWith('application_')) {
    final parts = noti.type.split('_');
    if (parts.length > 1) {
      final jobId = parts[1];
      if (context.mounted) {
        context.push('/home/candidates/$jobId');
      }
      return;
    }

61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

Future<void> _pickAndUploadImage({bool cover = false}) async {
  final picker = ImagePicker();
  final pickedFile = await picker.pickImage(
    source: ImageSource.gallery,
    // ภาพปกเป็นแนวนอนเต็มความกว้าง จึงให้ความละเอียดมากกว่าโลโก้
    maxWidth: cover ? 1600 : 800,
    maxHeight: cover ? 900 : 800,
    imageQuality: 85,
  );

  if (pickedFile == null) return;

  setState(() => _isUploading = true);
  final userId = SessionService.instance.userId;

  final res = await ApiService().uploadProfileImage(
    userId: userId,
    role: 'employer',
    bytes: await pickedFile.readAsBytes(),
    fileName: pickedFile.name,
    kind: cover ? 'cover' : null,
  );

  setState(() => _isUploading = false);

  if (!mounted) return;

  if (res['success'] == true && res['image_url'] != null) {
    final imageUrl = res['image_url'] as String;
    if (!cover) await SessionService.instance.updateProfileImage(imageUrl);
    await _loadProfile();

66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

Future<void> _fetchJobs({bool silent = false}) async {
  // silent = รีเฟรชเบื้องหลัง ไม่แสดงวงหมุน และถ้าโหลดไม่สำเร็จก็คงรายการเดิมไว้
  if (!silent) setState(() => _isLoading = true);
  final userId = SessionService.instance.userId;
  if (userId <= 0) {
    if (mounted) setState(() => _isLoading = false);
    return;
  }

  final res = await ApiService().getJobsForSeeker(userId);
  if (!mounted) return;

  if (res['success'] == true && res['data'] is List) {
    final list = (res['data'] as List)
        .map((j) => JobPostingModel.fromJson(j))
        .toList();

    // งานแนะนำ: คะแนนถึงระดับ "เหมาะสมดี" ขึ้นไป ตามเกณฑ์ที่ Admin ตั้ง (ตารางที่ 2.1)
    final matched = list.where((j) => j.isRecommended).toList();

    // งานที่น่าสนใจ: เอางานที่เหลือที่ไม่ได้อยู่ใน matched มาแสดงเป็นงานมาใหม่
    final interesting = list.where((j) => !j.isRecommended).toList();
    // เรียงตามคะแนนความเหมาะสมก่อน (ขอบเขต 1.3.4.4) คะแนนเท่ากันเอางานใหม่ขึ้นก่อน
    interesting.sort((a, b) {
      final byScore = b.matchScore.compareTo(a.matchScore);
      return byScore != 0 ? byScore : b.jobId.compareTo(a.jobId);
    });

    setState(() {
      _allJobs = list;
      _filteredJobs = matched;
      _interestingJobs = interesting;
      _isLoading = false;
    });
  } else if (!silent) {
    setState(() => _isLoading = false);
  }
}

73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

/// ขอตำแหน่ง GPS ปัจจุบัน (ถ้าผู้ใช้ไม่อนุญาต จะใช้พิกัดในโปรไฟล์แทนที่ backend)
Future<Position?> _currentPosition() async {
  try {
    if (!canUseGps) return null; // เว็บแบบ http: ไม่รอ GPS ให้โหลดรายการงานทันที
    if (!await Geolocator.isLocationServiceEnabled()) return null;
    var permission = await Geolocator.checkPermission();
    if (permission == LocationPermission.denied) {
      permission = await Geolocator.requestPermission();
    }
    if (permission == LocationPermission.denied || permission == LocationPermission.deniedForever) {
      return null;
    }
    return await Geolocator.getCurrentPosition(
      locationSettings: const LocationSettings(accuracy: LocationAccuracy.medium),
    ).timeout(const Duration(seconds: 8));
  } catch (_) {
    return null;
  }
}

Future<void> _fetchJobs() async {
  setState(() => _isLoading = true);
  // จำกัดเวลารอ GPS/หน้าต่างขออนุญาต ไม่ให้รายการงานค้าง ถ้าเกินเวลาใช้พิกัดในโปรไฟล์แทน
  final position = await _currentPosition()
      .timeout(const Duration(seconds: 6), onTimeout: () => null);
  final res = await ApiService().getJobsForSeeker(
    SessionService.instance.userId,
    lat: position?.latitude,
    lng: position?.longitude,
  );
  if (!mounted) return;

  if (res['success'] == true && res['data'] is List) {
    final origin = res['origin'];
    setState(() {
      _allJobs = (res['data'] as List).map((j) => JobPostingModel.fromJson(j)).toList();
      _origin = origin is Map
          ? LatLng((origin['lat'] as num).toDouble(), (origin['lng'] as num).toDouble())
          : null;
      _isLoading = false;
    });
    _applyFilters();
  } else {
    setState(() => _isLoading = false);
  }
}

120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154

void _applyFilters() {
  final q = _searchController.text.trim().toLowerCase();
  final result = _allJobs.where((j) {
    if (q.isNotEmpty) {
      final haystack = [
        j.jobTitle,
        j.companyName ?? '',
        j.jobLocation,
        j.jobType,
        j.requiredSkills.join(' '),
      ].join(' ').toLowerCase();
      if (!haystack.contains(q)) return false;
    }
    if (_jobTypes.isNotEmpty && !_jobTypes.contains(j.jobType)) return false;
    if (_maxDistanceKm != null && (j.distanceKm == null || j.distanceKm! > _maxDistanceKm!)) return false;
    if (_minSalary != null && (j.salaryValue == null || j.salaryValue! < _minSalary!)) return false;
    return true;
  }).toList();

  int compareNullable(double? a, double? b, {bool descending = false}) {
    if (a == null && b == null) return 0;
    if (a == null) return 1; // ไม่มีข้อมูลไว้ท้ายสุด
    if (b == null) return -1;
    return descending ? b.compareTo(a) : a.compareTo(b);
  }

  result.sort((a, b) => switch (_sortBy) {
        _SortBy.match => b.matchScore.compareTo(a.matchScore),
        _SortBy.distance => compareNullable(a.distanceKm, b.distanceKm),
        _SortBy.salary => compareNullable(a.salaryValue, b.salaryValue, descending: true),
        _SortBy.newest => b.jobId.compareTo(a.jobId),
      });

  setState(() => _filteredJobs = result);
}

32
33
34
35
36
37
38
39
40
41
42
43

/// งานหลายตำแหน่งที่พิกัดเดียวกันจะซ้อนกัน จึงรวมเป็นกลุ่มต่อพิกัด
Map<LatLng, List<JobPostingModel>> get _groupedJobs {
  final groups = <LatLng, List<JobPostingModel>>{};
  for (final job in _jobsWithLocation) {
    final point = LatLng(
      double.parse(job.latitude!.toStringAsFixed(4)),
      double.parse(job.longitude!.toStringAsFixed(4)),
    );
    groups.putIfAbsent(point, () => []).add(job);
  }
  return groups;
}

111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156

FlutterMap(
  mapController: _mapController,
  options: MapOptions(
    initialCenter: _initialCenter,
    initialZoom: widget.origin != null ? 11 : 6,
    onTap: (_, __) => setState(() => _selected = null),
  ),
  children: [
    TileLayer(
      urlTemplate: 'https://tile.openstreetmap.org/{z}/{x}/{y}.png',
      userAgentPackageName: 'com.jobmatch.jobmatch_employer',
    ),
    MarkerLayer(
      markers: [
        if (widget.origin != null)
          Marker(
            point: widget.origin!,
            width: 26,
            height: 26,
            child: Container(
              decoration: BoxDecoration(
                color: AppTheme.primaryLight,
                shape: BoxShape.circle,
                border: Border.all(color: Colors.white, width: 3),
                boxShadow: const [BoxShadow(color: Colors.black26, blurRadius: 4)],
              ),
            ),
          ),
        for (final entry in groups.entries)
          Marker(
            point: entry.key,
            width: 44,
            height: 44,
            alignment: Alignment.topCenter,
            child: GestureDetector(
              onTap: () => _showJobsAt(entry.value),
              child: _JobPin(jobs: entry.value),
            ),
          ),
      ],
    ),
    const RichAttributionWidget(
      attributions: [TextSourceAttribution('OpenStreetMap contributors')],
    ),
  ],
),

136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193

Future<void> _checkApplicationStatus() async {
  final seekerId = SessionService.instance.seekerId;
  if (seekerId <= 0) return;

  final apps = await ApiService().getApplicationsBySeeker(seekerId);
  final found = apps
      .where(
        (a) => a.jobId == widget.jobId && a.status != _cancelledStatus,
      )
      .toList();

  if (!mounted) return;
  setState(() {
    _myApplication = found.isNotEmpty ? found.first : null;
  });
}

Future<void> _handleApply() async {
  final seekerId = SessionService.instance.seekerId;
  if (seekerId <= 0) {
    ScaffoldMessenger.of(context).showSnackBar(
      const SnackBar(
        content: Text('กรุณาล็อกอินด้วยบัญชีผู้หางานก่อนสมัครงาน'),
        backgroundColor: AppTheme.error,
      ),
    );
    return;
  }

  setState(() => _isApplying = true);
  final res = await ApiService().applyJob(
    jobId: widget.jobId,
    seekerId: seekerId,
  );

  if (!mounted) return;

  if (res['success'] == true) {
    // ดึงสถานะใบสมัครล่าสุดมาแสดง เพื่อสลับปุ่มเป็น "ยกเลิกการสมัคร"
    await _checkApplicationStatus();
    if (!mounted) return;
    setState(() => _isApplying = false);
    ScaffoldMessenger.of(context).showSnackBar(
      const SnackBar(
        content: Text('สมัครงานสำเร็จแล้ว! นายจ้างจะพิจารณาในลำดับถัดไป'),
        backgroundColor: AppTheme.success,
      ),
    );
  } else {
    setState(() => _isApplying = false);
    ScaffoldMessenger.of(context).showSnackBar(
      SnackBar(
        content: Text(res['message'] ?? 'เกิดข้อผิดพลาดในการสมัครงาน'),
        backgroundColor: AppTheme.error,
      ),
    );
  }
}

45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

// หยุด/เริ่มโพลใหม่ตามสถานะแอป จะได้ไม่ยิง request ทิ้งขว้างตอนแอปอยู่เบื้องหลัง
@override
void didChangeAppLifecycleState(AppLifecycleState state) {
  if (state == AppLifecycleState.resumed) {
    _startPolling();
    _fetchApplications(silent: true);
  } else {
    _pollTimer?.cancel();
  }
}

void _startPolling() {
  _pollTimer?.cancel();
  _pollTimer = Timer.periodic(_pollInterval, (_) => _fetchApplications(silent: true));
}

// silent = true: รีเฟรชเบื้องหลังแบบเงียบๆ (ใช้กับ polling) ไม่โชว์ spinner เต็มจอ
Future<void> _fetchApplications({bool silent = false}) async {
  if (!silent) setState(() => _isLoading = true);

  final seekerId = SessionService.instance.seekerId;
  final list = await ApiService().getApplicationsBySeeker(seekerId);
  if (!mounted) return;

  // เทียบสถานะเก่ากับใหม่ เพื่อแจ้งเตือนผู้ใช้เมื่อมีอะไรเปลี่ยน (สไตล์ real-time)
  final changedTitles = <String>[];
  for (final app in list) {
    final prevStatus = _lastKnownStatuses[app.applicationId];
    if (prevStatus != null && prevStatus != app.status) {
      changedTitles.add(app.jobTitle ?? 'ตำแหน่งงาน');
    }
  }
  _lastKnownStatuses = {for (final a in list) a.applicationId: a.status};

  setState(() {
    _applications = list;
    _isLoading = false;
  });

  if (changedTitles.isNotEmpty) {
    ScaffoldMessenger.of(context).showSnackBar(
      SnackBar(
        content: Text('สถานะอัปเดต: ${changedTitles.join(", ")}'),
        backgroundColor: AppTheme.primary,
        behavior: SnackBarBehavior.floating,
        shape: RoundedRectangleBorder(borderRadius: BorderRadius.circular(12)),
        margin: const EdgeInsets.all(16),
      ),
    );
  }
}

151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184

Future<void> _respondToOffer(ApplicationModel app, bool accept) async {
  final confirm = await showDialog<bool>(
    context: context,
    builder: (context) => AlertDialog(
      title: Text(accept ? 'ยืนยันตอบรับงาน' : 'ยืนยันปฏิเสธงาน'),
      content: Text(
        accept
            ? 'คุณต้องการตอบรับตำแหน่ง "${app.jobTitle ?? ''}" ใช่หรือไม่?'
            : 'คุณต้องการปฏิเสธตำแหน่ง "${app.jobTitle ?? ''}" ใช่หรือไม่? การตัดสินใจนี้ไม่สามารถย้อนกลับได้',
      ),
      actions: [
        TextButton(
          onPressed: () => Navigator.pop(context, false),
          child: const Text('ยกเลิก', style: TextStyle(color: Colors.grey)),
        ),
        ElevatedButton(
          onPressed: () => Navigator.pop(context, true),
          style: ElevatedButton.styleFrom(
            backgroundColor: accept ? AppTheme.success : Colors.red,
            foregroundColor: Colors.white,
          ),
          child: Text(accept ? 'ตอบรับ' : 'ปฏิเสธ'),
        ),
      ],
    ),
  );

  if (confirm != true) return;
  if (!mounted) return;

  setState(() => _isLoading = true);
  final res = await ApiService().updateApplicationStatus(
    app.applicationId,
    accept ? _acceptedStatus : _rejectedStatus,

43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

// แจ้งเตือนงานแนะนำ (recommend_job_<job_id>) -> เปิดหน้ารายละเอียดงานนั้น
int? _recommendedJobId(String type) =>
    type.startsWith('recommend_job_') ? int.tryParse(type.substring('recommend_job_'.length)) : null;

// แจ้งเตือนเรื่องใบสมัคร (application_<job_id>: นัดสัมภาษณ์ / ผลการพิจารณา) -> ไปแท็บ "งานของฉัน"
bool _isApplicationUpdate(String type) => type.startsWith('application_');

bool _hasDestination(String type) => _recommendedJobId(type) != null || _isApplicationUpdate(type);

IconData _getIconForType(NotificationModel n) => notificationVisual(n).icon;

Color _getColorForType(NotificationModel n) => notificationVisual(n).color;

// แตะแจ้งเตือน -> ทำเครื่องหมายว่าอ่านแล้ว (แจ้งเตือนยังอยู่ในรายการแต่จางลง) แล้วพาไปหน้าที่เกี่ยวข้อง
Future<void> _handleTap(int index) async {
  final item = _notifications[index];

  if (!item.isRead) {
    setState(() => _notifications[index] = _asRead(item));
    ApiService().markNotificationAsRead(item.notiId).then((res) {
      if (res['success'] != true && mounted) {
        // บันทึกไม่สำเร็จ -> คืนสถานะยังไม่อ่าน
        setState(() => _notifications[index] = item);
      }
    });
  }

  final jobId = _recommendedJobId(item.type);
  if (jobId != null) {
    context.push('/seeker-home/job/$jobId');
  } else if (_isApplicationUpdate(item.type)) {
    context.pop(kOpenApplicationsTab);
  }
}

289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321

Future<void> _pickAndUploadDocument(String type) async {
  if (!_isEditing) return;
  final label = type == 'portfolio' ? 'Portfolio' : 'Resume';
  try {
    final result = await FilePicker.platform.pickFiles(
      type: FileType.custom,
      allowedExtensions: ['pdf'],
      withData: true,
    );
    if (result == null || !mounted) return;
    final file = result.files.single;

    String? error;
    if (!file.name.toLowerCase().endsWith('.pdf')) {
      error = 'กรุณาเลือกไฟล์ PDF เท่านั้น';
    } else if (file.size > _maxDocumentBytes) {
      error = 'ไฟล์มีขนาดเกิน 5 MB';
    }
    if (error != null) {
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(content: Text(error), backgroundColor: AppTheme.error),
      );
      return;
    }

    setState(() => _isSaving = true);
    final res = await ApiService().uploadResume(
      userId: SessionService.instance.userId,
      filePath: file.path,
      bytes: file.bytes,
      fileName: file.name,
      type: type,
    );

420
421
422
423
424
425
426
427

String? get _effectiveCategory {
  if (_jobCategories.containsKey(_selectedCategory)) return _selectedCategory;
  final skills = _skillsController.text.split(',').map((s) => s.trim()).where((s) => s.isNotEmpty).toSet();
  for (final entry in _jobCategories.entries) {
    if (entry.value.any(skills.contains)) return entry.key;
  }
  return null;
}

547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571

String finalProfileDetail = _experienceController.text.trim();
if (_selectedCategory != null) {
  finalProfileDetail = "ความสนใจ: $_selectedCategory\n\n$finalProfileDetail";
}

// ยังไม่เคยมีที่อยู่ ช่องกรอกจะเปิดอยู่แล้วโดยไม่ต้องกด "เปลี่ยนที่อยู่"
final changingAddress = _isChangingAddress || _addressController.text.trim().isEmpty;
final address = changingAddress && _addressInput.isComplete
    ? _addressInput.fullAddress
    : _addressController.text.trim();

final res = await ApiService().updateSeekerProfile(
  userId: userId,
  name: _nameController.text.trim(),
  phone: _phoneController.text.trim(),
  skills: _skillsController.text.trim(),
  profileDetail: finalProfileDetail.trim(),
  address: address,
  age: int.tryParse(_ageController.text.trim()) ?? 0,
  idCard: _idCardController.text.trim(),
  dateOfBirth: _formatDateForApi(_dobController.text.trim()),
  education: _selectedEducation ?? '',
  gender: _selectedGender ?? 'ไม่ระบุ',
  experience: _experienceController.text.trim(),
);

32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

@override
void initState() {
  super.initState();
  _fetchMessages();
  // Polling ข้อความใหม่ทุก 3 วินาที
  _timer = Timer.periodic(const Duration(seconds: 3), (_) => _fetchMessages(silent: true));
}

@override
void dispose() {
  _timer?.cancel();
  _messageController.dispose();
  _scrollController.dispose();
  super.dispose();
}

Future<void> _fetchMessages({bool silent = false}) async {
  if (!silent) setState(() => _isLoading = true);
  final senderId = SessionService.instance.userId;

  if (senderId <= 0) {
    if (!silent && mounted) {
      setState(() => _isLoading = false);
      ScaffoldMessenger.of(context).showSnackBar(
        const SnackBar(
          content: Text('ไม่พบข้อมูลผู้ใช้งาน กรุณาล็อกอินใหม่'),
          backgroundColor: AppTheme.error,
        ),
      );
    }
    return;
  }

  final msgs = await ApiService().getMessages(senderId, widget.receiverId);
  if (!mounted) return;
  setState(() {
    _messages = msgs;
    if (!silent) _isLoading = false;
  });
  if (_messages.isNotEmpty && !silent) {
    _scrollToBottom();
  }
}

void _scrollToBottom() {
  WidgetsBinding.instance.addPostFrameCallback((_) {
    if (_scrollController.hasClients) {
      _scrollController.animateTo(
        _scrollController.position.maxScrollExtent,
        duration: const Duration(milliseconds: 300),
        curve: Curves.easeOut,
      );
    }
  });
}

5
6
7
8
9
10
11
12
13
14
15
16

Color matchLevelColor(String level) {
  switch (level) {
    case 'very_high':
      return const Color(0xFF047857);
    case 'good':
      return AppTheme.primary;
    case 'medium':
      return const Color(0xFFB45309);
    default:
      return AppTheme.textSecondary;
  }
}

79
80
81
82
83
84
85
86
87
88

onPressed: () {
  if (startDate == null) {
    setDialogState(() => error = 'กรุณาเลือกวันเริ่มงาน');
    return;
  }
  Navigator.pop(
    dialogContext,
    HireDetails(startDate!.toIso8601String().substring(0, 10), messageController.text.trim()),
  );
},

58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86

void deleteNotificationWithUndo(
  BuildContext context, {
  required NotificationModel item,
  required VoidCallback onRemove,
  required VoidCallback onRestore,
}) {
  onRemove();
  final messenger = ScaffoldMessenger.of(context);
  messenger.hideCurrentSnackBar();
  messenger
      .showSnackBar(
        SnackBar(
          content: const Text('ลบการแจ้งเตือนแล้ว'),
          duration: const Duration(seconds: 4),
          action: SnackBarAction(label: 'เลิกทำ', textColor: AppTheme.primaryLight, onPressed: onRestore),
        ),
      )
      .closed
      .then((reason) async {
    if (reason == SnackBarClosedReason.action) return;
    final res = await ApiService().deleteNotification(item.notiId);
    if (res['success'] != true) {
      onRestore();
      messenger.showSnackBar(
        const SnackBar(content: Text('ลบการแจ้งเตือนไม่สำเร็จ ลองใหม่อีกครั้ง'), backgroundColor: AppTheme.error),
      );
    }
  });
}

6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

class ThaiAddressInputController {
  final TextEditingController detail = TextEditingController();
  final ThaiAddressController thai = ThaiAddressController();

  bool get isComplete =>
      detail.text.trim().isNotEmpty &&
      thai.province != null &&
      thai.district != null &&
      thai.subdistrict != null;

  /// ที่อยู่รวมเป็นข้อความเดียว เช่น "99/1 ต.ในเมือง อ.เมืองขอนแก่น จ.ขอนแก่น 40000"
  /// (backend ใช้รูปแบบ ต./อ./จ. นี้หาพิกัดของตำบล)
  String get fullAddress {
    final sub = thai.subdistrict;
    return '${detail.text.trim()} ต.${sub?.nameTh ?? ''} อ.${thai.district?.nameTh ?? ''} '
            'จ.${thai.province?.nameTh ?? ''} ${sub?.postcode ?? ''}'
        .trim();
  }

7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

// ปิดการแสดง error เป็น HTML (ป้องกัน <br /> ปนใน JSON response)
ini_set('display_errors', '0');
error_reporting(E_ALL);
ini_set('log_errors', '1');

header('Content-Type: application/json; charset=utf-8');
header('Access-Control-Allow-Origin: *');
header('Access-Control-Allow-Methods: POST, GET, PUT, OPTIONS');
header('Access-Control-Allow-Headers: Content-Type, Authorization, X-User-Id');

if ($_SERVER['REQUEST_METHOD'] === 'OPTIONS') {
    http_response_code(200);
    exit();
}

$host = 'localhost';
$db   = 'job_matching_system';
$user = 'root';
$pass = '';

try {
    $pdo = new PDO("mysql:host=$host;dbname=$db;charset=utf8mb4", $user, $pass, [
        PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
        PDO::ATTR_EMULATE_PREPARES   => false,
    ]);
} catch (PDOException $e) {
    http_response_code(500);
    error_log('db_connect: ' . $e->getMessage());
    echo json_encode(['success' => false, 'message' => 'เกิดข้อผิดพลาดของระบบ กรุณาลองใหม่อีกครั้ง'], JSON_UNESCAPED_UNICODE);
    exit();
}

8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

/** user_id ของผู้ใช้ที่ล็อกอินอยู่ แอปส่งมาใน header "X-User-Id" ทุกคำขอ (0 = ไม่ได้ล็อกอิน) */
function requestUserId(): int {
    $value = $_SERVER['HTTP_X_USER_ID'] ?? '';
    return ctype_digit(trim((string) $value)) ? (int) $value : 0;
}

function authFail(int $code, string $message): void {
    http_response_code($code);
    echo json_encode(['success' => false, 'message' => $message, 'auth_error' => $code === 401], JSON_UNESCAPED_UNICODE);
    exit;
}

/**
 * คืนข้อมูลผู้ใช้ที่ล็อกอินอยู่: ['user_id', 'role', 'seeker_id' | null, 'employer_id' | null]
 * $required = false ใช้กับ endpoint ที่ดูได้โดยไม่ต้องล็อกอิน (คืน null ถ้าไม่ได้ส่ง user_id)
 */
function currentUser(PDO $pdo, bool $required = true): ?array {
    static $user = false;
    if ($user !== false) return $user;

    $userId = requestUserId();
    if ($userId === 0) {
        if ($required) authFail(401, 'กรุณาเข้าสู่ระบบใหม่อีกครั้ง');
        return $user = null;
    }

    $stmt = $pdo->prepare('
        SELECT m.user_id, m.role, m.status, js.seeker_id, e.employer_id
        FROM member m
        LEFT JOIN job_seeker js ON js.user_id = m.user_id
        LEFT JOIN employer e ON e.user_id = m.user_id
        WHERE m.user_id = ?
        LIMIT 1
    ');
    $stmt->execute([$userId]);
    $row = $stmt->fetch();

    if (!$row) {
        if ($required) authFail(401, 'ไม่พบบัญชีผู้ใช้ กรุณาเข้าสู่ระบบใหม่อีกครั้ง');
        return $user = null;
    }
    if (($row['status'] ?? 'active') !== 'active') {
        authFail(403, 'บัญชีของคุณถูกระงับการใช้งาน');
    }

    return $user = [
        'user_id'     => (int) $row['user_id'],
        'role'        => $row['role'],
        'seeker_id'   => $row['seeker_id'] !== null ? (int) $row['seeker_id'] : null,
        'employer_id' => $row['employer_id'] !== null ? (int) $row['employer_id'] : null,
    ];
}

61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

function requireSeeker(PDO $pdo): array {
    $user = currentUser($pdo);
    if ($user['seeker_id'] === null) authFail(403, 'เฉพาะผู้หางานเท่านั้น');
    return $user;
}

function requireEmployer(PDO $pdo): array {
    $user = currentUser($pdo);
    if ($user['employer_id'] === null) authFail(403, 'เฉพาะผู้ว่าจ้างเท่านั้น');
    return $user;
}

/** ปฏิเสธคำขอถ้าเงื่อนไขความเป็นเจ้าของไม่ผ่าน */
function ensureOwner(bool $isOwner): void {
    if (!$isOwner) authFail(403, 'คุณไม่มีสิทธิ์เข้าถึงข้อมูลนี้');
}

function employerOwnsJob(PDO $pdo, int $employerId, int $jobId): bool {
    $stmt = $pdo->prepare('SELECT COUNT(*) FROM job_posting WHERE job_id = ? AND employer_id = ?');
    $stmt->execute([$jobId, $employerId]);
    return $stmt->fetchColumn() > 0;
}

/** ข้อมูลเจ้าของใบสมัคร: seeker_id ของผู้สมัคร และ employer_id ของงาน */
function applicationOwners(PDO $pdo, int $applicationId): ?array {
    $stmt = $pdo->prepare('
        SELECT a.seeker_id, j.employer_id
        FROM application a JOIN job_posting j ON a.job_id = j.job_id
        WHERE a.application_id = ?
    ');
    $stmt->execute([$applicationId]);
    $row = $stmt->fetch();
    return $row ? ['seeker_id' => (int) $row['seeker_id'], 'employer_id' => (int) $row['employer_id']] : null;
}

1
2
3
4
5

# ไฟล์ตั้งค่าและไฟล์ฟังก์ชันภายใน ห้ามเรียกตรงจากเว็บ
<FilesMatch "^(config|db_connect|api_auth|matching_service|skill_matcher|pdf_text|ai_service|geocode_service)\.php$">
    Require all denied
</FilesMatch>
Options -Indexes

45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

$storedPassword = $user['password'];
$isBcryptHash = password_get_info($storedPassword)['algo'] !== null;

if ($isBcryptHash) {
    $isValid = password_verify($password, $storedPassword);
} else {
    $isValid = hash_equals($storedPassword, $password);
    if ($isValid) {
        $newHash = password_hash($password, PASSWORD_DEFAULT);
        $upd = $pdo->prepare('UPDATE member SET password = ? WHERE user_id = ?');
        $upd->execute([$newHash, $user['user_id']]);
    }
}

if (!$isValid) {
    http_response_code(401);
    echo json_encode(['success' => false, 'message' => 'อีเมลหรือรหัสผ่านไม่ถูกต้อง']);
    exit();
}

75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101

if ($user['role'] === 'employer') {
    $empStmt = $pdo->prepare('SELECT employer_id, company_name, company_detail, contact_phone, company_address FROM employer WHERE user_id = ? LIMIT 1');
    $empStmt->execute([$user['user_id']]);
    $emp = $empStmt->fetch(PDO::FETCH_ASSOC);
    if ($emp) {
        $emp['employer_id'] = (int) $emp['employer_id'];
        $data = array_merge($data, $emp);
    }
} elseif ($user['role'] === 'seeker') {
    $seekerStmt = $pdo->prepare('SELECT seeker_id, fullname, age, date_of_birth, education, phone, skills, profile_detail, address FROM job_seeker WHERE user_id = ? LIMIT 1');
    $seekerStmt->execute([$user['user_id']]);
    $seeker = $seekerStmt->fetch(PDO::FETCH_ASSOC);
    if (!$seeker) {
        // บัญชีเก่าที่ยังไม่มีโปรไฟล์ผู้หางาน -> สร้างโปรไฟล์เปล่าให้ จะได้สมัครงานและกรอกทักษะได้
        $pdo->prepare('INSERT INTO job_seeker (user_id, fullname, phone) VALUES (?, ?, ?)')
            ->execute([$user['user_id'], mb_substr($user['name'], 0, 50), mb_substr($user['phone'] ?? '', 0, 10)]);
        $seekerStmt->execute([$user['user_id']]);
        $seeker = $seekerStmt->fetch(PDO::FETCH_ASSOC);
    }
    if ($seeker) {
        $seeker['seeker_id'] = (int) $seeker['seeker_id'];
        if (isset($seeker['age'])) {
            $seeker['age'] = (int) $seeker['age'];
        }
        $data = array_merge($data, $seeker);
    }
}

84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140

$passwordHash = password_hash($password, PASSWORD_DEFAULT);

try {
    $pdo->beginTransaction();

    // 1. บันทึกลงตาราง member
    $stmt = $pdo->prepare('INSERT INTO member (name, email, password, role) VALUES (?, ?, ?, "seeker")');
    $stmt->execute([$name, $email, $passwordHash]);
    $userId = (int) $pdo->lastInsertId();

    // 2. บันทึกลงตาราง job_seeker (ครบถ้วนทั้ง 12 ฟิลด์ตรงกับโครงสร้างตาราง)[cite: 1]
    $stmt2 = $pdo->prepare('
        INSERT INTO job_seeker
        (user_id, fullname, age, date_of_birth, phone, gender, skills, profile_detail, education, experience, address, latitude, longitude)
        VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
    ');

    $stmt2->execute([
        $userId,
        $name,
        $age,
        $dob,
        $phone,
        $gender,
        $skills,
        $profileDetail,
        $education,
        $experience,
        $address,
        $latitude,
        $longitude
    ]);

    $seekerId = (int) $pdo->lastInsertId();

    $pdo->commit();

    // ผู้หางานใหม่ -> คำนวณการจับคู่กับงานทั้งหมด (ขอบเขต 1.3.4.6)
    try {
        recalculateAllMatching($pdo);
    } catch (PDOException $e) {
        error_log('register_seeker matching: ' . $e->getMessage());
    }

    http_response_code(201);
    echo json_encode([
        'success'   => true,
        'message'   => 'สมัครสมาชิกผู้หางานสำเร็จ',
        'user_id'   => $userId,
        'seeker_id' => $seekerId,
    ]);
} catch (PDOException $e) {
    $pdo->rollBack();
    http_response_code(500);
    error_log('register_seeker: ' . $e->getMessage());
    echo json_encode(['success' => false, 'message' => 'เกิดข้อผิดพลาดของระบบ กรุณาลองใหม่อีกครั้ง'], JSON_UNESCAPED_UNICODE);
}

57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

if ($normalizedRole === 'seeker') {
    $seekerStmt = $pdo->prepare(
        'SELECT seeker_id, fullname, age, date_of_birth, education, phone, gender, skills, experience, profile_detail, address,
                resume_url, resume_keywords, updated_at, profile_image
         FROM job_seeker WHERE user_id = ? LIMIT 1'
    );
    $seekerStmt->execute([$userId]);
    $seeker = $seekerStmt->fetch();
    if ($seeker) {
        $seeker['seeker_id'] = (int) $seeker['seeker_id'];
        // แปลง age ให้เป็น int ถ้ามีค่า
        if (isset($seeker['age'])) {
            $seeker['age'] = (int) $seeker['age'];
        }
        if (!$isSelf) {
            // ข้อมูลส่วนบุคคล: เลขบัตรประชาชนและวันเกิดให้เห็นเฉพาะเจ้าของบัญชี
            unset($seeker['date_of_birth'], $seeker['resume_keywords']);
        }
        $data = array_merge($data, $seeker);
    }

58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

// ผู้หางานตอบรับ/ปฏิเสธได้เฉพาะใบสมัครของตัวเอง ส่วนสถานะอื่นผู้ว่าจ้างเจ้าของงานเป็นคนเปลี่ยน
$isSeekerAction = in_array($status, $offerResponseStatuses, true);
ensureOwner($isSeekerAction
    ? $owners['seeker_id'] === $authUser['seeker_id']
    : $owners['employer_id'] === $authUser['employer_id']);

// ลำดับสถานะที่อนุญาต: รอดำเนินการ -> นัดสัมภาษณ์ -> ผ่าน/ไม่ผ่าน -> (ผู้หางาน) ตอบรับ/ปฏิเสธ
$currentStmt = $pdo->prepare('SELECT status FROM application WHERE application_id = ?');
$currentStmt->execute([$applicationId]);
$currentStatus = $currentStmt->fetchColumn();

if ($currentStatus === $status) {
    // กดซ้ำ -> ไม่ต้องบันทึกและไม่ส่งแจ้งเตือนซ้ำ
    echo json_encode(['success' => true, 'message' => 'สถานะนี้ถูกบันทึกไว้แล้ว', 'status' => $status]);
    exit();
}
if ($isSeekerAction && $currentStatus !== 'ผ่านการคัดเลือก') {
    http_response_code(409);
    echo json_encode(['success' => false, 'message' => 'ตอบรับหรือปฏิเสธได้เฉพาะเมื่อผ่านการคัดเลือกแล้ว']);
    exit();
}
if (!$isSeekerAction && in_array($currentStatus, $offerResponseStatuses, true)) {
    http_response_code(409);
    echo json_encode(['success' => false, 'message' => 'ผู้สมัครตอบกลับข้อเสนอแล้ว ไม่สามารถเปลี่ยนสถานะได้']);
    exit();
}

110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

// อัปเดตจำนวน hired_count ของงานนั้นใหม่ (นับเฉพาะคนที่ ผ่านการคัดเลือก หรือ ตอบรับงานแล้ว)
if ($jobId) {
    $updateHiredCountStmt = $pdo->prepare("
        UPDATE job_posting
        SET hired_count = (
            SELECT COUNT(*)
            FROM application
            WHERE job_id = ? AND status IN ('ผ่านการคัดเลือก', 'ตอบรับงานแล้ว')
        )
        WHERE job_id = ?
    ");
    $updateHiredCountStmt->execute([$jobId, $jobId]);

    // รับครบตามจำนวนที่เปิดรับแล้ว -> ปิดรับสมัครอัตโนมัติ, ถ้ากลับมาไม่ครบ (เช่น ผู้สมัครปฏิเสธ) -> เปิดรับอีกครั้ง
    $pdo->prepare("UPDATE job_posting SET status = 'closed' WHERE job_id = ? AND hired_count >= vacancy AND status IN ('open', 'approved')")->execute([$jobId]);
    $pdo->prepare("UPDATE job_posting SET status = 'approved' WHERE job_id = ? AND hired_count < vacancy AND status = 'closed'")->execute([$jobId]);
}

158
159
160
161
162
163
164
165
166
167
168
169
170
171
172

// ส่งผลการพิจารณาเข้าแชทด้วย (จากบริษัทถึงผู้สมัคร) เหมือนตอนนัดสัมภาษณ์
if ($status === 'ผ่านการคัดเลือก') {
    $chatMessage = "ยินดีด้วยครับ/ค่ะ คุณผ่านการคัดเลือกในตำแหน่ง " . $jobTitle;
    if ($startDate !== '') {
        $chatMessage .= "\nวันเริ่มงาน: " . date('d/m/Y', strtotime($startDate));
    }
    $chatMessage .= "\nกรุณากดตอบรับหรือปฏิเสธงานในหน้า \"งานของฉัน\"";
} else {
    $chatMessage = "ขอบคุณที่สนใจสมัครงานตำแหน่ง " . $jobTitle . " ขออภัย คุณไม่ผ่านการคัดเลือกในครั้งนี้";
}
if ($resultMessage !== '') {
    $chatMessage .= "\nเพิ่มเติม: " . $resultMessage;
}
$pdo->prepare('INSERT INTO message (sender_id, receiver_id, message, sent_date, is_read) VALUES (?, ?, ?, NOW(), 0)')
    ->execute([$info['employer_user_id'], $seekerUserId, $chatMessage]);

55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

// 1 ใบสมัครมีนัดสัมภาษณ์ได้ 1 นัด: ถ้ามีอยู่แล้วถือเป็นการเลื่อนนัด (แก้ไขนัดเดิม ไม่สร้างซ้ำ)
$existing = $pdo->prepare('SELECT interview_id, interview_date, interview_time, interview_type, location_link, additional_notes FROM interview WHERE application_id = ? ORDER BY interview_id DESC LIMIT 1');
$existing->execute([$applicationId]);
$existingRow = $existing->fetch();
$isReschedule = (bool) $existingRow;

if ($existingRow
    && $existingRow['interview_date'] === $interviewDate
    && substr($existingRow['interview_time'], 0, 5) === substr($interviewTime, 0, 5)
    && $existingRow['interview_type'] === $interviewType
    && $existingRow['location_link'] === $locationLink
    && $existingRow['additional_notes'] === $additionalNotes) {
    // ข้อมูลเหมือนเดิมทุกอย่าง (เช่น กดปุ่มซ้ำ) -> ไม่ส่งแจ้งเตือน/แชทซ้ำ
    echo json_encode(['success' => true, 'message' => 'นัดสัมภาษณ์นี้ถูกบันทึกไว้แล้ว', 'interview_id' => (int) $existingRow['interview_id']]);
    exit();
}

if ($isReschedule) {
    $interviewId = (int) $existingRow['interview_id'];
    $pdo->prepare('UPDATE interview SET interview_date = ?, interview_time = ?, interview_type = ?, location_link = ?, additional_notes = ?, status = "scheduled" WHERE interview_id = ?')
        ->execute([$interviewDate, $interviewTime, $interviewType, $locationLink, $additionalNotes, $interviewId]);
} else {
    $stmt = $pdo->prepare('
        INSERT INTO interview (application_id, interview_date, interview_time, interview_type, location_link, additional_notes)
        VALUES (?, ?, ?, ?, ?, ?)
    ');
    $stmt->execute([$applicationId, $interviewDate, $interviewTime, $interviewType, $locationLink, $additionalNotes]);
    $interviewId = (int) $pdo->lastInsertId();
}

43
44
45
46
47
48

// ตรวจเนื้อไฟล์จริง ไม่ใช่แค่นามสกุล: ต้องเป็น PDF (ขึ้นต้นด้วย %PDF)
$header = (string) file_get_contents($file['tmp_name'], false, null, 0, 5);
$mime = function_exists('finfo_open') ? finfo_file(finfo_open(FILEINFO_MIME_TYPE), $file['tmp_name']) : 'application/pdf';
if (strncmp($header, '%PDF', 4) !== 0 || $mime !== 'application/pdf') {
    fail(400, 'อนุญาตให้อัปโหลดเฉพาะไฟล์ PDF เท่านั้น');
}

66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

try {
    $column = 'resume_url';
    $keywords = [];

    if ($type === 'resume') {
        // Keyword Matching จากเนื้อหา Resume (PDF ที่เป็นภาพสแกนจะดึงข้อความไม่ได้ -> ไม่มีคีย์เวิร์ด)
        $keywords = extractKeywordsFromText($pdo, extractPdfText(__DIR__ . '/' . $relativePath));
        $stmt = $pdo->prepare('UPDATE job_seeker SET resume_url = ?, resume_keywords = ? WHERE user_id = ?');
        $stmt->execute([$relativePath, implode(', ', $keywords), $userId]);
        recalculateAllMatching($pdo);
    } else {
        $stmt = $pdo->prepare("UPDATE job_seeker SET $column = ? WHERE user_id = ?");
        $stmt->execute([$relativePath, $userId]);
    }

    // ลบไฟล์เก่าของประเภทเดียวกัน (1 ไฟล์ต่อประเภท)
    $old = $seekerRow[$column] ?? '';
    if ($old && $old !== $relativePath && str_starts_with($old, 'uploads/resumes/') && is_file(__DIR__ . '/' . $old)) {
        @unlink(__DIR__ . '/' . $old);
    }

21
22
23
24
25
26
27

$userId = isset($_POST['user_id']) ? (int) $_POST['user_id'] : 0;
$role   = isset($_POST['role']) ? trim($_POST['role']) : 'seeker';
// อัปโหลดได้เฉพาะรูปของตัวเอง
$authUser = currentUser($pdo);
$userId = $authUser['user_id'];
$role   = $authUser['employer_id'] !== null ? 'employer' : 'seeker';
$isCover = $role === 'employer' && ($_POST['kind'] ?? '') === 'cover';

61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

$stmt = $pdo->prepare('
    SELECT
        CASE WHEN m.sender_id = ? THEN m.receiver_id ELSE m.sender_id END AS other_user_id,
        mem.name AS other_name,
        COALESCE(NULLIF(MAX(e.company_logo), ""), MAX(js.profile_image)) AS other_image,
        m.message AS last_message,
        m.sent_date AS last_sent_date,
        SUM(CASE WHEN m.receiver_id = ? AND m.is_read = 0 THEN 1 ELSE 0 END) AS unread_count
    FROM message m
    JOIN member mem ON mem.user_id = CASE WHEN m.sender_id = ? THEN m.receiver_id ELSE m.sender_id END
    LEFT JOIN employer e ON e.user_id = mem.user_id
    LEFT JOIN job_seeker js ON js.user_id = mem.user_id
    WHERE m.sender_id = ? OR m.receiver_id = ?
    GROUP BY other_user_id
    ORDER BY last_sent_date DESC
');
$stmt->execute([$userId, $userId, $userId, $userId, $userId]);

36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

// เบอร์โทรเก็บแยกตามบทบาท: ผู้หางาน = job_seeker.phone, ผู้ว่าจ้าง = employer.contact_phone
$stmt = $pdo->prepare('
    SELECT m.user_id, m.status, COALESCE(js.phone, e.contact_phone) AS phone
    FROM member m
    LEFT JOIN job_seeker js ON js.user_id = m.user_id
    LEFT JOIN employer e ON e.user_id = m.user_id
    WHERE m.email = ? AND m.role IN ("seeker", "employer")
    LIMIT 1
');
$stmt->execute([$email]);
$user = $stmt->fetch();

// ไม่บอกว่าผิดที่อีเมลหรือเบอร์ เพื่อไม่ให้ใช้เดาว่าอีเมลไหนมีในระบบ
if (!$user || preg_replace('/\D/', '', $user['phone'] ?? '') !== $phone) {
    fail(401, 'อีเมลหรือเบอร์โทรศัพท์ไม่ตรงกับข้อมูลที่สมัครไว้');
}
if ($user['status'] !== 'active') {
    fail(403, 'บัญชีของคุณถูกระงับการใช้งาน');
}

$pdo->prepare('UPDATE member SET password = ? WHERE user_id = ?')
    ->execute([password_hash($newPassword, PASSWORD_DEFAULT), $user['user_id']]);

21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

$employerId     = (int) ($input['employer_id'] ?? 0);
// ใช้ employer_id จาก token เสมอ (กันโพสต์งานในนามบริษัทอื่น)
$employerId     = requireEmployer($pdo)['employer_id'];
$jobTitle       = trim($input['job_title'] ?? '');
$jobDescription = trim($input['job_description'] ?? '');
$qualifications = trim($input['qualifications'] ?? '');
$jobLocation    = trim($input['job_location'] ?? '');
$rawRequiredSkills = trim($input['required_skills'] ?? '');
// ให้ AI ช่วยแปลงคำศัพท์เป็นคำมาตรฐาน
$requiredSkills = normalizeSkillsWithAI($rawRequiredSkills);

$jobType        = trim($input['job_type'] ?? '');
$salary         = trim($input['salary'] ?? '');
// ระบบไม่มีขั้นตอนอนุมัติ: ประกาศงานแสดงให้ผู้หางานเห็นทันที
$status         = 'approved';
$vacancy        = (int) ($input['vacancy'] ?? 1);
$latitude       = isset($input['latitude']) && $input['latitude'] !== '' ? (float) $input['latitude'] : null;
$longitude      = isset($input['longitude']) && $input['longitude'] !== '' ? (float) $input['longitude'] : null;
// กดใช้ตำแหน่งปัจจุบันแล้วแอปหาชื่อสถานที่ไม่ได้ จะได้ "พิกัด xx, yy" -> แปลงเป็น ต./อ./จ.
$jobLocation    = readableLocation($jobLocation, $latitude, $longitude);
// พิมพ์ที่อยู่เอง (ไม่ได้ใช้ GPS) -> หาพิกัดจากที่อยู่ เพื่อคำนวณระยะทาง "ห่าง x กม." ได้
if (($latitude === null || $longitude === null) && $jobLocation !== '') {
    [$latitude, $longitude] = coordinatesForAddress($jobLocation, null, null);
}

63
64
65
66
67
68
69
70
71
72

$stmt = $pdo->prepare('
    INSERT INTO job_posting (employer_id, job_title, job_description, qualifications, job_location, required_skills, job_type, salary, status, post_date, vacancy, latitude, longitude)
    VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, CURDATE(), ?, ?, ?)
');
$stmt->execute([$employerId, $jobTitle, $jobDescription, $qualifications, $jobLocation, $requiredSkills, $jobType, $salary, $status, $vacancy, $latitude, $longitude]);
$jobId = (int) $pdo->lastInsertId();

// คำนวณการจับคู่ทันที แล้วแจ้งเตือนงานแนะนำให้ผู้หางานที่คะแนนถึงเกณฑ์
recalculateMatchingForJob($pdo, $jobId);
notifyRecommendedSeekers($pdo, $jobId);

15
16
17
18
19
20
21
22
23
24
25
26

function coordinatesForAddress(string $address, $latitude, $longitude, ?array $current = null): array {
    if (is_numeric($latitude) && is_numeric($longitude)) {
        return [(float) $latitude, (float) $longitude];
    }
    $address = trim($address);
    if ($current !== null && ($address === '' || $address === trim((string) ($current['address'] ?? '')))
        && $current['latitude'] !== null && $current['longitude'] !== null) {
        return [(float) $current['latitude'], (float) $current['longitude']];
    }
    $found = geocodeThaiAddress($address !== '' ? $address : (string) ($current['address'] ?? ''));
    return $found ? [$found['latitude'], $found['longitude']] : [null, null];
}

87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125

function geocodeThaiAddress(string $address): ?array {
    $address = trim($address);
    if ($address === '') return null;

    $queries = [];
    if (preg_match('/ต\.\s*(\S+)\s+อ\.\s*(\S+)\s+จ\.\s*(\S+)/u', $address, $m)) {
        [, $sub, $dist, $prov] = $m;
        $queries[] = "ตำบล$sub อำเภอ$dist จังหวัด$prov";
        $queries[] = "$sub $dist $prov";   // กรุงเทพฯ ใช้แขวง/เขต จึงลองแบบไม่ใส่คำนำหน้าด้วย
        $queries[] = "$dist $prov";        // หาตำบลไม่เจอ ใช้พิกัดระดับอำเภอแทน
    } else {
        $queries[] = $address;
    }

    foreach ($queries as $i => $query) {
        if ($i > 0) usleep(1100000); // Nominatim จำกัด 1 คำขอต่อวินาที
        $url = 'https://nominatim.openstreetmap.org/search?format=json&limit=1&countrycodes=th&q=' . rawurlencode($query);
        $ch = curl_init($url);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_CONNECTTIMEOUT => 3,
            CURLOPT_TIMEOUT        => 5,
            CURLOPT_USERAGENT      => 'JobMatch-student-project/1.0',
        ]);
        $body = curl_exec($ch);
        $code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($body === false || $code !== 200) {
            error_log("geocode_service: Nominatim unavailable (HTTP $code)");
            return null; // เชื่อมต่อไม่ได้ ไม่ต้องลองคำค้นถัดไปให้ผู้ใช้รอนาน
        }
        $rows = json_decode($body, true);
        if (is_array($rows) && isset($rows[0]['lat'], $rows[0]['lon'])) {
            return ['latitude' => round((float) $rows[0]['lat'], 7), 'longitude' => round((float) $rows[0]['lon'], 7)];
        }
    }
    return null;
}

26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

$keywords = $pdo->query('SELECT keyword FROM keywords')->fetchAll(PDO::FETCH_COLUMN);
$inputSkills = array_values(array_filter(array_map('trim', explode(',', $rawSkillsString)), fn($s) => $s !== ''));

// ทักษะที่ตรงกับฐานข้อมูลอยู่แล้ว ไม่ต้องส่งให้ AI
$lowerKeywords = array_combine(array_map('mb_strtolower', $keywords), $keywords);
$result = [];
$unknown = [];
foreach ($inputSkills as $skill) {
    if (isset($lowerKeywords[mb_strtolower($skill)])) {
        $result[] = $lowerKeywords[mb_strtolower($skill)];
    } else {
        $unknown[] = $skill;
    }
}
if (!$unknown) {
    return implode(', ', array_unique($result));
}

$model = $config['gemini_model'] ?? 'gemini-flash-latest';
$url = 'https://generativelanguage.googleapis.com/v1beta/models/' . rawurlencode($model) . ':generateContent';
$prompt = "You map job skills typed by users to a fixed keyword list.\n"
    . "Keyword list: " . implode(' | ', $keywords) . "\n"
    . "For each input skill, answer with the single closest keyword from the list, copied exactly, "
    . "or the input skill unchanged if nothing in the list has the same meaning.\n"
    . "Return ONLY a JSON array of strings in the same order as the input.\n"
    . "Input: " . json_encode($unknown, JSON_UNESCAPED_UNICODE);

75
76
77
78
79
80
81
82
83
84
85

if (!is_array($mapped) || count($mapped) !== count($unknown)) {
    error_log('ai_service: Gemini unavailable (HTTP ' . $httpCode . '), keeping raw skills');
    return implode(', ', array_unique(array_merge($result, $unknown)));
}

foreach ($mapped as $i => $value) {
    $value = trim((string) $value);
    // ยอมรับเฉพาะคำที่อยู่ในฐานข้อมูลจริง ถ้า AI ตอบคำอื่นมาให้ใช้คำที่ผู้ใช้พิมพ์
    $result[] = isset($lowerKeywords[mb_strtolower($value)]) ? $lowerKeywords[mb_strtolower($value)] : $unknown[$i];
}
return implode(', ', array_unique($result));

17
18
19
20
21
22
23
24
25
26
27
28
29
30

// 1) อ่าน stream ทั้งหมด (คลายการบีบอัดถ้าเป็น FlateDecode)
$streams = [];
if (preg_match_all('/<<(.*?)>>\s*stream\r?\n(.*?)\r?\nendstream/s', $data, $matches, PREG_SET_ORDER)) {
    foreach ($matches as $m) {
        $content = $m[2];
        if (str_contains($m[1], '/FlateDecode')) {
            $inflated = @gzuncompress($content);
            if ($inflated === false) $inflated = @gzinflate($content);
            if ($inflated === false) continue;
            $content = $inflated;
        }
        $streams[] = $content;
    }
}

56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

// 3) ดึงข้อความจากคำสั่งแสดงผลข้อความใน content stream
$text = '';
foreach ($streams as $s) {
    // เฉพาะ content stream ที่มีบล็อกข้อความ (BT ... ET) ข้ามฟอนต์/รูปภาพ
    if (!preg_match('/\bBT\b/', $s)) continue;
    if (!preg_match_all('/(\[(?:[^\]\\\\]|\\\\.)*\]|\((?:[^()\\\\]|\\\\.)*\)|<[0-9A-Fa-f\s]+>)\s*(Tj|TJ|\'|")/s', $s, $ops, PREG_SET_ORDER)) {
        continue;
    }
    foreach ($ops as $op) {
        $operand = $op[1];
        if ($operand[0] === '[') {
            preg_match_all('/\((?:[^()\\\\]|\\\\.)*\)|<[0-9A-Fa-f\s]+>/s', $operand, $parts);
            foreach ($parts[0] as $part) $text .= decodePdfString($part, $cmap);
        } else {
            $text .= decodePdfString($operand, $cmap);
        }
        $text .= ' ';
    }
    $text .= "\n";
}

return trim(preg_replace('/[ \t]+/u', ' ', $text) ?? '');

29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

// บัญชีผู้ดูแลระบบอยู่ในตาราง member (role = 'admin') ล็อกอินด้วยอีเมลเต็ม หรือส่วนหน้า @ ก็ได้ (เช่น admin)
$stmt = $pdo->prepare("SELECT * FROM member WHERE role = 'admin' AND status = 'active' AND (email = ? OR SUBSTRING_INDEX(email, '@', 1) = ?)");
$stmt->execute([$username, $username]);
$admin = $stmt->fetch();

// ตรวจรหัสผ่านกับค่า bcrypt ที่เก็บไว้ ถ้ายังเป็นรหัสแบบข้อความธรรมดา (ข้อมูลเก่า)
// ให้เทียบตรงๆ แล้วแปลงเป็น bcrypt ทันที เหมือน login.php ของแอป
$isValid = false;
if ($admin) {
    $stored = (string) $admin['password'];
    if (password_get_info($stored)['algo'] !== null) {
        $isValid = password_verify($password, $stored);
    } elseif (hash_equals($stored, $password)) {
        $isValid = true;
        $upd = $pdo->prepare('UPDATE member SET password = ? WHERE user_id = ?');
        $upd->execute([password_hash($password, PASSWORD_DEFAULT), $admin['user_id']]);
    }
}

if ($isValid) {
    // ป้องกัน session fixation: สร้าง session id ใหม่หลัง login สำเร็จ
    session_regenerate_id(true);

    $_SESSION['admin_id'] = $admin['user_id'];
    $_SESSION['admin_name'] = $admin['name'];
    $_SESSION['admin_username'] = $admin['email'];

    session_write_close(); // Ensure session is saved before redirect
    header('Location: dashboard.php');
    exit;

20
21
22
23
24
25
26
27
28
29
30

// ตั้งค่า cookie ให้ path ครอบคลุมทั้ง root และ /api/ (กัน session หายเวลาข้ามโฟลเดอร์)
session_set_cookie_params([
    'lifetime' => 0,
    'path'     => '/',
    'domain'   => '',
    'secure'   => isset($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off',
    'httponly' => true,
    'samesite' => 'Lax',
]);

session_start();

11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

function requireLogin() {
    if (!isset($_SESSION['admin_id'])) {
        header('Location: index.php');
        exit;
    }
}

function isLoggedIn() {
    return isset($_SESSION['admin_id']);
}

function getAdminName() {
    return $_SESSION['admin_name'] ?? 'Administrator';
}

function getAdminId() {
    return $_SESSION['admin_id'] ?? null;
}

// Log admin actions
function logAction($pdo, $action, $targetType = null, $targetId = null, $details = null) {
    try {
        $stmt = $pdo->prepare("INSERT INTO system_logs (admin_id, action, target_type, target_id, details, ip_address) VALUES (?, ?, ?, ?, ?, ?)");
        $stmt->execute([
            getAdminId(),
            $action,
            $targetType,
            $targetId,
            $details,
            $_SERVER['REMOTE_ADDR'] ?? '127.0.0.1'
        ]);
    } catch (Exception $e) {
        // Silently fail - logging should not break the application
    }
}

25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

// กิจกรรมล่าสุดสำหรับปุ่มแจ้งเตือน: สมาชิกสมัครใหม่ + ประกาศงานใหม่
// "ใหม่" = id มากกว่าที่ผู้ดูแลเคยเปิดดูแล้ว (จำไว้ใน localStorage ฝั่งเบราว์เซอร์)
$adminActivity = [];
try {
    $roleLabels = ['seeker' => 'ผู้หางาน', 'employer' => 'ผู้ว่าจ้าง'];
    $rows = $pdo->query("SELECT user_id, name, email, role, created_at FROM member
                         WHERE role IN ('seeker','employer') ORDER BY user_id DESC LIMIT 6")->fetchAll();
    foreach ($rows as $r) {
        $adminActivity[] = [
            'type'  => 'member', 'id' => (int) $r['user_id'], 'icon' => 'fa-user-plus',
            'title' => 'สมาชิกใหม่: ' . $r['name'],
            'sub'   => ($roleLabels[$r['role']] ?? $r['role']) . ' · ' . date('d/m/Y H:i', strtotime($r['created_at'])),
            'url'   => 'users.php?search=' . urlencode($r['email']),
            'sort'  => strtotime($r['created_at']),
        ];
    }
    $rows = $pdo->query("SELECT j.job_id, j.job_title, j.post_date, e.company_name FROM job_posting j
                         LEFT JOIN employer e ON e.employer_id = j.employer_id
                         ORDER BY j.job_id DESC LIMIT 6")->fetchAll();
    foreach ($rows as $r) {
        $adminActivity[] = [
            'type'  => 'job', 'id' => (int) $r['job_id'], 'icon' => 'fa-briefcase',
            'title' => 'ประกาศงานใหม่: ' . $r['job_title'],
            'sub'   => ($r['company_name'] ?: 'ไม่ระบุบริษัท') . ' · ' . date('d/m/Y', strtotime($r['post_date'])),
            'url'   => 'job_postings.php?search=' . urlencode($r['job_title']),
            // post_date ไม่มีเวลา: ใช้สิ้นวันเพื่อให้งานของวันเดียวกันอยู่ใกล้สมาชิกใหม่ของวันนั้น
            'sort'  => strtotime($r['post_date'] . ' 23:59:59'),
        ];
    }
    usort($adminActivity, fn($a, $b) => $b['sort'] <=> $a['sort']);
    $adminActivity = array_slice($adminActivity, 0, 8);
} catch (Exception $e) { $adminActivity = []; }

19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

// แจ้งเตือนกิจกรรมล่าสุด: จำ id ล่าสุดที่เคยเห็นแยกตามประเภท เพื่อแสดงจุดแดงเมื่อมีรายการใหม่
const NOTI_KEY = 'jobmatchAdminNotiSeen';
function readNotiSeen() {
    try { return JSON.parse(localStorage.getItem(NOTI_KEY)) || {}; } catch (e) { return {}; }
}
function refreshNotiState() {
    const seen = readNotiSeen();
    let hasNew = false;
    document.querySelectorAll('.noti-item').forEach(item => {
        const isNew = Number(item.dataset.id) > (seen[item.dataset.type] || 0);
        item.classList.toggle('is-new', isNew);
        if (isNew) hasNew = true;
    });
    const dot = document.getElementById('notiDot');
    if (dot) dot.hidden = !hasNew;
}
function toggleNotiPanel(e) {
    e.stopPropagation();
    const panel = document.getElementById('notiPanel');
    const opening = !panel.classList.contains('open');
    panel.classList.toggle('open', opening);
    if (opening) {
        // เปิดดูแล้ว = ถือว่าเห็นทุกรายการ แต่ยังคงไฮไลต์ "ใหม่" ไว้จนกว่าจะปิดแผง
        const seen = readNotiSeen();
        document.querySelectorAll('.noti-item').forEach(item => {
            seen[item.dataset.type] = Math.max(seen[item.dataset.type] || 0, Number(item.dataset.id));
        });
        try { localStorage.setItem(NOTI_KEY, JSON.stringify(seen)); } catch (e) {}
        document.getElementById('notiDot').hidden = true;
    } else {
        refreshNotiState();
    }
}
document.addEventListener('click', function(e) {
    const panel = document.getElementById('notiPanel');
    if (panel && panel.classList.contains('open') && !panel.contains(e.target)) {
        panel.classList.remove('open');
        refreshNotiState();
    }
});
refreshNotiState();

25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

if ($_SERVER['REQUEST_METHOD'] === 'POST' && ($_POST['action'] ?? '') === 'save') {
    $values = [];
    $errors = [];
    foreach ($fields as $key => $meta) {
        $v = $_POST[$key] ?? '';
        if (!is_numeric($v) || $v < 0 || $v > 100) {
            $errors[] = $meta['label'] . ' ต้องเป็นตัวเลข 0-100';
        }
        $values[$key] = (float) $v;
    }
    if (!$errors && !($values['level_medium'] <= $values['level_good'] && $values['level_good'] <= $values['level_very_high'])) {
        $errors[] = 'ระดับคะแนนต้องเรียงกัน: ปานกลาง ≤ ดี ≤ สูงมาก';
    }

    if ($errors) {
        $message = implode(' / ', $errors);
        $messageType = 'danger';
    } else {
        $stmt = $pdo->prepare('INSERT INTO system_settings (setting_key, setting_value) VALUES (?, ?)
                               ON DUPLICATE KEY UPDATE setting_value = VALUES(setting_value)');
        foreach ($values as $key => $value) {
            $stmt->execute([$key, rtrim(rtrim(number_format($value, 2, '.', ''), '0'), '.')]);
        }
        logAction($pdo, 'update_matching_settings', 'system_settings', null, json_encode($values, JSON_UNESCAPED_UNICODE));
        $message = 'บันทึกเกณฑ์การจับคู่สำเร็จ ระบบจะใช้เกณฑ์ใหม่ทันที';
        $messageType = 'success';
    }
}

if ($_SERVER['REQUEST_METHOD'] === 'POST' && ($_POST['action'] ?? '') === 'recalculate') {
    recalculateAllMatching($pdo);
    logAction($pdo, 'recalculate_matching', 'matching', null, 'คำนวณผลการจับคู่ใหม่ทั้งหมด');
    $message = 'คำนวณผลการจับคู่ใหม่ทั้งหมดเรียบร้อย';
    $messageType = 'success';
}

27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

$validStatuses = [
    'approve' => 'active',
    'suspend' => 'suspended',
    'ban' => 'banned',
    'activate' => 'active',
];

if (!isset($validStatuses[$action])) {
    echo json_encode(['success' => false, 'message' => 'Invalid action']);
    exit;
}

try {
    $newStatus = $validStatuses[$action];
    $stmt = $pdo->prepare("UPDATE member SET status = ? WHERE user_id = ?");
    $stmt->execute([$newStatus, $memberId]);

    logAction($pdo, $action . '_user', 'member', $memberId, "API: $action user");