Compiled from "CpImageStorePersonSynManager.java"
public class cn.cloudwalk.service.organization.service.CpImageStorePersonSynManager extends cn.cloudwalk.service.organization.common.AbstractImagStoreService {
  public static final java.lang.String TASK_IS_ALL;
  public static final java.lang.String TASK_JSON_ADD_KEY;
  public static final java.lang.String TASK_JSON_MOD_KEY;
  public static final java.lang.String TASK_JSON_DEL_KEY;
  private static final java.lang.String WAIT_SYN_TASK_KEY;
  private static final java.lang.String SYN_QUEUE_HEAD_DATA;
  private java.lang.String serverInstanceId;
  private java.lang.String lockHandleSynTaskSecond;
  private int taskIsAllThreshold;
  private org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor taskExecutor;
  private org.springframework.data.redis.core.StringRedisTemplate redisTemplate;
  private org.springframework.data.redis.core.script.DefaultRedisScript<java.lang.String> addWaitSynTaskRedisScript;
  private org.springframework.data.redis.core.script.DefaultRedisScript<java.lang.String> lockHandleSynTaskRedisScript;
  private org.springframework.data.redis.core.script.DefaultRedisScript<java.lang.String> lockHeadSynTaskRedisScript;
  private org.springframework.data.redis.core.script.DefaultRedisScript<java.lang.String> handleSuccessSynTaskRedisScript;
  private org.springframework.data.redis.core.script.DefaultRedisScript<java.lang.String> handleFailSynTaskRedisScript;
  private org.springframework.data.redis.core.script.DefaultRedisScript<java.lang.String> refreshHandleSynTaskRedisScript;
  private cn.cloudwalk.service.organization.service.CpImageStorePersonManager cpImageStorePersonManager;
  private cn.cloudwalk.service.organization.service.CpImageStorePersonTxHandler cpImageStorePersonTxHandler;
  private cn.cloudwalk.service.organization.service.CpImageStorePersonValidateManager cpImageStorePersonValidateManager;
  private cn.cloudwalk.data.organization.mapper.ImgStorePersonMapper imgStorePersonMapper;
  private cn.cloudwalk.client.aggregate.group.service.AgImageStoreService agImageStoreService;
  private cn.cloudwalk.client.aggregate.application.service.ApplicationImageStoreService appImageStoreService;
  private cn.cloudwalk.cloud.context.CloudwalkCallContext context;
  public cn.cloudwalk.service.organization.service.CpImageStorePersonSynManager();
  public void init();
  public void addGroupPersonSynTask(java.util.List<java.lang.String>, java.lang.String);
  public void addGroupPersonSynTask(java.lang.String, java.lang.String, boolean);
  public void addGroupPersonSynTask(java.util.List<java.lang.String>, java.util.List<java.lang.String>, boolean);
  public java.util.List<java.lang.String> addGroupPersonSynTask(java.lang.String);
  public java.util.List<java.lang.String> addGroupPersonSynTask(java.lang.String, java.lang.String, java.util.List<java.lang.String>);
  public java.util.List<java.lang.String> addGroupPersonSynTask(java.lang.String, java.util.List<java.lang.String>, boolean);
  public void handleGroupPersonSynTask(java.lang.String);
  private void groupPersonSyn(java.lang.String, java.lang.String);
  private void handleImageStoreFullSyn(cn.cloudwalk.client.aggregate.group.result.AgImageStoreResult) throws java.lang.Exception;
  private void handleImageStoreIncrementSyn(cn.cloudwalk.client.aggregate.group.result.AgImageStoreResult, java.lang.String) throws java.lang.Exception;
  private cn.cloudwalk.client.aggregate.group.result.AgImageStoreResult getImageStoreById(java.lang.String) throws java.lang.Exception;
  public java.lang.Long addWaitSynTask(java.lang.String, java.lang.String);
  public java.lang.Long lockHandleSynTask(java.lang.String);
  public java.lang.Long lockHeadSynTask(java.lang.String);
  public java.lang.Long handleSuccessSynTask(java.lang.String);
  public java.lang.Long handleFailSynTask(java.lang.String);
  public void refreshHandleSynTaskLockExpireTime();
  public void checkHandleSynTaskException();
  private void lambda$checkHandleSynTaskException$16(java.lang.String);
  private void lambda$checkHandleSynTaskException$15(java.lang.String);
  private java.lang.Object lambda$refreshHandleSynTaskLockExpireTime$14(org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException;
  private java.lang.Object lambda$handleFailSynTask$13(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException;
  private java.lang.Object lambda$handleSuccessSynTask$12(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException;
  private java.lang.Object lambda$lockHeadSynTask$11(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException;
  private java.lang.Object lambda$lockHandleSynTask$10(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException;
  private java.lang.Object lambda$addWaitSynTask$9(java.lang.String, java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException;
  private void lambda$handleImageStoreIncrementSyn$8(java.util.Map, java.util.Map, java.util.List, java.lang.String);
  private void lambda$handleImageStoreIncrementSyn$7(java.util.Map, java.util.Map, java.util.Map, java.util.List, java.util.List, java.lang.String);
  private static cn.cloudwalk.data.organization.entity.ImgStorePerson lambda$handleImageStoreIncrementSyn$6(cn.cloudwalk.data.organization.entity.ImgStorePerson);
  private static void lambda$handleImageStoreFullSyn$5(java.util.Map, java.util.List, java.lang.String);
  private void lambda$handleImageStoreFullSyn$4(java.util.Map, java.util.Map, java.util.Map, java.util.List, java.util.List, java.lang.String);
  private static cn.cloudwalk.data.organization.entity.ImgStorePerson lambda$handleImageStoreFullSyn$3(cn.cloudwalk.data.organization.entity.ImgStorePerson);
  private void lambda$handleGroupPersonSynTask$2(java.lang.String);
  private void lambda$addGroupPersonSynTask$1(java.lang.String, java.lang.String);
  private void lambda$addGroupPersonSynTask$0(java.lang.String, java.lang.String);
}
