feat(wm-production): #68 值班管理完整实现

- 后端: 4个实体 + 4个Mapper + 4个Service + 1个Controller
  - DutyScheduleService: 排班CRUD + 自动排班(轮转算法)
  - DutyRecordService: 上下班打卡 + 状态管理 + 统计
  - HandoverService: 交接班记录 + 双方签字确认
  - DutyLogService: 值班日志(时间线) + 处理事项 + 统计
  - DutyController: /api/production/duty 统一入口
- 前端: Vue3 + TypeScript + Element Plus
  - ScheduleView.vue: 日历排班视图(拖拽排班+自动排班)
  - DutyPanel.vue: 值班面板(打卡+状态+联系方式+统计)
  - HandoverView.vue: 交接班记录(列表+新建+签字+详情)
  - DutyLogView.vue: 值班日志(时间线+统计+处理)
  - duty.ts: 完整API封装
- SQL DDL: V_duty.sql (4张表+索引)
- 单元测试: 4个Service测试类(30+测试用例)

frontend/src/api/duty.ts

+import request from './request'
+
+// ==================== 排班管理 ====================
+export function getMonthlySchedule(year: number, month: number) {
+  return request.get('/production/duty/schedule/monthly', { params: { year, month } })
+}
+
+export function getScheduleRange(start: string, end: string) {
+  return request.get('/production/duty/schedule/range', { params: { start, end } })
+}
+
+export function getTodaySchedule() {
+  return request.get('/production/duty/schedule/today')
+}
+
+export function createSchedule(data: any) {
+  return request.post('/production/duty/schedule', data)
+}
+
+export function batchCreateSchedule(data: any[]) {
+  return request.post('/production/duty/schedule/batch', data)
+}
+
+export function autoSchedule(data: { userIds: number[], startDate: string, endDate: string, shiftType?: string }) {
+  return request.post('/production/duty/schedule/auto', data)
+}
+
+export function updateSchedule(id: number, data: any) {
+  return request.put(`/production/duty/schedule/${id}`, data)
+}
+
+export function cancelSchedule(id: number) {
+  return request.delete(`/production/duty/schedule/${id}`)
+}
+
+// ==================== 上下班打卡 ====================
+export function getTodayRecords() {
+  return request.get('/production/duty/record/today')
+}
+
+export function getRecordsByDate(date: string) {
+  return request.get(`/production/duty/record/date/${date}`)
+}
+
+export function getUserRecords(userId: number, start: string, end: string) {
+  return request.get(`/production/duty/record/user/${userId}`, { params: { start, end } })
+}
+
+export function startDuty(data: { userId: number, location?: string }) {
+  return request.post('/production/duty/record/start', data)
+}
+
+export function endDuty(data: { userId: number, location?: string, handoverRemark?: string }) {
+  return request.post('/production/duty/record/end', data)
+}
+
+export function getCurrentDutyStatus(userId: number) {
+  return request.get(`/production/duty/record/status/${userId}`)
+}
+
+export function getDutyStats(userId: number, year: number, month: number) {
+  return request.get(`/production/duty/record/stats/${userId}`, { params: { year, month } })
+}
+
+// ==================== 交接班管理 ====================
+export function createHandover(data: any) {
+  return request.post('/production/duty/handover', data)
+}
+
+export function getHandoversByDate(date: string) {
+  return request.get(`/production/duty/handover/date/${date}`)
+}
+
+export function getHandoversByRange(start: string, end: string) {
+  return request.get('/production/duty/handover/range', { params: { start, end } })
+}
+
+export function getHandoverDetail(id: number) {
+  return request.get(`/production/duty/handover/${id}`)
+}
+
+export function updateHandover(id: number, data: any) {
+  return request.put(`/production/duty/handover/${id}`, data)
+}
+
+export function signFrom(id: number) {
+  return request.post(`/production/duty/handover/${id}/sign-from`)
+}
+
+export function signTo(id: number) {
+  return request.post(`/production/duty/handover/${id}/sign-to`)
+}
+
+export function checkHandoverStatus(date: string) {
+  return request.get(`/production/duty/handover/status/${date}`)
+}
+
+// ==================== 值班日志 ====================
+export function createDutyLog(data: any) {
+  return request.post('/production/duty/log', data)
+}
+
+export function getLogsByDate(date: string) {
+  return request.get(`/production/duty/log/date/${date}`)
+}
+
+export function getLogsByRange(start: string, end: string) {
+  return request.get('/production/duty/log/range', { params: { start, end } })
+}
+
+export function getLogDetail(id: number) {
+  return request.get(`/production/duty/log/${id}`)
+}
+
+export function updateLog(id: number, data: any) {
+  return request.put(`/production/duty/log/${id}`, data)
+}
+
+export function deleteLog(id: number) {
+  return request.delete(`/production/duty/log/${id}`)
+}
+
+export function handleLog(id: number, data: { handlerId: number, result: string }) {
+  return request.post(`/production/duty/log/${id}/handle`, data)
+}
+
+export function getLogStats(date: string) {
+  return request.get(`/production/duty/log/stats/${date}`)
+}
+
+// ==================== 联系方式面板 ====================
+export function getDutyContacts() {
+  return request.get('/production/duty/contacts')
+}

frontend/src/router/index.ts

       { path: 'system/role', name: 'role', component: () => import('@/views/system/role/RoleList.vue') },
       { path: 'system/menu', name: 'menu', component: () => import('@/views/system/menu/MenuList.vue') },
       { path: 'system/dept', name: 'dept', component: () => import('@/views/system/dept/DeptList.vue') },
+      { path: 'duty/schedule', name: 'dutySchedule', component: () => import('@/views/duty/ScheduleView.vue') },
+      { path: 'duty/panel', name: 'dutyPanel', component: () => import('@/views/duty/DutyPanel.vue') },
+      { path: 'duty/handover', name: 'dutyHandover', component: () => import('@/views/duty/HandoverView.vue') },
+      { path: 'duty/log', name: 'dutyLog', component: () => import('@/views/duty/DutyLogView.vue') },
     ]
   },
   { path: '/:pathMatch(.*)*', redirect: '/dashboard' }

frontend/src/views/duty/DutyLogView.vue

