批量活码处理

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/hm/impl/HmClerkRelationServiceImpl.java

@@ -46,7 +46,9 @@ import com.gic.haoban.manage.service.pojo.bo.hm.HmClerkRelationBO;
 import com.gic.haoban.manage.service.service.PreDealService;
 import com.gic.haoban.manage.service.service.SyncTaskService;
 import com.gic.haoban.manage.service.service.hm.HmClerkRelationService;
+import com.gic.haoban.manage.service.task.hm.QwHmOperation;
 import com.gic.mq.sdk.GicMQClient;
+import com.gic.redis.data.util.RedisUtil;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 
@@ -150,9 +152,14 @@ public class HmClerkRelationServiceImpl implements HmClerkRelationService {
     
     @Override
     public ServiceResponse<List<HmBatchModifyResultDTO>> batchModify(HmBatchModifyQDTO qdto) {
+        String wxEnterpriseId = qdto.getWxEnterpriseId() ;
+        String enterpriseId = qdto.getEnterpriseId() ;
+        String cacheKey = QwHmOperation.hmCachKey+wxEnterpriseId+enterpriseId ;
+        if(null != RedisUtil.getCache(cacheKey)) {
+            return ServiceResponse.failure("9999", "已有任务在执行,请稍后在处理") ;
+        }
         int maxCount = 3 ;
         List<Long> hmIdList = qdto.getHmIdList() ;
-        String enterpriseId = qdto.getEnterpriseId() ;
         List<TabHaobanHmClerkRelation> list = this.tabHaobanHmClerkRelationMapper.listHmClerkByHmIdList(hmIdList) ;
         log.info("查询活码关联导购数={},活码数={}",list.size(),hmIdList.size());
         Map<Long,List<TabHaobanHmClerkRelation>> map = list.stream().collect(Collectors.groupingBy(TabHaobanHmClerkRelation::getHmId));
@@ -214,19 +221,26 @@ public class HmClerkRelationServiceImpl implements HmClerkRelationService {
             });
             return ServiceResponse.success(errList) ;
         }
-        
-        String wxEnterpriseId = qdto.getWxEnterpriseId() ;
-        String clerkId = qdto.getOptClerkId() ;
-        String name = qdto.getOptName() ;
-        String taskName = "批量修改多人活码";
-        
         if(modifyMap.size()==0) {
             return ServiceResponse.failure("9999", "没有需要处理的活码") ;
         }
-        
+        String lockKey = cacheKey+"lock";
+        if(RedisUtil.isLocked(lockKey) || null != RedisUtil.getCache(cacheKey)) {
+            return ServiceResponse.failure("9999", "已有任务在执行,请稍后在处理") ;
+        }
+        RedisUtil.lock(lockKey, 2L);
+        if(null != RedisUtil.getCache(cacheKey)) {
+            return ServiceResponse.failure("9999", "已有任务在执行,请稍后在处理") ;
+        }
+        RedisUtil.setCache(cacheKey,"1") ;
+        RedisUtil.unlock(lockKey);
+        String clerkId = qdto.getOptClerkId() ;
+        String name = qdto.getOptName() ;
+        String taskName = "批量修改多人活码";
         String taskId = this.createModifyHmTask(wxEnterpriseId, taskName, clerkId,
                 name, SyncTaskTypeEnum.BATCH_MODIFY_HM.getType());
         if (StringUtils.isBlank(taskId)) {
+            RedisUtil.delCache(cacheKey) ;
             return ServiceResponse.failure("9999", "创建任务失败") ;
         }
         if(CollectionUtils.isNotEmpty(errList)) {

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

@@ -20,11 +20,13 @@ import com.gic.haoban.manage.service.entity.TabHaobanSyncTask;
 import com.gic.haoban.manage.service.service.PreDealService;
 import com.gic.haoban.manage.service.service.SyncTaskService;
 import com.gic.haoban.manage.service.task.BaseSyncOperation;
+import com.gic.redis.data.util.RedisUtil;
 
 @Service
 public class QwHmOperation implements BaseSyncOperation {
 
     private static final Logger logger = LoggerFactory.getLogger(QwHmOperation.class);
+    public static final String hmCachKey = "hm:batch:key" ;
     @Autowired
     private HmQrcodeApiService hmQrcodeApiService;
     @Autowired
@@ -35,11 +37,12 @@ public class QwHmOperation implements BaseSyncOperation {
     @Override
     public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) {
         String taskId = dealParamMqDTO.getTaskId();
+        String wxEnterpriseId = dataPre.getWxEnterpriseId();
+        String enterpriseId = dataPre.getEnterpriseId();
         Long hmId = Long.valueOf(dataPre.getDataId());
+        try {
             logger.info("开始处理活码={},{}",taskId,hmId);
             String clerkIds = dataPre.getDataContent();
-        String wxEnterpriseId = dataPre.getWxEnterpriseId();
-        String enterpriseId = dataPre.getEnterpriseId();
             List<String> clerkIdList = JSONArray.parseArray(clerkIds, String.class);
             // 删除
             ServiceResponse resp = null ;
@@ -59,8 +62,13 @@ public class QwHmOperation implements BaseSyncOperation {
             }else {
                 this.preDealService.updateStatusByDataId(taskId, dataPre.getDataId(), 3, resp.getMessage());
             }
+        }catch(Exception e) {
+            logger.info("活码处理异常={},{}",hmId,e.getMessage());
+            this.preDealService.updateStatusByDataId(taskId, dataPre.getDataId(), 3, "执行异常");
+        }finally{
             this.dealSuccess(taskId, dataPre.getDataId(), enterpriseId, wxEnterpriseId);
         }
+    }
 
     @Override
     public void dealException(String taskId, String dataId, String enterpriseId, String reason) {
@@ -75,9 +83,11 @@ public class QwHmOperation implements BaseSyncOperation {
         logger.info("批量修改活码完成={}", taskId);
         TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId);
         if (syncTask.getStatusFlag() == SyncTaskStatusEnum.compute.getVal()) {
+            RedisUtil.delCache(hmCachKey+wxEnterpriseId+enterpriseId) ;
             return;
         }
         logger.info("批量修改活码完成,status={}", taskId);
+        RedisUtil.delCache(hmCachKey+wxEnterpriseId+enterpriseId) ;
         this.syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal());
     }