From d1399868aa72b2cc75725e74500936b33de49910 Mon Sep 17 00:00:00 2001
From: liukangdong <898885815@qq.com>
Date: 星期一, 06 一月 2025 18:15:05 +0800
Subject: [PATCH] ll
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java | 88 ++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 88 insertions(+), 0 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java
index 405f54a..9132ddb 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java
@@ -3,6 +3,8 @@
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.TypeReference;
import com.doumee.biz.system.SystemDictDataBiz;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
import com.doumee.core.tms.model.TMSContants;
import com.doumee.core.tms.model.request.*;
import com.doumee.core.tms.model.response.*;
@@ -10,6 +12,7 @@
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.HttpsUtil;
import com.doumee.dao.business.*;
+import com.doumee.dao.business.dao.MemberMapper;
import com.doumee.dao.business.dao.SmsEmailMapper;
import com.doumee.dao.business.model.*;
import com.doumee.service.business.third.TmsService;
@@ -165,6 +168,10 @@
for(Integer t :statusList){
for(TmsCircleStatusListResponse status :data){
if(Constants.equalsInteger(status.getOrderStatus(),Constants.FOUR)
+ && Constants.equalsInteger(status.getType(),TMSContants.StatusCode.rggx)) {
+ continue;
+ }
+ if(Constants.equalsInteger(status.getOrderStatus(),Constants.FOUR)
&& Constants.equalsInteger(status.getType(),TMSContants.StatusCode.app)) {
status.setOrderStatus(TMSContants.ChildStatusLevel.clqdapp.getOrderStatus());
}
@@ -208,6 +215,87 @@
}
/**
+ * 鏌ヨ鍙告満鎵�鏈変唬鍔炰换鍔�
+ * @param param 鍙傛暟
+ * @return TmsBaseResponse
+ */
+ @Override
+ public TmsBasePageResponse<TmsDriveTaskListResponse> getDriverTaskList(TmsDriverTaskListRequest param){
+ String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode()
+ +TMSContants.InterfacePath.getDriverTaskList[0];
+
+// url = "http://10.163.4.56:8088"+TMSContants.InterfacePath.getDriverTaskList[0];
+ TmsBaseResponse<TmsBasePageResponse<TmsDriveTaskListResponse> > response = sendHttpRequest(url,TMSContants.InterfacePath.getDriverTaskList[1],JSONObject.toJSONString(param)
+ ,new TypeReference< TmsBaseResponse<TmsBasePageResponse<TmsDriveTaskListResponse>>>(){});
+ if(response ==null || response.getData() == null){
+ return new TmsBasePageResponse<>();
+ }
+ return response.getData();
+ }
+ /**
+ * 鍙告満寰呭姙浠诲姟璇︽儏
+ * @param param 鍙傛暟
+ * @return TmsBaseResponse
+ */
+ @Override
+ public TmsDriveTaskInfoResponse getDriverTaskDetail(TmsDriverTaskInfoRequest param){
+ if(StringUtils.isBlank(param.getId()) ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode()
+ +TMSContants.InterfacePath.getDriverTaskDetail[0];
+
+// url = "http://10.163.4.56:8088"+TMSContants.InterfacePath.getDriverTaskDetail[0];
+ TmsBaseResponse<TmsDriveTaskInfoResponse > response = sendHttpRequest(url,TMSContants.InterfacePath.getDriverTaskDetail[1],JSONObject.toJSONString(param)
+ ,new TypeReference< TmsBaseResponse<TmsDriveTaskInfoResponse>>(){});
+ if(response ==null || response.getData() == null){
+ return new TmsDriveTaskInfoResponse();
+ }
+ return response.getData();
+ }
+ /**
+ * 鍙告満鍚繍
+ * @param param 鍙傛暟
+ * @return TmsBaseResponse
+ */
+ @Override
+ public boolean driverStart(TmsDriverStartAndArrivalRequest param){
+ if(StringUtils.isBlank(param.getId()) || StringUtils.isBlank(param.getOptType())){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode()
+ +TMSContants.InterfacePath.driverStart[0];
+// url = "http://10.163.4.56:8088"+TMSContants.InterfacePath.driverStart[0];
+ TmsBaseResponse<TmsDriveTaskInfoResponse > response = sendHttpRequest(url,TMSContants.InterfacePath.driverStart[1],JSONObject.toJSONString(param)
+ ,new TypeReference< TmsBaseResponse<TmsDriveTaskInfoResponse>>(){});
+ if(response ==null || !StringUtils.equals(response.getCode(),"0")){
+ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"瀵逛笉璧凤紝浠诲姟鍒拌揣鎻愪氦澶辫触锛岃绋嶅悗閲嶈瘯锛�");
+ }
+ return true;
+ }
+ /**
+ * 鍙告満鍒拌揣
+ * @param param 鍙傛暟
+ * @return TmsBaseResponse
+ */
+ @Override
+ public boolean driverArrival(TmsDriverStartAndArrivalRequest param){
+ if(StringUtils.isBlank(param.getId())
+ || StringUtils.isBlank(param.getOptType())
+ || param.getStopNumber() == null){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode()
+ +TMSContants.InterfacePath.driverArrival[0];
+// url = "http://10.163.4.56:8088"+TMSContants.InterfacePath.driverArrival[0];
+ TmsBaseResponse<TmsDriveTaskInfoResponse > response = sendHttpRequest(url,TMSContants.InterfacePath.driverArrival[1],JSONObject.toJSONString(param)
+ ,new TypeReference< TmsBaseResponse<TmsDriveTaskInfoResponse>>(){});
+ if(response ==null ||!StringUtils.equals(response.getCode(),"0")){
+ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"瀵逛笉璧凤紝浠诲姟鍒拌揣鎻愪氦澶辫触锛岃绋嶅悗閲嶈瘯锛�");
+ }
+ return true;
+ }
+ /**
* 鍑哄簱鑳藉姏缁熻
* 鏌ヨ鏌愪釜鍘�/鍏ㄩ儴鍘傜殑浠婃棩璁″垝閲忋�佷粖鏃ュ嚭搴撻噺銆佷粖鏃ユ湭鍑哄簱閲忔暟鎹��
* @param param 鍙傛暟
--
Gitblit v1.9.3