package org.springblade.modules.equipage.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONException;
|
import net.sf.json.JSONObject;
|
import org.springblade.common.utils.HttpReqUtil;
|
import org.springblade.common.utils.Md5SignUtil;
|
import org.springblade.modules.FTP.FtpUtil;
|
import org.springblade.modules.equipage.service.CarService;
|
import org.springblade.modules.location.entity.LiveLocation;
|
import org.springblade.modules.location.entity.Locus;
|
import org.springblade.modules.location.service.LiveLocationService;
|
import org.springblade.modules.location.service.LocusService;
|
import org.springblade.modules.system.service.IUserService;
|
import org.springblade.modules.system.service.MyAsyncService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.io.IOException;
|
import java.text.DateFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@Component("fixed")
|
public class fixed {
|
private static final DateFormat JSON = null;
|
@Autowired
|
private LiveLocationService liveLocationService;
|
@Autowired
|
private IUserService userService;
|
@Autowired
|
private LocusService locusService;
|
@Autowired
|
private CarService carService;
|
@Autowired
|
private MyAsyncService myAsyncService;
|
|
/**
|
* 押运人员
|
*
|
* @return
|
* @throws Exception
|
*/
|
// @Scheduled(cron = "0 */5 * * * ?")
|
public void Peo() throws Exception {
|
String url = "http://47.104.104.46/api/client/getgis.php";
|
//查询有押运人员的数据
|
List<Map<String, Object>> list = userService.selectEquipent();
|
if (list.size() > 0) {
|
for (int i = 0; i < list.size(); i++) {
|
//实时位置实体类
|
LiveLocation liveLocation = new LiveLocation();
|
liveLocation.setType(1);
|
String id = list.get(i).get("id").toString();
|
liveLocation.setWorkerId(id);
|
Map<String, Object> params = new HashMap<>();
|
String equipmentCode = list.get(i).get("code").toString();
|
//设备imei号
|
params.put("acc", equipmentCode);
|
String res = null;
|
res = HttpReqUtil.getInstance().doPost(url, params, null);
|
JSONArray jsonArray = JSONArray.fromObject(res);
|
JSONArray sortedJsonArray = new JSONArray();
|
List<JSONObject> jsonValues = new ArrayList<JSONObject>();
|
for (int j = 0; j < jsonArray.size(); j++) {
|
jsonValues.add(jsonArray.getJSONObject(j));
|
}
|
Collections.sort(jsonValues, new Comparator<JSONObject>() {
|
private static final String KEY_NAME = "date";
|
String string1;
|
String string2;
|
|
@Override
|
public int compare(JSONObject a, JSONObject b) {
|
try {
|
string1 = a.getString(KEY_NAME).replaceAll("-", "");
|
string2 = b.getString(KEY_NAME).replaceAll("-", "");
|
} catch (JSONException e) {
|
// 处理异常
|
}
|
//这里是按照时间逆序排列,不加负号为正序排列
|
return -string1.compareTo(string2);
|
}
|
});
|
for (int c = 0; c < jsonArray.size(); c++) {
|
sortedJsonArray.add(jsonValues.get(c));
|
}
|
//经度
|
String gis_jd = sortedJsonArray.getJSONObject(0).getString("gis_jd");
|
//纬度
|
String gis_wd = sortedJsonArray.getJSONObject(0).getString("gis_wd");
|
String date = sortedJsonArray.getJSONObject(0).getString("date");
|
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
Date dates = formatter.parse(date);
|
//经度
|
liveLocation.setLongitude(gis_jd);
|
liveLocation.setLatitude(gis_wd);
|
//纬度
|
liveLocation.setRecordTime(dates);
|
//先查询是否已有实时位置信息，如果有，则更新，没有则插入
|
LiveLocation liveLocationInfo = liveLocationService.getLiveLocationInfo(liveLocation);
|
boolean status = false;
|
if (null == liveLocationInfo) {
|
//新增
|
status = liveLocationService.save(liveLocation);
|
//数据推送
|
String s1 =
|
"insert into sys_live_location(id,type,worker_id,longitude,latitude,record_time) " +
|
"values(" + "'" + liveLocation.getId() + "'" + "," +
|
"'" + liveLocation.getType() + "'" + "," +
|
"'" + liveLocation.getWorkerId() + "'" + "," +
|
"'" + liveLocation.getLongitude() + "'" + "," +
|
"'" + liveLocation.getLatitude() + "'" + "," +
|
"'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + ")";
|
//FtpUtil.sqlFileUpload(s1);
|
myAsyncService.FTP(s1);
|
} else {
|
status = liveLocationService.updateById(liveLocationInfo);
|
//内网同步
|
String s1 =
|
"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);
|
myAsyncService.FTP(s1);
|
}
|
}
|
}
|
}
|
|
/**
|
* 押运人员轨迹
|
*
|
* @return
|
* @throws Exception
|
*/
|
// @Scheduled(cron = "0 0 * * * ?")
|
public void Peog() throws Exception {
|
System.out.println("押运人员");
|
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", 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();
|
if (track.equals("[]")) {
|
System.out.println("数据为空");
|
} else {
|
JSONArray jsonArray1 = JSONArray.fromObject(track);
|
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);
|
myAsyncService.FTP(s1);
|
}
|
}
|
}
|
|
|
/**
|
* 车辆实时位置
|
*/
|
// @Scheduled(cron = "0 */5 * * * ?")
|
public void locationcar() {
|
String url = "http://dvopenapi.aimap.net.cn/openapi/device/location";
|
String res = null;
|
List<Map<Object, Object>> maps = carService.selectCar();
|
for (int i = 0; i < maps.size(); i++) {
|
Map<String, Object> params = new HashMap<>();
|
params.put("imei", maps.get(i).get("code").toString());
|
params.put("appId", "PO00000761");
|
params.put("timestamp", System.currentTimeMillis());
|
String secert = "dXRGb2pRNVdWOGQ3d1ouV29UYzc1MnJaUnBwTzUx";
|
String computeSign = "";
|
try {
|
computeSign = Md5SignUtil.signRequest(params, secert);
|
} catch (IOException e1) {
|
e1.printStackTrace();
|
}
|
params.put("sign", computeSign);
|
try {
|
res = HttpReqUtil.getInstance().doPost(url, params, null);
|
String a = "[" + res + "]";
|
JSONArray jsonArray = JSONArray.fromObject(a);
|
String code = jsonArray.getJSONObject(0).get("code").toString();
|
if (Integer.parseInt(code) == 200) {
|
String data = jsonArray.getJSONObject(0).get("data").toString();
|
String b = "[" + data + "]";
|
JSONArray jsonArrayb = JSONArray.fromObject(b);
|
String x = jsonArrayb.getJSONObject(0).get("x").toString();
|
String y = jsonArrayb.getJSONObject(0).get("y").toString();
|
String timestamp = jsonArrayb.getJSONObject(0).get("timestamp").toString();
|
//实时位置实体类
|
LiveLocation liveLocation = new LiveLocation();
|
liveLocation.setType(2);
|
String carnumber = maps.get(i).get("carnumber").toString();
|
liveLocation.setWorkerId(carnumber);
|
//经度
|
liveLocation.setLongitude(x);
|
//纬度
|
liveLocation.setLatitude(y);
|
Date date = timeStamp2Date(timestamp);
|
liveLocation.setRecordTime(date);
|
//先查询是否已有实时位置信息，如果有，则更新，没有则插入
|
LiveLocation liveLocationInfo = liveLocationService.getLiveLocationInfo(liveLocation);
|
boolean status = false;
|
if (null == liveLocationInfo) {
|
//新增
|
status = liveLocationService.save(liveLocation);
|
if (status) {
|
//数据推送
|
String s1 =
|
"insert into sys_live_location(id,type,worker_id,longitude,latitude,record_time) " +
|
"values(" + "'" + liveLocation.getId() + "'" + "," +
|
"'" + liveLocation.getType() + "'" + "," +
|
"'" + liveLocation.getWorkerId() + "'" + "," +
|
"'" + liveLocation.getLongitude() + "'" + "," +
|
"'" + liveLocation.getLatitude() + "'" + "," +
|
"'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(liveLocation.getRecordTime()) + "'" + ")";
|
//FtpUtil.sqlFileUpload(s1);
|
myAsyncService.FTP(s1);
|
}
|
} else {
|
status = liveLocationService.updateById(liveLocationInfo);
|
//内网同步
|
if (status) {
|
String s1 =
|
"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);
|
myAsyncService.FTP(s1);
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
public static Date timeStamp2Date(String time) {
|
Long timeLong = Long.parseLong(time);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:00:00");//要转换的时间格式
|
Date date;
|
try {
|
date = sdf.parse(sdf.format(timeLong));
|
return date;
|
} catch (ParseException e) {
|
e.printStackTrace();
|
return null;
|
}
|
|
}
|
|
/**
|
* 查询车辆轨迹
|
*/
|
// @Scheduled(cron = "0 0 * * * ?")
|
public void locationhistoryTrack() {
|
Calendar calendar = Calendar.getInstance();
|
/* HOUR_OF_DAY 指示一天中的小时 */
|
calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 1);
|
SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHH");
|
String url = "http://dvopenapi.aimap.net.cn/openapi/device/historyTrack";
|
String res = null;
|
List<Map<Object, Object>> maps = carService.selectCar();
|
for (int i = 0; i < maps.size(); i++) {
|
Map<String, Object> params = new HashMap<>();
|
params.put("imei", maps.get(i).get("code").toString());
|
params.put("beginTime", df.format(calendar.getTime()));
|
params.put("endTime", df.format(new Date()));
|
params.put("rectify", 0);
|
params.put("callbackUrl", "http://61.131.136.25:2080/api/locus/SaveUrl");
|
params.put("callbackId", maps.get(i).get("carnumber").toString());
|
params.put("appId", "PO00000761");
|
params.put("timestamp", System.currentTimeMillis());
|
String secert = "dXRGb2pRNVdWOGQ3d1ouV29UYzc1MnJaUnBwTzUx";
|
String computeSign = "";
|
try {
|
computeSign = Md5SignUtil.signRequest(params, secert);
|
} catch (IOException e1) {
|
e1.printStackTrace();
|
}
|
params.put("sign", computeSign);
|
try {
|
res = HttpReqUtil.getInstance().doPost(url, params, null);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
}
|
|
}
|
