调试

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/DealSyncOperationApiServiceImpl.java

@@ -645,6 +645,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         Object cache = RedisUtil.getCache(staffLockKey);
         if (null != cache) {
             RedisUtil.unlock(lockKey);
+            logger.info("限制此操作,lockKey={}",staffLockKey);
             return null;
         }
         TabHaobanSyncTask tabHaobanSyncTask = new TabHaobanSyncTask();

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

@@ -101,9 +101,8 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
                 return;
             }
             //relationkey
-            logger.info("生成relationKey：{},{},{}",staffId,externalUserDTO.getName(),externalUserDTO.getAddCreateTime());
             relationKey = SecureUtil.md5(staffId + "_" + externalUserDTO.getName() + "_" + externalUserDTO.getAddCreateTime());
-            logger.info("relationKey：{}，{}", relationKey, externalUserDTO.getExternalUserId());
+            logger.info("第三方生成relationKey：{},{},{} 客户={}, 结果={}",staffId,externalUserDTO.getName(),externalUserDTO.getAddCreateTime() , externalUserDTO.getExternalUserId() , relationKey);
             // 根据关联键relationkey查看自建应用 是否有数据
             TabHaobanPreDealLog selfPre = preDealService.getByRelationKey(taskId, PreDealTypeEnum.self_friend.getVal(), relationKey);
             if (null == selfPre) {
@@ -133,6 +132,7 @@ public class FriendSyncNewOperation implements BaseSyncOperation {
             dealFlag = tryAgainToMq(dataPre);
             reason = "接口重试超出限制";
         } catch (Exception e) {
+            e.printStackTrace();
             logger.info("同步失败：{},{}", JSONObject.toJSONString(dataPre), e);
             reason = "第三方好友处理异常";
             dealFlag = false;