This commit is contained in:
dzc committed 2025-03-19 16:33:54 +08:00
1 parent ecf4c32ca6
commit e150f96f3a
3 files changed
+33 -25

No files matched your search

+22 -21
View File
@@ -112,27 +112,28 @@ class AppMqTool {
}
break;
case MqtActionEnum.FACE:
final msg = MqttInvoiceMsg.fromJson(json.decode(orgStr));
final storagePath = await AppFileTool.getFacePath();
if (ObjectUtil.isEmpty(storagePath)) {
logger.e("|$_tag|mq同步人脸错误,创建人脸存储路径错误");
return;
}
final sysSetting = await AppSettingTool.getSysSetting();
var merchantDeptId = sysSetting.merchantDeptId;
if (ObjectUtil.isEmpty(storagePath)) {
logger.e("|$_tag|mq同步人脸错误,merchantId为空");
return;
}
await SyncFaceTool.syncGroupFace(
pageNo: 1,
userId: msg.userId,
merchantDeptId: merchantDeptId!,
storagePath: storagePath!,
isGlobalFace: msg.isGlobalFace,
);
mqUpdateEventBus.fire(MqtActionEnum.FACE);
break;
return;
// final msg = MqttInvoiceMsg.fromJson(json.decode(orgStr));
// final storagePath = await AppFileTool.getFacePath();
// if (ObjectUtil.isEmpty(storagePath)) {
// logger.e("|$_tag|mq同步人脸错误,创建人脸存储路径错误");
// return;
// }
// final sysSetting = await AppSettingTool.getSysSetting();
// var merchantDeptId = sysSetting.merchantDeptId;
// if (ObjectUtil.isEmpty(storagePath)) {
// logger.e("|$_tag|mq同步人脸错误,merchantId为空");
// return;
// }
// await SyncFaceTool.syncGroupFace(
// pageNo: 1,
// userId: msg.userId,
// merchantDeptId: merchantDeptId!,
// storagePath: storagePath!,
// isGlobalFace: msg.isGlobalFace,
// );
// mqUpdateEventBus.fire(MqtActionEnum.FACE);
// break;
default:
break;
}