Commit b16addf9 by fudahua

同步优化初步3

parent 68543c35
......@@ -131,6 +131,7 @@ public class StoreSyncOperation implements BaseSyncOperation {
return;
}
List<ClerkListDTO> clerks = clerkService.getClerkByStoreId(enterpriseId, dataId);
logger.info("导入clerk:{}", JSONObject.toJSONString(clerks));
//预处理门店 写入预处理表
if (CollectionUtils.isNotEmpty(clerks)) {
List<TabHaobanPreDealLog> preDealLogList = clerks.stream().map(clerkMid -> {
......@@ -157,7 +158,7 @@ public class StoreSyncOperation implements BaseSyncOperation {
if (!b) {
return;
}
logger.info("部门继续成功,开始门店同步:{}", taskId);
logger.info("门店继续成功,成员同步:{}", taskId);
String key = "haoban_sync_store_task_" + taskId;
RedisUtil.lock(key, 3L);
TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment