Skip to content

M
map-parent
Commit 282a8582 by yangyang
Options

重庆服务管理提交(重庆)

parent d4713d21
Showing with 166 additions and 22 deletions
common/common_utils/src/main/java/com/founder/commonutils/model/thirdEntity/TokenThirdParams.java 0 → 100644
package com.founder.commonutils.model.thirdEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
/**
* @author yangyang
* @create 2022/12/07
*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@ApiModel(value="TokenThirdParams对象", description="第三方token获取")
public class TokenThirdParams {
@ApiModelProperty(value = "用户名")
private String username;
@ApiModelProperty(value = "appid")
private String appid;
}
common/service_base/src/main/java/com/founder/servicebase/config/Knife4jConfig.java
......@@ -4,23 +4,32 @@ package com.founder.servicebase.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import springfox.documentation.builders.ApiInfoBuilder;
import springfox.documentation.builders.ParameterBuilder;
import springfox.documentation.builders.PathSelectors;
import springfox.documentation.builders.RequestHandlerSelectors;
import springfox.documentation.schema.ModelRef;
import springfox.documentation.service.ApiInfo;
import springfox.documentation.service.Contact;
import springfox.documentation.spi.DocumentationType;
import springfox.documentation.spring.web.plugins.Docket;
import springfox.documentation.swagger2.annotations.EnableSwagger2;
import java.util.ArrayList;
import java.util.List;
@Configuration
@EnableSwagger2
public class Knife4jConfig {
public static final String publicapiApi = "com.founder.publicapi";
public static final String publicapiApi = "com.founder.publicapi.controller.cqService";
public static final String publicapiApitoken = "com.founder.publicapi.controller.cqTokenService";
@Bean
public Docket tokenApi() {
return new Docket(DocumentationType.SWAGGER_2)
.groupName("token")
.useDefaultResponseMessages(false)
.apiInfo(apiInfo())
.select()
.apis(RequestHandlerSelectors.basePackage(publicapiApitoken))
.paths(PathSelectors.any())
.build();
}
@Bean
public Docket zdryApi() {
/* //添加head参数配置start
......@@ -40,12 +49,13 @@ public class Knife4jConfig {
/*.globalOperationParameters(pars)*/;
}
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
.title("实战分析中心API文档")
.description("本文档描述了实战分析微服务接口定义")
.version("1.0")
.contact(new Contact("java", "http://founder.com", "chentian@founder.com"))
.contact(new Contact("java", "http://founder.com", "@founder.com"))
.build();
}
......
common/service_base/src/main/java/com/founder/servicebase/controller/SkServiceApplyController.java
......@@ -9,11 +9,13 @@ import com.founder.commonutils.model.newPublicEntity.MapRestResult;
import com.founder.commonutils.model.newPublicEntity.SkService;
import com.founder.commonutils.model.newPublicEntity.SkServiceApply;
import com.founder.commonutils.model.newPublicEntity.ThirdToken;
import com.founder.commonutils.model.thirdEntity.TokenThirdParams;
import com.founder.commonutils.model.vo.param.SkServiceApplyParam;
import com.founder.commonutils.model.vo.response.SkServiceApplyVO;
import com.founder.commonutils.util.ExportExcelUtil;
import com.founder.commonutils.util.JwtUser;
import com.founder.commonutils.util.KeyUtil;
import com.founder.commonutils.util.NetworkUtil;
import com.founder.servicebase.logs.OperLog;
import com.founder.servicebase.logs.OperationType;
import com.founder.servicebase.service.SkServiceApplyService;
......@@ -29,10 +31,13 @@ import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;
import static com.founder.commonutils.util.AesEncryptUtil.encrypt;
/**
* 服务授权表(SkServiceApply)表控制层
*
......@@ -61,8 +66,8 @@ public class SkServiceApplyController extends ApiController {
@OperLog(message = "新增服务授权信息", operation = OperationType.ADD)
public MapRestResult save(SkServiceApply skService) throws IOException {
skService.setXxzjbh(KeyUtil.getUUIDKey("SQ"));
//时间不能为空 这块前端做校验去了
skService.setSqsj(new Date());
boolean save = skServiceApplyService.save(skService);
if (save) {
return new MapRestResult();
......@@ -82,7 +87,7 @@ public class SkServiceApplyController extends ApiController {
if (update) {
return new MapRestResult();
} else {
return new MapRestResult().error("更新失败");
return new MapRestResult(200,"更新失败",null);
}
}
......@@ -90,26 +95,37 @@ public class SkServiceApplyController extends ApiController {
@PostMapping("apply")
@ApiOperation(value = "给服务授权或撤销")
@OperLog(message = "给服务授权或撤销", operation = OperationType.UPDATE)
public MapRestResult apply(SkServiceApply skRegionalsResult, String servicename) throws Exception {
public MapRestResult apply(SkServiceApply skServiceApply, String servicename) throws Exception {
UpdateWrapper updateWrapper = new UpdateWrapper();
updateWrapper.eq("xxzjbh", skRegionalsResult.getXxzjbh());
updateWrapper.eq("xxzjbh", skServiceApply.getXxzjbh());
String message="";
if ("0".equals(skRegionalsResult.getStatus())) {//撤销
if ("0".equals(skServiceApply.getStatus())) {//撤销
updateWrapper.set("token", null);
updateWrapper.set("ssqsj", null);
message="撤销成功";
} else if ("1".equals(skRegionalsResult.getStatus())) {//授权
ThirdToken thirdToken=new ThirdToken(servicename,skRegionalsResult.getApplygs(),skRegionalsResult.getApplyurl());
JSONObject jsonObject = (JSONObject)JSONObject.toJSON(thirdToken);
String token = jwtUser.createJWT(jsonObject.toString(),Long.parseLong(skRegionalsResult.getTime()));
} else if ("1".equals(skServiceApply.getStatus())) {//授权
ThirdToken thirdToken=new ThirdToken(servicename,skServiceApply.getApplygs(),skServiceApply.getApplyurl());
// 公司名称 username appid通过使用AES-128-CBC加密模式
Date now = new Date();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMdd");
String today = simpleDateFormat.format(now);
String KEY = "maplogin" + today;
String IV = "map_vues" + today;
String username = encrypt(thirdToken.getGsNama(), KEY, IV);
String appid = encrypt(thirdToken.getGsNama()+"third", KEY, IV);
JSONObject jsonObject = new JSONObject();
jsonObject.put("username",username);
jsonObject.put("appid",appid);
message="授权成功";
updateWrapper.set("token",token);
updateWrapper.set("token",JSONObject.toJSONString(jsonObject));
updateWrapper.set("ssqsj",new Date());
}
updateWrapper.set("status",skRegionalsResult.getStatus());
boolean update = skServiceApplyService.update(skRegionalsResult, updateWrapper);
updateWrapper.set("status",skServiceApply.getStatus());
boolean update = skServiceApplyService.update(skServiceApply, updateWrapper);
if (update) {
return new MapRestResult(message);
} else {
return new MapRestResult().error("更新失败");
return new MapRestResult(200,"更新失败",null);
}
}
......@@ -138,7 +154,7 @@ public class SkServiceApplyController extends ApiController {
public MapRestResult detail(String xxzjbh) {
SkServiceApply byId = skServiceApplyService.getById(xxzjbh);
if (byId == null) {
return new MapRestResult().error("不存在该数据");
return new MapRestResult(200,"不存在该数据",null);
} else {
QueryWrapper queryWrapper=new QueryWrapper();
queryWrapper.select("serviceName","serviceMs");
......@@ -162,6 +178,7 @@ public class SkServiceApplyController extends ApiController {
return new MapRestResult(200, "OK", count, list);
}
/**
* 服务授权列表信息导出
*/
......@@ -191,7 +208,34 @@ public class SkServiceApplyController extends ApiController {
String[] headersName = {"服务名称","服务描述","申请公司","申请ip","申请时效","token值","备注"};
String[] headersField = {"servicename","servicems","applygs","applyurl","time","token","content"};
exportExcelUtil.exportExcel("DataStatistics", headersName, headersField, list, response,"服务授权列表信息");
}
@PostMapping("getThirdToken")
@ApiOperation(value = "获取三方token")
public MapRestResult getThirdToken(@RequestBody TokenThirdParams tokenThirdParams) {
String token = null;
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("token", JSONObject.toJSONString(tokenThirdParams));
SkServiceApply skServiceApply = skServiceApplyService.getOne(queryWrapper);
if (null == skServiceApply) {
return new MapRestResult(201, "error", 1, "无该用户!");
} else {
QueryWrapper queryWrapper1 = new QueryWrapper();
queryWrapper1.eq("xxzjbh", skServiceApply.getServiceid());
SkService skService = service.getOne(queryWrapper1);
if (null != skService) {
ThirdToken thirdToken = new ThirdToken(skService.getServicename(),skServiceApply.getApplygs(),skServiceApply.getApplyurl());
JSONObject jsonObject = (JSONObject)JSONObject.toJSON(thirdToken);
try {
token = jwtUser.createJWT(jsonObject.toString(),1000 * 60 * 60 * 24);// 24小时失效
} catch (Exception e) {
e.printStackTrace();
}
}else{
return new MapRestResult(201, "error", 1, "token获取失败!");
}
}
return new MapRestResult(200, "OK", 1, token);
}
}
service/publicapi/src/main/java/com/founder/publicapi/controller/cqService/CqController.java
......@@ -26,7 +26,7 @@ import java.io.BufferedInputStream;
import java.io.InputStream;
@Api(tags = "市局接口管理(供第三方公司使用)重庆")
@Api(tags = "刑侦服务")
@RestController
@RequestMapping("/fhdaas")
public class CqController {
......
service/publicapi/src/main/java/com/founder/publicapi/controller/cqTokenService/CqTokenController.java 0 → 100644
package com.founder.publicapi.controller.cqTokenService;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.founder.commonutils.model.newPublicEntity.MapRestResult;
import com.founder.commonutils.model.newPublicEntity.SkService;
import com.founder.commonutils.model.newPublicEntity.SkServiceApply;
import com.founder.commonutils.model.newPublicEntity.ThirdToken;
import com.founder.commonutils.model.thirdEntity.TokenThirdParams;
import com.founder.commonutils.util.JwtUser;
import com.founder.servicebase.service.SkServiceApplyService;
import com.founder.servicebase.service.SkServiceService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
@Api(tags = "刑侦服务token")
@RestController
@RequestMapping("/token")
public class CqTokenController {
/**
* 服务授权对象
*/
@Resource
private SkServiceApplyService skServiceApplyService;
@Autowired
private SkServiceService service;
private JwtUser jwtUser = new JwtUser();
@PostMapping("getThirdToken")
@ApiOperation(value = "获取三方token")
public MapRestResult getThirdToken(@RequestBody TokenThirdParams tokenThirdParams) {
String token = null;
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("token", JSONObject.toJSONString(tokenThirdParams));
SkServiceApply skServiceApply = skServiceApplyService.getOne(queryWrapper);
if (null == skServiceApply) {
return new MapRestResult(201, "error", 1, "无该用户!");
} else {
QueryWrapper queryWrapper1 = new QueryWrapper();
queryWrapper1.eq("xxzjbh", skServiceApply.getServiceid());
SkService skService = service.getOne(queryWrapper1);
if (null != skService) {
ThirdToken thirdToken = new ThirdToken(skService.getServicename(),skServiceApply.getApplygs(),skServiceApply.getApplyurl());
JSONObject jsonObject = (JSONObject)JSONObject.toJSON(thirdToken);
try {
token = jwtUser.createJWT(jsonObject.toString(),1000 * 60 * 60 * 24);// 24小时失效
} catch (Exception e) {
e.printStackTrace();
}
}else{
return new MapRestResult(201, "error", 1, "token获取失败!");
}
}
return new MapRestResult(200, "OK", 1, token);
}
}
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