Commit 0d846999 by 李辅翼

v14

parent d6c4b79b
...@@ -65,8 +65,10 @@ public class PicController { ...@@ -65,8 +65,10 @@ public class PicController {
* 同步指定时间段车辆图片数据 * 同步指定时间段车辆图片数据
*/ */
@GetMapping("/getVehPicStage") @GetMapping("/getVehPicStage")
public void getVehPicStage(@RequestParam("start") String start, @RequestParam("end") String end) { @ResponseBody
public ResponseEntity getVehPicStage(@RequestParam("start") String start, @RequestParam("end") String end) {
vehicle.getVehPicStage(start, end); vehicle.getVehPicStage(start, end);
return new ResponseEntity("complete", HttpStatus.OK);
} }
......
...@@ -263,7 +263,7 @@ public class VehicleImpl implements Vehicle { ...@@ -263,7 +263,7 @@ public class VehicleImpl implements Vehicle {
put.addColumn("info".getBytes(), "hpzl".getBytes(), (hpzl == null ? "null" : hpzl).getBytes()); put.addColumn("info".getBytes(), "hpzl".getBytes(), (hpzl == null ? "null" : hpzl).getBytes());
put.addColumn("info".getBytes(), "gxsj".getBytes(), (gxsj == null ? "null" : gxsj).getBytes()); put.addColumn("info".getBytes(), "gxsj".getBytes(), (gxsj == null ? "null" : gxsj).getBytes());
byte[] bytes = sqlHelp.blobToBytes(zp); byte[] bytes = sqlHelp.blobToBytes(zp);
logger.info(xh+"---------------------"+bytes.length); // logger.info(xh+"---------------------"+bytes.length);
put.addColumn("info".getBytes(),"picLen".getBytes(),String.valueOf(bytes.length/1024).getBytes()); put.addColumn("info".getBytes(),"picLen".getBytes(),String.valueOf(bytes.length/1024).getBytes());
//写入fastdfs //写入fastdfs
int count = 0; int count = 0;
...@@ -276,6 +276,12 @@ public class VehicleImpl implements Vehicle { ...@@ -276,6 +276,12 @@ public class VehicleImpl implements Vehicle {
return; return;
} }
} }
//验证
byte[] bytesDown = fileService.downloadFile("/" + picUrl);
if(bytesDown.length!=bytes.length) {
logger.info("length not right:-----------"+xh+"----------"+bytesDown.length);
picUrl=uploadFileStor(bytes,xh);
}
put.addColumn("info".getBytes(), "picUrl".getBytes(), ("/"+picUrl).getBytes()); put.addColumn("info".getBytes(), "picUrl".getBytes(), ("/"+picUrl).getBytes());
vehPicTable.put(put); vehPicTable.put(put);
vehPicTable.close(); vehPicTable.close();
......
package com.hikcreate.illegalPic;
/**
* @author lifuyi
* @date ${Date}
* @description
*/
public class synchronizationDay {
}
...@@ -36,7 +36,7 @@ public class PicSchedule { ...@@ -36,7 +36,7 @@ public class PicSchedule {
/** /**
* 每天早上9点同步机动车的增量数据 * 每天早上9点同步机动车的增量数据
*/ */
// @Scheduled(cron = "0 0 9 * * *") @Scheduled(cron = "0 0 9 * * *")
public void getIncrementVehPic(){ public void getIncrementVehPic(){
vehicle.getIncrementVehPic(); vehicle.getIncrementVehPic();
} }
......
...@@ -17,10 +17,10 @@ fdfs.thumb-image.width = 150 ...@@ -17,10 +17,10 @@ fdfs.thumb-image.width = 150
fdfs.thumb-image.height = 150 fdfs.thumb-image.height = 150
fdfs.tracker-list[0] = 172.16.25.23:22122 fdfs.tracker-list[0] = 172.16.25.23:22122
fdfs.tracker-list[1] = 172.16.25.26:22122 fdfs.tracker-list[1] = 172.16.25.26:22122
fdfs.pool.max-total = 153 fdfs.pool.max-total = 200
fdfs.pool.max-wait-millis = 102 fdfs.pool.max-wait-millis = 150
#˿ #˿
server.port=8099 server.port=8084
hbase.zookeeper.property.clientPort=2181 hbase.zookeeper.property.clientPort=2181
hbase.zookeeper.quorum=172.16.25.25,172.16.25.28,172.16.25.24,172.16.25.26,172.16.25.27 hbase.zookeeper.quorum=172.16.25.25,172.16.25.28,172.16.25.24,172.16.25.26,172.16.25.27
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment