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

集成任务添加状态字段

This commit is contained in:
lvleigang 2024-09-25 16:52:00 +08:00
parent 62cf866111
commit 23d06b59bb
3 changed files with 45 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
base-service/src/main/java/com/hzya/frame/sysnew/integratedForegroundTask/service/impl/SysIntegratedForegroundTaskServiceImpl.java
View File

@ -106,17 +106,24 @@ public class SysIntegratedForegroundTaskServiceImpl extends BaseService<SysInteg
sysIntegratedForegroundTaskParameterEntity.setFormmainId(entity.getId()); sysIntegratedForegroundTaskParameterEntity.setFormmainId(entity.getId());
sysIntegratedForegroundTaskParameterEntity.setInParameter(jsonObject.toJSONString()); sysIntegratedForegroundTaskParameterEntity.setInParameter(jsonObject.toJSONString());
sysIntegratedForegroundTaskParameterEntity.setCreate(); sysIntegratedForegroundTaskParameterEntity.setCreate();
sysIntegratedForegroundTaskParameterEntity.setStatus("1");
sysIntegratedForegroundTaskParameterDao.save(sysIntegratedForegroundTaskParameterEntity); sysIntegratedForegroundTaskParameterDao.save(sysIntegratedForegroundTaskParameterEntity);
PluginBaseEntity pluginBaseEntity = PluginUtils.getPluginsById(entity.getPlugId()); PluginBaseEntity pluginBaseEntity = PluginUtils.getPluginsById(entity.getPlugId());
if(pluginBaseEntity != null ){ if(pluginBaseEntity != null ){
taskExecutor.execute(() -> { taskExecutor.execute(() -> {
try { try {
pluginBaseEntity.executeBusiness(jsonObject); pluginBaseEntity.executeBusiness(jsonObject);
sysIntegratedForegroundTaskParameterEntity.setStatus("2");
sysIntegratedForegroundTaskParameterEntity.setModify_time(new Date());
sysIntegratedForegroundTaskParameterDao.update(sysIntegratedForegroundTaskParameterEntity);
} catch (Exception e) { } catch (Exception e) {
logger.error("插件："+entity.getPlugId()+"执行失败："+e.getMessage()); logger.error("插件："+entity.getPlugId()+"执行失败："+e.getMessage());
} }
}); });
}else { }else {
sysIntegratedForegroundTaskParameterEntity.setStatus("2");
sysIntegratedForegroundTaskParameterEntity.setModify_time(new Date());
sysIntegratedForegroundTaskParameterDao.update(sysIntegratedForegroundTaskParameterEntity);
return BaseResult.getSuccessMessageEntity("提交成功，当前任务执行失败，请联系系统管理员"); return BaseResult.getSuccessMessageEntity("提交成功，当前任务执行失败，请联系系统管理员");
} }
return BaseResult.getSuccessMessageEntity("提交成功，执行结果请去查看任务日志"); return BaseResult.getSuccessMessageEntity("提交成功，执行结果请去查看任务日志");
@ -171,17 +178,25 @@ public class SysIntegratedForegroundTaskServiceImpl extends BaseService<SysInteg
sysIntegratedForegroundTaskParameterEntity.setFormmainId(entity.getId()); sysIntegratedForegroundTaskParameterEntity.setFormmainId(entity.getId());
sysIntegratedForegroundTaskParameterEntity.setInParameter(jsonObject.toJSONString()); sysIntegratedForegroundTaskParameterEntity.setInParameter(jsonObject.toJSONString());
sysIntegratedForegroundTaskParameterEntity.setCreate(); sysIntegratedForegroundTaskParameterEntity.setCreate();
sysIntegratedForegroundTaskParameterEntity.setStatus("1");
sysIntegratedForegroundTaskParameterDao.save(sysIntegratedForegroundTaskParameterEntity); sysIntegratedForegroundTaskParameterDao.save(sysIntegratedForegroundTaskParameterEntity);
PluginBaseEntity pluginBaseEntity = PluginUtils.getPluginsById(entity.getPlugId()); PluginBaseEntity pluginBaseEntity = PluginUtils.getPluginsById(entity.getPlugId());
if(pluginBaseEntity != null ){ if(pluginBaseEntity != null ){
taskExecutor.execute(() -> { taskExecutor.execute(() -> {
try { try {
pluginBaseEntity.executeBusiness(jsonObject); pluginBaseEntity.executeBusiness(jsonObject);
sysIntegratedForegroundTaskParameterEntity.setStatus("2");
sysIntegratedForegroundTaskParameterEntity.setModify_time(new Date());
sysIntegratedForegroundTaskParameterDao.update(sysIntegratedForegroundTaskParameterEntity);
} catch (Exception e) { } catch (Exception e) {
logger.error("插件："+entity.getPlugId()+"执行失败："+e.getMessage()); logger.error("插件："+entity.getPlugId()+"执行失败："+e.getMessage());
} }
}); });
}else { }else {
sysIntegratedForegroundTaskParameterEntity.setStatus("2");
sysIntegratedForegroundTaskParameterEntity.setModify_time(new Date());
sysIntegratedForegroundTaskParameterDao.update(sysIntegratedForegroundTaskParameterEntity);
return BaseResult.getSuccessMessageEntity("提交成功，当前任务执行失败，请联系系统管理员"); return BaseResult.getSuccessMessageEntity("提交成功，当前任务执行失败，请联系系统管理员");
} }
return BaseResult.getSuccessMessageEntity("提交成功，执行结果请去查看任务日志"); return BaseResult.getSuccessMessageEntity("提交成功，执行结果请去查看任务日志");

