Skip to content

Commit 8ef4c00

Browse files
author
lixin_33
committed
[app-builder] 分域pr检视意见修改
1 parent 8fe37e7 commit 8ef4c00

9 files changed

Lines changed: 136 additions & 73 deletions

File tree

‎app-builder/plugins/aipp-plugin/src/main/java/modelengine/fit/jober/aipp/common/exception/AippErrCode.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -779,7 +779,7 @@ public enum AippErrCode implements ErrorCode, RetCode {
779779
/**
780780
* 应用未打开游客模式。
781781
*/
782-
THE_APP_IS_NOT_IN_GUEST_MODE(90002144, "应用未打开游客模式。"),
782+
APP_NOT_IN_GUEST_MODE(90002144, "应用未打开游客模式。"),
783783

784784
/**
785785
* 应用模板不存在。

‎app-builder/plugins/aipp-plugin/src/main/java/modelengine/fit/jober/aipp/controller/AppBuilderGuestController.java‎

Lines changed: 16 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,16 @@
77
package modelengine.fit.jober.aipp.controller;
88

99
import io.opentelemetry.api.trace.Span;
10-
import modelengine.fit.http.annotation.*;
10+
import modelengine.fit.http.annotation.DeleteMapping;
11+
import modelengine.fit.http.annotation.GetMapping;
12+
import modelengine.fit.http.annotation.PatchMapping;
13+
import modelengine.fit.http.annotation.PathVariable;
14+
import modelengine.fit.http.annotation.PostMapping;
15+
import modelengine.fit.http.annotation.PutMapping;
16+
import modelengine.fit.http.annotation.RequestBean;
17+
import modelengine.fit.http.annotation.RequestBody;
18+
import modelengine.fit.http.annotation.RequestMapping;
19+
import modelengine.fit.http.annotation.RequestParam;
1120
import modelengine.fit.http.entity.PartitionedEntity;
1221
import modelengine.fit.http.server.HttpClassicServerRequest;
1322
import modelengine.fit.jane.common.controller.AbstractController;
@@ -19,7 +28,12 @@
1928
import modelengine.fit.jober.aipp.common.exception.AippParamException;
2029
import modelengine.fit.jober.aipp.common.exception.AippTaskNotFoundException;
2130
import modelengine.fit.jober.aipp.constants.AippConst;
22-
import modelengine.fit.jober.aipp.dto.*;
31+
import modelengine.fit.jober.aipp.dto.AippCreateDto;
32+
import modelengine.fit.jober.aipp.dto.AppBuilderAppDto;
33+
import modelengine.fit.jober.aipp.dto.AppBuilderPromptCategoryDto;
34+
import modelengine.fit.jober.aipp.dto.AppBuilderPromptDto;
35+
import modelengine.fit.jober.aipp.dto.FileRspDto;
36+
import modelengine.fit.jober.aipp.dto.ResumeAippDto;
2337
import modelengine.fit.jober.aipp.dto.aipplog.AippInstLogDataDto;
2438
import modelengine.fit.jober.aipp.dto.chat.CreateAppChatRequest;
2539
import modelengine.fit.jober.aipp.dto.chat.QueryChatRequest;

‎app-builder/plugins/aipp-plugin/src/main/java/modelengine/fit/jober/aipp/domains/appversion/AppVersion.java‎

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,12 @@
1414
import static modelengine.fit.jober.aipp.common.exception.AippErrCode.INPUT_PARAM_IS_INVALID;
1515
import static modelengine.fit.jober.aipp.common.exception.AippErrCode.NEW_VERSION_IS_LOWER;
1616
import static modelengine.fit.jober.aipp.common.exception.AippErrCode.UPDATE_APP_CONFIGURATION_FAILED;
17-
import static modelengine.fit.jober.aipp.constants.AippConst.*;
17+
import static modelengine.fit.jober.aipp.constants.AippConst.ATTR_AIPP_TYPE_KEY;
18+
import static modelengine.fit.jober.aipp.constants.AippConst.ATTR_APP_IS_UPDATE;
19+
import static modelengine.fit.jober.aipp.constants.AippConst.ATTR_META_STATUS_KEY;
20+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_QUESTION_KEY;
21+
import static modelengine.fit.jober.aipp.constants.AippConst.CONTEXT_IS_GUEST;
22+
import static modelengine.fit.jober.aipp.constants.AippConst.RESTART_MODE;
1823
import static modelengine.fit.jober.aipp.enums.AippMetaStatusEnum.ACTIVE;
1924
import static modelengine.fit.jober.aipp.enums.AippTypeEnum.NORMAL;
2025
import static modelengine.fit.jober.aipp.enums.AippTypeEnum.PREVIEW;
@@ -697,7 +702,7 @@ public boolean isApp() {
697702
* @return true/false.
698703
*/
699704
public boolean isUpdated() {
700-
return ObjectUtils.cast(this.attributes.getOrDefault(AippConst.ATTR_APP_IS_UPDATE, true));
705+
return ObjectUtils.cast(this.attributes.getOrDefault(ATTR_APP_IS_UPDATE, true));
701706
}
702707

703708
/**
@@ -974,7 +979,7 @@ public boolean isEqual(AppVersion appVersion) {
974979
*/
975980
public void putAttributes(Map<String, Object> attributes) {
976981
this.attributes.putAll(attributes);
977-
this.attributes.put(AippConst.ATTR_APP_IS_UPDATE, true);
982+
this.attributes.put(ATTR_APP_IS_UPDATE, true);
978983
}
979984

980985
/**

‎app-builder/plugins/aipp-plugin/src/main/java/modelengine/fit/jober/aipp/domains/business/RunContext.java‎

Lines changed: 26 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,24 @@
66

77
package modelengine.fit.jober.aipp.domains.business;
88

9+
import static modelengine.fit.jober.aipp.constants.AippConst.ATTR_AIPP_TYPE_KEY;
10+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_FILE_DESC_KEY;
11+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_ID_KEY;
12+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_INST_ID_KEY;
13+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_MEMORIES_KEY;
14+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_QUESTION_KEY;
15+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_USE_MEMORY_KEY;
16+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_AIPP_VERSION_KEY;
17+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_CHAT_ID;
18+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_HTTP_CONTEXT_KEY;
19+
import static modelengine.fit.jober.aipp.constants.AippConst.BS_META_VERSION_ID_KEY;
20+
import static modelengine.fit.jober.aipp.constants.AippConst.CONTEXT_APP_CREATE_BY;
21+
import static modelengine.fit.jober.aipp.constants.AippConst.CONTEXT_IS_GUEST;
22+
import static modelengine.fit.jober.aipp.constants.AippConst.CONTEXT_USER_ID;
23+
import static modelengine.fit.jober.aipp.constants.AippConst.PARENT_CALLBACK_ID;
24+
import static modelengine.fit.jober.aipp.constants.AippConst.PARENT_INSTANCE_ID;
25+
import static modelengine.fit.jober.aipp.constants.AippConst.RESTART_MODE;
26+
927
import modelengine.fit.jane.common.entity.OperationContext;
1028
import modelengine.fit.jober.aipp.constants.AippConst;
1129
import modelengine.fit.jober.aipp.domains.task.AppTask;
@@ -27,8 +45,6 @@
2745
import java.util.Optional;
2846
import java.util.stream.Collectors;
2947

30-
import static modelengine.fit.jober.aipp.constants.AippConst.*;
31-
3248
/**
3349
* 运行时的上下文.
3450
*
@@ -162,16 +178,16 @@ public void setAppSuiteId(String appSuiteId) {
162178
}
163179

164180
/**
165-
* 设置是否是游客模式.
181+
* 设置是否是游客模式。
166182
*
167-
* @param isGuest 表示是否是游客模式
183+
* @param isGuest 表示是否是游客模式。
168184
*/
169185
public void setIsGuest(boolean isGuest) {
170186
this.businessData.put(CONTEXT_IS_GUEST, isGuest);
171187
}
172188

173189
/**
174-
* 设置应用创建者.
190+
* 设置应用创建者。
175191
*
176192
* @param appCreateBy 表示应用创建者
177193
*/
@@ -185,7 +201,7 @@ public void setAppCreateBy(String appCreateBy) {
185201
* @return 应用id.
186202
*/
187203
public String getAppSuiteId() {
188-
return ObjectUtils.cast(this.businessData.get(AippConst.ATTR_AIPP_TYPE_KEY));
204+
return ObjectUtils.cast(this.businessData.get(ATTR_AIPP_TYPE_KEY));
189205
}
190206

191207
/**
@@ -239,7 +255,7 @@ public void setAippType(String aippType) {
239255
* @return aipp类型.
240256
*/
241257
public String getAippType() {
242-
return ObjectUtils.cast(this.businessData.get(AippConst.ATTR_AIPP_TYPE_KEY));
258+
return ObjectUtils.cast(this.businessData.get(ATTR_AIPP_TYPE_KEY));
243259
}
244260

245261
/**
@@ -276,7 +292,7 @@ public void setStartTime(Object startTime) {
276292
* @param restartMode restart模式.
277293
*/
278294
public void setRestartMode(String restartMode) {
279-
this.businessData.put(AippConst.RESTART_MODE, restartMode);
295+
this.businessData.put(RESTART_MODE, restartMode);
280296
}
281297

282298
/**
@@ -294,7 +310,7 @@ public boolean isOverWriteMode() {
294310
* @param question 问题.
295311
*/
296312
public void setQuestion(String question) {
297-
this.businessData.put(AippConst.BS_AIPP_QUESTION_KEY, question);
313+
this.businessData.put(BS_AIPP_QUESTION_KEY, question);
298314
}
299315

300316
/**
@@ -303,7 +319,7 @@ public void setQuestion(String question) {
303319
* @return {@link String} 对象
304320
*/
305321
public String getRestartMode() {
306-
return ObjectUtils.cast(this.businessData.get(AippConst.RESTART_MODE));
322+
return ObjectUtils.cast(this.businessData.get(RESTART_MODE));
307323
}
308324

309325
/**

‎app-builder/plugins/aipp-plugin/src/main/java/modelengine/fit/jober/aipp/domains/task/AppTask.java‎

Lines changed: 44 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -120,18 +120,18 @@ public class AppTask implements AppTaskRunnable {
120120
}
121121

122122
/**
123-
* 作为实体.
123+
* 作为实体。
124124
*
125-
* @return {@link TaskDomainEntity} 对象.
125+
* @return {@link TaskDomainEntity} 对象。
126126
*/
127127
public static TaskDomainEntity asEntity() {
128128
return new TaskDomainEntity();
129129
}
130130

131131
/**
132-
* 作为创建参数.
132+
* 作为创建参数。
133133
*
134-
* @return {@link TaskDomainEntity} 对象
134+
* @return {@link TaskDomainEntity} 对象。
135135
*/
136136
public static TaskDomainEntity asCreateEntity() {
137137
TaskDomainEntity entity = new TaskDomainEntity();
@@ -144,10 +144,10 @@ public static TaskDomainEntity asCreateEntity() {
144144
}
145145

146146
/**
147-
* 作为修改参数.
147+
* 作为修改参数。
148148
*
149-
* @param taskId 任务唯一标识.
150-
* @return {@link TaskDomainEntity} 对象.
149+
* @param taskId 任务唯一标识。
150+
* @return {@link TaskDomainEntity} 对象。
151151
*/
152152
public static TaskDomainEntity asUpdateEntity(String taskId) {
153153
TaskDomainEntity entity = new TaskDomainEntity();
@@ -156,21 +156,21 @@ public static TaskDomainEntity asUpdateEntity(String taskId) {
156156
}
157157

158158
/**
159-
* 作为查询参数.
159+
* 作为查询参数。
160160
*
161-
* @param offset 偏移量.
162-
* @param limit 限制.
163-
* @return {@link TaskQueryEntity} 对象.
161+
* @param offset 偏移量。
162+
* @param limit 限制。
163+
* @return {@link TaskQueryEntity} 对象。
164164
*/
165165
public static TaskQueryEntity asQueryEntity(long offset, int limit) {
166166
return new TaskQueryEntity(offset, limit);
167167
}
168168

169169
/**
170-
* 将entity转换为特定的Entity类型对象.
170+
* 将entity转换为特定的Entity类型对象。
171171
*
172-
* @param <T> 代表Entity的类型.
173-
* @return 特定的 {@link TaskEntity} 类型.
172+
* @param <T> 代表Entity的类型。
173+
* @return 特定的 {@link TaskEntity} 类型。
174174
*/
175175
public <T extends TaskEntity<T>> T getEntity() {
176176
return ObjectUtils.cast(this.entity);
@@ -312,9 +312,9 @@ private void insertLog(String logType, AippLogData logData, RunContext runContex
312312
}
313313

314314
/**
315-
* 获取表单配置项集合.
315+
* 获取表单配置项集合。
316316
*
317-
* @return {@link List}{@code <}{@link AppBuilderFormProperty}{@code >} 集合.
317+
* @return {@link List}{@code <}{@link AppBuilderFormProperty}{@code >} 集合。
318318
*/
319319
public List<AppBuilderFormProperty> getFormProperties() {
320320
return UsefulUtils.lazyGet(this.formProperties,
@@ -346,9 +346,9 @@ private List<Map<String, Object>> getMemoryConfigs(String flowDefinitionId, Oper
346346
}
347347

348348
/**
349-
* 是否处于草稿态.
349+
* 是否处于草稿态。
350350
*
351-
* @return true/false.
351+
* @return true/false。
352352
*/
353353
public boolean isDraft() {
354354
String baseLineVersion = this.entity.getBaseLineVersion();
@@ -357,47 +357,47 @@ public boolean isDraft() {
357357
}
358358

359359
/**
360-
* 是否是正常类型任务.
360+
* 是否是正常类型任务。
361361
*
362-
* @return true/false.
362+
* @return true/false。
363363
*/
364364
public boolean isNormal() {
365365
return StringUtils.equalsIgnoreCase(this.entity.getAippType(), NORMAL.name());
366366
}
367367

368368
/**
369-
* 是否处于active状态.
369+
* 是否处于active状态。
370370
*
371-
* @return true/false.
371+
* @return true/false。
372372
*/
373373
public boolean isActive() {
374374
return StringUtils.equals(AippMetaStatusEnum.ACTIVE.getCode(), this.entity.getStatus());
375375
}
376376

377377
/**
378-
* 通过最新的版本判断是否是升级.
378+
* 通过最新的版本判断是否是升级。
379379
*
380-
* @param newVersion 最新的版本号.
381-
* @return true/false.
380+
* @param newVersion 最新的版本号。
381+
* @return true/false。
382382
*/
383383
public boolean isUpgrade(String newVersion) {
384384
return this.isActive() || !StringUtils.equals(newVersion, this.entity.getVersion());
385385
}
386386

387387
/**
388-
* 判断任务是否属于某个app版本.
388+
* 判断任务是否属于某个app版本。
389389
*
390-
* @param appId 应用版本id.
391-
* @return true/false.
390+
* @param appId 应用版本id。
391+
* @return true/false。
392392
*/
393393
public boolean isBelongApp(String appId) {
394394
return StringUtils.equals(appId, this.entity.getAppId());
395395
}
396396

397397
/**
398-
* 是否已发布.
398+
* 是否已发布。
399399
*
400-
* @return true/false.
400+
* @return true/false。
401401
*/
402402
public boolean isPublished() {
403403
if (StringUtils.isBlank(this.entity.getAippType()) || StringUtils.isBlank(this.entity.getStatus())) {
@@ -408,9 +408,9 @@ public boolean isPublished() {
408408
}
409409

410410
/**
411-
* 停止所有运行中的实例.
411+
* 停止所有运行中的实例。
412412
*
413-
* @param context 操作人上下文信息.
413+
* @param context 操作人上下文信息。
414414
*/
415415
public void terminateAllInstances(OperationContext context) {
416416
String taskId = this.entity.getTaskId();
@@ -434,9 +434,9 @@ public void terminateAllInstances(OperationContext context) {
434434
}
435435

436436
/**
437-
* 清理资源.
437+
* 清理资源。
438438
*
439-
* @param context 操作人上下文信息.
439+
* @param context 操作人上下文信息。
440440
*/
441441
public void cleanResource(OperationContext context) {
442442
String previewVersion = this.getEntity().getVersion();
@@ -457,10 +457,10 @@ public void cleanResource(OperationContext context) {
457457
}
458458

459459
/**
460-
* 获取所有实例.
460+
* 获取所有实例。
461461
*
462462
* @param context 操作人上下文信息.
463-
* @return {@link AppTaskInstance} 列表.
463+
* @return {@link AppTaskInstance} 列表。
464464
*/
465465
public List<AppTaskInstance> getInstances(OperationContext context) {
466466
return UsefulUtils.lazyGet(this.instances,
@@ -469,9 +469,9 @@ public List<AppTaskInstance> getInstances(OperationContext context) {
469469
}
470470

471471
/**
472-
* 删除task，同时删除相关数据.
472+
* 删除task，同时删除相关数据。
473473
*
474-
* @param context 操作人上下文信息.
474+
* @param context 操作人上下文信息。
475475
*/
476476
public void delete(OperationContext context) {
477477
// 需要先删除instance，再删除task
@@ -483,13 +483,13 @@ public void delete(OperationContext context) {
483483
}
484484

485485
/**
486-
* 恢复执行.
486+
* 恢复执行。
487487
*
488-
* @param instanceId 实例id.
489-
* @param logId 日志id.
490-
* @param formArgs 表单参数.
491-
* @param context 操作人上下文.
492-
* @param isGuest 是否是游客模式.
488+
* @param instanceId 实例id。
489+
* @param logId 日志id。
490+
* @param formArgs 表单参数。
491+
* @param context 操作人上下文。
492+
* @param isGuest 是否是游客模式。
493493
*/
494494
public void resume(String instanceId, Long logId, Map<String, Object> formArgs, OperationContext context,
495495
boolean isGuest) {

0 commit comments

Comments
 (0)