liutongsz/fibo-rule
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first commit

Browse Source
This commit is contained in:
niuge
2021-11-29 14:06:41 +08:00
parent 9fe956e941
commit 9450445e2a
259 changed files with 27872 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

136
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/controller/InterfaceController.java Normal file
View File

@@ -0,0 +1,136 @@
package com.risk.riskmanage.interfacemanage.controller;
import com.github.pagehelper.PageInfo;
import com.risk.riskmanage.common.constants.OpTypeConst;
import com.risk.riskmanage.common.enums.ErrorCodeEnum;
import com.risk.riskmanage.common.exception.ApiException;
import com.risk.riskmanage.common.model.ResponseEntityDto;
import com.risk.riskmanage.common.model.requestParam.QueryListParam;
import com.risk.riskmanage.common.utils.ResponseEntityBuilder;
import com.risk.riskmanage.interfacemanage.model.InterfaceInfo;
import com.risk.riskmanage.interfacemanage.model.request.InterfaceListParam;
import com.risk.riskmanage.interfacemanage.model.request.InterfaceUpdateStatusParam;
import com.risk.riskmanage.interfacemanage.model.vo.InterfaceVo;
import com.risk.riskmanage.interfacemanage.service.InterfaceService;
import com.risk.riskmanage.logger.ArchivesLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.HashMap;
/**
* 提供interface相关接口
*
* @apiDefine interface 2.接口管理
*/
@RestController
@RequestMapping("v3/interface")
public class InterfaceController {
@Autowired
InterfaceService interfaceService;
@RequestMapping("testInterface")
public String test(){
String str = "{\n" +
" \"status\": \"1\",\n" +
" \"error\": \"00000000\",\n" +
" \"msg\": null,\n" +
" \"data\": {\n" +
" \"name\": \"张三\",\n" +
" \"age\": 25\n" +
" }\n" +
"}";
return str;
}
/**
* @api {POST} /v3/interface/getInterfaceInfo/{id} 3.19. V3获取Interface信息
* @apiGroup knowledge
* @apiVersion 2.0.0
* @apiParam {Long} id : 规则id
* @apiSuccess {String} status 状态：1成功，0失败
* @apiParamExample {json} 请求示例：
* {}
* @apiSuccessExample {json} 成功返回数据示例：
* {"status":"1","error":"00000000","msg":null,"data":{"id":666,"name":"2021_4_6测试接口","versionCode":"test2021_4_6第二次输入","description":"接口测试","priority":0,"parentId":0,"author":135,"userId":135,"organId":46,"engineId":null,"status":1,"type":1,"isNon":null,"content":"test","created":"2021-04-06T08:38:17.000+00:00","updated":"2021-04-07T05:12:52.000+00:00","ruleType":0,"ruleAudit":2,"score":0,"lastLogical":"","ruleConditionVo":{"id":14,"logical":"&&","fieldId":null,"operator":null,"fieldValue":null,"ruleId":666,"parentId":0,"conditionType":1,"createTime":"2021-04-06T08:38:26.000+00:00","updateTime":null,"insertTempId":null,"children":[{"id":15,"logical":null,"fieldId":null,"operator":">","fieldValue":"1000","ruleId":666,"parentId":14,"conditionType":1,"createTime":"2021-04-06T08:38:26.000+00:00","updateTime":null,"insertTempId":null,"children":[],"tempParentId":null},{"id":16,"logical":null,"fieldId":null,"operator":"<","fieldValue":"10000","ruleId":666,"parentId":14,"conditionType":1,"createTime":"2021-04-06T08:38:26.000+00:00","updateTime":null,"insertTempId":null,"children":[],"tempParentId":null}],"tempParentId":null},"ruleContentInfoList":[{"id":16,"fieldId":10000,"fieldValue":"test01","ruleId":666},{"id":17,"fieldId":10000,"fieldValue":"test02","ruleId":666}]}}
*/
@RequestMapping(value = "getInterfaceInfo/{id}", method = RequestMethod.POST)
public ResponseEntityDto<InterfaceVo> getInterfaceById(@PathVariable Long id) {
if (id==null){
throw new ApiException(ErrorCodeEnum.PARAMS_EXCEPTION.getCode(),ErrorCodeEnum.PARAMS_EXCEPTION.getMessage());
}
InterfaceVo interfaceVo = interfaceService.getInterfaceById(id);
ResponseEntityDto<InterfaceVo> ruleResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(interfaceVo);
return ruleResponseEntityDto;
}
//测试http请求，并获得响应
@PostMapping("getHttpResponse")
public ResponseEntityDto getHttpResponse(@RequestBody InterfaceInfo interfaceInfo) {
String result = interfaceService.getHttpResponse(interfaceInfo);
ResponseEntityDto interfaceResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(result);
return interfaceResponseEntityDto;
}
//查询所有接口
@PostMapping("getInterfaceList")
public ResponseEntityDto getInterfaceList(@RequestBody QueryListParam<InterfaceInfo> param) {
// PageBean<InterfaceVo> pageBean = interfaceService.pageQuery(param.getPageNo(), param.getPageSize());
// ResponseEntityDto ruleResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(pageBean);
PageInfo pageInfo = interfaceService.queryByEntity(param);
HashMap<String, Object> responseMap = new HashMap<>();
responseMap.put("pageInfo",pageInfo);
responseMap.put("klist",pageInfo.getList());
pageInfo.setList(null);
ResponseEntityDto interfaceResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(responseMap);
return interfaceResponseEntityDto;
}
//添加接口
@PostMapping("addInterface")
@ArchivesLog(operationType = OpTypeConst.ADD_INTERFACE)
public ResponseEntityDto<InterfaceVo> addInterface(@RequestBody InterfaceVo interfaceVo ) {
InterfaceVo insert = interfaceService.inserInterfaceInfo(interfaceVo);
ResponseEntityDto<InterfaceVo> ruleResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(insert);
return ruleResponseEntityDto;
}
//删除接口
@PostMapping("deleteInterface")
@ArchivesLog(operationType = OpTypeConst.DELETE_INTERFACE)
public ResponseEntityDto<Boolean> deleteInterface(@RequestBody InterfaceVo interfaceVo ) {
Boolean bool = interfaceService.deleteInterfaceInfo(interfaceVo);
ResponseEntityDto<Boolean> ruleResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(bool);
return ruleResponseEntityDto;
}
//编辑接口
@PostMapping("updateInterface")
@ArchivesLog(operationType = OpTypeConst.UPDATE_INTERFACE)
public ResponseEntityDto<InterfaceVo> updateInterface(@RequestBody InterfaceVo interfaceVo ) {
InterfaceVo insert = interfaceService.updateInterfaceInfo(interfaceVo);
ResponseEntityDto<InterfaceVo> ruleResponseEntityDto = ResponseEntityBuilder.buildNormalResponse(insert);
return ruleResponseEntityDto;
}
//批量更新接口状态
@PostMapping("updateInterfaceStatus")
@ArchivesLog(operationType = OpTypeConst.UPDATE_INTERFACE_STATUS)
public ResponseEntityDto updateStatus(@RequestBody InterfaceUpdateStatusParam param) {
Long[] ids = param.getIds();
Integer status = param.getStatus();
if (ids==null||ids.length==0||status==null){
throw new ApiException(ErrorCodeEnum.PARAMS_EXCEPTION.getCode(),ErrorCodeEnum.PARAMS_EXCEPTION.getMessage());
}
boolean updateResult = interfaceService.updateStatus(ids, status);
if (updateResult){
return ResponseEntityBuilder.buildNormalResponse(updateResult);
}else {
return ResponseEntityBuilder.buildErrorResponse(ErrorCodeEnum.SERVER_ERROR);
}
}
}

18
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/mapper/InterfaceMapper.java Normal file
View File

@@ -0,0 +1,18 @@
package com.risk.riskmanage.interfacemanage.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.risk.riskmanage.interfacemanage.model.InterfaceInfo;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@Mapper
public interface InterfaceMapper extends BaseMapper<InterfaceInfo> {
int updateStatus(@Param(value = "ids") Long[] ids, @Param(value = "status") Integer status);
List<InterfaceInfo> queryInterfaceList(InterfaceInfo interfaceInfo);
List<InterfaceInfo> queryLimit(@Param(value = "start")int start, @Param(value = "size")int size);
}

61
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/model/InterfaceInfo.java Normal file
View File

@@ -0,0 +1,61 @@
package com.risk.riskmanage.interfacemanage.model;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.util.Date;
@Data
@NoArgsConstructor
@AllArgsConstructor
@Accessors
@TableName("t_field_interface")
public class InterfaceInfo implements Serializable {
private static final long serialVersionUID = 1L;
@TableId(type = IdType.AUTO)
private Integer id; //接口id
private String name; //接口名称
private String url; //请求地址
private String method; //请求方法
private String requestHeaders; //请求体类型
private String requestBody; //请求参数体
private String bindParam; //绑定参数
private String responseBody; //请求响应体
private Long creator; //创建者
private Long modifier; //修改者
private Long organId; //企业编号
private Integer status; //请求状态
private Date createTime; //创建时间
private Date updateTime; //更新时间
private String requestType;
@TableField(exist = false)
private String username; //用户名
}