11
base-service/src/main/java/com/hzya/frame/sysnew/integratedForegroundTaskParameter/entity/SysIntegratedForegroundTaskParameterEntity.java
View File

@ -20,7 +20,8 @@ public class SysIntegratedForegroundTaskParameterEntity extends BaseEntity {
private String inParameter; private String inParameter;
/** 备注 */ /** 备注 */
private String remark; private String remark;
/** 任务状态 1、执行中 2、执行完成 */
private String status;
public String getFormmainId() { public String getFormmainId() {
return formmainId; return formmainId;
@ -53,5 +54,13 @@ public class SysIntegratedForegroundTaskParameterEntity extends BaseEntity {
this.setCreate_time(new Date()); this.setCreate_time(new Date());
this.setModify_time(new Date()); this.setModify_time(new Date());
} }
public String getStatus() {
return status;
}
public void setStatus(String status) {
this.status = status;
}
} }

22
base-service/src/main/java/com/hzya/frame/sysnew/integratedForegroundTaskParameter/entity/SysIntegratedForegroundTaskParameterEntity.xml
View File

@ -7,6 +7,8 @@
<result property="formmainId" column="formmain_id" jdbcType="VARCHAR"/> <result property="formmainId" column="formmain_id" jdbcType="VARCHAR"/>
<result property="inParameter" column="in_parameter" jdbcType="VARCHAR"/> <result property="inParameter" column="in_parameter" jdbcType="VARCHAR"/>
<result property="remark" column="remark" jdbcType="VARCHAR"/> <result property="remark" column="remark" jdbcType="VARCHAR"/>
<result property="status" column="status" jdbcType="VARCHAR"/>
<result property="sorts" column="sorts" jdbcType="INTEGER"/> <result property="sorts" column="sorts" jdbcType="INTEGER"/>
<result property="create_user_id" column="create_user_id" jdbcType="VARCHAR"/> <result property="create_user_id" column="create_user_id" jdbcType="VARCHAR"/>
<result property="create_time" column="create_time" jdbcType="TIMESTAMP"/> <result property="create_time" column="create_time" jdbcType="TIMESTAMP"/>
@ -21,6 +23,7 @@
,formmain_id ,formmain_id
,in_parameter ,in_parameter
,remark ,remark
,status
,sorts ,sorts
,create_user_id ,create_user_id
,create_time ,create_time
@ -39,6 +42,7 @@
<if test="formmainId != null and formmainId != ''"> and formmain_id = #{formmainId} </if> <if test="formmainId != null and formmainId != ''"> and formmain_id = #{formmainId} </if>
<if test="inParameter != null and inParameter != ''"> and in_parameter = #{inParameter} </if> <if test="inParameter != null and inParameter != ''"> and in_parameter = #{inParameter} </if>
<if test="remark != null and remark != ''"> and remark = #{remark} </if> <if test="remark != null and remark != ''"> and remark = #{remark} </if>
<if test="status != null and status != ''"> and status = #{status} </if>
<if test="sorts != null"> and sorts = #{sorts} </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_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="create_time != null"> and create_time = #{create_time} </if>
@ -60,6 +64,7 @@
<if test="formmainId != null and formmainId != ''"> and formmain_id = #{formmainId} </if> <if test="formmainId != null and formmainId != ''"> and formmain_id = #{formmainId} </if>
<if test="inParameter != null and inParameter != ''"> and in_parameter = #{inParameter} </if> <if test="inParameter != null and inParameter != ''"> and in_parameter = #{inParameter} </if>
<if test="remark != null and remark != ''"> and remark = #{remark} </if> <if test="remark != null and remark != ''"> and remark = #{remark} </if>
<if test="status != null and status != ''"> and status = #{status} </if>
<if test="sorts != null"> and sorts = #{sorts} </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_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="create_time != null"> and create_time = #{create_time} </if>
@ -83,6 +88,7 @@
<if test="formmainId != null and formmainId != ''"> and formmain_id like concat('%',#{formmainId},'%') </if> <if test="formmainId != null and formmainId != ''"> and formmain_id like concat('%',#{formmainId},'%') </if>
<if test="inParameter != null and inParameter != ''"> and in_parameter like concat('%',#{inParameter},'%') </if> <if test="inParameter != null and inParameter != ''"> and in_parameter like concat('%',#{inParameter},'%') </if>
<if test="remark != null and remark != ''"> and remark like concat('%',#{remark},'%') </if> <if test="remark != null and remark != ''"> and remark like concat('%',#{remark},'%') </if>
<if test="status != null and status != ''"> and status like concat('%',#{status},'%') </if>
<if test="sorts != null"> and sorts like concat('%',#{sorts},'%') </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},'%') </if> <if test="create_user_id != null and create_user_id != ''"> and create_user_id like concat('%',#{create_user_id},'%') </if>
<if test="create_time != null"> and create_time like concat('%',#{create_time},'%') </if> <if test="create_time != null"> and create_time like concat('%',#{create_time},'%') </if>
@ -106,6 +112,7 @@
<if test="formmainId != null and formmainId != ''"> or formmain_id = #{formmainId} </if> <if test="formmainId != null and formmainId != ''"> or formmain_id = #{formmainId} </if>
<if test="inParameter != null and inParameter != ''"> or in_parameter = #{inParameter} </if> <if test="inParameter != null and inParameter != ''"> or in_parameter = #{inParameter} </if>
<if test="remark != null and remark != ''"> or remark = #{remark} </if> <if test="remark != null and remark != ''"> or remark = #{remark} </if>
<if test="status != null and status != ''"> or status = #{status} </if>
<if test="sorts != null"> or sorts = #{sorts} </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_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> <if test="create_time != null"> or create_time = #{create_time} </if>
@ -127,6 +134,7 @@
<if test="formmainId != null and formmainId != ''"> formmain_id , </if> <if test="formmainId != null and formmainId != ''"> formmain_id , </if>
<if test="inParameter != null and inParameter != ''"> in_parameter , </if> <if test="inParameter != null and inParameter != ''"> in_parameter , </if>
<if test="remark != null and remark != ''"> remark , </if> <if test="remark != null and remark != ''"> remark , </if>
<if test="status != null and status != ''"> status , </if>
<if test="sorts != null"> sorts , </if> <if test="sorts != null"> sorts , </if>
<if test="create_user_id != null and create_user_id != ''"> create_user_id , </if> <if test="create_user_id != null and create_user_id != ''"> create_user_id , </if>
<if test="create_time != null"> create_time , </if> <if test="create_time != null"> create_time , </if>
@ -142,6 +150,7 @@
<if test="formmainId != null and formmainId != ''"> #{formmainId} ,</if> <if test="formmainId != null and formmainId != ''"> #{formmainId} ,</if>
<if test="inParameter != null and inParameter != ''"> #{inParameter} ,</if> <if test="inParameter != null and inParameter != ''"> #{inParameter} ,</if>
<if test="remark != null and remark != ''"> #{remark} ,</if> <if test="remark != null and remark != ''"> #{remark} ,</if>
<if test="status != null and status != ''"> #{status} ,</if>
<if test="sorts != null"> #{sorts} ,</if> <if test="sorts != null"> #{sorts} ,</if>
<if test="create_user_id != null and create_user_id != ''"> #{create_user_id} ,</if> <if test="create_user_id != null and create_user_id != ''"> #{create_user_id} ,</if>
<if test="create_time != null"> #{create_time} ,</if> <if test="create_time != null"> #{create_time} ,</if>
@ -155,23 +164,24 @@
</insert> </insert>
<!-- 批量新增 --> <!-- 批量新增 -->
<insert id="entityInsertBatch" > <insert id="entityInsertBatch" >
insert into sys_integrated_foreground_task_parameter(formmain_id, in_parameter, remark, sorts, create_user_id, create_time, modify_user_id, modify_time, sts, org_id, sts) insert into sys_integrated_foreground_task_parameter(formmain_id, in_parameter, remark, status, sorts, create_user_id, create_time, modify_user_id, modify_time, sts, org_id, sts)
values values
<foreach collection="entities" item="entity" separator=","> <foreach collection="entities" item="entity" separator=",">
(#{entity.formmainId},#{entity.inParameter},#{entity.remark},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id}, 'Y') (#{entity.formmainId},#{entity.inParameter},#{entity.remark},#{entity.status},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id}, 'Y')
</foreach> </foreach>
</insert> </insert>
<!-- 批量新增或者修改--> <!-- 批量新增或者修改-->
<insert id="entityInsertOrUpdateBatch" > <insert id="entityInsertOrUpdateBatch" >
insert into sys_integrated_foreground_task_parameter(formmain_id, in_parameter, remark, sorts, create_user_id, create_time, modify_user_id, modify_time, sts, org_id) insert into sys_integrated_foreground_task_parameter(formmain_id, in_parameter, remark,status, sorts, create_user_id, create_time, modify_user_id, modify_time, sts, org_id)
values values
<foreach collection="entities" item="entity" separator=","> <foreach collection="entities" item="entity" separator=",">
(#{entity.formmainId},#{entity.inParameter},#{entity.remark},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id}) (#{entity.formmainId},#{entity.inParameter},#{entity.remark},#{entity.status},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id})
</foreach> </foreach>
on duplicate key update on duplicate key update
formmain_id = values(formmain_id), formmain_id = values(formmain_id),
in_parameter = values(in_parameter), in_parameter = values(in_parameter),
remark = values(remark), remark = values(remark),
status = values(status),
sorts = values(sorts), sorts = values(sorts),
create_user_id = values(create_user_id), create_user_id = values(create_user_id),
create_time = values(create_time), create_time = values(create_time),
@ -186,6 +196,7 @@ update sys_integrated_foreground_task_parameter set
<if test="formmainId != null and formmainId != ''"> formmain_id = #{formmainId},</if> <if test="formmainId != null and formmainId != ''"> formmain_id = #{formmainId},</if>
<if test="inParameter != null and inParameter != ''"> in_parameter = #{inParameter},</if> <if test="inParameter != null and inParameter != ''"> in_parameter = #{inParameter},</if>
<if test="remark != null and remark != ''"> remark = #{remark},</if> <if test="remark != null and remark != ''"> remark = #{remark},</if>
<if test="status != null and status != ''"> status = #{status},</if>
<if test="sorts != null"> sorts = #{sorts},</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_user_id != null and create_user_id != ''"> create_user_id = #{create_user_id},</if>
<if test="create_time != null"> create_time = #{create_time},</if> <if test="create_time != null"> create_time = #{create_time},</if>
@ -209,6 +220,7 @@ update sys_integrated_foreground_task_parameter set sts= 'N' ,modify_time = #{m
<if test="formmainId != null and formmainId != ''"> and formmain_id = #{formmainId} </if> <if test="formmainId != null and formmainId != ''"> and formmain_id = #{formmainId} </if>
<if test="inParameter != null and inParameter != ''"> and in_parameter = #{inParameter} </if> <if test="inParameter != null and inParameter != ''"> and in_parameter = #{inParameter} </if>
<if test="remark != null and remark != ''"> and remark = #{remark} </if> <if test="remark != null and remark != ''"> and remark = #{remark} </if>
<if test="status != null and status != ''"> and status = #{status} </if>
<if test="sorts != null"> and sorts = #{sorts} </if> <if test="sorts != null"> and sorts = #{sorts} </if>
<if test="sts != null and sts != ''"> and sts = #{sts} </if> <if test="sts != null and sts != ''"> and sts = #{sts} </if>
and sts='Y' and sts='Y'
@ -226,6 +238,7 @@ update sys_integrated_foreground_task_parameter set sts= 'N' ,modify_time = #{m
,a.formmain_id ,a.formmain_id
,a.in_parameter ,a.in_parameter
,a.remark ,a.remark
,a.status
,a.sorts ,a.sorts
,p.person_name as create_user_id ,p.person_name as create_user_id
,a.create_time ,a.create_time
@ -241,6 +254,7 @@ update sys_integrated_foreground_task_parameter set sts= 'N' ,modify_time = #{m
<if test="formmainId != null and formmainId != ''"> and a.formmain_id = #{formmainId} </if> <if test="formmainId != null and formmainId != ''"> and a.formmain_id = #{formmainId} </if>
<if test="inParameter != null and inParameter != ''"> and a.in_parameter = #{inParameter} </if> <if test="inParameter != null and inParameter != ''"> and a.in_parameter = #{inParameter} </if>
<if test="remark != null and remark != ''"> and a.remark = #{remark} </if> <if test="remark != null and remark != ''"> and a.remark = #{remark} </if>
<if test="status != null and status != ''"> and a.status = #{status} </if>
<if test="sorts != null"> and a.sorts = #{sorts} </if> <if test="sorts != null"> and a.sorts = #{sorts} </if>
<if test="create_user_id != null and create_user_id != ''"> and a.create_user_id = #{create_user_id} </if> <if test="create_user_id != null and create_user_id != ''"> and a.create_user_id = #{create_user_id} </if>
<if test="create_time != null"> and a.create_time = #{create_time} </if> <if test="create_time != null"> and a.create_time = #{create_time} </if>