三诺体征设备数据上传服务开发

svr/svr-iot-sunnuo/src/main/java/com/yihu/iot/datainput/controller/IotAnalyzerController.java

@@ -58,6 +58,7 @@ public class IotAnalyzerController extends EnvelopRestEndpoint {
        String str = "";
        String strResult = "";
        String accessToken  = "sannuo";
        Map res = new HashMap();
        try {
            Map info = new HashMap();
@@ -74,11 +75,20 @@ public class IotAnalyzerController extends EnvelopRestEndpoint {
            }
            JSONObject data = new JSONObject();
            // 增加判断，当测量值小于1时，定义为异常值，不进行数据的存储。
            if(Integer.parseInt(info.get("result").toString()) < 1){
                res.put("statusCode", "00");
                res.put("desc", info.get("devicesn") + "体征数据异常（小于正常值）。");
                return objectMapper.writeValueAsString(res);
            }else{
                data.put("data",info.get("result") == null? "":info.get("result").toString());
            }
            data.put("code",info.get("code") == null? "":info.get("code").toString());
            data.put("deviceSn",info.get("devicesn") == null? "":info.get("devicesn").toString());
            data.put("userCode",info.get("usercode") == null? "":info.get("usercode").toString());
            data.put("openId",info.get("openid") == null? "":info.get("openid").toString());
            data.put("data",info.get("result") == null? "":info.get("result").toString());
            data.put("unit",info.get("unit") == null? "":info.get("unit").toString());
            data.put("sendTime",info.get("testtime") == null? "":info.get("testtime").toString());
            //血糖测试时间段标志位(0餐前 1餐后 2随机)
@@ -96,7 +106,7 @@ public class IotAnalyzerController extends EnvelopRestEndpoint {
            params.put("measure_time",info.get("testtime") == null? "":info.get("testtime").toString());
            params.put("sn",info.get("devicesn") == null? "":info.get("devicesn").toString());
            Map res = new HashMap();
            //体征信息上传成功后，同步到厦门I健康
            data.put("id","");
            boolean synFlag = dataInputService.synXMIjk(data);
@@ -143,7 +153,6 @@ public class IotAnalyzerController extends EnvelopRestEndpoint {
            return strResult;
        } catch (Exception e) {
            e.printStackTrace();
            Map res = new HashMap();
            res.put("statusCode", "03");
            res.put("desc", "服务异常，体征信息上传失败。");
            strResult = objectMapper.writeValueAsString(res);