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

增加nifi字段

This commit is contained in:
xiang2lin 2025-05-12 13:46:04 +08:00
parent a0ab2e87ba
commit bd9c7b166d
4 changed files with 37 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
base-service/src/main/java/com/hzya/frame/sysnew/application/entity/SysApplicationDto.java
View File

@ -61,6 +61,8 @@ public class SysApplicationDto {
private List<SysApplicationApiParaEntity> apiParas;
/** 系统类型 1、致远OA 2、用友U8C 3、用友BIP */
private String appType;
//nifi的id
private String nifiAppId;
//数据源
private SysApplicationDatabaseEntity databaseEntity;
private Integer pageNum;
@ -271,5 +273,13 @@ public class SysApplicationDto {
public void setAppType(String appType) {
this.appType = appType;
}
public String getNifiAppId() {
return nifiAppId;
}
public void setNifiAppId(String nifiAppId) {
this.nifiAppId = nifiAppId;
}
}

10
base-service/src/main/java/com/hzya/frame/sysnew/application/entity/SysApplicationEntity.java
View File

@ -44,6 +44,8 @@ public class SysApplicationEntity extends BaseEntity {
private String dbStatus;
/** 新消息数 */
private int newMessageCount;
//nifi的appid
private String nifiAppId;
public int getNewMessageCount() {
return newMessageCount;
@ -211,5 +213,13 @@ public class SysApplicationEntity extends BaseEntity {
public void setAppType(String appType) {
this.appType = appType;
}
public String getNifiAppId() {
return nifiAppId;
}
public void setNifiAppId(String nifiAppId) {
this.nifiAppId = nifiAppId;
}
}

20
base-service/src/main/java/com/hzya/frame/sysnew/application/entity/SysApplicationEntity.xml
View File

@ -23,6 +23,7 @@
<result property="interfaceStatus" column="interface_status" jdbcType="VARCHAR"/>
<result property="dbStatus" column="db_status" jdbcType="VARCHAR"/>
<result property="appType" column="app_type" jdbcType="VARCHAR"/>
<result property="nifiAppId" column="nifi_app_id" jdbcType="VARCHAR"/>
<result property="sorts" column="sorts" jdbcType="INTEGER"/>
<result property="org_id" column="org_id" jdbcType="VARCHAR"/>
<result property="sts" column="sts" jdbcType="VARCHAR"/>
@ -53,6 +54,7 @@
,interface_status
,db_status
,app_type
,nifi_app_id
,sorts
,org_id
,sts
@ -93,6 +95,7 @@
<if test="interfaceStatus != null and interfaceStatus != ''"> and interface_status = #{interfaceStatus} </if>
<if test="dbStatus != null and dbStatus != ''"> and db_status = #{dbStatus} </if>
<if test="appType != null and appType != ''"> and app_type = #{appType} </if>
<if test="nifiAppId != null and nifiAppId != ''"> and nifi_app_id = #{nifiAppId} </if>
<if test="sorts != null"> and sorts = #{sorts} </if>
<if test="org_id != null and org_id != ''"> and org_id = #{org_id} </if>
<if test="sts != null and sts != ''"> and sts = #{sts} </if>
@ -130,6 +133,7 @@
<if test="interfaceStatus != null and interfaceStatus != ''"> and interface_status = #{interfaceStatus} </if>
<if test="dbStatus != null and dbStatus != ''"> and db_status = #{dbStatus} </if>
<if test="appType != null and appType != ''"> and app_type = #{appType} </if>
<if test="nifiAppId != null and nifiAppId != ''"> and nifi_app_id = #{nifiAppId} </if>
<if test="sorts != null"> and sorts = #{sorts} </if>
<if test="org_id != null and org_id != ''"> and org_id = #{org_id} </if>
<if test="sts != null and sts != ''"> and sts = #{sts} </if>
@ -169,6 +173,7 @@
<if test="interfaceStatus != null and interfaceStatus != ''"> and interface_status like concat('%',#{interfaceStatus},'%') </if>
<if test="dbStatus != null and dbStatus != ''"> and db_status like concat('%',#{dbStatus},'%') </if>
<if test="appType != null and appType != ''"> and app_type like concat('%',#{appType},'%') </if>
<if test="nifiAppId != null and nifiAppId != ''"> and nifi_app_id like concat('%',#{nifiAppId},'%') </if>
<if test="sorts != null"> and sorts like concat('%',#{sorts},'%') </if>
<if test="org_id != null and org_id != ''"> and org_id like concat('%',#{org_id},'%') </if>
<if test="sts != null and sts != ''"> and sts like concat('%',#{sts},'%') </if>
@ -208,6 +213,7 @@
<if test="interfaceStatus != null and interfaceStatus != ''"> or interface_status = #{interfaceStatus} </if>
<if test="dbStatus != null and dbStatus != ''"> or db_status = #{dbStatus} </if>
<if test="appType != null and appType != ''"> or app_type = #{appType} </if>
<if test="nifiAppId != null and nifiAppId != ''"> or nifi_app_id = #{nifiAppId} </if>
<if test="sorts != null"> or sorts = #{sorts} </if>
<if test="org_id != null and org_id != ''"> or org_id = #{org_id} </if>
<if test="sts != null and sts != ''"> or sts = #{sts} </if>
@ -246,6 +252,7 @@
<if test="interfaceStatus != null and interfaceStatus != ''"> interface_status , </if>
<if test="dbStatus != null and dbStatus != ''"> db_status , </if>
<if test="appType != null and appType != ''"> app_type , </if>
<if test="nifiAppId != null and nifiAppId != ''"> nifi_app_id , </if>
<if test="sorts != null"> sorts , </if>
<if test="org_id != null and org_id != ''"> org_id , </if>
<if test="sts != null and sts != ''"> sts , </if>
@ -278,6 +285,7 @@
<if test="interfaceStatus != null and interfaceStatus != ''"> #{interfaceStatus} ,</if>
<if test="dbStatus != null and dbStatus != ''"> #{dbStatus} ,</if>
<if test="appType != null and appType != ''"> #{appType} ,</if>
<if test="nifiAppId != null and nifiAppId != ''"> #{nifiAppId} ,</if>
<if test="sorts != null"> #{sorts} ,</if>
<if test="org_id != null and org_id != ''"> #{org_id} ,</if>
<if test="sts != null and sts != ''"> #{sts} ,</if>
@ -291,18 +299,18 @@
</insert>
<!-- 批量新增 -->
<insert id="entityInsertBatch" >
insert into sys_application(app_logo, app_status, name, version_number, app_id, system_address, access_mode, affiliation_field, manufacturer, app_introduction, client_path, web_path, program_path, public_key, secret_key, interface_address, interface_status, db_status,app_type, sorts, org_id, sts, create_time, create_user_id, modify_time, modify_user_id, sts)
insert into sys_application(app_logo, app_status, name, version_number, app_id, system_address, access_mode, affiliation_field, manufacturer, app_introduction, client_path, web_path, program_path, public_key, secret_key, interface_address, interface_status, db_status,app_type,nifi_app_id, sorts, org_id, sts, create_time, create_user_id, modify_time, modify_user_id, sts)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.appLogo},#{entity.appStatus},#{entity.name},#{entity.versionNumber},#{entity.appId},#{entity.systemAddress},#{entity.accessMode},#{entity.affiliationField},#{entity.manufacturer},#{entity.appIntroduction},#{entity.clientPath},#{entity.webPath},#{entity.programPath},#{entity.publicKey},#{entity.secretKey},#{entity.interfaceAddress},#{entity.interfaceStatus},#{entity.dbStatus},#{entity.appType},#{entity.sorts},#{entity.org_id},#{entity.sts},#{entity.create_time},#{entity.create_user_id},#{entity.modify_time},#{entity.modify_user_id}, 'Y')
(#{entity.appLogo},#{entity.appStatus},#{entity.name},#{entity.versionNumber},#{entity.appId},#{entity.systemAddress},#{entity.accessMode},#{entity.affiliationField},#{entity.manufacturer},#{entity.appIntroduction},#{entity.clientPath},#{entity.webPath},#{entity.programPath},#{entity.publicKey},#{entity.secretKey},#{entity.interfaceAddress},#{entity.interfaceStatus},#{entity.dbStatus},#{entity.appType},#{entity.nifiAppId},#{entity.sorts},#{entity.org_id},#{entity.sts},#{entity.create_time},#{entity.create_user_id},#{entity.modify_time},#{entity.modify_user_id}, 'Y')
</foreach>
</insert>
<!-- 批量新增或者修改-->
<insert id="entityInsertOrUpdateBatch" >
insert into sys_application(app_logo, app_status, name, version_number,app_id,system_address, access_mode, affiliation_field, manufacturer, app_introduction, client_path, web_path, program_path, public_key, secret_key, interface_address, interface_status, db_status,app_type, sorts, org_id, sts, create_time, create_user_id, modify_time, modify_user_id)
insert into sys_application(app_logo, app_status, name, version_number,app_id,system_address, access_mode, affiliation_field, manufacturer, app_introduction, client_path, web_path, program_path, public_key, secret_key, interface_address, interface_status, db_status,app_type,nifi_app_id, sorts, org_id, sts, create_time, create_user_id, modify_time, modify_user_id)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.appLogo},#{entity.appStatus},#{entity.name},#{entity.versionNumber},#{entity.appId},#{entity.systemAddress},#{entity.accessMode},#{entity.affiliationField},#{entity.manufacturer},#{entity.appIntroduction},#{entity.clientPath},#{entity.webPath},#{entity.programPath},#{entity.publicKey},#{entity.secretKey},#{entity.interfaceAddress},#{entity.interfaceStatus},#{entity.dbStatus},#{entity.appType},#{entity.sorts},#{entity.org_id},#{entity.sts},#{entity.create_time},#{entity.create_user_id},#{entity.modify_time},#{entity.modify_user_id})
(#{entity.appLogo},#{entity.appStatus},#{entity.name},#{entity.versionNumber},#{entity.appId},#{entity.systemAddress},#{entity.accessMode},#{entity.affiliationField},#{entity.manufacturer},#{entity.appIntroduction},#{entity.clientPath},#{entity.webPath},#{entity.programPath},#{entity.publicKey},#{entity.secretKey},#{entity.interfaceAddress},#{entity.interfaceStatus},#{entity.dbStatus},#{entity.appType},#{entity.nifiAppId},#{entity.sorts},#{entity.org_id},#{entity.sts},#{entity.create_time},#{entity.create_user_id},#{entity.modify_time},#{entity.modify_user_id})
</foreach>
on duplicate key update
app_logo = values(app_logo),
@ -324,6 +332,7 @@
interface_status = values(interface_status),
db_status = values(db_status),
app_type = values(app_type),
nifi_app_id = values(nifi_app_id),
sorts = values(sorts),
org_id = values(org_id),
sts = values(sts),
@ -354,6 +363,7 @@ update sys_application set
<if test="interfaceStatus != null and interfaceStatus != ''"> interface_status = #{interfaceStatus},</if>
<if test="dbStatus != null and dbStatus != ''"> db_status = #{dbStatus},</if>
<if test="appType != null and appType != ''"> app_type = #{appType},</if>
<if test="nifiAppId != null and nifiAppId != ''"> nifi_app_id = #{nifiAppId},</if>
<if test="sorts != null"> sorts = #{sorts},</if>
<if test="org_id != null and org_id != ''"> org_id = #{org_id},</if>
<if test="sts != null and sts != ''"> sts = #{sts},</if>
@ -393,6 +403,7 @@ update sys_application set sts= 'N' ,modify_time = #{modify_time},modify_user_i
<if test="interfaceStatus != null and interfaceStatus != ''"> and interface_status = #{interfaceStatus} </if>
<if test="dbStatus != null and dbStatus != ''"> and db_status = #{dbStatus} </if>
<if test="appType != null and appType != ''"> and app_type = #{appType} </if>
<if test="nifiAppId != null and nifiAppId != ''"> and nifi_app_id = #{nifiAppId} </if>
<if test="sorts != null"> and sorts = #{sorts} </if>
<if test="sts != null and sts != ''"> and sts = #{sts} </if>
and sts='Y'
@ -421,6 +432,7 @@ update sys_application set sts= 'N' ,modify_time = #{modify_time},modify_user_i
,a.interface_status as interfaceStatus
,a.db_status as dbStatus
,a.app_type as appType
,a.nifi_app_id as nifiAppId
from sys_application a
<trim prefix="where" prefixOverrides="and">
<if test="affiliationField != null and affiliationField != ''"> and a.affiliation_field = #{affiliationField} </if>

1
base-service/src/main/java/com/hzya/frame/sysnew/application/service/impl/SysApplicationServiceImpl.java
View File

@ -718,6 +718,7 @@ public class SysApplicationServiceImpl extends BaseService<SysApplicationEntity,
sysApplicationEntity.setSts("Y");
sysApplicationEntity.setModify_user_id(StpUtil.getLoginIdAsString());
sysApplicationEntity.setModify_time(new Date());
sysApplicationEntity.setNifiAppId(entity.getNifiAppId());
sysApplicationDao.update(sysApplicationEntity);
applicationCache.reloadData("1");
return sysApplicationEntity;