22
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/model/request/InterfaceListParam.java Normal file
View File

@@ -0,0 +1,22 @@
package com.risk.riskmanage.interfacemanage.model.request;
import com.risk.riskmanage.interfacemanage.model.InterfaceInfo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class InterfaceListParam {
protected Integer pageNo = 1; // 第几页
protected Integer pageSize = 10; // 每页的数量
// protected Boolean search = false; // 是否搜索
protected InterfaceInfo interfaceInfo;//查询实体对象
// protected Integer parentId = 0; // 文件夹的id
}

15
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/model/request/InterfaceUpdateParent.java Normal file
View File

@@ -0,0 +1,15 @@
package com.risk.riskmanage.interfacemanage.model.request;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Accessors
public class InterfaceUpdateParent {
private Long[] ids;//规则id
private Long parentId;//文件夹id
}

16
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/model/request/InterfaceUpdateStatusParam.java Normal file
View File

@@ -0,0 +1,16 @@
package com.risk.riskmanage.interfacemanage.model.request;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Accessors
public class InterfaceUpdateStatusParam {
private Long[] ids;//id
private Integer status;//状态
}

64
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/model/vo/InterfaceVo.java Normal file
View File

@@ -0,0 +1,64 @@
package com.risk.riskmanage.interfacemanage.model.vo;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.util.Date;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Accessors
@TableName("t_field_interface")
public class InterfaceVo implements Serializable {
private static final long serialVersionUID = 1L;
private Integer id; //接口id
private String name; //接口名称
private String url; //请求地址
private String method; //请求方法
private String requestHeaders; //请求体类型
private String requestBody; //请求参数体
private String bindParam; //绑定参数
private String responseBody; //请求响应体
private Long creator; //创建者
private Long modifier; //修改者
private Long organId; //企业编号
private Long status; //请求状态
private Date createTime; //创建时间
private Date updateTime; //更新时间
private String requestType;
@TableField(exist = false)
private String username; //用户名
@TableField(exist = false)
private String creatorName; //创建者姓名
@TableField(exist = false)
private String modifierName; //修改者姓名
}

31
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/service/InterfaceService.java Normal file
View File

@@ -0,0 +1,31 @@
package com.risk.riskmanage.interfacemanage.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.github.pagehelper.PageInfo;
import com.risk.riskmanage.common.model.requestParam.QueryListParam;
import com.risk.riskmanage.interfacemanage.model.InterfaceInfo;
import com.risk.riskmanage.interfacemanage.model.request.InterfaceListParam;
import com.risk.riskmanage.interfacemanage.model.vo.InterfaceVo;
public interface InterfaceService extends IService<InterfaceInfo> {
InterfaceVo getInterfaceById(Long id);
// Map<String, Object> getInterfaceList(PageDto pageDto);
PageInfo queryByEntity( QueryListParam<InterfaceInfo> param);
InterfaceVo inserInterfaceInfo(InterfaceVo interfaceVo);
InterfaceVo updateInterfaceInfo(InterfaceVo interfaceVo);
//更新接口
boolean updateStatus(Long[] ids, Integer status);
//删除接口
Boolean deleteInterfaceInfo(InterfaceVo interfaceVo);
// public PageBean<InterfaceVo> pageQuery(int currentPage, int pageSize);
//http请求
String getHttpResponse(InterfaceInfo interfaceInfo);
}

