Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
M
map-parent
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
常超
map-parent
Commits
6e9eca2a
Commit
6e9eca2a
authored
Dec 20, 2022
by
宋珺琪
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
服务概述接口、api返回结果修改
parent
290245f0
Show whitespace changes
Inline
Side-by-side
Showing
11 changed files
with
511 additions
and
10 deletions
+511
-10
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/PortEntity.java
+54
-0
common/common_utils/src/main/java/com/founder/commonutils/util/HttpUtil.java
+114
-2
common/service_base/src/main/java/com/founder/servicebase/controller/SysUserController.java
+1
-1
common/service_base/src/main/java/com/founder/servicebase/service/serviceimpl/SkServiceApplyServiceImpl.java
+9
-1
service/publicapi/src/main/java/com/founder/publicapi/controller/ApprovalService/UserController.java
+1
-1
service/publicapi/src/main/java/com/founder/publicapi/controller/PortServiceController/PortController.java
+314
-0
service/publicapi/src/main/java/com/founder/publicapi/controller/SkDataOperation/SkServiceSqController.java
+3
-0
service/publicapi/src/main/java/com/founder/publicapi/controller/SkModelService/SkbsController.java
+4
-2
service/publicapi/src/main/java/com/founder/publicapi/controller/hnksh/HnTbStRygxController.java
+2
-2
service/publicapi/src/main/java/com/founder/publicapi/mapper/mysqlMapper/PortMapper.java
+8
-0
service/publicapi/src/main/java/com/founder/publicapi/service/serviceimpl/SpxxServiceImpl.java
+1
-1
No files found.
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/PortEntity.java
0 → 100644
View file @
6e9eca2a
package
com
.
founder
.
commonutils
.
model
.
newPublicEntity
;
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
io.swagger.annotations.ApiModel
;
import
lombok.Data
;
@Data
@TableName
(
"sk_Interface"
)
@ApiModel
(
value
=
"服务概述接口表"
,
description
=
""
)
public
class
PortEntity
{
@TableId
(
type
=
IdType
.
INPUT
)
@TableField
(
"id"
)
private
String
id
;
@TableField
(
"first_module"
)
private
String
firstModule
;
@TableField
(
"second_module"
)
private
String
secondModule
;
@TableField
(
"api_name"
)
private
String
apiName
;
@TableField
(
"url"
)
private
String
url
;
@TableField
(
"method"
)
private
String
method
;
@TableField
(
"headers"
)
private
String
headers
;
@TableField
(
"default_params"
)
private
String
defaultParams
;
@TableField
(
"call_time"
)
private
String
callTime
;
@TableField
(
"return_param"
)
private
String
returnParam
;
@TableField
(
"state"
)
private
String
state
;
// 0未成功 1成功
@TableField
(
"is_delete"
)
private
String
isDelete
;
//0未删除 1删除
}
common/common_utils/src/main/java/com/founder/commonutils/util/HttpUtil.java
View file @
6e9eca2a
package
com
.
founder
.
commonutils
.
util
;
package
com
.
founder
.
commonutils
.
util
;
import
org.apache.cxf.helpers.IOUtils
;
import
org.apache.http.HttpEntity
;
import
org.apache.http.HttpEntity
;
import
org.apache.http.HttpResponse
;
import
org.apache.http.HttpResponse
;
import
org.apache.http.NameValuePair
;
import
org.apache.http.NameValuePair
;
import
org.apache.http.client.ClientProtocolException
;
import
org.apache.http.client.ClientProtocolException
;
import
org.apache.http.client.HttpClient
;
import
org.apache.http.client.HttpClient
;
import
org.apache.http.client.config.RequestConfig
;
import
org.apache.http.client.entity.UrlEncodedFormEntity
;
import
org.apache.http.client.entity.UrlEncodedFormEntity
;
import
org.apache.http.client.methods.CloseableHttpResponse
;
import
org.apache.http.client.methods.CloseableHttpResponse
;
import
org.apache.http.client.methods.HttpGet
;
import
org.apache.http.client.methods.HttpGet
;
import
org.apache.http.client.methods.HttpPost
;
import
org.apache.http.client.methods.HttpPost
;
import
org.apache.http.client.params.ClientPNames
;
import
org.apache.http.client.params.ClientPNames
;
import
org.apache.http.client.utils.URIBuilder
;
import
org.apache.http.entity.ContentType
;
import
org.apache.http.entity.ContentType
;
import
org.apache.http.entity.InputStreamEntity
;
import
org.apache.http.entity.InputStreamEntity
;
import
org.apache.http.entity.StringEntity
;
import
org.apache.http.entity.StringEntity
;
...
@@ -23,6 +26,11 @@ import org.apache.http.params.HttpParams;
...
@@ -23,6 +26,11 @@ import org.apache.http.params.HttpParams;
import
org.apache.http.util.EntityUtils
;
import
org.apache.http.util.EntityUtils
;
import
java.io.*
;
import
java.io.*
;
import
java.net.HttpURLConnection
;
import
java.net.URISyntaxException
;
import
java.net.URL
;
import
java.nio.charset.StandardCharsets
;
import
java.text.SimpleDateFormat
;
import
java.util.*
;
import
java.util.*
;
import
java.util.Map.Entry
;
import
java.util.Map.Entry
;
...
@@ -281,7 +289,7 @@ public class HttpUtil {
...
@@ -281,7 +289,7 @@ public class HttpUtil {
return
resultString
;
return
resultString
;
}
}
/*
public static void main(String[] args) {
public static void main(String[] args) {
try {
try {
Date date1=new Date();
Date date1=new Date();
...
@@ -305,7 +313,7 @@ public class HttpUtil {
...
@@ -305,7 +313,7 @@ public class HttpUtil {
// TODO Auto-generated catch block
// TODO Auto-generated catch block
e.printStackTrace();
e.printStackTrace();
}
}
}
}
*/
// 全国常口请求得到XML
// 全国常口请求得到XML
public
static
String
doGetQg
(
String
uri
)
{
public
static
String
doGetQg
(
String
uri
)
{
HttpClient
httpclient
=
new
DefaultHttpClient
();
HttpClient
httpclient
=
new
DefaultHttpClient
();
...
@@ -397,4 +405,108 @@ public class HttpUtil {
...
@@ -397,4 +405,108 @@ public class HttpUtil {
public
static
boolean
ckeckEmpty
(
String
string
)
{
public
static
boolean
ckeckEmpty
(
String
string
)
{
return
(
null
==
string
)
||
(
""
.
equals
(
string
));
return
(
null
==
string
)
||
(
""
.
equals
(
string
));
}
}
public
static
String
fwdoPost
(
String
url
,
Map
<
String
,
String
>
map
,
String
token
)
throws
Exception
{
String
result
=
""
;
CloseableHttpClient
client
=
null
;
CloseableHttpResponse
response
=
null
;
RequestConfig
defaultRequestConfig
=
RequestConfig
.
custom
().
setSocketTimeout
(
550000
).
setConnectTimeout
(
550000
)
.
setConnectionRequestTimeout
(
550000
).
setStaleConnectionCheckEnabled
(
true
).
build
();
client
=
HttpClients
.
custom
().
setDefaultRequestConfig
(
defaultRequestConfig
).
build
();
// client = HttpClients.createDefault();
URIBuilder
uriBuilder
=
new
URIBuilder
(
url
);
HttpPost
httpPost
=
new
HttpPost
(
uriBuilder
.
build
());
httpPost
.
setHeader
(
"Connection"
,
"Keep-Alive"
);
httpPost
.
setHeader
(
"Charset"
,
"UTF-8"
);
httpPost
.
setHeader
(
"Content-Type"
,
"application/x-www-form-urlencoded"
);
httpPost
.
setHeader
(
"Authorization"
,
token
);
Iterator
<
Entry
<
String
,
String
>>
it
=
map
.
entrySet
().
iterator
();
List
<
NameValuePair
>
params
=
new
ArrayList
<
NameValuePair
>();
while
(
it
.
hasNext
())
{
Map
.
Entry
<
String
,
String
>
entry
=
it
.
next
();
NameValuePair
pair
=
new
BasicNameValuePair
(
entry
.
getKey
(),
entry
.
getValue
());
params
.
add
(
pair
);
}
httpPost
.
setEntity
(
new
UrlEncodedFormEntity
(
params
,
"UTF-8"
));
try
{
response
=
client
.
execute
(
httpPost
);
if
(
response
!=
null
)
{
HttpEntity
resEntity
=
response
.
getEntity
();
if
(
resEntity
!=
null
)
{
result
=
EntityUtils
.
toString
(
resEntity
,
"UTF-8"
);
}
}
}
catch
(
ClientProtocolException
e
)
{
throw
new
RuntimeException
(
"创建连接失败"
+
e
);
}
catch
(
IOException
e
)
{
throw
new
RuntimeException
(
"创建连接失败"
+
e
);
}
return
result
;
}
public
static
String
fwdoPostJson
(
String
url
,
String
json
,
String
token
)
{
// 创建Httpclient对象
CloseableHttpClient
httpClient
=
HttpClients
.
createDefault
();
CloseableHttpResponse
response
=
null
;
String
resultString
=
""
;
try
{
// 创建Http Post请求
HttpPost
httpPost
=
new
HttpPost
(
url
);
// 创建请求内容
StringEntity
entity
=
new
StringEntity
(
json
,
ContentType
.
APPLICATION_JSON
);
httpPost
.
setEntity
(
entity
);
httpPost
.
setHeader
(
"Authorization"
,
token
);
// 执行http请求
response
=
httpClient
.
execute
(
httpPost
);
resultString
=
EntityUtils
.
toString
(
response
.
getEntity
(),
"utf-8"
);
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
}
finally
{
try
{
response
.
close
();
}
catch
(
IOException
e
)
{
// TODO Auto-generated catch block
e
.
printStackTrace
();
}
}
return
resultString
;
}
public
static
String
fwdoGet
(
String
url
,
Map
<
String
,
String
>
params
,
String
token
)
{
String
apiUrl
=
url
;
StringBuffer
param
=
new
StringBuffer
();
int
i
=
0
;
for
(
String
key
:
params
.
keySet
())
{
if
(
i
==
0
)
param
.
append
(
"?"
);
else
param
.
append
(
"&"
);
param
.
append
(
key
).
append
(
"="
).
append
(
params
.
get
(
key
));
i
++;
}
apiUrl
+=
param
;
String
result
=
null
;
HttpClient
httpClient
=
null
;
httpClient
=
HttpClients
.
createDefault
();
try
{
HttpGet
httpGet
=
new
HttpGet
(
apiUrl
);
httpGet
.
setHeader
(
"Authorization"
,
token
);
HttpResponse
response
=
httpClient
.
execute
(
httpGet
);
HttpEntity
entity
=
response
.
getEntity
();
if
(
entity
!=
null
)
{
InputStream
instream
=
entity
.
getContent
();
result
=
IOUtils
.
toString
(
instream
,
"UTF-8"
);
}
}
catch
(
IOException
e
)
{
e
.
printStackTrace
();
}
return
result
;
}
}
}
common/service_base/src/main/java/com/founder/servicebase/controller/SysUserController.java
View file @
6e9eca2a
...
@@ -116,7 +116,7 @@ public class SysUserController extends ApiController {
...
@@ -116,7 +116,7 @@ public class SysUserController extends ApiController {
queryWrapper
.
eq
(
"SCBZ"
,
0
);
queryWrapper
.
eq
(
"SCBZ"
,
0
);
SysUser
one
=
sysUserService
.
getOne
(
queryWrapper
);
SysUser
one
=
sysUserService
.
getOne
(
queryWrapper
);
if
(
one
==
null
)
{
if
(
one
==
null
)
{
return
MapRestResult
.
build
(
5
00
,
"该用户不存在"
,
null
);
return
MapRestResult
.
build
(
2
00
,
"该用户不存在"
,
null
);
}
}
// 拿到真实ip
// 拿到真实ip
one
.
setIp
(
NetworkUtil
.
getIpAddr
(
request
));
one
.
setIp
(
NetworkUtil
.
getIpAddr
(
request
));
...
...
common/service_base/src/main/java/com/founder/servicebase/service/serviceimpl/SkServiceApplyServiceImpl.java
View file @
6e9eca2a
...
@@ -7,6 +7,7 @@ import com.founder.commonutils.model.vo.param.SkServiceApplyParam;
...
@@ -7,6 +7,7 @@ import com.founder.commonutils.model.vo.param.SkServiceApplyParam;
import
com.founder.commonutils.model.vo.response.SkServiceApplyVO
;
import
com.founder.commonutils.model.vo.response.SkServiceApplyVO
;
import
com.founder.servicebase.logs.mapper.mysqlMapper.SkServiceApplyMapper
;
import
com.founder.servicebase.logs.mapper.mysqlMapper.SkServiceApplyMapper
;
import
com.founder.servicebase.service.SkServiceApplyService
;
import
com.founder.servicebase.service.SkServiceApplyService
;
import
org.apache.commons.lang.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
...
@@ -31,8 +32,15 @@ public class SkServiceApplyServiceImpl extends ServiceImpl<SkServiceApplyMapper,
...
@@ -31,8 +32,15 @@ public class SkServiceApplyServiceImpl extends ServiceImpl<SkServiceApplyMapper,
int
count
=
baseMapper
.
count
(
skRegionalsDetailParam
);
int
count
=
baseMapper
.
count
(
skRegionalsDetailParam
);
skRegionalsDetailParam
.
setPage
((
skRegionalsDetailParam
.
getPage
()-
1
)*
skRegionalsDetailParam
.
getPageSize
());
skRegionalsDetailParam
.
setPage
((
skRegionalsDetailParam
.
getPage
()-
1
)*
skRegionalsDetailParam
.
getPageSize
());
List
<
SkServiceApplyVO
>
list
=
baseMapper
.
findAll
(
skRegionalsDetailParam
);
List
<
SkServiceApplyVO
>
list
=
baseMapper
.
findAll
(
skRegionalsDetailParam
);
if
(
list
==
null
){
map
.
put
(
"count"
,
0
);
map
.
put
(
"list"
,
""
);
return
map
;
}
//把数据为空的去掉
List
<
SkServiceApplyVO
>
collect
=
list
.
stream
().
filter
(
s
->
StringUtils
.
isNotBlank
(
s
.
getFlag
())
&&
StringUtils
.
isNotBlank
(
s
.
getServiceDeleted
())).
collect
(
Collectors
.
toList
());
// 拿出展示状态(服务申请),flag0代表不展示;服务删除标志serviceDeleted,将申请表Status置为3失效状态
// 拿出展示状态(服务申请),flag0代表不展示;服务删除标志serviceDeleted,将申请表Status置为3失效状态
List
<
SkServiceApplyVO
>
listFilter
=
lis
t
.
stream
().
filter
(
p
->
p
.
getFlag
().
equals
(
"0"
)||
p
.
getServiceDeleted
().
equals
(
"1"
)).
collect
(
Collectors
.
toList
());
List
<
SkServiceApplyVO
>
listFilter
=
collec
t
.
stream
().
filter
(
p
->
p
.
getFlag
().
equals
(
"0"
)||
p
.
getServiceDeleted
().
equals
(
"1"
)).
collect
(
Collectors
.
toList
());
listFilter
.
stream
().
forEach
(
p
->{
listFilter
.
stream
().
forEach
(
p
->{
SkServiceApply
skServiceApply
=
new
SkServiceApply
();
SkServiceApply
skServiceApply
=
new
SkServiceApply
();
p
.
setStatus
(
"3"
);
p
.
setStatus
(
"3"
);
...
...
service/publicapi/src/main/java/com/founder/publicapi/controller/ApprovalService/UserController.java
View file @
6e9eca2a
...
@@ -179,7 +179,7 @@ public class UserController {
...
@@ -179,7 +179,7 @@ public class UserController {
Map
<
String
,
Object
>
result
=
new
HashMap
<>();
Map
<
String
,
Object
>
result
=
new
HashMap
<>();
List
<
User
>
list
=
userService
.
getAllowAgentUsers
(
loginUserPoliceId
,
agentUserPoliceId
,
agentUserXm
);
List
<
User
>
list
=
userService
.
getAllowAgentUsers
(
loginUserPoliceId
,
agentUserPoliceId
,
agentUserXm
);
result
.
put
(
"msg"
,
"success"
);
result
.
put
(
"msg"
,
"success"
);
result
.
put
(
"status"
,
"200"
);
result
.
put
(
"status"
,
200
);
result
.
put
(
"data"
,
list
);
result
.
put
(
"data"
,
list
);
result
.
put
(
"count"
,
list
.
size
());
result
.
put
(
"count"
,
list
.
size
());
return
result
;
return
result
;
...
...
service/publicapi/src/main/java/com/founder/publicapi/controller/PortServiceController/PortController.java
0 → 100644
View file @
6e9eca2a
package
com
.
founder
.
publicapi
.
controller
.
PortServiceController
;
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.PortEntity
;
import
com.founder.commonutils.model.newPublicEntity.SysUser
;
import
com.founder.commonutils.model.newPublicEntity.Token
;
import
com.founder.commonutils.util.*
;
import
com.founder.publicapi.mapper.mysqlMapper.PortMapper
;
import
com.founder.servicebase.logs.OperLog
;
import
com.founder.servicebase.logs.OperationType
;
import
com.founder.servicebase.service.SysUserService
;
import
com.google.common.reflect.TypeToken
;
import
com.google.gson.Gson
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.apache.commons.lang.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.scheduling.annotation.Scheduled
;
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
;
import
java.lang.reflect.Type
;
import
java.text.SimpleDateFormat
;
import
java.util.*
;
import
java.util.stream.Collectors
;
import
static
com
.
founder
.
commonutils
.
util
.
AesEncryptUtil
.
desEncrypt
;
@RestController
@RequestMapping
(
"/portservive"
)
@Api
(
tags
=
"服务概述"
)
public
class
PortController
{
@Autowired
PortMapper
portMapper
;
@Resource
private
SysUserService
sysUserService
;
@Scheduled
(
cron
=
"0 0 01 * * ?"
)
public
void
poets
()
throws
Exception
{
QueryWrapper
<
PortEntity
>
wrapper
=
new
QueryWrapper
<>();
wrapper
.
eq
(
"is_delete"
,
"0"
);
List
<
PortEntity
>
portEntities
=
portMapper
.
selectList
(
wrapper
);
String
token
=
gettoken
(
"admin"
);
for
(
PortEntity
port
:
portEntities
)
{
if
(
StringUtils
.
isEmpty
(
port
.
getHeaders
())){
port
.
setHeaders
(
"application/json"
);
}
port
.
setState
(
"0"
);
if
(
!
port
.
getUrl
().
contains
(
"47.92.48.137:1003"
)){
port
.
setReturnParam
(
"接口不通"
);
port
.
setState
(
"2"
);
}
else
if
(
port
.
getUrl
().
contains
(
"export"
)
||
port
.
getUrl
().
contains
(
"Export"
)||
port
.
getApiName
().
equals
(
"上传文件"
)||
port
.
getApiName
().
equals
(
"下载文件"
)||
port
.
getApiName
().
equals
(
"消息群发"
)||
port
.
getApiName
().
equals
(
"消息单发"
)){
port
.
setState
(
"1"
);
}
else
{
if
(
port
.
getMethod
().
equals
(
"post"
)
&&
port
.
getHeaders
().
equals
(
"application/json"
))
{
String
s
=
HttpUtil
.
fwdoPostJson
(
port
.
getUrl
(),
port
.
getDefaultParams
(),
token
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)
||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
else
if
(
port
.
getMethod
().
equals
(
"post"
)
&&
port
.
getHeaders
().
equals
(
"form-data"
))
{
//String 转为Map
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
port
.
getDefaultParams
(),
type
);
System
.
out
.
println
(
result
);
String
s
=
HttpUtil
.
fwdoPost
(
port
.
getUrl
(),
result
,
token
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
else
if
(
port
.
getMethod
().
equals
(
"get"
)
&&
port
.
getHeaders
().
equals
(
"form-data"
))
{
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
port
.
getDefaultParams
(),
type
);
String
s
=
HttpUtil
.
fwdoGet
(
port
.
getUrl
(),
result
,
token
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
else
if
(
port
.
getMethod
().
equals
(
"post"
)
&&
port
.
getHeaders
().
equals
(
"x-www-form-urlencoded"
)){
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
port
.
getDefaultParams
(),
type
);
String
s
=
HttpUtil
.
fwdoPost
(
port
.
getUrl
(),
result
,
token
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
}
port
.
setCallTime
(
nowTime
());
portMapper
.
updateById
(
port
);
}
}
@PostMapping
(
"text"
)
public
MapRestResult
text
()
throws
Exception
{
QueryWrapper
<
PortEntity
>
wrapper
=
new
QueryWrapper
<>();
wrapper
.
eq
(
"is_delete"
,
"0"
);
wrapper
.
eq
(
"state"
,
2
);
List
<
PortEntity
>
portEntities
=
portMapper
.
selectList
(
wrapper
);
String
token
=
gettoken
(
"admin"
);
ArrayList
list
=
new
ArrayList
<>();
for
(
PortEntity
port
:
portEntities
)
{
if
(
StringUtils
.
isEmpty
(
port
.
getHeaders
())){
port
.
setHeaders
(
"application/json"
);
}
port
.
setState
(
"0"
);
if
(
!
port
.
getUrl
().
contains
(
"localhost"
)){
port
.
setState
(
"2"
);
}
else
if
(
port
.
getUrl
().
contains
(
"export"
)
||
port
.
getUrl
().
contains
(
"Export"
)||
port
.
getApiName
().
equals
(
"上传文件"
)||
port
.
getApiName
().
equals
(
"下载文件"
)||
port
.
getApiName
().
equals
(
"消息群发"
)||
port
.
getApiName
().
equals
(
"消息单发"
)){
port
.
setState
(
"1"
);
}
else
{
if
(
port
.
getMethod
().
equals
(
"post"
)
&&
port
.
getHeaders
().
equals
(
"application/json"
))
{
String
s
=
HttpUtil
.
fwdoPostJson
(
port
.
getUrl
(),
port
.
getDefaultParams
(),
token
);
list
.
add
(
s
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)
||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
else
if
(
port
.
getMethod
().
equals
(
"post"
)
&&
port
.
getHeaders
().
equals
(
"form-data"
))
{
//String 转为Map
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
port
.
getDefaultParams
(),
type
);
System
.
out
.
println
(
result
);
String
s
=
HttpUtil
.
fwdoPost
(
port
.
getUrl
(),
result
,
token
);
list
.
add
(
s
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
else
if
(
port
.
getMethod
().
equals
(
"get"
)
&&
port
.
getHeaders
().
equals
(
"form-data"
))
{
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
port
.
getDefaultParams
(),
type
);
String
s
=
HttpUtil
.
fwdoGet
(
port
.
getUrl
(),
result
,
token
);
list
.
add
(
s
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
else
if
(
port
.
getMethod
().
equals
(
"post"
)
&&
port
.
getHeaders
().
equals
(
"x-www-form-urlencoded"
)){
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
port
.
getDefaultParams
(),
type
);
String
s
=
HttpUtil
.
fwdoPost
(
port
.
getUrl
(),
result
,
token
);
list
.
add
(
s
);
port
.
setReturnParam
(
s
);
if
(
s
.
contains
(
"\"status\":200"
)
||
s
.
contains
(
"\"msg\":\"成功\""
)
||
s
.
contains
(
"\"message\":\"成功\""
)||
s
.
contains
(
"\"code\":200"
))
{
port
.
setState
(
"1"
);
}
else
port
.
setState
(
"2"
);
}
}
port
.
setCallTime
(
nowTime
());
portMapper
.
updateById
(
port
);
}
return
new
MapRestResult
(
200
,
"ok"
,
list
);
}
@PostMapping
(
"portAdd"
)
@ApiOperation
(
value
=
"接口入库"
)
@OperLog
(
message
=
"接口入库"
,
operation
=
OperationType
.
ADD
)
public
MapRestResult
portAdd
(
@RequestBody
List
<
PortEntity
>
portEntity
){
//入库前先把库里边所有的删除
QueryWrapper
wrapper
=
new
QueryWrapper
<>();
wrapper
.
select
(
"id"
);
List
<
PortEntity
>
list
=
portMapper
.
selectList
(
wrapper
);
List
<
String
>
collect
=
list
.
stream
().
map
(
PortEntity:
:
getId
).
collect
(
Collectors
.
toList
());
if
(
list
.
size
()>
0
){
int
i
=
portMapper
.
deleteBatchIds
(
collect
);
}
Map
map
=
new
HashMap
<>();
List
error
=
new
ArrayList
<>();
List
secceed
=
new
ArrayList
<>();
for
(
PortEntity
entity
:
portEntity
)
{
String
id
=
genUniqueKey
();
// String id = KeyUtilNaotu.getJzKey("JK");
entity
.
setId
(
id
);
int
insert
=
portMapper
.
insert
(
entity
);
if
(
insert
>
0
){
secceed
.
add
(
entity
.
getApiName
());
}
else
{
error
.
add
(
entity
.
getApiName
());
}
}
map
.
put
(
"成功"
,
secceed
);
map
.
put
(
"失败"
,
error
);
return
new
MapRestResult
(
200
,
"ok"
,
map
);
}
@PostMapping
(
"portDelete"
)
@ApiOperation
(
value
=
"接口删除"
)
@OperLog
(
message
=
"接口删除"
,
operation
=
OperationType
.
DELETE
)
public
MapRestResult
portDelete
(
@RequestBody
List
<
PortEntity
>
portEntity
){
Map
map
=
new
HashMap
<>();
List
error
=
new
ArrayList
<>();
List
secceed
=
new
ArrayList
<>();
for
(
PortEntity
entity
:
portEntity
)
{
entity
.
setIsDelete
(
"0"
);
int
i
=
portMapper
.
updateById
(
entity
);
if
(
i
>
0
){
secceed
.
add
(
entity
.
getApiName
());
}
else
{
error
.
add
(
entity
.
getApiName
());
}
}
map
.
put
(
"成功"
,
secceed
);
map
.
put
(
"失败"
,
error
);
return
new
MapRestResult
(
200
,
"ok"
,
map
);
}
@PostMapping
(
"portQueryIs"
)
@ApiOperation
(
value
=
"接口查询调用是否成功"
)
@OperLog
(
message
=
"接口查询调用是否成功"
,
operation
=
OperationType
.
ADD
)
public
MapRestResult
portQueryIs
(){
QueryWrapper
<
PortEntity
>
wrapper
=
new
QueryWrapper
<>();
wrapper
.
eq
(
"is_delete"
,
"0"
);
List
<
PortEntity
>
list
=
portMapper
.
selectList
(
wrapper
);
// 根据状态分组
Map
<
String
,
List
<
PortEntity
>>
collect
=
list
.
stream
().
collect
(
Collectors
.
groupingBy
(
PortEntity:
:
getState
,
Collectors
.
toList
()));
return
new
MapRestResult
(
200
,
"ok"
,
collect
);
}
public
static
Map
<
String
,
String
>
StringFoMap
(
String
str
)
{
Gson
gson
=
new
Gson
();
Type
type
=
new
TypeToken
<
Map
<
String
,
String
>>()
{
}.
getType
();
Map
<
String
,
String
>
result
=
gson
.
fromJson
(
str
,
type
);
return
result
;
}
public
static
String
test
(
String
str
)
throws
Exception
{
Date
now
=
new
Date
();
SimpleDateFormat
simpleDateFormat
=
new
SimpleDateFormat
(
"yyyyMMdd"
);
String
today
=
simpleDateFormat
.
format
(
now
);
String
KEY
=
"maplogin"
+
today
;
String
IV
=
"map_vues"
+
today
;
return
AesEncryptUtil
.
encrypt
(
str
,
KEY
,
IV
);
}
public
String
gettoken
(
String
user
)
throws
Exception
{
String
admin
=
test
(
user
);
//使用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
=
desEncrypt
(
admin
,
KEY
,
IV
).
trim
();
String
password
=
desEncrypt
(
admin
,
KEY
,
IV
).
trim
();
QueryWrapper
queryWrapper
=
new
QueryWrapper
();
queryWrapper
.
eq
(
"USERNAME"
,
username
);
queryWrapper
.
eq
(
"PASSWORD"
,
DigestUtil
.
encrypt
(
password
));
queryWrapper
.
eq
(
"SCBZ"
,
0
);
SysUser
one
=
sysUserService
.
getOne
(
queryWrapper
);
JwtUser
util
=
new
JwtUser
();
//密码加密与刑专一致
Token
tokenEntity
=
new
Token
(
one
.
getUsername
(),
one
.
getIp
(),
DigestUtil
.
encrypt
(
password
));
JSONObject
jsonObject
=
(
JSONObject
)
JSONObject
.
toJSON
(
tokenEntity
);
//用户JWT生成token
String
token
=
util
.
createJWT
(
jsonObject
.
toString
());
return
token
;
}
/*
生成唯一主键
格式:时间+随机数
*/
public
static
String
genUniqueKey
()
{
Random
random
=
new
Random
();
Integer
number
=
random
.
nextInt
(
9000
)
+
1000
;
return
"JK"
+
System
.
currentTimeMillis
()
+
String
.
valueOf
(
number
);
}
/**
* 当前时间
* @return
*/
public
String
nowTime
(){
Date
date
=
new
Date
();
SimpleDateFormat
formatter
=
new
SimpleDateFormat
(
"yyyy-MM-dd HH:mm:ss"
);
return
formatter
.
format
(
date
);
}
}
service/publicapi/src/main/java/com/founder/publicapi/controller/SkDataOperation/SkServiceSqController.java
View file @
6e9eca2a
...
@@ -133,6 +133,9 @@ public class SkServiceSqController {
...
@@ -133,6 +133,9 @@ public class SkServiceSqController {
@OperLog
(
message
=
"更新服务列表展示状态"
,
operation
=
OperationType
.
UPDATE
)
@OperLog
(
message
=
"更新服务列表展示状态"
,
operation
=
OperationType
.
UPDATE
)
public
MapRestResult
queryApply
(
String
xxzjbh
,
String
flag
)
{
public
MapRestResult
queryApply
(
String
xxzjbh
,
String
flag
)
{
SkService
skService
=
skServiceService
.
getById
(
xxzjbh
);
SkService
skService
=
skServiceService
.
getById
(
xxzjbh
);
if
(
skService
==
null
)
{
return
new
MapRestResult
(
200
,
"此xxzjbh不存在"
,
null
);
}
skService
.
setFlag
(
flag
);
skService
.
setFlag
(
flag
);
boolean
updateById
=
skServiceService
.
updateById
(
skService
);
boolean
updateById
=
skServiceService
.
updateById
(
skService
);
if
(
updateById
)
{
if
(
updateById
)
{
...
...
service/publicapi/src/main/java/com/founder/publicapi/controller/SkModelService/SkbsController.java
View file @
6e9eca2a
package
com
.
founder
.
publicapi
.
controller
.
SkModelService
;
package
com
.
founder
.
publicapi
.
controller
.
SkModelService
;
import
com.founder.commonutils.model.newPublicEntity.MapRestResult
;
import
com.founder.commonutils.model.newPublicEntity.SkTrail
;
import
com.founder.commonutils.model.newPublicEntity.SkTrail
;
import
com.founder.commonutils.model.newPublicEntity.TogetherEntity
;
import
com.founder.commonutils.model.newPublicEntity.TogetherEntity
;
import
com.founder.servicebase.logs.OperLog
;
import
com.founder.servicebase.logs.OperLog
;
...
@@ -33,14 +34,15 @@ public class SkbsController {
...
@@ -33,14 +34,15 @@ public class SkbsController {
@PostMapping
(
"getSkbs"
)
@PostMapping
(
"getSkbs"
)
@OperLog
(
message
=
"轨迹分析_伴随分析"
,
operation
=
OperationType
.
QUERY
)
@OperLog
(
message
=
"轨迹分析_伴随分析"
,
operation
=
OperationType
.
QUERY
)
@ApiOperation
(
value
=
"轨迹分析_伴随分析"
)
@ApiOperation
(
value
=
"轨迹分析_伴随分析"
)
public
Lis
t
getSkbs
(
@RequestBody
SkbsParam
skbsParam
){
public
MapRestResul
t
getSkbs
(
@RequestBody
SkbsParam
skbsParam
){
//获取需要伴随的轨迹
//获取需要伴随的轨迹
// List<SkTrail> list=getYToGjInfo(requestParams);
// List<SkTrail> list=getYToGjInfo(requestParams);
//转换轨迹
//转换轨迹
List
gjlist
=
getYToGjInfo
(
skbsParam
.
getRequestParams
(),
skbsParam
.
getList
());
List
gjlist
=
getYToGjInfo
(
skbsParam
.
getRequestParams
(),
skbsParam
.
getList
());
//进行伴随分析
//进行伴随分析
List
resultList
=
getSkbsfx
(
skbsParam
.
getRequestParams
(),
gjlist
);
List
resultList
=
getSkbsfx
(
skbsParam
.
getRequestParams
(),
gjlist
);
return
resultList
;
return
new
MapRestResult
(
200
,
"ok"
,
resultList
);
// return resultList;
}
}
/**
/**
...
...
service/publicapi/src/main/java/com/founder/publicapi/controller/hnksh/HnTbStRygxController.java
View file @
6e9eca2a
...
@@ -535,7 +535,7 @@ public class HnTbStRygxController {
...
@@ -535,7 +535,7 @@ public class HnTbStRygxController {
public
Result
delFileByExcelId
(
String
excelId
)
{
public
Result
delFileByExcelId
(
String
excelId
)
{
HnTbStRygxRw
excelInfo
=
hnKshRwService
.
getOne
(
new
QueryWrapper
<
HnTbStRygxRw
>().
eq
(
"excel_id"
,
excelId
));
HnTbStRygxRw
excelInfo
=
hnKshRwService
.
getOne
(
new
QueryWrapper
<
HnTbStRygxRw
>().
eq
(
"excel_id"
,
excelId
));
if
(
excelInfo
==
null
)
{
if
(
excelInfo
==
null
)
{
return
Result
.
error
().
message
(
"不存在该文件"
);
return
Result
.
ok
().
message
(
"不存在该文件"
);
}
}
String
taskId
=
excelInfo
.
getParentId
();
String
taskId
=
excelInfo
.
getParentId
();
String
createName
=
excelInfo
.
getCreateName
();
String
createName
=
excelInfo
.
getCreateName
();
...
@@ -565,7 +565,7 @@ public class HnTbStRygxController {
...
@@ -565,7 +565,7 @@ public class HnTbStRygxController {
public
Result
delFileByTaskId
(
String
taskId
)
{
public
Result
delFileByTaskId
(
String
taskId
)
{
List
<
HnTbStRygxRw
>
rwList
=
hnKshRwService
.
list
(
new
QueryWrapper
<
HnTbStRygxRw
>().
eq
(
"RWID"
,
taskId
));
List
<
HnTbStRygxRw
>
rwList
=
hnKshRwService
.
list
(
new
QueryWrapper
<
HnTbStRygxRw
>().
eq
(
"RWID"
,
taskId
));
if
(
rwList
.
isEmpty
())
{
if
(
rwList
.
isEmpty
())
{
return
Result
.
error
().
message
(
"不存在该任务"
);
return
Result
.
ok
().
message
(
"不存在该任务"
);
}
}
//删除 ksh_st_rygx_rw表的Excel信息
//删除 ksh_st_rygx_rw表的Excel信息
//1.删除任务
//1.删除任务
...
...
service/publicapi/src/main/java/com/founder/publicapi/mapper/mysqlMapper/PortMapper.java
0 → 100644
View file @
6e9eca2a
package
com
.
founder
.
publicapi
.
mapper
.
mysqlMapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.founder.commonutils.model.newPublicEntity.PortEntity
;
public
interface
PortMapper
extends
BaseMapper
<
PortEntity
>
{
}
service/publicapi/src/main/java/com/founder/publicapi/service/serviceimpl/SpxxServiceImpl.java
View file @
6e9eca2a
...
@@ -480,7 +480,7 @@ public class SpxxServiceImpl implements SpxxService {
...
@@ -480,7 +480,7 @@ public class SpxxServiceImpl implements SpxxService {
//柱状图 申请状态
//柱状图 申请状态
//柱状图 统计结果
//柱状图 统计结果
jsonObject
.
put
(
"data"
,
""
);
jsonObject
.
put
(
"data"
,
""
);
jsonObject
.
put
(
"status"
,
"success"
);
jsonObject
.
put
(
"status"
,
200
);
jsonObject
.
put
(
"code"
,
"200"
);
jsonObject
.
put
(
"code"
,
"200"
);
return
jsonObject
;
return
jsonObject
;
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment