From 5f2ee03958a1a16dc27195c76ea7cffb422c95d1 Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期五, 19 十二月 2025 22:40:34 +0800
Subject: [PATCH] feat: 任务修改接口，删除一些不要的字段同步
---
ruoyi-system/src/main/java/com/ruoyi/system/service/impl/LegacySystemSyncServiceImpl.java | 1253 ++++------------------------------------------------------
1 files changed, 104 insertions(+), 1,149 deletions(-)
diff --git a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/LegacySystemSyncServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/LegacySystemSyncServiceImpl.java
index 487b710..f78b7ff 100644
--- a/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/LegacySystemSyncServiceImpl.java
+++ b/ruoyi-system/src/main/java/com/ruoyi/system/service/impl/LegacySystemSyncServiceImpl.java
@@ -1,44 +1,20 @@
package com.ruoyi.system.service.impl;
-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.text.SimpleDateFormat;
import java.util.Date;
-import java.util.HashMap;
import java.util.List;
-import java.util.Map;
-import javax.net.ssl.HttpsURLConnection;
-import javax.net.ssl.SSLContext;
-import javax.net.ssl.TrustManager;
-import javax.net.ssl.X509TrustManager;
-import java.security.cert.X509Certificate;
+import com.ruoyi.common.utils.LongUtil;
import com.ruoyi.system.domain.*;
+import com.ruoyi.system.mapper.*;
import com.ruoyi.system.service.*;
import com.ruoyi.system.task.ITaskAttachmentService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
import com.ruoyi.common.config.LegacySystemConfig;
-import com.ruoyi.common.utils.StringUtils;
-import com.ruoyi.common.core.domain.entity.SysUser;
-import com.ruoyi.common.core.domain.entity.SysDept;
-import com.ruoyi.system.domain.vo.TaskCreateVO;
-import com.ruoyi.system.mapper.SysTaskMapper;
-import com.ruoyi.system.mapper.SysTaskEmergencyMapper;
-import com.ruoyi.system.mapper.SysTaskVehicleMapper;
-import com.ruoyi.system.mapper.SysTaskAssigneeMapper;
-import com.ruoyi.system.mapper.VehicleInfoMapper;
-import com.ruoyi.system.mapper.SysUserMapper;
-import com.ruoyi.system.mapper.SysDeptMapper;
-import com.ruoyi.system.utils.TaskStatusConverter;
/**
* 鏃х郴缁熷悓姝ervice涓氬姟灞傚鐞�
@@ -91,103 +67,28 @@
private ITaskAttachmentService taskAttachmentService;
+ @Autowired
+ private ApplicationEventPublisher eventPublisher;
- /**
- * 鍚屾鎬ユ晳杞繍浠诲姟鍒版棫绯荤粺
- */
+ @Autowired
+ private LegacyTransferSyncMapper legacyTransferSyncMapper;
+
+
+ @Autowired
+ private TaskEmergencySyncService taskEmergencySyncService;
+
+
+ @Autowired
+ private ITaskDispatchSyncService taskDispatchSyncService;
+
+
+
+
@Override
- @Transactional
public Long syncEmergencyTaskToLegacy(Long taskId) {
- if (!legacyConfig.isEnabled()) {
- log.info("鏃х郴缁熷悓姝ュ凡绂佺敤锛岃烦杩囦换鍔D: {}", taskId);
- return null;
- }
-
- try {
- // 鏌ヨ浠诲姟淇℃伅
- SysTask task = sysTaskMapper.selectSysTaskByTaskId(taskId);
- if (task == null) {
- log.error("浠诲姟涓嶅瓨鍦紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 鍙悓姝ユ�ユ晳杞繍浠诲姟
- if (!"EMERGENCY_TRANSFER".equals(task.getTaskType())) {
- log.info("闈炴�ユ晳杞繍浠诲姟锛岃烦杩囧悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 鏌ヨ鎬ユ晳杞繍鎵╁睍淇℃伅
- SysTaskEmergency emergency = sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
- if (emergency == null) {
- log.error("鎬ユ晳杞繍鎵╁睍淇℃伅涓嶅瓨鍦紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 濡傛灉宸茬粡鍚屾杩囷紝涓嶅啀閲嶅鍚屾
- if (emergency.getLegacyServiceOrdId() != null && emergency.getLegacyServiceOrdId() > 0) {
- log.info("浠诲姟宸插悓姝ヨ繃锛屼换鍔D: {}, ServiceOrdID: {}", taskId, emergency.getLegacyServiceOrdId());
- return emergency.getLegacyServiceOrdId();
- }
-
- // 鏇存柊鍚屾鐘舵�佷负鍚屾涓�
- emergency.setSyncStatus(1);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- // 鏋勫缓璇锋眰鍙傛暟
- Map<String, String> params = buildSyncParams(task, emergency);
-
- // 鍙戦�丠TTP璇锋眰
- String response = sendHttpPost(legacyConfig.getEmergencyCreateUrl(), params);
-
- // 瑙ｆ瀽鍝嶅簲
- Long serviceOrdId = parseResponse(response);
-
- if (serviceOrdId != null && serviceOrdId > 0) {
- // 鍚屾鎴愬姛锛屾洿鏂拌褰�
- emergency.setLegacyServiceOrdId(serviceOrdId);
- emergency.setSyncStatus(2); // 鍚屾鎴愬姛
- emergency.setSyncTime(new Date());
- emergency.setSyncErrorMsg(null);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- // 鏇存柊浠诲姟涓昏〃鍚屾鏍囪
- task.setLegacySynced(1);
- sysTaskMapper.updateSysTask(task);
-
- log.info("浠诲姟鍚屾鎴愬姛锛屼换鍔D: {}, ServiceOrdID: {}", taskId, serviceOrdId);
- return serviceOrdId;
- } else {
- // 鍚屾澶辫触
- emergency.setSyncStatus(3); // 鍚屾澶辫触
- emergency.setSyncTime(new Date());
- emergency.setSyncErrorMsg("鏃х郴缁熻繑鍥炴棤鏁堢殑ServiceOrdID: " + response);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- log.error("浠诲姟鍚屾澶辫触锛屼换鍔D: {}, 鍝嶅簲: {}", taskId, response);
- return null;
- }
-
- } catch (Exception e) {
- log.error("鍚屾浠诲姟鍒版棫绯荤粺寮傚父锛屼换鍔D: {}", taskId, e);
-
- // 鏇存柊鍚屾鐘舵�佷负澶辫触
- try {
- SysTaskEmergency emergency = sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
- if (emergency != null) {
- emergency.setSyncStatus(3); // 鍚屾澶辫触
- emergency.setSyncTime(new Date());
- emergency.setSyncErrorMsg("鍚屾寮傚父: " + e.getMessage());
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
- }
- } catch (Exception ex) {
- log.error("鏇存柊鍚屾鐘舵�佸け璐�", ex);
- }
-
- return null;
- }
+ return taskEmergencySyncService.syncEmergency(taskId);
}
-
+
/**
* 鎵归噺鍚屾鏈悓姝ョ殑鎬ユ晳杞繍浠诲姟
* 浣跨敤鍒嗛〉鏌ヨ锛岀‘淇濇墍鏈夌鍚堟潯浠剁殑浠诲姟閮借兘琚悓姝�
@@ -213,12 +114,12 @@
break; // 娌℃湁鏇村鏁版嵁锛岄��鍑哄惊鐜�
}
- log.info("寮�濮嬪悓姝ョ {} 椤碉紝浠诲姟鏁伴噺: {}", (offset / pageSize) + 1, pendingTasks.size());
+// log.info("寮�濮嬪悓姝ョ {} 椤碉紝浠诲姟鏁伴噺: {}", (offset / pageSize) + 1, pendingTasks.size());
int pageSuccessCount = 0;
for (SysTaskEmergency emergency : pendingTasks) {
Long serviceOrdId = syncEmergencyTaskToLegacy(emergency.getTaskId());
- if (serviceOrdId != null && serviceOrdId > 0) {
+ if (LongUtil.isNotEmpty(serviceOrdId)) {
pageSuccessCount++;
}
@@ -233,19 +134,19 @@
}
totalSuccessCount += pageSuccessCount;
- log.info("绗� {} 椤靛悓姝ュ畬鎴愶紝鎬绘暟: {}, 鎴愬姛: {}",
- (offset / pageSize) + 1, pendingTasks.size(), pageSuccessCount);
+// log.info("绗� {} 椤靛悓姝ュ畬鎴愶紝鎬绘暟: {}, 鎴愬姛: {}",
+// (offset / pageSize) + 1, pendingTasks.size(), pageSuccessCount);
// 濡傛灉鏈〉鏁版嵁灏戜簬姣忛〉澶у皬锛岃鏄庡凡缁忔槸鏈�鍚庝竴椤�
if (pendingTasks.size() < pageSize) {
- log.info("宸插埌杈炬渶鍚庝竴椤碉紝鍚屾缁撴潫");
+// log.info("宸插埌杈炬渶鍚庝竴椤碉紝鍚屾缁撴潫");
break;
}
offset += pageSize; // 涓嬩竴椤�
}
- log.info("鎵归噺鍚屾瀹屾垚锛屾�绘垚鍔熸暟: {}", totalSuccessCount);
+// log.info("鎵归噺鍚屾瀹屾垚锛屾�绘垚鍔熸暟: {}", totalSuccessCount);
return totalSuccessCount;
} catch (Exception e) {
@@ -271,12 +172,17 @@
// 閲嶆柊鍚屾
Long serviceOrdId = syncEmergencyTaskToLegacy(taskId);
- return serviceOrdId != null && serviceOrdId > 0;
+ return LongUtil.isNotEmpty(serviceOrdId);
} catch (Exception e) {
log.error("閲嶆柊鍚屾浠诲姟澶辫触锛屼换鍔D: {}", taskId, e);
return false;
}
+ }
+
+ @Override
+ public Long syncDispatchOrderToLegacy(Long taskId) {
+ return taskDispatchSyncService.syncDispatch(taskId);
}
@@ -299,180 +205,17 @@
}
});
}
- /**
- * 鍚屾璋冨害鍗曞埌鏃х郴缁燂紙admin_save_24.asp锛�
- */
+
+
@Override
- @Transactional
- public Long syncDispatchOrderToLegacy(Long taskId) {
- if (!legacyConfig.isEnabled()) {
- log.info("鏃х郴缁熷悓姝ュ凡绂佺敤锛岃烦杩囪皟搴﹀崟鍚屾锛屼换鍔D: {}", taskId);
- return null;
- }
-
- try {
- // 鏌ヨ浠诲姟淇℃伅
- SysTask task = sysTaskMapper.selectSysTaskByTaskId(taskId);
- if (task == null) {
- log.error("浠诲姟涓嶅瓨鍦紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 鍙悓姝ユ�ユ晳杞繍浠诲姟
- if (!"EMERGENCY_TRANSFER".equals(task.getTaskType())) {
- log.info("闈炴�ユ晳杞繍浠诲姟锛岃烦杩囪皟搴﹀崟鍚屾锛屼换鍔D: {}", taskId);
- return null;
- }
-
- // 鏌ヨ鎬ユ晳杞繍鎵╁睍淇℃伅
- SysTaskEmergency emergency = sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
- if (emergency == null) {
- log.error("鎬ユ晳杞繍鎵╁睍淇℃伅涓嶅瓨鍦紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 濡傛灉宸茬粡鍚屾杩囷紝涓嶅啀閲嶅鍚屾
- if (emergency.getLegacyDispatchOrdId() != null && emergency.getLegacyDispatchOrdId() > 0) {
- log.info("璋冨害鍗曞凡鍚屾杩囷紝浠诲姟ID: {}, DispatchOrdID: {}", taskId, emergency.getLegacyDispatchOrdId());
- return emergency.getLegacyDispatchOrdId();
- }
-
- Long serviceOrdId=emergency.getLegacyServiceOrdId();
- // 蹇呴』鍏堝悓姝ユ湇鍔″崟
- if (serviceOrdId == null || serviceOrdId <= 0) {
- log.warn("鏈嶅姟鍗曟湭鍚屾锛屾棤娉曞悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", taskId);
- return null;
- }
-
- // ====== 鍓嶇疆鏍￠獙锛氱‘淇濅换鍔℃暟鎹畬鏁� ======
-
- // 1. 妫�鏌ユ槸鍚﹀凡鍒嗛厤杞﹁締
- List<SysTaskVehicle> taskVehicles = sysTaskVehicleMapper.selectSysTaskVehicleByTaskId(taskId);
- if (taskVehicles == null || taskVehicles.isEmpty()) {
- log.warn("浠诲姟鏈垎閰嶈溅杈嗭紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 2. 妫�鏌ユ槸鍚﹀凡鍒嗛厤鎵ц浜哄憳
- List<SysTaskAssignee> taskAssignees = sysTaskAssigneeMapper.selectSysTaskAssigneeByTaskId(taskId);
- if (taskAssignees == null || taskAssignees.isEmpty()) {
- log.warn("浠诲姟鏈垎閰嶆墽琛屼汉鍛橈紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 3. 妫�鏌ラ绾︽椂闂存槸鍚︽湁鏁堬紙蹇呴』澶т簬1970骞达級
- if (task.getPlannedStartTime() == null) {
- log.warn("浠诲姟鏈缃绾︽椂闂达紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- // 妫�鏌ラ绾︽椂闂存槸鍚﹀ぇ浜�1970-01-01锛堟椂闂存埑0瀵瑰簲1970-01-01 00:00:00锛�
- long timestamp1970 = 0L;
- if (task.getPlannedStartTime().getTime() <= timestamp1970) {
- log.warn("浠诲姟棰勭害鏃堕棿鏃犳晥锛堝皬浜庣瓑浜�1970骞达級锛岃烦杩囪皟搴﹀崟鍚屾锛屼换鍔D: {}, 棰勭害鏃堕棿: {}",
- taskId, task.getPlannedStartTime());
- return null;
- }
-
- // 4. 妫�鏌ヨ浆鍑哄尰闄俊鎭�
- if (StringUtils.isEmpty(emergency.getHospitalOutName())) {
- log.warn("浠诲姟鏈缃浆鍑哄尰闄紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- if (StringUtils.isEmpty(emergency.getHospitalOutAddress())) {
- log.warn("浠诲姟鏈缃浆鍑哄尰闄㈠湴鍧�锛岃烦杩囪皟搴﹀崟鍚屾锛屼换鍔D: {}", taskId);
- return null;
- }
-
- // 5. 妫�鏌ヨ浆鍏ュ尰闄俊鎭�
- if (StringUtils.isEmpty(emergency.getHospitalInName())) {
- log.warn("浠诲姟鏈缃浆鍏ュ尰闄紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- if (StringUtils.isEmpty(emergency.getHospitalInAddress())) {
- log.warn("浠诲姟鏈缃浆鍏ュ尰闄㈠湴鍧�锛岃烦杩囪皟搴﹀崟鍚屾锛屼换鍔D: {}", taskId);
- return null;
- }
-
- // 6. 妫�鏌ユ偅鑰呭熀鏈俊鎭�
- if (StringUtils.isEmpty(emergency.getPatientName())) {
- log.warn("浠诲姟鏈缃偅鑰呭鍚嶏紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- if (StringUtils.isEmpty(emergency.getPatientPhone())) {
- log.warn("浠诲姟鏈缃偅鑰呯數璇濓紝璺宠繃璋冨害鍗曞悓姝ワ紝浠诲姟ID: {}", taskId);
- return null;
- }
-
- log.info("浠诲姟鏁版嵁鏍￠獙閫氳繃锛屽紑濮嬪悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", taskId);
-
- // 鏇存柊鍚屾鐘舵�佷负鍚屾涓�
- emergency.setDispatchSyncStatus(1);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- SysUser u=sysUserMapper.selectUserById(task.getCreatorId());
- Integer oaUserID= u.getOaUserId();
-
- // 鏋勫缓璇锋眰鍙傛暟
- Map<String, String> params = buildDispatchOrderParams(task, emergency);
-
-
- // 鍙戦�丠TTP璇锋眰
- String response = sendHttpPost(legacyConfig.getDispatchCreateUrl(), params);
-
- // 瑙ｆ瀽鍝嶅簲
- Long dispatchOrdId = parseResponse(response);
-
- if (dispatchOrdId != null && dispatchOrdId > 0) {
- // 鍚屾鎴愬姛锛屾洿鏂拌褰�
- emergency.setLegacyDispatchOrdId(dispatchOrdId);
- emergency.setDispatchSyncStatus(2); // 鍚屾鎴愬姛
- emergency.setDispatchSyncTime(new Date());
- emergency.setDispatchSyncErrorMsg(null);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- List<SysTaskAttachment> taskAttachments= sysTaskService.getAttachmentsByTaskId(taskId);
- if (taskAttachments != null && !taskAttachments.isEmpty()) {
- //鍚屾闄勪欢
- this.syncAttachmentToLegacy(taskAttachments,serviceOrdId,dispatchOrdId,oaUserID);
- }
-
- log.info("璋冨害鍗曞悓姝ユ垚鍔燂紝浠诲姟ID: {}, DispatchOrdID: {}", taskId, dispatchOrdId);
- return dispatchOrdId;
- } else {
- // 鍚屾澶辫触
- emergency.setDispatchSyncStatus(3); // 鍚屾澶辫触
- emergency.setDispatchSyncTime(new Date());
- emergency.setDispatchSyncErrorMsg("鏃х郴缁熻繑鍥炴棤鏁堢殑DispatchOrdID: " + response);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- log.error("璋冨害鍗曞悓姝ュけ璐ワ紝浠诲姟ID: {}, 鍝嶅簲: {}", taskId, response);
- return null;
- }
-
- } catch (Exception e) {
- log.error("鍚屾璋冨害鍗曞埌鏃х郴缁熷紓甯革紝浠诲姟ID: {}", taskId, e);
-
- // 鏇存柊鍚屾鐘舵�佷负澶辫触
- try {
- SysTaskEmergency emergency = sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
- if (emergency != null) {
- emergency.setDispatchSyncStatus(3); // 鍚屾澶辫触
- emergency.setDispatchSyncTime(new Date());
- emergency.setDispatchSyncErrorMsg("鍚屾寮傚父: " + e.getMessage());
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
- }
- } catch (Exception ex) {
- log.error("鏇存柊璋冨害鍗曞悓姝ョ姸鎬佸け璐�", ex);
- }
-
- return null;
+ public void syncTaskAttachment(Long taskId, Long dispatchOrdId, Long serviceOrdId, Integer oaUserID){
+ List<SysTaskAttachment> taskAttachments= sysTaskService.getAttachmentsByTaskId(taskId);
+ if (taskAttachments != null && !taskAttachments.isEmpty()) {
+ //鍚屾闄勪欢
+ this.syncAttachmentToLegacy(taskAttachments,serviceOrdId,dispatchOrdId,oaUserID);
}
}
-
+
/**
* 鎵归噺鍚屾鏈悓姝ョ殑璋冨害鍗�
* 浣跨敤鍒嗛〉鏌ヨ锛岀‘淇濇墍鏈夌鍚堟潯浠剁殑浠诲姟閮借兘琚悓姝�
@@ -492,17 +235,17 @@
while (true) {
// 鍒嗛〉鏌ヨ宸插悓姝ユ湇鍔″崟浣嗘湭鍚屾璋冨害鍗曠殑浠诲姟
List<SysTaskEmergency> pendingTasks = sysTaskEmergencyService.selectPendingDispatchSyncTasks(offset, pageSize);
- log.info("鏌ヨ鍒版湭鍚屾璋冨害鍗曠殑浠诲姟鏁伴噺: {}", pendingTasks.size());
+// log.info("鏌ヨ鍒版湭鍚屾璋冨害鍗曠殑浠诲姟鏁伴噺: {}", pendingTasks.size());
if (pendingTasks == null || pendingTasks.isEmpty()) {
log.info("娌℃湁鏇村闇�瑕佸悓姝ヨ皟搴﹀崟鐨勪换鍔★紝offset: {}", offset);
break; // 娌℃湁鏇村鏁版嵁锛岄��鍑哄惊鐜�
}
- log.info("寮�濮嬪悓姝ヨ皟搴﹀崟绗� {} 椤碉紝浠诲姟鏁伴噺: {}", (offset / pageSize) + 1, pendingTasks.size());
+// log.info("寮�濮嬪悓姝ヨ皟搴﹀崟绗� {} 椤碉紝浠诲姟鏁伴噺: {}", (offset / pageSize) + 1, pendingTasks.size());
int pageSuccessCount = 0;
for (SysTaskEmergency emergency : pendingTasks) {
- log.info("寮�濮嬪悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", emergency.getTaskId());
+// log.info("寮�濮嬪悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", emergency.getTaskId());
Long dispatchOrdId = syncDispatchOrderToLegacy(emergency.getTaskId());
if (dispatchOrdId != null && dispatchOrdId > 0) {
@@ -520,19 +263,19 @@
}
totalSuccessCount += pageSuccessCount;
- log.info("璋冨害鍗曠 {} 椤靛悓姝ュ畬鎴愶紝鎬绘暟: {}, 鎴愬姛: {}",
- (offset / pageSize) + 1, pendingTasks.size(), pageSuccessCount);
+// log.info("璋冨害鍗曠 {} 椤靛悓姝ュ畬鎴愶紝鎬绘暟: {}, 鎴愬姛: {}",
+// (offset / pageSize) + 1, pendingTasks.size(), pageSuccessCount);
// 濡傛灉鏈〉鏁版嵁灏戜簬姣忛〉澶у皬锛岃鏄庡凡缁忔槸鏈�鍚庝竴椤�
if (pendingTasks.size() < pageSize) {
- log.info("宸插埌杈炬渶鍚庝竴椤碉紝璋冨害鍗曞悓姝ョ粨鏉�");
+// log.info("宸插埌杈炬渶鍚庝竴椤碉紝璋冨害鍗曞悓姝ョ粨鏉�");
break;
}
offset += pageSize; // 涓嬩竴椤�
}
- log.info("鎵归噺鍚屾璋冨害鍗曞畬鎴愶紝鎬绘垚鍔熸暟: {}", totalSuccessCount);
+// log.info("鎵归噺鍚屾璋冨害鍗曞畬鎴愶紝鎬绘垚鍔熸暟: {}", totalSuccessCount);
return totalSuccessCount;
} catch (Exception e) {
@@ -540,828 +283,27 @@
return 0;
}
}
-
- /**
- * 鏋勫缓璋冨害鍗曞悓姝ュ弬鏁�
- */
- private Map<String, String> buildDispatchOrderParams(SysTask task, SysTaskEmergency emergency) {
- Map<String, String> params = new HashMap<>();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
- // 鑾峰彇绠＄悊鍛業D锛堝垱寤轰汉ID瀵瑰簲鐨凮A_UserID锛�
- String adminID = this.getAdminID(task);
-
- // 鑾峰彇璋冨害鍗曠被鍨嬶紙浠庝换鍔℃墍灞為儴闂ㄧ殑璋冨害鍗曠紪鐮佽幏鍙栵級
- String dispatchOrdClass = "SA"; // 榛樿鍊�
- if (task.getDeptId() != null) {
- try {
- SysDept dept = sysDeptMapper.selectDeptById(task.getDeptId());
- if (dept != null && StringUtils.isNotEmpty(dept.getDispatchOrderClass())) {
- dispatchOrdClass = dept.getDispatchOrderClass();
- log.info("鑾峰彇浠诲姟鎵�灞為儴闂ㄧ殑璋冨害鍗曠紪鐮佹垚鍔燂紝閮ㄩ棬ID: {}, 璋冨害鍗曠紪鐮�: {}", task.getDeptId(), dispatchOrdClass);
- }
- } catch (Exception e) {
- log.error("鏌ヨ浠诲姟鎵�灞為儴闂ㄤ俊鎭紓甯革紝閮ㄩ棬ID: {}", task.getDeptId(), e);
- }
- }
- params.put("AdminID", adminID);
-
- // 鍩烘湰淇℃伅
- params.put("DispatchOrdClass", dispatchOrdClass);
- params.put("ServiceOrdID", emergency.getLegacyServiceOrdId().toString());
- params.put("DispatchOrdState", "1"); // 璋冨害鍗曠姸鎬�
-
- // 鏃堕棿淇℃伅
- if (task.getPlannedStartTime() != null) {
- params.put("DispatchOrdTraSDTime", sdf.format(task.getPlannedStartTime())); // 鎷熷嚭鍙戞椂闂�
- } else {
- params.put("DispatchOrdTraSDTime", "");
- }
- params.put("DispatchOrd_NS_Time", task.getCreateTime() != null ? sdf.format(task.getCreateTime()) : sdf.format(new Date())); // 寮�鍗曟椂闂�
-
- // 杞﹁締淇℃伅 - 浠庝换鍔″叧鑱旂殑杞﹁締鑾峰彇CarID
- Long carId = getTaskVehicleCarId(task.getTaskId());
- params.put("DispatchOrdCarID", carId.toString());
-
- // 鑱旂郴浜轰俊鎭�
- params.put("DispatchOrdCoName", StringUtils.nvl(emergency.getPatientContact(), ""));
- params.put("DispatchOrdCoPhone", StringUtils.nvl(emergency.getPatientPhone(), ""));
- params.put("ServiceOrdCoName", StringUtils.nvl(emergency.getPatientContact(), ""));
- params.put("ServiceOrdCoPhone", StringUtils.nvl(emergency.getPatientPhone(), ""));
- params.put("ServiceOrdPtName", StringUtils.nvl(emergency.getPatientName(), ""));
- params.put("ServiceOrdTraStreet",StringUtils.nvl(task.getDepartureAddress(), StringUtils.nvl(emergency.getHospitalOutAddress(), "")));
- // 鍦板潃淇℃伅
- params.put("DispatchOrdTraStreet", StringUtils.nvl(task.getDepartureAddress(), StringUtils.nvl(emergency.getHospitalOutAddress(), "")));
- params.put("DispatchOrdTraEnd", StringUtils.nvl(task.getDestinationAddress(), StringUtils.nvl(emergency.getHospitalInAddress(), "")));
- params.put("DispatchOrdTraVia", ""); // 瀹為檯閫旂粡鍦�
-
- // 鎿嶄綔鍛戒护
- params.put("DispatchOrd_Check", "0"); // 3=鐩存帴寮哄埗瀹屾垚
-
- // 缁╂晥鍜岃垂鐢細纭繚鏁板�煎瓧娈典笉涓簄ull
- String transferPrice = "0";
- if (emergency.getTransferPrice() != null) {
- try {
- transferPrice = emergency.getTransferPrice().toString();
- if (transferPrice.contains(".")) {
- transferPrice = new java.math.BigDecimal(transferPrice).stripTrailingZeros().toPlainString();
- }
- } catch (Exception e) {
- log.warn("杞崲杞繍浠锋牸澶辫触锛屼换鍔D: {}, 浣跨敤榛樿鍊�0", task.getTaskId(), e);
- transferPrice = "0";
- }
- }
- params.put("DispatchOrdPerfomance", transferPrice);
- params.put("StretcherMoney", "0"); // 鎶媴鏋惰垂
- params.put("AddMoneyType", ""); // 闄勫姞椤圭洰
- params.put("AddMoney", "0"); // 闄勫姞椤圭洰璐圭敤
- params.put("AddMoneyExplain", ""); // 闄勫姞椤圭洰璇存槑
-
- // 浜哄憳淇℃伅
- params.put("EntourageName_aid1", ""); // 澶栨彺浜哄憳1
- params.put("EntourageName_aid2", ""); // 澶栨彺浜哄憳2
- params.put("DispatchOrd_NS_ID", adminID); // 璋冨害浜哄憳ID
- params.put("RecommendedCar", ""); // 鎸囧畾杞﹀瀷
- params.put("ServiceOrdTaskRemarks", StringUtils.nvl(task.getTaskDescription(), "")); // 鍖绘姢鍙稿娉�
-
- // 鐢佃瘽淇℃伅
- params.put("Phone", StringUtils.nvl(emergency.getPatientPhone(), ""));
- params.put("TEL_Time", sdf.format(new Date()));
- params.put("TEL_Remarks", "鏂扮郴缁熷悓姝ュ垱寤鸿皟搴﹀崟");
-
- // 鏃堕暱淇℃伅
- params.put("TimeLength_Program", "0"); // 澶у瀷娲诲姩淇濋殰鏃堕暱
- params.put("TimeLength_ICU", "0"); // 灞呭ICU鏃堕暱
- params.put("TimeLength_Wait", "0"); // 绛夊緟鏃堕暱
-
- // 閲岀▼鏁�
- params.put("DispatchOrdTraStreetMileage", ""); // 寮�濮嬮噷绋嬫暟
- params.put("DispatchOrdTraEndMileage", ""); // 缁撴潫閲岀▼鏁�
-
- // 鏈嶅姟鍗曠浉鍏充俊鎭紙浠巃dmin_save_24.gds 221-255琛岃ˉ鍏咃級
- params.put("ServiceOrdPtCondition", StringUtils.nvl(emergency.getPatientCondition(), "")); // 鐥呮儏鎻忚堪
- params.put("ServiceOrdPtDoctor", ""); // 鎮ｈ�呭尰鐢�
- params.put("ServiceOrdPtDoctorPhone", ""); // 鎮ｈ�呭尰鐢熺數璇�
- params.put("TransferModeID", ""); // 杞繍鏂瑰紡
- params.put("ServiceOrdVIP", "0"); // VIP瀹㈡埛
- // 浠锋牸瀛楁澶嶇敤锛岀‘淇濅竴鑷存��
- params.put("ServiceOrdTraTxnPrice", transferPrice); // 鎴愪氦浠�
- params.put("ServiceOrdTraPrePayment", "0"); // 闇�棰勪粯娆�
- params.put("SettlementPrice", "0"); // 缁撶畻浠�
- params.put("ServiceOrdTraPriceReason", ""); // 宸环鍘熷洜
- params.put("ServiceOrd_CC_ID", ""); // 瀹㈡湇浜哄憳ID
- params.put("ServiceOrd_Sale_ID", ""); // 閿�鍞汉鍛業D
- 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("ServiceOrdApptDate", task.getPlannedStartTime() != null ? sdf.format(task.getPlannedStartTime()) : ""); // 棰勭害鏃堕棿
- params.put("ServiceOrdPtDiagnosis", ""); // 璇婃柇
- params.put("ServiceOrdOperationRemarks", "鏂扮郴缁熷悓姝ュ垱寤�"); // 鎿嶄綔澶囨敞
- params.put("ServiceOrdEstimatedOrderDate", ""); // 棰勮娲惧崟鏃堕棿
- params.put("ServiceOrdEstimatedOrderDateOld", ""); // 鍘熼璁℃淳鍗曟椂闂�
- params.put("ServiceOrdViaDistance", "0"); // 涓�旇窛绂�
- // 璺濈瀛楁锛氱‘淇濅笉涓虹┖锛岄伩鍏嶆棫绯荤粺鎺ュ彛鎶ラ敊
- String transferDistance = "0";
- if (emergency.getTransferDistance() != null) {
- try {
- transferDistance = emergency.getTransferDistance().toString();
- // 鍘婚櫎鍙兘鐨勫皬鏁扮偣鍚庡浣欑殑0
- if (transferDistance.contains(".")) {
- transferDistance = new java.math.BigDecimal(transferDistance).stripTrailingZeros().toPlainString();
- }
- } catch (Exception e) {
- log.warn("杞崲杞繍璺濈澶辫触锛屼换鍔D: {}, 浣跨敤榛樿鍊�0", task.getTaskId(), e);
- transferDistance = "0";
- }
- }
- params.put("ServiceOrdTraDistance", transferDistance);
- params.put("OrderLevel", "0"); // 鏌ョ湅绛夌骇
- params.put("ServiceOrdDepartureType", "1"); // 棰勭害绫诲瀷
- params.put("ConditionLevel", "0"); // 鐥呴噸绾у埆
- params.put("DirectionType", "0"); // 杞繍鍘诲悜
- params.put("ServiceOrdPtOutHospID", emergency.getHospitalOutId() != null ? emergency.getHospitalOutId().toString() : "0"); // 杞嚭鍖婚櫌ID
- params.put("ServiceOrdPtInHospID", emergency.getHospitalInId() != null ? emergency.getHospitalInId().toString() : "0"); // 杞叆鍖婚櫌ID
- params.put("ServiceOrdPtOutHosp", StringUtils.nvl(emergency.getHospitalOutName(), "")); // 杞嚭鍖婚櫌
- params.put("ServiceOrdTraVia", StringUtils.nvl(task.getDepartureAddress(), StringUtils.nvl(emergency.getHospitalOutAddress(), ""))); // 杞嚭鍦板潃
- params.put("ServiceOrdPtInHosp", StringUtils.nvl(emergency.getHospitalInName(), "")); // 杞叆鍖婚櫌
- params.put("ServiceOrdTraEnd", StringUtils.nvl(task.getDestinationAddress(), StringUtils.nvl(emergency.getHospitalInAddress(), ""))); // 杞叆鍦板潃
- params.put("FromHQ2_is", "0"); // 骞垮窞鎬婚儴鎺ㄩ�佷换鍔℃爣璁�
-
- // 鐥呮儏ID鍒楄〃锛圛CD-10鐤剧梾ID锛岀敤浜庤瘖鏂璉CD锛�
- // 鏍煎紡锛氶�楀彿鍒嗛殧鐨処D鍒楄〃锛屽 ",1,2,3,"
- String ordIcdId = "";
- if (StringUtils.isNotEmpty(emergency.getDiseaseIds())) {
- // 灏嗗瓨鍌ㄧ殑 "1,2,3" 鏍煎紡杞崲涓烘棫绯荤粺瑕佹眰鐨� ",1,2,3," 鏍煎紡
- ordIcdId = "," + emergency.getDiseaseIds() + ",";
- log.info("鐥呮儏ID鍒楄〃宸茶缃紝浠诲姟ID: {}, OrdICD_ID: {}", task.getTaskId(), ordIcdId);
- }
- params.put("OrdICD_ID", ordIcdId);
- params.put("OrdICD_ID_old", ""); // 鏃х梾鎯匢D鍒楄〃锛堢敤浜庡姣旀槸鍚﹂渶瑕佹洿鏂帮級
-
- // 鎵ц浜哄憳淇℃伅锛堥殢琛屼汉鍛橈級
- syncTaskAssignees(task, params);
-
- return params;
- }
-
- /**
- * 鍚屾浠诲姟鎵ц浜哄憳淇℃伅鍒拌皟搴﹀崟闅忚浜哄憳鍙傛暟
- *
- * @param task 浠诲姟淇℃伅
- * @param params 璋冨害鍗曞弬鏁癕ap
- */
- private void syncTaskAssignees(SysTask task, Map<String, String> params) {
- try {
- // 鑾峰彇浠诲姟鐨勬墽琛屼汉鍛樹俊鎭垪琛紙鍖呭惈瑙掕壊绫诲瀷锛� //TODO 濡傛灉鏈変袱涓徃鏈哄氨瑕� 璁剧疆銆�Entourage_1鍜孍ntourage_2
- //涓や釜鎶ゅ＋灏辫璁剧疆 Entourage_4鍜孍ntourage_6
- //涓や釜鍖荤敓瑕佽缃� Entourage_3鍜孍ntourage_5
- List<TaskCreateVO.AssigneeInfo> assignees = getTaskAssignees(task.getTaskId());
-
- if (assignees == null || assignees.isEmpty()) {
- log.warn("浠诲姟鏃犳墽琛屼汉鍛橈紝浠诲姟ID: {}", task.getTaskId());
- // 璁剧疆榛樿绌哄��
- params.put("EntourageLeadID", "");
- params.put("Entourage_1", ""); // 鍙告満
- params.put("Entourage_2", ""); //鍙告満
- params.put("Entourage_3", ""); // 鍖荤敓
- params.put("Entourage_5", ""); //鍖荤敓
- params.put("Entourage_4", ""); // 鎶ゅ＋
- params.put("Entourage_6", ""); // 鎶ゅ＋
- return;
- }
-
- String leadEntourageId = ""; // 棰嗛槦鐨凟ntourageID
- String driverOaId = ""; // 鍙告満鐨凮A_UserID
- String doctorOaId = ""; // 鍖荤敓鐨凮A_UserID
- String nurseOaId = ""; // 鎶ゅ＋鐨凮A_UserID
-
- // 閬嶅巻鎵ц浜哄憳锛屾牴鎹鑹茬被鍨嬪垎閰嶅埌瀵瑰簲鐨凟ntourage鍙傛暟
- for (int i = 0; i < assignees.size(); i++) {
- TaskCreateVO.AssigneeInfo assignee = assignees.get(i);
- Long userId = assignee.getUserId();
- String userType = assignee.getUserType(); // 鐩存帴浣跨敤鍓嶇浼犻�掔殑瑙掕壊绫诲瀷
-
- if (userId == null) {
- continue;
- }
-
- // 鏌ヨ鐢ㄦ埛鐨凮A_UserID
- SysUser user = sysUserMapper.selectUserById(userId);
- if (user == null || user.getOaUserId() == null) {
- log.warn("鎵ц浜哄憳淇℃伅涓嶅瓨鍦ㄦ垨鏈厤缃甇A_UserID锛岀敤鎴稩D: {}", userId);
- continue;
- }
-
- String oaUserId = user.getOaUserId().toString();
-
- // 鏍规嵁鐢ㄦ埛绫诲瀷鍒嗛厤鍒板搴旂殑Entourage鍙傛暟
- if ("driver".equals(userType)) {
- if (driverOaId.isEmpty()) {
- driverOaId = oaUserId;
- if(params.get("Entourage_1")==null) {
- params.put("Entourage_1", oaUserId);
- }else{
- params.put("Entourage_2", oaUserId);
- }
- // 濡傛灉鏄涓�涓墽琛屼汉鍛橈紝璁剧疆涓洪闃�
- if (i == 0 && leadEntourageId.isEmpty()) {
- leadEntourageId = "1"; // 鍙告満瀵瑰簲Entourage_1
- }
- }
- } else if ("doctor".equals(userType)) {
- if (doctorOaId.isEmpty()) {
- doctorOaId = oaUserId;
- if(params.get("Entourage_3")==null) {
- params.put("Entourage_3", oaUserId);
- }else{
- params.put("Entourage_5", oaUserId);
- }
- // 濡傛灉鏄涓�涓墽琛屼汉鍛橈紝璁剧疆涓洪闃�
- if (i == 0 && leadEntourageId.isEmpty()) {
- leadEntourageId = "3"; // 鍖荤敓瀵瑰簲Entourage_3
- }
- }
- } else if ("nurse".equals(userType)) {
- if (nurseOaId.isEmpty()) {
- nurseOaId = oaUserId;
- if(params.get("Entourage_4")==null) {
- params.put("Entourage_4", oaUserId);
- }else{
- params.put("Entourage_6", oaUserId);
- }
- // 濡傛灉鏄涓�涓墽琛屼汉鍛橈紝璁剧疆涓洪闃�
- if (i == 0 && leadEntourageId.isEmpty()) {
- leadEntourageId = "4"; // 鎶ゅ＋瀵瑰簲Entourage_4
- }
- }
- }
- }
-
- // 璁剧疆鍙傛暟
- params.put("EntourageLeadID", leadEntourageId);
-// params.put("Entourage_1", driverOaId); // 鍙告満
-// params.put("Entourage_3", doctorOaId); // 鍖荤敓
-// params.put("Entourage_4", nurseOaId); // 鎶ゅ＋
-
- log.info("浠诲姟鎵ц浜哄憳鍚屾鎴愬姛锛屼换鍔D: {}, 棰嗛槦ID: {}, 鍙告満: {}, 鍖荤敓: {}, 鎶ゅ＋: {}",
- task.getTaskId(), leadEntourageId, driverOaId, doctorOaId, nurseOaId);
-
- } catch (Exception e) {
- log.error("鍚屾浠诲姟鎵ц浜哄憳寮傚父锛屼换鍔D: {}", task.getTaskId(), e);
- // 璁剧疆榛樿绌哄��
- params.put("EntourageLeadID", "");
- params.put("Entourage_1", "");
- params.put("Entourage_3", "");
- params.put("Entourage_4", "");
- }
- }
-
- /**
- * 鑾峰彇浠诲姟鐨勬墽琛屼汉鍛樹俊鎭垪琛紙鍖呭惈瑙掕壊绫诲瀷锛�
- *
- * @param taskId 浠诲姟ID
- * @return 鎵ц浜哄憳淇℃伅鍒楄〃
- */
- private List<TaskCreateVO.AssigneeInfo> getTaskAssignees(Long taskId) {
- List<TaskCreateVO.AssigneeInfo> assignees = new java.util.ArrayList<>();
-
- try {
- // 浠庢暟鎹簱鏌ヨ鎵ц浜哄憳淇℃伅锛堟寜鎺掑簭椤哄簭锛�
- List<SysTaskAssignee> taskAssignees = sysTaskAssigneeMapper.selectSysTaskAssigneeByTaskId(taskId);
-
- if (taskAssignees != null && !taskAssignees.isEmpty()) {
- // 灏嗘暟鎹簱涓殑鎵ц浜哄憳杞崲涓篈ssigneeInfo瀵硅薄
- for (SysTaskAssignee taskAssignee : taskAssignees) {
- TaskCreateVO.AssigneeInfo assignee = new TaskCreateVO.AssigneeInfo();
- assignee.setUserId(taskAssignee.getUserId());
- assignee.setUserName(taskAssignee.getUserName());
- assignee.setUserType(taskAssignee.getUserType());
- assignees.add(assignee);
- }
-
- log.info("浠庢暟鎹簱鑾峰彇鎵ц浜哄憳淇℃伅鎴愬姛锛屼换鍔D: {}, 浜哄憳鏁伴噺: {}", taskId, assignees.size());
- return assignees;
- }
-
- // 濡傛灉鏁版嵁搴撲腑娌℃湁鎵ц浜哄憳淇℃伅锛屽皾璇曚粠浠诲姟鐨勪富瑕佹墽琛屼汉鑾峰彇
- log.warn("鏁版嵁搴撲腑鏈壘鍒版墽琛屼汉鍛樹俊鎭紝灏濊瘯浠庝换鍔′富瑕佹墽琛屼汉鑾峰彇锛屼换鍔D: {}", taskId);
- SysTask task = sysTaskMapper.selectSysTaskByTaskId(taskId);
- if (task != null && task.getAssigneeId() != null) {
- SysUser user = sysUserMapper.selectUserById(task.getAssigneeId());
- if (user != null) {
- TaskCreateVO.AssigneeInfo assignee = new TaskCreateVO.AssigneeInfo();
- assignee.setUserId(user.getUserId());
- assignee.setUserName(user.getNickName());
- assignee.setUserType(getUserType(user)); // 閫氳繃瑙掕壊鍒ゆ柇绫诲瀷
- assignees.add(assignee);
- }
- }
- } catch (Exception e) {
- log.error("鑾峰彇浠诲姟鎵ц浜哄憳淇℃伅寮傚父锛屼换鍔D: {}", taskId, e);
- }
-
- return assignees;
- }
-
-
- /**
- * 鍒ゆ柇鐢ㄦ埛绫诲瀷锛堝徃鏈�/鍖荤敓/鎶ゅ＋/鍏朵粬锛�
- * 鏍规嵁鐢ㄦ埛鐨勮鑹插悕绉版潵鍒ゆ柇
- *
- * @param user 鐢ㄦ埛淇℃伅
- * @return 鐢ㄦ埛绫诲瀷锛歞river/doctor/nurse/other
- */
- private 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("鐢ㄦ埛瑙掕壊鏃犳硶鍒ゆ柇绫诲瀷锛岄粯璁や负鍙告満锛岀敤鎴稩D: {}, 瑙掕壊: {}", user.getUserId(), roleName);
- return "driver";
- }
-
- /**
- * 鑾峰彇浠诲姟鍏宠仈杞﹁締鐨勬棫绯荤粺CarID
- *
- * @param taskId 浠诲姟ID
- * @return CarID锛屽鏋滄湭鎵惧埌鍒欒繑鍥�0L
- */
- private Long getTaskVehicleCarId(Long taskId) {
- try {
- // 浠� sys_task_vehicle 琛ㄦ煡璇㈣溅杈咺D
- List<SysTaskVehicle> taskVehicles = sysTaskVehicleMapper.selectSysTaskVehicleByTaskId(taskId);
- if (taskVehicles != null && !taskVehicles.isEmpty()) {
- // 鍙栫涓�涓叧鑱旂殑杞﹁締
- Long vehicleId = taskVehicles.get(0).getVehicleId();
- if (vehicleId != null) {
- // 浠� tb_vehicle_info 琛ㄨ幏鍙� car_id
- VehicleInfo vehicleInfo = vehicleInfoMapper.selectVehicleInfoById(vehicleId);
- if (vehicleInfo != null && vehicleInfo.getCarId() != null) {
- Long carId = vehicleInfo.getCarId().longValue();
- log.info("鑾峰彇浠诲姟鍏宠仈杞﹁締鐨凜arID鎴愬姛锛屼换鍔D: {}, 杞﹁締ID: {}, CarID: {}",
- taskId, vehicleId, carId);
- return carId;
- } else {
- log.warn("杞﹁締淇℃伅涓湭閰嶇疆CarID锛屼换鍔D: {}, 杞﹁締ID: {}", taskId, vehicleId);
- }
- } else {
- log.warn("浠诲姟杞﹁締鍏宠仈璁板綍涓溅杈咺D涓虹┖锛屼换鍔D: {}", taskId);
- }
- } else {
- log.warn("浠诲姟鏈叧鑱旇溅杈嗭紝浠诲姟ID: {}", taskId);
- }
- } catch (Exception e) {
- log.error("鏌ヨ浠诲姟鍏宠仈杞﹁締鐨凜arID寮傚父锛屼换鍔D: {}", taskId, e);
- }
- return 0L;
- }
-
- private String getAdminID(SysTask task) {
- String adminID="";
-if (task.getCreatorId() != null) {
- try {
- SysUser creator = sysUserMapper.selectUserById(task.getCreatorId());
- if (creator != null && creator.getOaUserId() != null) {
- adminID = creator.getOaUserId().toString();
- log.info("鑾峰彇鍒涘缓浜篛A_UserID鎴愬姛锛岀敤鎴稩D: {}, OA_UserID: {}", task.getCreatorId(), adminID);
- } else {
- log.warn("鍒涘缓浜烘湭閰嶇疆OA_UserID锛岀敤鎴稩D: {}", task.getCreatorId());
- }
- } catch (Exception e) {
- log.error("鏌ヨ鍒涘缓浜篛A_UserID寮傚父锛岀敤鎴稩D: {}", task.getCreatorId(), e);
- }
- }
- return adminID;
- }
- /**
- * 鏋勫缓鍚屾鍙傛暟
- */
- private Map<String, String> buildSyncParams(SysTask task, SysTaskEmergency emergency) {
- Map<String, String> params = new HashMap<>();
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd");
- Long taskId=task.getTaskId();
- // 绠＄悊鍛業D锛堝垱寤轰汉ID瀵瑰簲鐨凮A_UserID锛�
- String adminID = this.getAdminID(task);
-
- params.put("adminID", adminID);
-
- // 鏈嶅姟鍗曞垎绫伙紙浠庝换鍔℃墍灞為儴闂ㄧ殑鏈嶅姟鍗曠紪鐮佽幏鍙栵級
- String serviceOrdClass = "BF"; // ServiceOrdClass榛樿鍊�
- if (task.getDeptId() != null) {
- try {
- SysDept dept = sysDeptMapper.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鎴愬姛锛屼换鍔D: {}, 鍗曟嵁绫诲瀷ID: {}", task.getTaskId(), serviceOrdAreaType);
- } else {
- log.warn("浠诲姟鏈厤缃崟鎹被鍨婭D锛屼换鍔D: {}锛屼娇鐢ㄩ粯璁ゅ��", 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鎴愬姛锛屼换鍔D: {}, 浠诲姟绫诲瀷ID: {}", taskId, serviceOrdType);
- } else {
- log.warn("浠诲姟鏈厤缃换鍔＄被鍨婭D锛屼换鍔D: {}锛屼娇鐢ㄩ粯璁ゅ��", 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.getHospitalOutDepartment(), ""));
- params.put("ServiceOrdPtServicesID", StringUtils.nvl(emergency.getHospitalOutDepartmentId(), "0")); // 杞嚭绉戝ID
- params.put("ServiceOrdPtInServices", StringUtils.nvl(emergency.getHospitalInDepartment(), ""));
- 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", ""); // 閿�鍞汉鍛業D
- 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;
- }
-
- /**
- * 鍙戦�丠TTP/HTTPS POST璇锋眰
- * 鏀寔HTTPS鑷鍚嶈瘉涔�
- */
- private String sendHttpPost(String urlString, Map<String, String> params) throws Exception {
- URL url = new URL(urlString);
- HttpURLConnection conn = (HttpURLConnection) url.openConnection();
-
- // 濡傛灉鏄疕TTPS璇锋眰锛岄厤缃甋SL淇′换鎵�鏈夎瘉涔�
- if (conn instanceof HttpsURLConnection) {
- HttpsURLConnection httpsConn = (HttpsURLConnection) conn;
- httpsConn.setSSLSocketFactory(createTrustAllSSLContext().getSocketFactory());
- httpsConn.setHostnameVerifier((hostname, session) -> true); // 淇′换鎵�鏈変富鏈哄悕
- log.debug("閰嶇疆HTTPS杩炴帴锛屼俊浠绘墍鏈塖SL璇佷功锛孶RL: {}", urlString);
- }
-
- try {
- // 璁剧疆杩炴帴灞炴��
- conn.setRequestMethod("POST");
- conn.setConnectTimeout(legacyConfig.getConnectTimeout());
- conn.setReadTimeout(legacyConfig.getReadTimeout());
- conn.setDoOutput(true);
- conn.setDoInput(true);
- conn.setUseCaches(false);
- conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=" + legacyConfig.getCharset());
- conn.setRequestProperty("Accept-Charset", legacyConfig.getCharset());
-
- // 鏋勫缓POST鏁版嵁
- StringBuilder postData = new StringBuilder();
- for (Map.Entry<String, String> entry : params.entrySet()) {
- if (postData.length() > 0) {
- postData.append("&");
- }
- postData.append(URLEncoder.encode(entry.getKey(), legacyConfig.getCharset()));
- postData.append("=");
- postData.append(URLEncoder.encode(entry.getValue(), legacyConfig.getCharset()));
- }
-
- // 鍙戦�丳OST鏁版嵁
- try (OutputStream os = conn.getOutputStream()) {
- os.write(postData.toString().getBytes(legacyConfig.getCharset()));
- os.flush();
- }
-
-
-
- // 璇诲彇鍝嶅簲
- int responseCode = conn.getResponseCode();
- if (responseCode == HttpURLConnection.HTTP_OK) {
- try (BufferedReader reader = new BufferedReader(
- new InputStreamReader(conn.getInputStream(), legacyConfig.getCharset()))) {
- StringBuilder response = new StringBuilder();
- String line;
- while ((line = reader.readLine()) != null) {
- response.append(line);
- }
- return response.toString().trim();
- }
- } else {
- log.error("璇锋眰澶辫触锛岃姹俇RL {},鍙傛暟 {}",urlString,postData);
- throw new Exception("HTTP/HTTPS璇锋眰澶辫触锛屽搷搴旂爜: " + responseCode);
- }
-
- } finally {
- conn.disconnect();
- }
- }
-
- /**
- * 鍒涘缓淇′换鎵�鏈塖SL璇佷功鐨凷SLContext
- * 鐢ㄤ簬鏀寔鑷鍚嶈瘉涔︾殑HTTPS璇锋眰
- *
- * 娉ㄦ剰锛氭鏂规硶浼氫俊浠绘墍鏈塖SL璇佷功锛屽寘鎷嚜绛惧悕璇佷功
- * 浠呯敤浜庝笌鏃х郴缁熺殑鍐呴儴閫氫俊锛岀敓浜х幆澧冨缓璁娇鐢ㄦ瑙凜A璇佷功
- */
- 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;
- }
-
- /**
- * 瑙ｆ瀽鏃х郴缁熷搷搴�
- * 棰勬湡鏍煎紡: "OK:ServiceOrdID" 鎴栭敊璇俊鎭�
- */
- private Long parseResponse(String response) {
- if (StringUtils.isEmpty(response)) {
- return null;
- }
-
- // 鍘婚櫎鍙兘鐨凥TML鏍囩鍜岀┖鐧藉瓧绗�
- 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;
- }
- }
-
- /**
- * 閲嶆柊鍚屾杞﹁締鍜屼汉鍛樺彉鏇寸殑浠诲姟鍒版棫绯荤粺
- * 褰撲换鍔＄殑杞﹁締淇℃伅鎴栦汉鍛樹俊鎭彂鐢熷彉鏇存椂锛岄渶瑕佽皟鐢ㄦ棫绯荤粺鎺ュ彛閲嶆柊鍚屾
- * 浣跨敤 admin_save_25.asp 鎺ュ彛锛岃�屼笉鏄� admin_save_24.gds
- */
@Override
- @Transactional
public boolean resyncDispatchOrderToLegacy(Long taskId) {
- if (!legacyConfig.isEnabled()) {
- log.info("鏃х郴缁熷悓姝ュ凡绂佺敤锛岃烦杩囪皟搴﹀崟閲嶆柊鍚屾锛屼换鍔D: {}", taskId);
- return false;
- }
-
- try {
- // 鏌ヨ浠诲姟淇℃伅
- SysTask task = sysTaskMapper.selectSysTaskByTaskId(taskId);
- if (task == null) {
- log.error("浠诲姟涓嶅瓨鍦紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- // 鍙悓姝ユ�ユ晳杞繍浠诲姟
- if (!"EMERGENCY_TRANSFER".equals(task.getTaskType())) {
- log.info("闈炴�ユ晳杞繍浠诲姟锛岃烦杩囪皟搴﹀崟閲嶆柊鍚屾锛屼换鍔D: {}", taskId);
- return false;
- }
-
- // 鏌ヨ鎬ユ晳杞繍鎵╁睍淇℃伅
- SysTaskEmergency emergency = sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
- if (emergency == null) {
- log.error("鎬ユ晳杞繍鎵╁睍淇℃伅涓嶅瓨鍦紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- // 蹇呴』宸茬粡鍚屾杩囪皟搴﹀崟
- if (emergency.getLegacyDispatchOrdId() == null || emergency.getLegacyDispatchOrdId() <= 0) {
- log.warn("璋冨害鍗曟湭鍚屾锛屾棤娉曢噸鏂板悓姝ワ紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- Long serviceOrdId = emergency.getLegacyServiceOrdId();
- if (serviceOrdId == null || serviceOrdId <= 0) {
- log.warn("鏈嶅姟鍗曟湭鍚屾锛屾棤娉曢噸鏂板悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", taskId);
- return false;
- }
-
- // ====== 鍓嶇疆鏍￠獙锛氱‘淇濅换鍔℃暟鎹畬鏁� ======
-
- // 1. 妫�鏌ユ槸鍚﹀凡鍒嗛厤杞﹁締
- List<SysTaskVehicle> taskVehicles = sysTaskVehicleMapper.selectSysTaskVehicleByTaskId(taskId);
- if (taskVehicles == null || taskVehicles.isEmpty()) {
- log.warn("浠诲姟鏈垎閰嶈溅杈嗭紝璺宠繃璋冨害鍗曢噸鏂板悓姝ワ紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- // 2. 妫�鏌ユ槸鍚﹀凡鍒嗛厤鎵ц浜哄憳
- List<SysTaskAssignee> taskAssignees = sysTaskAssigneeMapper.selectSysTaskAssigneeByTaskId(taskId);
- if (taskAssignees == null || taskAssignees.isEmpty()) {
- log.warn("浠诲姟鏈垎閰嶆墽琛屼汉鍛橈紝璺宠繃璋冨害鍗曢噸鏂板悓姝ワ紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- // 3. 妫�鏌ラ绾︽椂闂存槸鍚︽湁鏁�
- if (task.getPlannedStartTime() == null || task.getPlannedStartTime().getTime() <= 0L) {
- log.warn("浠诲姟棰勭害鏃堕棿鏃犳晥锛岃烦杩囪皟搴﹀崟閲嶆柊鍚屾锛屼换鍔D: {}", taskId);
- return false;
- }
-
- // 4. 妫�鏌ヨ浆鍑哄尰闄俊鎭�
- if (StringUtils.isEmpty(emergency.getHospitalOutName()) || StringUtils.isEmpty(emergency.getHospitalOutAddress())) {
- log.warn("浠诲姟杞嚭鍖婚櫌淇℃伅涓嶅畬鏁达紝璺宠繃璋冨害鍗曢噸鏂板悓姝ワ紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- // 5. 妫�鏌ヨ浆鍏ュ尰闄俊鎭�
- if (StringUtils.isEmpty(emergency.getHospitalInName()) || StringUtils.isEmpty(emergency.getHospitalInAddress())) {
- log.warn("浠诲姟杞叆鍖婚櫌淇℃伅涓嶅畬鏁达紝璺宠繃璋冨害鍗曢噸鏂板悓姝ワ紝浠诲姟ID: {}", taskId);
- return false;
- }
-
- // 6. 妫�鏌ユ偅鑰呭熀鏈俊鎭�
- if (StringUtils.isEmpty(emergency.getPatientName()) || StringUtils.isEmpty(emergency.getPatientPhone())) {
- log.warn("浠诲姟鎮ｈ�呬俊鎭笉瀹屾暣锛岃烦杩囪皟搴﹀崟閲嶆柊鍚屾锛屼换鍔D: {}", taskId);
- return false;
- }
-
- log.info("浠诲姟鏁版嵁鏍￠獙閫氳繃锛屽紑濮嬮噸鏂板悓姝ヨ皟搴﹀崟锛屼换鍔D: {}, DispatchOrdID: {}", taskId, emergency.getLegacyDispatchOrdId());
-
- // 鏋勫缓璇锋眰鍙傛暟锛堜娇鐢ㄧ浉鍚岀殑鍙傛暟鏋勫缓鏂规硶锛�
- Map<String, String> params = buildDispatchOrderParams(task, emergency);
- params.put("DispatchOrdID", emergency.getLegacyDispatchOrdId().toString());
- params.put("ServiceOrdID", emergency.getLegacyServiceOrdId().toString());
- params.put("DispatchOrdState", "3");
- log.info("閲嶆柊鍚屾璋冨害鍗曞埌鏃х郴缁熻姹傚弬鏁�: {}", params);
- // 鍙戦�丠TTP璇锋眰鍒版棫绯荤粺锛堜娇鐢╝dmin_save_25.asp鎺ュ彛锛�
- String response = sendHttpPost(legacyConfig.getDispatchUpdateUrl(), params);
- log.info("閲嶆柊鍚屾璋冨害鍗曞埌鏃х郴缁熷搷搴�: ServiceOrdID:{},DispatchOrdId:{},Result: {}",emergency.getLegacyServiceOrdId(),emergency.getLegacyDispatchOrdId(), response);
- // 瑙ｆ瀽鍝嶅簲
-// Long dispatchOrdId = parseResponse(response);
-
- if (response != null && response.equals("OK")) {
- // 閲嶆柊鍚屾鎴愬姛锛屾竻闄ら噸鏂板悓姝ユ爣璁�
+ SysTaskEmergency emergency=sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
+ Long dispatchOrderId = emergency.getLegacyDispatchOrdId();
+ if(LongUtil.isEmpty(dispatchOrderId)){
+ Long serviceOrderId= taskEmergencySyncService.syncEmergency(taskId);
+ if(LongUtil.isNotEmpty(serviceOrderId)) {
emergency.setNeedResync(0);
- emergency.setDispatchSyncTime(new Date());
- emergency.setDispatchSyncErrorMsg(null);
+// emergency.setSyncStatus(2);
+ emergency.setSyncTime(new Date());
sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- log.info("璋冨害鍗曢噸鏂板悓姝ユ垚鍔燂紝浠诲姟ID: {}, DispatchOrdID: {}", taskId, emergency.getLegacyDispatchOrdId());
return true;
- } else {
- // 閲嶆柊鍚屾澶辫触
- emergency.setDispatchSyncErrorMsg("閲嶆柊鍚屾澶辫触锛�" + response);
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
-
- log.error("璋冨害鍗曢噸鏂板悓姝ュけ璐ワ紝浠诲姟ID: {}, 鍝嶅簲: {}", taskId, response);
- return false;
}
-
- } catch (Exception e) {
- log.error("閲嶆柊鍚屾璋冨害鍗曞埌鏃х郴缁熷紓甯革紝浠诲姟ID: {}", taskId, e);
-
- // 鏇存柊鍚屾鐘舵�佷负澶辫触
- try {
- SysTaskEmergency emergency = sysTaskEmergencyService.selectSysTaskEmergencyByTaskId(taskId);
- if (emergency != null) {
- emergency.setDispatchSyncErrorMsg("閲嶆柊鍚屾寮傚父: " + e.getMessage());
- sysTaskEmergencyService.updateSysTaskEmergency(emergency);
- }
- } catch (Exception ex) {
- log.error("鏇存柊璋冨害鍗曞悓姝ョ姸鎬佸け璐�", ex);
- }
-
return false;
+ }else {
+ return taskDispatchSyncService.resyncDispatchOrderToLegacy(taskId);
}
}
-
+
+
/**
* 鎵归噺閲嶆柊鍚屾闇�瑕佹洿鏂扮殑璋冨害鍗�
*/
@@ -1380,48 +322,61 @@
while (true) {
// 鍒嗛〉鏌ヨ闇�瑕侀噸鏂板悓姝ョ殑浠诲姟
List<SysTaskEmergency> needResyncTasks = sysTaskEmergencyMapper.selectNeedResyncTasks(offset, pageSize);
-
- log.info("鏌ヨ鍒伴渶瑕侀噸鏂板悓姝ョ殑浠诲姟鏁伴噺: {}", needResyncTasks.size());
+
+// log.info("鏌ヨ鍒伴渶瑕侀噸鏂板悓姝ョ殑浠诲姟鏁伴噺: {}", needResyncTasks.size());
if (needResyncTasks == null || needResyncTasks.isEmpty()) {
log.info("娌℃湁鏇村闇�瑕侀噸鏂板悓姝ョ殑浠诲姟锛宱ffset: {}", offset);
break; // 娌℃湁鏇村鏁版嵁锛岄��鍑哄惊鐜�
}
-
- log.info("寮�濮嬮噸鏂板悓姝ヨ皟搴﹀崟绗� {} 椤碉紝浠诲姟鏁伴噺: {}", (offset / pageSize) + 1, needResyncTasks.size());
-
+
+// log.info("寮�濮嬮噸鏂板悓姝ヨ皟搴﹀崟绗� {} 椤碉紝浠诲姟鏁伴噺: {}", (offset / pageSize) + 1, needResyncTasks.size());
+
int pageSuccessCount = 0;
for (SysTaskEmergency emergency : needResyncTasks) {
- log.info("寮�濮嬮噸鏂板悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", emergency.getTaskId());
- boolean success = resyncDispatchOrderToLegacy(emergency.getTaskId());
-
- if (success) {
- pageSuccessCount++;
+ Long dispatchOrdId = emergency.getLegacyDispatchOrdId();
+ Long taskId = emergency.getTaskId();
+ if (LongUtil.isEmpty(dispatchOrdId)) {
+ //娌℃湁璋冨害鍗曪紝鎴戜滑灏辫皟鐢ㄥ垱寤鸿皟搴﹀崟
+ Long serviceOrderId = syncDispatchOrderToLegacy(taskId);
+ if (LongUtil.isNotEmpty(serviceOrderId)) {
+ emergency.setNeedResync(0);
+ emergency.setDispatchSyncTime(new Date());
+ emergency.setDispatchSyncErrorMsg(null);
+ sysTaskEmergencyService.updateSysTaskEmergency(emergency);
+
+ continue;
+ }
+// log.info("寮�濮嬮噸鏂板悓姝ヨ皟搴﹀崟锛屼换鍔D: {}", emergency.getTaskId());
+ boolean success = resyncDispatchOrderToLegacy(emergency.getTaskId());
+
+ if (success) {
+ pageSuccessCount++;
+ }
+
+ // 閬垮厤杩囦簬棰戠箒鐨勮姹�
+ try {
+ Thread.sleep(1000); // 姣忎釜璇锋眰闂撮殧1绉�
+ } catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
+ log.warn("閲嶆柊鍚屾璋冨害鍗曡涓柇");
+ return totalSuccessCount + pageSuccessCount;
+ }
}
-
- // 閬垮厤杩囦簬棰戠箒鐨勮姹�
- try {
- Thread.sleep(1000); // 姣忎釜璇锋眰闂撮殧1绉�
- } catch (InterruptedException e) {
- Thread.currentThread().interrupt();
- log.warn("閲嶆柊鍚屾璋冨害鍗曡涓柇");
- return totalSuccessCount + pageSuccessCount;
+
+ totalSuccessCount += pageSuccessCount;
+// log.info("璋冨害鍗曢噸鏂板悓姝ョ {} 椤靛畬鎴愶紝鎬绘暟: {}, 鎴愬姛: {}",
+// (offset / pageSize) + 1, needResyncTasks.size(), pageSuccessCount);
+
+ // 濡傛灉鏈〉鏁版嵁灏戜簬姣忛〉澶у皬锛岃鏄庡凡缁忔槸鏈�鍚庝竴椤�
+ if (needResyncTasks.size() < pageSize) {
+// log.info("宸插埌杈炬渶鍚庝竴椤碉紝璋冨害鍗曢噸鏂板悓姝ョ粨鏉�");
+ break;
}
+
+ offset += pageSize; // 涓嬩竴椤�
}
-
- totalSuccessCount += pageSuccessCount;
- log.info("璋冨害鍗曢噸鏂板悓姝ョ {} 椤靛畬鎴愶紝鎬绘暟: {}, 鎴愬姛: {}",
- (offset / pageSize) + 1, needResyncTasks.size(), pageSuccessCount);
-
- // 濡傛灉鏈〉鏁版嵁灏戜簬姣忛〉澶у皬锛岃鏄庡凡缁忔槸鏈�鍚庝竴椤�
- if (needResyncTasks.size() < pageSize) {
- log.info("宸插埌杈炬渶鍚庝竴椤碉紝璋冨害鍗曢噸鏂板悓姝ョ粨鏉�");
- break;
- }
-
- offset += pageSize; // 涓嬩竴椤�
}
-
- log.info("鎵归噺閲嶆柊鍚屾璋冨害鍗曞畬鎴愶紝鎬绘垚鍔熸暟: {}", totalSuccessCount);
+// log.info("鎵归噺閲嶆柊鍚屾璋冨害鍗曞畬鎴愶紝鎬绘垚鍔熸暟: {}", totalSuccessCount);
return totalSuccessCount;
} catch (Exception e) {
--
Gitblit v1.9.1