From 28b2160a656fa3ac7bbd55c5b1b4d1d19d12ef62 Mon Sep 17 00:00:00 2001 From: luoluogit <1014532975@qq.com> Date: Tue, 5 Nov 2024 16:18:42 +0800 Subject: [PATCH 01/11] =?UTF-8?q?=E7=9B=AE=E5=BD=95=E5=B1=82=E6=AC=A1?= =?UTF-8?q?=E7=BB=93=E6=9E=84=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sys/shkd-sys-sys/build.gradle | 14 -------------- .../sys => src/main/java}/sys/business/test.java | 2 +- .../main/java}/sys/common/AppflgConstant.java | 2 +- 3 files changed, 2 insertions(+), 16 deletions(-) delete mode 100644 sys/shkd-sys-sys/build.gradle rename sys/{shkd-sys-sys/src/main/java/shkd/sys => src/main/java}/sys/business/test.java (86%) rename sys/{shkd-sys-sys/src/main/java/shkd/sys => src/main/java}/sys/common/AppflgConstant.java (96%) diff --git a/sys/shkd-sys-sys/build.gradle b/sys/shkd-sys-sys/build.gradle deleted file mode 100644 index 8f470ce..0000000 --- a/sys/shkd-sys-sys/build.gradle +++ /dev/null @@ -1,14 +0,0 @@ -/* - * This is a kingdee cosmic template project that is automatically generated by the Kingdee cosmic development assistant plugin. - * If there are any issues during the use process, you can provide feedback to the kingdee developer community website. - * Website: https://developer.kingdee.com/developer?productLineId=29 - * Author: liebin.zheng - * Generate Date: 2024-10-25 13:35:51 - */ - -dependencies { - api project(':shkd-base-common') - api project(':shkd-base-helper') -} - - diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/business/test.java b/sys/src/main/java/sys/business/test.java similarity index 86% rename from sys/shkd-sys-sys/src/main/java/shkd/sys/sys/business/test.java rename to sys/src/main/java/sys/business/test.java index 9290473..5b53bf2 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/business/test.java +++ b/sys/src/main/java/sys/business/test.java @@ -1,4 +1,4 @@ -package shkd.sys.sys.business; +package sys.business; import java.util.ArrayList; import java.util.List; diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/common/AppflgConstant.java b/sys/src/main/java/sys/common/AppflgConstant.java similarity index 96% rename from sys/shkd-sys-sys/src/main/java/shkd/sys/sys/common/AppflgConstant.java rename to sys/src/main/java/sys/common/AppflgConstant.java index 1d45dfa..26390eb 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/common/AppflgConstant.java +++ b/sys/src/main/java/sys/common/AppflgConstant.java @@ -5,7 +5,7 @@ * Author: liebin.zheng * Generate Date: 2024-10-25 13:35:51 */ -package shkd.sys.sys.common; +package sys.common; /** * sys云sys应用-通用常量类
From f620aba27f006b649ded2591954a0dbe44ee9022 Mon Sep 17 00:00:00 2001 From: luoluogit <1014532975@qq.com> Date: Thu, 7 Nov 2024 10:45:01 +0800 Subject: [PATCH 02/11] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E5=88=97=E8=A1=A8?= =?UTF-8?q?=E6=8F=92=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/fi/plugin/APPaymentListPlugin.java | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) create mode 100644 sys/src/main/java/fi/plugin/APPaymentListPlugin.java diff --git a/sys/src/main/java/fi/plugin/APPaymentListPlugin.java b/sys/src/main/java/fi/plugin/APPaymentListPlugin.java new file mode 100644 index 0000000..cb606cf --- /dev/null +++ b/sys/src/main/java/fi/plugin/APPaymentListPlugin.java @@ -0,0 +1,20 @@ +package fi.plugin; + +import kd.bos.form.control.events.BeforeItemClickEvent; +import kd.bos.form.control.events.ItemClickEvent; +import kd.bos.list.plugin.AbstractListPlugin; + +import java.util.EventObject; + +public class APPaymentListPlugin extends AbstractListPlugin { + + @Override + public void beforeItemClick(BeforeItemClickEvent evt) { + super.beforeItemClick(evt); + String itemKey = evt.getItemKey(); + if ("tbldel".equals(itemKey)){ + this.getView().showErrorNotification("测试————无法删除！"); + evt.setCancel(true); + } + } +} From d75a97e0c01e03601568837c18cdb4dbaffab98c Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Thu, 7 Nov 2024 11:42:48 +0800 Subject: [PATCH 03/11] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/resources/.gitkeep | 0 .../main/java/shkd/sys/sys/business/.gitkeep | 0 .../shkd/sys}/sys/common/AppflgConstant.java | 6 +++--- .../main/java/shkd/sys/sys/mservice/.gitkeep | 0 .../sys/plugin/api/PayBillApiSavePlugin.java | 18 ++++++++++++++++++ .../java/shkd/sys/sys/plugin/form/.gitkeep | 0 .../java/shkd/sys/sys/plugin/operate/.gitkeep | 0 .../java/shkd/sys/sys/plugin/other/.gitkeep | 0 .../java/shkd/sys/sys/plugin/report/.gitkeep | 0 .../java/shkd/sys/sys/plugin/workflow/.gitkeep | 0 .../src/main/java/shkd/sys/sys/webapi/.gitkeep | 0 11 files changed, 21 insertions(+), 3 deletions(-) create mode 100644 sys/shkd-sys-sys/src/main/java/resources/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/business/.gitkeep rename sys/{src/main/java => shkd-sys-sys/src/main/java/shkd/sys}/sys/common/AppflgConstant.java (87%) create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operate/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/other/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/workflow/.gitkeep create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/webapi/.gitkeep diff --git a/sys/shkd-sys-sys/src/main/java/resources/.gitkeep b/sys/shkd-sys-sys/src/main/java/resources/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/business/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/business/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/src/main/java/sys/common/AppflgConstant.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/common/AppflgConstant.java similarity index 87% rename from sys/src/main/java/sys/common/AppflgConstant.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/common/AppflgConstant.java index 26390eb..c5ef03a 100644 --- a/sys/src/main/java/sys/common/AppflgConstant.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/common/AppflgConstant.java @@ -3,9 +3,9 @@ * If there are any issues during the use process, you can provide feedback to the kingdee developer community website. * Website: https://developer.kingdee.com/developer?productLineId=29 * Author: liebin.zheng - * Generate Date: 2024-10-25 13:35:51 + * Generate Date: 2024-10-25 14:27:06 */ -package sys.common; +package shkd.shkd1.sys.sys.common; /** * sys云sys应用-通用常量类
@@ -13,7 +13,7 @@ package sys.common; * 标识或缓存的常量，需以"KEY_"、"FID_"、"ENTRY_"或"SUBENTRY_"作为变量的前缀。
* * @author shkd - * @date 2024-10-25 13:35:51 + * @date 2024-10-25 14:27:06 */ public class AppflgConstant { diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/mservice/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java new file mode 100644 index 0000000..91b0082 --- /dev/null +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -0,0 +1,18 @@ +package shkd.sys.sys.plugin.api; + +import kd.bos.openapi.api.plugin.ApiSavePlugin; + +import java.util.List; +import java.util.Map; + +/** + * @Description + * @Author Tao + * @Date 2024/11/7 + */ +public class PayBillApiSavePlugin implements ApiSavePlugin { + @Override + public List> preHandleRequestData(List> reqData) { + return reqData; + } +} diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/form/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operate/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operate/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/other/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/other/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/report/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/workflow/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/workflow/.gitkeep new file mode 100644 index 0000000..e69de29 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/webapi/.gitkeep b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/webapi/.gitkeep new file mode 100644 index 0000000..e69de29 From ee49f80e14720229f331aa6bcc5282492fefa2e9 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Thu, 7 Nov 2024 11:45:01 +0800 Subject: [PATCH 04/11] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java | 1 + sys/shkd-sys-sys/src/main/resources/.gitkeep | 0 2 files changed, 1 insertion(+) create mode 100644 sys/shkd-sys-sys/src/main/resources/.gitkeep diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java index 91b0082..06b5ba2 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -13,6 +13,7 @@ import java.util.Map; public class PayBillApiSavePlugin implements ApiSavePlugin { @Override public List> preHandleRequestData(List> reqData) { + return reqData; } } diff --git a/sys/shkd-sys-sys/src/main/resources/.gitkeep b/sys/shkd-sys-sys/src/main/resources/.gitkeep new file mode 100644 index 0000000..e69de29 From f463dfc5d8dcd92d90da9388f88f1f002e59a4b3 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Thu, 7 Nov 2024 11:47:18 +0800 Subject: [PATCH 05/11] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java | 1 - 1 file changed, 1 deletion(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java index 06b5ba2..91b0082 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -13,7 +13,6 @@ import java.util.Map; public class PayBillApiSavePlugin implements ApiSavePlugin { @Override public List> preHandleRequestData(List> reqData) { - return reqData; } } From 23613791a2f6a6b784d8b7b6ae8d667dd6747375 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Thu, 7 Nov 2024 14:04:14 +0800 Subject: [PATCH 06/11] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java | 1 + 1 file changed, 1 insertion(+) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java index 91b0082..06b5ba2 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -13,6 +13,7 @@ import java.util.Map; public class PayBillApiSavePlugin implements ApiSavePlugin { @Override public List> preHandleRequestData(List> reqData) { + return reqData; } } From 3d638bb5183fc68baa2de26558df3d956c9e2692 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Fri, 8 Nov 2024 09:06:02 +0800 Subject: [PATCH 07/11] =?UTF-8?q?=E9=A1=B9=E7=9B=AE=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java | 1 - 1 file changed, 1 deletion(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java index 06b5ba2..91b0082 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -13,7 +13,6 @@ import java.util.Map; public class PayBillApiSavePlugin implements ApiSavePlugin { @Override public List> preHandleRequestData(List> reqData) { - return reqData; } } From f9ce076e999a1b7c09f3c015970524f6d1c75d83 Mon Sep 17 00:00:00 2001 From: fang <123456> Date: Fri, 8 Nov 2024 10:07:39 +0800 Subject: [PATCH 08/11] =?UTF-8?q?=E5=BE=85=E5=8A=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cosmic/debug/tools/CosmicLauncher.class | Bin 0 -> 11032 bytes .../shkd/cosmic/debug/DebugApplication.class | Bin 0 -> 1025 bytes .../sys/shkd/sys/sys/business/test.class | Bin 0 -> 399 bytes .../shkd/sys/sys/common/AppflgConstant.class | Bin 0 -> 388 bytes .../ct/backlogTack/ToDoResendTack.java | 243 ++++++++++++++++++ .../ct/constant/ToDoCenterConstant.java | 16 ++ .../ct/handler/CreateToDoHandler.java | 59 +++++ .../ct/handler/DealToDoHandler.java | 58 +++++ .../ct/handler/deleteToDoHandler.java | 57 ++++ .../midservice/ct/model/BacklogMessage.java | 176 +++++++++++++ .../servicehandler/BacklogServiceHandle.java | 112 ++++++++ .../sse/midservice/ct/utils/GetUrlUtils.java | 52 ++++ .../midservice/ct/utils/RequestClient.java | 130 ++++++++++ 13 files changed, 903 insertions(+) create mode 100644 out/production/shkd-cosmic-debug/kd/cosmic/debug/tools/CosmicLauncher.class create mode 100644 out/production/shkd-cosmic-debug/shkd/cosmic/debug/DebugApplication.class create mode 100644 out/production/sys/shkd/sys/sys/business/test.class create mode 100644 out/production/sys/shkd/sys/sys/common/AppflgConstant.class create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/backlogTack/ToDoResendTack.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java create mode 100644 shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java diff --git a/out/production/shkd-cosmic-debug/kd/cosmic/debug/tools/CosmicLauncher.class b/out/production/shkd-cosmic-debug/kd/cosmic/debug/tools/CosmicLauncher.class new file mode 100644 index 0000000000000000000000000000000000000000..d90851686a91e6981e83edd1b04634654b551348 GIT binary patch literal 11032 zcmbVR34B!5)jwx4$-GQnAbAiV0fZ_d4rB%plmuKt2olI<5|*Vv)^1k5|GD?gn;}VmpTDx)?cIC!?cRCf z^#>j#qE((UKi$PE%jpb0Lz-1SUhO9@uQd2f>Ccj8jlm7lH_DE+(ya5NIosfK3_e$e z=Na5&@Op!r4c=gIi@_TWKHuO?2Dci#+2Ab(x5>tKIo)A!r%bvGzCikJgL@3_mEl%t zwn?*HnhT}bVen4rcNu(<^cNfaX6bhue2Mg7Y5IH|k-lFVTbcoB2BjI2ChF%sJnZKf z$E8UaoHRIP@QA@_A7>1D%HXWQIfF-K`(A^dk$#`S`whO-;L8kti@|U8^V|6C248OQ zI}CoO!S6Eo-LiIt!B-mm9zS2jR~!6ZgWqTH`whOv;A;)O&fx0}zQN!d4Zg|X4;Xy2 z!M7NEtHB=>Vs7*C?S2{(sox>}hYbF(!5=aBqXyq;@W%}PxGXms{0W0UDH{8fpFhn9 z{CpRG#?J@&vj*R7@aGKvypO-&r?>DSgYPl;UW4xwChj-*u)$*nA2E2`$6xf*mHdD- zM}7PyKV8jV_VI&$eu$6x_$vl~Rfbvzg|f-`%vKtz~ytcV|~i zcW-M;&+Zd|%-PVgv1w~tuU_p{pm%pQ^=@J^ab|N%vtDB|+B%z?+IF{g0ZA+w3CA`i zGue)C97xQJodw>3=-}3LjEQ$L`6J0pJR0drrn6XRWh&PTYQyYY#%_=F*y+(|#MTEl zM$;MWEL#^%M6>5Gl`J`Z8B+oB1(BNy+p)4k!o7*?z{p#9>ke!CCyi0Zp5R04*7|_cN7_YAuuu%IU>ZoIZW>ap)PyL^^i5HN{jj z)iI#(MDfwT!A_;^NH}ZvGu3wI64_|n-WJV7A(o~@BAE?mqp%33Sw)BnXCQ@XK&F*p zr}F+b{(sMPMBxoV+3esRW#a9m(oV5I$@m4Xa9pGnu`~G^novAMSRfqlATkl!Av`QIuq?9urxRbJft_7ibk|4Y|LoOQ>HMLU={jm z;BAeE2koNGCX8JBm^wRi$&|M3hy_~IVyOcpEzh>-;1DDxEetf4g#Uz08?}eSL0VKt&@7qHW2+JTo(5`SFGE7#3lO0LXw=Qv{=BU&Ky{hfC;( zN3|yrK9gy{L2}db+mP$)OXi`L!Qzz3RpsrVE1evTD%#wo=44!%6U-x)Ob+K#D%c|E zfPH88fh6B8NLD>iqJw{T2O$tH8Gq>?oG(I!f9kBmC3ZSoCqnnThTQ2 z_owYlX04BZj7$&ly5_wpDM_y)l}_$KK+|UID)W+hJ%8f&pd;(6R=FpRfmCs|FPXTL1Y#q{wmD&1IvpkPv96 zvr${veG&x0Qm&%L?qd-f_`Z(J5axdsk*(hqqVoQ zd-tZ^-mcwUo!z}S($LU=PnDb7FFbL1dBX|_25F}!6^p`JO9zl&0K7_Pi6DU6!R-DN zmdZ4>CeIaC4$(oiBqfna->1icL~%;b$+&#DKcb?1Jv_YLq#x4bCjEjQH0ihWJCpuE zFPi)&dKD%RLOGI+M(Tx|dWV0Lo);j~3L;&(V$BLs2Ucq)$$QQ6hUF%GOW}2onDi38 zY|<5-rlml8zr|c zsQoyc8Hojv?U4xzli-A`Kg~U>3{ueiwm=U=lC}3`b&dsU%vH1w<|Dd~e`oUV`2`3? z%tVV7tTiIqh6*bom{T~5YIi6O+4iU~tc71UX*r70Ev-LJj~3FtUa2WwDcV^OK~oo8 zOWi4|W0KzYswA(4&r~;QO_>5b8ww$qu*&(4d1N*w)6Jk6E;f7OdJn=iQX#6JaBMIc z%peh>LV;XRGH6n3)i@3}jYR~Aqsv$>Z1Nw(!DdYkT#}w)pyJkNr^9`H(QJG~!qtng zUP&CVw^Av_q<4(5yvP>IMx9ON&{bX+)kyArxM$Q4hX;nk!F_R3$g#0FOFVVY6k z%1wSI|6QW$Y<*hWPI|v$^Q{6DQ{^EWg^i?cBRB+1h!e3{iwU+l18By ziSoOLP$ZbVNMhgX{DR5H=~0tDCwagM>6{#dbeyaUS5#C?NXBqjwd|yPVfS&Q+BRX*0Qyaf$#`CG&8JnN<1|J{#F&9`gbx5jeJnq>#*JvgvRt zv>qcda<4>bx$*3p1aYlY?ZxaUEkUIyWSx=+my8NjYlWFlUD-Pa5O?rAFd3w*PeDAG zT9ix=hQcX{E0A$Kj<~EIXU+&|W}KAek7hcO+4T_lFw@*(!8H$s(>*qlNFrjdJspoI zm2!RPu~WDZB9<{NE8eYvuANMxd!sO<42|Jh0v9;pGNu+m@$`bGoqf~tN7|B7UgAk% z@hvQ7A|99fWH4`b^fz?((og)8PnQq%;ysN+DMn?(gr(rSPJX$;gAsoMM{Yu%gULZoBSv zLv}i-CO8SuiG9hv!+EucW*ps@VckxQ!j0^GxVA$}c=UqSs|(C+ME+LTyfNrQ)Tmhm z-%kB67Vb}@i~%1_u^6qOGw3e7R{N=rK0^nQK0k|@hi=CF?xOjPm?IkDTOEDAX#IN3 zzfd$^PUTX)Dj2BmRgV&1^(fF)j~X5QslbJ60NO8Nb{UmmMAQ&CLL4YLOrAjX$@d(l zlE6{&?l?lFR@oT&0{2tN7#UVM#$)6^Ock=#42)6bJqq*#Xip*^+H=SY*2-x$Rnb`# zqII;2&ZRYU9v#J3QzN4<(U&n3LLPJoxfX1^7h zD4M0QIur^0A|?c4xy@+W_!dABA-xi?rdiX+s48GpTbAl)STj{$W6e_iY-^6{Yppuf z&$Z^EAE){E(MbVo!5A$JSZ^AmlU?zi0+HTJC!w_#6(kKIkI|_C2z_zD>m8%h0$K%2 z^5@3sbU6YIh(g9_DZZPx)0qKl*%;Latl$`h0@m{C1)m(F75TwR8Kj=6-goC1tqPRz z7_B}4ReBZv)q?HJ0Fa#}qcwpNLEIqvEg{iwn&zQxgIwF8+YXvTowSg;XbD|F%c&bW z?uGQW(gxZ_n`t{GX$NI#CtXSx(L3p4x`QsEk5eDaJ_1wjhwg1UMnm)@?ZH(mK|iAr z`Xx^MmiE$%IQ25UrO0MpaWr%cG?bC&-}HSSbn=zFj$m`5Gon%+r^bR&`jvVwhXUVG z1gz9GKwL+0Ogy0#J4?{}mM$Bowc96xcsHbOZEzBb`DwQ6s|8db$N#ytRnHEiT7f z=n2K~F`Pp9XrymoKv1NphUuH=S#GXqh4%9t+Kqs99%!nXDB6!gaCa6VGF(IkeOn=7 zxg(0nkui5T&Jn+zThU55ey+g5MEELO=s|NmxzaQ6vB% zeHSCq?P~fSMkR0x!fsDUf)3swCQGqpDk**$EI(MpZm|@9;INAa3kTY{jud@?rSS5N z1^H=*c^Ha(qzIVLCEQ2PxWIno0P6=Zk$QE&I$ubecbk^WripTS95g;b6|k2oScxPA z?M&4!_-Y3{fYFZ;h&@UgFtRG(!UKkbaj!$Z6|h?80-Lq@08-T!$GCL7(wsa6Ku;HO zV!5a+`l*WaBJR`3a~$U4@zKxVu4sMq>~Y}I3nh91YgocdkV8a~UAIl8kspHFXNpi4 zYvkvS5b=8CKx=kbst8!^bH}M;3P*Vs<-&7C04rQxDiAq!*1`kIWb!(vBJX*S_nRVU z#pM0kArCKBlc9A@1?@#Z`{RFs_8SKpUdbG2yBv$D30N06%m%FPc@x>z&ipFa{yWXY z(^bJ@YFyT9==X|sq8fTZSq#fdoP+3cN2==rC=veOqQ>fxG&@ec5?8FPm{gpghFOTs zM8}b2h!){?w}L&imP?A*Ugy%a4&t~URIoh0In=})wrc~{HivB_o9(xeKVWqtzNpZs ztycvSt{^{~RLzw%ho={@U+bc&rN21r*V11hXV+oo04E*`9n8lNQN%?@1J;H4%FfLo zI}p%NrWn@Fd}IUnyWZHgi{8k#LU_?^&8E|M4s~!X<+!ehtx=b)Q76TKVkJjOs(AHu zxVhQkrZZq&{6_ExtT(@rZ3Qxw;ql2J^AwP|sEEW)m&8t>vQztO7>i6Qi=9uXs& zkoP&D0P12mpZ6IyK83UGp2FF91^IZTf}v}NV%N<(8y`mutsW8Tc=NulDgyYW(0sOpuLTP+)i7# zgWk-Y6y+|(L${{R2>9yGCGctI3%9^Fp|n+4+6?T1ej8?5mpW&15cxi zxP-lktSnFV4*yT#oP?o9Zb#}Xw=(SqsLaZ?<1UaJqfs!r*P1y_`#J*Fe((v6Txwm0 z{s8$Ky~65S?*XLgC{I?R!q(9yh@?z>A)c&uP#NzclXuf}?x%%303R5n5bvRtJVdKF zN)0@$_*?}l7Q$A_6epOmj}661qsx0Em#gUH!Rz03U|l|cqB-e^G77`pOEY;toy7XupewEgE-4ETL?uN6G*44` zLPpauLUkd(k~jn$0eT@|R{$aL9cKsTqdg~Jy%QwpwD7KcD0w%cC5+5x<>RNii9z01 zOt}Mq485ZeXH@0QS3u@hLgw$GS$q|(;j3vUzgNjvGqKBMVwW3pb~!NzgtCQ1BTV2) zS2F<(Y9EOlr7L&LJwoqk=Z?8&dQscXM{QdJ8@cKLS&gOjV(afcpo-h8YP@%gfppY* zA8IU{xYbuL-jLr~TlP?UV6OKP$mVXC=PbNN%%`hiMAKkax<3mtY{CV66XqdYxn)kY z3>U)pVZKxK+W53nT|*UoEu88)T82Kv*U(uQ@8auSL6p-4T*DHSc98*No2>#*#1&4& z$+*XWXD5{(2T7$;(D`_dk82T*(fUh{GKJ*g)EZ#Cs@81GRwprI6f-7EkNPQ{8Q^++?hFqYvvOfhUgTwMcD(AZZ>oZiz zpH(~xXMQRHj(O^A70>6BaPAoXS4n|dF7zyrW?>0V12 z&BZ-?0YBgp4uE_zJX~(Ub$kj&tOzeB&ucUjzU~LFcxKlWBm0*iz!7yht^$eqtPkq) zqx~q|hM0bP$5Fat$Fd{zAsx0pd>bt|N*~!#>pemrbxik8vEPr?!wWxthz~V-`4D)U zhr4_mtZXxFQGIcUdl1AwMDzG7w3xq&@clJ}v#-;+{4j0cM`$xYMs55AQvQ>Qu}xs6 z0p-_XJ`KTcG0rUE(-9pyphK}gi4$E8+ZZ|b_L;N}8D4_jJOs?8ybQb^!_GzId7U;x z6h5x^aZv6TFvMq_e_St$t%GHU+((T@g@Negd_egG9ucfhTAv!DPm90~Xo1~Fw@OGU P(m5?fI9QG~53l$?WYR=n literal 0 HcmV?d00001 diff --git a/out/production/shkd-cosmic-debug/shkd/cosmic/debug/DebugApplication.class b/out/production/shkd-cosmic-debug/shkd/cosmic/debug/DebugApplication.class new file mode 100644 index 0000000000000000000000000000000000000000..7659d9a8ce1f8ee60763d8841c95b2693cafcc98 GIT binary patch literal 1025 zcma)5?M@Rx6g|@dEoGrlzExBZp|G^umd}>`mfsa?55I zOMWb!@^fx9xLq^K(zEQ^W}wZz8nF%Eu}nTY>O1$e$vWE$8w% z4F$DxYQJEZ(kLF4Uw+!#KhCCT=eh8V3sK>&t6@`_+QPPm9rbB5|DFuP;LSMRR8EB{ zX;#S(Y9xccki|yJm%{6u2Ktl9yQdeY)+1qaTmI?nqe?k&ci=J%5PD^H@H?-;peb(0 z{%q9(*iZ08RNe~zkjwhDbTHEs;T}3(VCq1b>h>k~B&IP$_dq=%(5b-)#Zf{AWk$Js z@e1rRSRSL;6BOeZr+2N>fC)?z>cu_Wr;6JA6=9+S^4}49AHG7kq$j%C=ni6!o`|#& z)f2sK#Pmd88=9WzZ(~3onz?KvuD3CGBe;kd5sef5B;q77iU%Y!MZOFoZ&kruyj8pio`N1Ky?ENBOS&~pAiEX%vpfkN`~m(b zads6H)P?zaGw;pp+xyEafOG66=wLU(Fv5rsUZ`4`OG0OSJR|s5&0G@tnX2W@dX>xe zPUICM!>lPpH509}^%v-yh0=t>OfMehsorR3`C2nu>(oeXCak#u zGM$=M)#b$P6m7{Wqd(e&WZJCTLS8F-L~Iq$tVj<&0>Z)niwT48ZMXSS76wP~`0w_4 z;JXm854lP?635`=8T91Z5&O`AA+|X0eGVW-!c~l}LoE4}&60l+yFZA8ZS1(gK6?*? E4=?mj+yDRo literal 0 HcmV?d00001 diff --git a/out/production/sys/shkd/sys/sys/common/AppflgConstant.class b/out/production/sys/shkd/sys/sys/common/AppflgConstant.class new file mode 100644 index 0000000000000000000000000000000000000000..72b133c08c01042d192513828584c31487fcab4a GIT binary patch literal 388 zcmah_O-sW-5Pj1oO^vD6R1Y2%4=QLb-V`B}dNI~QCE%%S(wJ^dHYFc|Kg*Ng!5`p{ z5+^|sPafv&ytl)=nfds9dk1ia9TRPA8L$lu2-fxJe&$Xlv$1(O^=nXSfltPuhNUErdZ9?ZlDp_6<+J{FzK^tcCh_LBN6^*Mji1IrTB&^t87K+3d zxvcrOsFe#@5DvUz@i=#i=c0))OVdm_?rQar#6OPgZcei*52Gtt_Z$5EKCP#<(8U^I z|Nm};{_lFX!7>U map) throws KDException { + logger.info("待办重发开始"); + String startTime = (String) map.get("starttime"); + String endTime = (String) map.get("endtime"); + Date startTimeDate = null; + Date endTimeDate = null; + if (StringUtils.isEmpty(startTime) || startTime.length() != 19) { + Date date = new Date(); + logger.error("调度作业参数提供的开始时间格式不对或者未传入开始时间，自动转成：" + date); + //获得前三天对应的时间 + endTimeDate = date; + long time = endTimeDate.getTime() - 86400000 * 3; + startTimeDate = new Date(time); + } else { + startTimeDate = DateUtils.parseDateTime(startTime, "yyyy-MM-dd HH:mm:ss"); + endTimeDate = DateUtils.parseDateTime(endTime, "yyyy-MM-dd HH:mm:ss"); + logger.info("待办重发-starttime:" + startTimeDate); + logger.info("待办重发-endtime:" + endTimeDate); + } + logger.info("组装待办、已办重发的数据"); + Date beginTimeDate = startTimeDate; + // 待办 + boolean hasNext = true; + logger.info("开始抽取待办,参数 beginTimeDate：" + beginTimeDate + "endTimeDate:" + endTimeDate); + extractToDoList(beginTimeDate, endTimeDate, "1"); + extractToDoList(beginTimeDate, endTimeDate, "2"); + extractToDoList(beginTimeDate, endTimeDate, "5"); + } + + /*** + * 抽取待办 + * @param startTime 开始时间 + * @param endTime 结束时间 + * @param t_status 待办状态 + * @return + */ + private void extractToDoList(Date startTime, Date endTime, String t_status) { + String accountId = System.getProperty("efms.midservice.accountid"); + logger.info("拼接sql,此次拼接的待办类型为:" + t_status + "(1:待办、2已办、5撤销),使用参数startTime：" + startTime + "endTime:" + + endTime); + StringBuffer cwbSql1 = new StringBuffer(); + cwbSql1.append("SELECT "); + cwbSql1.append("b.FID,"); + cwbSql1.append("b.FPROCDEFID,"); + cwbSql1.append("b.FTASKDEFKEY,"); + cwbSql1.append("b.FPROCINSTID,"); + cwbSql1.append("b.FEXECUTIONID,"); + cwbSql1.append("b.FPARENTTASKID,"); + cwbSql1.append("b.FOWNER,"); + cwbSql1.append("b.FASSIGNEE,"); + cwbSql1.append("b.FCLAIMTIME,"); + cwbSql1.append("b.FENDTIME,"); + cwbSql1.append("b.FDURATION,"); + cwbSql1.append("b.FPRIORITY,"); + cwbSql1.append("b.FDUEDATE,"); + cwbSql1.append("b.FFORMKEY,"); + cwbSql1.append("b.FCATEGORY,"); + cwbSql1.append("b.FISDISPLAY,"); + cwbSql1.append("b.FSTARTERID,"); + cwbSql1.append("b.FENTITYNUMBER,"); + cwbSql1.append("b.FCREATEDATE,"); + cwbSql1.append("b.FMODIFYDATE,"); + cwbSql1.append("b.FASSIGNEEID,"); + cwbSql1.append("b.FOWNERID,"); + cwbSql1.append("b.FEXECUTIONTYPE,"); + cwbSql1.append("b.FBUSINESSKEY,"); + cwbSql1.append("b.FYZJGROUPID,"); + cwbSql1.append("b.FPROCESSINGPAGE,"); + cwbSql1.append("b.FHANDLESTATE,"); + cwbSql1.append("b.FMOBILEFORMKEY,"); + cwbSql1.append("b.FDELEGATION,"); + cwbSql1.append("b.FBILLNO,"); + cwbSql1.append("b.FPROCESSINGMOBILEPAGE,"); + cwbSql1.append("b.FENDTYPE,"); + cwbSql1.append("b.FSOURCE,"); + cwbSql1.append("b.FVALIDATEOPERATION,"); + cwbSql1.append("b.FNAME,"); + cwbSql1.append("b.FSUBACTIVITYNAME,"); + cwbSql1.append("b.FDESCRIPTION,"); + cwbSql1.append("b.FSUBJECT,"); + cwbSql1.append("b.FENTITYNAME,"); + cwbSql1.append("b.FSENDERNAME,"); + cwbSql1.append("b.FSTARTNAME,"); + cwbSql1.append("b.FPARTICIPANTNAME,"); + cwbSql1.append("b.FGROUPNUMBER,"); + cwbSql1.append("b.FREALDURATION,"); + cwbSql1.append("b.FBATCHOP,"); + cwbSql1.append("b.FBILLTYPE,"); + cwbSql1.append("b.FBIZTRACENO,"); + cwbSql1.append("b.FSENDERNAMEFORMAT,"); + cwbSql1.append("b.FSTARTNAMEFORMAT,"); + cwbSql1.append("b.FPRESENTASSIGNEE,"); + cwbSql1.append("b.FORGUNITID,"); + cwbSql1.append("b.FORGVIEWID,"); + cwbSql1.append("b.FPROCESSTYPE,"); + cwbSql1.append("b.FSENDERID,"); + cwbSql1.append("b.FCONTROL,"); + cwbSql1.append("b.FEXTENDDATE,"); + cwbSql1.append("b.FEXTENDNUMBER,"); + cwbSql1.append("b.FEXTENDSTR1,"); + cwbSql1.append("b.FEXTENDSTR2,"); + cwbSql1.append("b.FDELETEREASON,"); + cwbSql1.append("b.FEXTENDFORMAT,"); + cwbSql1.append("b.FEXTENDMULSTR1,"); + cwbSql1.append("b.FEXTENDMULSTR2,"); + cwbSql1.append("a.FCREATEDATE fstarttime,"); + cwbSql1.append("c.FID as factivityId,"); + cwbSql1.append("d.FUSERID freceiveuserid,"); + cwbSql1.append("d.FUSERNAME freceiveusername,"); + cwbSql1.append("d.FCREATEDATE freceivetime,"); + cwbSql1.append("d.FENDTIME fcompletetime,"); + cwbSql1.append("d.FMODIFYDATE flastmodifytime "); + cwbSql1.append("from t_wf_hitaskinst b "); + cwbSql1.append("INNER JOIN t_wf_hiparticipant d on d.FTASKID=b.FID "); + cwbSql1.append("INNER JOIN t_wf_hiactinst c on c.FTASKID=b.FID "); + cwbSql1.append("INNER JOIN t_wf_hiprocinst a on a.FID=b.FPROCINSTID "); + cwbSql1.append("where b.FMODIFYDATE >= ? and b.FMODIFYDATE <=?"); + if (Objects.equal("1", t_status)) { + cwbSql1.append("and (b.FDELETEREASON is null or b.FDELETEREASON =' ' or b.fdeletereason='') "); + cwbSql1.append(" and b.FENDTIME is null and d.FENDTIME is null "); + } else if (Objects.equal("2", t_status)) { + // cwbSql1.append(" and (b.FDELETEREASON ='task complete' ) "); + cwbSql1.append(" and (b.FDELETEREASON ='task complete' or b.FDELETEREASON ='first_usertask_skip') "); + cwbSql1.append(" and b.FENDTIME is not null and d.FENDTIME is not null "); + } else if (Objects.equal("5", t_status)) { + cwbSql1.append(" and not ((b.FDELETEREASON is null or b.FDELETEREASON =' ' or b.fdeletereason='') "); + cwbSql1.append(" and b.FENDTIME is null and d.FENDTIME is null) "); + cwbSql1.append(" and not ((b.FDELETEREASON ='task complete' or b.FDELETEREASON ='first_usertask_skip') and b.FENDTIME is not null and d.FENDTIME is not null)"); + } + cwbSql1.append(" ORDER BY b.FMODIFYDATE,b.FID"); + DataSet cwbAmount1 = DB.queryDataSet(this.getClass().getName(), DBRoute.of("sys"), cwbSql1.toString(), new Object[]{startTime, endTime}); + Iterator iterator = cwbAmount1.iterator(); + logger.info("开始拼接待办数据"); + try { + while (iterator.hasNext()) { + Row next = iterator.next(); + //接收人手机号 + DynamicObject dynamicObject = QueryServiceHelper.queryOne("bos_user", "name,shkd_pid," + + "phone", new QFilter[]{new QFilter("id", "=", next.getString("freceiveuserid"))}); + String phone = dynamicObject.getString("phone"); + switch (t_status) { + case "1": + BacklogMessage backlogMessage = new BacklogMessage(); + //业务类型名称 + backlogMessage.setbName("业务类型名称"); + // 紧急程度 + backlogMessage.setUrGency("0"); + //当前节点名称 + backlogMessage.setCurrentStepName(next.getString("FNAME")); + //上步骤名称 + backlogMessage.setPreStepName(""); + // startname发起人名称 + backlogMessage.setSendUserName(dynamicObject.getString("startname")); + //接收人手机号 + backlogMessage.setReceiveUserId(phone); + //标题 + String title = "请处理" + next.getString("fstartname") + "提交的" + next.getString("fentityname"); + backlogMessage.setTitle(title); + //PC地址 + String pcUrl = GetUrlUtils.getInstance().getPcUrl(next.getString("fprocessingpage"), + next.getString("fprocessingmobilepage"), + next.getString("fsource"), + accountId, + next.getString("factivityId"), + next.getString("fbusinesskey"), + next.getString("fid")); + backlogMessage.setHandleUrl(pcUrl); + //PC地址查看 + backlogMessage.setViewUrl(pcUrl + "&ado=view"); + //app地址 + backlogMessage.setAppHandleUrl(pcUrl); + //App应用名称 + backlogMessage.setAppName(""); + //app地址查看 + backlogMessage.setAppViewUrl(pcUrl + "&ado=view"); + //业务id + backlogMessage.setPendingId(String.valueOf(next.getLong("fid"))); + // 业务编码 + backlogMessage.setBussinessCode(next.getString("fbillno")); + //属性 + backlogMessage.setPendingAttr("0"); + //notifyMsg 通知消息 + backlogMessage.setNotifyMsg(""); + //notifyMethod 通知方式 + backlogMessage.setNotifyMethod(""); + //业务自定义数据 + backlogMessage.setJsonData(""); + CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(backlogMessage); + break; + case "2": + DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("id"),phone); + break; + case "5": + deleteToDoHandler.get_deleteToDoHandler().sendDeleteToDo(next.getLong("id"),phone); + break; + default: + break; + } + } + } catch (Exception e) { + logger.error("###待办数据拼接、发送失败,状态为"+t_status+",（1:待办,2:已办,5:撤销）,具体原因：", e.getMessage(), e); + } + + logger.info("待办数据拼接和发送完成"); + } +} + diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java new file mode 100644 index 0000000..99d32f1 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java @@ -0,0 +1,16 @@ +package shkd.sse.midservice.ct.constant; + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 16:37 + * @Version: 1.0 + * @Ability + */ +public class ToDoCenterConstant { + public static String URI_send_addNew = "/bpm/task/api/addNew.dhtml"; + + public static String URI_SEND_finish = "/bpm/task/api/finishByRecordIdAndUserId.dhtml"; + + public static String URI_send_deleteP = "/oa/task/api/deletePendingByRecordIdAndUserId.dhtml"; +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java new file mode 100644 index 0000000..f045001 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java @@ -0,0 +1,59 @@ +package shkd.sse.midservice.ct.handler; + +import com.alibaba.fastjson.JSONObject; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import shkd.sse.midservice.ct.constant.ToDoCenterConstant; +import shkd.sse.midservice.ct.model.BacklogMessage; +import shkd.sse.midservice.ct.utils.RequestClient; + + +import java.util.Objects; + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 14:16 + * @Version: 1.0 + * @Ability 待办 + */ +public class CreateToDoHandler { + + private static Log logger = LogFactory.getLog(CreateToDoHandler.class); + private static CreateToDoHandler _CreateToDoHandler; + + public static synchronized CreateToDoHandler get_CreateToDoHandler(){ + if(_CreateToDoHandler == null){ + _CreateToDoHandler = new CreateToDoHandler(); + } + return _CreateToDoHandler; + } + public boolean sendCreateToDo(BacklogMessage messageInfo) { + try { + //body + JSONObject jsonObject2 = new JSONObject(); + jsonObject2.put("params",messageInfo); + String jsonMessage = jsonObject2.toJSONString(); + //调用接口结果 + String result = RequestClient.getInstance().callService(ToDoCenterConstant.URI_send_addNew,jsonMessage); + //接口调用结果 + JSONObject jsonObject = JSONObject.parseObject(result); + if(Objects.equals("success",jsonObject.getString("status"))){ + //发送成功 + //调用保存操作 + RequestClient.getInstance().saveCreateToDo(messageInfo.getTitle(),ToDoCenterConstant.URI_send_addNew,true,result,jsonMessage); + return true; + }else{ + //调用保存操作 + RequestClient.getInstance().saveCreateToDo(messageInfo.getTitle(),ToDoCenterConstant.URI_send_addNew,false,result,jsonMessage); + //发送失败 + logger.error("##接口调通失败"); + return false; + } + } catch (Exception e) { + logger.error("###调用接口失败："+e.getMessage(),e); + return false; + } + } + +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java new file mode 100644 index 0000000..b155e77 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java @@ -0,0 +1,58 @@ +package shkd.sse.midservice.ct.handler; + +import com.alibaba.fastjson.JSONObject; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import shkd.sse.midservice.ct.constant.ToDoCenterConstant; +import shkd.sse.midservice.ct.utils.RequestClient; + + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 14:18 + * @Version: 1.0 + * @Ability 处理（已办） + */ +public class DealToDoHandler { + private static Log logger = LogFactory.getLog(DealToDoHandler.class); + + private static DealToDoHandler _DealToDoHandler; + + public static synchronized DealToDoHandler get_DealToDoHandler(){ + if(_DealToDoHandler == null){ + _DealToDoHandler = new DealToDoHandler(); + } + return _DealToDoHandler; + } + + public boolean sendDealToDo(Long appRecordId,String userId) { + try { + //body + JSONObject jsonObject2 = new JSONObject(); + JSONObject jsonObject_1 = new JSONObject(); + jsonObject_1.put("appRecordId", appRecordId); + jsonObject_1.put("userId",userId); + jsonObject2.put("params",jsonObject_1); + String jsonMessage = jsonObject2.toJSONString(); + //调用接口结果 + String result = RequestClient.getInstance().callService(ToDoCenterConstant.URI_SEND_finish,jsonMessage); + //保存发送消息日志 + // writeMessageLog(MessageCenterConstant.URI_SEND_MESSAGE,messageInfo,result); + //接口调用结果 + JSONObject jsonObject = JSONObject.parseObject(result); + if(jsonObject.getBoolean("success")){ + //发送成功 + RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_SEND_finish,true,result,jsonMessage,"2"); + return true; + }else{ + //发送失败 + RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_SEND_finish,false,result,jsonMessage,"2"); + return false; + } + } catch (Exception e) { + logger.error("调用接口失败："+e.getMessage(),e); + return false; + } + } +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java new file mode 100644 index 0000000..77f68d0 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java @@ -0,0 +1,57 @@ +package shkd.sse.midservice.ct.handler; + +import com.alibaba.fastjson.JSONObject; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import shkd.sse.midservice.ct.constant.ToDoCenterConstant; +import shkd.sse.midservice.ct.utils.RequestClient; + + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 14:18 + * @Version: 1.0 + * @Ability 撤销 + */ +public class deleteToDoHandler { + private static Log logger = LogFactory.getLog(deleteToDoHandler.class); + + private static deleteToDoHandler _deleteToDoHandler; + + public static synchronized deleteToDoHandler get_deleteToDoHandler(){ + if(_deleteToDoHandler == null){ + _deleteToDoHandler = new deleteToDoHandler(); + } + return _deleteToDoHandler; + } + + public boolean sendDeleteToDo(Long appRecordId,String userId) { + try { + //body + JSONObject jsonObject2 = new JSONObject(); + JSONObject jsonObject_1 = new JSONObject(); + jsonObject_1.put("appRecordId", appRecordId); + jsonObject_1.put("userId",userId); + jsonObject2.put("params",jsonObject_1); + String jsonMessage = jsonObject2.toJSONString(); + //调用接口结果 + String result = RequestClient.getInstance().callService(ToDoCenterConstant.URI_send_deleteP,jsonMessage); + //保存发送消息日志 + // writeMessageLog(MessageCenterConstant.URI_SEND_MESSAGE,messageInfo,result); + //接口调用结果 + JSONObject jsonObject = JSONObject.parseObject(result); + if(jsonObject.getBoolean("success")){ + //发送成功 + RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_send_deleteP,true,result,jsonMessage,"5"); + return true; + }else{ + RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_send_deleteP,false,result,jsonMessage,"5"); + return false; + } + } catch (Exception e) { + logger.error("###调用中台服务消息中心发送消息服务异常："+e.getMessage(),e); + return false; + } + } +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java new file mode 100644 index 0000000..f13c341 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java @@ -0,0 +1,176 @@ +package shkd.sse.midservice.ct.model; + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 13:38 + * @Version: 1.0 + * @Ability + */ +public class BacklogMessage { + + private String bName;//业务类型名称 String false + private String urGency;//紧急程度 int true 0:普通;1:紧急;2:加急;3:特急 true + private String currentStepName;// 当前步骤名称 String false + private String preStepName;// 上步步骤名称 String false + private String sendUserName;// 发起人名称 String true + private String receiveUserId; //接收人 id String true 支持如下三种类型1.身份证号 2.手机号 3.登录账号 + private String title;// 待办名称 String true + private String handleUrl;// pc 办理 url 地址 String true + private String appHandleUrl;// app 办理地址 String false + private String appViewUrl;// app 查看地址 String false + private String appName;// 应用名称 String false + private String viewUrl;// pc 查看 url 地址 String true + private String pendingId;// 业务 id String true + private String bussinessCode;// 业务编码 String true + private String pendingAttr;// 属性 Int true 0:待办;1:待阅；3:承办 + private String notifyMsg;// 通知消息 String false + private String notifyMethod;// 通知方式 String false 0- 系统消息 1- 短信 2- 邮件3-app 消息推送。多个方式英文逗号隔开 + private String jsonData;// 业务自定义数据 String false 业务模块的数据，再调用查询待办的接口将会返回，建议传一个 json 字符串; + + public String getbName() { + return bName; + } + + public void setbName(String bName) { + this.bName = bName; + } + + public String getUrGency() { + return urGency; + } + + public void setUrGency(String urGency) { + this.urGency = urGency; + } + + public String getCurrentStepName() { + return currentStepName; + } + + public void setCurrentStepName(String currentStepName) { + this.currentStepName = currentStepName; + } + + public String getPreStepName() { + return preStepName; + } + + public void setPreStepName(String preStepName) { + this.preStepName = preStepName; + } + + public String getSendUserName() { + return sendUserName; + } + + public void setSendUserName(String sendUserName) { + this.sendUserName = sendUserName; + } + + public String getReceiveUserId() { + return receiveUserId; + } + + public void setReceiveUserId(String receiveUserId) { + this.receiveUserId = receiveUserId; + } + + public String getTitle() { + return title; + } + + public void setTitle(String title) { + this.title = title; + } + + public String getHandleUrl() { + return handleUrl; + } + + public void setHandleUrl(String handleUrl) { + this.handleUrl = handleUrl; + } + + public String getAppHandleUrl() { + return appHandleUrl; + } + + public void setAppHandleUrl(String appHandleUrl) { + this.appHandleUrl = appHandleUrl; + } + + public String getAppViewUrl() { + return appViewUrl; + } + + public void setAppViewUrl(String appViewUrl) { + this.appViewUrl = appViewUrl; + } + + public String getAppName() { + return appName; + } + + public void setAppName(String appName) { + this.appName = appName; + } + + public String getViewUrl() { + return viewUrl; + } + + public void setViewUrl(String viewUrl) { + this.viewUrl = viewUrl; + } + + public String getPendingId() { + return pendingId; + } + + public void setPendingId(String pendingId) { + this.pendingId = pendingId; + } + + public String getBussinessCode() { + return bussinessCode; + } + + public void setBussinessCode(String bussinessCode) { + this.bussinessCode = bussinessCode; + } + + public String getPendingAttr() { + return pendingAttr; + } + + public void setPendingAttr(String pendingAttr) { + this.pendingAttr = pendingAttr; + } + + public String getNotifyMsg() { + return notifyMsg; + } + + public void setNotifyMsg(String notifyMsg) { + this.notifyMsg = notifyMsg; + } + + public String getNotifyMethod() { + return notifyMethod; + } + + public void setNotifyMethod(String notifyMethod) { + this.notifyMethod = notifyMethod; + } + + public String getJsonData() { + return jsonData; + } + + public void setJsonData(String jsonData) { + this.jsonData = jsonData; + } + + +} \ No newline at end of file diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java new file mode 100644 index 0000000..867ccf6 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java @@ -0,0 +1,112 @@ +package shkd.sse.midservice.ct.servicehandler; + +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.logging.Log; +import kd.bos.logging.LogFactory; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.QueryServiceHelper; +import kd.bos.workflow.engine.msg.ctx.MessageContext; +import kd.bos.workflow.engine.msg.handler.AbstractServiceHandler; +import kd.bos.workflow.engine.msg.info.ToDoInfo; +import shkd.sse.midservice.ct.handler.CreateToDoHandler; +import shkd.sse.midservice.ct.handler.DealToDoHandler; +import shkd.sse.midservice.ct.handler.deleteToDoHandler; +import shkd.sse.midservice.ct.model.BacklogMessage; + +import java.util.List; + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 14:07 + * @Version: 1.0 + * @Ability + */ +public class BacklogServiceHandle extends AbstractServiceHandler { + + public static final String TYPE = "todo"; + + private static final Log logger = LogFactory.getLog(BacklogServiceHandle.class); + + public void createToDo(MessageContext ctx, ToDoInfo todoInfo) { + + logger.info("###创建待办_createToDo"); + //几个待办 + List userIds = todoInfo.getUserIds(); + DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone", new QFilter[]{new QFilter("id", "in", userIds)}); + DynamicObject dynamicObject = QueryServiceHelper.queryOne("wf_hitaskinst", "billno,startname,id,name", + new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())}); + for (DynamicObject query_one : query) { + + BacklogMessage backlogMessage = new BacklogMessage(); + //业务类型名称 + backlogMessage.setbName("业务类型名称"); + // 紧急程度 + backlogMessage.setUrGency("0"); + //当前节点名称 + backlogMessage.setCurrentStepName(dynamicObject.getString("name")); + //上步骤名称 + backlogMessage.setPreStepName(""); + // startname发起人名称 + backlogMessage.setSendUserName(dynamicObject.getString("startname")); + //接收人手机号 + backlogMessage.setReceiveUserId(query_one.getString("phone")); + //标题 + backlogMessage.setTitle(todoInfo.getTitle()); + //PC地址 + backlogMessage.setHandleUrl(todoInfo.getUrl()); + //PC地址查看 + backlogMessage.setViewUrl(todoInfo.getUrl()+"&ado=view"); + //app地址 + backlogMessage.setAppHandleUrl(todoInfo.getUrl()); + //App应用名称 + backlogMessage.setAppName(""); + //app地址查看 + backlogMessage.setAppViewUrl(todoInfo.getUrl()+"&ado=view"); + //业务id + backlogMessage.setPendingId(String.valueOf(todoInfo.getTaskId())); + // 业务编码 + backlogMessage.setBussinessCode(dynamicObject.getString("billno")); + //属性 + backlogMessage.setPendingAttr("0"); + //notifyMsg 通知消息 + backlogMessage.setNotifyMsg(""); + //notifyMethod 通知方式 + backlogMessage.setNotifyMethod(""); + //业务自定义数据 + backlogMessage.setJsonData(""); + CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(backlogMessage); + } + logger.info("###结束待办_createToDo"); + + } + + //已办 + public void dealToDo(MessageContext ctx, ToDoInfo info){ + logger.info("###创建已办_dealToDo"); + //几个已办 + List userIds = info.getUserIds(); + DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone", new QFilter[]{new QFilter("id", "in", userIds)}); + //业务id + Long taskId = ctx.getTaskId(); + for (DynamicObject queryOne : query) { + DealToDoHandler.get_DealToDoHandler().sendDealToDo(taskId,queryOne.getString("phone")); + } + logger.info("###结束已办_dealToDo"); + + } + //撤销 + public void deleteToDo(MessageContext ctx, ToDoInfo info){ + logger.info("###创建撤销_deleteToDo"); + List userIds = info.getUserIds(); + DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone", new QFilter[]{new QFilter("id", "in", userIds)}); + //业务id + Long taskId = ctx.getTaskId(); + for (DynamicObject queryOne : query) { + deleteToDoHandler.get_deleteToDoHandler().sendDeleteToDo(taskId,queryOne.getString("phone")); + } + logger.info("###结束撤销_deleteToDo"); + } + +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java new file mode 100644 index 0000000..d823963 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java @@ -0,0 +1,52 @@ +package shkd.sse.midservice.ct.utils; + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/7 14:38 + * @Version: 1.0 + * @Ability 获得url地址 + */ +public class GetUrlUtils { + + private static GetUrlUtils _instance; + /** + * 获取实例 + */ + public static synchronized GetUrlUtils getInstance() { + if (_instance == null) { + _instance = new GetUrlUtils(); + } + return _instance; + } + + /** + * 构建待办链接 + * @param formId PC表单id + * @param mobFormId 移动表单id + * @param source 来源应用编码 + * @param accountId 数据中心 + * @param activityId 活动id + * @param pkId 单据id + * @param taskId 任务id + * @return + */ + public String getPcUrl(String formId, String mobFormId, String source, String accountId, + Object activityId, Object pkId, Object taskId) { + StringBuffer urlBuffer = new StringBuffer(); + urlBuffer.append(System.getProperty("efms.midservice.backlog.url")); + // urlBuffer.append("http:10.17.85:8022/ierp"); + urlBuffer.append("/integration/yzjShareOpen.do"); + urlBuffer.append("?formId=").append(formId); + urlBuffer.append("&mb_formId=").append(mobFormId); + urlBuffer.append("&pkId=").append(pkId); + urlBuffer.append("&src=").append(source.toLowerCase()); + urlBuffer.append("&accountId=").append(accountId); + urlBuffer.append("&activityId=").append(activityId); + urlBuffer.append("&tId=").append(taskId); + urlBuffer.append("&apptype=backlogMQ"); + return urlBuffer.toString(); + } + + +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java new file mode 100644 index 0000000..8ad5fa4 --- /dev/null +++ b/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java @@ -0,0 +1,130 @@ +package shkd.sse.midservice.ct.utils; + +import com.alibaba.fastjson.JSON; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import kd.bos.util.HttpClientUtils; +import kd.bos.util.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.IOException; +import java.util.HashMap; +import java.util.Map; + +/** + * @Description: + * @Author: FangShiXiao + * @Date: 2024/11/5 14:46 + * @Version: 1.0 + * @Ability + */ +public class RequestClient { + private static RequestClient _instance; + private static Logger logger = LoggerFactory.getLogger(RequestClient.class); + // application/x-www-form-urlencoded + private String protocal;//http + private String ip;// 域名 + private String port;// 端口 + + private RequestClient() { + this.protocal = System.getProperty("efms.midservice.protocal"); + this.ip = System.getProperty("efms.midservice.ip"); + this.port = System.getProperty("efms.midservice.port"); + } + /** + * 获取中台服务客户端实例 + * + * @return + */ + public static synchronized RequestClient getInstance() { + if (_instance == null) { + _instance = new RequestClient(); + } + return _instance; + } + /** + * 封装中台请求头，执行POST请求 + * + * @param url 接口地址（不含http://ip:port的后半部分） + * @param body JSON格式字符串 + * @return 响应结果报文 + */ + public String callService(String url, String body) { + Map header = new HashMap<>(); + header.put("Content-Type", "application/x-www-form-urlencoded"); + StringBuffer urlStr = new StringBuffer(); + urlStr.append(this.protocal).append("://").append(this.ip); + if (!StringUtils.isEmpty(this.port)) { + urlStr.append(":").append(this.port); + } + urlStr.append(url); + String responseText = null; + try { + //直接POST请求 + responseText = HttpClientUtils.postjson(urlStr.toString(), header, body); + logger.info(String.format("###调用接口成功，请求URL：%s，请求Header：%s，请求Body：%s，响应报文：%s", url, JSON.toJSONString(header), body, responseText)); + } catch (IOException e) { + logger.error(String.format("###调用接口异常：%s，请求URL：%s，请求Header：%s，请求Body：%s", e.getMessage(), url, JSON.toJSONString(header), body), e); + } + return responseText; + } + + /*** + * 保存待办日志 + * @param title 标题 + * @param url 路径 + * @param isTrue 接口调用是否成功 + * @param result 响应报文 + * @param jsonMessage 请求报文 + */ + public void saveCreateToDo(String title,String url, boolean isTrue,String result,String jsonMessage){ + logger.info("###开始调用待办保存日志方法"); + StringBuffer urlStr = new StringBuffer(); + urlStr.append(this.protocal).append("://").append(this.ip); + if (!StringUtils.isEmpty(this.port)) { + urlStr.append(":").append(this.port); + } + urlStr.append(url);; + DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog"); + dynamicObject.set("shkd_url",urlStr); + dynamicObject.set("shkd_request",title); + dynamicObject.set("shkd_request_tag",jsonMessage); + dynamicObject.set("shkd_response",isTrue); + dynamicObject.set("shkd_response",result); + dynamicObject.set("shkd_status","0"); + SaveServiceHelper.save(new DynamicObject[]{dynamicObject}); + logger.info("###结束调用待办保存日志方法"); + } + /*** + * 保存待办日志 + * @param appRecordId 业务id + * @param userId 接收人id + * @param url 路径 + * @param isTrue 接口调用是否成功 + * @param result 响应报文 + * @param jsonMessage 请求报文 + * @param status 类型 2：已办 5：撤销 + */ + public void saveDeLToDo(Long appRecordId,String userId,String url,boolean isTrue,String result,String jsonMessage,String status){ + logger.info("###开始调用已办、撤销保存日志方法"); + StringBuffer urlStr = new StringBuffer(); + urlStr.append(this.protocal).append("://").append(this.ip); + if (!StringUtils.isEmpty(this.port)) { + urlStr.append(":").append(this.port); + } + urlStr.append(url); + DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog"); + dynamicObject.set("shkd_url",urlStr); + dynamicObject.set("shkd_request","业务id:"+appRecordId+",接收人手机号："+userId); + dynamicObject.set("shkd_request_tag",jsonMessage); + dynamicObject.set("shkd_response",isTrue); + dynamicObject.set("shkd_response",result); + dynamicObject.set("shkd_status",status); + logger.info("###开始调用已办、撤销保存日志方法"); + + } + + +} From 894d29729c8599fa1365f2b5b3561251a10d122d Mon Sep 17 00:00:00 2001 From: fang <123456> Date: Fri, 8 Nov 2024 10:34:00 +0800 Subject: [PATCH 09/11] =?UTF-8?q?=E5=BE=85=E5=8A=9E=5F1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sys/midservice}/backlogTack/ToDoResendTack.java | 13 ++++++------- .../midservice}/constant/ToDoCenterConstant.java | 2 +- .../sys/midservice}/handler/CreateToDoHandler.java | 8 ++++---- .../sys/midservice}/handler/DealToDoHandler.java | 6 +++--- .../sys/midservice}/handler/deleteToDoHandler.java | 6 +++--- .../sys/sys/midservice}/model/BacklogMessage.java | 4 ++-- .../servicehandler/BacklogServiceHandle.java | 10 +++++----- .../shkd/sys/sys/midservice}/utils/GetUrlUtils.java | 2 +- .../sys/sys/midservice}/utils/RequestClient.java | 2 +- 9 files changed, 26 insertions(+), 27 deletions(-) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/backlogTack/ToDoResendTack.java (96%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/constant/ToDoCenterConstant.java (90%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/handler/CreateToDoHandler.java (90%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/handler/DealToDoHandler.java (93%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/handler/deleteToDoHandler.java (93%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/model/BacklogMessage.java (99%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/servicehandler/BacklogServiceHandle.java (94%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/utils/GetUrlUtils.java (97%) rename {shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct => sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice}/utils/RequestClient.java (99%) diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/backlogTack/ToDoResendTack.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/backlogTack/ToDoResendTack.java similarity index 96% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/backlogTack/ToDoResendTack.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/backlogTack/ToDoResendTack.java index a7ba1eb..ddb81b6 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/backlogTack/ToDoResendTack.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/backlogTack/ToDoResendTack.java @@ -1,6 +1,5 @@ -package shkd.sse.midservice.ct.backlogTack; +package shkd.sys.sys.midservice.backlogTack; -import com.bes.admin.jeemx.util.ObjectUtil; import com.google.common.base.Objects; import kd.bos.algo.DataSet; import kd.bos.algo.Row; @@ -16,11 +15,11 @@ import kd.bos.orm.query.QFilter; import kd.bos.schedule.executor.AbstractTask; import kd.bos.servicehelper.QueryServiceHelper; import kd.bos.util.StringUtils; -import shkd.sse.midservice.ct.handler.CreateToDoHandler; -import shkd.sse.midservice.ct.handler.DealToDoHandler; -import shkd.sse.midservice.ct.handler.deleteToDoHandler; -import shkd.sse.midservice.ct.model.BacklogMessage; -import shkd.sse.midservice.ct.utils.GetUrlUtils; +import shkd.sys.sys.midservice.handler.CreateToDoHandler; +import shkd.sys.sys.midservice.handler.DealToDoHandler; +import shkd.sys.sys.midservice.handler.deleteToDoHandler; +import shkd.sys.sys.midservice.model.BacklogMessage; +import shkd.sys.sys.midservice.utils.GetUrlUtils; import java.util.*; diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/constant/ToDoCenterConstant.java similarity index 90% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/constant/ToDoCenterConstant.java index 99d32f1..9691a68 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/constant/ToDoCenterConstant.java @@ -1,4 +1,4 @@ -package shkd.sse.midservice.ct.constant; +package shkd.sys.sys.midservice.constant; /** * @Description: diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/CreateToDoHandler.java similarity index 90% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/CreateToDoHandler.java index f045001..60c0870 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/CreateToDoHandler.java @@ -1,11 +1,11 @@ -package shkd.sse.midservice.ct.handler; +package shkd.sys.sys.midservice.handler; import com.alibaba.fastjson.JSONObject; import kd.bos.logging.Log; import kd.bos.logging.LogFactory; -import shkd.sse.midservice.ct.constant.ToDoCenterConstant; -import shkd.sse.midservice.ct.model.BacklogMessage; -import shkd.sse.midservice.ct.utils.RequestClient; +import shkd.sys.sys.midservice.constant.ToDoCenterConstant; +import shkd.sys.sys.midservice.model.BacklogMessage; +import shkd.sys.sys.midservice.utils.RequestClient; import java.util.Objects; diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/DealToDoHandler.java similarity index 93% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/DealToDoHandler.java index b155e77..d418ef5 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/DealToDoHandler.java @@ -1,10 +1,10 @@ -package shkd.sse.midservice.ct.handler; +package shkd.sys.sys.midservice.handler; import com.alibaba.fastjson.JSONObject; import kd.bos.logging.Log; import kd.bos.logging.LogFactory; -import shkd.sse.midservice.ct.constant.ToDoCenterConstant; -import shkd.sse.midservice.ct.utils.RequestClient; +import shkd.sys.sys.midservice.constant.ToDoCenterConstant; +import shkd.sys.sys.midservice.utils.RequestClient; /** diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/deleteToDoHandler.java similarity index 93% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/deleteToDoHandler.java index 77f68d0..0f6ad85 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/handler/deleteToDoHandler.java @@ -1,10 +1,10 @@ -package shkd.sse.midservice.ct.handler; +package shkd.sys.sys.midservice.handler; import com.alibaba.fastjson.JSONObject; import kd.bos.logging.Log; import kd.bos.logging.LogFactory; -import shkd.sse.midservice.ct.constant.ToDoCenterConstant; -import shkd.sse.midservice.ct.utils.RequestClient; +import shkd.sys.sys.midservice.constant.ToDoCenterConstant; +import shkd.sys.sys.midservice.utils.RequestClient; /** diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/model/BacklogMessage.java similarity index 99% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/model/BacklogMessage.java index f13c341..7169bb7 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/model/BacklogMessage.java @@ -1,4 +1,4 @@ -package shkd.sse.midservice.ct.model; +package shkd.sys.sys.midservice.model; /** * @Description: @@ -173,4 +173,4 @@ public class BacklogMessage { } -} \ No newline at end of file +} diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java similarity index 94% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java index 867ccf6..f7843e8 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/servicehandler/BacklogServiceHandle.java @@ -1,4 +1,4 @@ -package shkd.sse.midservice.ct.servicehandler; +package shkd.sys.sys.midservice.servicehandler; import kd.bos.dataentity.entity.DynamicObject; import kd.bos.dataentity.entity.DynamicObjectCollection; @@ -9,10 +9,10 @@ import kd.bos.servicehelper.QueryServiceHelper; import kd.bos.workflow.engine.msg.ctx.MessageContext; import kd.bos.workflow.engine.msg.handler.AbstractServiceHandler; import kd.bos.workflow.engine.msg.info.ToDoInfo; -import shkd.sse.midservice.ct.handler.CreateToDoHandler; -import shkd.sse.midservice.ct.handler.DealToDoHandler; -import shkd.sse.midservice.ct.handler.deleteToDoHandler; -import shkd.sse.midservice.ct.model.BacklogMessage; +import shkd.sys.sys.midservice.handler.CreateToDoHandler; +import shkd.sys.sys.midservice.handler.DealToDoHandler; +import shkd.sys.sys.midservice.handler.deleteToDoHandler; +import shkd.sys.sys.midservice.model.BacklogMessage; import java.util.List; diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/GetUrlUtils.java similarity index 97% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/GetUrlUtils.java index d823963..fe3d90c 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/GetUrlUtils.java @@ -1,4 +1,4 @@ -package shkd.sse.midservice.ct.utils; +package shkd.sys.sys.midservice.utils; /** * @Description: diff --git a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/RequestClient.java similarity index 99% rename from shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java rename to sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/RequestClient.java index 8ad5fa4..446b0a5 100644 --- a/shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/midservice/utils/RequestClient.java @@ -1,4 +1,4 @@ -package shkd.sse.midservice.ct.utils; +package shkd.sys.sys.midservice.utils; import com.alibaba.fastjson.JSON; import kd.bos.dataentity.entity.DynamicObject; From fdc582e08e8b1da15e56a855e3b6507a0beccf71 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Fri, 8 Nov 2024 14:27:55 +0800 Subject: [PATCH 10/11] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E5=85=A5=E5=8F=82?= =?UTF-8?q?=E3=80=81=E5=87=BA=E5=8F=82=E5=A4=84=E7=90=86=E6=8F=92=E4=BB=B6?= =?UTF-8?q?1.0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sys/plugin/api/PayBillApiSavePlugin.java | 40 +++++++++++++++++++ .../api/PayBillApiSerializerPlugin.java | 34 ++++++++++++++++ 2 files changed, 74 insertions(+) create mode 100644 sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java index 91b0082..f08ae3b 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -1,6 +1,10 @@ package shkd.sys.sys.plugin.api; +import kd.bos.dataentity.entity.DynamicObject; import kd.bos.openapi.api.plugin.ApiSavePlugin; +import kd.bos.orm.query.QCP; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; import java.util.List; import java.util.Map; @@ -13,6 +17,42 @@ import java.util.Map; public class PayBillApiSavePlugin implements ApiSavePlugin { @Override public List> preHandleRequestData(List> reqData) { + //付款处理 → 收款人ID payee → 付款银行.编码 payerbank_number payeetype 收款人类型 → payeenumber 收款人编码 + //payeracctbank_number 付款银行账号.number + + //收款处理 → 付款人ID payer → 收款银行.number payeebank_number payertype 付款人类型 → payernumber 付款人编码 + //accountbank_number 收款银行账号.number + + //重复支付校验 + + String objectType;//对象类型（收/付人类型） + String objectNumber;//对象编码（收/付人编码） + String fieldName1;//字段名称（收/付人ID） + + String bankNumber;//（收/付款银行账号.number） + String fieldName2;//字段名称（收/付款银行.number） + for (Map map : reqData) { + Object payeetype = map.get("payeetype");//如果是收款人类型 则为付款处理保存接口 + if (payeetype != null) { + objectType = payeetype.toString(); + objectNumber = map.get("payeenumber").toString(); + fieldName1 = "payee"; + + bankNumber = map.get("payeracctbank_number").toString(); + fieldName2 = "payerbank_number"; + } else { + objectType = map.get("payertype").toString(); + objectNumber = map.get("payernumber").toString(); + fieldName1 = "payer"; + + bankNumber = map.get("accountbank_number").toString(); + fieldName2 = "payeebank_number"; + } + DynamicObject dynamicObject = BusinessDataServiceHelper.loadSingle(objectType, "id", new QFilter("billno", QCP.equals, objectNumber).toArray()); + DynamicObject amAccountbank = BusinessDataServiceHelper.loadSingle("am_accountbank", "id,bank,bank.number", new QFilter("number", QCP.equals, bankNumber).toArray()); + map.put(fieldName1, dynamicObject.getString("id")); + map.put(fieldName2, amAccountbank.getDynamicObject("bank").getString("number")); + } return reqData; } } diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java new file mode 100644 index 0000000..98972fd --- /dev/null +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java @@ -0,0 +1,34 @@ +package shkd.sys.sys.plugin.api; + +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; +import kd.bos.openapi.api.plugin.ApiSerializerPlugin; +import kd.bos.openapi.api.plugin.SerializerResult; +import kd.bos.openapi.common.constant.MediaType; + +/** + * @Description + * @Author Tao + * @Date 2024/11/7 + */ +public class PayBillApiSerializerPlugin implements ApiSerializerPlugin { + private static final long serialVersionUID = 3514721933945848571L; + + @Override + public SerializerResult serialize(Object response, String accept, String contentType) { + try { + if (contentType.contains(MediaType.APPLICATION_JSON)) { + //返回text文本 + String responseStr = new ObjectMapper().writeValueAsString(response); + return new SerializerResult(MediaType.TEXT_PLAIN, "实际返回：" + responseStr); + } else { + //其他类型的出参序列化 + return null; + } + } catch (JsonProcessingException e) { + //处理异常时严禁抛出异常，可以定义自己的错误返回信息 + String result="..."; + return new SerializerResult(MediaType.TEXT_PLAIN,result); + } + } +} From 5c25ea95f5e46467524915385dbd731edb791d61 Mon Sep 17 00:00:00 2001 From: zoujiangtao Date: Fri, 8 Nov 2024 14:29:03 +0800 Subject: [PATCH 11/11] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BA=BA=EF=BC=9A?= =?UTF-8?q?=E9=82=B9=E6=B1=9F=E6=B6=9B=20=E4=BF=AE=E6=94=B9=E5=86=85?= =?UTF-8?q?=E5=AE=B9=EF=BC=9A=E6=8E=A5=E5=8F=A3=E5=85=A5=E5=8F=82=E3=80=81?= =?UTF-8?q?=E5=87=BA=E5=8F=82=E5=A4=84=E7=90=86=E6=8F=92=E4=BB=B61.0=20?= =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=97=B6=E9=97=B4=EF=BC=9A2024/11/08?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java | 4 ++-- .../shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java index f08ae3b..415303f 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSavePlugin.java @@ -18,10 +18,10 @@ public class PayBillApiSavePlugin implements ApiSavePlugin { @Override public List> preHandleRequestData(List> reqData) { //付款处理 → 收款人ID payee → 付款银行.编码 payerbank_number payeetype 收款人类型 → payeenumber 收款人编码 - //payeracctbank_number 付款银行账号.number + //payeracctbank_number 付款银行账号.number //收款处理 → 付款人ID payer → 收款银行.number payeebank_number payertype 付款人类型 → payernumber 付款人编码 - //accountbank_number 收款银行账号.number + //accountbank_number 收款银行账号.number //重复支付校验 diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java index 98972fd..b0ecfe2 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/api/PayBillApiSerializerPlugin.java @@ -27,8 +27,8 @@ public class PayBillApiSerializerPlugin implements ApiSerializerPlugin { } } catch (JsonProcessingException e) { //处理异常时严禁抛出异常，可以定义自己的错误返回信息 - String result="..."; - return new SerializerResult(MediaType.TEXT_PLAIN,result); + String result = "..."; + return new SerializerResult(MediaType.TEXT_PLAIN, result); } } }