hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'dev' of http://192.168.2.237:3000/root/kangarooDataCenterV3 into lvleigang 

 Conflicts:
	service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
This commit is contained in:
lvleigang 2024-04-30 10:17:06 +08:00
parent 66cc698844 52bfd726e3
commit 341f620c73
14 changed files with 536 additions and 145 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
service/src/main/java/com/hzya/frame/sysnew/application/api/dao/ISysApplicationApiDao.java
View File

@ -20,5 +20,8 @@ public interface ISysApplicationApiDao extends IBaseDao<SysApplicationApiEntity,
Integer entity_count_not_id(SysApplicationApiEntity checkEntity);
Integer checkCatalogue(SysApplicationApiEntity checkEntity);
List<SysApplicationApiEntity> queryBaseName(SysApplicationApiEntity entity);
}

6
service/src/main/java/com/hzya/frame/sysnew/application/api/dao/impl/SysApplicationApiDaoImpl.java
View File

@ -24,6 +24,12 @@ public class SysApplicationApiDaoImpl extends MybatisGenericDao<SysApplicationAp
return o;
}
@Override
public List<SysApplicationApiEntity> queryBaseName(SysApplicationApiEntity entity) {
List<SysApplicationApiEntity> o = (List<SysApplicationApiEntity>) super.selectList(getSqlIdPrifx() + "queryBaseName", entity);
return o;
}
// 查询符合条件的数量

30
service/src/main/java/com/hzya/frame/sysnew/application/api/entity/SysApplicationApiDto.java
View File

