1

api/controller_admin/resume_info.js

@@ -358,6 +358,100 @@ return ctx.success({ message: '简历删除成功' });
       console.error('AI 分析失败:', error);
       return ctx.fail('AI 分析失败: ' + error.message);
     }
+  },
+
+  /**
+   * @swagger
+   * /admin_api/resume/sync-online:
+   *   post:
+   *     summary: 同步在线简历
+   *     description: 通过MQTT指令获取用户在线简历并更新到数据库
+   *     tags: [后台-简历管理]
+   *     requestBody:
+   *       required: true
+   *       content:
+   *         application/json:
+   *           schema:
+   *             type: object
+   *             required:
+   *               - resumeId
+   *             properties:
+   *               resumeId:
+   *                 type: string
+   *                 description: 简历ID
+   *     responses:
+   *       200:
+   *         description: 同步成功
+   */
+  'POST /resume/sync-online': async (ctx) => {
+    const models = Framework.getModels();
+    const { resume_info } = models;
+    const { resumeId } = ctx.getBody();
+
+    if (!resumeId) {
+      return ctx.fail('简历ID不能为空');
+    }
+
+    const resume = await resume_info.findOne({ where: { resumeId } });
+
+    if (!resume) {
+      return ctx.fail('简历不存在');
+    }
+
+    const { sn_code, platform } = resume;
+
+    if (!sn_code) {
+      return ctx.fail('该简历未绑定设备SN码');
+    }
+
+    try {
+      const scheduleManager = require('../middleware/schedule');
+      const resumeManager = require('../middleware/job/resumeManager');
+
+      // 检查 MQTT 客户端是否已初始化
+      if (!scheduleManager.mqttClient) {
+        return ctx.fail('MQTT客户端未初始化，请检查调度系统是否正常启动');
+      }
+
+      // 检查设备是否在线
+      // const deviceManager = require('../middleware/schedule/deviceManager');
+      // if (!deviceManager.isDeviceOnline(sn_code)) {
+      //   return ctx.fail('设备离线，无法同步在线简历');
+      // }
+
+      // 调用简历管理器获取并保存简历
+      const resumeData = await resumeManager.get_online_resume(sn_code, scheduleManager.mqttClient, {
+        platform: platform || 'boss'
+      });
+
+      // 重新获取更新后的简历数据
+      const updatedResume = await resume_info.findOne({ where: { resumeId } });
+      if (!updatedResume) {
+        return ctx.fail('同步成功但未找到更新后的简历记录');
+      }
+
+      const resumeDetail = updatedResume.toJSON();
+      
+      // 解析 JSON 字段
+      const jsonFields = ['skills', 'certifications', 'projectExperience', 'workExperience', 'aiSkillTags'];
+      jsonFields.forEach(field => {
+        if (resumeDetail[field]) {
+          try {
+            resumeDetail[field] = JSON.parse(resumeDetail[field]);
+          } catch (e) {
+            console.error(`解析字段 ${field} 失败:`, e);
+          }
+        }
+      });
+
+      return ctx.success({
+        message: '同步在线简历成功',
+        data: resumeDetail
+      });
+    } catch (error) {
+      console.error('同步在线简历失败:', error);
+      return ctx.fail('同步在线简历失败: ' + (error.message || '未知错误'));
+    }
   }
 };