207
jar-enginex-manager/src/main/java/com/risk/riskmanage/interfacemanage/service/impl/InterfaceServiceImpl.java Normal file
View File

@@ -0,0 +1,207 @@
package com.risk.riskmanage.interfacemanage.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.risk.riskmanage.common.enums.ErrorCodeEnum;
import com.risk.riskmanage.common.exception.ApiException;
import com.risk.riskmanage.common.model.requestParam.QueryListParam;
import com.risk.riskmanage.interfacemanage.mapper.InterfaceMapper;
import com.risk.riskmanage.interfacemanage.model.InterfaceInfo;
import com.risk.riskmanage.interfacemanage.model.request.InterfaceListParam;
import com.risk.riskmanage.interfacemanage.model.vo.InterfaceVo;
import com.risk.riskmanage.interfacemanage.service.InterfaceService;
import com.risk.riskmanage.system.mapper.UserMapper;
import com.risk.riskmanage.system.model.User;
import com.risk.riskmanage.util.SessionManager;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
@Service
public class InterfaceServiceImpl extends ServiceImpl<InterfaceMapper,InterfaceInfo> implements InterfaceService {
@Resource
InterfaceMapper interfaceMapper;
@Resource
UserMapper userMapper;
@Autowired
private RestTemplate restTemplate;
@Value("${runner.url}")
private String runnerUrl;
@Override
public String getHttpResponse(InterfaceInfo interfaceInfo) {
HttpHeaders httpHeaders = new HttpHeaders();
// 设置请求头
httpHeaders.setContentType(MediaType.APPLICATION_JSON);
// 封装请求体
JSONObject body = JSONObject.parseObject(JSONObject.toJSONString(interfaceInfo));
// 封装参数和头信息
HttpEntity<JSONObject> httpEntity = new HttpEntity(body, httpHeaders);
String url = runnerUrl + "/manager/invokeInterface";
ResponseEntity<String> responseEntity = restTemplate.postForEntity(url, httpEntity, String.class);
return responseEntity.getBody();
}
@Override
public Boolean deleteInterfaceInfo(InterfaceVo interfaceVo) {
interfaceMapper.deleteById(interfaceVo.getId());
return true;
}
@Override
public InterfaceVo updateInterfaceInfo(InterfaceVo interfaceVo) {
InterfaceInfo interfaceInfo = new InterfaceInfo();
BeanUtils.copyProperties(interfaceVo,interfaceInfo);
User user = SessionManager.getLoginAccount();
//设置创建者和修改者id
interfaceInfo.setModifier(user.getUserId());
interfaceMapper.updateById(interfaceInfo);
return interfaceVo;
}
@Override
@Transactional
public boolean updateStatus(Long[] ids, Integer status) {
int updateNum = interfaceMapper.updateStatus(ids, status);
if (updateNum>0){
return true;
}
return false;
}
//添加接口信息
@Override
public InterfaceVo inserInterfaceInfo(InterfaceVo interfaceVo) {
//拷贝VO到Info对象
InterfaceInfo interfaceInfo = new InterfaceInfo();
BeanUtils.copyProperties(interfaceVo, interfaceInfo);
User user = SessionManager.getLoginAccount();
//设置创建者和修改者id
interfaceInfo.setCreator(user.getUserId());
interfaceInfo.setModifier(user.getUserId());
interfaceInfo.setOrganId(user.getOrganId());
interfaceInfo.setStatus(1);
//插入并获取insert后实体对象返回id
boolean save = this.save(interfaceInfo);
if (!save) {
throw new ApiException(ErrorCodeEnum.INTERFACE_SAVE_ERROR.getCode(), ErrorCodeEnum.INTERFACE_SAVE_ERROR.getMessage());
}
return interfaceVo;
}
@Override
public PageInfo queryByEntity(QueryListParam<InterfaceInfo> interfaceListParam) {
InterfaceInfo interfaceInfo = interfaceListParam.getEntity();
Integer pageNo = interfaceListParam.getPageNum();
Integer pageSize = interfaceListParam.getPageSize();
if (pageNo > 0 && pageSize > 0) {
PageHelper.startPage(pageNo, pageSize);
}
Wrapper<InterfaceInfo> wrapper = createWrapper(interfaceListParam.getEntity());
List<InterfaceInfo> interfaceList = interfaceMapper.selectList(wrapper);
PageInfo pageInfo = new PageInfo(interfaceList);
// 级联操作完成拼装
List<InterfaceVo> interfaceVos = new ArrayList<>();
User user = SessionManager.getLoginAccount();
for(InterfaceInfo info: interfaceList){
InterfaceVo interfaceVo = new InterfaceVo();
BeanUtils.copyProperties(info,interfaceVo);
interfaceVo.setUsername(user.getNickName());
//设置创建者昵称
interfaceVo.setCreatorName(userMapper.findNickNameById(info.getCreator()));
//设置修改者昵称
interfaceVo.setModifierName(userMapper.findNickNameById(info.getModifier()));
interfaceVos.add(interfaceVo);
}
pageInfo.setList(interfaceVos);
return pageInfo;
}
@Override
public InterfaceVo getInterfaceById(Long id) {
InterfaceInfo info = interfaceMapper.selectById(id);
InterfaceVo interfaceVo = new InterfaceVo();
BeanUtils.copyProperties(info,interfaceVo);
User user = SessionManager.getLoginAccount();
interfaceVo.setUsername(user.getNickName());
//设置创建者昵称
interfaceVo.setCreatorName(userMapper.findNickNameById(info.getCreator()));
//设置修改者昵称
interfaceVo.setModifierName(userMapper.findNickNameById(info.getModifier()));
return interfaceVo;
}
//新插入数据的准备工作
// private InterfaceVo initParam(InterfaceVo interfaceVo) {
// //加入用户信息
// User user = SessionManager.getLoginAccount();
// interfaceVo.setOrganId(user.getOrganId());
// interfaceVo.setUsername(user.getNickName());
//
// return interfaceVo;
// }
//唯一性检查
private boolean checkUniqueness(InterfaceVo vo) {
InterfaceInfo interfaceInfo = new InterfaceInfo();
interfaceInfo.setName(vo.getName());
InterfaceInfo info = this.getOne(new QueryWrapper<>(interfaceInfo));
if (info != null) {
throw new ApiException(ErrorCodeEnum.INTERFACE_NAME_REPEAT.getCode(), ErrorCodeEnum.INTERFACE_NAME_REPEAT.getMessage());
}
return true;
}
//创建查询器
private Wrapper<InterfaceInfo> createWrapper(InterfaceInfo query){
LambdaQueryWrapper<InterfaceInfo> wrapper = new LambdaQueryWrapper<>();
if (query!=null){
if (StringUtils.isNotBlank(query.getName())){
wrapper.like(InterfaceInfo::getName,query.getName());
}
if (StringUtils.isNotBlank(query.getMethod())){
wrapper.eq(InterfaceInfo::getMethod,query.getMethod());
}
if (StringUtils.isNotBlank(query.getUrl())){
wrapper.eq(InterfaceInfo::getUrl,query.getUrl());
}
if (query.getStatus()!=null){
wrapper.eq(InterfaceInfo::getStatus,query.getStatus());
}else {
wrapper.ne(InterfaceInfo::getStatus,-1);
}
}else {
wrapper.ne(InterfaceInfo::getStatus,-1);
}
wrapper.orderByDesc(InterfaceInfo::getId);
return wrapper;
}
}