From efd9ac5b88dfdb3c4d2e4bcc5e7a5258aa55542c Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期一, 21 四月 2025 20:29:15 +0800 Subject: [PATCH] 更换缓存连接方式 --- DriverZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderPositionServiceImpl.java | 38 +++++++++++++++++++------------------- 1 files changed, 19 insertions(+), 19 deletions(-) diff --git a/DriverZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderPositionServiceImpl.java b/DriverZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderPositionServiceImpl.java index 4936bd0..2e223a4 100644 --- a/DriverZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderPositionServiceImpl.java +++ b/DriverZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderPositionServiceImpl.java @@ -51,25 +51,25 @@ @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(); -// } -// //写入相应的文件 -// PrintWriter out = new PrintWriter(new FileWriter(file)); -// orderPositions.add(orderPosition); + 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(); + } + //写入相应的文件 + PrintWriter out = new PrintWriter(new FileWriter(file)); + orderPositions.add(orderPosition); // System.err.println("存储新数据:" + JSON.toJSONString(orderPositions)); -// out.write(JSON.toJSONString(orderPositions)); -// out.flush(); -// out.close(); -// } + out.write(JSON.toJSONString(orderPositions)); + out.flush(); + out.close(); + } new Thread(new Runnable() { @Override @@ -124,7 +124,7 @@ if(ToolUtil.isNotEmpty(sb.toString())){ list = JSONArray.parseArray(sb.toString(), OrderPosition.class); } - System.err.println("坐标:" + sb); +// System.err.println("坐标:" + sb); return list; } } -- Gitblit v1.7.1