+<template>
+  <div class="duty-log-view">
+    <div class="header">
+      <h2>值班日志</h2>
+      <div class="actions">
+        <el-date-picker v-model="selectedDate" type="date" placeholder="选择日期"
+                        value-format="YYYY-MM-DD" @change="loadLogs" />
+        <el-select v-model="filterType" placeholder="日志类型" clearable style="width:120px" @change="loadLogs">
+          <el-option label="巡查" value="patrol" />
+          <el-option label="检查" value="inspection" />
+          <el-option label="事件" value="event" />
+          <el-option label="维修" value="maintenance" />
+          <el-option label="其他" value="other" />
+        </el-select>
+        <el-button type="primary" @click="showCreateDialog">新建日志</el-button>
+      </div>
+    </div>
+
+    <!-- 统计卡片 -->
+    <el-row :gutter="12" style="margin-bottom: 16px" v-if="logStats">
+      <el-col :span="6">
+        <el-card shadow="hover" class="stat-card">
+          <div class="stat-value">{{ logStats.total }}</div>
+          <div class="stat-title">总记录数</div>
+        </el-card>
+      </el-col>
+      <el-col :span="6">
+        <el-card shadow="hover" class="stat-card">
+          <div class="stat-value warning">{{ logStats.unhandled }}</div>
+          <div class="stat-title">待处理</div>
+        </el-card>
+      </el-col>
+      <el-col :span="12">
+        <el-card shadow="hover">
+          <div class="type-bars">
+            <div v-for="(count, type) in logStats.byType" :key="type" class="type-bar">
+              <span class="type-label">{{ getTypeLabel(type as string) }}</span>
+              <el-progress :percentage="Math.round((count as number) / Math.max(logStats.total, 1) * 100)"
+                          :stroke-width="12" :text-inside="true" :format="() => String(count)" />
+            </div>
+          </div>
+        </el-card>
+      </el-col>
+    </el-row>
+
+    <el-row :gutter="16">
+      <!-- 时间线 -->
+      <el-col :span="14">
+        <el-card shadow="hover">
+          <el-timeline>
+            <el-timeline-item v-for="log in filteredLogs" :key="log.id"
+                              :timestamp="formatTime(log.log_time)"
+                              :type="getSeverityType(log.severity)"
+                              :hollow="log.handled"
+                              placement="top">
+              <el-card shadow="never" class="log-card" :class="{ handled: log.handled }">
+                <div class="log-header">
+                  <el-tag size="small" :type="getTypeTagType(log.log_type)">{{ getTypeLabel(log.log_type) }}</el-tag>
+                  <span class="log-title">{{ log.title }}</span>
+                  <el-tag v-if="log.severity === 'critical'" type="danger" size="small" effect="dark">紧急</el-tag>
+                  <el-tag v-else-if="log.severity === 'warning'" type="warning" size="small">注意</el-tag>
+                </div>
+                <div class="log-body">
+                  <p>{{ log.content || '无详细内容' }}</p>
+                  <div v-if="log.location" class="log-location">📍 {{ log.location }}</div>
+                  <div v-if="log.real_name" class="log-author">👤 {{ log.real_name }}</div>
+                </div>
+                <div class="log-actions" v-if="!log.handled">
+                  <el-button text type="primary" size="small" @click="handleLogAction(log)">处理</el-button>
+                  <el-button text type="warning" size="small" @click="editLog(log)">编辑</el-button>
+                  <el-button text type="danger" size="small" @click="handleDeleteLog(log.id)">删除</el-button>
+                </div>
+                <div v-else class="log-handled-info">
+                  ✅ 已处理 {{ log.handle_result ? '— ' + log.handle_result : '' }}
+                </div>
+              </el-card>
+            </el-timeline-item>
+          </el-timeline>
+          <el-empty v-if="!filteredLogs.length" description="暂无日志记录" />
+        </el-card>
+      </el-col>
+
+      <!-- 右侧详情/表单 -->
+      <el-col :span="10">
+        <el-card shadow="hover">
+          <template #header>{{ formMode === 'create' ? '新建日志' : '编辑日志' }}</template>
+          <el-form :model="logForm" label-width="80px" v-if="showForm">
+            <el-form-item label="日志类型">
+              <el-select v-model="logForm.logType">
+                <el-option label="巡查" value="patrol" />
+                <el-option label="检查" value="inspection" />
+                <el-option label="事件" value="event" />
+                <el-option label="维修" value="maintenance" />
+                <el-option label="其他" value="other" />
+              </el-select>
+            </el-form-item>
+            <el-form-item label="标题">
+              <el-input v-model="logForm.title" placeholder="日志标题" />
+            </el-form-item>
+            <el-form-item label="内容">
+              <el-input v-model="logForm.content" type="textarea" :rows="4" placeholder="详细内容..." />
+            </el-form-item>
+            <el-form-item label="位置">
+              <el-input v-model="logForm.location" placeholder="记录位置" />
+            </el-form-item>
+            <el-form-item label="严重程度">
+              <el-radio-group v-model="logForm.severity">
+                <el-radio-button value="normal">一般</el-radio-button>
+                <el-radio-button value="warning">注意</el-radio-button>
+                <el-radio-button value="critical">紧急</el-radio-button>
+              </el-radio-group>
+            </el-form-item>
+            <el-form-item>
+              <el-button type="primary" @click="handleSubmitLog">
+                {{ formMode === 'create' ? '提交' : '保存' }}
+              </el-button>
+              <el-button @click="showForm = false">取消</el-button>
+            </el-form-item>
+          </el-form>
+          <el-empty v-else description="点击「新建日志」开始记录" />
+        </el-card>
+      </el-col>
+    </el-row>
+
+    <!-- 处理对话框 -->
+    <el-dialog v-model="handleDialogVisible" title="处理日志事项" width="400px">
+      <el-form label-width="80px">
+        <el-form-item label="处理结果">
+          <el-input v-model="handleForm.result" type="textarea" :rows="3" placeholder="处理说明..." />
+        </el-form-item>
+      </el-form>
+      <template #footer>
+        <el-button @click="handleDialogVisible = false">取消</el-button>
+        <el-button type="primary" @click="submitHandle">确认处理</el-button>
+      </template>
+    </el-dialog>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, computed, onMounted } from 'vue'
+import { ElMessage, ElMessageBox } from 'element-plus'
+import { createDutyLog, getLogsByDate, getLogStats, updateLog, deleteLog, handleLog } from '@/api/duty'
+
+const selectedDate = ref(new Date().toISOString().slice(0, 10))
+const filterType = ref('')
+const logList = ref<any[]>([])
+const logStats = ref<any>(null)
+const showForm = ref(false)
+const formMode = ref<'create' | 'edit'>('create')
+const handleDialogVisible = ref(false)
+const handleForm = ref({ id: 0, result: '' })
+const currentUserId = 1 // TODO: 从登录状态获取
+
+const logForm = ref({
+  id: 0,
+  logType: 'patrol',
+  title: '',
+  content: '',
+  location: '',
+  severity: 'normal'
+})
+
+const filteredLogs = computed(() => {
+  if (!filterType.value) return logList.value
+  return logList.value.filter(l => l.log_type === filterType.value)
+})
+
+function getTypeLabel(type: string) {
+  const map: any = { patrol: '巡查', inspection: '检查', event: '事件', maintenance: '维修', other: '其他' }
+  return map[type] || type
+}
+
+function getTypeTagType(type: string) {
+  const map: any = { patrol: '', inspection: 'success', event: 'warning', maintenance: 'info', other: 'info' }
+  return map[type] || ''
+}
+
+function getSeverityType(severity: string): 'primary' | 'success' | 'warning' | 'danger' | 'info' {
+  const map: any = { normal: 'primary', warning: 'warning', critical: 'danger' }
+  return map[severity] || 'info'
+}
+
+function formatTime(t: string) {
+  return t ? new Date(t).toLocaleString('zh-CN') : '-'
+}
+
+async function loadLogs() {
+  try {
+    const date = selectedDate.value || new Date().toISOString().slice(0, 10)
+    const res = await getLogsByDate(date)
+    logList.value = res.data || []
+
+    const statsRes = await getLogStats(date)
+    logStats.value = statsRes.data
+  } catch (e) { console.error(e) }
+}
+
+function showCreateDialog() {
+  formMode.value = 'create'
+  logForm.value = { id: 0, logType: 'patrol', title: '', content: '', location: '', severity: 'normal' }
+  showForm.value = true
+}
+
+function editLog(log: any) {
+  formMode.value = 'edit'
+  logForm.value = {
+    id: log.id,
+    logType: log.log_type,
+    title: log.title,
+    content: log.content || '',
+    location: log.location || '',
+    severity: log.severity || 'normal'
+  }
+  showForm.value = true
+}
+
+async function handleSubmitLog() {
+  if (!logForm.value.title) {
+    ElMessage.warning('请填写标题')
+    return
+  }
+  try {
+    if (formMode.value === 'create') {
+      await createDutyLog({ ...logForm.value, userId: currentUserId, dutyDate: selectedDate.value })
+    } else {
+      await updateLog(logForm.value.id, logForm.value)
+    }
+    ElMessage.success(formMode.value === 'create' ? '日志创建成功' : '日志更新成功')
+    showForm.value = false
+    loadLogs()
+  } catch (e) { console.error(e) }
+}
+
+async function handleDeleteLog(id: number) {
+  try {
+    await ElMessageBox.confirm('确定删除该日志?', '提示', { type: 'warning' })
+    await deleteLog(id)
+    ElMessage.success('已删除')
+    loadLogs()
+  } catch {}
+}
+
+function handleLogAction(log: any) {
+  handleForm.value = { id: log.id, result: '' }
+  handleDialogVisible.value = true
+}
+
+async function submitHandle() {
+  try {
+    await handleLog(handleForm.value.id, { handlerId: currentUserId, result: handleForm.value.result })
+    ElMessage.success('处理完成')
+    handleDialogVisible.value = false
+    loadLogs()
+  } catch (e) { console.error(e) }
+}
+
+onMounted(() => loadLogs())
+</script>
+
+<style scoped>
+.duty-log-view { padding: 20px; }
+.header { display: flex; justify-content: space-between; align-items: center; margin-bottom: 16px; }
+.actions { display: flex; gap: 8px; align-items: center; }
+.stat-card { text-align: center; }
+.stat-value { font-size: 28px; font-weight: bold; color: #409eff; }
+.stat-value.warning { color: #e6a23c; }
+.stat-title { font-size: 13px; color: #909399; margin-top: 4px; }
+.type-bars { display: flex; flex-direction: column; gap: 8px; }
+.type-bar { display: flex; align-items: center; gap: 8px; }
+.type-label { width: 40px; font-size: 13px; text-align: right; }
+.log-card { margin-bottom: 4px; }
+.log-card.handled { opacity: 0.7; }
+.log-header { display: flex; align-items: center; gap: 8px; margin-bottom: 8px; }
+.log-title { font-weight: bold; font-size: 15px; }
+.log-body p { margin: 4px 0; color: #606266; line-height: 1.6; }
+.log-location, .log-author { font-size: 12px; color: #909399; }
+.log-actions { margin-top: 8px; }
+.log-handled-info { margin-top: 8px; font-size: 13px; color: #67c23a; }
+</style>

frontend/src/views/duty/DutyPanel.vue

+<template>
+  <div class="duty-panel">
+    <h2>值班面板</h2>
+    <el-row :gutter="16">
+      <!-- 我的值班状态 -->
+      <el-col :span="8">
+        <el-card shadow="hover">
+          <template #header>
+            <div class="card-header">
+              <span>我的值班状态</span>
+              <el-tag :type="statusTagType">{{ statusLabel }}</el-tag>
+            </div>
+          </template>
+          <div class="status-info">
+            <div class="time-display">
+              <div class="time-label">当前时间</div>
+              <div class="time-value">{{ currentTime }}</div>
+            </div>
+            <div v-if="myStatus.onDutyAt" class="time-display">
+              <div class="time-label">上班时间</div>
+              <div class="time-value">{{ formatTime(myStatus.onDutyAt) }}</div>
+            </div>
+            <div v-if="myStatus.offDutyAt" class="time-display">
+              <div class="time-label">下班时间</div>
+              <div class="time-value">{{ formatTime(myStatus.offDutyAt) }}</div>
+            </div>
+            <div class="action-buttons">
+              <el-button type="success" size="large" :disabled="myStatus.status === 'on_duty'"
+                         @click="handleStartDuty" :loading="actionLoading">
+                🟢 上班打卡
+              </el-button>
+              <el-button type="danger" size="large" :disabled="myStatus.status !== 'on_duty'"
+                         @click="showEndDialog = true" :loading="actionLoading">
+                🔴 下班打卡
+              </el-button>
+            </div>
+          </div>
+        </el-card>
+      </el-col>
+
+      <!-- 今日值班列表 -->
+      <el-col :span="10">
+        <el-card shadow="hover">
+          <template #header>
+            <div class="card-header">
+              <span>今日值班人员</span>
+              <el-button text type="primary" @click="loadTodayData">刷新</el-button>
+            </div>
+          </template>
+          <el-table :data="todayRecords" stripe size="small">
+            <el-table-column prop="real_name" label="姓名" width="80" />
+            <el-table-column prop="shift_type" label="班次" width="70">
+              <template #default="{ row }">
+                <el-tag size="small" :type="getShiftType(row.shift_type)">{{ getShiftLabel(row.shift_type) }}</el-tag>
+              </template>
+            </el-table-column>
+            <el-table-column prop="status" label="状态" width="80">
+              <template #default="{ row }">
+                <el-tag size="small" :type="getStatusType(row.status)">{{ getStatusLabel(row.status) }}</el-tag>
+              </template>
+            </el-table-column>
+            <el-table-column prop="on_duty_at" label="上班" width="80">
+              <template #default="{ row }">{{ row.on_duty_at ? formatTime(row.on_duty_at).slice(11, 16) : '-' }}</template>
+            </el-table-column>
+            <el-table-column prop="off_duty_at" label="下班" width="80">
+              <template #default="{ row }">{{ row.off_duty_at ? formatTime(row.off_duty_at).slice(11, 16) : '-' }}</template>
+            </el-table-column>
+          </el-table>
+        </el-card>
+      </el-col>
+
+      <!-- 联系方式面板 -->
+      <el-col :span="6">
+        <el-card shadow="hover">
+          <template #header>
+            <span>📞 值班联系方式</span>
+          </template>
+          <div class="contact-list">
+            <div v-for="contact in contacts" :key="contact.userId" class="contact-item">
+              <div class="contact-name">{{ contact.name }}</div>
+              <div class="contact-info">
+                <el-tag size="small">{{ getShiftLabel(contact.shiftType) }}班</el-tag>
+                <a :href="`tel:${contact.phone}`" class="phone-link">📱 {{ contact.phone }}</a>
+              </div>
+              <div v-if="contact.area" class="contact-area">{{ contact.area }}</div>
+            </div>
+            <el-empty v-if="!contacts.length" description="今日无排班" :image-size="60" />
+          </div>
+        </el-card>
+      </el-col>
+    </el-row>
+
+    <!-- 值班统计 -->
+    <el-row :gutter="16" style="margin-top: 16px">
+      <el-col :span="6" v-for="stat in statCards" :key="stat.title">
+        <el-card shadow="hover">
+          <div class="stat-card">
+            <div class="stat-value">{{ stat.value }}</div>
+            <div class="stat-title">{{ stat.title }}</div>
+          </div>
+        </el-card>
+      </el-col>
+    </el-row>
+
+    <!-- 下班对话框 -->
+    <el-dialog v-model="showEndDialog" title="下班打卡" width="400px">
+      <el-form label-width="80px">
+        <el-form-item label="交接备注">
+          <el-input v-model="endForm.handoverRemark" type="textarea" :rows="3"
+                    placeholder="请填写交接事项..." />
+        </el-form-item>
+        <el-form-item label="位置">
+          <el-input v-model="endForm.location" placeholder="打卡位置" />
+        </el-form-item>
+      </el-form>
+      <template #footer>
+        <el-button @click="showEndDialog = false">取消</el-button>
+        <el-button type="primary" @click="handleEndDuty">确认下班</el-button>
+      </template>
+    </el-dialog>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, computed, onMounted, onUnmounted } from 'vue'
+import { ElMessage } from 'element-plus'
+import { getTodayRecords, startDuty, endDuty, getCurrentDutyStatus, getDutyContacts, getDutyStats } from '@/api/duty'
+
+const currentUserId = 1 // TODO: 从登录状态获取
+const currentTime = ref('')
+const myStatus = ref<any>({})
+const todayRecords = ref<any[]>([])
+const contacts = ref<any[]>([])
+const actionLoading = ref(false)
+const showEndDialog = ref(false)
+const endForm = ref({ handoverRemark: '', location: '' })
+let timer: number
+
+const statusLabel = computed(() => {
+  const map: any = { scheduled: '待上班', on_duty: '值班中', off_duty: '已下班', no_schedule: '无排班' }
+  return map[myStatus.value.status] || '未知'
+})
+
+const statusTagType = computed(() => {
+  const map: any = { scheduled: 'info', on_duty: 'success', off_duty: '', no_schedule: 'warning' }
+  return map[myStatus.value.status] || 'info'
+})
+
+const statCards = computed(() => {
+  const stats = myStatus.value.stats || {}
+  return [
+    { title: '本月值班天数', value: stats.totalDays || 0 },
+    { title: '准时上班', value: stats.onTimeCount || 0 },
+    { title: '已完成', value: stats.completedCount || 0 },
+    { title: '缺勤', value: stats.absentCount || 0 },
+  ]
+})
+
+function getShiftLabel(type: string) {
+  return { day: '白班', night: '夜班', full: '全天' }[type] || type
+}
+
+function getShiftType(type: string): '' | 'success' | 'warning' {
+  return ({ day: '', night: 'warning', full: 'success' } as any)[type] || ''
+}
+
+function getStatusType(status: string) {
+  const map: any = { scheduled: 'info', on_duty: 'success', off_duty: '', absent: 'danger' }
+  return map[status] || 'info'
+}
+
+function getStatusLabel(status: string) {
+  const map: any = { scheduled: '待上班', on_duty: '值班中', off_duty: '已下班', absent: '缺勤' }
+  return map[status] || status
+}
+
+function formatTime(t: string) {
+  if (!t) return '-'
+  return new Date(t).toLocaleString('zh-CN')
+}
+
+function updateClock() {
+  currentTime.value = new Date().toLocaleString('zh-CN')
+}
+
+async function loadMyStatus() {
+  try {
+    const res = await getCurrentDutyStatus(currentUserId)
+    myStatus.value = res.data || {}
+    // 加载统计
+    const now = new Date()
+    const statsRes = await getDutyStats(currentUserId, now.getFullYear(), now.getMonth() + 1)
+    myStatus.value.stats = statsRes.data
+  } catch (e) { console.error(e) }
+}
+
+async function loadTodayData() {
+  try {
+    const res = await getTodayRecords()
+    todayRecords.value = res.data || []
+  } catch (e) { console.error(e) }
+}
+
+async function loadContacts() {
+  try {
+    const res = await getDutyContacts()
+    contacts.value = res.data || []
+  } catch (e) { console.error(e) }
+}
+
+async function handleStartDuty() {
+  actionLoading.value = true
+  try {
+    await startDuty({ userId: currentUserId, location: '办公楼' })
+    ElMessage.success('上班打卡成功')
+    await loadMyStatus()
+    await loadTodayData()
+  } catch (e) { console.error(e) }
+  finally { actionLoading.value = false }
+}
+
+async function handleEndDuty() {
+  actionLoading.value = true
+  try {
+    await endDuty({ userId: currentUserId, ...endForm.value })
+    ElMessage.success('下班打卡成功')
+    showEndDialog.value = false
+    endForm.value = { handoverRemark: '', location: '' }
+    await loadMyStatus()
+    await loadTodayData()
+  } catch (e) { console.error(e) }
+  finally { actionLoading.value = false }
+}
+
+onMounted(() => {
+  updateClock()
+  timer = window.setInterval(updateClock, 1000)
+  loadMyStatus()
+  loadTodayData()
+  loadContacts()
+})
+
+onUnmounted(() => clearInterval(timer))
+</script>
+
+<style scoped>
+.duty-panel { padding: 20px; }
+.card-header { display: flex; justify-content: space-between; align-items: center; }
+.status-info { text-align: center; }
+.time-display { margin: 12px 0; }
+.time-label { font-size: 12px; color: #909399; }
+.time-value { font-size: 24px; font-weight: bold; color: #303133; }
+.action-buttons { display: flex; gap: 12px; justify-content: center; margin-top: 20px; }
+.contact-list { display: flex; flex-direction: column; gap: 12px; }
+.contact-item { padding: 8px; border-bottom: 1px solid #f0f0f0; }
+.contact-name { font-weight: bold; font-size: 14px; }
+.contact-info { display: flex; gap: 8px; align-items: center; margin-top: 4px; }
+.phone-link { color: #409eff; text-decoration: none; font-size: 13px; }
+.contact-area { font-size: 12px; color: #909399; margin-top: 2px; }
+.stat-card { text-align: center; padding: 8px; }
+.stat-value { font-size: 28px; font-weight: bold; color: #409eff; }
+.stat-title { font-size: 13px; color: #909399; margin-top: 4px; }
+</style>

frontend/src/views/duty/HandoverView.vue

+<template>
+  <div class="handover-view">
+    <div class="header">
+      <h2>交接班记录</h2>
+      <div class="actions">
+        <el-date-picker v-model="selectedDate" type="date" placeholder="选择日期"
+                        value-format="YYYY-MM-DD" @change="loadHandovers" />
+        <el-button type="primary" @click="showCreateDialog">新建交接</el-button>
+      </div>
+    </div>
+
+    <!-- 交接状态概览 -->
+    <el-alert v-if="handoverStatus" :type="handoverStatus.allSigned ? 'success' : 'warning'"
+              :closable="false" style="margin-bottom: 16px">
+      <template #title>
+        {{ selectedDate || '今日' }} 交接状态：共 {{ handoverStatus.totalRecords }} 条记录
+        {{ handoverStatus.allSigned ? '✅ 全部签字完成' : '⚠️ 尚有未签字项' }}
+      </template>
+    </el-alert>
+
+    <!-- 交接记录列表 -->
+    <el-table :data="handoverList" stripe border style="width: 100%">
+      <el-table-column prop="from_user_name" label="交班人" width="100" />
+      <el-table-column prop="to_user_name" label="接班人" width="100" />
+      <el-table-column prop="shift_type" label="班次" width="80">
+        <template #default="{ row }">
+          <el-tag size="small">{{ getShiftLabel(row.shift_type) }}</el-tag>
+        </template>
+      </el-table-column>
+      <el-table-column prop="handover_time" label="交接时间" width="160">
+        <template #default="{ row }">{{ formatTime(row.handover_time) }}</template>
+      </el-table-column>
+      <el-table-column prop="content" label="交接内容" min-width="200" show-overflow-tooltip />
+      <el-table-column label="签字状态" width="140">
+        <template #default="{ row }">
+          <el-tag size="small" :type="row.from_sign ? 'success' : 'danger'" style="margin-right:4px">
+            交班 {{ row.from_sign ? '✓' : '✗' }}
+          </el-tag>
+          <el-tag size="small" :type="row.to_sign ? 'success' : 'danger'">
+            接班 {{ row.to_sign ? '✓' : '✗' }}
+          </el-tag>
+        </template>
+      </el-table-column>
+      <el-table-column label="操作" width="180" fixed="right">
+        <template #default="{ row }">
+          <el-button text type="primary" size="small" @click="viewDetail(row)">查看</el-button>
+          <el-button v-if="!row.from_sign" text type="warning" size="small" @click="handleSignFrom(row.id)">交班签字</el-button>
+          <el-button v-if="!row.to_sign" text type="success" size="small" @click="handleSignTo(row.id)">接班签字</el-button>
+        </template>
+      </el-table-column>
+    </el-table>
+
+    <!-- 新建交接对话框 -->
+    <el-dialog v-model="createDialogVisible" title="新建交接班记录" width="600px">
+      <el-form :model="createForm" label-width="100px">
+        <el-form-item label="交班人">
+          <el-select v-model="createForm.fromUserId" placeholder="选择交班人">
+            <el-option v-for="u in userList" :key="u.id" :label="u.name" :value="u.id" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="接班人">
+          <el-select v-model="createForm.toUserId" placeholder="选择接班人">
+            <el-option v-for="u in userList" :key="u.id" :label="u.name" :value="u.id" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="交接日期">
+          <el-date-picker v-model="createForm.dutyDate" type="date" value-format="YYYY-MM-DD" />
+        </el-form-item>
+        <el-form-item label="班次">
+          <el-radio-group v-model="createForm.shiftType">
+            <el-radio-button value="day">白班</el-radio-button>
+            <el-radio-button value="night">夜班</el-radio-button>
+            <el-radio-button value="full">全天</el-radio-button>
+          </el-radio-group>
+        </el-form-item>
+        <el-form-item label="交接内容">
+          <el-input v-model="createForm.content" type="textarea" :rows="4" placeholder="交接事项详细说明..." />
+        </el-form-item>
+        <el-form-item label="异常事项">
+          <el-input v-model="createForm.abnormalItems" type="textarea" :rows="2"
+                    placeholder='JSON格式，如: [{"item":"XX设备故障","level":"warning"}]' />
+        </el-form-item>
+        <el-form-item label="待处理事项">
+          <el-input v-model="createForm.pendingItems" type="textarea" :rows="2"
+                    placeholder='JSON格式，如: [{"item":"待维修阀门","assignee":"张三"}]' />
+        </el-form-item>
+        <el-form-item label="设备状态">
+          <el-input v-model="createForm.equipmentStatus" type="textarea" :rows="2"
+                    placeholder='JSON格式，如: {"pump1":"正常","pump2":"故障"}' />
+        </el-form-item>
+      </el-form>
+      <template #footer>
+        <el-button @click="createDialogVisible = false">取消</el-button>
+        <el-button type="primary" @click="handleCreate">提交</el-button>
+      </template>
+    </el-dialog>
+
+    <!-- 详情对话框 -->
+    <el-dialog v-model="detailDialogVisible" title="交接班详情" width="600px">
+      <el-descriptions v-if="detailData" :column="2" border>
+        <el-descriptions-item label="交班人">{{ detailData.fromUserName || detailData.from_user_name }}</el-descriptions-item>
+        <el-descriptions-item label="接班人">{{ detailData.toUserName || detailData.to_user_name }}</el-descriptions-item>
+        <el-descriptions-item label="交接日期">{{ detailData.dutyDate || detailData.duty_date }}</el-descriptions-item>
+        <el-descriptions-item label="班次">{{ getShiftLabel(detailData.shiftType || detailData.shift_type) }}</el-descriptions-item>
+        <el-descriptions-item label="交接时间" :span="2">{{ formatTime(detailData.handoverTime || detailData.handover_time) }}</el-descriptions-item>
+        <el-descriptions-item label="交接内容" :span="2">{{ detailData.content || '无' }}</el-descriptions-item>
+        <el-descriptions-item label="异常事项" :span="2">
+          <pre style="white-space:pre-wrap;margin:0">{{ formatJson(detailData.abnormalItems || detailData.abnormal_items) }}</pre>
+        </el-descriptions-item>
+        <el-descriptions-item label="待处理事项" :span="2">
+          <pre style="white-space:pre-wrap;margin:0">{{ formatJson(detailData.pendingItems || detailData.pending_items) }}</pre>
+        </el-descriptions-item>
+        <el-descriptions-item label="设备状态" :span="2">
+          <pre style="white-space:pre-wrap;margin:0">{{ formatJson(detailData.equipmentStatus || detailData.equipment_status) }}</pre>
+        </el-descriptions-item>
+        <el-descriptions-item label="交班人签字">
+          <el-tag :type="(detailData.fromSign || detailData.from_sign) ? 'success' : 'danger'">
+            {{ (detailData.fromSign || detailData.from_sign) ? '已签字 ✓' : '未签字' }}
+          </el-tag>
+        </el-descriptions-item>
+        <el-descriptions-item label="接班人签字">
+          <el-tag :type="(detailData.toSign || detailData.to_sign) ? 'success' : 'danger'">
+            {{ (detailData.toSign || detailData.to_sign) ? '已签字 ✓' : '未签字' }}
+          </el-tag>
+        </el-descriptions-item>
+      </el-descriptions>
+    </el-dialog>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, onMounted } from 'vue'
+import { ElMessage, ElMessageBox } from 'element-plus'
+import {
+  getHandoversByDate, createHandover, getHandoverDetail,
+  signFrom, signTo, checkHandoverStatus
+} from '@/api/duty'
+
+const selectedDate = ref(new Date().toISOString().slice(0, 10))
+const handoverList = ref<any[]>([])
+const handoverStatus = ref<any>(null)
+const createDialogVisible = ref(false)
+const detailDialogVisible = ref(false)
+const detailData = ref<any>(null)
+
+const userList = ref([
+  { id: 1, name: '张三' }, { id: 2, name: '李四' },
+  { id: 3, name: '王五' }, { id: 4, name: '赵六' },
+])
+
+const createForm = ref({
+  fromUserId: null as number | null,
+  toUserId: null as number | null,
+  dutyDate: '',
+  shiftType: 'day',
+  content: '',
+  abnormalItems: '',
+  pendingItems: '',
+  equipmentStatus: ''
+})
+
+function getShiftLabel(type: string) {
+  return { day: '白班', night: '夜班', full: '全天' }[type] || type
+}
+
+function formatTime(t: string) {
+  return t ? new Date(t).toLocaleString('zh-CN') : '-'
+}
+
+function formatJson(str: string) {
+  if (!str) return '无'
+  try { return JSON.stringify(JSON.parse(str), null, 2) }
+  catch { return str }
+}
+
+async function loadHandovers() {
+  try {
+    const date = selectedDate.value || new Date().toISOString().slice(0, 10)
+    const res = await getHandoversByDate(date)
+    handoverList.value = res.data || []
+
+    const statusRes = await checkHandoverStatus(date)
+    handoverStatus.value = statusRes.data
+  } catch (e) { console.error(e) }
+}
+
+function showCreateDialog() {
+  createForm.value = {
+    fromUserId: null, toUserId: null,
+    dutyDate: selectedDate.value || new Date().toISOString().slice(0, 10),
+    shiftType: 'day', content: '', abnormalItems: '', pendingItems: '', equipmentStatus: ''
+  }
+  createDialogVisible.value = true
+}
+
+async function handleCreate() {
+  if (!createForm.value.fromUserId || !createForm.value.toUserId) {
+    ElMessage.warning('请选择交班人和接班人')
+    return
+  }
+  try {
+    await createHandover(createForm.value)
+    ElMessage.success('交接记录创建成功')
+    createDialogVisible.value = false
+    loadHandovers()
+  } catch (e) { console.error(e) }
+}
+
+async function viewDetail(row: any) {
+  try {
+    const res = await getHandoverDetail(row.id)
+    detailData.value = res.data
+    detailDialogVisible.value = true
+  } catch (e) { console.error(e) }
+}
+
+async function handleSignFrom(id: number) {
+  try {
+    await ElMessageBox.confirm('确认以交班人身份签字?', '交班签字')
+    await signFrom(id)
+    ElMessage.success('交班签字完成')
+    loadHandovers()
+  } catch {}
+}
+
+async function handleSignTo(id: number) {
+  try {
+    await ElMessageBox.confirm('确认以接班人身份签字?', '接班签字')
+    await signTo(id)
+    ElMessage.success('接班签字完成')
+    loadHandovers()
+  } catch {}
+}
+
+onMounted(() => loadHandovers())
+</script>
+
+<style scoped>
+.handover-view { padding: 20px; }
+.header { display: flex; justify-content: space-between; align-items: center; margin-bottom: 16px; }
+.actions { display: flex; gap: 8px; align-items: center; }
+</style>

frontend/src/views/duty/ScheduleView.vue

+<template>
+  <div class="schedule-view">
+    <div class="header">
+      <h2>排班管理</h2>
+      <div class="actions">
+        <el-date-picker v-model="currentDate" type="month" placeholder="选择月份"
+                        format="YYYY年MM月" value-format="YYYY-MM" @change="loadSchedule" />
+        <el-button type="primary" @click="showCreateDialog">新建排班</el-button>
+        <el-button type="success" @click="showAutoDialog">自动排班</el-button>
+      </div>
+    </div>
+
+    <!-- 日历视图 -->
+    <div class="calendar">
+      <div class="calendar-header">
+        <el-button text @click="prevMonth">&lt;</el-button>
+        <span class="month-title">{{ year }}年{{ month }}月</span>
+        <el-button text @click="nextMonth">&gt;</el-button>
+      </div>
+      <div class="calendar-grid">
+        <div class="weekday" v-for="day in weekdays" :key="day">{{ day }}</div>
+        <div class="day-cell" v-for="(cell, idx) in calendarCells" :key="idx"
+             :class="{ 'other-month': !cell.currentMonth, 'today': cell.isToday }"
+             @click="cell.currentMonth && onDayClick(cell.date)">
+          <div class="day-number">{{ cell.day }}</div>
+          <div class="duty-list">
+            <el-tag v-for="person in cell.persons" :key="person.userId"
+                    :type="getShiftTagType(person.shiftType)" size="small" class="duty-tag"
+                    closable @close="handleCancelSchedule(person.id)">
+              {{ person.realName }} {{ getShiftLabel(person.shiftType) }}
+            </el-tag>
+          </div>
+        </div>
+      </div>
+    </div>
+
+    <!-- 新建排班对话框 -->
+    <el-dialog v-model="createDialogVisible" title="新建排班" width="480px">
+      <el-form :model="createForm" label-width="80px">
+        <el-form-item label="值班人员">
+          <el-select v-model="createForm.userId" placeholder="选择人员" multiple>
+            <el-option v-for="u in userList" :key="u.id" :label="u.name" :value="u.id" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="值班日期">
+          <el-date-picker v-model="createForm.dutyDate" type="date" placeholder="选择日期"
+                          value-format="YYYY-MM-DD" />
+        </el-form-item>
+        <el-form-item label="班次">
+          <el-radio-group v-model="createForm.shiftType">
+            <el-radio-button value="day">白班</el-radio-button>
+            <el-radio-button value="night">夜班</el-radio-button>
+            <el-radio-button value="full">全天</el-radio-button>
+          </el-radio-group>
+        </el-form-item>
+        <el-form-item label="区域">
+          <el-input v-model="createForm.area" placeholder="值班区域" />
+        </el-form-item>
+        <el-form-item label="备注">
+          <el-input v-model="createForm.remark" type="textarea" :rows="2" />
+        </el-form-item>
+      </el-form>
+      <template #footer>
+        <el-button @click="createDialogVisible = false">取消</el-button>
+        <el-button type="primary" @click="handleCreate">确定</el-button>
+      </template>
+    </el-dialog>
+
+    <!-- 自动排班对话框 -->
+    <el-dialog v-model="autoDialogVisible" title="自动排班" width="480px">
+      <el-form :model="autoForm" label-width="80px">
+        <el-form-item label="值班人员">
+          <el-select v-model="autoForm.userIds" placeholder="选择人员" multiple>
+            <el-option v-for="u in userList" :key="u.id" :label="u.name" :value="u.id" />
+          </el-select>
+        </el-form-item>
+        <el-form-item label="开始日期">
+          <el-date-picker v-model="autoForm.startDate" type="date" value-format="YYYY-MM-DD" />
+        </el-form-item>
+        <el-form-item label="结束日期">
+          <el-date-picker v-model="autoForm.endDate" type="date" value-format="YYYY-MM-DD" />
+        </el-form-item>
+        <el-form-item label="班次">
+          <el-radio-group v-model="autoForm.shiftType">
+            <el-radio-button value="day">白班</el-radio-button>
+            <el-radio-button value="night">夜班</el-radio-button>
+            <el-radio-button value="full">全天</el-radio-button>
+          </el-radio-group>
+        </el-form-item>
+      </el-form>
+      <template #footer>
+        <el-button @click="autoDialogVisible = false">取消</el-button>
+        <el-button type="primary" @click="handleAutoSchedule">生成排班</el-button>
+      </template>
+    </el-dialog>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, computed, onMounted } from 'vue'
+import { ElMessage, ElMessageBox } from 'element-plus'
+import { getMonthlySchedule, createSchedule, autoSchedule, cancelSchedule } from '@/api/duty'
+
+const weekdays = ['日', '一', '二', '三', '四', '五', '六']
+const currentDate = ref(new Date().toISOString().slice(0, 7))
+const scheduleData = ref<any[]>([])
+const createDialogVisible = ref(false)
+const autoDialogVisible = ref(false)
+
+const userList = ref([
+  { id: 1, name: '张三' }, { id: 2, name: '李四' },
+  { id: 3, name: '王五' }, { id: 4, name: '赵六' },
+])
+
+const createForm = ref({
+  userId: [] as number[],
+  dutyDate: '',
+  shiftType: 'day',
+  area: '',
+  remark: ''
+})
+
+const autoForm = ref({
+  userIds: [] as number[],
+  startDate: '',
+  endDate: '',
+  shiftType: 'day'
+})
+
+const year = computed(() => parseInt(currentDate.value.split('-')[0]))
+const month = computed(() => parseInt(currentDate.value.split('-')[1]))
+
+const calendarCells = computed(() => {
+  const firstDay = new Date(year.value, month.value - 1, 1)
+  const lastDay = new Date(year.value, month.value, 0)
+  const startDay = firstDay.getDay()
+  const cells: any[] = []
+  const today = new Date().toISOString().slice(0, 10)
+
+  // 上月填充
+  const prevLastDay = new Date(year.value, month.value - 1, 0).getDate()
+  for (let i = startDay - 1; i >= 0; i--) {
+    cells.push({ day: prevLastDay - i, date: '', currentMonth: false, persons: [] })
+  }
+
+  // 当月
+  for (let d = 1; d <= lastDay.getDate(); d++) {
+    const dateStr = `${year.value}-${String(month.value).padStart(2, '0')}-${String(d).padStart(2, '0')}`
+    const persons = scheduleData.value.filter(s => s.duty_date === dateStr || s.dutyDate === dateStr)
+    cells.push({ day: d, date: dateStr, currentMonth: true, isToday: dateStr === today, persons })
+  }
+
+  // 下月填充
+  const remaining = 42 - cells.length
+  for (let d = 1; d <= remaining; d++) {
+    cells.push({ day: d, date: '', currentMonth: false, persons: [] })
+  }
+
+  return cells
+})
+
+function getShiftLabel(type: string) {
+  return { day: '白', night: '夜', full: '全' }[type] || type
+}
+
+function getShiftTagType(type: string): '' | 'success' | 'warning' | 'danger' {
+  return ({ day: '', night: 'warning', full: 'success' } as any)[type] || ''
+}
+
+async function loadSchedule() {
+  try {
+    const res = await getMonthlySchedule(year.value, month.value)
+    scheduleData.value = res.data || []
+  } catch (e) { console.error(e) }
+}
+
+function prevMonth() {
+  const d = new Date(year.value, month.value - 2, 1)
+  currentDate.value = `${d.getFullYear()}-${String(d.getMonth() + 1).padStart(2, '0')}`
+  loadSchedule()
+}
+
+function nextMonth() {
+  const d = new Date(year.value, month.value, 1)
+  currentDate.value = `${d.getFullYear()}-${String(d.getMonth() + 1).padStart(2, '0')}`
+  loadSchedule()
+}
+
+function onDayClick(date: string) {
+  createForm.value.dutyDate = date
+  createDialogVisible.value = true
+}
+
+function showCreateDialog() {
+  createForm.value = { userId: [], dutyDate: '', shiftType: 'day', area: '', remark: '' }
+  createDialogVisible.value = true
+}
+
+function showAutoDialog() {
+  autoForm.value = { userIds: [], startDate: '', endDate: '', shiftType: 'day' }
+  autoDialogVisible.value = true
+}
+
+async function handleCreate() {
+  if (!createForm.value.userId.length || !createForm.value.dutyDate) {
+    ElMessage.warning('请选择人员和日期')
+    return
+  }
+  try {
+    const schedules = createForm.value.userId.map(uid => ({
+      userId: uid,
+      dutyDate: createForm.value.dutyDate,
+      shiftType: createForm.value.shiftType,
+      area: createForm.value.area,
+      remark: createForm.value.remark
+    }))
+    await createSchedule(schedules.length === 1 ? schedules[0] : schedules)
+    ElMessage.success('排班创建成功')
+    createDialogVisible.value = false
+    loadSchedule()
+  } catch (e) { console.error(e) }
+}
+
+async function handleAutoSchedule() {
+  if (!autoForm.value.userIds.length || !autoForm.value.startDate || !autoForm.value.endDate) {
+    ElMessage.warning('请填写完整信息')
+    return
+  }
+  try {
+    await autoSchedule(autoForm.value)
+    ElMessage.success('自动排班完成')
+    autoDialogVisible.value = false
+    loadSchedule()
+  } catch (e) { console.error(e) }
+}
+
+async function handleCancelSchedule(id: number) {
+  try {
+    await ElMessageBox.confirm('确定取消该排班?', '提示', { type: 'warning' })
+    await cancelSchedule(id)
+    ElMessage.success('已取消')
+    loadSchedule()
+  } catch {}
+}
+
+onMounted(() => loadSchedule())
+</script>
+
+<style scoped>
+.schedule-view { padding: 20px; }
+.header { display: flex; justify-content: space-between; align-items: center; margin-bottom: 16px; }
+.actions { display: flex; gap: 8px; align-items: center; }
+.calendar-header { display: flex; align-items: center; gap: 16px; margin-bottom: 12px; }
+.month-title { font-size: 18px; font-weight: bold; }
+.calendar-grid { display: grid; grid-template-columns: repeat(7, 1fr); gap: 1px; background: #e4e7ed; border-radius: 4px; overflow: hidden; }
+.weekday { background: #f5f7fa; text-align: center; padding: 8px; font-weight: bold; font-size: 14px; }
+.day-cell { background: #fff; min-height: 100px; padding: 4px; cursor: pointer; transition: background 0.2s; }
+.day-cell:hover { background: #f0f9ff; }
+.day-cell.other-month { background: #fafafa; color: #c0c4cc; }
+.day-cell.today { background: #ecf5ff; }
+.day-number { font-size: 14px; margin-bottom: 4px; }
+.duty-list { display: flex; flex-direction: column; gap: 2px; }
+.duty-tag { font-size: 12px; }
+</style>

wm-production/src/main/java/com/water/production/controller/DutyController.java

+package com.water.production.controller;
+
+import com.water.common.core.result.R;
+import com.water.production.entity.DutyLog;
+import com.water.production.entity.DutySchedule;
+import com.water.production.entity.HandoverRecord;
+import com.water.production.service.*;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.RequiredArgsConstructor;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.web.bind.annotation.*;
+
+import java.time.LocalDate;
+import java.util.*;
+
+@Tag(name = "值班管理")
+@RestController
+@RequestMapping("/api/production/duty")
+@RequiredArgsConstructor
+public class DutyController {
+
+    private final DutyScheduleService scheduleService;
+    private final DutyRecordService recordService;
+    private final HandoverService handoverService;
+    private final DutyLogService logService;
+
+    // ==================== 排班管理 ====================
+
+    @Operation(summary = "获取月度排班表")
+    @GetMapping("/schedule/monthly")
+    public R<List<Map<String, Object>>> getMonthlySchedule(
+            @RequestParam int year, @RequestParam int month) {
+        return R.ok(scheduleService.getMonthlySchedule(year, month));
+    }
+
+    @Operation(summary = "获取日期范围排班")
+    @GetMapping("/schedule/range")
+    public R<List<Map<String, Object>>> getScheduleRange(
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate start,
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate end) {
+        return R.ok(scheduleService.getScheduleRange(start, end));
+    }
+
+    @Operation(summary = "获取今日排班")
+    @GetMapping("/schedule/today")
+    public R<List<Map<String, Object>>> getTodaySchedule() {
+        return R.ok(scheduleService.getTodaySchedule());
+    }
+
+    @Operation(summary = "创建排班")
+    @PostMapping("/schedule")
+    public R<DutySchedule> createSchedule(@RequestBody DutySchedule schedule) {
+        return R.ok(scheduleService.createSchedule(schedule));
+    }
+
+    @Operation(summary = "批量创建排班")
+    @PostMapping("/schedule/batch")
+    public R<List<DutySchedule>> batchCreateSchedule(@RequestBody List<DutySchedule> schedules) {
+        return R.ok(scheduleService.batchCreateSchedule(schedules));
+    }
+
+    @Operation(summary = "自动排班")
+    @PostMapping("/schedule/auto")
+    public R<List<DutySchedule>> autoSchedule(@RequestBody Map<String, Object> req) {
+        @SuppressWarnings("unchecked")
+        List<Long> userIds = ((List<Number>) req.get("userIds")).stream()
+                .map(Number::longValue).toList();
+        LocalDate startDate = LocalDate.parse((String) req.get("startDate"));
+        LocalDate endDate = LocalDate.parse((String) req.get("endDate"));
+        String shiftType = (String) req.getOrDefault("shiftType", "day");
+        return R.ok(scheduleService.autoSchedule(userIds, startDate, endDate, shiftType));
+    }
+
+    @Operation(summary = "更新排班")
+    @PutMapping("/schedule/{id}")
+    public R<DutySchedule> updateSchedule(@PathVariable Long id, @RequestBody DutySchedule schedule) {
+        schedule.setId(id);
+        return R.ok(scheduleService.updateSchedule(schedule));
+    }
+
+    @Operation(summary = "取消排班")
+    @DeleteMapping("/schedule/{id}")
+    public R<String> cancelSchedule(@PathVariable Long id) {
+        scheduleService.cancelSchedule(id);
+        return R.ok("排班已取消");
+    }
+
+    // ==================== 上下班打卡 ====================
+
+    @Operation(summary = "获取今日值班记录")
+    @GetMapping("/record/today")
+    public R<List<Map<String, Object>>> getTodayRecords() {
+        return R.ok(recordService.getTodayRecords());
+    }
+
+    @Operation(summary = "获取指定日期值班记录")
+    @GetMapping("/record/date/{date}")
+    public R<List<Map<String, Object>>> getRecordsByDate(
+            @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate date) {
+        return R.ok(recordService.getRecordsByDate(date));
+    }
+
+    @Operation(summary = "获取用户值班记录")
+    @GetMapping("/record/user/{userId}")
+    public R<List<Map<String, Object>>> getUserRecords(
+            @PathVariable Long userId,
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate start,
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate end) {
+        return R.ok(recordService.getUserRecords(userId, start, end));
+    }
+
+    @Operation(summary = "上班打卡")
+    @PostMapping("/record/start")
+    public R<Map<String, Object>> startDuty(@RequestBody Map<String, Object> req) {
+        Long userId = ((Number) req.get("userId")).longValue();
+        String location = (String) req.getOrDefault("location", "");
+        return R.ok(recordService.startDuty(userId, location));
+    }
+
+    @Operation(summary = "下班打卡")
+    @PostMapping("/record/end")
+    public R<Map<String, Object>> endDuty(@RequestBody Map<String, Object> req) {
+        Long userId = ((Number) req.get("userId")).longValue();
+        String location = (String) req.getOrDefault("location", "");
+        String remark = (String) req.getOrDefault("handoverRemark", "");
+        return R.ok(recordService.endDuty(userId, location, remark));
+    }
+
+    @Operation(summary = "获取当前值班状态")
+    @GetMapping("/record/status/{userId}")
+    public R<Map<String, Object>> getCurrentStatus(@PathVariable Long userId) {
+        return R.ok(recordService.getCurrentDutyStatus(userId));
+    }
+
+    @Operation(summary = "获取值班统计")
+    @GetMapping("/record/stats/{userId}")
+    public R<Map<String, Object>> getDutyStats(
+            @PathVariable Long userId,
+            @RequestParam int year, @RequestParam int month) {
+        return R.ok(recordService.getDutyStats(userId, year, month));
+    }
+
+    // ==================== 交接班管理 ====================
+
+    @Operation(summary = "创建交接班记录")
+    @PostMapping("/handover")
+    public R<HandoverRecord> createHandover(@RequestBody HandoverRecord record) {
+        return R.ok(handoverService.createHandover(record));
+    }
+
+    @Operation(summary = "获取指定日期交接班记录")
+    @GetMapping("/handover/date/{date}")
+    public R<List<Map<String, Object>>> getHandoversByDate(
+            @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate date) {
+        return R.ok(handoverService.getByDate(date));
+    }
+
+    @Operation(summary = "获取日期范围交接班记录")
+    @GetMapping("/handover/range")
+    public R<List<Map<String, Object>>> getHandoversByRange(
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate start,
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate end) {
+        return R.ok(handoverService.getByDateRange(start, end));
+    }
+
+    @Operation(summary = "交接班详情")
+    @GetMapping("/handover/{id}")
+    public R<HandoverRecord> getHandoverDetail(@PathVariable Long id) {
+        return R.ok(handoverService.getDetail(id));
+    }
+
+    @Operation(summary = "更新交接班内容")
+    @PutMapping("/handover/{id}")
+    public R<HandoverRecord> updateHandover(@PathVariable Long id, @RequestBody HandoverRecord record) {
+        record.setId(id);
+        return R.ok(handoverService.updateHandover(record));
+    }
+
+    @Operation(summary = "交班人签字")
+    @PostMapping("/handover/{id}/sign-from")
+    public R<String> signFrom(@PathVariable Long id) {
+        handoverService.signFrom(id);
+        return R.ok("交班人已签字");
+    }
+
+    @Operation(summary = "接班人签字")
+    @PostMapping("/handover/{id}/sign-to")
+    public R<String> signTo(@PathVariable Long id) {
+        handoverService.signTo(id);
+        return R.ok("接班人已签字");
+    }
+
+    @Operation(summary = "检查交接状态")
+    @GetMapping("/handover/status/{date}")
+    public R<Map<String, Object>> checkHandoverStatus(
+            @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate date) {
+        return R.ok(handoverService.checkHandoverStatus(date));
+    }
+
+    // ==================== 值班日志 ====================
+
+    @Operation(summary = "创建值班日志")
+    @PostMapping("/log")
+    public R<DutyLog> createLog(@RequestBody DutyLog dutyLog) {
+        return R.ok(logService.createLog(dutyLog));
+    }
+
+    @Operation(summary = "获取指定日期日志（时间线）")
+    @GetMapping("/log/date/{date}")
+    public R<List<Map<String, Object>>> getLogsByDate(
+            @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate date) {
+        return R.ok(logService.getByDate(date));
+    }
+
+    @Operation(summary = "获取日期范围日志")
+    @GetMapping("/log/range")
+    public R<List<Map<String, Object>>> getLogsByRange(
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate start,
+            @RequestParam @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate end) {
+        return R.ok(logService.getByDateRange(start, end));
+    }
+
+    @Operation(summary = "日志详情")
+    @GetMapping("/log/{id}")
+    public R<DutyLog> getLogDetail(@PathVariable Long id) {
+        return R.ok(logService.getDetail(id));
+    }
+
+    @Operation(summary = "更新日志")
+    @PutMapping("/log/{id}")
+    public R<DutyLog> updateLog(@PathVariable Long id, @RequestBody DutyLog dutyLog) {
+        dutyLog.setId(id);
+        return R.ok(logService.updateLog(dutyLog));
+    }
+
+    @Operation(summary = "删除日志")
+    @DeleteMapping("/log/{id}")
+    public R<String> deleteLog(@PathVariable Long id) {
+        logService.deleteLog(id);
+        return R.ok("日志已删除");
+    }
+
+    @Operation(summary = "处理日志事项")
+    @PostMapping("/log/{id}/handle")
+    public R<String> handleLog(@PathVariable Long id, @RequestBody Map<String, Object> req) {
+        Long handlerId = ((Number) req.get("handlerId")).longValue();
+        String result = (String) req.getOrDefault("result", "");
+        logService.handleLog(id, handlerId, result);
+        return R.ok("已处理");
+    }
+
+    @Operation(summary = "日志统计")
+    @GetMapping("/log/stats/{date}")
+    public R<Map<String, Object>> getLogStats(
+            @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) LocalDate date) {
+        return R.ok(logService.getLogStats(date));
+    }
+
+    // ==================== 联系方式面板 ====================
+
+    @Operation(summary = "获取值班联系方式面板")
+    @GetMapping("/contacts")
+    public R<List<Map<String, Object>>> getContacts() {
+        // 获取今日值班人员及联系方式
+        List<Map<String, Object>> todaySchedule = scheduleService.getTodaySchedule();
+        List<Map<String, Object>> contacts = new ArrayList<>();
+        for (Map<String, Object> s : todaySchedule) {
+            Map<String, Object> contact = new LinkedHashMap<>();
+            contact.put("userId", s.get("user_id"));
+            contact.put("name", s.get("real_name"));
+            contact.put("phone", s.get("phone"));
+            contact.put("shiftType", s.get("shift_type"));
+            contact.put("area", s.get("area"));
+            contact.put("status", s.get("status"));
+            contacts.add(contact);
+        }
+        return R.ok(contacts);
+    }
+}

wm-production/src/main/java/com/water/production/entity/DutyLog.java

+package com.water.production.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("duty_log")
+public class DutyLog {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    private Long userId;
+    private LocalDate dutyDate;
+    private LocalDateTime logTime;
+    private String logType; // patrol/inspection/event/maintenance/other
+    private String title;
+    private String content;
+    private String location;
+    private String images; // JSON
+    private String severity; // normal/warning/critical
+    private Boolean handled;
+    private Long handlerId;
+    private LocalDateTime handleTime;
+    private String handleResult;
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createdTime;
+}

wm-production/src/main/java/com/water/production/entity/DutyRecord.java

+package com.water.production.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("duty_record")
+public class DutyRecord {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    private Long scheduleId;
+    private Long userId;
+    private LocalDate dutyDate;
+    private String shiftType;
+    private String status; // scheduled/on_duty/off_duty/absent
+    private LocalDateTime onDutyAt;
+    private LocalDateTime offDutyAt;
+    private String onDutyLocation;
+    private String offDutyLocation;
+    private String handoverRemark;
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createdTime;
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updatedTime;
+}

wm-production/src/main/java/com/water/production/entity/DutySchedule.java

+package com.water.production.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("duty_schedule")
+public class DutySchedule {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    private Long userId;
+    private LocalDate dutyDate;
+    private String shiftType; // day/night/full
+    private String area;
+    private Integer status; // 0=已取消 1=已排班 2=已完成
+    private String remark;
+    private Long createdBy;
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createdTime;
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updatedTime;
+}

wm-production/src/main/java/com/water/production/entity/HandoverRecord.java

+package com.water.production.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Data
+@TableName("handover_record")
+public class HandoverRecord {
+    @TableId(type = IdType.AUTO)
+    private Long id;
+    private Long fromUserId;
+    private Long toUserId;
+    private LocalDate dutyDate;
+    private String shiftType;
+    private LocalDateTime handoverTime;
+    private String content;
+    private String abnormalItems;  // JSON
+    private String pendingItems;   // JSON
+    private String equipmentStatus; // JSON
+    private Boolean fromSign;
+    private Boolean toSign;
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createdTime;
+}

wm-production/src/main/java/com/water/production/mapper/DutyLogMapper.java

+package com.water.production.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.production.entity.DutyLog;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.annotations.Update;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface DutyLogMapper extends BaseMapper<DutyLog> {
+
+    @Select("SELECT dl.*, u.real_name FROM duty_log dl " +
+            "LEFT JOIN sys_user u ON dl.user_id = u.id " +
+            "WHERE dl.duty_date = #{date} ORDER BY dl.log_time DESC")
+    List<Map<String, Object>> selectByDate(@Param("date") LocalDate date);
+
+    @Select("SELECT dl.*, u.real_name FROM duty_log dl " +
+            "LEFT JOIN sys_user u ON dl.user_id = u.id " +
+            "WHERE dl.duty_date BETWEEN #{start} AND #{end} " +
+            "ORDER BY dl.log_time DESC")
+    List<Map<String, Object>> selectByDateRange(@Param("start") LocalDate start, @Param("end") LocalDate end);
+
+    @Update("UPDATE duty_log SET handled = true, handler_id = #{handlerId}, " +
+            "handle_time = NOW(), handle_result = #{result} WHERE id = #{id}")
+    int markHandled(@Param("id") Long id, @Param("handlerId") Long handlerId, @Param("result") String result);
+}

wm-production/src/main/java/com/water/production/mapper/DutyRecordMapper.java

+package com.water.production.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.production.entity.DutyRecord;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface DutyRecordMapper extends BaseMapper<DutyRecord> {
+
+    @Select("SELECT dr.*, u.real_name, u.phone, ds.shift_type, ds.area " +
+            "FROM duty_record dr " +
+            "LEFT JOIN sys_user u ON dr.user_id = u.id " +
+            "LEFT JOIN duty_schedule ds ON dr.schedule_id = ds.id " +
+            "WHERE dr.duty_date = #{date} ORDER BY dr.on_duty_at")
+    List<Map<String, Object>> selectByDate(@Param("date") LocalDate date);
+
+    @Select("SELECT dr.*, u.real_name, u.phone FROM duty_record dr " +
+            "LEFT JOIN sys_user u ON dr.user_id = u.id " +
+            "WHERE dr.user_id = #{userId} AND dr.duty_date BETWEEN #{start} AND #{end} " +
+            "ORDER BY dr.duty_date DESC")
+    List<Map<String, Object>> selectUserRecords(@Param("userId") Long userId,
+                                                 @Param("start") LocalDate start,
+                                                 @Param("end") LocalDate end);
+}

wm-production/src/main/java/com/water/production/mapper/DutyScheduleMapper.java

+package com.water.production.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.production.entity.DutySchedule;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface DutyScheduleMapper extends BaseMapper<DutySchedule> {
+
+    @Select("SELECT ds.*, u.real_name, u.phone FROM duty_schedule ds " +
+            "LEFT JOIN sys_user u ON ds.user_id = u.id " +
+            "WHERE ds.duty_date BETWEEN #{start} AND #{end} " +
+            "ORDER BY ds.duty_date, ds.shift_type")
+    List<Map<String, Object>> selectScheduleRange(@Param("start") LocalDate start, @Param("end") LocalDate end);
+
+    @Select("SELECT ds.*, u.real_name, u.phone FROM duty_schedule ds " +
+            "LEFT JOIN sys_user u ON ds.user_id = u.id " +
+            "WHERE ds.duty_date = #{date} AND ds.status = 1")
+    List<Map<String, Object>> selectTodaySchedule(@Param("date") LocalDate date);
+}

wm-production/src/main/java/com/water/production/mapper/HandoverRecordMapper.java

+package com.water.production.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.water.production.entity.HandoverRecord;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
+
+import java.time.LocalDate;
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface HandoverRecordMapper extends BaseMapper<HandoverRecord> {
+
+    @Select("SELECT hr.*, " +
+            "f.real_name AS from_user_name, f.phone AS from_user_phone, " +
+            "t.real_name AS to_user_name, t.phone AS to_user_phone " +
+            "FROM handover_record hr " +
+            "LEFT JOIN sys_user f ON hr.from_user_id = f.id " +
+            "LEFT JOIN sys_user t ON hr.to_user_id = t.id " +
+            "WHERE hr.duty_date = #{date} ORDER BY hr.handover_time DESC")
+    List<Map<String, Object>> selectByDate(@Param("date") LocalDate date);
+
+    @Select("SELECT hr.*, " +
+            "f.real_name AS from_user_name, " +
+            "t.real_name AS to_user_name " +
+            "FROM handover_record hr " +
+            "LEFT JOIN sys_user f ON hr.from_user_id = f.id " +
+            "LEFT JOIN sys_user t ON hr.to_user_id = t.id " +
+            "WHERE hr.duty_date BETWEEN #{start} AND #{end} " +
+            "ORDER BY hr.handover_time DESC")
+    List<Map<String, Object>> selectByDateRange(@Param("start") LocalDate start, @Param("end") LocalDate end);
+}

wm-production/src/main/java/com/water/production/service/DutyLogService.java

+package com.water.production.service;
+
+import com.water.production.entity.DutyLog;
+import com.water.production.mapper.DutyLogMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.*;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class DutyLogService {
+
+    private final DutyLogMapper dutyLogMapper;
+
+    /**
+     * 创建值班日志
+     */
+    @Transactional
+    public DutyLog createLog(DutyLog dutyLog) {
+        if (dutyLog.getLogTime() == null) {
+            dutyLog.setLogTime(LocalDateTime.now());
+        }
+        if (dutyLog.getDutyDate() == null) {
+            dutyLog.setDutyDate(LocalDate.now());
+        }
+        dutyLog.setHandled(false);
+        dutyLog.setCreatedTime(null);
+        dutyLogMapper.insert(dutyLog);
+        log.info("Duty log created: user={} type={} title={}",
+                dutyLog.getUserId(), dutyLog.getLogType(), dutyLog.getTitle());
+        return dutyLog;
+    }
+
+    /**
+     * 获取指定日期的值班日志（时间线）
+     */
+    public List<Map<String, Object>> getByDate(LocalDate date) {
+        return dutyLogMapper.selectByDate(date);
+    }
+
+    /**
+     * 获取日期范围的值班日志
+     */
+    public List<Map<String, Object>> getByDateRange(LocalDate start, LocalDate end) {
+        return dutyLogMapper.selectByDateRange(start, end);
+    }
+
+    /**
+     * 获取日志详情
+     */
+    public DutyLog getDetail(Long id) {
+        DutyLog dutyLog = dutyLogMapper.selectById(id);
+        if (dutyLog == null) {
+            throw new IllegalArgumentException("值班日志不存在");
+        }
+        return dutyLog;
+    }
+
+    /**
+     * 处理日志事项
+     */
+    @Transactional
+    public void handleLog(Long id, Long handlerId, String result) {
+        int rows = dutyLogMapper.markHandled(id, handlerId, result);
+        if (rows == 0) {
+            throw new IllegalArgumentException("值班日志不存在");
+        }
+        log.info("Duty log handled: id={} handler={}", id, handlerId);
+    }
+
+    /**
+     * 更新日志
+     */
+    @Transactional
+    public DutyLog updateLog(DutyLog update) {
+        DutyLog existing = dutyLogMapper.selectById(update.getId());
+        if (existing == null) {
+            throw new IllegalArgumentException("值班日志不存在");
+        }
+        if (update.getTitle() != null) existing.setTitle(update.getTitle());
+        if (update.getContent() != null) existing.setContent(update.getContent());
+        if (update.getLogType() != null) existing.setLogType(update.getLogType());
+        if (update.getLocation() != null) existing.setLocation(update.getLocation());
+        if (update.getImages() != null) existing.setImages(update.getImages());
+        if (update.getSeverity() != null) existing.setSeverity(update.getSeverity());
+        dutyLogMapper.updateById(existing);
+        return existing;
+    }
+
+    /**
+     * 删除日志
+     */
+    @Transactional
+    public void deleteLog(Long id) {
+        dutyLogMapper.deleteById(id);
+        log.info("Duty log deleted: id={}", id);
+    }
+
+    /**
+     * 获取日志统计
+     */
+    public Map<String, Object> getLogStats(LocalDate date) {
+        List<Map<String, Object>> logs = dutyLogMapper.selectByDate(date);
+        Map<String, Object> stats = new LinkedHashMap<>();
+        stats.put("total", logs.size());
+        stats.put("byType", logs.stream()
+                .collect(java.util.stream.Collectors.groupingBy(
+                        l -> String.valueOf(l.getOrDefault("log_type", "other")),
+                        java.util.stream.Collectors.counting())));
+        stats.put("bySeverity", logs.stream()
+                .collect(java.util.stream.Collectors.groupingBy(
+                        l -> String.valueOf(l.getOrDefault("severity", "normal")),
+                        java.util.stream.Collectors.counting())));
+        stats.put("unhandled", logs.stream()
+                .filter(l -> !Boolean.TRUE.equals(l.get("handled")))
+                .count());
+        return stats;
+    }
+}

wm-production/src/main/java/com/water/production/service/DutyRecordService.java

+package com.water.production.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.water.production.entity.DutyRecord;
+import com.water.production.entity.DutySchedule;
+import com.water.production.mapper.DutyRecordMapper;
+import com.water.production.mapper.DutyScheduleMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.*;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class DutyRecordService {
+
+    private final DutyRecordMapper recordMapper;
+    private final DutyScheduleMapper scheduleMapper;
+
+    /**
+     * 获取今日值班列表
+     */
+    public List<Map<String, Object>> getTodayRecords() {
+        return recordMapper.selectByDate(LocalDate.now());
+    }
+
+    /**
+     * 获取指定日期的值班记录
+     */
+    public List<Map<String, Object>> getRecordsByDate(LocalDate date) {
+        return recordMapper.selectByDate(date);
+    }
+
+    /**
+     * 获取用户指定日期范围的值班记录
+     */
+    public List<Map<String, Object>> getUserRecords(Long userId, LocalDate start, LocalDate end) {
+        return recordMapper.selectUserRecords(userId, start, end);
+    }
+
+    /**
+     * 上班打卡
+     */
+    @Transactional
+    public Map<String, Object> startDuty(Long userId, String location) {
+        LocalDate today = LocalDate.now();
+
+        // 查找今日排班
+        LambdaQueryWrapper<DutyRecord> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(DutyRecord::getUserId, userId)
+               .eq(DutyRecord::getDutyDate, today)
+               .eq(DutyRecord::getStatus, "scheduled");
+        DutyRecord record = recordMapper.selectOne(wrapper);
+
+        if (record == null) {
+            // 没有排班也允许打卡（临时值班）
+            record = new DutyRecord();
+            record.setUserId(userId);
+            record.setDutyDate(today);
+            record.setShiftType("day");
+            record.setStatus("on_duty");
+            record.setOnDutyAt(LocalDateTime.now());
+            record.setOnDutyLocation(location);
+            record.setCreatedTime(null);
+            recordMapper.insert(record);
+        } else {
+            record.setStatus("on_duty");
+            record.setOnDutyAt(LocalDateTime.now());
+            record.setOnDutyLocation(location);
+            recordMapper.updateById(record);
+        }
+
+        log.info("User {} started duty at {}", userId, record.getOnDutyAt());
+        Map<String, Object> result = new LinkedHashMap<>();
+        result.put("recordId", record.getId());
+        result.put("status", "on_duty");
+        result.put("onDutyAt", record.getOnDutyAt());
+        result.put("message", "上班打卡成功");
+        return result;
+    }
+
+    /**
+     * 下班打卡
+     */
+    @Transactional
+    public Map<String, Object> endDuty(Long userId, String location, String handoverRemark) {
+        LocalDate today = LocalDate.now();
+
+        LambdaQueryWrapper<DutyRecord> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(DutyRecord::getUserId, userId)
+               .eq(DutyRecord::getDutyDate, today)
+               .eq(DutyRecord::getStatus, "on_duty");
+        DutyRecord record = recordMapper.selectOne(wrapper);
+
+        if (record == null) {
+            throw new IllegalStateException("当前无上班记录，无法下班打卡");
+        }
+
+        record.setStatus("off_duty");
+        record.setOffDutyAt(LocalDateTime.now());
+        record.setOffDutyLocation(location);
+        record.setHandoverRemark(handoverRemark);
+        recordMapper.updateById(record);
+
+        // 更新排班状态为已完成
+        if (record.getScheduleId() != null) {
+            DutySchedule schedule = scheduleMapper.selectById(record.getScheduleId());
+            if (schedule != null) {
+                schedule.setStatus(2);
+                scheduleMapper.updateById(schedule);
+            }
+        }
+
+        log.info("User {} ended duty at {}", userId, record.getOffDutyAt());
+        Map<String, Object> result = new LinkedHashMap<>();
+        result.put("recordId", record.getId());
+        result.put("status", "off_duty");
+        result.put("offDutyAt", record.getOffDutyAt());
+        result.put("workDurationMinutes",
+                java.time.Duration.between(record.getOnDutyAt(), record.getOffDutyAt()).toMinutes());
+        result.put("message", "下班打卡成功");
+        return result;
+    }
+
+    /**
+     * 获取值班统计
+     */
+    public Map<String, Object> getDutyStats(Long userId, int year, int month) {
+        LocalDate start = LocalDate.of(year, month, 1);
+        LocalDate end = start.plusMonths(1).minusDays(1);
+
+        List<Map<String, Object>> records = recordMapper.selectUserRecords(userId, start, end);
+
+        long totalDays = records.size();
+        long onTimeCount = records.stream()
+                .filter(r -> r.get("on_duty_at") != null)
+                .count();
+        long completedCount = records.stream()
+                .filter(r -> "off_duty".equals(r.get("status")))
+                .count();
+
+        Map<String, Object> stats = new LinkedHashMap<>();
+        stats.put("totalDays", totalDays);
+        stats.put("onTimeCount", onTimeCount);
+        stats.put("completedCount", completedCount);
+        stats.put("absentCount", totalDays - onTimeCount);
+        stats.put("month", year + "-" + String.format("%02d", month));
+        return stats;
+    }
+
+    /**
+     * 获取当前值班状态
+     */
+    public Map<String, Object> getCurrentDutyStatus(Long userId) {
+        LocalDate today = LocalDate.now();
+        LambdaQueryWrapper<DutyRecord> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(DutyRecord::getUserId, userId)
+               .eq(DutyRecord::getDutyDate, today);
+        DutyRecord record = recordMapper.selectOne(wrapper);
+
+        Map<String, Object> result = new LinkedHashMap<>();
+        if (record == null) {
+            result.put("status", "no_schedule");
+            result.put("message", "今日无排班");
+        } else {
+            result.put("status", record.getStatus());
+            result.put("recordId", record.getId());
+            result.put("onDutyAt", record.getOnDutyAt());
+            result.put("offDutyAt", record.getOffDutyAt());
+            result.put("shiftType", record.getShiftType());
+        }
+        return result;
+    }
+}

wm-production/src/main/java/com/water/production/service/DutyScheduleService.java

+package com.water.production.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.water.production.entity.DutyRecord;
+import com.water.production.entity.DutySchedule;
+import com.water.production.mapper.DutyRecordMapper;
+import com.water.production.mapper.DutyScheduleMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.util.*;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class DutyScheduleService {
+
+    private final DutyScheduleMapper scheduleMapper;
+    private final DutyRecordMapper recordMapper;
+
+    /**
+     * 获取指定月份的排班表
+     */
+    public List<Map<String, Object>> getMonthlySchedule(int year, int month) {
+        LocalDate start = LocalDate.of(year, month, 1);
+        LocalDate end = start.plusMonths(1).minusDays(1);
+        return scheduleMapper.selectScheduleRange(start, end);
+    }
+
+    /**
+     * 获取指定日期范围的排班表
+     */
+    public List<Map<String, Object>> getScheduleRange(LocalDate start, LocalDate end) {
+        return scheduleMapper.selectScheduleRange(start, end);
+    }
+
+    /**
+     * 创建排班
+     */
+    @Transactional
+    public DutySchedule createSchedule(DutySchedule schedule) {
+        schedule.setStatus(1);
+        schedule.setCreatedTime(null);
+        scheduleMapper.insert(schedule);
+
+        // 同时创建值班记录
+        DutyRecord record = new DutyRecord();
+        record.setScheduleId(schedule.getId());
+        record.setUserId(schedule.getUserId());
+        record.setDutyDate(schedule.getDutyDate());
+        record.setShiftType(schedule.getShiftType());
+        record.setStatus("scheduled");
+        record.setCreatedTime(null);
+        recordMapper.insert(record);
+
+        log.info("Created schedule: user={} date={} shift={}",
+                schedule.getUserId(), schedule.getDutyDate(), schedule.getShiftType());
+        return schedule;
+    }
+
+    /**
+     * 批量排班
+     */
+    @Transactional
+    public List<DutySchedule> batchCreateSchedule(List<DutySchedule> schedules) {
+        List<DutySchedule> created = new ArrayList<>();
+        for (DutySchedule s : schedules) {
+            created.add(createSchedule(s));
+        }
+        return created;
+    }
+
+    /**
+     * 自动排班 — 简单轮转算法
+     * @param userIds 值班人员列表
+     * @param startDate 开始日期
+     * @param endDate 结束日期
+     * @param shiftType 班次类型
+     */
+    @Transactional
+    public List<DutySchedule> autoSchedule(List<Long> userIds, LocalDate startDate, LocalDate endDate, String shiftType) {
+        if (userIds == null || userIds.isEmpty()) {
+            throw new IllegalArgumentException("值班人员列表不能为空");
+        }
+        List<DutySchedule> result = new ArrayList<>();
+        LocalDate current = startDate;
+        int idx = 0;
+        while (!current.isAfter(endDate)) {
+            DutySchedule schedule = new DutySchedule();
+            schedule.setUserId(userIds.get(idx % userIds.size()));
+            schedule.setDutyDate(current);
+            schedule.setShiftType(shiftType != null ? shiftType : "day");
+            schedule.setCreatedBy(0L); // system
+            result.add(createSchedule(schedule));
+            current = current.plusDays(1);
+            idx++;
+        }
+        log.info("Auto-scheduled {} days for {} users", result.size(), userIds.size());
+        return result;
+    }
+
+    /**
+     * 取消排班
+     */
+    @Transactional
+    public void cancelSchedule(Long scheduleId) {
+        DutySchedule schedule = scheduleMapper.selectById(scheduleId);
+        if (schedule == null) {
+            throw new IllegalArgumentException("排班记录不存在");
+        }
+        schedule.setStatus(0);
+        scheduleMapper.updateById(schedule);
+
+        // 更新对应的值班记录
+        LambdaQueryWrapper<DutyRecord> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(DutyRecord::getScheduleId, scheduleId);
+        DutyRecord record = recordMapper.selectOne(wrapper);
+        if (record != null) {
+            record.setStatus("absent");
+            recordMapper.updateById(record);
+        }
+        log.info("Cancelled schedule: id={}", scheduleId);
+    }
+
+    /**
+     * 更新排班
+     */
+    @Transactional
+    public DutySchedule updateSchedule(DutySchedule schedule) {
+        DutySchedule existing = scheduleMapper.selectById(schedule.getId());
+        if (existing == null) {
+            throw new IllegalArgumentException("排班记录不存在");
+        }
+        // 只允许修改部分字段
+        if (schedule.getUserId() != null) existing.setUserId(schedule.getUserId());
+        if (schedule.getShiftType() != null) existing.setShiftType(schedule.getShiftType());
+        if (schedule.getArea() != null) existing.setArea(schedule.getArea());
+        if (schedule.getRemark() != null) existing.setRemark(schedule.getRemark());
+        scheduleMapper.updateById(existing);
+        return existing;
+    }
+
+    /**
+     * 获取今日排班
+     */
+    public List<Map<String, Object>> getTodaySchedule() {
+        return scheduleMapper.selectTodaySchedule(LocalDate.now());
+    }
+}

wm-production/src/main/java/com/water/production/service/HandoverService.java

+package com.water.production.service;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.water.production.entity.HandoverRecord;
+import com.water.production.mapper.HandoverRecordMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.util.*;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class HandoverService {
+
+    private final HandoverRecordMapper handoverMapper;
+
+    /**
+     * 创建交接班记录
+     */
+    @Transactional
+    public HandoverRecord createHandover(HandoverRecord record) {
+        record.setHandoverTime(java.time.LocalDateTime.now());
+        record.setFromSign(false);
+        record.setToSign(false);
+        record.setCreatedTime(null);
+        handoverMapper.insert(record);
+        log.info("Handover created: from={} to={} date={}",
+                record.getFromUserId(), record.getToUserId(), record.getDutyDate());
+        return record;
+    }
+
+    /**
+     * 交班人签字确认
+     */
+    @Transactional
+    public void signFrom(Long handoverId) {
+        HandoverRecord record = handoverMapper.selectById(handoverId);
+        if (record == null) {
+            throw new IllegalArgumentException("交接班记录不存在");
+        }
+        record.setFromSign(true);
+        handoverMapper.updateById(record);
+        log.info("Handover signed by from-user: id={}", handoverId);
+    }
+
+    /**
+     * 接班人签字确认
+     */
+    @Transactional
+    public void signTo(Long handoverId) {
+        HandoverRecord record = handoverMapper.selectById(handoverId);
+        if (record == null) {
+            throw new IllegalArgumentException("交接班记录不存在");
+        }
+        record.setToSign(true);
+        handoverMapper.updateById(record);
+        log.info("Handover signed by to-user: id={}", handoverId);
+    }
+
+    /**
+     * 获取指定日期的交接班记录
+     */
+    public List<Map<String, Object>> getByDate(LocalDate date) {
+        return handoverMapper.selectByDate(date);
+    }
+
+    /**
+     * 获取日期范围的交接班记录
+     */
+    public List<Map<String, Object>> getByDateRange(LocalDate start, LocalDate end) {
+        return handoverMapper.selectByDateRange(start, end);
+    }
+
+    /**
+     * 获取交接班详情
+     */
+    public HandoverRecord getDetail(Long id) {
+        HandoverRecord record = handoverMapper.selectById(id);
+        if (record == null) {
+            throw new IllegalArgumentException("交接班记录不存在");
+        }
+        return record;
+    }
+
+    /**
+     * 更新交接班内容
+     */
+    @Transactional
+    public HandoverRecord updateHandover(HandoverRecord update) {
+        HandoverRecord existing = handoverMapper.selectById(update.getId());
+        if (existing == null) {
+            throw new IllegalArgumentException("交接班记录不存在");
+        }
+        if (update.getContent() != null) existing.setContent(update.getContent());
+        if (update.getAbnormalItems() != null) existing.setAbnormalItems(update.getAbnormalItems());
+        if (update.getPendingItems() != null) existing.setPendingItems(update.getPendingItems());
+        if (update.getEquipmentStatus() != null) existing.setEquipmentStatus(update.getEquipmentStatus());
+        handoverMapper.updateById(existing);
+        return existing;
+    }
+
+    /**
+     * 检查指定日期是否已完成交接
+     */
+    public Map<String, Object> checkHandoverStatus(LocalDate date) {
+        LambdaQueryWrapper<HandoverRecord> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(HandoverRecord::getDutyDate, date);
+        List<HandoverRecord> records = handoverMapper.selectList(wrapper);
+
+        Map<String, Object> result = new LinkedHashMap<>();
+        result.put("date", date.toString());
+        result.put("totalRecords", records.size());
+        result.put("allSigned", records.stream().allMatch(r ->
+                Boolean.TRUE.equals(r.getFromSign()) && Boolean.TRUE.equals(r.getToSign())));
+        result.put("records", records);
+        return result;
+    }
+}

wm-production/src/main/resources/db/V_duty.sql

+-- 值班管理模块 DDL
+
+-- 排班表
+CREATE TABLE IF NOT EXISTS duty_schedule (
+    id BIGSERIAL PRIMARY KEY,
+    user_id BIGINT NOT NULL,
+    duty_date DATE NOT NULL,
+    shift_type VARCHAR(20) NOT NULL DEFAULT 'day', -- day/night/full
+    area VARCHAR(100),
+    status INT DEFAULT 1, -- 0=已取消 1=已排班 2=已完成
+    remark VARCHAR(500),
+    created_by BIGINT,
+    created_time TIMESTAMP DEFAULT NOW(),
+    updated_time TIMESTAMP DEFAULT NOW(),
+    UNIQUE(user_id, duty_date, shift_type)
+);
+
+CREATE INDEX idx_duty_schedule_date ON duty_schedule(duty_date);
+CREATE INDEX idx_duty_schedule_user ON duty_schedule(user_id);
+
+-- 值班记录（上下班打卡）
+CREATE TABLE IF NOT EXISTS duty_record (
+    id BIGSERIAL PRIMARY KEY,
+    schedule_id BIGINT REFERENCES duty_schedule(id),
+    user_id BIGINT NOT NULL,
+    duty_date DATE NOT NULL,
+    shift_type VARCHAR(20) NOT NULL,
+    status VARCHAR(20) DEFAULT 'scheduled', -- scheduled/on_duty/off_duty/absent
+    on_duty_at TIMESTAMP,
+    off_duty_at TIMESTAMP,
+    on_duty_location VARCHAR(200),
+    off_duty_location VARCHAR(200),
+    handover_remark TEXT,
+    created_time TIMESTAMP DEFAULT NOW(),
+    updated_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX idx_duty_record_date ON duty_record(duty_date);
+CREATE INDEX idx_duty_record_user ON duty_record(user_id);
+CREATE INDEX idx_duty_record_status ON duty_record(status);
+
+-- 交接班记录
+CREATE TABLE IF NOT EXISTS handover_record (
+    id BIGSERIAL PRIMARY KEY,
+    from_user_id BIGINT NOT NULL,
+    to_user_id BIGINT NOT NULL,
+    duty_date DATE NOT NULL,
+    shift_type VARCHAR(20) NOT NULL,
+    handover_time TIMESTAMP DEFAULT NOW(),
+    content TEXT,
+    abnormal_items TEXT, -- JSON: 异常事项列表
+    pending_items TEXT,  -- JSON: 待处理事项
+    equipment_status TEXT, -- JSON: 设备状态
+    from_sign BOOLEAN DEFAULT FALSE,
+    to_sign BOOLEAN DEFAULT FALSE,
+    created_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX idx_handover_date ON handover_record(duty_date);
+CREATE INDEX idx_handover_from ON handover_record(from_user_id);
+CREATE INDEX idx_handover_to ON handover_record(to_user_id);
+
+-- 值班日志
+CREATE TABLE IF NOT EXISTS duty_log (
+    id BIGSERIAL PRIMARY KEY,
+    user_id BIGINT NOT NULL,
+    duty_date DATE NOT NULL,
+    log_time TIMESTAMP DEFAULT NOW(),
+    log_type VARCHAR(30) NOT NULL, -- patrol/inspection/event/maintenance/other
+    title VARCHAR(200) NOT NULL,
+    content TEXT,
+    location VARCHAR(200),
+    images TEXT, -- JSON: 图片路径列表
+    severity VARCHAR(10), -- normal/warning/critical
+    handled BOOLEAN DEFAULT FALSE,
+    handler_id BIGINT,
+    handle_time TIMESTAMP,
+    handle_result TEXT,
+    created_time TIMESTAMP DEFAULT NOW()
+);
+
+CREATE INDEX idx_duty_log_date ON duty_log(duty_date);
+CREATE INDEX idx_duty_log_user ON duty_log(user_id);
+CREATE INDEX idx_duty_log_type ON duty_log(log_type);

wm-production/src/test/java/com/water/production/service/DutyLogServiceTest.java

+package com.water.production.service;
+
+import com.water.production.entity.DutyLog;
+import com.water.production.mapper.DutyLogMapper;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class DutyLogServiceTest {
+
+    @Mock
+    private DutyLogMapper dutyLogMapper;
+
+    @InjectMocks
+    private DutyLogService logService;
+
+    @Test
+    void testCreateLog() {
+        when(dutyLogMapper.insert(any())).thenReturn(1);
+
+        DutyLog log = new DutyLog();
+        log.setUserId(1L);
+        log.setLogType("patrol");
+        log.setTitle("上午巡查");
+        log.setContent("设备运行正常");
+        log.setSeverity("normal");
+
+        DutyLog result = logService.createLog(log);
+
+        assertFalse(result.getHandled());
+        assertNotNull(result.getLogTime());
+        assertNotNull(result.getDutyDate());
+        verify(dutyLogMapper).insert(any());
+    }
+
+    @Test
+    void testCreateLogWithCustomTime() {
+        when(dutyLogMapper.insert(any())).thenReturn(1);
+
+        DutyLog log = new DutyLog();
+        log.setUserId(1L);
+        log.setLogType("event");
+        log.setTitle("管道泄漏");
+        log.setLogTime(LocalDateTime.of(2026, 6, 14, 10, 30));
+        log.setDutyDate(LocalDate.of(2026, 6, 14));
+
+        DutyLog result = logService.createLog(log);
+
+        assertEquals(LocalDateTime.of(2026, 6, 14, 10, 30), result.getLogTime());
+        assertEquals(LocalDate.of(2026, 6, 14), result.getDutyDate());
+    }
+
+    @Test
+    void testHandleLog() {
+        when(dutyLogMapper.markHandled(eq(1L), eq(1L), eq("已修复"))).thenReturn(1);
+
+        logService.handleLog(1L, 1L, "已修复");
+
+        verify(dutyLogMapper).markHandled(1L, 1L, "已修复");
+    }
+
+    @Test
+    void testHandleLogNotFound() {
+        when(dutyLogMapper.markHandled(eq(999L), any(), any())).thenReturn(0);
+
+        assertThrows(IllegalArgumentException.class, () ->
+                logService.handleLog(999L, 1L, "已修复"));
+    }
+
+    @Test
+    void testGetDetail() {
+        DutyLog log = new DutyLog();
+        log.setId(1L);
+        log.setTitle("巡查记录");
+        when(dutyLogMapper.selectById(1L)).thenReturn(log);
+
+        DutyLog result = logService.getDetail(1L);
+        assertEquals("巡查记录", result.getTitle());
+    }
+
+    @Test
+    void testGetDetailNotFound() {
+        when(dutyLogMapper.selectById(999L)).thenReturn(null);
+        assertThrows(IllegalArgumentException.class, () -> logService.getDetail(999L));
+    }
+
+    @Test
+    void testUpdateLog() {
+        DutyLog existing = new DutyLog();
+        existing.setId(1L);
+        existing.setTitle("原始标题");
+        when(dutyLogMapper.selectById(1L)).thenReturn(existing);
+        when(dutyLogMapper.updateById(any())).thenReturn(1);
+
+        DutyLog update = new DutyLog();
+        update.setId(1L);
+        update.setTitle("更新标题");
+        update.setSeverity("critical");
+
+        DutyLog result = logService.updateLog(update);
+        assertEquals("更新标题", result.getTitle());
+        assertEquals("critical", result.getSeverity());
+    }
+
+    @Test
+    void testDeleteLog() {
+        when(dutyLogMapper.deleteById(1L)).thenReturn(1);
+        logService.deleteLog(1L);
+        verify(dutyLogMapper).deleteById(1L);
+    }
+
+    @Test
+    void testGetLogStats() {
+        List<Map<String, Object>> logs = List.of(
+                Map.of("log_type", "patrol", "severity", "normal", "handled", true),
+                Map.of("log_type", "patrol", "severity", "normal", "handled", false),
+                Map.of("log_type", "event", "severity", "critical", "handled", false)
+        );
+        when(dutyLogMapper.selectByDate(any())).thenReturn(logs);
+
+        Map<String, Object> stats = logService.getLogStats(LocalDate.now());
+
+        assertEquals(3, stats.get("total"));
+        assertEquals(2L, stats.get("unhandled"));
+        @SuppressWarnings("unchecked")
+        Map<String, Long> byType = (Map<String, Long>) stats.get("byType");
+        assertEquals(2L, byType.get("patrol"));
+        assertEquals(1L, byType.get("event"));
+    }
+}

wm-production/src/test/java/com/water/production/service/DutyRecordServiceTest.java

+package com.water.production.service;
+
+import com.water.production.entity.DutyRecord;
+import com.water.production.entity.DutySchedule;
+import com.water.production.mapper.DutyRecordMapper;
+import com.water.production.mapper.DutyScheduleMapper;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class DutyRecordServiceTest {
+
+    @Mock
+    private DutyRecordMapper recordMapper;
+
+    @Mock
+    private DutyScheduleMapper scheduleMapper;
+
+    @InjectMocks
+    private DutyRecordService recordService;
+
+    @Test
+    void testStartDutyWithExistingRecord() {
+        DutyRecord record = new DutyRecord();
+        record.setId(1L);
+        record.setUserId(1L);
+        record.setDutyDate(LocalDate.now());
+        record.setStatus("scheduled");
+
+        when(recordMapper.selectOne(any())).thenReturn(record);
+        when(recordMapper.updateById(any())).thenReturn(1);
+
+        Map<String, Object> result = recordService.startDuty(1L, "办公楼");
+
+        assertEquals("on_duty", result.get("status"));
+        assertNotNull(result.get("onDutyAt"));
+        assertEquals("上班打卡成功", result.get("message"));
+
+        ArgumentCaptor<DutyRecord> captor = ArgumentCaptor.forClass(DutyRecord.class);
+        verify(recordMapper).updateById(captor.capture());
+        assertEquals("on_duty", captor.getValue().getStatus());
+        assertEquals("办公楼", captor.getValue().getOnDutyLocation());
+    }
+
+    @Test
+    void testStartDutyWithoutSchedule() {
+        when(recordMapper.selectOne(any())).thenReturn(null);
+        when(recordMapper.insert(any())).thenReturn(1);
+
+        Map<String, Object> result = recordService.startDuty(1L, "办公楼");
+
+        assertEquals("on_duty", result.get("status"));
+        verify(recordMapper).insert(any());
+    }
+
+    @Test
+    void testEndDuty() {
+        DutyRecord record = new DutyRecord();
+        record.setId(1L);
+        record.setUserId(1L);
+        record.setDutyDate(LocalDate.now());
+        record.setStatus("on_duty");
+        record.setOnDutyAt(LocalDateTime.now().minusHours(8));
+        record.setScheduleId(10L);
+
+        when(recordMapper.selectOne(any())).thenReturn(record);
+        when(recordMapper.updateById(any())).thenReturn(1);
+        when(scheduleMapper.selectById(10L)).thenReturn(new DutySchedule());
+        when(scheduleMapper.updateById(any())).thenReturn(1);
+
+        Map<String, Object> result = recordService.endDuty(1L, "办公楼", "设备正常");
+
+        assertEquals("off_duty", result.get("status"));
+        assertNotNull(result.get("offDutyAt"));
+        assertNotNull(result.get("workDurationMinutes"));
+        assertEquals("下班打卡成功", result.get("message"));
+    }
+
+    @Test
+    void testEndDutyWithoutStartRecord() {
+        when(recordMapper.selectOne(any())).thenReturn(null);
+        assertThrows(IllegalStateException.class, () ->
+                recordService.endDuty(1L, "办公楼", ""));
+    }
+
+    @Test
+    void testGetCurrentDutyStatus() {
+        DutyRecord record = new DutyRecord();
+        record.setStatus("on_duty");
+        record.setOnDutyAt(LocalDateTime.of(2026, 6, 14, 8, 0));
+
+        when(recordMapper.selectOne(any())).thenReturn(record);
+
+        Map<String, Object> result = recordService.getCurrentDutyStatus(1L);
+        assertEquals("on_duty", result.get("status"));
+    }
+
+    @Test
+    void testGetCurrentDutyStatusNoSchedule() {
+        when(recordMapper.selectOne(any())).thenReturn(null);
+
+        Map<String, Object> result = recordService.getCurrentDutyStatus(1L);
+        assertEquals("no_schedule", result.get("status"));
+    }
+
+    @Test
+    void testGetDutyStats() {
+        List<Map<String, Object>> records = List.of(
+                Map.of("status", "off_duty", "on_duty_at", LocalDateTime.of(2026, 6, 1, 8, 0)),
+                Map.of("status", "off_duty", "on_duty_at", LocalDateTime.of(2026, 6, 2, 8, 0)),
+                Map.of("status", "scheduled")
+        );
+        when(recordMapper.selectUserRecords(any(), any(), any())).thenReturn(records);
+
+        Map<String, Object> stats = recordService.getDutyStats(1L, 2026, 6);
+
+        assertEquals(3L, stats.get("totalDays"));
+        assertEquals(2L, stats.get("onTimeCount"));
+        assertEquals(2L, stats.get("completedCount"));
+        assertEquals(1L, stats.get("absentCount"));
+    }
+}

wm-production/src/test/java/com/water/production/service/DutyScheduleServiceTest.java

+package com.water.production.service;
+
+import com.water.production.entity.DutySchedule;
+import com.water.production.mapper.DutyRecordMapper;
+import com.water.production.mapper.DutyScheduleMapper;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.time.LocalDate;
+import java.util.*;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class DutyScheduleServiceTest {
+
+    @Mock
+    private DutyScheduleMapper scheduleMapper;
+
+    @Mock
+    private DutyRecordMapper recordMapper;
+
+    @InjectMocks
+    private DutyScheduleService scheduleService;
+
+    @Test
+    void testGetMonthlySchedule() {
+        List<Map<String, Object>> mockData = List.of(
+                Map.of("id", 1L, "user_id", 1L, "duty_date", LocalDate.of(2026, 6, 1)),
+                Map.of("id", 2L, "user_id", 2L, "duty_date", LocalDate.of(2026, 6, 2))
+        );
+        when(scheduleMapper.selectScheduleRange(any(), any())).thenReturn(mockData);
+
+        List<Map<String, Object>> result = scheduleService.getMonthlySchedule(2026, 6);
+        assertEquals(2, result.size());
+        verify(scheduleMapper).selectScheduleRange(
+                LocalDate.of(2026, 6, 1),
+                LocalDate.of(2026, 6, 30));
+    }
+
+    @Test
+    void testCreateSchedule() {
+        when(scheduleMapper.insert(any())).thenReturn(1);
+        when(recordMapper.insert(any())).thenReturn(1);
+
+        DutySchedule schedule = new DutySchedule();
+        schedule.setUserId(1L);
+        schedule.setDutyDate(LocalDate.of(2026, 6, 15));
+        schedule.setShiftType("day");
+
+        DutySchedule result = scheduleService.createSchedule(schedule);
+
+        assertEquals(1, result.getStatus());
+        verify(scheduleMapper).insert(any());
+        verify(recordMapper).insert(any());
+    }
+
+    @Test
+    void testAutoSchedule() {
+        when(scheduleMapper.insert(any())).thenReturn(1);
+        when(recordMapper.insert(any())).thenReturn(1);
+
+        List<Long> userIds = List.of(1L, 2L, 3L);
+        LocalDate start = LocalDate.of(2026, 6, 1);
+        LocalDate end = LocalDate.of(2026, 6, 5);
+
+        List<DutySchedule> result = scheduleService.autoSchedule(userIds, start, end, "day");
+
+        assertEquals(5, result.size());
+        // 验证轮转：第1天user1，第2天user2，第3天user3，第4天user1，第5天user2
+        assertEquals(1L, result.get(0).getUserId());
+        assertEquals(2L, result.get(1).getUserId());
+        assertEquals(3L, result.get(2).getUserId());
+        assertEquals(1L, result.get(3).getUserId());
+        assertEquals(2L, result.get(4).getUserId());
+    }
+
+    @Test
+    void testAutoScheduleEmptyUsers() {
+        assertThrows(IllegalArgumentException.class, () ->
+                scheduleService.autoSchedule(List.of(), LocalDate.now(), LocalDate.now().plusDays(5), "day"));
+    }
+
+    @Test
+    void testCancelSchedule() {
+        DutySchedule schedule = new DutySchedule();
+        schedule.setId(1L);
+        schedule.setStatus(1);
+        when(scheduleMapper.selectById(1L)).thenReturn(schedule);
+        when(scheduleMapper.updateById(any())).thenReturn(1);
+
+        scheduleService.cancelSchedule(1L);
+
+        ArgumentCaptor<DutySchedule> captor = ArgumentCaptor.forClass(DutySchedule.class);
+        verify(scheduleMapper).updateById(captor.capture());
+        assertEquals(0, captor.getValue().getStatus());
+    }
+
+    @Test
+    void testCancelNonExistentSchedule() {
+        when(scheduleMapper.selectById(999L)).thenReturn(null);
+        assertThrows(IllegalArgumentException.class, () -> scheduleService.cancelSchedule(999L));
+    }
+
+    @Test
+    void testUpdateSchedule() {
+        DutySchedule existing = new DutySchedule();
+        existing.setId(1L);
+        existing.setUserId(1L);
+        existing.setShiftType("day");
+        when(scheduleMapper.selectById(1L)).thenReturn(existing);
+        when(scheduleMapper.updateById(any())).thenReturn(1);
+
+        DutySchedule update = new DutySchedule();
+        update.setId(1L);
+        update.setShiftType("night");
+        update.setArea("新区");
+
+        DutySchedule result = scheduleService.updateSchedule(update);
+        assertEquals("night", result.getShiftType());
+        assertEquals("新区", result.getArea());
+    }
+}

wm-production/src/test/java/com/water/production/service/HandoverServiceTest.java

+package com.water.production.service;
+
+import com.water.production.entity.HandoverRecord;
+import com.water.production.mapper.HandoverRecordMapper;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.time.LocalDate;
+import java.util.Map;
+
+import static org.junit.jupiter.api.Assertions.*;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.*;
+
+@ExtendWith(MockitoExtension.class)
+class HandoverServiceTest {
+
+    @Mock
+    private HandoverRecordMapper handoverMapper;
+
+    @InjectMocks
+    private HandoverService handoverService;
+
+    @Test
+    void testCreateHandover() {
+        when(handoverMapper.insert(any())).thenReturn(1);
+
+        HandoverRecord record = new HandoverRecord();
+        record.setFromUserId(1L);
+        record.setToUserId(2L);
+        record.setDutyDate(LocalDate.now());
+        record.setShiftType("day");
+        record.setContent("设备运行正常");
+
+        HandoverRecord result = handoverService.createHandover(record);
+
+        assertFalse(result.getFromSign());
+        assertFalse(result.getToSign());
+        assertNotNull(result.getHandoverTime());
+        verify(handoverMapper).insert(any());
+    }
+
+    @Test
+    void testSignFrom() {
+        HandoverRecord record = new HandoverRecord();
+        record.setId(1L);
+        record.setFromSign(false);
+        when(handoverMapper.selectById(1L)).thenReturn(record);
+        when(handoverMapper.updateById(any())).thenReturn(1);
+
+        handoverService.signFrom(1L);
+
+        ArgumentCaptor<HandoverRecord> captor = ArgumentCaptor.forClass(HandoverRecord.class);
+        verify(handoverMapper).updateById(captor.capture());
+        assertTrue(captor.getValue().getFromSign());
+    }
+
+    @Test
+    void testSignTo() {
+        HandoverRecord record = new HandoverRecord();
+        record.setId(1L);
+        record.setToSign(false);
+        when(handoverMapper.selectById(1L)).thenReturn(record);
+        when(handoverMapper.updateById(any())).thenReturn(1);
+
+        handoverService.signTo(1L);
+
+        ArgumentCaptor<HandoverRecord> captor = ArgumentCaptor.forClass(HandoverRecord.class);
+        verify(handoverMapper).updateById(captor.capture());
+        assertTrue(captor.getValue().getToSign());
+    }
+
+    @Test
+    void testSignNonExistentRecord() {
+        when(handoverMapper.selectById(999L)).thenReturn(null);
+        assertThrows(IllegalArgumentException.class, () -> handoverService.signFrom(999L));
+        assertThrows(IllegalArgumentException.class, () -> handoverService.signTo(999L));
+    }
+
+    @Test
+    void testGetDetail() {
+        HandoverRecord record = new HandoverRecord();
+        record.setId(1L);
+        record.setContent("交接内容");
+        when(handoverMapper.selectById(1L)).thenReturn(record);
+
+        HandoverRecord result = handoverService.getDetail(1L);
+        assertEquals("交接内容", result.getContent());
+    }
+
+    @Test
+    void testGetDetailNotFound() {
+        when(handoverMapper.selectById(999L)).thenReturn(null);
+        assertThrows(IllegalArgumentException.class, () -> handoverService.getDetail(999L));
+    }
+
+    @Test
+    void testUpdateHandover() {
+        HandoverRecord existing = new HandoverRecord();
+        existing.setId(1L);
+        existing.setContent("原始内容");
+        when(handoverMapper.selectById(1L)).thenReturn(existing);
+        when(handoverMapper.updateById(any())).thenReturn(1);
+
+        HandoverRecord update = new HandoverRecord();
+        update.setId(1L);
+        update.setContent("更新内容");
+
+        HandoverRecord result = handoverService.updateHandover(update);
+        assertEquals("更新内容", result.getContent());
+    }
+}