package com.ruoyi.system.service.impl; import com.ruoyi.common.config.LegacySystemConfig; import com.ruoyi.common.core.domain.entity.SysDept; import com.ruoyi.common.core.domain.entity.SysUser; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.system.domain.SysTask; import com.ruoyi.system.domain.SysTaskEmergency; import com.ruoyi.system.service.ISysDeptService; import com.ruoyi.system.service.ISysUserService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import javax.net.ssl.HttpsURLConnection; import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.OutputStream; import java.net.HttpURLConnection; import java.net.URL; import java.net.URLEncoder; import java.security.cert.X509Certificate; import java.text.SimpleDateFormat; import java.util.Date; import java.util.HashMap; import java.util.Map; @Slf4j @Service public class TaskSyncUtilService { @Autowired private ISysUserService sysUserService; @Autowired private ISysDeptService sysDeptService; @Autowired private LegacySystemConfig legacySystemConfig; /** * 判断用户类型（司机/医生/护士/其他） * 根据用户的角色名称来判断 * * @param user 用户信息 * @return 用户类型：driver/doctor/nurse/other */ public String getUserType(SysUser user) { String roleName = ""; // 从用户的角色列表中获取角色名称 if (user.getRoles() != null && !user.getRoles().isEmpty()) { roleName = user.getRoles().get(0).getRoleName(); } // 判断是否为司机 if (roleName != null && roleName.contains("司机")) { return "driver"; } // 判断是否为医生 if (roleName != null && roleName.contains("医生")) { return "doctor"; } // 判断是否为护士 if (roleName != null && roleName.contains("护士")) { return "nurse"; } // 其他类型，默认为司机（保证至少有一个人员） log.warn("用户角色无法判断类型，默认为司机，用户ID: {}, 角色: {}", user.getUserId(), roleName); return "driver"; } public String getAdminID(SysTask task) { String adminID=""; if (task.getCreatorId() != null) { try { SysUser creator = sysUserService.selectUserById(task.getCreatorId()); if (creator != null && creator.getOaUserId() != null) { adminID = creator.getOaUserId().toString(); log.info("获取创建人OA_UserID成功，用户ID: {}, OA_UserID: {}", task.getCreatorId(), adminID); } else { log.warn("创建人未配置OA_UserID，用户ID: {}", task.getCreatorId()); } } catch (Exception e) { log.error("查询创建人OA_UserID异常，用户ID: {}", task.getCreatorId(), e); } } return adminID; } /** * 构建同步参数 */ public Map buildSyncParams(SysTask task, SysTaskEmergency emergency) { Map params = new HashMap<>(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd"); Long taskId=task.getTaskId(); // 管理员ID（创建人ID对应的OA_UserID） String adminID = this.getAdminID(task); params.put("adminID", adminID); // 服务单分类（从任务所属部门的服务单编码获取） String serviceOrdClass = "BF"; // ServiceOrdClass默认值 if (task.getDeptId() != null) { try { SysDept dept = sysDeptService.selectDeptById(task.getDeptId()); if (dept != null && StringUtils.isNotEmpty(dept.getServiceOrderClass())) { // 使用部门的服务单编码作为ServiceOrdClass serviceOrdClass = dept.getServiceOrderClass(); // log.info("获取任务所属部门的服务单编码成功，部门ID: {}, 部门名称: {}, 服务单编码: {}", // task.getDeptId(), dept.getDeptName(), serviceOrdClass); } else { log.warn("任务所属部门未配置服务单编码，部门ID: {}、部门名称: {}，使用默认值", task.getDeptId(), dept != null ? dept.getDeptName() : "null"); } } catch (Exception e) { log.error("查询任务所属部门信息异常，部门ID: {}", task.getDeptId(), e); } } else { log.warn("任务未关联部门，使用默认服务单编码"); } // 服务单执行区域（从任务的document_type_id获取） String serviceOrdAreaType = "1"; // 默认值 if (StringUtils.isNotEmpty(emergency.getDocumentTypeId())) { serviceOrdAreaType = emergency.getDocumentTypeId(); // log.info("获取单据类型ID成功，任务ID: {}, 单据类型ID: {}", task.getTaskId(), serviceOrdAreaType); } else { log.warn("任务未配置单据类型ID，任务ID: {}，使用默认值", task.getTaskId()); } // 基础信息 params.put("ServiceOrdClass", serviceOrdClass); // 从部门的服务单编码获取 params.put("ServiceOrdAreaType", serviceOrdAreaType); // 从任务的document_type_id获取 // 服务单执行类型（从任务的task_type_id获取） String serviceOrdType = "1"; // 默认值 if (StringUtils.isNotEmpty(emergency.getTaskTypeId())) { serviceOrdType = emergency.getTaskTypeId(); // log.info("获取任务类型ID成功，任务ID: {}, 任务类型ID: {}", taskId, serviceOrdType); } else { log.warn("任务未配置任务类型ID，任务ID: {}，使用默认值", taskId); } params.put("ServiceOrdType", serviceOrdType); // 服务单执行类型（从任务的task_type_id获取） params.put("ServiceOrdState", "2"); // 服务单状态（2=正式单） params.put("ServiceOrdStartDate", task.getCreateTime() != null ? sdfDate.format(task.getCreateTime()) : sdfDate.format(new Date())); // 预约时间 if (task.getPlannedStartTime() != null) { params.put("ServiceOrdApptDate", sdf.format(task.getPlannedStartTime())); } // 联系人信息 params.put("ServiceOrdCoName", StringUtils.nvl(emergency.getPatientContact(), "")); params.put("ServiceOrdCoPhone", StringUtils.nvl(emergency.getPatientPhone(), "")); params.put("ServiceOrdCoTies", ""); // 联系人与患者关系 // 患者信息 params.put("ServiceOrdPtName", StringUtils.nvl(emergency.getPatientName(), "")); params.put("ServiceOrdPtAge", ""); // 年龄 params.put("ServiceOrdPtKG", ""); // 体重 params.put("ServiceOrdPtSex", "0".equals(emergency.getPatientGender()) ? "男" : "1".equals(emergency.getPatientGender()) ? "女" : ""); params.put("ServiceOrdPtNat", ""); // 国籍 params.put("ServiceOrdPtIDCard", StringUtils.nvl(emergency.getPatientIdCard(), "")); // 医院信息 params.put("ServiceOrdPtOutHosp", StringUtils.nvl(emergency.getHospitalOutName(), "")); params.put("ServiceOrdPtOutHospID", emergency.getHospitalOutId() != null ? emergency.getHospitalOutId().toString() : "0"); // 转出医院ID params.put("ServiceOrdPtInHosp", StringUtils.nvl(emergency.getHospitalInName(), "")); params.put("ServiceOrdPtInHospID", emergency.getHospitalInId() != null ? emergency.getHospitalInId().toString() : "0"); // 转入医院ID // 科室信息 params.put("ServiceOrdPtServices", StringUtils.nvl(emergency.getHospitalOutBedNumber(), "")); //转出床位 params.put("ServiceOrdPtServicesID", StringUtils.nvl(emergency.getHospitalOutDepartmentId(), "0")); // 转出科室ID params.put("ServiceOrdPtInServices", StringUtils.nvl(emergency.getHospitalInBedNumber(), "")); //转入床位 params.put("ServiceOrdPtInServicesID", StringUtils.nvl(emergency.getHospitalInDepartmentId(), "0")); // 转入科室ID // 病情信息 params.put("ServiceOrdPtDiagnosis", ""); // 诊断 //病情描述 params.put("ServiceOrdPtCondition", StringUtils.nvl(emergency.getPatientCondition(), "")); params.put("ServiceOrdTaskRemarks", StringUtils.nvl(task.getTaskDescription(), "")); params.put("ServiceOrdPtDoctor", ""); // 患者医生 params.put("ServiceOrdPtDoctorPhone", ""); // 患者医生电话 // 地址信息 params.put("province", ""); // 出发地省份 params.put("city", ""); // 出发地城市 params.put("ServiceOrdTraStreet",task.getDepartureAddress()); //派车地址 params.put("ServiceOrdTraStreetCoo", ""); // 出发地坐标 params.put("ServiceOrdTraEnd", StringUtils.nvl(task.getDestinationAddress(), StringUtils.nvl(emergency.getHospitalInAddress(), ""))); params.put("ServiceOrdTraEndCoo", ""); // 目的地坐标 params.put("ServiceOrdTraVia", ""); // 途经地 // 距离和价格信息 params.put("ServiceOrdViaDistance", "0"); // 中途距离 params.put("ServiceOrdTraDistance", emergency.getTransferDistance() != null ? emergency.getTransferDistance().toString() : "0"); params.put("ServiceOrdTraDuration", ""); // 预计行程时间 params.put("ServiceOrdTraUnitPrice", "0"); // 单价/公里 params.put("ServiceOrdTraOfferPrice", emergency.getTransferPrice() != null ? emergency.getTransferPrice().toString() : "0"); params.put("ServiceOrdTraTxnPrice", emergency.getTransferPrice() != null ? emergency.getTransferPrice().toString() : "0"); params.put("ServiceOrdTraPrePayment", "0"); // 需预付款 params.put("SettlementPrice", "0"); // 结算价 params.put("ServiceOrdTraPriceReason", ""); // 差价原因 // 其他信息 params.put("Phone", StringUtils.nvl(emergency.getPatientPhone(), "")); // 来电电话 params.put("TEL_Time", sdf.format(new Date())); // 来电时间 params.put("TEL_Remarks", "新系统同步"); // 来电备注 params.put("TransferModeID", ""); // 转运方式 params.put("ServiceOrdVIP", "0"); // VIP客户 params.put("ServiceOrd_CC_ID", ""); // 客服人员ID params.put("ServiceOrd_Sale_ID", ""); // 销售人员ID params.put("ServiceOrdIntroducer", ""); // 介绍人 params.put("ServiceOrd_work_ID", ""); // 主要企微客服ID params.put("ServiceOrd_work_IDs", ""); // 其他企微客服ID params.put("ServiceOrd_work_is", "0"); // 是否企微成交 params.put("CommissionScenarioID", "0"); // 企微绩效方案 params.put("ServiceOrdOperationRemarks", "新系统同步创建"); // 操作备注 params.put("ServiceOrdEstimatedOrderDate", ""); // 预计派单时间 params.put("ServiceOrdSource", "10"); // 订单来源（10=新系统） params.put("OrderLevel", "0"); // 查看等级 params.put("ServiceOrdDepartureType", "1"); // 预约类型 params.put("ConditionLevel", "0"); // 病重级别 params.put("DirectionType", "0"); // 转运去向 params.put("ServiceOrd_m", "1"); // 来源入口 params.put("FromHQ2_is", "0"); // 广州总部推送任务标记 params.put("OrderPrice_Auto", "0"); // 订单自动报价参考值 return params; } /** * 发送HTTP/HTTPS POST请求 * 支持HTTPS自签名证书 */ public String sendHttpPost(String urlString, Map params) throws Exception { URL url = new URL(urlString); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); // 如果是HTTPS请求，配置SSL信任所有证书 if (conn instanceof HttpsURLConnection) { HttpsURLConnection httpsConn = (HttpsURLConnection) conn; httpsConn.setSSLSocketFactory(createTrustAllSSLContext().getSocketFactory()); httpsConn.setHostnameVerifier((hostname, session) -> true); // 信任所有主机名 // log.debug("配置HTTPS连接，信任所有SSL证书，URL: {}", urlString); } try { // 设置连接属性 conn.setRequestMethod("POST"); conn.setConnectTimeout(legacySystemConfig.getConnectTimeout()); conn.setReadTimeout(legacySystemConfig.getReadTimeout()); conn.setDoOutput(true); conn.setDoInput(true); conn.setUseCaches(false); conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=" + legacySystemConfig.getCharset()); conn.setRequestProperty("Accept-Charset", legacySystemConfig.getCharset()); // 构建POST数据 StringBuilder postData = new StringBuilder(); for (Map.Entry entry : params.entrySet()) { if (postData.length() > 0) { postData.append("&"); } postData.append(URLEncoder.encode(entry.getKey(), legacySystemConfig.getCharset())); postData.append("="); postData.append(URLEncoder.encode(entry.getValue().toString(), legacySystemConfig.getCharset())); } // 发送POST数据 try (OutputStream os = conn.getOutputStream()) { os.write(postData.toString().getBytes(legacySystemConfig.getCharset())); os.flush(); } // 读取响应 int responseCode = conn.getResponseCode(); if (responseCode == HttpURLConnection.HTTP_OK) { try (BufferedReader reader = new BufferedReader( new InputStreamReader(conn.getInputStream(), legacySystemConfig.getCharset()))) { StringBuilder response = new StringBuilder(); String line; while ((line = reader.readLine()) != null) { response.append(line); } return response.toString().trim(); } } else { log.error("请求失败，请求URL {},参数 {}",urlString,postData); throw new Exception("HTTP/HTTPS请求失败，响应码: " + responseCode); } } finally { conn.disconnect(); } } /** * 解析旧系统响应 * 预期格式: "OK:ServiceOrdID" 或错误信息 */ public Long parseResponse(String response) { if (StringUtils.isEmpty(response)) { return null; } // 去除可能的HTML标签和空白字符 response = response.replaceAll("<[^>]*>", "").trim(); // 检查是否成功响应 if (response.startsWith("OK:")) { try { String serviceOrdIdStr = response.substring(3).trim(); return Long.parseLong(serviceOrdIdStr); } catch (NumberFormatException e) { log.error("解析ServiceOrdID失败: {}", response, e); return null; } } else { log.error("旧系统返回错误: {}", response); return null; } } /** * 创建信任所有SSL证书的SSLContext * 用于支持自签名证书的HTTPS请求 * * 注意：此方法会信任所有SSL证书，包括自签名证书 * 仅用于与旧系统的内部通信，生产环境建议使用正规CA证书 */ private SSLContext createTrustAllSSLContext() throws Exception { // 创建信任所有证书的TrustManager TrustManager[] trustAllCerts = new TrustManager[] { new X509TrustManager() { @Override public X509Certificate[] getAcceptedIssuers() { return null; } @Override public void checkClientTrusted(X509Certificate[] certs, String authType) { // 信任所有客户端证书 } @Override public void checkServerTrusted(X509Certificate[] certs, String authType) { // 信任所有服务器证书 } } }; // 安装信任所有证书的TrustManager SSLContext sslContext = SSLContext.getInstance("TLS"); sslContext.init(null, trustAllCerts, new java.security.SecureRandom()); return sslContext; } }