增加与ai大模型对话

huimv-employment/fe-api/src/main/java/com/huimv/employment/controller/internal/InternalDraftController.java

@@ -0,0 +1,41 @@
+package com.huimv.employment.controller.internal;
+
+import com.huimv.employment.common.web.R;
+import com.huimv.employment.service.draft.DraftService;
+import com.huimv.employment.service.draft.dto.DraftCreateRequest;
+import com.huimv.employment.service.draft.dto.DraftDetailResponse;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.enums.ParameterIn;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * AI 内网工具：用工草稿写入。
+ * <p>鉴权：请求头 {@code X-Fe-Ai-Key}（见 {@code fe.internal.ai-key}），不走 JWT。</p>
+ */
+@RestController
+@RequestMapping("/internal/fe/drafts")
+@Tag(name = "内网-AI工具", description = "供智能体 HTTP 回调，使用 X-Fe-Ai-Key 鉴权")
+public class InternalDraftController {
+
+    private final DraftService draftService;
+
+    public InternalDraftController(DraftService draftService) {
+        this.draftService = draftService;
+    }
+
+    @PostMapping
+    @Operation(summary = "创建用工草稿",
+            description = "AI 子模块根据对话上下文生成草稿后调用。写入 fe_employment_draft 与 fe_draft_field，"
+                    + "返回 draftId 供小程序 card_payload / next_action 跳转。",
+            parameters = @Parameter(name = "X-Fe-Ai-Key", in = ParameterIn.HEADER,
+                    description = "内网服务密钥，与 fe.internal.ai-key 一致"))
+    public R<DraftDetailResponse> create(@Validated @RequestBody DraftCreateRequest request) {
+        return R.ok(draftService.createFromAi(request));
+    }
+}

huimv-employment/fe-api/src/main/java/com/huimv/employment/security/InternalAiAuthFilter.java

