|
@@ -4,21 +4,26 @@ import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.ydd.common.core.redis.RedisCache;
|
|
|
-import com.ydd.third.common.utils.*;
|
|
|
+import com.ydd.third.common.config.DeliveryConfig;
|
|
|
+import com.ydd.third.common.utils.CoordinateUtils;
|
|
|
+import com.ydd.third.common.utils.DateUtils;
|
|
|
+import com.ydd.third.common.utils.StringUtils;
|
|
|
import com.ydd.third.common.vo.ResObject;
|
|
|
+import com.ydd.third.common.vo.shop.*;
|
|
|
+import com.ydd.third.common.vo.vo.order.*;
|
|
|
import com.ydd.third.delivery.ClientHandler;
|
|
|
-import com.ydd.third.delivery.config.DeliveryConfig;
|
|
|
import com.ydd.third.delivery.shansong.constants.RequestConstant;
|
|
|
import com.ydd.third.delivery.shansong.sign.SignHelper;
|
|
|
import com.ydd.third.delivery.shansong.utils.HttpClient;
|
|
|
-import com.ydd.third.delivery.vo.order.*;
|
|
|
-import com.ydd.third.delivery.vo.shop.*;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
-import java.util.*;
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
|
|
|
import static com.ydd.third.delivery.shansong.constants.RequestConstant.*;
|
|
|
|
|
@@ -49,30 +54,6 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
public ResObject<OrderResultVo> queryOrderDeliverFee(OrderVo order) {
|
|
|
String url = RequestConstant.getApiUrl(appConfig.isTest()) + SH_ORDER_CALCULATE_URL;
|
|
|
ResObject<OrderResultVo> resObject = new ResObject<>();
|
|
|
- /**
|
|
|
- String token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- try {
|
|
|
- ResObject resObjectToken = refreshToken();
|
|
|
- if (resObjectToken.getCode() == 0) {
|
|
|
- token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- } else {
|
|
|
- return resObjectToken;
|
|
|
- }
|
|
|
-
|
|
|
- } catch (Exception ex) {
|
|
|
- log.error(ex.getMessage());
|
|
|
- resObject.setCode(1);
|
|
|
- resObject.setMsg("token 无效,重新获取token时发生异常,"+ex.getMessage());
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- }
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- resObject.setCode(2);
|
|
|
- resObject.setMsg("token 无效,重新授权");
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- **/
|
|
|
resObject.setCode(1);
|
|
|
resObject.setMsg("非法访问");
|
|
|
// JSONObject jsonParams = JSONObject.parseObject(jsonParamsStr);
|
|
@@ -131,6 +112,7 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
List<Map<String, String>> receiverList = new ArrayList<>();
|
|
|
receiverList.add(receiverMap);
|
|
|
dataMap.put("receiverList", receiverList);
|
|
|
+ dataMap.put("storeId",order.getShopNo());
|
|
|
dataMap.put("appointType", order.getIsAppoint()); //预约类型 int/YES 0立即单,1预约单
|
|
|
dataMap.put("appointmentDate", DateUtils.format(order.getExpectedPickupTime(), "yyyy-MM-dd HH:mm")); //预约时间 String/NO 2020-02-02 22:00,指的是预约取件时间
|
|
|
|
|
@@ -211,51 +193,9 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
public ResObject<OrderResultVo> createOrder(OrderVo order) {
|
|
|
String url = RequestConstant.getApiUrl(appConfig.isTest()) + SH_CREATE_ORDER_URL;
|
|
|
ResObject<OrderResultVo> resObject = new ResObject<>();
|
|
|
- /**
|
|
|
- String token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- //
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- try {
|
|
|
- ResObject resObjectToken = refreshToken();
|
|
|
- if (resObjectToken.getCode() == 0) {
|
|
|
- token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- } else {
|
|
|
- return resObjectToken;
|
|
|
- // return tokenJson.toJSONString();
|
|
|
- }
|
|
|
-
|
|
|
- } catch (Exception ex) {
|
|
|
- log.error(ex.getMessage());
|
|
|
- resObject.setCode(1);
|
|
|
- resObject.setMsg("token 无效,重新获取token时发生异常,"+ex.getMessage());
|
|
|
- return resObject;
|
|
|
- //return JSONUtil.toJson(resObject);
|
|
|
- }
|
|
|
- }
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- resObject.setCode(2);
|
|
|
- resObject.setMsg("token 无效,重新授权");
|
|
|
- return resObject;
|
|
|
- //return JSONUtil.toJson(resObject);
|
|
|
- }
|
|
|
- **/
|
|
|
resObject.setCode(1);
|
|
|
resObject.setMsg("非法访问");
|
|
|
|
|
|
-
|
|
|
-// ResObject<OrderResultVo> orderRes = queryOrderDeliverFee(order);
|
|
|
-// // JSONObject orderResJson = JSONObject.parseObject(orderResStr);
|
|
|
-// if (orderRes.getCode() != 0) {
|
|
|
-// resObject.setCode(1);
|
|
|
-// String errMsg = orderRes.getMsg();
|
|
|
-// if (StringUtils.isBlank(errMsg)) {
|
|
|
-// errMsg = "操作失败";
|
|
|
-// }
|
|
|
-// resObject.setMsg(errMsg);
|
|
|
-// return resObject;
|
|
|
-// // return orderResStr;
|
|
|
-// }
|
|
|
- // String orderNumber = (orderRes.getData()).getDeliveryOrderNo();
|
|
|
String orderNumber = order.getOrderNumber();
|
|
|
// orderResJson.getString("orderNumber");
|
|
|
Map<String, Object> dataMap = new HashMap<String, Object>();
|
|
@@ -329,30 +269,6 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
String url = RequestConstant.getApiUrl(appConfig.isTest()) + SH_ABORT_ORDER_URL;
|
|
|
|
|
|
ResObject<CancelOrderResultVo> resObject = new ResObject<>();
|
|
|
- /**
|
|
|
- String token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- try {
|
|
|
- ResObject resObjectToken = refreshToken();
|
|
|
- if (resObjectToken.getCode() == 0) {
|
|
|
- token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- } else {
|
|
|
- return resObjectToken;
|
|
|
- }
|
|
|
-
|
|
|
- } catch (Exception ex) {
|
|
|
- log.error(ex.getMessage());
|
|
|
- resObject.setCode(1);
|
|
|
- resObject.setMsg("token 无效,重新获取token时发生异常,"+ex.getMessage());
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- }
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- resObject.setCode(2);
|
|
|
- resObject.setMsg("token 无效,重新授权");
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- **/
|
|
|
resObject.setCode(1);
|
|
|
resObject.setMsg("非法访问");
|
|
|
//JSONObject jsonParams = JSONObject.parseObject(jsonParamsStr);
|
|
@@ -413,30 +329,7 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
public ResObject<OrderQueryResultVo> queryOrderInfo(OrderQueryVo orderQueryVo) {
|
|
|
String url = RequestConstant.getApiUrl(appConfig.isTest()) + SH_ORDER_INFO_URL;
|
|
|
ResObject<OrderQueryResultVo> resObject = new ResObject<>();
|
|
|
- /**
|
|
|
- String token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- try {
|
|
|
- ResObject resObjectToken = refreshToken();
|
|
|
- if (resObjectToken.getCode() == 0) {
|
|
|
- token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- } else {
|
|
|
- return resObjectToken;
|
|
|
- }
|
|
|
|
|
|
- } catch (Exception ex) {
|
|
|
- log.error(ex.getMessage());
|
|
|
- resObject.setCode(1);
|
|
|
- resObject.setMsg("token 无效,重新获取token时发生异常,"+ex.getMessage());
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- }
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- resObject.setCode(2);
|
|
|
- resObject.setMsg("token 无效,重新授权");
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- **/
|
|
|
resObject.setCode(1);
|
|
|
resObject.setMsg("非法访问");
|
|
|
|
|
@@ -514,30 +407,7 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
public ResObject<OrderTipsResultVo> orderAddTip(OrderTipsVo orderTipsVo) {
|
|
|
String url = RequestConstant.getApiUrl(appConfig.isTest()) + SH_ADDITION_URL;
|
|
|
ResObject<OrderTipsResultVo> resObject = new ResObject<>();
|
|
|
- /**
|
|
|
- String token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- try {
|
|
|
- ResObject resObjectToken = refreshToken();
|
|
|
- if (resObjectToken.getCode() == 0) {
|
|
|
- token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- } else {
|
|
|
- return resObjectToken;
|
|
|
- }
|
|
|
|
|
|
- } catch (Exception ex) {
|
|
|
- log.error(ex.getMessage());
|
|
|
- resObject.setCode(1);
|
|
|
- resObject.setMsg("token 无效,重新获取token时发生异常,"+ex.getMessage());
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- }
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- resObject.setCode(2);
|
|
|
- resObject.setMsg("token 无效,重新授权");
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- **/
|
|
|
resObject.setCode(1);
|
|
|
resObject.setMsg("非法访问");
|
|
|
//JSONObject jsonParams = JSONObject.parseObject(jsonParamsStr);
|
|
@@ -838,30 +708,6 @@ public class ShansongSHClient implements ClientHandler {
|
|
|
public ResObject<AmountResultVo> queryAmount(QueryAmount queryAmount) {
|
|
|
String url = RequestConstant.getApiUrl(appConfig.isTest()) + SH_GET_USER_ACCOUNT_URL;
|
|
|
ResObject resObject = new ResObject();
|
|
|
- /**
|
|
|
- String token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- try {
|
|
|
- ResObject resObjectToken = refreshToken();
|
|
|
- if (resObjectToken.getCode() == 0) {
|
|
|
- token = redisCache.getCacheObject("DELIVERY_SHANSONG_TOKEN");
|
|
|
- } else {
|
|
|
- return resObjectToken;
|
|
|
- }
|
|
|
-
|
|
|
- } catch (Exception ex) {
|
|
|
- log.error(ex.getMessage());
|
|
|
- resObject.setCode(1);
|
|
|
- resObject.setMsg("token 无效,重新获取token时发生异常,"+ex.getMessage());
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- }
|
|
|
- if (StringUtils.isBlank(token)) {
|
|
|
- resObject.setCode(2);
|
|
|
- resObject.setMsg("token 无效,重新授权");
|
|
|
- return resObject;
|
|
|
- }
|
|
|
- **/
|
|
|
resObject.setCode(1);
|
|
|
resObject.setMsg("非法访问");
|
|
|
// JSONObject jsonParams = JSONObject.parseObject(jsonParamsStr);
|