Commit d4a6d3d9 authored by 梁光意's avatar 梁光意

修改初始化的分组和树结构的代码

parent 30d2a863
...@@ -3,23 +3,22 @@ package com.syc.slm.slmbi.controller; ...@@ -3,23 +3,22 @@ package com.syc.slm.slmbi.controller;
import com.syc.slm.common.core.util.R; import com.syc.slm.common.core.util.R;
import com.syc.slm.slmbi.service.CompanyService; import com.syc.slm.slmbi.service.CompanyService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.servlet.http.HttpServletRequest;
import java.util.Set; import java.util.Set;
/** /**
* @author: guangyi-liang * @author: guangyi-liang
* @date: 2021/5/20 * @date: 2021/5/20
*/ */
@RequestMapping("/company") @RequestMapping("/{appId}/company")
@RestController @RestController
@Api(value = "初始化相关管理接口", tags = "初始化相关管理接口") @Api(value = "初始化相关管理接口", tags = "初始化相关管理接口")
public class InitController { public class InitController extends BaseRestController{
@Autowired @Autowired
...@@ -27,13 +26,15 @@ public class InitController { ...@@ -27,13 +26,15 @@ public class InitController {
@GetMapping("/app-id") @GetMapping("/app-id")
@ApiOperation("测试") @ApiOperation("测试")
public R<Set<String>> findAll() { @ApiImplicitParam(name = "appId", value = "租户id", required = true,dataTypeClass = String.class)
return R.ok(companyService.findAll()); public R<Set<String>> findAll(HttpServletRequest request, @PathVariable String appId) {
return call(()-> companyService.findAll(appId));
} }
// @PostMapping("/group/tree/init") @PostMapping("/group/tree/init")
// @ApiOperation("测试顶级分组和蜀兴结构") @ApiOperation("初始化顶级分组和树结构")
// public R<Boolean> initGroupAndTree() { @ApiImplicitParam(name = "appId", value = "租户id", required = true,dataTypeClass = String.class)
// return R.ok(companyService.initGroupAndTree()); public R<Boolean> initGroupAndTree(HttpServletRequest request, @PathVariable String appId) {
// } return call(()-> companyService.initGroupAndTree(appId));
}
} }
...@@ -8,11 +8,17 @@ import java.util.Set; ...@@ -8,11 +8,17 @@ import java.util.Set;
*/ */
public interface CompanyService { public interface CompanyService {
Set<String> findAll(); /**
* 测试查询所有
* @param appId 当前租户AppId
* @return 公司全部appId
*/
Set<String> findAll(String appId);
/** /**
* 初始化顶级分组和树 * 初始化顶级分组和树
* @param appId 当前租户AppId
* @return 是否成功 * @return 是否成功
*/ */
boolean initGroupAndTree(); boolean initGroupAndTree(String appId);
} }
...@@ -39,22 +39,21 @@ public class CompanyServiceImpl implements CompanyService { ...@@ -39,22 +39,21 @@ public class CompanyServiceImpl implements CompanyService {
private InstrumentPanelTreeInitMapper treeInitMapper; private InstrumentPanelTreeInitMapper treeInitMapper;
@Override @Override
public Set<String> findAll() { public Set<String> findAll(String appId) {
this.initGroupAndTree(); return this.findAllAppId(appId);
return this.findAllAppId();
} }
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public boolean initGroupAndTree() { public boolean initGroupAndTree(String appId) {
String name = "全部分组"; String name = "全部分组";
Set<String> stringSet = this.findAllAppId(); Set<String> stringSet = this.findAllAppId(appId);
for (String appId:stringSet){ for (String companyAppId:stringSet){
LambdaQueryWrapper<InstrumentPanelGroupInit> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<InstrumentPanelGroupInit> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(InstrumentPanelGroupInit::getAppId,appId); wrapper.eq(InstrumentPanelGroupInit::getAppId,companyAppId);
Integer count = groupInitMapper.selectCount(wrapper); Integer count = groupInitMapper.selectCount(wrapper);
if (count <= 0){ if (count <= 0){
InstrumentPanelGroupInit groupInit = this.initGroup(appId,name); InstrumentPanelGroupInit groupInit = this.initGroup(companyAppId,name);
groupInitMapper.insert(groupInit); groupInitMapper.insert(groupInit);
InstrumentPanelTreeInit treeInit = this.initTree(groupInit); InstrumentPanelTreeInit treeInit = this.initTree(groupInit);
treeInitMapper.insert(treeInit); treeInitMapper.insert(treeInit);
...@@ -63,9 +62,9 @@ public class CompanyServiceImpl implements CompanyService { ...@@ -63,9 +62,9 @@ public class CompanyServiceImpl implements CompanyService {
return true; return true;
} }
private Set<String> findAllAppId(){ private Set<String> findAllAppId(String appId){
Map<String,String> map = Maps.newHashMap(); Map<String,String> map = Maps.newHashMap();
map.put("test","test"); map.put("appId",appId);
R<Set<String>> result = RestTemplateUtils.get(centerConfig.getHost()+centerConfig.getCompanyAppId(), new TypeToken<R<Set<String>>>() {}.getType(),map); R<Set<String>> result = RestTemplateUtils.get(centerConfig.getHost()+centerConfig.getCompanyAppId(), new TypeToken<R<Set<String>>>() {}.getType(),map);
return result.detach(); return result.detach();
} }
......
...@@ -72,4 +72,4 @@ dc_client: ...@@ -72,4 +72,4 @@ dc_client:
# historyCurve : /{appId}/variables/history-curve # historyCurve : /{appId}/variables/history-curve
permissionCodeUrl : /{appId}/bi/permission/code permissionCodeUrl : /{appId}/bi/permission/code
variableStatusRealTimeDataList: /{appId}/variables/status/real-time/data variableStatusRealTimeDataList: /{appId}/variables/status/real-time/data
companyAppId: /init/bi/company/app-id companyAppId: /{appId}/bi/company/init/app-id
\ No newline at end of file \ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment