新增轨迹创建逻辑，并基于运单消息触发轨迹生成

alexyang
1 parent 3d8f71d6
Showing 2 changed files with 75 additions and 0 deletions
sl-express-ms-track-service/src/main/java/com/sl/ms/track/mq/MQListener.java
sl-express-ms-track-service/src/main/java/com/sl/ms/track/service/impl/TrackServiceImpl.java
 package com.sl.ms.track.mq;
  
+import cn.hutool.json.JSONUtil;
 import com.sl.ms.track.service.TrackService;
 import com.sl.transport.common.constant.Constants;
+import com.sl.transport.common.vo.TransportOrderMsg;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.ExchangeTypes;
 import org.springframework.amqp.rabbit.annotation.Exchange;
@@ -37,6 +39,8 @@ public class MQListener {
     ))
     public void listenTransportOrderCreatedMsg(String msg) {
         log.info("接收到新增运单的消息 ({})-> {}", Constants.MQ.Queues.TRACK_TRANSPORT_ORDER_CREATED, msg);
+        TransportOrderMsg transportOrderMsg = JSONUtil.toBean(msg, TransportOrderMsg.class);
+        trackService.create(transportOrderMsg.getId());
         //TODO 实战完成
     }
  
 package com.sl.ms.track.service.impl;
  
+import cn.hutool.core.convert.Convert;
+import cn.hutool.core.map.MapUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.itheima.em.sdk.EagleMapTemplate;
+import com.itheima.em.sdk.enums.ProviderEnum;
+import com.itheima.em.sdk.vo.Coordinate;
+import com.sl.ms.oms.api.OrderFeign;
+import com.sl.ms.oms.dto.OrderLocationDTO;
+import com.sl.ms.track.domain.enums.TrackStatusEnum;
+import com.sl.ms.track.domain.enums.TrackTypeEnum;
 import com.sl.ms.track.entity.TrackEntity;
 import com.sl.ms.track.service.TrackService;
+import com.sl.ms.work.api.TransportOrderFeign;
+import com.sl.ms.work.domain.dto.TransportOrderDTO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.stereotype.Service;
  
 import java.util.List;
+import java.util.Map;
  
 @Service
 public class TrackServiceImpl implements TrackService {
+
+    @Autowired
+    private OrderFeign orderFeign;
+
+    @Autowired
+    private TransportOrderFeign transportOrderFeign;
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    @Autowired
+    private EagleMapTemplate eagleMapTemplate;
+
     @Override
     public boolean create(String transportOrderId) {
+        TransportOrderDTO transportOrderDTO = transportOrderFeign.findById(transportOrderId);
+
+        OrderLocationDTO orderLocationDTO = orderFeign.findOrderLocationByOrderId(transportOrderDTO.getOrderId());
+
+        TrackEntity trackEntity = new TrackEntity();
+        trackEntity.setTransportOrderId(transportOrderId);
+
+        String sendLocation = orderLocationDTO.getSendLocation();
+        String receiveLocation = orderLocationDTO.getReceiveLocation();
+
+        double sendLnt = Double.parseDouble(sendLocation.split(",")[0]);
+        double sendLat = Double.parseDouble(sendLocation.split(",")[1]);
+
+
+        double receiveLnt = Double.parseDouble(receiveLocation.split(",")[0]);
+        double receiveLat = Double.parseDouble(receiveLocation.split(",")[1]);
+
+        Coordinate origin = new Coordinate(sendLnt, sendLat);
+        Coordinate destination = new Coordinate(receiveLnt, receiveLat);
+
+        //设置高德地图参数，默认是不返回预计耗时的，需要额外设置参数
+        Map<String, Object> param = MapUtil.<String, Object>builder().put("show_fields", "polyline").build();
+        String driving = this.eagleMapTemplate.opsForDirection().driving(ProviderEnum.AMAP, origin, destination, param);
+        if (StrUtil.isEmpty(driving)) {
+            return false;
+        }
+        JSONObject jsonObject = JSONUtil.parseObj(driving);
+
+        //距离，单位：米
+        Double distance = Convert.toDouble(jsonObject.getByPath("route.paths[0].distance"), -1d);
+        trackEntity.setDistance(distance);
+        trackEntity.setStatus(TrackStatusEnum.NEW);
+        trackEntity.setType(TrackTypeEnum.COURIER);
+
+        JSONArray steps = jsonObject.getByPath("route.paths[0].steps", JSONArray.class);
+        for (int i = 0; i < steps.size(); i++) {
+            JSONObject entries = steps.getJSONObject(i);
+            String polyline = entries.getStr("polyline");
+        }
+
         return false;
     }