From 7e6d74cf910839ef6e376935c952842b2a54152e Mon Sep 17 00:00:00 2001
From: yuqh <123456>
Date: Wed, 15 May 2024 14:19:09 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E7=94=9F=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../IntegrationTaskLivingDetailsEntity.java | 266 ++++++++++
.../IntegrationTaskLivingDetailsEntity.xml | 455 ++++++++++++++++++
.../IIntegrationTaskLivingDetailsService.java | 12 +
...tegrationTaskLivingDetailsServiceImpl.java | 26 +
4 files changed, 759 insertions(+)
create mode 100644 service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.java
create mode 100644 service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.xml
create mode 100644 service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/IIntegrationTaskLivingDetailsService.java
create mode 100644 service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/impl/IntegrationTaskLivingDetailsServiceImpl.java
diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.java b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.java
new file mode 100644
index 00000000..c85adbd5
--- /dev/null
+++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.java
@@ -0,0 +1,266 @@
+package com.hzya.frame.sysnew.integtationTaskLivingDetails.entity;
+
+import java.util.Date;
+import com.hzya.frame.web.entity.BaseEntity;
+/**
+ * 集成任务-实例详情(IntegrationTaskLivingDetails)实体类
+ *
+ * @author makejava
+ * @since 2024-05-15 14:06:41
+ */
+public class IntegrationTaskLivingDetailsEntity 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;
+ /** 备注 */
+ 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() {
+ return taskLinvingId;
+ }
+
+ public void setTaskLinvingId(String taskLinvingId) {
+ this.taskLinvingId = taskLinvingId;
+ }
+
+ public String getResult() {
+ return result;
+ }
+
+ public void setResult(String result) {
+ this.result = result;
+ }
+
+ public String getQueryCondition() {
+ return queryCondition;
+ }
+
+ public void setQueryCondition(String queryCondition) {
+ this.queryCondition = queryCondition;
+ }
+
+ public String getRootAppPk() {
+ return rootAppPk;
+ }
+
+ public void setRootAppPk(String rootAppPk) {
+ this.rootAppPk = rootAppPk;
+ }
+
+ public String getRootAppBill() {
+ return rootAppBill;
+ }
+
+ public void setRootAppBill(String rootAppBill) {
+ this.rootAppBill = rootAppBill;
+ }
+
+ public String getRootAppNewData() {
+ return rootAppNewData;
+ }
+
+ public void setRootAppNewData(String rootAppNewData) {
+ this.rootAppNewData = rootAppNewData;
+ }
+
+ public String getNewTransmitInfo() {
+ return newTransmitInfo;
+ }
+
+ public void setNewTransmitInfo(String newTransmitInfo) {
+ this.newTransmitInfo = newTransmitInfo;
+ }
+
+ public Date getNewPushDate() {
+ return newPushDate;
+ }
+
+ public void setNewPushDate(Date newPushDate) {
+ this.newPushDate = newPushDate;
+ }
+
+ public String getRepairPust() {
+ return repairPust;
+ }
+
+ 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 String getRemark() {
+ return remark;
+ }
+
+ 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/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.xml b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.xml
new file mode 100644
index 00000000..d620468c
--- /dev/null
+++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/entity/IntegrationTaskLivingDetailsEntity.xml
@@ -0,0 +1,455 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ 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
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ insert into integration_task_living_details(
+
+ 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,
+ 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' ),
+ '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)
+ 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')
+
+
+
+
+ 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)
+ 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})
+
+ 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),
+ create_time = values(create_time),
+ create_user_id = values(create_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)
+
+
+update integration_task_living_details 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},
+
+where id = #{id}
+
+
+
+update integration_task_living_details 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}
+
+ 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 sts='Y'
+
+
+
+
+ delete from integration_task_living_details where id = #{id}
+
+
+
+
diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/IIntegrationTaskLivingDetailsService.java b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/IIntegrationTaskLivingDetailsService.java
new file mode 100644
index 00000000..1e3d9edd
--- /dev/null
+++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/IIntegrationTaskLivingDetailsService.java
@@ -0,0 +1,12 @@
+package com.hzya.frame.sysnew.integtationTaskLivingDetails.service;
+
+import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
+import com.hzya.frame.basedao.service.IBaseService;
+/**
+ * 集成任务-实例详情(IntegrationTaskLivingDetails)表服务接口
+ *
+ * @author makejava
+ * @since 2024-05-15 14:06:43
+ */
+public interface IIntegrationTaskLivingDetailsService extends IBaseService{
+}
diff --git a/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/impl/IntegrationTaskLivingDetailsServiceImpl.java b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/impl/IntegrationTaskLivingDetailsServiceImpl.java
new file mode 100644
index 00000000..34b21725
--- /dev/null
+++ b/service/src/main/java/com/hzya/frame/sysnew/integtationTaskLivingDetails/service/impl/IntegrationTaskLivingDetailsServiceImpl.java
@@ -0,0 +1,26 @@
+package com.hzya.frame.sysnew.integtationTaskLivingDetails.service.impl;
+
+import com.hzya.frame.sysnew.integtationTaskLivingDetails.entity.IntegrationTaskLivingDetailsEntity;
+import com.hzya.frame.sysnew.integtationTaskLivingDetails.dao.IIntegrationTaskLivingDetailsDao;
+import com.hzya.frame.sysnew.integtationTaskLivingDetails.service.IIntegrationTaskLivingDetailsService;
+import org.springframework.stereotype.Service;
+import org.springframework.beans.factory.annotation.Autowired;
+import javax.annotation.Resource;
+import com.hzya.frame.basedao.service.impl.BaseService;
+/**
+ * 集成任务-实例详情(IntegrationTaskLivingDetails)表服务实现类
+ *
+ * @author makejava
+ * @since 2024-05-15 14:06:46
+ */
+@Service(value = "integrationTaskLivingDetailsService")
+public class IntegrationTaskLivingDetailsServiceImpl extends BaseService implements IIntegrationTaskLivingDetailsService {
+
+ private IIntegrationTaskLivingDetailsDao integrationTaskLivingDetailsDao;
+
+ @Autowired
+ public void setIntegrationTaskLivingDetailsDao(IIntegrationTaskLivingDetailsDao dao) {
+ this.integrationTaskLivingDetailsDao = dao;
+ this.dao = dao;
+ }
+}