|
|
@ -0,0 +1,430 @@
|
|
|
package com.yihu.jw.care.controller;
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
import com.yihu.jw.care.service.AqgService;
|
|
|
import io.swagger.annotations.Api;
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
import io.swagger.annotations.ApiParam;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
import org.springframework.web.bind.annotation.RequestMethod;
|
|
|
import org.springframework.web.bind.annotation.RequestParam;
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
* Created by yeshijie on 2021/10/14.
|
|
|
*/
|
|
|
@RestController
|
|
|
@RequestMapping(value = "/device",produces = "application/json")
|
|
|
@Api(value = "请求转发相关服务", description = "请求转发相关服务")
|
|
|
public class TransforController {
|
|
|
|
|
|
private static Logger logger = LoggerFactory.getLogger(TransforController.class);
|
|
|
@Autowired
|
|
|
private AqgService aqgService;
|
|
|
|
|
|
@ApiOperation("爱牵挂设备sos数据接收")
|
|
|
@RequestMapping(value = "aqgsos", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String aqgsos(
|
|
|
@ApiParam(name="imei",required = false,value="15位设备唯一序号",defaultValue = "")
|
|
|
@RequestParam(value = "imei",required = false) String imei,
|
|
|
@ApiParam(name="label_mac",required = false,value="只有主机下有绑定标贴才会发送这个参数，按哪个标贴就报哪个标贴Mac，按主机报警则不会发送",defaultValue = "")
|
|
|
@RequestParam(value = "label_mac",required = false) String label_mac,
|
|
|
@ApiParam(name="time_begin",required = false,value="发生时间YYYY-MM-DD HH:mm:SS",defaultValue = "1")
|
|
|
@RequestParam(value = "time_begin",required = false) String time_begin,
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/aqgsos?imei="+imei+"&label_mac="+label_mac+"&time_begin="+time_begin;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂设备sos数据接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂设备开关机数据接收")
|
|
|
@RequestMapping(value = "aqgSwitch", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String aqgSwitch(
|
|
|
@ApiParam(name="imei",required = false,value="15位设备唯一序号",defaultValue = "")
|
|
|
@RequestParam(value = "imei",required = false) String imei,
|
|
|
@ApiParam(name="time_begin",required = false,value="发生时间YYYY-MM-DD HH:mm:SS",defaultValue = "1")
|
|
|
@RequestParam(value = "time_begin",required = false) String time_begin,
|
|
|
@ApiParam(name="remaining_power",required = false,value="剩余电量(%） ",defaultValue = "")
|
|
|
@RequestParam(value = "remaining_power",required = false) String remaining_power,
|
|
|
@ApiParam(name="type",required = false,value=" 开/关机类型 0开机 2普通 3低电 ",defaultValue = "")
|
|
|
@RequestParam(value = "type",required = false) String type,
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/aqgSwitch?imei="+imei+"&remaining_power="+remaining_power+"&time_begin="+time_begin+"&type="+type;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂设备开关机数据接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂设备消息通知数据接收")
|
|
|
@RequestMapping(value = "pushdata", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String pushdata(
|
|
|
@ApiParam(name="type",required = false,value="根据type来定义给用户推送提示 type=1 SOS，type=5 设备低电， 其他类型非本机型所有",defaultValue = "")
|
|
|
@RequestParam(value = "type",required = false) int type,
|
|
|
@ApiParam(name="deviceid",required = false,value="15位设备唯一序号",defaultValue = "")
|
|
|
@RequestParam(value = "deviceid",required = false) String deviceid,
|
|
|
@ApiParam(name="communityid",required = false,value="机构ID",defaultValue = "1")
|
|
|
@RequestParam(value = "communityid",required = false) String communityid,
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/pushdata?deviceid="+deviceid+"&communityid="+communityid+"&type="+type;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂设备消息通知数据接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂位置接收")
|
|
|
@RequestMapping(value = "byLocation", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String byLocation(
|
|
|
@ApiParam(name="imei",required = false,value="15位设备唯一序号",defaultValue = "")
|
|
|
@RequestParam(value = "imei",required = true) String imei,
|
|
|
@ApiParam(name="time_begin",required = false,value="发生时间YYYY-MM-DD HH:mm:SS",defaultValue = "1")
|
|
|
@RequestParam(value = "time_begin",required = false) String time_begin,
|
|
|
@ApiParam(name="is_reply",required = false,value="是否为响应")
|
|
|
@RequestParam(value = "is_reply",required = false) boolean is_reply,
|
|
|
@ApiParam(name="is_track",required = false,value="是否轨迹")
|
|
|
@RequestParam(value = "is_track",required = false) boolean is_track,
|
|
|
@ApiParam(name="city",required = false,value="城市")
|
|
|
@RequestParam(value = "city",required = false) String city,
|
|
|
@ApiParam(name="address",required = false,value="地址")
|
|
|
@RequestParam(value = "address",required = false) String address,
|
|
|
@ApiParam(name="lon",required = false,value="经度")
|
|
|
@RequestParam(value = "lon",required = false) double lon,
|
|
|
@ApiParam(name="lat",required = false,value="纬度")
|
|
|
@RequestParam(value = "lat",required = false) double lat,
|
|
|
@ApiParam(name="type",required = false,value="类型 0:Gps定位; 1:基站定位")
|
|
|
@RequestParam(value = "type",required = false) String type,
|
|
|
HttpServletRequest request){
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/byLocation?imei="+imei+"&is_reply="+is_reply+"&is_track="+is_track+"&city="+city
|
|
|
+"&address="+address+"&lon="+lon+"&lat="+lat+"&time_begin="+time_begin+"&type="+type;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂位置接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
@ApiOperation("爱牵挂心率数据接收")
|
|
|
@RequestMapping(value = "byHeartRate", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String byHeartRate(
|
|
|
@ApiParam(name = "imei", value = "15位设备唯一序号")
|
|
|
@RequestParam(value = "imei",required = true)String imei,
|
|
|
@ApiParam(name = "time_begin", value = "发生时间YYYY-MM-DD HH:mm:SS")
|
|
|
@RequestParam(value = "time_begin",required = false)String time_begin,
|
|
|
@ApiParam(name = "heartrate", value = "心率")
|
|
|
@RequestParam(value = "heartrate",required = false)int heartrate,
|
|
|
@ApiParam(name = "theshold_heartrate_h", value = "心率阈值上限")
|
|
|
@RequestParam(value = "theshold_heartrate_h",required = false)int theshold_heartrate_h,
|
|
|
@ApiParam(name = "theshold_heartrate_l", value = "心率阈值下限")
|
|
|
@RequestParam(value = "theshold_heartrate_l",required = false)int theshold_heartrate_l,
|
|
|
HttpServletRequest request){
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/byHeartRate?imei="+imei+"&heartrate="+heartrate+"&time_begin="+time_begin+"&theshold_heartrate_h="+theshold_heartrate_h+"&theshold_heartrate_l="+theshold_heartrate_l;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂心率数据接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂血压数据接收")
|
|
|
@RequestMapping(value = "byBloodPressure", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String byBloodPressure(
|
|
|
@ApiParam(name = "imei", value = "15位设备唯一序号", required = true)
|
|
|
@RequestParam(value = "imei",required = true)String imei,
|
|
|
@ApiParam(name = "time_begin", value = "发生时间YYYY-MM-DD HH:mm:SS", required = true)
|
|
|
@RequestParam(value = "time_begin",required = false)String time_begin,
|
|
|
@ApiParam(name = "dbp", value = "舒张压", required = true)
|
|
|
@RequestParam(value = "dbp",required = false)int dbp,
|
|
|
@ApiParam(name = "dbp_l", value = "舒张压报警下限", required = true)
|
|
|
@RequestParam(value = "dbp_l",required = false)int dbp_l,
|
|
|
@ApiParam(name = "sbp", value = "收缩压", required = true)
|
|
|
@RequestParam(value = "sbp",required = false)int sbp,
|
|
|
@ApiParam(name = "sbp_h", value = "收缩压报警上限", required = true)
|
|
|
@RequestParam(value = "sbp_h",required = false)int sbp_h,
|
|
|
HttpServletRequest request){
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/byBloodPressure?imei="+imei+"&dbp="+dbp+"&time_begin="+time_begin+"&dbp_l="+dbp_l+"&sbp="+sbp+"&sbp_h="+sbp_h;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂血压数据接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂跌倒数据接收")
|
|
|
@RequestMapping(value = "byFall", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String byFall(
|
|
|
@ApiParam(name = "imei", value = "15位设备唯一序号", required = true)
|
|
|
@RequestParam(value = "imei",required = true)String imei,
|
|
|
@ApiParam(name = "time_begin", value = "发生时间YYYY-MM-DD HH:mm:SS", required = true)
|
|
|
@RequestParam(value = "time_begin",required = false)String time_begin,
|
|
|
@ApiParam(name = "city", value = "城市", required = false)
|
|
|
@RequestParam(value = "city",required = false)String city,
|
|
|
@ApiParam(name = "address", value = "地址", required = false)
|
|
|
@RequestParam(value = "address",required = false)String address,
|
|
|
@ApiParam(name = "lon", value = "经度", required = false)
|
|
|
@RequestParam(value = "lon",required = false)double lon,
|
|
|
@ApiParam(name = "lat", value = "纬度", required = false)
|
|
|
@RequestParam(value = "lat",required = false)double lat,
|
|
|
@ApiParam(name = "type", value = "纬度", required = false)
|
|
|
@RequestParam(value = "type",required = false)String type,
|
|
|
HttpServletRequest request){
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/byFall?imei="+imei+"&city="+city+"&address="+address+"&lon="+lon+"&lat="+lat+"&time_begin="+time_begin+"&type="+type;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂跌倒数据接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("设备步数接收")
|
|
|
@RequestMapping(value = "bySteps", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String bySteps(
|
|
|
@ApiParam(name="imei",required = false,value="15位设备唯一序号",defaultValue = "")
|
|
|
@RequestParam(value = "imei",required = true) String imei,
|
|
|
@ApiParam(name="time_begin",required = false,value="发生时间YYYY-MM-DD HH:mm:SS")
|
|
|
@RequestParam(value = "time_begin",required = false) String time_begin,
|
|
|
@ApiParam(name="value",required = false,value="步数")
|
|
|
@RequestParam(value = "value",required = false) int value,
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/bySteps?imei="+imei+"&value="+value+"&time_begin="+time_begin;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("设备步数接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/*******************************************睡眠带begin****************************************************************/
|
|
|
@ApiOperation("爱牵挂-睡眠带睡眠接收")
|
|
|
@RequestMapping(value = "bySleep", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String bySleep(
|
|
|
@ApiParam(name="device",required = false,value="睡眠带MAC地址",defaultValue = "")
|
|
|
@RequestParam(value = "device",required = true) String device,
|
|
|
@ApiParam(name="time_begin",required = false,value="发生时间YYYY-MM-DD HH:mm:SS")
|
|
|
@RequestParam(value = "time_begin",required = false) String time_begin,
|
|
|
@ApiParam(name="heartrate",required = false,value="心率数据(离床或翻身测量失败时为0)")
|
|
|
@RequestParam(value = "heartrate",required = false) String heartrate,
|
|
|
@ApiParam(name="breath",required = false,value="呼吸率(离床或翻身测量失败时为0)")
|
|
|
@RequestParam(value = "breath",required = false) String breath,
|
|
|
@ApiParam(name="bed_status",required = false,value="在离床状态(0 离床，1 在床) ")
|
|
|
@RequestParam(value = "bed_status",required = false) String bed_status,
|
|
|
@ApiParam(name="turn_over",required = false,value="翻身状态(0 没翻身，1 在翻身)")
|
|
|
@RequestParam(value = "turn_over",required = false)String turn_over,
|
|
|
@ApiParam(name="is_warn",required = false,value="是否为离床报警(0 否 默认，1 是)")
|
|
|
@RequestParam(value = "is_warn",required = false)String is_warn,
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/bySleep?device="+device+"&heartrate="+heartrate+"&time_begin="+time_begin
|
|
|
+"&breath="+breath+"&bed_status="+bed_status+"&turn_over="+turn_over+"&is_warn="+is_warn;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂-睡眠带睡眠接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂-睡眠带睡眠报告接收")
|
|
|
@RequestMapping(value = "bySleepReport", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String bySleep(
|
|
|
@ApiParam(name="device",required = false,value="睡眠带MAC地址",defaultValue = "")
|
|
|
@RequestParam(value = "device",required = true) String device,
|
|
|
@ApiParam(name="date",required = false,value="产生日期 YYYYMMDD")
|
|
|
@RequestParam(value = "date",required = false) String date,
|
|
|
@ApiParam(name="fallasleep",required = false,value="入睡时长 （分钟）")
|
|
|
@RequestParam(value = "fallasleep",required = false) String fallasleep,
|
|
|
@ApiParam(name="sleepTime",required = false,value="睡眠时长 （分钟）")
|
|
|
@RequestParam(value = "sleepTime",required = false) String sleepTime,
|
|
|
@ApiParam(name="restTime",required = false,value="休息时长 （分钟）")
|
|
|
@RequestParam(value = "restTime",required = false) String restTime,
|
|
|
@ApiParam(name="bed_status",required = false,value="在离床状态(0 离床，1 在床) ")
|
|
|
@RequestParam(value = "bed_status",required = false) String bed_status,
|
|
|
@ApiParam(name="awakeTime",required = false,value="清醒时长 （分钟）")
|
|
|
@RequestParam(value = "awakeTime",required = false)String awakeTime,
|
|
|
@ApiParam(name="lightTime",required = false,value="浅睡时长 （分钟）")
|
|
|
@RequestParam(value = "lightTime",required = false)String lightTime,
|
|
|
@ApiParam(name="remTime",required = false,value="rem时长 （分钟）")
|
|
|
@RequestParam(value = "remTime",required = false)String remTime,
|
|
|
@ApiParam(name="deepTime",required = false,value="深睡时长 （分钟） ")
|
|
|
@RequestParam(value = "deepTime",required = false)String deepTime,
|
|
|
@ApiParam(name="bucket",required = false,value="睡眠时段 ['18:00-18:21', '21:30-07:09'] ")
|
|
|
@RequestParam(value = "bucket",required = false)String[] bucket,
|
|
|
@ApiParam(name="avghr",required = false,value="平均心率 ")
|
|
|
@RequestParam(value = "avghr",required = false)String avghr,
|
|
|
@ApiParam(name="avgbr",required = false,value="平均呼吸率 ")
|
|
|
@RequestParam(value = "avgbr",required = false)String avgbr,
|
|
|
@ApiParam(name="awakePer",required = false,value="清醒百分比")
|
|
|
@RequestParam(value = "awakePer",required = false)String awakePer,
|
|
|
@ApiParam(name="remPer",required = false,value="rem百分比")
|
|
|
@RequestParam(value = "remPer",required = false)String remPer,
|
|
|
@ApiParam(name="lightPer",required = false,value="浅睡百分比")
|
|
|
@RequestParam(value = "lightPer",required = false)String lightPer,
|
|
|
@ApiParam(name="deepPer",required = false,value="深睡百分比")
|
|
|
@RequestParam(value = "deepPer",required = false)String deepPer,
|
|
|
@ApiParam(name="efficiency",required = false,value="睡眠效率")
|
|
|
@RequestParam(value = "efficiency",required = false)String efficiency,
|
|
|
@ApiParam(name="score",required = false,value="睡眠评分 <=0无睡眠数据,<60待改善,<70一般,<85良好 其他，非常好")
|
|
|
@RequestParam(value = "score",required = false)String score,
|
|
|
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/bySleep?device="+device+"&date="+date+"&fallasleep="+fallasleep+"&sleepTime="+sleepTime
|
|
|
+"&restTime="+restTime+"&bed_status="+bed_status+"&awakeTime="+awakeTime+"&lightTime="+lightTime
|
|
|
+"&remTime="+remTime+"&deepTime="+deepTime+"&bucket="+bucket+"&avghr="+avghr
|
|
|
+"&avgbr="+avgbr+"&awakePer="+awakePer+"&remPer="+remPer+"&lightPer="+lightPer
|
|
|
+"&deepPer="+deepPer+"&efficiency="+efficiency+"&score="+score;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂-睡眠带睡眠报告接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@ApiOperation("爱牵挂-睡眠带wifi在线状态接收")
|
|
|
@RequestMapping(value = "byOnlineStatus", method = {RequestMethod.POST,RequestMethod.GET})
|
|
|
public String byOnlineStatus(
|
|
|
@ApiParam(name="device",required = false,value="睡眠带MAC地址",defaultValue = "")
|
|
|
@RequestParam(value = "device",required = true) String device,
|
|
|
@ApiParam(name="onlinestatu",required = false,value="在线状态（0不在线，1在线）")
|
|
|
@RequestParam(value = "onlinestatu",required = false) String onlinestatu,
|
|
|
@ApiParam(name="time_begin",required = false,value="发生时间YYYY-MM-DD HH:mm:SS")
|
|
|
@RequestParam(value = "time_begin",required = false) String time_begin,
|
|
|
HttpServletRequest request) {
|
|
|
try {
|
|
|
long startTime=System.currentTimeMillis();
|
|
|
String paraString = JSON.toJSONString(request.getParameterMap());
|
|
|
String url = "device/byOnlineStatus?device="+device+"&onlinestatu="+onlinestatu+"&time_begin="+time_begin;
|
|
|
String result = aqgService.aqgForward(url);
|
|
|
long endTime=System.currentTimeMillis();
|
|
|
logger.info("爱牵挂-睡眠带wifi在线状态接收,请求参数:"+paraString+" "+(endTime-startTime)+"ms; 响应："+result);
|
|
|
return success();
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return error(-1,"Device data incoming failure");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/*******************************************睡眠带end****************************************************************/
|
|
|
/**
|
|
|
* 返回接口处理结果
|
|
|
*
|
|
|
* @param code 结果码，成功为200
|
|
|
* @param msg 结果提示信息
|
|
|
* @return
|
|
|
*/
|
|
|
public String error(int code, String msg) {
|
|
|
try {
|
|
|
Map<Object, Object> map = new HashMap<Object, Object>();
|
|
|
ObjectMapper mapper = new ObjectMapper();
|
|
|
map.put("status", code);
|
|
|
map.put("msg", msg);
|
|
|
map.put("success", false);
|
|
|
return mapper.writeValueAsString(map);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 接口处理成功
|
|
|
* @return
|
|
|
*/
|
|
|
public String success() {
|
|
|
try {
|
|
|
Map<Object, Object> map = new HashMap<Object, Object>();
|
|
|
ObjectMapper mapper = new ObjectMapper();
|
|
|
map.put("status", 200);
|
|
|
map.put("success", true);
|
|
|
return mapper.writeValueAsString(map);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public String write(int code, String msg) {
|
|
|
try {
|
|
|
Map<Object, Object> map = new HashMap<Object, Object>();
|
|
|
ObjectMapper mapper = new ObjectMapper();
|
|
|
map.put("status", code);
|
|
|
map.put("msg", msg);
|
|
|
map.put("success", true);
|
|
|
return mapper.writeValueAsString(map);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
}
|
