Merge remote-tracking branch 'origin/develop' into develop
Showing
5 changed files
with
119 additions
and
4 deletions
... | @@ -96,6 +96,13 @@ public class DemandController { | ... | @@ -96,6 +96,13 @@ public class DemandController { |
96 | Boolean vo = demandService.lastApprove(dto); | 96 | Boolean vo = demandService.lastApprove(dto); |
97 | return CommonRes.success(vo); | 97 | return CommonRes.success(vo); |
98 | } | 98 | } |
99 | |||
100 | @PostMapping("/process-order-list") | ||
101 | @Operation(summary = "查询加工单列表") | ||
102 | public CommonRes<List<ProcessOrderProcessDtlRSVO>> listByProcessOrderNo() { | ||
103 | List<ProcessOrderProcessDtlRSVO> pageVO = demandService.listByProcessOrderNo(); | ||
104 | return CommonRes.success(pageVO); | ||
105 | } | ||
99 | 106 | ||
100 | //endregion | 107 | //endregion |
101 | 108 | ... | ... |
1 | package com.csbr.qingcloud.portal.domain.vo; | ||
2 | |||
3 | import com.fasterxml.jackson.annotation.JsonFormat; | ||
4 | import io.swagger.v3.oas.annotations.media.Schema; | ||
5 | import lombok.Data; | ||
6 | |||
7 | import java.util.Date; | ||
8 | |||
9 | /** | ||
10 | * @program: | ||
11 | * @description: 加工单加工明细返回参数 | ||
12 | * @author: xup | ||
13 | * @create: 2025-02-10 17:57 | ||
14 | **/ | ||
15 | @Data | ||
16 | @Schema(title = "加工单加工明细返回参数") | ||
17 | public class ProcessOrderProcessDtlRSVO { | ||
18 | |||
19 | /** | ||
20 | * 系统唯一标识 | ||
21 | */ | ||
22 | @Schema(description = "系统唯一标识") | ||
23 | private String guid; | ||
24 | |||
25 | /** | ||
26 | * 会员Guid | ||
27 | */ | ||
28 | @Schema(description = "会员Guid") | ||
29 | private String tenantGuid; | ||
30 | |||
31 | /** | ||
32 | * 加工单Guid | ||
33 | */ | ||
34 | @Schema(description = "加工单Guid") | ||
35 | private String processOrderGuid; | ||
36 | |||
37 | /** | ||
38 | * 加工单号 | ||
39 | */ | ||
40 | @Schema(description = "加工单号") | ||
41 | private String processOrderNo; | ||
42 | |||
43 | /** | ||
44 | * 加工单名称 | ||
45 | */ | ||
46 | @Schema(description = "加工单名称") | ||
47 | private String processOrderName; | ||
48 | |||
49 | /** | ||
50 | * 加工方式(1 数据服务;2 需求申请) | ||
51 | */ | ||
52 | @Schema(description = "加工方式(1 数据服务;2 需求申请)") | ||
53 | private Integer processType; | ||
54 | |||
55 | /** | ||
56 | * 业务Guid | ||
57 | */ | ||
58 | @Schema(description = "业务Guid") | ||
59 | private String bizGuid; | ||
60 | |||
61 | /** | ||
62 | * 加工状态(N 未开始;A 进行中;Y 已完成) | ||
63 | */ | ||
64 | @Schema(description = "加工状态(N 未开始;A 进行中;Y 已完成)") | ||
65 | private String processState; | ||
66 | |||
67 | /** | ||
68 | * 加工时间 | ||
69 | */ | ||
70 | @Schema(description = "加工时间") | ||
71 | @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") | ||
72 | private Date processTime; | ||
73 | |||
74 | /** | ||
75 | * 交付时间 | ||
76 | */ | ||
77 | @Schema(description = "交付时间") | ||
78 | @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") | ||
79 | private Date deliverTime; | ||
80 | |||
81 | /******** 库表存储属性 需处理 *****/ | ||
82 | |||
83 | /******** 自定义扩展 *****/ | ||
84 | |||
85 | /******** 子对象 *****/ | ||
86 | |||
87 | } |
... | @@ -3,6 +3,7 @@ package com.csbr.qingcloud.portal.feign; | ... | @@ -3,6 +3,7 @@ package com.csbr.qingcloud.portal.feign; |
3 | import com.csbr.cloud.common.config.FastCallFeignConfiguration; | 3 | import com.csbr.cloud.common.config.FastCallFeignConfiguration; |
4 | import com.csbr.cloud.common.response.CommonRes; | 4 | import com.csbr.cloud.common.response.CommonRes; |
5 | import com.csbr.qingcloud.portal.domain.vo.DemandUpdateStateVO; | 5 | import com.csbr.qingcloud.portal.domain.vo.DemandUpdateStateVO; |
6 | import com.csbr.qingcloud.portal.domain.vo.ProcessOrderProcessDtlRSVO; | ||
6 | import com.csbr.qingcloud.portal.domain.vo.ProcessOrderRQVO; | 7 | import com.csbr.qingcloud.portal.domain.vo.ProcessOrderRQVO; |
7 | import jakarta.validation.Valid; | 8 | import jakarta.validation.Valid; |
8 | import org.springframework.cloud.openfeign.FeignClient; | 9 | import org.springframework.cloud.openfeign.FeignClient; |
... | @@ -24,4 +25,7 @@ public interface DataProcessBasicFeign { | ... | @@ -24,4 +25,7 @@ public interface DataProcessBasicFeign { |
24 | @PostMapping(value = "/process-order-process-dtl/get-order-state", produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE) | 25 | @PostMapping(value = "/process-order-process-dtl/get-order-state", produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE) |
25 | CommonRes<Map<String, DemandUpdateStateVO>> getOrderState(@RequestBody List<String> processOrderGuids); | 26 | CommonRes<Map<String, DemandUpdateStateVO>> getOrderState(@RequestBody List<String> processOrderGuids); |
26 | 27 | ||
28 | @PostMapping(value = "/process-order-process-dtl/process-order-list", produces = MediaType.APPLICATION_JSON_VALUE, consumes = MediaType.APPLICATION_JSON_VALUE) | ||
29 | CommonRes<List<ProcessOrderProcessDtlRSVO>> processOrderList(@RequestBody List<String> processOrderGuids); | ||
30 | |||
27 | } | 31 | } | ... | ... |
1 | package com.csbr.qingcloud.portal.service; | 1 | package com.csbr.qingcloud.portal.service; |
2 | 2 | ||
3 | import com.csbr.qingcloud.portal.domain.vo.DemandApproveVO; | 3 | import com.csbr.qingcloud.portal.domain.vo.*; |
4 | import com.csbr.qingcloud.portal.domain.vo.DemandUpdateStateVO; | ||
5 | import csbr.cloud.entity.domain.base.vo.PageListVO; | 4 | import csbr.cloud.entity.domain.base.vo.PageListVO; |
6 | import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO; | 5 | import com.csbr.cloud.workflow.domain.dto.callback.BizCallbackDTO; |
7 | import com.csbr.cloud.workflow.domain.vo.appove.FlowRQBaseVO; | 6 | import com.csbr.cloud.workflow.domain.vo.appove.FlowRQBaseVO; |
8 | import com.csbr.qingcloud.portal.domain.vo.DemandQueryVO; | ||
9 | import com.csbr.qingcloud.portal.domain.vo.DemandRSVO; | ||
10 | 7 | ||
11 | import java.util.List; | 8 | import java.util.List; |
12 | 9 | ||
... | @@ -76,4 +73,9 @@ public interface DemandService { | ... | @@ -76,4 +73,9 @@ public interface DemandService { |
76 | 73 | ||
77 | DemandRSVO getDemandDetailByProcess(String processOrderNo); | 74 | DemandRSVO getDemandDetailByProcess(String processOrderNo); |
78 | 75 | ||
76 | /** | ||
77 | * 根据加工单编号查询资产列表 | ||
78 | * @return | ||
79 | */ | ||
80 | List<ProcessOrderProcessDtlRSVO> listByProcessOrderNo(); | ||
79 | } | 81 | } | ... | ... |
... | @@ -2,6 +2,7 @@ package com.csbr.qingcloud.portal.service.impl; | ... | @@ -2,6 +2,7 @@ package com.csbr.qingcloud.portal.service.impl; |
2 | 2 | ||
3 | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; | 3 | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
4 | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; | 4 | import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
5 | import com.baomidou.mybatisplus.core.toolkit.Wrappers; | ||
5 | import com.csbr.cloud.common.enums.SystemError; | 6 | import com.csbr.cloud.common.enums.SystemError; |
6 | import com.csbr.cloud.common.enums.WorkFlowBizEnum; | 7 | import com.csbr.cloud.common.enums.WorkFlowBizEnum; |
7 | import com.csbr.cloud.workflow.domain.dto.appove.FlowUpdateStateDTO; | 8 | import com.csbr.cloud.workflow.domain.dto.appove.FlowUpdateStateDTO; |
... | @@ -30,6 +31,7 @@ import csbr.cloud.entity.utils.UserContextHolder; | ... | @@ -30,6 +31,7 @@ import csbr.cloud.entity.utils.UserContextHolder; |
30 | import jakarta.annotation.Resource; | 31 | import jakarta.annotation.Resource; |
31 | import lombok.extern.slf4j.Slf4j; | 32 | import lombok.extern.slf4j.Slf4j; |
32 | import org.apache.commons.collections.CollectionUtils; | 33 | import org.apache.commons.collections.CollectionUtils; |
34 | import org.apache.commons.lang3.ObjectUtils; | ||
33 | import org.apache.commons.lang3.StringUtils; | 35 | import org.apache.commons.lang3.StringUtils; |
34 | import org.springframework.stereotype.Service; | 36 | import org.springframework.stereotype.Service; |
35 | import io.seata.spring.annotation.GlobalTransactional; | 37 | import io.seata.spring.annotation.GlobalTransactional; |
... | @@ -342,6 +344,19 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService | ... | @@ -342,6 +344,19 @@ public class DemandServiceImpl extends FlowAbstractImpl implements DemandService |
342 | return convertToVO(list.get(0),getStateMap(Collections.singletonList(list.get(0).getGuid()))); | 344 | return convertToVO(list.get(0),getStateMap(Collections.singletonList(list.get(0).getGuid()))); |
343 | } | 345 | } |
344 | 346 | ||
347 | @Override | ||
348 | public List<ProcessOrderProcessDtlRSVO> listByProcessOrderNo() { | ||
349 | LambdaQueryWrapper<MfDemand> queryWrapper = Wrappers.lambdaQuery(MfDemand.class); | ||
350 | queryWrapper.isNotNull(MfDemand::getRequirementOrderNo).isNotNull(MfDemand::getProcessOrderNo); | ||
351 | queryWrapper.orderByDesc(MfDemand::getCreateTime); | ||
352 | List<MfDemand> mfDemands = mfDemandService.list(queryWrapper); | ||
353 | if (ObjectUtils.isEmpty(mfDemands)) { | ||
354 | return null; | ||
355 | } | ||
356 | List<String> guids = mfDemands.stream().map(MfDemand::getGuid).toList(); | ||
357 | return dataProcessBasicFeign.processOrderList(guids).getData(); | ||
358 | } | ||
359 | |||
345 | /** | 360 | /** |
346 | * 获取发起流程参数 | 361 | * 获取发起流程参数 |
347 | * @author xcq | 362 | * @author xcq | ... | ... |
-
Please register or sign in to post a comment