From 9a978a2f7bd1c916c798e8237539ca66dc9a8f06 Mon Sep 17 00:00:00 2001
From: sx <@sx.com>
Date: Fri, 13 Sep 2024 11:26:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=90=8C=E6=AD=A5=E6=96=B9?=
 =?UTF-8?q?=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../CustdocAutoAllotPluginInitializer.java    | 25 +++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java
index 114f9ae6..874084cc 100644
--- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java
+++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java
@@ -88,6 +88,31 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
 
     @Override
     public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
+        logger.info("调用：" + getPluginName() + "-插件");
+        String prod = "prod";
+        String param = String.valueOf(requestJson.get("param"));
+        if (requestJson != null && ProfilesActiveConstant.TYPE_DATE.equals(requestJson.get("type"))) {
+            //按日期
+            if (param != null && !"".equals(param)) {
+                String[] split = param.split("/");
+                if (!(split.length == 2)) {
+                    Assert.state(false, "时间格式传递不正确");
+                }
+                Assert.notNull(split[0], "开始时间不能为空");
+                Assert.notNull(split[1], "结束时间不能为空");
+                start(split[0], split[1]);
+            }
+        } else if (requestJson != null && ProfilesActiveConstant.TYPE_VBILLCODE.equals(requestJson.get("type"))) {
+            if (param != null && !"".equals(param)) {
+                start(param);
+            }
+        } else if (ProfilesActiveConstant.TYPE_DETAIL_ERROR.equals(requestJson.get("type"))) {
+            String integration_task_living_details_id = (String) requestJson.get("integration_task_living_details_id");
+            IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = saveOrUpdateBusinessLogUtil.queryIntegrationTaskLivingDetailsEntity(integration_task_living_details_id);
+            start(integrationTaskLivingDetailsEntity.getRootAppPk());
+        } else if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals(prod)) {
+            start();
+        }
         return null;
     }