同步优化初步3-同步成员重试

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/StoreSyncOperation.java

@@ -15,6 +15,7 @@ import com.gic.haoban.manage.api.dto.DepartmentDTO;
 import com.gic.haoban.manage.api.enums.PreDealStatusEnum;
 import com.gic.haoban.manage.api.enums.PreDealTypeEnum;
 import com.gic.haoban.manage.api.enums.SyncTaskStatusEnum;
+import com.gic.haoban.manage.api.service.DealSyncOperationApiService;
 import com.gic.haoban.manage.api.service.DepartmentApiService;
 import com.gic.haoban.manage.service.entity.TabHaobanDepartment;
 import com.gic.haoban.manage.service.entity.TabHaobanPreDealLog;
@@ -64,6 +65,9 @@ public class StoreSyncOperation implements BaseSyncOperation {
     @Autowired
     private ClerkService clerkService;
 
+    @Autowired
+    private DealSyncOperationApiService dealSyncOperationApiService;
+
     @Override
     public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) {
         logger.info("处理单条门店：{}", JSONObject.toJSONString(dealParamMqDTO));
@@ -173,6 +177,7 @@ public class StoreSyncOperation implements BaseSyncOperation {
             List<TabHaobanPreDealLog> dealLogs = preDealService.listByTaskId(taskId, PreDealTypeEnum.clerk.getVal(), PreDealStatusEnum.pre.getVal());
             if (CollectionUtils.isEmpty(dealLogs)) {
                 syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal());
+                dealSyncOperationApiService.unlockTask(taskId);
             } else {
                 logger.info("处理成员开始");
                 Set<String> dataIds = dealLogs.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());