package com.stylefeng.guns.modular.system.service.impl;
|
|
import cn.hutool.core.io.FileUtil;
|
import cn.hutool.core.util.CharsetUtil;
|
import com.alibaba.fastjson.JSON;
|
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 com.stylefeng.guns.modular.system.service.IOrderService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.io.*;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
|
@Service
|
public class OrderPositionServiceImpl extends ServiceImpl<OrderPositionMapper, OrderPosition> implements IOrderPositionService {
|
|
@Resource
|
private OrderPositionMapper orderPositionMapper;
|
|
@Autowired
|
private IOrderService orderService;
|
|
@Value("${filePath}")
|
private String filePath;
|
|
|
|
/**
|
* 添加数据
|
* @param orderPosition
|
* @throws Exception
|
*/
|
@Override
|
public void saveData(OrderPosition orderPosition) throws Exception {
|
//计算实时里程
|
boolean b = orderService.calculateMileage(orderPosition);
|
if(b){//如果计算了里程则将新的数据存储到数据库作为下个起点
|
//先计算里程，在存储最新位置
|
orderPosition.setInsertTime(new Date());
|
//将数据存储到文件中
|
List<OrderPosition> orderPositions = this.queryPosition(orderPosition.getOrderId(), orderPosition.getOrderType());
|
File file = new File(filePath + orderPosition.getOrderId() + "_" + orderPosition.getOrderType() + ".txt");
|
if(!file.exists()){
|
file.getParentFile().mkdirs();
|
file.createNewFile();
|
}
|
//写入相应的文件
|
orderPositions.add(orderPosition);
|
System.err.println("存储新数据：" + JSON.toJSONString(orderPositions));
|
FileUtil.writeUtf8String(JSON.toJSONString(orderPositions), file);
|
}
|
}
|
|
|
/**
|
* 获取最新的坐标位置
|
* @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{
|
//将数据存储到文件中
|
File file = new File(filePath + orderId + "_" + orderType + ".txt");
|
if(!file.exists()){
|
return new ArrayList<>();
|
}
|
//读取文件(字符流)
|
String s = FileUtil.readString(file, CharsetUtil.CHARSET_UTF_8);
|
List<OrderPosition> list = new ArrayList<>();
|
if(ToolUtil.isNotEmpty(s)){
|
list = JSONArray.parseArray(s, OrderPosition.class);
|
}
|
return list;
|
}
|
}
|
