|
@@ -447,7 +447,9 @@ public class WebsocketService extends Service {
|
|
|
AppLogUtils.e(true, TAG + " ,receiveUserFaceData", "WebSocket, receiveUserFaceData(), 数据错误, op 为空");
|
|
|
return;
|
|
|
}
|
|
|
-
|
|
|
+ if(userFaceData.getData()!=null){
|
|
|
+ Log.i("____789"," 新增 "+userFaceData.getData().getTraceId());
|
|
|
+ }
|
|
|
|
|
|
if (op.equals(BaiduFaceConstant.OP_ISSUE_ALL)) { //全量下发
|
|
|
|
|
@@ -711,12 +713,12 @@ public class WebsocketService extends Service {
|
|
|
callbackItem.setMsg(msg);
|
|
|
callbackItems.add(callbackItem);
|
|
|
if (callbackItems.size() > 30 && callbackItems.size() < totalSize) {
|
|
|
- sendMessage_issueCallback(data.getTraceId(), STATUS_processing, "下发中", totalSize,currentCount, callbackItems);
|
|
|
+ sendMessage_issueCallback(data.getTraceId(), STATUS_processing, "下发中", totalSize,currentCount,errorUserDataCount, callbackItems);
|
|
|
callbackItems=new ArrayList<>();
|
|
|
}
|
|
|
}
|
|
|
Log.i("____789"," "+traceId+" 下发完成或结束");
|
|
|
- sendMessage_issueCallback(data.getTraceId(), isTaskCancel?STATUS_cancel:STATUS_success, "下发任务成功完成", totalSize, currentCount,callbackItems);
|
|
|
+ sendMessage_issueCallback(data.getTraceId(), isTaskCancel?STATUS_cancel:STATUS_success, "下发任务成功完成", totalSize, currentCount,errorUserDataCount,callbackItems);
|
|
|
|
|
|
if(!TextUtils.isEmpty(traceId)&&getWebSocketTaskMap().containsKey(traceId)){ //todo 人脸执行队列任务更新状态
|
|
|
WebSocketTask tempTask=getWebSocketTaskMap().get(traceId);
|
|
@@ -884,7 +886,7 @@ public class WebsocketService extends Service {
|
|
|
* @param totalCount 后台总共下发的用户数量
|
|
|
* @param callbackItems 客户端已处理的用户数据
|
|
|
*/
|
|
|
- private void sendMessage_issueCallback(String traceId, String status, String msg, int totalCount, int currCount,
|
|
|
+ private void sendMessage_issueCallback(String traceId, String status, String msg, int totalCount, int currCount,int failCount,
|
|
|
ArrayList<UserFaceDataIssueCallback.Data.Item> callbackItems) {
|
|
|
if (TextUtils.isEmpty(traceId)) {
|
|
|
AppLogUtils.e(true, TAG + " ,sendMessage_issueCallback", "WebSocket, sendMessage_deleteAllCallback(), traceId为空");
|
|
@@ -923,7 +925,8 @@ public class WebsocketService extends Service {
|
|
|
} else { //处理最后一条数据
|
|
|
data.setItems(callbackItems);
|
|
|
}
|
|
|
-
|
|
|
+ data.setHadIssuedFaceFailedCount(failCount);
|
|
|
+ data.setHadIssuedFaceSuccessCount(currCount);
|
|
|
issueCallback.setData(data);
|
|
|
|
|
|
String issueCallbackJsonStr = GsonUtil.toJson(issueCallback);
|