package com.stylefeng.guns.modular.system.service.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
|
import com.stylefeng.guns.core.util.ToolUtil;
|
import com.stylefeng.guns.modular.system.dao.OrderPositionMapper;
|
import com.stylefeng.guns.modular.system.model.OrderPosition;
|
import com.stylefeng.guns.modular.system.service.IOrderPositionService;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.mongodb.core.MongoTemplate;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.io.*;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
|
@Service
|
public class OrderPositionServiceImpl extends ServiceImpl<OrderPositionMapper, OrderPosition> implements IOrderPositionService {
|
|
@Resource
|
private OrderPositionMapper orderPositionMapper;
|
|
@Resource
|
private MongoTemplate mongoTemplate;
|
|
|
|
/**
|
* 获取最新的坐标位置
|
* @param orderId
|
* @param orderType
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public OrderPosition queryNew(Integer orderId, Integer orderType) throws Exception {
|
List<OrderPosition> orderPositions = this.queryPosition(orderId, orderType);
|
return orderPositions.size() > 0 ? orderPositions.get(orderPositions.size() - 1) : null;
|
}
|
|
|
/**
|
* 获取坐标文件中的坐标数据
|
* @param orderId
|
* @param orderType
|
* @return
|
* @throws Exception
|
*/
|
@Override
|
public List<OrderPosition> queryPosition(Integer orderId, Integer orderType) throws Exception{
|
//将数据存储到文件中
|
Query query = new Query()
|
.addCriteria(Criteria.where("orderId").is(orderId).and("orderType").is(orderType))
|
.with(new Sort(Sort.Direction.ASC, "insertTime"));
|
List<OrderPosition> positions = mongoTemplate.find(query, OrderPosition.class);
|
return positions;
|
}
|
}
|
