|
|
@@ -608,7 +608,7 @@ namespace TelpoPush.Ability.Worker.Handlers |
|
|
|
hisGpsPsych.FileDatData = sb.ToString(); |
|
|
|
hisGpsPsych.FileDatDataTime = DateTime.Parse(model.time); |
|
|
|
if (stepTotal <= 0) |
|
|
|
hisGpsPsych.ApiResult = $"解析后步数为{stepTotal},不处理"; |
|
|
|
hisGpsPsych.ApiResult = $"解析后步数为{stepTotal},上传OSS,不推送第三方,"; |
|
|
|
await _messagePsychClient.UpdateAsync(hisGpsPsych); |
|
|
|
_logger.LogError($"[心理数据解析结果保存<{obj.remark}>] 成功"); |
|
|
|
} |
|
|
@@ -621,8 +621,8 @@ namespace TelpoPush.Ability.Worker.Handlers |
|
|
|
if (start_timestamp > 0) |
|
|
|
{ |
|
|
|
await _psychHealthData.Save(imei, obj.msgId, healthData,"");//健康数据保存 |
|
|
|
if (stepTotal > 0) //没有步数信息不推送 |
|
|
|
{ |
|
|
|
//if (stepTotal > 0) //没有步数信息不推送 |
|
|
|
//{ |
|
|
|
string psycReqquestUrl = $"{_abilityConfig.CoreServiceApiUrl}/OpenPsych/terminal/fileuploaresult"; |
|
|
|
var psycResponseStr = await _httpHelper.PostAsync(psycReqquestUrl, psycJsonStr); |
|
|
|
JObject psycJsons = JObject.FromObject(psycJson); |
|
|
@@ -633,9 +633,9 @@ namespace TelpoPush.Ability.Worker.Handlers |
|
|
|
psycResponseStr = await _httpHelper.PostAsync(psycReqquestUrl, psycJsonStr);//重新推送 |
|
|
|
_logger.LogInformation($"[心理数据文件(推送异常)第2次<{obj.remark}>]URL:{psycReqquestUrl}: 请求参数:{JsonConvert.SerializeObject(psycJsons)},返回结果:{psycResponseStr}"); |
|
|
|
} |
|
|
|
} |
|
|
|
else |
|
|
|
_logger.LogInformation($"[心理数据文件(解析<{obj.remark}>]:{fileUrl}解析异常,步数为:{stepTotal}"); |
|
|
|
//} |
|
|
|
//else |
|
|
|
// _logger.LogInformation($"[心理数据文件(解析<{obj.remark}>]:{fileUrl}解析异常,步数为:{stepTotal}"); |
|
|
|
} |
|
|
|
else |
|
|
|
_logger.LogInformation($"[心理数据文件(解析)<{obj.remark}>]:{fileUrl} 解析异常,采集时间戳:{start_timestamp}"); |
|
|
|