caixiaofeng 4 mēneši atpakaļ
vecāks
revīzija
8a0186b1d2

+ 5 - 4
flow-workflow/flow-workflow-biz/src/main/java/com/flow/service/impl/FlowDefineServiceImpl.java

@@ -59,6 +59,7 @@ public class FlowDefineServiceImpl extends BaseServiceImpl<FlowDefineDao, FlowDe
     private RedisService<Map<String, Object>> redisMapService;
     @Autowired
     private ObjectMapper objectMapper;
+    private static final String TEMPORARILY_CACHE_PREFIX = "flow:temp:";
 
     @Transactional(rollbackFor = Exception.class)
     @Override
@@ -145,7 +146,7 @@ public class FlowDefineServiceImpl extends BaseServiceImpl<FlowDefineDao, FlowDe
                 .variables(values)
                 .start();
         // 删除暂存
-        redisMapService.hdel(startProcess.getDefineId(), SecurityContextUtil.getUserId());
+        redisMapService.hdel(TEMPORARILY_CACHE_PREFIX + SecurityContextUtil.getUserId(), startProcess.getDefineId());
         try {
             runtimeService.setVariable(instanceId, "_SKIP_INITIATOR", false);
         } catch (Exception ignored) {
@@ -196,18 +197,18 @@ public class FlowDefineServiceImpl extends BaseServiceImpl<FlowDefineDao, FlowDe
         }
         RootNode rootNode = (RootNode) define.getProcess();
         List<FieldProperty> formProperties = rootNode.getFormProperties();
-        Map variables = redisMapService.hget(defineId, SecurityContextUtil.getUserId(), Map.class);
+        Map variables = redisMapService.hget(TEMPORARILY_CACHE_PREFIX + SecurityContextUtil.getUserId(), defineId, Map.class);
         return new FormInfo(define, formProperties, variables);
     }
 
     @Transactional(rollbackFor = Exception.class)
     @Override
     public void storeFormDataTemporarily(StartProcess startProcess) {
-        redisMapService.hset(startProcess.getDefineId(), SecurityContextUtil.getUserId(), startProcess.getValues());
+        redisMapService.hset(TEMPORARILY_CACHE_PREFIX + SecurityContextUtil.getUserId(), startProcess.getDefineId(), startProcess.getValues());
     }
 
     @Override
     public Map<String, Object> getFormDataTemporarily(String defineId) {
-        return redisMapService.hget(defineId, SecurityContextUtil.getUserId(), Map.class);
+        return redisMapService.hget(TEMPORARILY_CACHE_PREFIX + SecurityContextUtil.getUserId(), defineId, Map.class);
     }
 }