iot内网数据上传同步

svr/svr-iot/src/main/java/com/yihu/iot/datainput/service/DataInputService.java

@@ -341,9 +341,9 @@ public class DataInputService {
            result.put("msg","upload signBodyData to elasticsearch failed," + e.getMessage());
        }
        if(success){
            if ("iotprodIn".equals(profiles)){
                String idcard = dataBodySignsDO.getIdCard();
                uploadDataToWlyy(idcard);
            String idcard = dataBodySignsDO.getIdCard();
            if (StringUtils.isNotBlank(idcard)){
                uploadDataToWlyy(json);
            }
            dataProcessLogService.saveLog(fileName, fileAbsPath, dataSource, "", DateUtils.formatDate(new Date(), DateUtil.yyyy_MM_dd_HH_mm_ss), "1", "4", "com.yihu.iot.datainput.service.DataInputService.uploadData", DataOperationTypeEnum.upload1.getName(), 0);
            JSONArray rids = new JSONArray();
@@ -374,11 +374,16 @@ public class DataInputService {
    }
    @Async
    public void uploadDataToWlyy(String idcard){
        String url = "http://10.95.22.10:8011/wlyy/third/syncDisPatient/common/iotDataImportJob";
    public void uploadDataToWlyy(String json){
        String url ="https://www.xmtyw.cn/wlyytest/third/syncDisPatient/common/iotDataImportData";
        if ("iotprodIn".equals(profiles)){
            url = "http://10.95.22.10:8011/wlyy/third/syncDisPatient/common/iotDataImportData";
        }
        List<NameValuePair> params = new ArrayList<>();
        params.add(new BasicNameValuePair("idcard",idcard));
        httpClientUtil.post(url,params,"UTF-8");
        params.add(new BasicNameValuePair("json",json));
        if ("iotprodIn".equals(profiles)){//内网才推数据
            httpClientUtil.post(url,params,"UTF-8");
        }
    }