@ -23,6 +23,12 @@ public class SysApplicationApiDto {
private Long apiCode;
/** Api接口地址(固定系统内部外放接口地址) */
private String apiPath;
/** bean名称 */
private String beanName;
/** 方法名称 */
private String funName;
/** 是否扩展api */
private String extensionApi;
public String getAppId() {
return appId;
}
@ -86,5 +92,29 @@ public class SysApplicationApiDto {
public void setApiPath(String apiPath) {
this.apiPath = apiPath;
}
public String getBeanName() {
return beanName;
}
public void setBeanName(String beanName) {
this.beanName = beanName;
}
public String getFunName() {
return funName;
}
public void setFunName(String funName) {
this.funName = funName;
}
public String getExtensionApi() {
return extensionApi;
}
public void setExtensionApi(String extensionApi) {
this.extensionApi = extensionApi;
}
}

30
service/src/main/java/com/hzya/frame/sysnew/application/api/entity/SysApplicationApiEntity.java
View File

@ -54,6 +54,12 @@ public class SysApplicationApiEntity extends BaseEntity {
private String bodyIn;
/** Body 出参 JSON */
private String bodyOut;
/** bean名称 */
private String beanName;
/** 方法名称 */
private String funName;
/** 是否扩展api 1、启用 2、停用*/
private String extensionApi;
public String getApiStatus() {
@ -231,5 +237,29 @@ public class SysApplicationApiEntity extends BaseEntity {
public void setApiPath(String apiPath) {
this.apiPath = apiPath;
}
public String getBeanName() {
return beanName;
}
public void setBeanName(String beanName) {
this.beanName = beanName;
}
public String getFunName() {
return funName;
}
public void setFunName(String funName) {
this.funName = funName;
}
public String getExtensionApi() {
return extensionApi;
}
public void setExtensionApi(String extensionApi) {
this.extensionApi = extensionApi;
}
}

102
service/src/main/java/com/hzya/frame/sysnew/application/api/entity/SysApplicationApiEntity.xml
View File

@ -27,6 +27,9 @@
<result property="bodyInType" column="body_in_type" jdbcType="VARCHAR"/>
<result property="bodyIn" column="body_in" jdbcType="VARCHAR"/>
<result property="bodyOut" column="body_out" jdbcType="VARCHAR"/>
<result property="beanName" column="bean_name" jdbcType="VARCHAR"/>
<result property="funName" column="fun_name" jdbcType="VARCHAR"/>
<result property="extensionApi" column="extension_api" jdbcType="VARCHAR"/>
<result property="sorts" column="sorts" jdbcType="INTEGER"/>
<result property="create_user_id" column="create_user_id" jdbcType="VARCHAR"/>
<result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
@ -58,6 +61,9 @@
,body_in_type
,body_in
,body_out
,bean_name
,fun_name
,extension_api
,sorts
,create_user_id
,create_time
@ -92,6 +98,9 @@
a.body_in_type,
a.body_in,
a.body_out,
a.bean_name,
a.fun_name,
a.extension_api,
a.sorts,
a.create_user_id,
a.create_time,
@ -143,6 +152,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">and body_in_type = #{bodyInType}</if>
<if test="bodyIn != null and bodyIn != ''">and body_in = #{bodyIn}</if>
<if test="bodyOut != null and bodyOut != ''">and body_out = #{bodyOut}</if>
<if test="beanName != null and beanName != ''">and bean_name = #{beanName}</if>
<if test="funName != null and funName != ''">and fun_name = #{funName}</if>
<if test="extensionApi != null and extensionApi != ''">and extension_api = #{extensionApi}</if>
<if test="sorts != null">and sorts = #{sorts}</if>
<if test="create_user_id != null and create_user_id != ''">and create_user_id = #{create_user_id}</if>
<if test="create_time != null">and create_time = #{create_time}</if>
@ -188,6 +200,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">and body_in_type = #{bodyInType}</if>
<if test="bodyIn != null and bodyIn != ''">and body_in = #{bodyIn}</if>
<if test="bodyOut != null and bodyOut != ''">and body_out = #{bodyOut}</if>
<if test="beanName != null and beanName != ''">and bean_name = #{beanName}</if>
<if test="funName != null and funName != ''">and fun_name = #{funName}</if>
<if test="extensionApi != null and extensionApi != ''">and extension_api = #{extensionApi}</if>
<if test="sorts != null">and sorts = #{sorts}</if>
<if test="create_user_id != null and create_user_id != ''">and create_user_id = #{create_user_id}</if>
<if test="create_time != null">and create_time = #{create_time}</if>
@ -244,6 +259,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">and body_in_type like concat('%',#{bodyInType},'%')</if>
<if test="bodyIn != null and bodyIn != ''">and body_in like concat('%',#{bodyIn},'%')</if>
<if test="bodyOut != null and bodyOut != ''">and body_out like concat('%',#{bodyOut},'%')</if>
<if test="beanName != null and beanName != ''">and bean_name like concat('%',#{beanName},'%')</if>
<if test="funName != null and funName != ''">and fun_name like concat('%',#{funName},'%')</if>
<if test="extensionApi != null and extensionApi != ''">and extension_api like concat('%',#{extensionApi},'%')</if>
<if test="sorts != null">and sorts like concat('%',#{sorts},'%')</if>
<if test="create_user_id != null and create_user_id != ''">and create_user_id like
concat('%',#{create_user_id},'%')
@ -295,6 +313,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">or body_in_type = #{bodyInType}</if>
<if test="bodyIn != null and bodyIn != ''">or body_in = #{bodyIn}</if>
<if test="bodyOut != null and bodyOut != ''">or body_out = #{bodyOut}</if>
<if test="beanName != null and beanName != ''">or bean_name = #{beanName}</if>
<if test="funName != null and funName != ''">or fun_name = #{funName}</if>
<if test="extensionApi != null and extensionApi != ''">or extension_api = #{extensionApi}</if>
<if test="sorts != null">or sorts = #{sorts}</if>
<if test="create_user_id != null and create_user_id != ''">or create_user_id = #{create_user_id}</if>
<if test="create_time != null">or create_time = #{create_time}</if>
@ -335,6 +356,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">body_in_type ,</if>
<if test="bodyIn != null and bodyIn != ''">body_in ,</if>
<if test="bodyOut != null and bodyOut != ''">body_out ,</if>
<if test="beanName != null and beanName != ''">bean_name ,</if>
<if test="funName != null and funName != ''">fun_name ,</if>
<if test="extensionApi != null and extensionApi != ''">extension_api ,</if>
<if test="sorts != null">sorts ,</if>
<if test="create_user_id != null and create_user_id != ''">create_user_id ,</if>
<if test="create_time != null">create_time ,</if>
@ -371,6 +395,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">#{bodyInType} ,</if>
<if test="bodyIn != null and bodyIn != ''">#{bodyIn} ,</if>
<if test="bodyOut != null and bodyOut != ''">#{bodyOut} ,</if>
<if test="beanName != null and beanName != ''">#{beanName} ,</if>
<if test="funName != null and funName != ''">#{funName} ,</if>
<if test="extensionApi != null and extensionApi != ''">#{extensionApi} ,</if>
<if test="sorts != null">#{sorts} ,</if>
<if test="create_user_id != null and create_user_id != ''">#{create_user_id} ,</if>
<if test="create_time != null">#{create_time} ,</if>
@ -389,11 +416,11 @@ WHERE
<insert id="entityInsertBatch" keyProperty="id" useGeneratedKeys="true">
insert into sys_application_api(api_status,api_code,api_path, app_id, catalogue_id, api_name, api_remark,
need_Login, authentication_port, parameter_passing_mode, destination_address, request_coding, request_method,
timeout_period, current_limiting, header_in, query_in, body_in_type, body_in, body_out, sorts, create_user_id,
timeout_period, current_limiting, header_in, query_in, body_in_type, body_in, body_out, bean_name, fun_name, extension_api, sorts, create_user_id,
create_time, modify_user_id, modify_time, sts, org_id, sts)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.apiStatus},#{entity.apiCode},#{entity.apiPath},#{entity.appId},#{entity.catalogueId},#{entity.apiName},#{entity.apiRemark},#{entity.needLogin},#{entity.authenticationPort},#{entity.parameterPassingMode},#{entity.destinationAddress},#{entity.requestCoding},#{entity.requestMethod},#{entity.timeoutPeriod},#{entity.currentLimiting},#{entity.headerIn},#{entity.queryIn},#{entity.bodyInType},#{entity.bodyIn},#{entity.bodyOut},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id},
(#{entity.apiStatus},#{entity.apiCode},#{entity.apiPath},#{entity.appId},#{entity.catalogueId},#{entity.apiName},#{entity.apiRemark},#{entity.needLogin},#{entity.authenticationPort},#{entity.parameterPassingMode},#{entity.destinationAddress},#{entity.requestCoding},#{entity.requestMethod},#{entity.timeoutPeriod},#{entity.currentLimiting},#{entity.headerIn},#{entity.queryIn},#{entity.bodyInType},#{entity.bodyIn},#{entity.bodyOut},#{entity.beanName},#{entity.funName},#{entity.extensionApi},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id},
'Y')
</foreach>
</insert>
@ -401,11 +428,11 @@ WHERE
<insert id="entityInsertOrUpdateBatch" keyProperty="id" useGeneratedKeys="true">
insert into sys_application_api(api_status,api_code,api_path, app_id, catalogue_id, api_name, api_remark,
need_Login, authentication_port, parameter_passing_mode, destination_address, request_coding, request_method,
timeout_period, current_limiting, header_in, query_in, body_in_type, body_in, body_out, sorts, create_user_id,
timeout_period, current_limiting, header_in, query_in, body_in_type, body_in, body_out,bean_name,fun_name,extension_api, sorts, create_user_id,
create_time, modify_user_id, modify_time, sts, org_id)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.apiStatus},#{entity.apiCode},#{entity.apiPath},#{entity.appId},#{entity.catalogueId},#{entity.apiName},#{entity.apiRemark},#{entity.needLogin},#{entity.authenticationPort},#{entity.parameterPassingMode},#{entity.destinationAddress},#{entity.requestCoding},#{entity.requestMethod},#{entity.timeoutPeriod},#{entity.currentLimiting},#{entity.headerIn},#{entity.queryIn},#{entity.bodyInType},#{entity.bodyIn},#{entity.bodyOut},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id})
(#{entity.apiStatus},#{entity.apiCode},#{entity.apiPath},#{entity.appId},#{entity.catalogueId},#{entity.apiName},#{entity.apiRemark},#{entity.needLogin},#{entity.authenticationPort},#{entity.parameterPassingMode},#{entity.destinationAddress},#{entity.requestCoding},#{entity.requestMethod},#{entity.timeoutPeriod},#{entity.currentLimiting},#{entity.headerIn},#{entity.queryIn},#{entity.bodyInType},#{entity.bodyIn},#{entity.bodyOut},#{entity.beanName},#{entity.funName},#{entity.extensionApi},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id})
</foreach>
on duplicate key update
api_status = values(api_status),
@ -427,7 +454,10 @@ WHERE
query_in = values(query_in),
body_in_type = values(body_in_type),
body_in = values(body_in),
body_out = values(body_out),
body_out = values(extension_api),
bean_name = values(bean_name),
fun_name = values(fun_name),
extension_api = values(extension_api),
sorts = values(sorts),
create_user_id = values(create_user_id),
create_time = values(create_time),
@ -466,6 +496,9 @@ WHERE
<if test="bodyInType != null and bodyInType != ''">body_in_type = #{bodyInType},</if>
<if test="bodyIn != null and bodyIn != ''">body_in = #{bodyIn},</if>
<if test="bodyOut != null and bodyOut != ''">body_out = #{bodyOut},</if>
<if test="beanName != null and beanName != ''">bean_name = #{beanName},</if>
<if test="funName != null and funName != ''">fun_name = #{funName},</if>
<if test="extensionApi != null and extensionApi != ''">extension_api = #{extensionApi},</if>
<if test="sorts != null">sorts = #{sorts},</if>
<if test="create_user_id != null and create_user_id != ''">create_user_id = #{create_user_id},</if>
<if test="create_time != null">create_time = #{create_time},</if>
@ -513,6 +546,9 @@ where id = #{id}
<if test="bodyInType != null and bodyInType != ''">and body_in_type = #{bodyInType}</if>
<if test="bodyIn != null and bodyIn != ''">and body_in = #{bodyIn}</if>
<if test="bodyOut != null and bodyOut != ''">and body_out = #{bodyOut}</if>
<if test="beanName != null and beanName != ''">and bean_name = #{beanName}</if>
<if test="funName != null and funName != ''">and fun_name = #{funName}</if>
<if test="extensionApi != null and extensionApi != ''">and extension_api = #{extensionApi}</if>
<if test="sorts != null">and sorts = #{sorts}</if>
<if test="sts != null and sts != ''">and sts = #{sts}</if>
and sts='Y'
@ -673,6 +709,57 @@ where id = #{id}
order by a.sorts asc
</select>
<!-- 查询 采用==查询 -->
<select id="queryBaseName" resultMap="get-SysApplicationApiEntity-result"
parameterType="com.hzya.frame.sysnew.application.api.entity.SysApplicationApiEntity">
select
id
,app_id
,api_name
from sys_application_api
<trim prefix="where" prefixOverrides="and">
<if test="id != null and id != ''">and id = #{id}</if>
<if test="apiStatus != null and apiStatus != ''">and api_status = #{apiStatus}</if>
<if test="apiCode != null ">and api_code = #{apiCode}</if>
<if test="apiPath != null and apiPath != ''">and api_path = #{apiPath}</if>
<if test="appId != null and appId != ''">and app_id = #{appId}</if>
<if test="catalogueId != null and catalogueId != ''">and catalogue_id = #{catalogueId}</if>
<if test="apiName != null and apiName != ''">and api_name = #{apiName}</if>
<if test="apiRemark != null and apiRemark != ''">and api_remark = #{apiRemark}</if>
<if test="needLogin != null and needLogin != ''">and need_Login = #{needLogin}</if>
<if test="authenticationPort != null and authenticationPort != ''">and authentication_port =
#{authenticationPort}
</if>
<if test="parameterPassingMode != null and parameterPassingMode != ''">and parameter_passing_mode =
#{parameterPassingMode}
</if>
<if test="destinationAddress != null and destinationAddress != ''">and destination_address =
#{destinationAddress}
</if>
<if test="requestCoding != null and requestCoding != ''">and request_coding = #{requestCoding}</if>
<if test="requestMethod != null and requestMethod != ''">and request_method = #{requestMethod}</if>
<if test="timeoutPeriod != null and timeoutPeriod != ''">and timeout_period = #{timeoutPeriod}</if>
<if test="currentLimiting != null and currentLimiting != ''">and current_limiting = #{currentLimiting}</if>
<if test="headerIn != null and headerIn != ''">and header_in = #{headerIn}</if>
<if test="queryIn != null and queryIn != ''">and query_in = #{queryIn}</if>
<if test="bodyInType != null and bodyInType != ''">and body_in_type = #{bodyInType}</if>
<if test="bodyIn != null and bodyIn != ''">and body_in = #{bodyIn}</if>
<if test="bodyOut != null and bodyOut != ''">and body_out = #{bodyOut}</if>
<if test="beanName != null and beanName != ''">and bean_name = #{beanName}</if>
<if test="funName != null and funName != ''">and fun_name = #{funName}</if>
<if test="extensionApi != null and extensionApi != ''">and extension_api = #{extensionApi}</if>
<if test="sorts != null">and sorts = #{sorts}</if>
<if test="create_user_id != null and create_user_id != ''">and create_user_id = #{create_user_id}</if>
<if test="create_time != null">and create_time = #{create_time}</if>
<if test="modify_user_id != null and modify_user_id != ''">and modify_user_id = #{modify_user_id}</if>
<if test="modify_time != null">and modify_time = #{modify_time}</if>
<if test="sts != null and sts != ''">and sts = #{sts}</if>
<if test="org_id != null and org_id != ''">and org_id = #{org_id}</if>
and sts='Y'
</trim>
<if test=" sort == null or sort == ''.toString() ">order by sorts asc</if>
<if test=" sort !='' and sort!=null and order !='' and order!=null ">order by ${sort} ${order}</if>
</select>
<!-- 查询符合条件的数量 -->
<select id="entity_count_not_id" resultType="Integer"
parameterType="com.hzya.frame.sysnew.application.api.entity.SysApplicationApiEntity">
@ -705,6 +792,9 @@ where id = #{id}
<if test="bodyInType != null and bodyInType != ''">and body_in_type = #{bodyInType}</if>
<if test="bodyIn != null and bodyIn != ''">and body_in = #{bodyIn}</if>
<if test="bodyOut != null and bodyOut != ''">and body_out = #{bodyOut}</if>
<if test="beanName != null and beanName != ''">and bean_name = #{beanName}</if>
<if test="funName != null and funName != ''">and fun_name = #{funName}</if>
<if test="extensionApi != null and extensionApi != ''">and extension_api = #{extensionApi}</if>
<if test="sorts != null">and sorts = #{sorts}</if>
<if test="create_user_id != null and create_user_id != ''">and create_user_id = #{create_user_id}</if>
<if test="create_time != null">and create_time = #{create_time}</if>
@ -718,8 +808,6 @@ where id = #{id}
<!-- 查询符合条件的数量 -->
<select id="checkCatalogue" resultType="Integer"
parameterType="com.hzya.frame.sysnew.application.api.entity.SysApplicationApiEntity">
SELECT count(*) from
sys_application_api
WHERE

31
service/src/main/java/com/hzya/frame/sysnew/application/api/entity/SysApplicationApiVo.java
View File

@ -33,7 +33,12 @@ public class SysApplicationApiVo {
private Long apiCode;
/** Api接口地址(固定系统内部外放接口地址) */
private String apiPath;
/** bean名称 */
private String beanName;
/** 方法名称 */
private String funName;
/** 是否扩展api */
private String extensionApi;
public Long getApiCode() {
return apiCode;
}
@ -129,5 +134,29 @@ public class SysApplicationApiVo {
public void setApiStatus(String apiStatus) {
this.apiStatus = apiStatus;
}
public String getBeanName() {
return beanName;
}
public void setBeanName(String beanName) {
this.beanName = beanName;
}
public String getFunName() {
return funName;
}
public void setFunName(String funName) {
this.funName = funName;
}
public String getExtensionApi() {
return extensionApi;
}
public void setExtensionApi(String extensionApi) {
this.extensionApi = extensionApi;
}
}

39
service/src/main/java/com/hzya/frame/sysnew/application/entity/SysExtensionApiEntity.java Normal file
View File

@ -0,0 +1,39 @@
package com.hzya.frame.sysnew.application.entity;
import java.util.Map;
public class SysExtensionApiEntity {
/** head */
private Map<String, String> headers;
/** query */
private String querys;
/** body */
private String bodys;
public Map<String, String> getHeaders() {
return headers;
}
public void setHeaders(Map<String, String> headers) {
this.headers = headers;
}
public String getQuerys() {
return querys;
}
public void setQuerys(String querys) {
this.querys = querys;
}
public String getBodys() {
return bodys;
}
public void setBodys(String bodys) {
this.bodys = bodys;
}
}

35
service/src/main/java/com/hzya/frame/sysnew/application/service/ISysApplicationService.java
View File

@ -305,4 +305,39 @@ public interface ISysApplicationService extends IBaseService<SysApplicationEntit
JsonResultEntity enableOrDisableAppDatasource(JSONObject jsonObject);
JsonResultEntity externalCallInterface(ServletRequest servletRequest, ServletResponse servletResponse);
/**
* @Author lvleigang
* @Description 应用列表查询接口 多字段模糊查询，枚举类型字段转换
* @Date 2:06 下午 2023/9/23
* @param jsonObject
* @return
**/
JsonResultEntity thirdInterfacequeryApp(JSONObject jsonObject);
/**
* @Author lvleigang
* @Description 应用列表查询接口 多字段模糊查询，枚举类型字段转换
* @Date 2:06 下午 2023/9/23
* @param jsonObject
* @return
**/
JsonResultEntity thirdInterfacequeryAppAll(JSONObject jsonObject);
/**
* @Author lvleigang
* @Description 查询接口日志 查询接口发送错误，以及不发送的数据
* @Date 2:08 下午 2023/9/23
* @param jsonObject
* @return
**/
JsonResultEntity thirdInterfacequeryAppApiLog(JSONObject jsonObject);
/**
* @Author lvleigang
* @Description 查询接口
* @Date 2:08 下午 2023/9/23
* @param jsonObject
* @return
**/
JsonResultEntity thirdInterfacequeryAppApi(JSONObject jsonObject);
}

268
service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
View File

@ -1,5 +1,6 @@
package com.hzya.frame.sysnew.application.service.impl;
import cn.dev33.satoken.exception.NotLoginException;
import cn.dev33.satoken.stp.StpUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
@ -30,6 +31,7 @@ import com.hzya.frame.sysnew.application.entity.SysApplicationDto;
import com.hzya.frame.sysnew.application.entity.SysApplicationEntity;
import com.hzya.frame.sysnew.application.dao.ISysApplicationDao;
import com.hzya.frame.sysnew.application.entity.SysApplicationVo;
import com.hzya.frame.sysnew.application.entity.SysExtensionApiEntity;
import com.hzya.frame.sysnew.application.plugin.dao.ISysApplicationPluginDao;
import com.hzya.frame.sysnew.application.plugin.entity.SysApplicationPluginDto;
import com.hzya.frame.sysnew.application.plugin.entity.SysApplicationPluginEntity;
@ -41,11 +43,16 @@ import com.hzya.frame.sysnew.messageManageDetail.entity.SysMessageManageDetailEn
import com.hzya.frame.sysnew.messageManageLog.dao.ISysMessageManageLogDao;
import com.hzya.frame.sysnew.messageManageLog.entity.SysMessageManageLogEntity;
import com.hzya.frame.sysnew.messageManageLog.entity.SysMessageManageLogPageVo;
import com.hzya.frame.sysnew.popedomInterface.entity.SysPopedomInterfaceEntity;
import com.hzya.frame.sysnew.sysInterface.entity.SysInterfaceEntity;
import com.hzya.frame.sysnew.userRoles.entity.SysUserRolesEntity;
import com.hzya.frame.util.AESUtil;
import com.hzya.frame.util.IPHelper;
import com.hzya.frame.uuid.UUIDUtils;
import com.hzya.frame.web.action.ApplicationContextUtil;
import com.hzya.frame.web.entity.BaseResult;
import com.hzya.frame.web.entity.JsonResultEntity;
import com.hzya.frame.web.exception.BaseSystemException;
import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
@ -65,8 +72,11 @@ import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import com.hzya.frame.basedao.service.impl.BaseService;
import org.springframework.util.ObjectUtils;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
@ -539,6 +549,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
return BaseResult.getFailureMessageEntity("测试连接数据源失败,请检查数据源配置是否正确");
}
}
//修改数据源
private void doUpdateDatabase(SysApplicationDto entity) {
//先删除明细再修改
@ -1603,14 +1614,9 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
long fsqsj = 0L;
long fshsj = 0L;
HttpServletRequest request = (HttpServletRequest) servletRequest;
String bodys = ServletUtil.getBody(servletRequest);
//if(bodys.startsWith("\"") && bodys.endsWith("\"")){
// bodys = bodys.substring(1);
// bodys = bodys.substring(0, bodys.length() - 1);
//}
//bodys = StringEscapeUtils.unescapeJson(bodys).replaceAll("\r\n","");
Map<String, String> headerMap = ServletUtil.getHeaderMap(request);
String querys = request.getQueryString();
String oldbodys = ServletUtil.getBody(servletRequest);
Map<String, String> oldheaderMap = ServletUtil.getHeaderMap(request);
String oldquerys = request.getQueryString();
//应用key
String publicKey = request.getHeader("publicKey");
//应用密钥
@ -1636,106 +1642,91 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
logger.info("请求参数：publicKey：【" + publicKey + "】secretKey：【" + secretKey + "】appId：【" + appId + "】apiCode：【" + apiCode);
//根据请求a应用的公钥、密钥是否能查找到一条数据
//TODO 修改为缓存获取
//SysApplicationEntity sendApp = new SysApplicationEntity();
//sendApp.setSts("Y");
//sendApp.setPublicKey(publicKey);
//sendApp.setSecretKey(secretKey);
//List<SysApplicationEntity> sysApplicationEntities = sysApplicationDao.queryBase(sendApp);
//if (sysApplicationEntities == null || sysApplicationEntities.size() != 1) {
// return BaseResult.getFailureMessageEntity("系统错误请联系中台管理员,应用配置错误");
//}
//sendApp = sysApplicationEntities.get(0);
SysApplicationEntity sendApp = getAppByPublicKeySecretKey(publicKey, secretKey);
if (sendApp == null) {
return BaseResult.getFailureMessageEntity("系统错误请联系中台管理员,应用配置错误");
return BaseResult.getFailureMessageEntity("系统错误请联系中台管理员,请联系管理员");
}
//判断应用是否启用
if (sendApp.getAppStatus() == null || !"1".equals(sendApp.getAppStatus())) {
return BaseResult.getFailureMessageEntity("发送方应用未启用,请联系中台管理员");
return BaseResult.getFailureMessageEntity(sendApp.getName()+"应用未启用,请联系管理员");
}
//判断应用接口是否启用
//if(sendApp.getInterfaceStatus() == null || !"1".equals(sendApp.getInterfaceStatus())){
// return BaseResult.getFailureMessageEntity("发送方应用接口未启用,请联系中台管理员");
//}
//估计请求的appID和接口编码 查询具体发送的那个应用那个接口
//SysApplicationEntity receiveApp = new SysApplicationEntity();
//receiveApp.setSts("Y");
//receiveApp.setAppId(Integer.valueOf(appId));
//List<SysApplicationEntity> receiveAppList = sysApplicationDao.queryBase(receiveApp);
//if (receiveAppList == null || receiveAppList.size() != 1) {
// return BaseResult.getFailureMessageEntity("系统错误请联系中台管理员,应用配置错误");
//}
//receiveApp = receiveAppList.get(0);
SysApplicationEntity receiveApp = getAppByAppId(appId);
if (receiveApp == null) {
return BaseResult.getFailureMessageEntity("系统错误请联系中台管理员,应用配置错误");
return BaseResult.getFailureMessageEntity("根据appId:"+appId+"未匹配到应用,请联系管理员");
}
//判断应用是否启用
if (receiveApp.getAppStatus() == null || !"1".equals(receiveApp.getAppStatus())) {
return BaseResult.getFailureMessageEntity("接收方应用未启用,请联系中台管理员");
return BaseResult.getFailureMessageEntity(receiveApp.getName()+"应用未启用,请联系管理员");
}
//判断应用接口是否启用
if (receiveApp.getInterfaceStatus() == null || !"1".equals(receiveApp.getInterfaceStatus())) {
return BaseResult.getFailureMessageEntity("接收方应用接口未启用,请联系中台管理员");
return BaseResult.getFailureMessageEntity(receiveApp.getName()+"应用接口环境未启用,请联系管理员");
}
//SysApplicationApiEntity receiveApi = new SysApplicationApiEntity();
//receiveApi.setSts("Y");
//receiveApi.setAppId(receiveApp.getId());
//receiveApi.setApiCode(Long.parseLong(apiCode));
//List<SysApplicationApiEntity> receiveApiList = sysApplicationApiDao.queryBase(receiveApi);
//if (receiveApiList == null || receiveApiList.size() != 1) {
// return BaseResult.getFailureMessageEntity(receiveApp.getName() + ":" + apiCode + "未启用或者未创建");
//}
//receiveApi = receiveApiList.get(0);
SysApplicationApiEntity receiveApi = getApiByAppIdApiCode(receiveApp.getId(), apiCode);
if (receiveApi == null) {
return BaseResult.getFailureMessageEntity(receiveApp.getName() + ":" + apiCode + "未启用或者未创建");
}
//获取A应用请求过来的IP，校验B应用设置三方的ip白名单是否一致
//SysApplicationApiAuthEntity sysApplicationApiAuthEntity = new SysApplicationApiAuthEntity();
//sysApplicationApiAuthEntity.setSts("Y");
//sysApplicationApiAuthEntity.setName(sendApp.getId());
//sysApplicationApiAuthEntity.setAppId(receiveApp.getId());
//sysApplicationApiAuthEntity.setSystemStatus("1");
//List<SysApplicationApiAuthEntity> sysApplicationApiAuthEntities = sysApplicationApiAuthDao.queryByLike(sysApplicationApiAuthEntity);
//if (sysApplicationApiAuthEntities == null || sysApplicationApiAuthEntities.size() == 0) {
// return BaseResult.getFailureMessageEntity("接收方应用权限配置错误");
//}
//for (int i = 0; i < sysApplicationApiAuthEntities.size(); i++) {
// if (sysApplicationApiAuthEntities.get(i).getSystemAddress() != null && !"".equals(sysApplicationApiAuthEntities.get(i).getSystemAddress())
// && !sysApplicationApiAuthEntities.get(i).getSystemAddress().contains(ip)) {
// logger.error("发送方应用ip配置错误,ip为：" + ip);
// return BaseResult.getFailureMessageEntity("发送方应用ip配置错误");
// }
//}
SysApplicationApiAuthEntity sysApplicationApiAuthEntity = getApiAuthByNameAppId(sendApp.getId(), receiveApp.getId());
if (sysApplicationApiAuthEntity == null) {
return BaseResult.getFailureMessageEntity("接收方应用权限配置错误");
return BaseResult.getFailureMessageEntity(receiveApp.getName()+"应用权限配置错误");
}
if (sysApplicationApiAuthEntity.getSystemAddress() != null && !"".equals(sysApplicationApiAuthEntity.getSystemAddress())
&& !sysApplicationApiAuthEntity.getSystemAddress().contains(ip)) {
logger.error("发送方应用ip配置错误,ip为：" + ip);
return BaseResult.getFailureMessageEntity("发送方应用ip配置错误");
return BaseResult.getFailureMessageEntity(receiveApp.getName()+"发送应用"+receiveApp.getName()+"的ip白名单配置错误");
}
//判断接口是否授权第三方
//SysApplicationApiAuthDetailEntity sysApplicationApiAuthDetailEntity = new SysApplicationApiAuthDetailEntity();
//sysApplicationApiAuthDetailEntity.setSts("Y");
//sysApplicationApiAuthDetailEntity.setAppId(receiveApp.getId());
//sysApplicationApiAuthDetailEntity.setApiId(receiveApi.getId());
//sysApplicationApiAuthDetailEntity.setStatusType("2");
//sysApplicationApiAuthDetailEntity.setTripartiteSystemId(sysApplicationApiAuthEntities.get(0).getId());
//List<SysApplicationApiAuthDetailEntity> sysApplicationApiAuthDetailEntities = sysApplicationApiAuthDetailDao.queryBase(sysApplicationApiAuthDetailEntity);
//if (sysApplicationApiAuthDetailEntities == null || sysApplicationApiAuthDetailEntities.size() == 0) {
// return BaseResult.getFailureMessageEntity("发送方未关联应用方");
//}
SysApplicationApiAuthDetailEntity sysApplicationApiAuthDetailEntity = getApiAuthDetailByAppIdApiIdTripartiteSystemId(receiveApp.getId(), receiveApi.getId(), sysApplicationApiAuthEntity.getId());
if (sysApplicationApiAuthDetailEntity == null) {
return BaseResult.getFailureMessageEntity("发送方未关联应用方");
saveLog(sendApp, receiveApp, receiveApi, oldbodys,null, oldheaderMap,null, null, oldquerys,null, null, jrff, fsqsj, fshsj,false);
return BaseResult.getFailureMessageEntity(receiveApi.getApiName()+"未授权给"+sendApp.getName()+"，请联系管理员");
}
SysExtensionApiEntity sysExtensionApiEntity = new SysExtensionApiEntity();
sysExtensionApiEntity.setHeaders(oldheaderMap);
sysExtensionApiEntity.setQuerys(oldquerys);
sysExtensionApiEntity.setBodys(oldbodys);
//TODO 判断是否有内部api 是否扩展api 1、启用 2、停用
if (receiveApi.getExtensionApi() != null && "1".equals(receiveApi.getExtensionApi())
&& receiveApi.getBeanName() != null && !"".equals(receiveApi.getBeanName())
&& receiveApi.getFunName() != null && !"".equals(receiveApi.getFunName())
) {
//获取类
Object object = null;
try {
object = ApplicationContextUtil.getBeanByName(receiveApi.getBeanName());
} catch (SecurityException e) {
}
//获取类下面的方法
Method[] methods = object.getClass().getMethods();
if (methods == null || methods.length == 0) {
return BaseResult.getFailureMessageEntity("未找到内部方法，请联系管理员");
}
for (Method m : methods) {
if (null != m) {
if (m.getName().equals(receiveApi.getFunName().trim())) {
try {
logger.info("invoke开始>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
sysExtensionApiEntity = (SysExtensionApiEntity) m.invoke(object, sysExtensionApiEntity);
logger.info("invoke结束>>>>>>>>>>>>>>>>>>>>>>>>>>>>");
} catch (Exception e) {
logger.error("invokeException{}", e.getMessage());
return BaseResult.getFailureMessageEntity("内部方法执行错误，请联系管理员");
}
}
}
}
}
//TODO 判断是否有内部api
Map<String, String> headerMap = sysExtensionApiEntity.getHeaders();
String querys = sysExtensionApiEntity.getQuerys();
String bodys = sysExtensionApiEntity.getBodys();
//设置参数获取参数
StringBuffer url = new StringBuffer();
url.append(receiveApp.getInterfaceAddress());
@ -1815,7 +1806,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
}
logger.info("保存日志开始");
saveLog(sendApp, receiveApp, receiveApi, bodys, headerMap, headers, querys, body.toString(), jrff, fsqsj, fshsj);
saveLog(sendApp, receiveApp, receiveApi, oldbodys,bodys, oldheaderMap,headerMap, headers, oldquerys,querys, body.toString(), jrff, fsqsj, fshsj,true);
logger.info("保存日志结束");
if (flag) {
if (JSONUtil.isTypeJSON(body.toString())) {
@ -1875,7 +1866,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
}
}
logger.info("保存日志开始");
saveLog(sendApp, receiveApp, receiveApi, bodys, headerMap, headers, querys, body.toString(), jrff, fsqsj, fshsj);
saveLog(sendApp, receiveApp, receiveApi, oldbodys,bodys, oldheaderMap,headerMap, headers, oldquerys,querys, body.toString(), jrff, fsqsj, fshsj,true);
logger.info("保存日志结束");
if (flag) {
return BaseResult.getSuccessMessageEntity("转发成功", body);
@ -1944,7 +1935,12 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
* @Description 保存日志
* @Date 11:36 上午 2023/10/20
**/
private void saveLog(SysApplicationEntity sendApp, SysApplicationEntity receiveApp, SysApplicationApiEntity receiveApi, String bodys, Map<String, String> headerMap, Map<String, String> headers, String querys, String body, long jrff, long fsqsj, long fshsj) {
private void saveLog(SysApplicationEntity sendApp, SysApplicationEntity receiveApp, SysApplicationApiEntity receiveApi,
String oldbodys,String bodys,
Map<String, String> oldheaderMap,Map<String, String> headerMap,
Map<String, String> headers,
String oldquerys,String querys,
String body, long jrff, long fsqsj, long fshsj,boolean flag) {
SysMessageManageLogEntity sysMessageManageLogEntity = new SysMessageManageLogEntity();
//messageManageId 消息主表主键
//theme 消息主题
@ -1956,9 +1952,9 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
sysMessageManageLogEntity.setReceiveApp(receiveApp.getId());//接收者应用
sysMessageManageLogEntity.setReceiveApi(receiveApi.getId());//接收者
JSONObject jsonObject = new JSONObject();
jsonObject.put("body", bodys);
jsonObject.put("header", headerMap);
jsonObject.put("querys", querys);
jsonObject.put("body", oldbodys);
jsonObject.put("header", oldheaderMap);
jsonObject.put("querys", oldquerys);
sysMessageManageLogEntity.setSourceData(jsonObject.toString());//源数据
JSONObject send = new JSONObject();
send.put("body", bodys);
@ -1966,7 +1962,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
send.put("querys", querys);
sysMessageManageLogEntity.setTargetData(send.toString());//目标data
sysMessageManageLogEntity.setReturnData(body);//返回信息
//status 状态（1、待发送 2、发送中3、发送成功 4、发送失败）
//status 状态（1、待发送 2、发送中3、发送成功 4、发送失败,5、系统异常（根据三个参数查出来多个））
//{"ResCode":0,"Success":true,"ResMsg":"登录成功,token有效时间为10分钟","Data":"123123"}
List<String> st = Arrays.asList(new String[]{"8000060000"});
//{"orderNo":"DB1003108862178","ErrorCode":"","ResultString":"success","ResultInt":0}
@ -1974,13 +1970,18 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
//{"status":"success","data":"[{\\"pk_corp\\":\\"1015\\",\\"unitcode\\":\\"3401\\",\\"unitname\\":\\"hjx建设银行有限公司\\",\\"createdate\\":\\"2023-01-01\\",\\"deptattr\\":\\"1\\",\\"deptname\\":\\"API新增部门02\\",\\"deptcode\\":\\"DEV02\\",\\"pk_deptdoc\\":\\"1015A210000000001QJ7\\"}]","taskNumber":"202309110119"}
List<String> ss = Arrays.asList(new String[]{"8000160014", "8000160015", "8000160016", "8000160017", "8000160021", "8000160022", "8000160023", "8000160018", "8000160019", "8000160020", "8000160025", "8000160026", "8000160027", "8000160029", "8000160030"});
sysMessageManageLogEntity.setStatus("4");//返回信息
if(st.contains(receiveApi.getApiCode().toString())){
sysMessageManageLogEntity.setRemark("转发失败");//返回信息
if(!flag){
sysMessageManageLogEntity.setStatus("4");//返回信息
sysMessageManageLogEntity.setRemark("API未授权，请联系管理员");//返回信息
}else if (st.contains(receiveApi.getApiCode().toString())) {
if (JSONUtil.isTypeJSON(body)) {
JSONObject cheackdatas = JSONObject.parseObject(body);
String checkdata = cheackdatas.getString("Success");
if(checkdata != null && "true".equals(checkdata)){
sysMessageManageLogEntity.setStatus("3");//返回信息
sysMessageManageLogEntity.setRemark("转发成功");//返回信息
}
}
} else if (rs.contains(receiveApi.getApiCode().toString())) {
@ -1989,6 +1990,8 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
String checkdata = cheackdatas.getString("ResultString");
if(checkdata != null && "success".equals(checkdata)){
sysMessageManageLogEntity.setStatus("3");//返回信息
sysMessageManageLogEntity.setRemark("转发成功");//返回信息
}
}
} else if (ss.contains(receiveApi.getApiCode().toString())) {
@ -1997,15 +2000,16 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
String checkdata = cheackdatas.getString("status");
if(checkdata != null && "success".equals(checkdata)){
sysMessageManageLogEntity.setStatus("3");//返回信息
sysMessageManageLogEntity.setRemark("转发成功");//返回信息
}
}
} else {
sysMessageManageLogEntity.setStatus("3");//返回信息
sysMessageManageLogEntity.setRemark("转发成功");//返回信息
}
//remark 备注
long s1 = jrff - fsqsj;
long s2 = fsqsj - fshsj;
sysMessageManageLogEntity.setRemark("转发成功,发送前时间：" + s1 + "ms，发送时间：" + s2 + "ms");//返回信息
sysMessageManageLogEntity.setErrorStatus("2");//返回信息
sysMessageManageLogEntity.setId(UUIDUtils.getUUID());
sysMessageManageLogEntity.setCreate_user_id("c796fd9ba4c9f5ff3cc2fa41a040e443");
@ -2027,4 +2031,88 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
sysMessageManageLogDao.save(manageLogEntities);
}
/**
* @param object
* @return
* @Author lvleigang
* @Description 应用列表查询接口 多字段模糊查询，枚举类型字段转换
* @Date 2:06 下午 2023/9/23
**/
@Override
public JsonResultEntity thirdInterfacequeryApp(JSONObject object) {
SysApplicationDto entity = getData("jsonStr", object, SysApplicationDto.class);
//判断分页
if (entity == null || entity.getPageNum() == null || entity.getPageSize() == null) {
return BaseResult.getFailureMessageEntity("分页查询参数不存在");
}
PageHelper.startPage(entity.getPageNum(), entity.getPageSize());
List<SysApplicationVo> sysApplicationVos = sysApplicationDao.queryApp(entity);
PageInfo pageInfo = new PageInfo(sysApplicationVos);
return BaseResult.getSuccessMessageEntity("查询数据成功", pageInfo);
}
/**
* @param object
* @return
* @Author lvleigang
* @Description 应用列表查询接口 多字段模糊查询，枚举类型字段转换
* @Date 2:06 下午 2023/9/23
**/
@Override
public JsonResultEntity thirdInterfacequeryAppAll(JSONObject object) {
SysApplicationDto entity = getData("jsonStr", object, SysApplicationDto.class);
List<SysApplicationVo> sysApplicationVos = sysApplicationDao.queryApp(entity);
return BaseResult.getSuccessMessageEntity("查询数据成功", sysApplicationVos);
}
/**
* @param object
* @return
* @Author lvleigang
* @Description 查询接口日志 查询接口发送错误，以及不发送的数据
* @Date 2:08 下午 2023/9/23
**/
@Override
public JsonResultEntity thirdInterfacequeryAppApiLog(JSONObject object) {
SysMessageManageLogEntity entity = getData("jsonStr", object, SysMessageManageLogEntity.class);
//判断分页
if (entity == null || entity.getPageNum() == null || entity.getPageSize() == null) {
return BaseResult.getFailureMessageEntity("分页查询参数不存在");
}
//日期转换
if (entity.getCreateTimeStart() != null) {
DateTime beginOfDay = DateUtil.beginOfDay(entity.getCreateTimeStart());
entity.setCreateTimeStart(beginOfDay);
}
//日期转换
if (entity.getCreateTimeEnd() != null) {
DateTime endOfDay = DateUtil.endOfDay(entity.getCreateTimeEnd());
entity.setCreateTimeEnd(endOfDay);
}
PageHelper.startPage(entity.getPageNum(), entity.getPageSize());
List<String> ids = sysMessageManageLogDao.querySysMessageManageLogIds(entity);
PageInfo pageInfo = new PageInfo(ids);
List<SysMessageManageLogPageVo> sysMessageManageLogEntities = new ArrayList<>();
if (ids != null && ids.size() > 0) {
entity.setIds(ids);
sysMessageManageLogEntities = sysMessageManageLogDao.queryListByErrorPageVo(entity);
}
pageInfo.setList(sysMessageManageLogEntities);
return BaseResult.getSuccessMessageEntity("查询数据成功", pageInfo);
}
/**
* @param object
* @return
* @Author lvleigang
* @Description 查询接口
* @Date 2:08 下午 2023/9/23
**/
@Override
public JsonResultEntity thirdInterfacequeryAppApi(JSONObject object) {
SysApplicationApiEntity entity = getData("jsonStr", object, SysApplicationApiEntity.class);
List<SysApplicationApiEntity> ids = sysApplicationApiDao.queryBaseName(entity);
return BaseResult.getSuccessMessageEntity("查询数据成功", ids);
}
}

9
service/src/main/java/com/hzya/frame/sysnew/messageManageLog/service/ISysMessageManageLogService.java
View File

@ -58,4 +58,13 @@ public interface ISysMessageManageLogService extends IBaseService<SysMessageMana
* @Date 2024/3/7 10:17
* **/
JsonResultEntity queryBackupData(JSONObject jsonObject);
/**
* @Author lvleigang
* @Description 根据id查询对象
* @Date 9:45 上午 2023/8/29
* @param jsonObject
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
JsonResultEntity thirdInterfacequeryEntity(JSONObject jsonObject);
}

22
service/src/main/java/com/hzya/frame/sysnew/messageManageLog/service/impl/SysMessageManageLogServiceImpl.java
View File

@ -205,4 +205,26 @@ public class SysMessageManageLogServiceImpl extends BaseService<SysMessageManage
}
return null;
}
/**
* @Author lvleigang
* @Description 根据id查询对象
* @Date 9:45 上午 2023/8/29
* @param object
* @return com.hzya.frame.web.entity.JsonResultEntity
**/
@Override
public JsonResultEntity thirdInterfacequeryEntity(JSONObject object) {
SysMessageManageLogEntity entity = getData("jsonStr", object, SysMessageManageLogEntity.class);
//判断主键
if (entity == null || entity.getId() == null || "".equals(entity.getId())) {
return BaseResult.getFailureMessageEntity("请先传递请求主键");
}
entity = sysMessageManageLogDao.queryOne(entity);
if (entity != null && entity.getId() != null) {
return BaseResult.getSuccessMessageEntity("查询数据成功", entity);
} else {
return BaseResult.getFailureMessageEntity("未查询到数据");
}
}
}

4
service/src/main/java/com/hzya/frame/sysnew/testCaching/service/ITestCachingService.java
View File

@ -2,6 +2,7 @@ package com.hzya.frame.sysnew.testCaching.service;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.basedao.service.IBaseService;
import com.hzya.frame.sysnew.application.entity.SysExtensionApiEntity;
import com.hzya.frame.sysnew.sysInterface.entity.SysInterfaceEntity;
import com.hzya.frame.sysnew.user.entity.SysUserEntity;
import com.hzya.frame.web.entity.JsonResultEntity;
@ -14,4 +15,7 @@ import com.hzya.frame.web.entity.JsonResultEntity;
*/
public interface ITestCachingService {
SysUserEntity getEntity(String id);
SysExtensionApiEntity testExtensionApi(SysExtensionApiEntity entity);
}

10
service/src/main/java/com/hzya/frame/sysnew/testCaching/service/impl/TestCachingServiceImpl.java
View File

@ -1,6 +1,7 @@
package com.hzya.frame.sysnew.testCaching.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.sysnew.application.entity.SysExtensionApiEntity;
import com.hzya.frame.sysnew.testCaching.service.ITestCachingService;
import com.hzya.frame.sysnew.user.dao.ISysUserDao;
import com.hzya.frame.sysnew.user.entity.SysUserEntity;
@ -10,7 +11,7 @@ import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
@Service(value = "testCachingService")
public class TestCachingServiceImpl implements ITestCachingService {
@Resource
@ -31,4 +32,11 @@ public class TestCachingServiceImpl implements ITestCachingService {
SysUserEntity sysUserEntity = sysUserDao.get(id);
return sysUserEntity;
}
@Override
public SysExtensionApiEntity testExtensionApi(SysExtensionApiEntity entity) {
entity.setQuerys("userCode=admin&entcode=004&orgcode=100303&clientid=001&clientsecret=3a4738524e1344309b9988b5b42c5a1a");
System.out.println(entity);
return entity;
}
}

6
service/src/main/java/com/hzya/frame/u8c/ax/service/impl/AxServiceImpl.java
View File

@ -61,9 +61,9 @@ public class AxServiceImpl extends BaseService<ArchivesEntity, String> implement
private final String bmApiCodexg = "8000160016";//部门档案修改
private final String bmApiCodesc = "8000160017";//部门档案删除
private final String chApiCodexz = "8000160021";//存货对照新增
private final String chApiCodexg = "8000160022";//存货对照修改
private final String chApiCodesc = "8000160023";//存货对照删除
private final String chApiCodexz = "8000160025";//存货对照新增
private final String chApiCodexg = "8000160026";//存货对照修改
private final String chApiCodesc = "8000160027";//存货对照删除
private final String ksApiCodexz = "8000160018";//客商辅助核算新增
private final String ksApiCodexg = "8000160019";//客商辅助核算修改