|
|
@ -78,7 +78,7 @@ public class IndexCalculateController { |
|
|
|
* 处理暂停中的计算 |
|
|
|
*/ |
|
|
|
@PostMapping("process-pendding-cals") |
|
|
|
public void processPenddingCalculate() { |
|
|
|
public Result processPenddingCalculate() { |
|
|
|
String keyPrefix = RedisKeys.getCustomerStatsCalKeyPrefix(); |
|
|
|
Set<String> calFlagKeys = redisUtils.keys(keyPrefix.concat("*")); |
|
|
|
calFlagKeys.forEach(key -> { |
|
|
@ -91,6 +91,8 @@ public class IndexCalculateController { |
|
|
|
indexCalculate(form); |
|
|
|
} |
|
|
|
}); |
|
|
|
|
|
|
|
return new Result(); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|