|
|
@@ -0,0 +1,109 @@
|
|
|
+package org.hswebframework.web.controller.dashboard;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import io.swagger.annotations.Api;
|
|
|
+import io.swagger.annotations.ApiOperation;
|
|
|
+import org.hswebframework.web.authorization.Authentication;
|
|
|
+import org.hswebframework.web.authorization.AuthenticationPredicate;
|
|
|
+import org.hswebframework.web.authorization.annotation.Authorize;
|
|
|
+import org.hswebframework.web.controller.dashboard.model.UserDashBoardResponse;
|
|
|
+import org.hswebframework.web.controller.message.ResponseMessage;
|
|
|
+import org.hswebframework.web.dashboard.DashBoardConfigEntity;
|
|
|
+import org.hswebframework.web.dashboard.DashBoardService;
|
|
|
+import org.hswebframework.web.dashboard.executor.DashBoardExecutor;
|
|
|
+import org.hswebframework.web.entity.authorization.UserSettingEntity;
|
|
|
+import org.hswebframework.web.service.authorization.UserSettingService;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.util.StringUtils;
|
|
|
+import org.springframework.web.bind.annotation.*;
|
|
|
+
|
|
|
+import javax.annotation.PostConstruct;
|
|
|
+import java.util.Collections;
|
|
|
+import java.util.Comparator;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Objects;
|
|
|
+import java.util.concurrent.Executor;
|
|
|
+import java.util.concurrent.Executors;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+/**
|
|
|
+ * @author zhouhao
|
|
|
+ * @since 3.0
|
|
|
+ */
|
|
|
+@RestController
|
|
|
+@RequestMapping("/dashboard-user")
|
|
|
+@Api(tags = "仪表盘-用户配置", value = "仪表盘用户配置")
|
|
|
+@Authorize
|
|
|
+public class DashBoardUserConfigController {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private UserSettingService userSettingService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DashBoardService dashBoardService;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private DashBoardExecutor dashBoardExecutor;
|
|
|
+
|
|
|
+ @Autowired(required = false)
|
|
|
+ private Executor executor;
|
|
|
+
|
|
|
+ @PostConstruct
|
|
|
+ public void init() {
|
|
|
+ executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);
|
|
|
+ }
|
|
|
+
|
|
|
+ @GetMapping("/all")
|
|
|
+ @ApiOperation("获取用户可选择的仪表盘配置")
|
|
|
+ public ResponseMessage<List<UserDashBoardResponse>> getUserAllDashBoardConfig(Authentication authentication) {
|
|
|
+ List<UserDashBoardResponse> configList = dashBoardService.select()
|
|
|
+ .stream()
|
|
|
+ .filter(Objects::nonNull)
|
|
|
+ //过滤权限
|
|
|
+ .filter(config -> StringUtils.isEmpty(config) ||
|
|
|
+ AuthenticationPredicate.has(config.getPermission()).test(authentication))
|
|
|
+ .map(config -> config.copyTo(new UserDashBoardResponse()))
|
|
|
+ .collect(Collectors.toList());
|
|
|
+ return ResponseMessage.ok(configList);
|
|
|
+ }
|
|
|
+
|
|
|
+ @GetMapping
|
|
|
+ @ApiOperation("获取用户自定义的仪表盘配置")
|
|
|
+ public ResponseMessage<List<UserDashBoardResponse>> getUserConfigDashBoardConfig(Authentication authentication) {
|
|
|
+ UserSettingEntity settingEntity = userSettingService.selectByUser(authentication.getUser().getId(), "dashboard-config", "current");
|
|
|
+ if (settingEntity == null) {
|
|
|
+ return ResponseMessage.ok(Collections.emptyList());
|
|
|
+ }
|
|
|
+
|
|
|
+ List<String> ids = JSON.parseArray(settingEntity.getSetting(), String.class);
|
|
|
+
|
|
|
+ List<UserDashBoardResponse> configList = ids
|
|
|
+ .parallelStream()
|
|
|
+ .map(dashBoardService::selectByPk) //为什么要单个查询不用批量查询?因为单个查询有缓存
|
|
|
+ .filter(Objects::nonNull)
|
|
|
+ //过滤权限
|
|
|
+ .filter(config -> StringUtils.isEmpty(config) ||
|
|
|
+ AuthenticationPredicate.has(config.getPermission()).test(authentication))
|
|
|
+ .map(config -> config.copyTo(new UserDashBoardResponse()))
|
|
|
+ .sorted(Comparator.comparing(conf -> ids.indexOf(conf.getId())))
|
|
|
+ .collect(Collectors.toList());
|
|
|
+
|
|
|
+ return ResponseMessage.ok(configList);
|
|
|
+ }
|
|
|
+
|
|
|
+ @PutMapping
|
|
|
+ @ApiOperation("保存用户自定义的仪表盘配置")
|
|
|
+ public ResponseMessage<Void> saveUserDashBoardConfig(@RequestBody List<String> configIdList, Authentication authentication) {
|
|
|
+ UserSettingEntity settingEntity = userSettingService.selectByUser(authentication.getUser().getId(), "dashboard-config", "current");
|
|
|
+ if (settingEntity == null) {
|
|
|
+ settingEntity = userSettingService.createEntity();
|
|
|
+ settingEntity.setUserId(authentication.getUser().getId());
|
|
|
+ settingEntity.setKey("dashboard-config");
|
|
|
+ settingEntity.setSettingId("current");
|
|
|
+ }
|
|
|
+ settingEntity.setSetting(JSON.toJSONString(configIdList));
|
|
|
+ userSettingService.saveOrUpdate(settingEntity);
|
|
|
+
|
|
|
+ return ResponseMessage.ok();
|
|
|
+ }
|
|
|
+}
|
zhouhao