Commit cf58fa31 authored by zhaochengming's avatar zhaochengming

赵呈明 --应用

parent 12ceff04
package com.pms.ocp.controller; package com.pms.ocp.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.pms.ocp.model.dto.OcpTenantGroupDto; import com.pms.ocp.model.dto.OcpTenantGroupDto;
import com.pms.ocp.model.dto.PageGroupDto;
import com.pms.ocp.model.dto.TenanBaseDto;
import com.pms.ocp.model.entity.OcpApiGroup;
import com.pms.ocp.model.entity.OcpTenantBase;
import com.pms.ocp.model.entity.OcpTenantGroup; import com.pms.ocp.model.entity.OcpTenantGroup;
import com.pms.ocp.model.vo.ResponseVO; import com.pms.ocp.model.vo.ResponseVO;
import com.pms.ocp.service.TenantService; import com.pms.ocp.service.TenantService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
...@@ -37,12 +43,43 @@ public class OcpTenantController { ...@@ -37,12 +43,43 @@ public class OcpTenantController {
@PostMapping("/tenantinster") @PostMapping("/tenantinster")
@ApiModelProperty("新增应用") @ApiModelProperty("新增应用")
public ResponseVO tenantInster(@RequestBody OcpTenantGroup ocpTenantGroup){ public ResponseVO tenantInster(@RequestBody TenanBaseDto TenanBaseDto){
boolean falg = tenantService.getTenanInster(ocpTenantGroup); boolean falg = tenantService.getTenanInster(TenanBaseDto);
if (falg){ if (falg){
return ResponseVO.ok("新建成功!"); return ResponseVO.ok("新建成功!");
} }
return ResponseVO.error("应用code已经存在!"); return ResponseVO.error("应用code已经存在!");
}
@PostMapping("/tenantupdata")
@ApiModelProperty("修改应用")
public ResponseVO tenantUpdata(@RequestBody OcpTenantGroup ocpTenantGroup){
boolean falg = tenantService.getTenantUpdata(ocpTenantGroup);
if (falg){
return ResponseVO.ok("修改成功!");
}
return ResponseVO.error("应用code已经存在!");
}
@PostMapping("/tenantdelete")
@ApiModelProperty("删除服务")
public ResponseVO tenantDelete(@RequestBody OcpTenantGroup ocpTenantGroup){
boolean falg = tenantService.gettenantDelete(ocpTenantGroup);
if (falg){
return ResponseVO.ok("删除成功!");
}
return ResponseVO.error("应用下存在服务,请先删除下级应该!");
}
@PostMapping("tenantone")
@ApiOperation("应用分类--分级数据")
public ResponseVO<Page<OcpApiGroup>> tenantOne(@RequestBody PageGroupDto pageGroupDto){
// Page<OcpApiGroup> onePages = tenantService.getOnePages(pageGroupDto);
return ResponseVO.ok();
} }
} }
package com.pms.ocp.model.dto;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.pms.ocp.model.entity.OcpTenantGroup;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.sql.Timestamp;
/**
* 新增应用封装对象
*/
@ApiModel(value = "新增应用封装对象")
@Data
public class TenanBaseDto extends OcpTenantGroup {
@TableId(type = IdType.ASSIGN_ID)
@ApiModelProperty("主键ID")
private String objId;
/**
* 应用名称
*/
@ApiModelProperty("应用名称")
private String tenantName;
/**
* 应用代码
*/
@ApiModelProperty("应用代码")
private String tenantCode;
/**
* 应用分类代码
*/
@ApiModelProperty("应用分类代码")
private String tenantGroupCode;
/**
* 应用ip
*/
@ApiModelProperty("应用ip")
private String tenantIp;
/**
* 应用url
*/
@ApiModelProperty("应用url")
private String tenantUrl;
/**
* 所属专业
*/
@ApiModelProperty("所属专业")
private String professionalKind;
/**
* 创建者用户ID
*/
@ApiModelProperty("创建者用户ID")
private String tenantUserId;
/**
* 排序
*/
@ApiModelProperty("排序")
private Integer tenantOrderNo;
/**
* 创建时间
*/
@ApiModelProperty("创建时间")
private Timestamp tenantCtime;
/**
* 最后更新时间
*/
@ApiModelProperty("最后更新时间")
private Timestamp tenantMtime;
/**
* 部署名称
*/
@ApiModelProperty("部署名称")
private String deploymentName;
/**
* 描述
*/
@ApiModelProperty("描述")
private String tenantDescription;
/**
* 应用状态0:设计态;1:运行态
*/
@ApiModelProperty("应用状态0:设计态;1:运行态")
private Short tenantState;
/**
* 建设单位
*/
@ApiModelProperty("建设单位")
private String tenantUnit;
/**
* 所属公司编码
*/
@ApiModelProperty("所属公司编码")
private String ownerCompanyCode;
/**
* 所属公司名称
*/
@ApiModelProperty("所属公司名称")
private String ownerCompanyName;
/**
* 是否删除0:否;1:是
*/
@ApiModelProperty("是否删除0:否;1:是")
private Short isDelete;
/**
* 所属区域 1:生产控制大区;2:信息关联大区;3:互联网大区
*/
@ApiModelProperty("所属区域 1:生产控制大区;2:信息关联大区;3:互联网大区")
private Short tenantZone;
/**
* 所属层级 1:应用层;2:平台层;3:网络层;4:感知层;
*/
@ApiModelProperty("所属层级 1:应用层;2:平台层;3:网络层;4:感知层;")
private Short tenantLayer;
/**
* 应用版本(当前版本)
*/
@ApiModelProperty("应用版本(当前版本)")
private String tenantVersion;
}
...@@ -10,6 +10,7 @@ import lombok.Data; ...@@ -10,6 +10,7 @@ import lombok.Data;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import java.io.Serializable; import java.io.Serializable;
import java.sql.Timestamp;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
...@@ -87,13 +88,13 @@ public class OcpTenantGroup implements Serializable { ...@@ -87,13 +88,13 @@ public class OcpTenantGroup implements Serializable {
* 创建时间 * 创建时间
*/ */
@ApiModelProperty("创建时间") @ApiModelProperty("创建时间")
private Date tenantGroupCtime; private Timestamp tenantGroupCtime;
/** /**
* 修改时间 * 修改时间
*/ */
@ApiModelProperty("修改时间") @ApiModelProperty("修改时间")
private Date tenantGroupMtime; private Timestamp tenantGroupMtime;
/** /**
* 是否删除 * 是否删除
...@@ -265,7 +266,7 @@ public class OcpTenantGroup implements Serializable { ...@@ -265,7 +266,7 @@ public class OcpTenantGroup implements Serializable {
/** /**
* 创建时间 * 创建时间
*/ */
public void setTenantGroupCtime(Date tenantGroupCtime) { public void setTenantGroupCtime(Timestamp tenantGroupCtime) {
this.tenantGroupCtime = tenantGroupCtime; this.tenantGroupCtime = tenantGroupCtime;
} }
...@@ -279,7 +280,7 @@ public class OcpTenantGroup implements Serializable { ...@@ -279,7 +280,7 @@ public class OcpTenantGroup implements Serializable {
/** /**
* 修改时间 * 修改时间
*/ */
public void setTenantGroupMtime(Date tenantGroupMtime) { public void setTenantGroupMtime(Timestamp tenantGroupMtime) {
this.tenantGroupMtime = tenantGroupMtime; this.tenantGroupMtime = tenantGroupMtime;
} }
......
package com.pms.ocp.service; package com.pms.ocp.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.pms.ocp.model.dto.OcpTenantGroupDto; import com.pms.ocp.model.dto.OcpTenantGroupDto;
import com.pms.ocp.model.dto.PageGroupDto;
import com.pms.ocp.model.dto.TenanBaseDto;
import com.pms.ocp.model.entity.OcpApiGroup;
import com.pms.ocp.model.entity.OcpTenantGroup; import com.pms.ocp.model.entity.OcpTenantGroup;
import java.util.List; import java.util.List;
...@@ -20,10 +24,24 @@ public interface TenantService extends IService<OcpTenantGroup> { ...@@ -20,10 +24,24 @@ public interface TenantService extends IService<OcpTenantGroup> {
/** /**
* 应用新增 * 应用新增
* @param
* @return
*/
boolean getTenanInster(TenanBaseDto TenanBaseDto);
/**
* 修改应用
* @param ocpTenantGroup
* @return
*/
boolean getTenantUpdata(OcpTenantGroup ocpTenantGroup);
/**
* 删除服务
* @param ocpTenantGroup * @param ocpTenantGroup
* @return * @return
*/ */
boolean getTenanInster(OcpTenantGroup ocpTenantGroup); boolean gettenantDelete(OcpTenantGroup ocpTenantGroup);
} }
...@@ -225,14 +225,21 @@ public class OcpApiTreeServiceImpl extends ServiceImpl<OcpApiTreeMapper,OcpApiGr ...@@ -225,14 +225,21 @@ public class OcpApiTreeServiceImpl extends ServiceImpl<OcpApiTreeMapper,OcpApiGr
*/ */
@Override @Override
public boolean deleteOcpTree(OcpApiGroup ocpApiGroup) { public boolean deleteOcpTree(OcpApiGroup ocpApiGroup) {
boolean flag = true;
String objId = ocpApiGroup.getObjId(); String objId = ocpApiGroup.getObjId();
OcpApiGroup ocpApiGroup1 = mapper.selectById(objId); OcpApiGroup ocpApiGroup1 = mapper.selectById(objId);
List<OcpApiGroup> ocpApiGroups = mapper.selectList(null);
if (StringUtils.isBlank(ocpApiGroup1.getApiGroupPcode())) { if (StringUtils.isBlank(ocpApiGroup1.getApiGroupPcode())) {
mapper.deleteById(objId); for (OcpApiGroup apiGroup : ocpApiGroups) {
return true; if ((ocpApiGroup1.getApiGroupCode()).equals(apiGroup.getApiGroupPcode())){
} else { flag = false;
return false; break;
}
}
} }
mapper.deleteById(objId);
return flag;
} }
......
package com.pms.ocp.service.impl; package com.pms.ocp.service.impl;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.pms.ocp.common.utils.RandomStringUtil; import com.pms.ocp.common.utils.RandomStringUtil;
import com.pms.ocp.mapper.TenantBasicManagementMapper;
import com.pms.ocp.mapper.TenantMapper; import com.pms.ocp.mapper.TenantMapper;
import com.pms.ocp.model.dto.OcpTenantGroupDto; import com.pms.ocp.model.dto.*;
import com.pms.ocp.model.dto.OneTenanList; import com.pms.ocp.model.entity.OcpApiGroup;
import com.pms.ocp.model.dto.ThreeTenanList; import com.pms.ocp.model.entity.OcpTenantAudit;
import com.pms.ocp.model.dto.TwoTenanList; import com.pms.ocp.model.entity.OcpTenantBase;
import com.pms.ocp.model.entity.OcpTenantGroup; import com.pms.ocp.model.entity.OcpTenantGroup;
import com.pms.ocp.service.TenantService; import com.pms.ocp.service.TenantService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.sql.Timestamp;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
@Service @Service
public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup> implements TenantService { public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup> implements TenantService {
...@@ -25,6 +26,8 @@ public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup> ...@@ -25,6 +26,8 @@ public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup>
@Autowired @Autowired
private TenantMapper tenantMapper; private TenantMapper tenantMapper;
@Autowired
private TenantBasicManagementMapper tenantBasicMapper;
/** /**
* 应用树分类管理 * 应用树分类管理
...@@ -96,15 +99,15 @@ public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup> ...@@ -96,15 +99,15 @@ public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup>
/** /**
* 应用新增 * 应用新增
* *
* @param ocpTenantGroup * @param
* @return * @return
*/ */
@Override @Override
public boolean getTenanInster(OcpTenantGroup ocpTenantGroup) { public boolean getTenanInster(TenanBaseDto tenanBaseDto) {
boolean falg = true; boolean falg = true;
OcpTenantGroup group = new OcpTenantGroup(); OcpTenantGroup group = new OcpTenantGroup();
String tenantGroupCode = ocpTenantGroup.getTenantGroupCode(); String tenantGroupCode = tenanBaseDto.getTenantGroupCode();
List<OcpTenantGroup> ocpTenantGroups = tenantMapper.selectList(null); List<OcpTenantGroup> ocpTenantGroups = tenantMapper.selectList(null);
for (OcpTenantGroup tenantGroup : ocpTenantGroups) { for (OcpTenantGroup tenantGroup : ocpTenantGroups) {
if (tenantGroup.getTenantGroupCode().equals(tenantGroupCode)){ if (tenantGroup.getTenantGroupCode().equals(tenantGroupCode)){
...@@ -112,9 +115,76 @@ public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup> ...@@ -112,9 +115,76 @@ public class TenantServiceImpl extends ServiceImpl<TenantMapper, OcpTenantGroup>
break; break;
} }
} }
group.setTenantGroupCode(RandomStringUtil.getRandomString(6)); String randomString = RandomStringUtil.getRandomString(6);
tenantMapper.insert(ocpTenantGroup); Timestamp timestamp = new Timestamp(System.currentTimeMillis());
OcpTenantGroup ocpTenantGroup = new OcpTenantGroup();
BeanUtils.copyProperties(tenanBaseDto,ocpTenantGroup);
if ("null".equals(tenanBaseDto.getOwnerCompanyCode())){
ocpTenantGroup.setTenantGroupCode(randomString);
}
ocpTenantGroup.setTenantGroupCtime(timestamp);
ocpTenantGroup.setTenantGroupMtime(timestamp);
if ("".equals(tenanBaseDto.getTenantVersion())){
ocpTenantGroup.setTenantGroupVersion("1.0");
}
OcpTenantBase ocpTenantBase = new OcpTenantBase();
BeanUtils.copyProperties(tenanBaseDto,ocpTenantBase);
if ("null".equals(tenanBaseDto.getTenantGroupCode())){
group.setTenantGroupCode(randomString);
}
tenantMapper.insert(tenanBaseDto);
tenantBasicMapper.insert(ocpTenantBase);
return falg; return falg;
} }
/**
* 修改应用
*
* @param ocpTenantGroup
* @return
*/
@Override
public boolean getTenantUpdata(OcpTenantGroup ocpTenantGroup) {
boolean falg = true;
List<OcpTenantGroup> ocpTenantGroupList = tenantMapper.selectList(null);
for (OcpTenantGroup ocpApiGroup : ocpTenantGroupList) {
String code = ocpTenantGroup.getTenantGroupCode();
if (code == ocpApiGroup.getTenantGroupCode()) {
falg = false;
break;
}
}
tenantMapper.updateById(ocpTenantGroup);
return falg;
}
/**
* 删除服务
*
* @param ocpTenantGroup
* @return
*/
@Override
public boolean gettenantDelete(OcpTenantGroup ocpTenantGroup) {
String objId = ocpTenantGroup.getObjId();
OcpTenantGroup ocpTenantGroup1 = tenantMapper.selectById(objId);
boolean flag = true;
List<OcpTenantGroup> ocpTenantGroupList = tenantMapper.selectList(null);
if (StringUtils.isBlank(ocpTenantGroup1.getTenantGroupPcode())) {
for (OcpTenantGroup tenantGroup : ocpTenantGroupList) {
String tenantGroupPcode = tenantGroup.getTenantGroupPcode();
if ((ocpTenantGroup.getTenantGroupCode().equals(tenantGroupPcode))){
flag = false;
break;
}
}
}
tenantMapper.deleteById(objId);
return flag;
}
} }
...@@ -2,11 +2,11 @@ spring: ...@@ -2,11 +2,11 @@ spring:
datasource: datasource:
driver-class-name: org.postgresql.Driver driver-class-name: org.postgresql.Driver
username: postgres username: postgres
password: root password: 1234
type: com.zaxxer.hikari.HikariDataSource type: com.zaxxer.hikari.HikariDataSource
# jdbc-url: jdbc:postgresql://192.168.43.20:33072/pms3?currentSchema=public&stringtype=unspecified&TimeZone=Asia/Shanghai&useAffectedRows=true # jdbc-url: jdbc:postgresql://192.168.43.20:33072/pms3?currentSchema=public&stringtype=unspecified&TimeZone=Asia/Shanghai&useAffectedRows=true
# jdbc-url: jdbc:postgresql://172.20.10.9:33072/pms3?currentSchema=public&stringtype=unspecified&TimeZone=Asia/Shanghai&useAffectedRows=true # jdbc-url: jdbc:postgresql://172.20.10.9:33072/pms3?currentSchema=public&stringtype=unspecified&TimeZone=Asia/Shanghai&useAffectedRows=true
url: jdbc:postgresql://localhost:5432/server?currentSchema=operating_platform&stringtype=unspecified&TimeZone=Asia/Shanghai&useAffectedRows=true url: jdbc:postgresql://localhost:5432/postgres?currentSchema=operating_platform&stringtype=unspecified&TimeZone=Asia/Shanghai&useAffectedRows=true
knife4j: knife4j:
enable: true enable: true
......
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.pms.ocp.mapper.TenantMapper">
<select id="oneTenantGroup" resultType="com.pms.ocp.model.entity.OcpTenantGroup">
SELECT * FROM ocp_tenant_group WHERE tenant_group_code = #{tenant_group_company_pcode};
</select>
<select id="twoTenantGroups" resultType="com.pms.ocp.model.entity.OcpTenantGroup">
SELECT * FROM ocp_tenant_group WHERE ocp_tenant_group.tenant_group_code = '{tenant_group_company_pcode};
</select>
</mapper>
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