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 addWaitSynTaskRedisScript; private org.springframework.data.redis.core.script.DefaultRedisScript lockHandleSynTaskRedisScript; private org.springframework.data.redis.core.script.DefaultRedisScript lockHeadSynTaskRedisScript; private org.springframework.data.redis.core.script.DefaultRedisScript handleSuccessSynTaskRedisScript; private org.springframework.data.redis.core.script.DefaultRedisScript handleFailSynTaskRedisScript; private org.springframework.data.redis.core.script.DefaultRedisScript 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); public void addGroupPersonSynTask(java.lang.String, java.lang.String, boolean); public void addGroupPersonSynTask(java.util.List, java.util.List, boolean); public java.util.List addGroupPersonSynTask(java.lang.String); public java.util.List addGroupPersonSynTask(java.lang.String, java.lang.String, java.util.List); public java.util.List addGroupPersonSynTask(java.lang.String, java.util.List, 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 byte[] lambda$refreshHandleSynTaskLockExpireTime$14(org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException; private java.lang.Long lambda$handleFailSynTask$13(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException; private java.lang.Long lambda$handleSuccessSynTask$12(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException; private java.lang.Long lambda$lockHeadSynTask$11(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException; private java.lang.Long lambda$lockHandleSynTask$10(java.lang.String, org.springframework.data.redis.connection.RedisConnection) throws org.springframework.dao.DataAccessException; private java.lang.Long 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); }