src/main/java/org/springblade/common/config/BladeConfiguration.java
@@ -39,6 +39,7 @@ SecureRegistry secureRegistry = new SecureRegistry(); secureRegistry.setEnabled(true); secureRegistry.excludePathPatterns("/blade-auth/**"); secureRegistry.excludePathPatterns("/blade-user/**"); secureRegistry.excludePathPatterns("/blade-system/menu/routes"); secureRegistry.excludePathPatterns("/blade-system/menu/auth-routes"); secureRegistry.excludePathPatterns("/blade-system/menu/top-menu"); @@ -84,6 +85,7 @@ secureRegistry.excludePathPatterns("/zc/**"); secureRegistry.excludePathPatterns("/licet/**"); secureRegistry.excludePathPatterns("/licetuser/**"); secureRegistry.excludePathPatterns("/locus/**"); return secureRegistry; }
@@ -44,9 +44,9 @@ * @return * @throws Exception */ //@Scheduled(cron = "0 */1 * * * ?") @Scheduled(cron = "0 */5 * * * ?") public void Peo() throws Exception { String url = "http://223.82.109.183:2080/Escort/getgis.php"; String url = "http://47.104.104.46/api/client/getgis.php"; //查询有押运人员的数据 List<Map<String, Object>> list = userService.selectEquipent(); for (int i = 0; i < list.size(); i++) { @@ -113,8 +113,7 @@ "'" + liveLocation.getWorkerId() + "'" + "," + "'" + liveLocation.getLongitude() + "'" + "," + "'" + liveLocation.getLatitude() + "'" + "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + "," + "'" + liveLocation.getLocation() + "'" + ")"; "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + ")"; FtpUtil.sqlFileUpload(s1); } else { status = liveLocationService.updateById(liveLocationInfo); @@ -125,7 +124,6 @@ ",longitude = " + "'" + liveLocationInfo.getLongitude() + "'" + ",latitude = " + "'" + liveLocationInfo.getLatitude() + "'" + ",record_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocationInfo.getRecordTime()) + "'" + ",location = " + "'" + liveLocationInfo.getLocation() + "'" + " " + "where id = " + "'" + liveLocationInfo.getId() + "'"; FtpUtil.sqlFileUpload(s1); } @@ -138,12 +136,12 @@ * @return * @throws Exception */ //@Scheduled(cron = "0 */1 * * * ?") @Scheduled(cron = "0 0 * * * ?") public void Peog() throws Exception { String url = "http://47.104.104.46/api/client/getgistrack.php"; Calendar calendar = Calendar.getInstance(); calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 1); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:00:00"); //查询有押运人员的数据 List<Map<String, Object>> list = userService.selectEquipent(); for (int i = 0; i < list.size(); i++) { @@ -156,13 +154,14 @@ String equipmentCode = list.get(i).get("code").toString(); //设备imei号 params.put("number", 7730); params.put("acc", 7731); params.put("acc", equipmentCode); params.put("startTime", df.format(calendar.getTime())); params.put("endTime", df.format(new Date())); String res = null; res = HttpReqUtil.getInstance().doPost(url, params, null); String a="["+res+"]"; JSONArray jsonArray = JSONArray.fromObject(a); String s1 = ""; String track = jsonArray.getJSONObject(0).get("track").toString(); JSONArray jsonArray1 = JSONArray.fromObject(track); for (int j = 0; j < jsonArray1.size(); j++) { @@ -181,16 +180,19 @@ locus.setLongitude(gis_jd); locus.setLatitude(gis_wd); locusService.save(locus); // //数据推送 // String s1 = "insert into sys_locus(id,type,worker_id,longitude,latitude,record_time) " + // "values(" + "'" + locus.getId() + "'" + "," + // "'" + locus.getType() + "'" + "," + // "'" + locus.getWorkerId() + "'" + "," + // "'" + locus.getLongitude() + "'" + "," + // "'" + locus.getLatitude() + "'" + "," + // "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(locus.getRecordTime()) + "'" + ")"; // FtpUtil.sqlFileUpload(s1); //数据推送 s1 += "insert into sys_locus(id,type,worker_id,longitude,latitude,record_time) values" + " (" + "'" + locus.getId() + "'" + "," + "'" + locus.getType() + "'" + "," + "'" + locus.getWorkerId() + "'" + "," + "'" + locus.getLongitude() + "'" + "," + "'" + locus.getLatitude() + "'" + "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(locus.getRecordTime()) + "'" + ")"; if (j != jsonArray1.size() - 1) { s1 += ";"; } } FtpUtil.sqlFileUpload(s1); } } @@ -198,7 +200,7 @@ /** * 车辆实时位置 */ //@Scheduled(cron = "0 */1 * * * ?") @Scheduled(cron = "0 */5 * * * ?") public void locationcar() { String url = "http://dvopenapi.aimap.net.cn/openapi/device/location"; String res = null; @@ -251,20 +253,18 @@ "'" + liveLocation.getWorkerId() + "'" + "," + "'" + liveLocation.getLongitude() + "'" + "," + "'" + liveLocation.getLatitude() + "'" + "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + "," + "'" + liveLocation.getLocation() + "'" + ")"; "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + ")"; FtpUtil.sqlFileUpload(s1); } else { status = liveLocationService.updateById(liveLocationInfo); //内网同步 String s1 = "update sys_live_location set type = " + "'" + liveLocation.getType() + "'" + ",worker_id = " + "'" + liveLocation.getWorkerId() + "'" + ",longitude = " + "'" + liveLocation.getLongitude() + "'" + ",latitude = " + "'" + liveLocation.getLatitude() + "'" + ",record_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + ",location = " + "'" + liveLocation.getLocation() + "'" + " " + "where id = " + "'" + liveLocation.getId() + "'"; "update sys_live_location set type = " + "'" + liveLocationInfo.getType() + "'" + ",worker_id = " + "'" + liveLocationInfo.getWorkerId() + "'" + ",longitude = " + "'" + liveLocationInfo.getLongitude() + "'" + ",latitude = " + "'" + liveLocationInfo.getLatitude() + "'" + ",record_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocationInfo.getRecordTime()) + "'" + " " + "where id = " + "'" + liveLocationInfo.getId() + "'"; FtpUtil.sqlFileUpload(s1); } } catch (Exception e) { @@ -290,8 +290,9 @@ /** * 查询车辆轨迹 */ //@Scheduled(cron = "0 */1 * * * ?") @Scheduled(cron = "0 0 * * * ?") public void locationhistoryTrack() { System.out.println("车辆轨迹"); Calendar calendar = Calendar.getInstance(); /* HOUR_OF_DAY 指示一天中的小时 */ calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 1); @@ -305,7 +306,7 @@ params.put("beginTime", df.format(calendar.getTime())); params.put("endTime", df.format(new Date())); params.put("rectify", 0); params.put("callbackUrl", "http://2h3f861221.wicp.vip/locus/SaveUrl"); params.put("callbackUrl", "http://223.82.109.183:2080/api/locus/SaveUrl"); params.put("callbackId", maps.get(i).get("carnumber").toString()); params.put("appId", "PO00000761"); params.put("timestamp", System.currentTimeMillis()); @@ -325,6 +326,5 @@ } } } src/main/java/org/springblade/modules/location/controller/LocusController.java
@@ -37,6 +37,8 @@ import java.util.*; import java.util.List; import static org.springblade.common.config.FtpConfig.localPath; /** * @author zhongrj * @time 2021-07-06 @@ -161,18 +163,18 @@ @ApiOperation(value = "详情", notes = "传入car") public void SaveUrl(String callbackId, String fileUrl) throws Exception { DowloadZipUtil dowloadZipUtil = new DowloadZipUtil(); File file = dowloadZipUtil.downloadFile(fileUrl, "D:\\caiji"); File file = dowloadZipUtil.downloadFile(fileUrl, "/usr/local/nginx/dist/enterprises/car"); //文件名 String name = file.getName(); String substring = name.substring(0, name.length() - 4); //解压数据 FileZip fileZip = new FileZip(); fileZip.ZipUncompress("D:\\caiji\\" + substring + ".zip", "D:\\caiji"); fileZip.ZipUncompress("/usr/local/nginx/dist/enterprises/car/" + substring + ".zip", "/usr/local/nginx/dist/enterprises/car"); try { // 用来保存数据 ArrayList<String[]> csvFileList = new ArrayList<String[]>(); // 定义一个CSV路径 String csvFilePath = "D:\\caiji\\" + substring + ".csv"; String csvFilePath = "/usr/local/nginx/dist/enterprises/car/" + substring + ".csv"; // 创建CSV读对象 例如:CsvReader(文件路径，分隔符，编码格式); CsvReader reader = new CsvReader(csvFilePath, ',', Charset.forName("UTF-8")); // 跳过表头 如果需要表头的话，这句可以忽略 @@ -184,6 +186,7 @@ reader.close(); Locus locus = new Locus(); String s1 = ""; if(csvFileList.size()!=0){ //遍历读取的CSV文件 for (int row = 0; row < csvFileList.size(); row++) { // 取得第row行第0列的数据 @@ -211,6 +214,9 @@ } } FtpUtil.sqlFileUpload(s1); deletescsv(substring); } deletescsv(substring); } catch (IOException e) { e.printStackTrace(); } @@ -230,68 +236,77 @@ } @PostMapping("/ss") public void Peog() throws Exception { String url = "http://47.104.104.46/api/client/getgistrack.php"; Calendar calendar = Calendar.getInstance(); calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 1); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:00:00"); //查询有押运人员的数据 List<Map<String, Object>> list = userService.selectEquipent(); for (int i = 0; i < list.size(); i++) { //实时位置实体类 Locus locus = new Locus(); locus.setType(1); String id = list.get(i).get("id").toString(); locus.setWorkerId(id); Map<String, Object> params = new HashMap<>(); String equipmentCode = list.get(i).get("code").toString(); //设备imei号 params.put("number", 7730); params.put("acc", equipmentCode); params.put("startTime", "2021-06-01"); params.put("endTime", "2021-08-01"); String res = null; res = HttpReqUtil.getInstance().doPost(url, params, null); String a = "[" + res + "]"; JSONArray jsonArray = JSONArray.fromObject(a); String track = jsonArray.getJSONObject(0).get("track").toString(); JSONArray jsonArray1 = JSONArray.fromObject(track); String s1 = ""; String sql="insert into sys_locus(id,type,worker_id,longitude,latitude,record_time) values "; for (int j = 0; j < jsonArray1.size(); j++) { String gis_jd = jsonArray1.getJSONObject(j).get("gis_jd").toString(); String gis_wd = jsonArray1.getJSONObject(j).get("gis_wd").toString(); String date = jsonArray1.getJSONObject(j).get("date").toString(); SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); try { //使用SimpleDateFormat的parse()方法生成Date Date dates = sf.parse(date); locus.setRecordTime(dates); //打印Date } catch (ParseException e) { e.printStackTrace(); } locus.setLongitude(gis_jd); locus.setLatitude(gis_wd); locusService.save(locus); //数据推送 s1 += "(" + "'" + locus.getId() + "'" + "," + "'" + locus.getType() + "'" + "," + "'" + locus.getWorkerId() + "'" + "," + "'" + locus.getLongitude() + "'" + "," + "'" + locus.getLatitude() + "'" + "," + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(locus.getRecordTime()) + "'" + ")"; if (j != jsonArray1.size() - 1) { s1 += ","; } else { s1+=";"; // @PostMapping("/ss") // public void Peog() throws Exception { // String url = "http://47.104.104.46/api/client/getgistrack.php"; // Calendar calendar = Calendar.getInstance(); // calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 1); // SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:00:00"); // //查询有押运人员的数据 // List<Map<String, Object>> list = userService.selectEquipent(); // for (int i = 0; i < list.size(); i++) { // //实时位置实体类 // Locus locus = new Locus(); // locus.setType(1); // String id = list.get(i).get("id").toString(); // locus.setWorkerId(id); // Map<String, Object> params = new HashMap<>(); // String equipmentCode = list.get(i).get("code").toString(); // //设备imei号 // params.put("number", 7730); // params.put("acc", equipmentCode); // params.put("startTime", "2021-12-01"); // params.put("endTime", "2021-12-02"); // String res = null; // res = HttpReqUtil.getInstance().doPost(url, params, null); // String a = "[" + res + "]"; // JSONArray jsonArray = JSONArray.fromObject(a); // String track = jsonArray.getJSONObject(0).get("track").toString(); // JSONArray jsonArray1 = JSONArray.fromObject(track); // String s1 = ""; // for (int j = 0; j < jsonArray1.size(); j++) { // String gis_jd = jsonArray1.getJSONObject(j).get("gis_jd").toString(); // String gis_wd = jsonArray1.getJSONObject(j).get("gis_wd").toString(); // String date = jsonArray1.getJSONObject(j).get("date").toString(); // SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // try { // //使用SimpleDateFormat的parse()方法生成Date // Date dates = sf.parse(date); // locus.setRecordTime(dates); // //打印Date // } catch (ParseException e) { // e.printStackTrace(); // } // locus.setLongitude(gis_jd); // locus.setLatitude(gis_wd); // locusService.save(locus); // //数据推送 // s1 += "insert into sys_locus(id,type,worker_id,longitude,latitude,record_time) values" + // " (" + "'" + locus.getId() + "'" + "," + // "'" + locus.getType() + "'" + "," + // "'" + locus.getWorkerId() + "'" + "," + // "'" + locus.getLongitude() + "'" + "," + // "'" + locus.getLatitude() + "'" + "," + // "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(locus.getRecordTime()) + "'" + ")"; // if (j != jsonArray1.size() - 1) { // s1 += ";"; // } // } // FtpUtil.sqlFileUpload(s1); // } // } /** * 删除本地csv文件 * @param fileName */ public static void deletescsv(String fileName){ File file = new File("D:\\caiji\\"+fileName+".csv"); if (file.isFile() && file.exists()) { file.delete(); } } String c = "a" +sql+ s1; FtpUtil.sqlFileUpload(c); } } }
