| | |
|---|
| | | import com.xiaopeng.common.core.utils.uuid.UUID; |
|---|
| | | import com.xiaopeng.common.redis.service.RedisService; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.data.mongodb.core.MongoTemplate; |
|---|
| | | import org.springframework.data.geo.Point;import org.springframework.data.mongodb.core.MongoTemplate; |
|---|
| | | import org.springframework.data.mongodb.core.geo.GeoJsonPoint; |
|---|
| | | import org.springframework.data.mongodb.core.query.Criteria; |
|---|
| | | import org.springframework.data.mongodb.core.query.Query; |
|---|
| | |
|---|
| | | long sequence = msgContent.getHeader().getSequence(); |
|---|
| | | responseMessage(sequence, vin); |
|---|
| | | //保存车辆实时位置到redis |
|---|
| | | redisTemplate.opsForGeo().add("vehiclePosition:" + vin, new GeoJsonPoint(longitude, latitude), vin); |
|---|
| | | redisTemplate.opsForGeo().add("vehiclePosition:" + vin, new Point(longitude, latitude), vin); |
|---|
| | | |
|---|
| | | //保存车辆实时信息到mongodb |
|---|
| | | VehiclePosition vehiclePosition = mongoTemplate.findOne(new Query(Criteria.where("vin").is(vin)), VehiclePosition.class); |
|---|
| | |
|---|
| | | //构建推送消息 |
|---|
| | | Map<String, Object> params = new HashMap<>(); |
|---|
| | | Map<String, Object> content = new HashMap<>(); |
|---|
| | | content.put("orderId", orderId); |
|---|
| | | content.put("orderId", orderId.toString()); |
|---|
| | | content.put("status", status.getCode()); |
|---|
| | | params.put("type", PushMessageTypeEnum.ORDER_STATUS.getDesc()); |
|---|
| | | params.put("content", JSONObject.toJSONString(content)); |
|---|
