From 5c795ebde6d66ed72f8e537e370c2793168ac7e4 Mon Sep 17 00:00:00 2001 From: zjh <15615273395@163.com> Date: Sun, 14 Dec 2025 16:09:32 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E6=89=B9=E9=87=8F?= =?UTF-8?q?=E5=8F=91=E8=B5=B7=E6=B5=81=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../config/BusinessDatabase.java | 7 +- .../controller/DeleteController.java | 265 ++++++++---------- .../TemplateApprovalController.java | 11 + .../controller/TemplateController.java | 30 ++ .../form/ApprovalAndParameterForm.java | 4 +- .../controller/form/ParameterForm.java | 2 + .../feign/ApaasMyTokenFeign.java | 22 +- .../feign/dto/ProcessLaunchRequest.java | 15 + .../feign/dto/ProcessLaunchResponse.java | 24 ++ .../listener/SheetDataListener.java | 8 - .../pojo/ApprovalParameterChangeDetails.java | 18 ++ .../self_development/pojo/ApprovalPerson.java | 24 ++ .../pojo/ClassificationAttribute.java | 15 + .../pojo/EnginePartsCollection.java | 18 ++ .../xdap/self_development/pojo/Template.java | 4 +- .../pojo/view/CalculationParameterView.java | 15 +- .../pojo/view/TCParameterValueView.java | 5 + .../pojo/view/TemplateChangeView.java | 2 +- .../ParameterValueCalculationTimer.java | 48 +++- .../service/impl/ParameterServiceImpl.java | 134 ++++----- .../impl/TemplateApprovalServiceImpl.java | 6 +- .../service/impl/TemplateServiceImpl.java | 4 +- src/main/resources/sql.sql | 10 +- 23 files changed, 445 insertions(+), 246 deletions(-) create mode 100644 src/main/java/com/xdap/self_development/feign/dto/ProcessLaunchRequest.java create mode 100644 src/main/java/com/xdap/self_development/feign/dto/ProcessLaunchResponse.java create mode 100644 src/main/java/com/xdap/self_development/pojo/ApprovalParameterChangeDetails.java create mode 100644 src/main/java/com/xdap/self_development/pojo/ApprovalPerson.java create mode 100644 src/main/java/com/xdap/self_development/pojo/ClassificationAttribute.java create mode 100644 src/main/java/com/xdap/self_development/pojo/EnginePartsCollection.java create mode 100644 src/main/java/com/xdap/self_development/pojo/view/TCParameterValueView.java diff --git a/src/main/java/com/xdap/self_development/config/BusinessDatabase.java b/src/main/java/com/xdap/self_development/config/BusinessDatabase.java index 863e2e7..2265585 100644 --- a/src/main/java/com/xdap/self_development/config/BusinessDatabase.java +++ b/src/main/java/com/xdap/self_development/config/BusinessDatabase.java @@ -2,6 +2,8 @@ package com.xdap.self_development.config; import com.definesys.mpaas.query.MpaasQuery; import com.definesys.mpaas.query.MpaasQueryFactory; +import com.xdap.common.constant.DatasourceConstant; +import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; @@ -12,8 +14,11 @@ public class BusinessDatabase { @Resource private MpaasQueryFactory queryFactory; + @Value("${apaas.single.tenantId}") + private String tenantId; + @Bean public MpaasQuery getBusinessDatabase() { - return queryFactory.buildFromDatasource("xdap_app_223770822127386625"); + return queryFactory.buildFromDatasource(DatasourceConstant.XDAP_MYSQL_PREFIX + tenantId); } } diff --git a/src/main/java/com/xdap/self_development/controller/DeleteController.java b/src/main/java/com/xdap/self_development/controller/DeleteController.java index c14472e..ab8869b 100644 --- a/src/main/java/com/xdap/self_development/controller/DeleteController.java +++ b/src/main/java/com/xdap/self_development/controller/DeleteController.java @@ -2,22 +2,26 @@ package com.xdap.self_development.controller; import com.definesys.mpaas.common.http.Response; import com.definesys.mpaas.query.MpaasQueryFactory; +import com.xdap.motor.entity.SnowflakeIdWorker; +import com.xdap.runtime.service.RuntimeAppContextService; import com.xdap.self_development.common.UserPermissionGetter; import com.xdap.self_development.config.BusinessDatabase; -import com.xdap.self_development.pojo.*; +import com.xdap.self_development.feign.ApaasMyTokenFeign; +import com.xdap.self_development.feign.dto.AppTokenDTO; +import com.xdap.self_development.feign.dto.ProcessLaunchRequest; +import com.xdap.self_development.feign.dto.ProcessLaunchResponse; +import com.xdap.self_development.feign.dto.UserTokenDT0; +import com.xdap.self_development.pojo.ApprovalParameterChangeDetails; +import com.xdap.self_development.pojo.ApprovalPerson; import lombok.extern.slf4j.Slf4j; -import org.springframework.transaction.annotation.Transactional; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.Set; -import java.util.stream.Collectors; +import java.util.*; @Slf4j @RestController @@ -29,156 +33,123 @@ public class DeleteController { private UserPermissionGetter getter; @Resource private MpaasQueryFactory queryFactory; + @Autowired + private ApaasMyTokenFeign apaasMyTokenFeign; + @Resource + private RuntimeAppContextService runtimeAppContextService; + @Resource + private SnowflakeIdWorker snowflakeIdWorker; + @Value("${apaas.token.clientId}") + private String clientId; + @Value("${apaas.token.clientSecred}") + private String clientSecret; - @GetMapping("/getTables") - public Response getTables(String ztj, String z_wlms) { - Map map = new HashMap<>(); - List> list = queryFactory - .buildFromDatasource("yc_lrs_test_relsult") - .eq("ztj", ztj) - .eq("z_wlms", z_wlms) - .table("ads_prd_f_yfsjglpt_fdjlbjcjb") - .doQuery(); - List> list1 = queryFactory - .buildFromDatasource("yc_lrs_test_relsult") - .table("ads_prd_f_tc_flsxb") - .doQuery(); - map.put("ads_prd_f_yfsjglpt_fdjlbjcjb", list); - map.put("ads_prd_f_tc_flsxb", list1); - return Response.ok().data(map); + @GetMapping("submitApproval") + public Response submitApproval() { + String currentTenantId = runtimeAppContextService.getCurrentTenantId(); + String currentUserId = getter.getCurrentUserId(); + AppTokenDTO token = apaasMyTokenFeign.getAppToken( + "client_credentials", + clientId, + clientSecret + ); + + UserTokenDT0 userToken = apaasMyTokenFeign.getUserToken( + token.getAccess_token(), + currentUserId + ); + String formId = "693cce312153aa5a1ac8599b"; + String documentId = snowflakeIdWorker.nextId(); + ApprovalPerson approvalPerson = new ApprovalPerson(); + approvalPerson.getDetails().setParameterName("测试参数名11"); + approvalPerson.setPz(Collections.singletonList("100771325212057665536")); + approvalPerson.setSh(Collections.singletonList("100771325212057665536")); + approvalPerson.setJd(Collections.singletonList("100771325212057665536")); + approvalPerson.setDocumentId(documentId); + bd.getBusinessDatabase().doInsert(approvalPerson); + List documentIds = Collections.singletonList(documentId); + + // 调用接口 + ProcessLaunchResponse response = batchLaunch(userToken.getAccess_token(), formId, documentIds); + + // 处理响应 + if (response.isSuccess()) { + return Response.ok().data("流程批量发起成功:" + response.getMessage()); + } else { + return Response.error("流程批量发起失败:" + response.getMessage()); + } } - @GetMapping("getAll") - public Response getAll() { - List