diff --git a/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/InstructionServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/InstructionServiceImpl.java index 8ea81f6..a88105b 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/InstructionServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/jarvis/service/impl/InstructionServiceImpl.java @@ -1478,123 +1478,214 @@ public class InstructionServiceImpl implements IInstructionService { return null; } - // 参照 JDUtil.parseOrderFromText + // 参照 JDUtil.parseOrderFromText，适配新模板格式 private JDOrder parseOrderFromText(String input) { - // 不要替换所有空格，保留换行符用于正确解析 + // 不清理空白字符，保持原始格式以便正确解析多行字段 Map fields = new HashMap<>(); - // 先尝试新格式（带第三方单号和京粉实际价格） - extractField(input, fields, "单：", "备注："); - extractField(input, fields, "备注：", "分销标记："); - - // 检查是否有"第三方单号："字段，如果没有则是旧格式 - boolean hasThirdPartyOrderNo = input.contains("第三方单号："); - boolean hasJingfenPrice = input.contains("京粉实际价格："); - - if (hasThirdPartyOrderNo) { - // 新格式：有第三方单号字段 - extractField(input, fields, "分销标记：", "第三方单号："); - extractField(input, fields, "第三方单号：", "型号："); - } else { - // 旧格式：分销标记后面直接是型号 - extractField(input, fields, "分销标记：", "型号："); - } - - extractField(input, fields, "型号：", "链接："); - extractField(input, fields, "链接：", "下单付款："); - extractField(input, fields, "下单付款：", "后返金额："); - extractField(input, fields, "后返金额：", "地址："); - extractField(input, fields, "地址：", "物流链接："); - extractField(input, fields, "物流链接：", "订单号："); - extractField(input, fields, "订单号：", "下单人："); - - // 京粉实际价格不从表单解析，而是从数据库查询获取 - // 如果表单中有这个字段，也提取出来（但不会使用，仅用于兼容） - if (hasJingfenPrice) { - extractField(input, fields, "下单人：", "京粉实际价格："); - extractField(input, fields, "京粉实际价格：", ""); + // 检查是否是新格式（包含"下单链接（必须用这个）："或"下单地址（注意带分机）："） + boolean isNewFormat = input.contains("下单链接（必须用这个）：") || input.contains("下单地址（注意带分机）："); + + if (isNewFormat) { + // 新格式：使用新的字段标签和分隔线 + extractFieldWithSeparator(input, fields, "单：", "分销标记："); + extractFieldWithSeparator(input, fields, "分销标记：", "第三方单号："); + extractFieldWithSeparator(input, fields, "第三方单号：", "下单链接（必须用这个）："); + extractFieldWithSeparator(input, fields, "下单链接（必须用这个）：", "下单地址（注意带分机）："); + extractFieldWithSeparator(input, fields, "下单地址（注意带分机）：", "型号："); + extractFieldWithSeparator(input, fields, "型号：", "下单人（需填）："); + extractFieldWithSeparator(input, fields, "下单人（需填）：", "下单付款（注意核对）："); + extractFieldWithSeparator(input, fields, "下单付款（注意核对）：", "后返金额（注意核对）："); + extractFieldWithSeparator(input, fields, "后返金额（注意核对）：", "订单号（需填）："); + extractFieldWithSeparator(input, fields, "订单号（需填）：", "物流链接（需填）："); + extractFieldWithSeparator(input, fields, "物流链接（需填）：", "备注（下单号码有变动/没法带分机号的写这里）："); + + // 手动提取"备注"字段（最后一个字段，可能后面有分隔线或"京粉实际价格"） + java.util.regex.Pattern remarkPattern = java.util.regex.Pattern.compile("备注（下单号码有变动/没法带分机号的写这里）：[\\s\\n]*([\\s\\S]*?)[\\s\\n]*(?=—————————|京粉实际价格|\\Z)", java.util.regex.Pattern.DOTALL); + java.util.regex.Matcher remarkMatcher = remarkPattern.matcher(input); + if (remarkMatcher.find()) { + String remarkValue = remarkMatcher.group(1); + if (remarkValue != null) { + remarkValue = remarkValue.trim(); + // 去掉可能的分隔线 + remarkValue = remarkValue.replaceAll("^—————————[\\s\\n]*", "").trim(); + if (!remarkValue.isEmpty()) { + fields.put("备注", remarkValue); + } + } + } } else { + // 旧格式：兼容旧模板 + extractField(input, fields, "单：", "备注："); + extractField(input, fields, "备注：", "分销标记："); + boolean hasThirdPartyOrderNo = input.contains("第三方单号："); + if (hasThirdPartyOrderNo) { + extractField(input, fields, "分销标记：", "第三方单号："); + extractField(input, fields, "第三方单号：", "型号："); + } else { + extractField(input, fields, "分销标记：", "型号："); + } + extractField(input, fields, "型号：", "链接："); + extractField(input, fields, "链接：", "下单付款："); + extractField(input, fields, "下单付款：", "后返金额："); + extractField(input, fields, "后返金额：", "地址："); + extractField(input, fields, "地址：", "物流链接："); + extractField(input, fields, "物流链接：", "订单号："); + extractField(input, fields, "订单号：", "下单人："); extractField(input, fields, "下单人：", ""); } - // 使用正则提取下单人（兼容新旧格式） - String nextField = hasJingfenPrice ? "京粉实际价格：" : "单："; - java.util.regex.Pattern buyerPattern = java.util.regex.Pattern.compile("下单人：\\s*(.*?)\\s*(?=" + nextField + "|\\Z)", java.util.regex.Pattern.DOTALL); - java.util.regex.Matcher buyerMatcher = buyerPattern.matcher(input); - if (buyerMatcher.find()) { - String buyer = buyerMatcher.group(1).trim(); - // 如果提取的内容包含换行符，可能是提取过度了，只取第一行 - if (buyer.contains("\n")) { - buyer = buyer.split("\n")[0].trim(); - } - fields.put("下单人", buyer); - } - JDOrder order = new JDOrder(); - order.setRemark(fields.getOrDefault("单", null)); - - // 处理分销标记：如果提取的内容包含换行符，说明可能提取过度了，只取第一行 + // 单号（格式：2025-12-13 006） + String orderNo = fields.getOrDefault("单", "").trim(); + order.setRemark(orderNo); + + // 处理分销标记 String distributionMark = fields.getOrDefault("分销标记", null); if (distributionMark != null && distributionMark.contains("\n")) { - // 如果包含换行符，只取第一行，并清理可能的额外内容 String firstLine = distributionMark.split("\n")[0].trim(); - // 检查第一行是否包含其他字段的关键词（如"型号："），如果有则截断 - if (firstLine.contains("型号：") || firstLine.contains("链接：")) { + if (firstLine.contains("型号：") || firstLine.contains("下单链接")) { int index = firstLine.indexOf("型号："); - if (index < 0) index = firstLine.indexOf("链接："); + if (index < 0) index = firstLine.indexOf("下单链接"); if (index > 0) { firstLine = firstLine.substring(0, index).trim(); } } distributionMark = firstLine; } - // 如果分销标记是H-TF格式（包含括号），只保留H-TF if (distributionMark != null && distributionMark.startsWith("H-TF(")) { distributionMark = "H-TF"; } order.setDistributionMark(distributionMark); - - // 优先从字段中获取第三方单号，如果没有则从分销标记中提取 + + // 型号 + order.setModelNumber(fields.getOrDefault("型号", null)); + + // 下单链接（新格式）或链接（旧格式） + String link = fields.getOrDefault("下单链接（必须用这个）", null); + if (link == null) { + link = fields.getOrDefault("链接", null); + } + order.setLink(link); + + // 备注字段 + order.setStatus(fields.getOrDefault("备注", null)); + + // 第三方单号 String thirdPartyOrderNo = fields.getOrDefault("第三方单号", null); if (thirdPartyOrderNo != null) { - // 清理换行符和空白字符 thirdPartyOrderNo = thirdPartyOrderNo.replaceAll("\\s+", "").trim(); } - if (thirdPartyOrderNo == null || thirdPartyOrderNo.isEmpty()) { - if (distributionMark != null && !distributionMark.isEmpty()) { - thirdPartyOrderNo = extractOrderNumber(distributionMark); + if ((thirdPartyOrderNo == null || thirdPartyOrderNo.isEmpty()) && distributionMark != null) { + thirdPartyOrderNo = extractOrderNumber(distributionMark); + } + if (thirdPartyOrderNo != null && !thirdPartyOrderNo.trim().isEmpty()) { + order.setThirdPartyOrderNo(thirdPartyOrderNo.trim()); + } + + // 下单付款（新格式）或下单付款（旧格式） + String paymentStr = fields.getOrDefault("下单付款（注意核对）", null); + if (paymentStr == null) { + paymentStr = fields.getOrDefault("下单付款", "0"); + } + try { + paymentStr = paymentStr.trim(); + if (!paymentStr.isEmpty() && !paymentStr.equals("0")) { + order.setPaymentAmount(Double.parseDouble(paymentStr)); } - } - // 保存第三方单号到订单对象 - order.setThirdPartyOrderNo(thirdPartyOrderNo != null && !thirdPartyOrderNo.trim().isEmpty() ? thirdPartyOrderNo.trim() : null); - order.setModelNumber(fields.getOrDefault("型号", null)); - order.setLink(fields.getOrDefault("链接", null)); - order.setStatus(fields.getOrDefault("备注", null)); - try { - order.setPaymentAmount(Double.parseDouble(fields.getOrDefault("下单付款", "0"))); } catch (Exception ignore) { } + + // 后返金额（新格式）或后返金额（旧格式） + String rebateStr = fields.getOrDefault("后返金额（注意核对）", null); + if (rebateStr == null) { + rebateStr = fields.getOrDefault("后返金额", "0"); + } try { - order.setRebateAmount(Double.parseDouble(fields.getOrDefault("后返金额", "0"))); + rebateStr = rebateStr.trim(); + if (!rebateStr.isEmpty() && !rebateStr.equals("0")) { + order.setRebateAmount(Double.parseDouble(rebateStr)); + } } catch (Exception ignore) { } - order.setAddress(fields.getOrDefault("地址", null)); - // 写入数据库时清理物流链接，只保留URL - order.setLogisticsLink(extractFirstUrl(fields.getOrDefault("物流链接", ""))); - order.setOrderId(fields.getOrDefault("订单号", null)); - order.setBuyer(fields.getOrDefault("下单人", null)); - // 京粉实际价格不从表单解析，而是从数据库order_rows表中查询获取 + + // 下单地址（新格式）或地址（旧格式） + String address = fields.getOrDefault("下单地址（注意带分机）", null); + if (address == null) { + address = fields.getOrDefault("地址", null); + } + order.setAddress(address); + + // 物流链接 + String logisticsLink = fields.getOrDefault("物流链接（需填）", null); + if (logisticsLink == null) { + logisticsLink = fields.getOrDefault("物流链接", ""); + } + order.setLogisticsLink(extractFirstUrl(logisticsLink)); + + // 订单号 + String orderId = fields.getOrDefault("订单号（需填）", null); + if (orderId == null) { + orderId = fields.getOrDefault("订单号", null); + } + order.setOrderId(orderId); + + // 下单人 + String buyer = fields.getOrDefault("下单人（需填）", null); + if (buyer == null) { + buyer = fields.getOrDefault("下单人", null); + } + order.setBuyer(buyer); + // 默认参与统计 order.setIsCountEnabled(1); + + // 设置下单时间 try { - String dateStr = fields.getOrDefault("单", "").split(" ")[0]; - java.text.SimpleDateFormat sdf2 = new java.text.SimpleDateFormat("yyyy-MM-dd"); - order.setOrderTime(sdf2.parse(dateStr)); + if (!orderNo.isEmpty()) { + String dateStr = orderNo.split("\\s+")[0]; // 从"2025-12-13 006"中提取日期部分 + java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd"); + order.setOrderTime(sdf.parse(dateStr)); + } else { + order.setOrderTime(new Date()); + } } catch (Exception e) { order.setOrderTime(new Date()); } + return order; } + + // 提取字段的方法（支持分隔线，用于新格式） + private void extractFieldWithSeparator(String input, Map map, String startKeyword, String endKeyword) { + try { + String escapedStart = java.util.regex.Pattern.quote(startKeyword); + String escapedEnd = java.util.regex.Pattern.quote(endKeyword); + + // 匹配模式：startKeyword + 可选的空白和换行 + 字段值（非贪婪，支持多行） + 后面是换行+endKeyword或换行+分隔线或结束 + String patternStr = escapedStart + "[\\s\\n]*([\\s\\S]*?)(?=\\s*\\n?\\s*" + escapedEnd + "|\\s*\\n?\\s*—————————|\\Z)"; + java.util.regex.Pattern pattern = java.util.regex.Pattern.compile(patternStr, java.util.regex.Pattern.DOTALL); + java.util.regex.Matcher matcher = pattern.matcher(input); + + if (matcher.find()) { + String value = matcher.group(1); + if (value != null) { + value = value.trim(); + // 去掉可能的分隔线（在值的前后） + value = value.replaceAll("^—————————[\\s\\n]*", "").replaceAll("[\\s\\n]*—————————$", "").trim(); + // 去掉字段标签本身（如果被匹配到了） + value = value.replaceAll("^" + escapedStart, "").trim(); + // 保存字段值，使用去掉冒号的key + String key = startKeyword.replace("：", "").trim(); + if (!value.isEmpty()) { + map.put(key, value); + } + } + } + } catch (Exception e) { + System.err.println("提取字段失败: startKeyword=" + startKeyword + ", endKeyword=" + endKeyword + ", error=" + e.getMessage()); + } + } private void extractField(String input, Map map, String startKeyword, String endKeyword) { // 如果结束关键词为空，匹配到字符串末尾