@@ -0,0 +1,84 @@
+package com.huimv.employment.security;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.huimv.employment.common.exception.ErrorCode;
+import com.huimv.employment.common.web.R;
+import com.huimv.employment.service.config.InternalApiProperties;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Component;
+import org.springframework.util.StringUtils;
+import org.springframework.web.filter.OncePerRequestFilter;
+
+import javax.servlet.FilterChain;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.nio.charset.StandardCharsets;
+
+/**
+ * 内网 AI 工具接口鉴权：保护 {@code /internal/fe/**}，校验 {@code X-Fe-Ai-Key} 与可选 IP 白名单。
+ */
+@Component
+@Order(Ordered.HIGHEST_PRECEDENCE + 10)
+public class InternalAiAuthFilter extends OncePerRequestFilter {
+
+    private static final String HEADER_AI_KEY = "X-Fe-Ai-Key";
+
+    private final InternalApiProperties internalApiProperties;
+    private final ObjectMapper objectMapper;
+
+    public InternalAiAuthFilter(InternalApiProperties internalApiProperties, ObjectMapper objectMapper) {
+        this.internalApiProperties = internalApiProperties;
+        this.objectMapper = objectMapper;
+    }
+
+    @Override
+    protected boolean shouldNotFilter(HttpServletRequest request) {
+        String path = request.getRequestURI();
+        return path == null || !path.startsWith("/internal/fe/");
+    }
+
+    @Override
+    protected void doFilterInternal(HttpServletRequest request,
+                                    HttpServletResponse response,
+                                    FilterChain filterChain) throws ServletException, IOException {
+        if (!internalApiProperties.isEnabled()) {
+            writeError(response, ErrorCode.INTERNAL_API_DISABLED);
+            return;
+        }
+        if (internalApiProperties.requiresAiKey()) {
+            String providedKey = request.getHeader(HEADER_AI_KEY);
+            if (!internalApiProperties.getAiKey().equals(providedKey)) {
+                writeError(response, ErrorCode.INTERNAL_API_UNAUTHORIZED);
+                return;
+            }
+        }
+        if (internalApiProperties.hasIpRestriction()) {
+            String clientIp = resolveClientIp(request);
+            if (!internalApiProperties.isAllowedIp(clientIp)) {
+                writeError(response, ErrorCode.FORBIDDEN);
+                return;
+            }
+        }
+        filterChain.doFilter(request, response);
+    }
+
+    private String resolveClientIp(HttpServletRequest request) {
+        String forwarded = request.getHeader("X-Forwarded-For");
+        if (StringUtils.hasText(forwarded)) {
+            int commaIndex = forwarded.indexOf(',');
+            return commaIndex > 0 ? forwarded.substring(0, commaIndex).trim() : forwarded.trim();
+        }
+        return request.getRemoteAddr();
+    }
+
+    private void writeError(HttpServletResponse response, ErrorCode errorCode) throws IOException {
+        response.setStatus(HttpServletResponse.SC_OK);
+        response.setCharacterEncoding(StandardCharsets.UTF_8.name());
+        response.setContentType(MediaType.APPLICATION_JSON_VALUE);
+        response.getWriter().write(objectMapper.writeValueAsString(R.fail(errorCode.getCode(), errorCode.getMessage())));
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/config/InternalApiProperties.java

@@ -0,0 +1,73 @@
+package com.huimv.employment.service.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.util.StringUtils;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * AI 内网工具接口配置，绑定 {@code fe.internal.*}。
+ */
+@ConfigurationProperties(prefix = "fe.internal")
+public class InternalApiProperties {
+
+    /** 是否启用 /internal/fe/** 接口 */
+    private boolean enabled = true;
+
+    /**
+     * 服务密钥，请求头 {@code X-Fe-Ai-Key} 须与此一致。
+     * 为空时不校验密钥（仅建议本地开发）。
+     */
+    private String aiKey = "";
+
+    /** 可选 IP 白名单；为空表示不限制来源 IP */
+    private List<String> allowedIps = new ArrayList<>();
+
+    public boolean isEnabled() {
+        return enabled;
+    }
+
+    public void setEnabled(boolean enabled) {
+        this.enabled = enabled;
+    }
+
+    public String getAiKey() {
+        return aiKey;
+    }
+
+    public void setAiKey(String aiKey) {
+        this.aiKey = aiKey;
+    }
+
+    public List<String> getAllowedIps() {
+        return allowedIps;
+    }
+
+    public void setAllowedIps(List<String> allowedIps) {
+        this.allowedIps = allowedIps != null ? allowedIps : new ArrayList<>();
+    }
+
+    public boolean requiresAiKey() {
+        return StringUtils.hasText(aiKey);
+    }
+
+    public boolean hasIpRestriction() {
+        return allowedIps != null && !allowedIps.isEmpty();
+    }
+
+    public boolean isAllowedIp(String clientIp) {
+        if (!hasIpRestriction()) {
+            return true;
+        }
+        if (!StringUtils.hasText(clientIp)) {
+            return false;
+        }
+        return allowedIps.contains(clientIp.trim());
+    }
+
+    public List<String> getAllowedIpsView() {
+        return allowedIps == null ? Collections.emptyList() : Collections.unmodifiableList(allowedIps);
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/draft/dto/DraftCreateRequest.java

@@ -0,0 +1,309 @@
+package com.huimv.employment.service.draft.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import javax.validation.Valid;
+import javax.validation.constraints.DecimalMin;
+import javax.validation.constraints.Max;
+import javax.validation.constraints.Min;
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import javax.validation.constraints.Size;
+import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.util.List;
+
+/**
+ * AI 内网创建用工草稿请求。
+ */
+@Schema(description = "AI 创建用工草稿请求")
+public class DraftCreateRequest {
+
+    @Schema(description = "所属企业 ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "10")
+    @NotNull(message = "enterpriseId 不能为空")
+    private Long enterpriseId;
+
+    @Schema(description = "来源会话 ID（可选）", example = "1")
+    private Long conversationId;
+
+    @Schema(description = "场景：existing_worker_regularization / new_demand",
+            requiredMode = Schema.RequiredMode.REQUIRED, example = "new_demand")
+    @NotBlank(message = "scenario 不能为空")
+    private String scenario;
+
+    @Schema(description = "自定义草稿编号（可选，须全局唯一；不传则自动生成）", example = "draft_001")
+    @Size(max = 32, message = "draftNo 不能超过 32 字符")
+    private String draftNo;
+
+    @Schema(description = "标题")
+    @Size(max = 200, message = "标题不能超过 200 字")
+    private String title;
+
+    @Schema(description = "计划用工人数")
+    @Min(value = 1, message = "用工人数至少为 1")
+    private Integer workerCount;
+
+    @Schema(description = "计划工作天数")
+    @Min(value = 1, message = "工作天数至少为 1")
+    private Integer workDays;
+
+    @Schema(description = "岗位/工种")
+    @Size(max = 100)
+    private String workType;
+
+    @Schema(description = "工作内容")
+    private String workContent;
+
+    @Schema(description = "工作地点")
+    @Size(max = 500)
+    private String workLocation;
+
+    @Schema(description = "工作地点来源：enterprise_registered_address / user_input / ai_inferred")
+    private String workLocationSource;
+
+    @Schema(description = "结算方式：daily / piece / monthly")
+    private String settlementMode;
+
+    @Schema(description = "日薪（元）")
+    @DecimalMin(value = "0.01", message = "日薪必须大于 0")
+    private BigDecimal dailyWage;
+
+    @Schema(description = "是否购买保险，默认 true")
+    private Boolean insuranceRequired;
+
+    @Schema(description = "保险档次：basic / standard / premium")
+    private String insuranceLevel;
+
+    @Schema(description = "是否要求打卡，默认 false")
+    private Boolean checkInRequired;
+
+    @Schema(description = "登记二维码有效天数，默认 7")
+    @Min(value = 1, message = "二维码有效天数至少为 1")
+    @Max(value = 90, message = "二维码有效天数不能超过 90")
+    private Integer qrValidDays;
+
+    @Schema(description = "计划开工日期")
+    private LocalDate workStartDate;
+
+    @Schema(description = "计划结束日期")
+    private LocalDate workEndDate;
+
+    @Schema(description = "岗位要求")
+    private String jobRequirements;
+
+    @Schema(description = "待补充字段名列表", example = "[\"daily_wage\",\"work_location\"]")
+    private List<String> missingFields;
+
+    @Schema(description = "风险提示", example = "[\"未签劳动合同存在用工风险\"]")
+    private List<String> riskPrompts;
+
+    @Schema(description = "预估总支出（元）")
+    private BigDecimal estimatedTotal;
+
+    @Schema(description = "预估人均成本（元）")
+    private BigDecimal estimatedPerCapita;
+
+    @Schema(description = "字段级明细（来源、可编辑性）")
+    @Valid
+    private List<DraftFieldCreateRequest> fields;
+
+    public Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+
+    public Long getConversationId() {
+        return conversationId;
+    }
+
+    public void setConversationId(Long conversationId) {
+        this.conversationId = conversationId;
+    }
+
+    public String getScenario() {
+        return scenario;
+    }
+
+    public void setScenario(String scenario) {
+        this.scenario = scenario;
+    }
+
+    public String getDraftNo() {
+        return draftNo;
+    }
+
+    public void setDraftNo(String draftNo) {
+        this.draftNo = draftNo;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public Integer getWorkerCount() {
+        return workerCount;
+    }
+
+    public void setWorkerCount(Integer workerCount) {
+        this.workerCount = workerCount;
+    }
+
+    public Integer getWorkDays() {
+        return workDays;
+    }
+
+    public void setWorkDays(Integer workDays) {
+        this.workDays = workDays;
+    }
+
+    public String getWorkType() {
+        return workType;
+    }
+
+    public void setWorkType(String workType) {
+        this.workType = workType;
+    }
+
+    public String getWorkContent() {
+        return workContent;
+    }
+
+    public void setWorkContent(String workContent) {
+        this.workContent = workContent;
+    }
+
+    public String getWorkLocation() {
+        return workLocation;
+    }
+
+    public void setWorkLocation(String workLocation) {
+        this.workLocation = workLocation;
+    }
+
+    public String getWorkLocationSource() {
+        return workLocationSource;
+    }
+
+    public void setWorkLocationSource(String workLocationSource) {
+        this.workLocationSource = workLocationSource;
+    }
+
+    public String getSettlementMode() {
+        return settlementMode;
+    }
+
+    public void setSettlementMode(String settlementMode) {
+        this.settlementMode = settlementMode;
+    }
+
+    public BigDecimal getDailyWage() {
+        return dailyWage;
+    }
+
+    public void setDailyWage(BigDecimal dailyWage) {
+        this.dailyWage = dailyWage;
+    }
+
+    public Boolean getInsuranceRequired() {
+        return insuranceRequired;
+    }
+
+    public void setInsuranceRequired(Boolean insuranceRequired) {
+        this.insuranceRequired = insuranceRequired;
+    }
+
+    public String getInsuranceLevel() {
+        return insuranceLevel;
+    }
+
+    public void setInsuranceLevel(String insuranceLevel) {
+        this.insuranceLevel = insuranceLevel;
+    }
+
+    public Boolean getCheckInRequired() {
+        return checkInRequired;
+    }
+
+    public void setCheckInRequired(Boolean checkInRequired) {
+        this.checkInRequired = checkInRequired;
+    }
+
+    public Integer getQrValidDays() {
+        return qrValidDays;
+    }
+
+    public void setQrValidDays(Integer qrValidDays) {
+        this.qrValidDays = qrValidDays;
+    }
+
+    public LocalDate getWorkStartDate() {
+        return workStartDate;
+    }
+
+    public void setWorkStartDate(LocalDate workStartDate) {
+        this.workStartDate = workStartDate;
+    }
+
+    public LocalDate getWorkEndDate() {
+        return workEndDate;
+    }
+
+    public void setWorkEndDate(LocalDate workEndDate) {
+        this.workEndDate = workEndDate;
+    }
+
+    public String getJobRequirements() {
+        return jobRequirements;
+    }
+
+    public void setJobRequirements(String jobRequirements) {
+        this.jobRequirements = jobRequirements;
+    }
+
+    public List<String> getMissingFields() {
+        return missingFields;
+    }
+
+    public void setMissingFields(List<String> missingFields) {
+        this.missingFields = missingFields;
+    }
+
+    public List<String> getRiskPrompts() {
+        return riskPrompts;
+    }
+
+    public void setRiskPrompts(List<String> riskPrompts) {
+        this.riskPrompts = riskPrompts;
+    }
+
+    public BigDecimal getEstimatedTotal() {
+        return estimatedTotal;
+    }
+
+    public void setEstimatedTotal(BigDecimal estimatedTotal) {
+        this.estimatedTotal = estimatedTotal;
+    }
+
+    public BigDecimal getEstimatedPerCapita() {
+        return estimatedPerCapita;
+    }
+
+    public void setEstimatedPerCapita(BigDecimal estimatedPerCapita) {
+        this.estimatedPerCapita = estimatedPerCapita;
+    }
+
+    public List<DraftFieldCreateRequest> getFields() {
+        return fields;
+    }
+
+    public void setFields(List<DraftFieldCreateRequest> fields) {
+        this.fields = fields;
+    }
+}

huimv-employment/fe-service/src/main/java/com/huimv/employment/service/draft/dto/DraftFieldCreateRequest.java

@@ -0,0 +1,93 @@
+package com.huimv.employment.service.draft.dto;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Size;
+
+/**
+ * AI 创建草稿时的字段明细。
+ */
+@Schema(description = "草稿字段明细（创建）")
+public class DraftFieldCreateRequest {
+
+    @Schema(description = "字段键名", example = "work_location", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotBlank(message = "fieldKey 不能为空")
+    @Size(max = 100, message = "fieldKey 不能超过 100 字符")
+    private String fieldKey;
+
+    @Schema(description = "字段中文标签", example = "工作地点")
+    @Size(max = 100, message = "fieldLabel 不能超过 100 字符")
+    private String fieldLabel;
+
+    @Schema(description = "文本值")
+    private String fieldValue;
+
+    @Schema(description = "复杂类型 JSON 值")
+    private String valueJson;
+
+    @Schema(description = "来源：enterprise_profile / ai_inferred / default 等", example = "ai_inferred")
+    private String source;
+
+    @Schema(description = "是否可编辑", example = "true")
+    private Boolean editable;
+
+    @Schema(description = "是否默认值（未修改）", example = "true")
+    private Boolean isDefault;
+
+    public String getFieldKey() {
+        return fieldKey;
+    }
+
+    public void setFieldKey(String fieldKey) {
+        this.fieldKey = fieldKey;
+    }
+
+    public String getFieldLabel() {
+        return fieldLabel;
+    }
+
+    public void setFieldLabel(String fieldLabel) {
+        this.fieldLabel = fieldLabel;
+    }
+
+    public String getFieldValue() {
+        return fieldValue;
+    }
+
+    public void setFieldValue(String fieldValue) {
+        this.fieldValue = fieldValue;
+    }
+
+    public String getValueJson() {
+        return valueJson;
+    }
+
+    public void setValueJson(String valueJson) {
+        this.valueJson = valueJson;
+    }
+
+    public String getSource() {
+        return source;
+    }
+
+    public void setSource(String source) {
+        this.source = source;
+    }
+
+    public Boolean getEditable() {
+        return editable;
+    }
+
+    public void setEditable(Boolean editable) {
+        this.editable = editable;
+    }
+
+    public Boolean getIsDefault() {
+        return isDefault;
+    }
+
+    public void setIsDefault(Boolean isDefault) {
+        this.isDefault = isDefault;
+    }
+}