diff --git a/service/src/main/java/com/hzya/frame/mdm/service/impl/MdmServiceImpl.java b/service/src/main/java/com/hzya/frame/mdm/service/impl/MdmServiceImpl.java index 35222c20..1b9921f9 100644 --- a/service/src/main/java/com/hzya/frame/mdm/service/impl/MdmServiceImpl.java +++ b/service/src/main/java/com/hzya/frame/mdm/service/impl/MdmServiceImpl.java @@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; +import com.hzya.frame.base.PluginBaseEntity; import com.hzya.frame.mdm.entity.DbFiledsDto; import com.hzya.frame.mdm.entity.MdmDataDto; import com.hzya.frame.mdm.entity.MdmDataFiledDto; @@ -61,6 +62,7 @@ import com.hzya.frame.sysnew.buttonConfig.dao.ISysButtonConfigDao; import com.hzya.frame.sysnew.buttonConfig.entity.SysButtonConfigEntity; import com.hzya.frame.sysnew.menuConfig.dao.ISysMenuConfigDao; import com.hzya.frame.sysnew.menuConfig.entity.SysMenuConfigEntity; +import com.hzya.frame.util.PluginUtils; import com.hzya.frame.uuid.UUIDUtils; import com.hzya.frame.web.entity.BaseResult; import com.hzya.frame.web.entity.JsonResultEntity; @@ -1531,9 +1533,14 @@ public class MdmServiceImpl implements IMdmService { mdmViewVo.setListList(listListVo); List buttonList = new ArrayList<>(); - MdmViewButtonVo mdmViewButtonVo = new MdmViewButtonVo(); + buttonList.add(new MdmViewButtonVo("new","新建")); + buttonList.add(new MdmViewButtonVo("resize","重置")); + buttonList.add(new MdmViewButtonVo("search","查询")); + buttonList.add(new MdmViewButtonVo("edit","修改")); + buttonList.add(new MdmViewButtonVo("dele","删除")); + buttonList.add(new MdmViewButtonVo("view","查看")); + buttonList.add(new MdmViewButtonVo("send","下发")); mdmViewVo.setButtonList(buttonList); - return BaseResult.getSuccessMessageEntity("获取字段成功", mdmViewVo); } @@ -2690,6 +2697,20 @@ public class MdmServiceImpl implements IMdmService { return BaseResult.getFailureMessageEntity("请先传递要删除的数据"); } //TODO 后续完成下发或者删除业务 + //1、根据服务名查询分发数据 + MdmModuleEntity mdmModuleEntity = new MdmModuleEntity(); + mdmModuleEntity.setMdmCode(jsonObject.getInteger("mdmCode")); + mdmModuleEntity.setSts("Y"); + List mdmModuleEntities = mdmModuleDao.queryBase(mdmModuleEntity); + //if() + MdmModuleDistributeEntity mdmModuleDistributeEntity = new MdmModuleDistributeEntity(); + //mdmModuleDistributeEntity + //mdmModuleDistributeDao. + //2、查找插件 + //3、调用插件 + //PluginBaseEntity pluginBaseEntity = PluginUtils.getPluginsById(jsonObjectStr.getString("plug_id")); + //JsonResultEntity s = pluginBaseEntity.executeBusiness(jsonObjectStr); + return BaseResult.getSuccessMessageEntity("处理分发数据成功"); } diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.java b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.java index ef3fc571..d2f73683 100644 --- a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.java +++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.java @@ -6,60 +6,30 @@ import com.hzya.frame.web.entity.BaseEntity; * 集成任务-实例详情(IntegrationTaskLog)实体类 * * @author makejava - * @since 2024-05-15 14:06:41 + * @since 2024-05-06 15:37:55 */ public class IntegrationTaskLogEntity extends BaseEntity { /** 集成任务-实例_id */ private String taskLinvingId; - /** 返回结果 */ - private String result; - /** 原始查询条件 */ - private String queryCondition; - /** 源系统主键 */ - private String rootAppPk; - /** 原系统单据 */ - private String rootAppBill; - /** 最新源系统数据详情 */ - private String rootAppNewData; - /** 最新传输信息 */ - private String newTransmitInfo; - /** 最新推送时间 */ - private Date newPushDate; - /** 是否补推(Y是N不是) */ - private String repairPust; - /** 场景id */ - private String senceId; - /** 最新推送状态 */ - private String newState; - /** 单据业务日期 */ - private String businessDate; - /** 插件id */ - private String pluginId; - /** 处理时间 */ - private Date processingTime; - /** 处理备注 */ - private String processingRemarks; - /** 处理⼈名称 */ - private String processorName; - /** 处理⼈ */ - private String processor; - /** 下游系统单号 */ - private String newSystemNumber; - /** 下游系统主键 */ - private String newSystemPrimary; + /** integration_task_id */ + private String taskId; + /** 任务编码 */ + private String taskCode; + /** 任务名称 */ + private String taskName; + /** 任务状态1、执行中2、执行成功 3、执行失败 4\当前任务已停止*/ + private String taskStatus; + /** 当前任务开始时间 */ + private Date startTime; + /** 结束时间 */ + private Date endTime; + /** 耗时 */ + private String diffTime; + /** 公司id */ + private String companyId; /** 备注 */ private String remark; - /** 扩展1 */ - private String def1; - /** 扩展2 */ - private String def2; - /** 扩展3 */ - private String def3; - /** 扩展4 */ - private String def4; - /** 扩展5 */ - private String def5; public String getTaskLinvingId() { @@ -70,148 +40,68 @@ public class IntegrationTaskLogEntity extends BaseEntity { this.taskLinvingId = taskLinvingId; } - public String getResult() { - return result; + public String getTaskId() { + return taskId; } - public void setResult(String result) { - this.result = result; + public void setTaskId(String taskId) { + this.taskId = taskId; } - public String getQueryCondition() { - return queryCondition; + public String getTaskCode() { + return taskCode; } - public void setQueryCondition(String queryCondition) { - this.queryCondition = queryCondition; + public void setTaskCode(String taskCode) { + this.taskCode = taskCode; } - public String getRootAppPk() { - return rootAppPk; + public String getTaskName() { + return taskName; } - public void setRootAppPk(String rootAppPk) { - this.rootAppPk = rootAppPk; + public void setTaskName(String taskName) { + this.taskName = taskName; } - public String getRootAppBill() { - return rootAppBill; + public String getTaskStatus() { + return taskStatus; } - public void setRootAppBill(String rootAppBill) { - this.rootAppBill = rootAppBill; + public void setTaskStatus(String taskStatus) { + this.taskStatus = taskStatus; } - public String getRootAppNewData() { - return rootAppNewData; + public Date getStartTime() { + return startTime; } - public void setRootAppNewData(String rootAppNewData) { - this.rootAppNewData = rootAppNewData; + public void setStartTime(Date startTime) { + this.startTime = startTime; } - public String getNewTransmitInfo() { - return newTransmitInfo; + public Date getEndTime() { + return endTime; } - public void setNewTransmitInfo(String newTransmitInfo) { - this.newTransmitInfo = newTransmitInfo; + public void setEndTime(Date endTime) { + this.endTime = endTime; } - public Date getNewPushDate() { - return newPushDate; + public String getDiffTime() { + return diffTime; } - public void setNewPushDate(Date newPushDate) { - this.newPushDate = newPushDate; + public void setDiffTime(String diffTime) { + this.diffTime = diffTime; } - public String getRepairPust() { - return repairPust; + public String getCompanyId() { + return companyId; } - public void setRepairPust(String repairPust) { - this.repairPust = repairPust; - } - - public String getSenceId() { - return senceId; - } - - public void setSenceId(String senceId) { - this.senceId = senceId; - } - - public String getNewState() { - return newState; - } - - public void setNewState(String newState) { - this.newState = newState; - } - - public String getBusinessDate() { - return businessDate; - } - - public void setBusinessDate(String businessDate) { - this.businessDate = businessDate; - } - - public String getPluginId() { - return pluginId; - } - - public void setPluginId(String pluginId) { - this.pluginId = pluginId; - } - - public Date getProcessingTime() { - return processingTime; - } - - public void setProcessingTime(Date processingTime) { - this.processingTime = processingTime; - } - - public String getProcessingRemarks() { - return processingRemarks; - } - - public void setProcessingRemarks(String processingRemarks) { - this.processingRemarks = processingRemarks; - } - - public String getProcessorName() { - return processorName; - } - - public void setProcessorName(String processorName) { - this.processorName = processorName; - } - - public String getProcessor() { - return processor; - } - - public void setProcessor(String processor) { - this.processor = processor; - } - - public String getNewSystemNumber() { - return newSystemNumber; - } - - public void setNewSystemNumber(String newSystemNumber) { - this.newSystemNumber = newSystemNumber; - } - - public String getNewSystemPrimary() { - return newSystemPrimary; - } - - public void setNewSystemPrimary(String newSystemPrimary) { - this.newSystemPrimary = newSystemPrimary; + public void setCompanyId(String companyId) { + this.companyId = companyId; } public String getRemark() { @@ -221,46 +111,5 @@ public class IntegrationTaskLogEntity extends BaseEntity { public void setRemark(String remark) { this.remark = remark; } - - public String getDef1() { - return def1; - } - - public void setDef1(String def1) { - this.def1 = def1; - } - - public String getDef2() { - return def2; - } - - public void setDef2(String def2) { - this.def2 = def2; - } - - public String getDef3() { - return def3; - } - - public void setDef3(String def3) { - this.def3 = def3; - } - - public String getDef4() { - return def4; - } - - public void setDef4(String def4) { - this.def4 = def4; - } - - public String getDef5() { - return def5; - } - - public void setDef5(String def5) { - this.def5 = def5; - } - } diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.xml b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.xml index c2f42e0e..a5a9d746 100644 --- a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.xml +++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/entity/IntegrationTaskLogEntity.xml @@ -2,453 +2,327 @@ - + - - - - - - - - - + + + + + + + + + + + - - - - - - - - - - - - - - - - - - + + - + id ,task_linving_id - ,result - ,query_condition - ,root_app_pk - ,root_app_bill - ,root_app_new_data - ,new_transmit_info - ,new_push_date - ,repair_pust - ,create_time + ,task_id + ,task_code + ,task_name + ,remark + ,task_status + ,start_time + ,end_time + ,diff_time + ,sorts ,create_user_id - ,modify_time - ,modify_user_id + ,create_time + ,modify_user_id + ,modify_time ,sts - ,sorts - ,sence_id - ,new_state - ,business_date - ,plugin_id - ,processing_time - ,processing_remarks - ,processor_name - ,processor - ,new_system_number - ,new_system_primary - ,remark - ,def1 - ,def2 - ,def3 - ,def4 - ,def5 + ,org_id + ,company_id + + - select - - from integration_task_living_details + + from integration_task_log - and id = #{id} - and task_linving_id = #{taskLinvingId} - and result = #{result} - and query_condition = #{queryCondition} - and root_app_pk = #{rootAppPk} - and root_app_bill = #{rootAppBill} - and root_app_new_data = #{rootAppNewData} - and new_transmit_info = #{newTransmitInfo} - and new_push_date = #{newPushDate} - and repair_pust = #{repairPust} - and create_time = #{create_time} - and create_user_id = #{create_user_id} - and modify_time = #{modify_time} - and modify_user_id = #{modify_user_id} - and sts = #{sts} - and sorts = #{sorts} - and sence_id = #{senceId} - and new_state = #{newState} - and business_date = #{businessDate} - and plugin_id = #{pluginId} - and processing_time = #{processingTime} - and processing_remarks = #{processingRemarks} - and processor_name = #{processorName} - and processor = #{processor} - and new_system_number = #{newSystemNumber} - and new_system_primary = #{newSystemPrimary} - and remark = #{remark} - and def1 = #{def1} - and def2 = #{def2} - and def3 = #{def3} - and def4 = #{def4} - and def5 = #{def5} + and id = #{id} + and task_linving_id = #{taskLinvingId} + and task_id = #{taskId} + and task_code = #{taskCode} + and task_name = #{taskName} + and remark = #{remark} + and task_status = #{taskStatus} + and start_time = #{startTime} + and end_time = #{endTime} + and diff_time = #{diffTime} + and sorts = #{sorts} + and create_user_id = #{create_user_id} + and create_time = #{create_time} + and modify_user_id = #{modify_user_id} + and modify_time = #{modify_time} + and sts = #{sts} + and org_id = #{org_id} + and company_id = #{companyId} and sts='Y' - order by sorts asc + order by sorts asc order by ${sort} ${order} - + select count(1) from integration_task_log - and id = #{id} - and task_linving_id = #{taskLinvingId} - and result = #{result} - and query_condition = #{queryCondition} - and root_app_pk = #{rootAppPk} - and root_app_bill = #{rootAppBill} - and root_app_new_data = #{rootAppNewData} - and new_transmit_info = #{newTransmitInfo} - and new_push_date = #{newPushDate} - and repair_pust = #{repairPust} - and create_time = #{create_time} - and create_user_id = #{create_user_id} - and modify_time = #{modify_time} - and modify_user_id = #{modify_user_id} - and sts = #{sts} - and sorts = #{sorts} - and sence_id = #{senceId} - and new_state = #{newState} - and business_date = #{businessDate} - and plugin_id = #{pluginId} - and processing_time = #{processingTime} - and processing_remarks = #{processingRemarks} - and processor_name = #{processorName} - and processor = #{processor} - and new_system_number = #{newSystemNumber} - and new_system_primary = #{newSystemPrimary} - and remark = #{remark} - and def1 = #{def1} - and def2 = #{def2} - and def3 = #{def3} - and def4 = #{def4} - and def5 = #{def5} + and id = #{id} + and task_linving_id = #{taskLinvingId} + and task_id = #{taskId} + and task_code = #{taskCode} + and task_name = #{taskName} + and remark = #{remark} + and task_status = #{taskStatus} + and start_time = #{startTime} + and end_time = #{endTime} + and diff_time = #{diffTime} + and sorts = #{sorts} + and create_user_id = #{create_user_id} + and create_time = #{create_time} + and modify_user_id = #{modify_user_id} + and modify_time = #{modify_time} + and sts = #{sts} + and org_id = #{org_id} + and company_id = #{companyId} and sts='Y' - order by sorts asc - order by ${sort} ${order} + order by sorts asc + order by ${sort} ${order} - select - - from integration_task_living_details + + from integration_task_log - and id like concat('%',#{id},'%') - and task_linving_id like concat('%',#{taskLinvingId},'%') - and result like concat('%',#{result},'%') - and query_condition like concat('%',#{queryCondition},'%') - and root_app_pk like concat('%',#{rootAppPk},'%') - and root_app_bill like concat('%',#{rootAppBill},'%') - and root_app_new_data like concat('%',#{rootAppNewData},'%') - and new_transmit_info like concat('%',#{newTransmitInfo},'%') - and new_push_date like concat('%',#{newPushDate},'%') - and repair_pust like concat('%',#{repairPust},'%') - and create_time like concat('%',#{create_time},'%') - and create_user_id like concat('%',#{create_user_id},'%') - and modify_time like concat('%',#{modify_time},'%') - and modify_user_id like concat('%',#{modify_user_id},'%') - and sts like concat('%',#{sts},'%') - and sorts like concat('%',#{sorts},'%') - and sence_id like concat('%',#{senceId},'%') - and new_state like concat('%',#{newState},'%') - and business_date like concat('%',#{businessDate},'%') - and plugin_id like concat('%',#{pluginId},'%') - and processing_time like concat('%',#{processingTime},'%') - and processing_remarks like concat('%',#{processingRemarks},'%') - and processor_name like concat('%',#{processorName},'%') - and processor like concat('%',#{processor},'%') - and new_system_number like concat('%',#{newSystemNumber},'%') - and new_system_primary like concat('%',#{newSystemPrimary},'%') - and remark like concat('%',#{remark},'%') - and def1 like concat('%',#{def1},'%') - and def2 like concat('%',#{def2},'%') - and def3 like concat('%',#{def3},'%') - and def4 like concat('%',#{def4},'%') - and def5 like concat('%',#{def5},'%') + and id like concat('%',#{id},'%') + and task_linving_id like + concat('%',#{taskLinvingId},'%') + + and task_id like concat('%',#{taskId},'%') + and task_code like concat('%',#{taskCode},'%') + and task_name like concat('%',#{taskName},'%') + and remark like concat('%',#{remark},'%') + and task_status like concat('%',#{taskStatus},'%') + and start_time like concat('%',#{startTime},'%') + and end_time like concat('%',#{endTime},'%') + and diff_time like concat('%',#{diffTime},'%') + and sorts like concat('%',#{sorts},'%') + and create_user_id like + concat('%',#{create_user_id},'%') + + and create_time like concat('%',#{create_time},'%') + and modify_user_id like + concat('%',#{modify_user_id},'%') + + and modify_time like concat('%',#{modify_time},'%') + and sts like concat('%',#{sts},'%') + and org_id like concat('%',#{org_id},'%') + and company_id like concat('%',#{companyId},'%') and sts='Y' - order by sorts asc + order by sorts asc order by ${sort} ${order} - select - - from integration_task_living_details + + from integration_task_log - or id = #{id} - or task_linving_id = #{taskLinvingId} - or result = #{result} - or query_condition = #{queryCondition} - or root_app_pk = #{rootAppPk} - or root_app_bill = #{rootAppBill} - or root_app_new_data = #{rootAppNewData} - or new_transmit_info = #{newTransmitInfo} - or new_push_date = #{newPushDate} - or repair_pust = #{repairPust} - or create_time = #{create_time} - or create_user_id = #{create_user_id} - or modify_time = #{modify_time} - or modify_user_id = #{modify_user_id} - or sts = #{sts} - or sorts = #{sorts} - or sence_id = #{senceId} - or new_state = #{newState} - or business_date = #{businessDate} - or plugin_id = #{pluginId} - or processing_time = #{processingTime} - or processing_remarks = #{processingRemarks} - or processor_name = #{processorName} - or processor = #{processor} - or new_system_number = #{newSystemNumber} - or new_system_primary = #{newSystemPrimary} - or remark = #{remark} - or def1 = #{def1} - or def2 = #{def2} - or def3 = #{def3} - or def4 = #{def4} - or def5 = #{def5} + or id = #{id} + or task_linving_id = #{taskLinvingId} + or task_id = #{taskId} + or task_code = #{taskCode} + or task_name = #{taskName} + or remark = #{remark} + or task_status = #{taskStatus} + or start_time = #{startTime} + or end_time = #{endTime} + or diff_time = #{diffTime} + or sorts = #{sorts} + or create_user_id = #{create_user_id} + or create_time = #{create_time} + or modify_user_id = #{modify_user_id} + or modify_time = #{modify_time} + or sts = #{sts} + or org_id = #{org_id} + or company_id = #{companyId} and sts='Y' - order by sorts asc + order by sorts asc order by ${sort} ${order} - - insert into integration_task_living_details( + + insert into integration_task_log( - id , - task_linving_id , - result , - query_condition , - root_app_pk , - root_app_bill , - root_app_new_data , - new_transmit_info , - new_push_date , - repair_pust , - create_time , - create_user_id , - modify_time , - modify_user_id , - sts , - sorts , - sence_id , - new_state , - business_date , - plugin_id , - processing_time , - processing_remarks , - processor_name , - processor , - new_system_number , - new_system_primary , - remark , - def1 , - def2 , - def3 , - def4 , - def5 , - sorts, + id , + task_linving_id , + task_id , + task_code , + task_name , + remark , + task_status , + start_time , + end_time , + diff_time , + sorts , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + org_id , + company_id , sts, )values( - #{id} , - #{taskLinvingId} , - #{result} , - #{queryCondition} , - #{rootAppPk} , - #{rootAppBill} , - #{rootAppNewData} , - #{newTransmitInfo} , - #{newPushDate} , - #{repairPust} , - #{create_time} , - #{create_user_id} , - #{modify_time} , - #{modify_user_id} , - #{sts} , - #{sorts} , - #{senceId} , - #{newState} , - #{businessDate} , - #{pluginId} , - #{processingTime} , - #{processingRemarks} , - #{processorName} , - #{processor} , - #{newSystemNumber} , - #{newSystemPrimary} , - #{remark} , - #{def1} , - #{def2} , - #{def3} , - #{def4} , - #{def5} , - (select (max(IFNULL( a.sorts, 0 )) + 1) as sort from integration_task_living_details a WHERE a.sts = 'Y' ), + #{id} , + #{taskLinvingId} , + #{taskId} , + #{taskCode} , + #{taskName} , + #{remark} , + #{taskStatus} , + #{startTime} , + #{endTime} , + #{diffTime} , + #{sorts} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{org_id} , + #{companyId} , + 'Y', ) - - insert into integration_task_living_details(task_linving_id, result, query_condition, root_app_pk, root_app_bill, root_app_new_data, new_transmit_info, new_push_date, repair_pust, create_time, create_user_id, modify_time, modify_user_id, sts, sence_id, new_state, business_date, plugin_id, processing_time, processing_remarks, processor_name, processor, new_system_number, new_system_primary, remark, def1, def2, def3, def4, def5, sts) + + insert into integration_task_log(task_linving_id, task_id, task_code, task_name, remark, task_status, + start_time, end_time, diff_time, sorts, create_user_id, create_time, modify_user_id, modify_time, sts, org_id, + company_id, sts) values - (#{entity.taskLinvingId},#{entity.result},#{entity.queryCondition},#{entity.rootAppPk},#{entity.rootAppBill},#{entity.rootAppNewData},#{entity.newTransmitInfo},#{entity.newPushDate},#{entity.repairPust},#{entity.create_time},#{entity.create_user_id},#{entity.modify_time},#{entity.modify_user_id},#{entity.sts},#{entity.senceId},#{entity.newState},#{entity.businessDate},#{entity.pluginId},#{entity.processingTime},#{entity.processingRemarks},#{entity.processorName},#{entity.processor},#{entity.newSystemNumber},#{entity.newSystemPrimary},#{entity.remark},#{entity.def1},#{entity.def2},#{entity.def3},#{entity.def4},#{entity.def5}, 'Y') + (#{entity.taskLinvingId},#{entity.taskId},#{entity.taskCode},#{entity.taskName},#{entity.remark},#{entity.taskStatus},#{entity.startTime},#{entity.endTime},#{entity.diffTime},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id},#{entity.companyId}, + 'Y') - - insert into integration_task_living_details(task_linving_id, result, query_condition, root_app_pk, root_app_bill, root_app_new_data, new_transmit_info, new_push_date, repair_pust, create_time, create_user_id, modify_time, modify_user_id, sts, sence_id, new_state, business_date, plugin_id, processing_time, processing_remarks, processor_name, processor, new_system_number, new_system_primary, remark, def1, def2, def3, def4, def5) + + insert into integration_task_log(task_linving_id, task_id, task_code, task_name, remark, task_status, + start_time, end_time, diff_time, sorts, create_user_id, create_time, modify_user_id, modify_time, sts, org_id, + company_id) values - (#{entity.taskLinvingId},#{entity.result},#{entity.queryCondition},#{entity.rootAppPk},#{entity.rootAppBill},#{entity.rootAppNewData},#{entity.newTransmitInfo},#{entity.newPushDate},#{entity.repairPust},#{entity.create_time},#{entity.create_user_id},#{entity.modify_time},#{entity.modify_user_id},#{entity.sts},#{entity.senceId},#{entity.newState},#{entity.businessDate},#{entity.pluginId},#{entity.processingTime},#{entity.processingRemarks},#{entity.processorName},#{entity.processor},#{entity.newSystemNumber},#{entity.newSystemPrimary},#{entity.remark},#{entity.def1},#{entity.def2},#{entity.def3},#{entity.def4},#{entity.def5}) + (#{entity.taskLinvingId},#{entity.taskId},#{entity.taskCode},#{entity.taskName},#{entity.remark},#{entity.taskStatus},#{entity.startTime},#{entity.endTime},#{entity.diffTime},#{entity.sorts},#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.org_id},#{entity.companyId}) on duplicate key update task_linving_id = values(task_linving_id), - result = values(result), - query_condition = values(query_condition), - root_app_pk = values(root_app_pk), - root_app_bill = values(root_app_bill), - root_app_new_data = values(root_app_new_data), - new_transmit_info = values(new_transmit_info), - new_push_date = values(new_push_date), - repair_pust = values(repair_pust), + task_id = values(task_id), + task_code = values(task_code), + task_name = values(task_name), + remark = values(remark), + task_status = values(task_status), + start_time = values(start_time), + end_time = values(end_time), + diff_time = values(diff_time), + sorts = values(sorts), + create_user_id = values(create_user_id), create_time = values(create_time), - create_user_id = values(create_user_id), + modify_user_id = values(modify_user_id), modify_time = values(modify_time), - modify_user_id = values(modify_user_id), sts = values(sts), - sence_id = values(sence_id), - new_state = values(new_state), - business_date = values(business_date), - plugin_id = values(plugin_id), - processing_time = values(processing_time), - processing_remarks = values(processing_remarks), - processor_name = values(processor_name), - processor = values(processor), - new_system_number = values(new_system_number), - new_system_primary = values(new_system_primary), - remark = values(remark), - def1 = values(def1), - def2 = values(def2), - def3 = values(def3), - def4 = values(def4), - def5 = values(def5) + org_id = values(org_id), + company_id = values(company_id) + - -update integration_task_living_details set + + update integration_task_log set - task_linving_id = #{taskLinvingId}, - result = #{result}, - query_condition = #{queryCondition}, - root_app_pk = #{rootAppPk}, - root_app_bill = #{rootAppBill}, - root_app_new_data = #{rootAppNewData}, - new_transmit_info = #{newTransmitInfo}, - new_push_date = #{newPushDate}, - repair_pust = #{repairPust}, - create_time = #{create_time}, - create_user_id = #{create_user_id}, - modify_time = #{modify_time}, - modify_user_id = #{modify_user_id}, - sts = #{sts}, - sence_id = #{senceId}, - new_state = #{newState}, - business_date = #{businessDate}, - plugin_id = #{pluginId}, - processing_time = #{processingTime}, - processing_remarks = #{processingRemarks}, - processor_name = #{processorName}, - processor = #{processor}, - new_system_number = #{newSystemNumber}, - new_system_primary = #{newSystemPrimary}, - remark = #{remark}, - def1 = #{def1}, - def2 = #{def2}, - def3 = #{def3}, - def4 = #{def4}, - def5 = #{def5}, + task_linving_id = #{taskLinvingId}, + task_id = #{taskId}, + task_code = #{taskCode}, + task_name = #{taskName}, + remark = #{remark}, + task_status = #{taskStatus}, + start_time = #{startTime}, + end_time = #{endTime}, + diff_time = #{diffTime}, + sorts = #{sorts}, + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + org_id = #{org_id}, + company_id = #{companyId}, where id = #{id} - -update integration_task_living_details set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + +update integration_task_log set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} where id = #{id} - -update integration_task_living_details set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + update integration_task_log set sts= 'N' ,modify_time = #{modify_time},modify_user_id = + #{modify_user_id} - and id = #{id} - and task_linving_id = #{taskLinvingId} - and result = #{result} - and query_condition = #{queryCondition} - and root_app_pk = #{rootAppPk} - and root_app_bill = #{rootAppBill} - and root_app_new_data = #{rootAppNewData} - and new_transmit_info = #{newTransmitInfo} - and new_push_date = #{newPushDate} - and repair_pust = #{repairPust} - and sts = #{sts} - and sorts = #{sorts} - and sence_id = #{senceId} - and new_state = #{newState} - and business_date = #{businessDate} - and plugin_id = #{pluginId} - and processing_time = #{processingTime} - and processing_remarks = #{processingRemarks} - and processor_name = #{processorName} - and processor = #{processor} - and new_system_number = #{newSystemNumber} - and new_system_primary = #{newSystemPrimary} - and remark = #{remark} - and def1 = #{def1} - and def2 = #{def2} - and def3 = #{def3} - and def4 = #{def4} - and def5 = #{def5} + and id = #{id} + and task_linving_id = #{taskLinvingId} + and task_id = #{taskId} + and task_code = #{taskCode} + and task_name = #{taskName} + and remark = #{remark} + and task_status = #{taskStatus} + and start_time = #{startTime} + and end_time = #{endTime} + and diff_time = #{diffTime} + and sorts = #{sorts} + and sts = #{sts} + and company_id = #{companyId} and sts='Y' - delete from integration_task_living_details where id = #{id} + delete from integration_task_log where id = #{id} diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/IIntegrationTaskLogService.java b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/IIntegrationTaskLogService.java index 67165e65..32bcfd0c 100644 --- a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/IIntegrationTaskLogService.java +++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/IIntegrationTaskLogService.java @@ -1,12 +1,33 @@ package com.hzya.frame.sysnew.integtationTaskLog.service; +import com.alibaba.fastjson.JSONObject; import com.hzya.frame.sysnew.integtationTaskLog.entity.IntegrationTaskLogEntity; import com.hzya.frame.basedao.service.IBaseService; +import com.hzya.frame.web.entity.JsonResultEntity; + /** * 集成任务-实例详情(IntegrationTaskLog)表服务接口 * * @author makejava - * @since 2024-05-15 14:06:43 + * @since 2024-05-06 15:37:55 */ public interface IIntegrationTaskLogService extends IBaseService{ + /** + * @param jsonObject + * @return com.hzya.frame.web.entity.JsonResultEntity + * @Author lvleigang + * @Description 查询任务日志列表分页 + * @Date 11:52 上午 2024/3/27 + **/ + JsonResultEntity queryEntityPage(JSONObject jsonObject); + + + /** + * @param jsonObject + * @return com.hzya.frame.web.entity.JsonResultEntity + * @Author lvleigang + * @Description 获取任务 + * @Date 2:36 下午 2024/3/27 + **/ + JsonResultEntity getEntity(JSONObject jsonObject); } diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/impl/IntegrationTaskLogServiceImpl.java b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/impl/IntegrationTaskLogServiceImpl.java index fe28a014..0cf7b360 100644 --- a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/impl/IntegrationTaskLogServiceImpl.java +++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLog/service/impl/IntegrationTaskLogServiceImpl.java @@ -1,17 +1,24 @@ package com.hzya.frame.sysnew.integtationTaskLog.service.impl; +import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; import com.hzya.frame.sysnew.integtationTaskLog.entity.IntegrationTaskLogEntity; import com.hzya.frame.sysnew.integtationTaskLog.dao.IIntegrationTaskLogDao; import com.hzya.frame.sysnew.integtationTaskLog.service.IIntegrationTaskLogService; -import org.springframework.stereotype.Service; +import com.hzya.frame.web.entity.BaseResult; +import com.hzya.frame.web.entity.JsonResultEntity; +import org.springframework.stereotype.Service; import org.springframework.beans.factory.annotation.Autowired; -import javax.annotation.Resource; import com.hzya.frame.basedao.service.impl.BaseService; + +import java.util.List; + /** * 集成任务-实例详情(IntegrationTaskLog)表服务实现类 * * @author makejava - * @since 2024-05-15 14:06:46 + * @since 2024-05-06 15:37:55 */ @Service(value = "integrationTaskLogService") public class IntegrationTaskLogServiceImpl extends BaseService implements IIntegrationTaskLogService { @@ -23,4 +30,48 @@ public class IntegrationTaskLogServiceImpl extends BaseService list = integrationTaskLogDao.queryByLike(entity); + PageInfo pageInfo = new PageInfo(list); + return BaseResult.getSuccessMessageEntity("查询数据成功", pageInfo); + } + + + /** + * @param jsonObject + * @return com.hzya.frame.web.entity.JsonResultEntity + * @Author lvleigang + * @Description 获取任务日志 + * @Date 2:36 下午 2024/3/27 + **/ + @Override + public JsonResultEntity getEntity(JSONObject jsonObject) { + IntegrationTaskLogEntity entity = getData("jsonStr", jsonObject, IntegrationTaskLogEntity.class); + if (entity == null) { + return BaseResult.getFailureMessageEntity("参数不允许为空"); + } + if (entity.getId() == null || "".equals(entity.getId())) { + return BaseResult.getFailureMessageEntity("系统错误"); + } + entity = integrationTaskLogDao.get(entity.getId()); + if (entity == null) { + return BaseResult.getFailureMessageEntity("获取任务日志失败"); + } + return BaseResult.getSuccessMessageEntity("获取任务日志成功", entity); + } }