通讯录

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

@@ -213,7 +213,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         RedisUtil.lock(key, 10L);
         String taskLock = getTaskLock(wxEnterpriseId);
         if (StringUtils.isNotBlank(taskLock)) {
-            logger.info("【同步锁】taskLock={},key={}", taskLock,key);
+            logger.info("在处理中,返回");
             RedisUtil.unlock(key);
             return null;
         }
@@ -393,6 +393,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
     @Override
     public String getTaskLock(String wxEnterpriseId) {
         String key = LOCK_KEY + wxEnterpriseId;
+        logger.info("缓存key={}",key);
         return (String) RedisUtil.getCache(key);
     }
 
@@ -870,7 +871,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
     public void taskSyncStaffTimer(String params) {
         try {
             RSet<String> set = RedisUtil.getRedisClient().getSet(PreDealServiceImpl.HAOBAN_TASK_DEPART_SET_CACHE);
-            logger.info("通讯录同步定时开始staff={},{}",set.size(),set);
+            logger.info("通讯录同步定时开始size={},{}",set.size(),set);
             Iterator<String> it = set.iterator() ;
             while(it.hasNext()) {
                 String v = it.next() ;
@@ -891,8 +892,8 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
                 if(task.getStatusFlag() != 4) {
                     this.syncTaskService.updateTaskStatus(taskId,4) ;
                 }
-                if(task.getCreateTime().getTime()+1000*60*60*12< System.currentTimeMillis()) {
-                    logger.info("超过一天taskId={},{}",taskId);
+                if(task.getCreateTime().getTime()+1000*60*60*3< System.currentTimeMillis()) {
+                    logger.info("超过3小时taskId={},{}",taskId);
                     it.remove();
                     continue;
                 }