xiaoyi
4 天以前 883f5e73fbe7458fd760dbe8560dd5d8757e04cd
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
package cn.iocoder.yudao.module.mes.controller.admin.pro.route;
 
import cn.iocoder.yudao.framework.apilog.core.annotation.ApiAccessLog;
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.pojo.PageParam;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.framework.excel.core.util.ExcelUtils;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.MesProRouteImportExcelVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.MesProRouteFullExcelVO;
import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteFullExcelService;
import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteFullImportService;
import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteWorkbookService;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.MesProRouteImportRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.MesProRoutePageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.MesProRouteRespVO;
import cn.iocoder.yudao.module.mes.controller.admin.pro.route.vo.MesProRouteSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteProductDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.route.MesProRouteProductMapper;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService;
import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Parameters;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.servlet.http.HttpServletResponse;
import jakarta.validation.Valid;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
 
import java.io.IOException;
import java.util.Collections;
import java.util.List;
 
import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.EXPORT;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
 
@Tag(name = "管理后台 - MES 工艺路线")
@RestController
@RequestMapping("/mes/pro/route")
@Validated
public class MesProRouteController {
 
    @Resource
    private MesProRouteService routeService;
    @Resource
    private MesProRouteFullExcelService fullExcelService;
    @Resource
    private MesProRouteFullImportService fullImportService;
    @Resource
    private MesProRouteWorkbookService routeWorkbookService;
    @Resource
    private MesProRouteProductMapper routeProductMapper;
    @Resource
    private MesMdItemService itemService;
 
    @PostMapping("/create")
    @Operation(summary = "创建工艺路线")
    @PreAuthorize("@ss.hasPermission('mes:pro-route:create')")
    public CommonResult<Long> createRoute(@Valid @RequestBody MesProRouteSaveReqVO createReqVO) {
        return success(routeService.createRoute(createReqVO));
    }
 
    @PutMapping("/update")
    @Operation(summary = "更新工艺路线")
    @PreAuthorize("@ss.hasPermission('mes:pro-route:update')")
    public CommonResult<Boolean> updateRoute(@Valid @RequestBody MesProRouteSaveReqVO updateReqVO) {
        routeService.updateRoute(updateReqVO);
        return success(true);
    }
 
    @PutMapping("/update-status")
    @Operation(summary = "更新工艺路线状态")
    @Parameters({
            @Parameter(name = "id", description = "编号", required = true),
            @Parameter(name = "status", description = "状态", required = true)
    })
    @PreAuthorize("@ss.hasPermission('mes:pro-route:update')")
    public CommonResult<Boolean> updateRouteStatus(@RequestParam("id") Long id,
                                                    @RequestParam("status") Integer status) {
        routeService.updateRouteStatus(id, status);
        return success(true);
    }
 
    @DeleteMapping("/delete")
    @Operation(summary = "删除工艺路线")
    @Parameter(name = "id", description = "编号", required = true)
    @PreAuthorize("@ss.hasPermission('mes:pro-route:delete')")
    public CommonResult<Boolean> deleteRoute(@RequestParam("id") Long id) {
        routeService.deleteRoute(id);
        return success(true);
    }
 
    @GetMapping("/get")
    @Operation(summary = "获得工艺路线")
    @Parameter(name = "id", description = "编号", required = true, example = "1024")
    public CommonResult<MesProRouteRespVO> getRoute(@RequestParam("id") Long id) {
        MesProRouteDO route = routeService.getRoute(id);
        return success(BeanUtils.toBean(route, MesProRouteRespVO.class));
    }
 
    @GetMapping("/page")
    @Operation(summary = "获得工艺路线分页")
    public CommonResult<PageResult<MesProRouteRespVO>> getRoutePage(@Valid MesProRoutePageReqVO pageReqVO) {
        PageResult<MesProRouteDO> pageResult = routeService.getRoutePage(pageReqVO);
        PageResult<MesProRouteRespVO> response = BeanUtils.toBean(pageResult, MesProRouteRespVO.class);
        if (!pageResult.getList().isEmpty()) {
            var routeIds = pageResult.getList().stream().map(MesProRouteDO::getId).toList();
            var references = routeProductMapper.selectList(new LambdaQueryWrapperX<MesProRouteProductDO>()
                    .in(MesProRouteProductDO::getRouteId, routeIds).eq(MesProRouteProductDO::getTemplateReference, true));
            var items = itemService.getItemMap(references.stream().map(MesProRouteProductDO::getItemId).toList());
            var byRoute = references.stream().collect(java.util.stream.Collectors.toMap(
                    MesProRouteProductDO::getRouteId, r -> r, (first, ignored) -> first));
            response.getList().forEach(vo -> {
                var reference = byRoute.get(vo.getId());
                MesMdItemDO item = reference == null ? null : items.get(reference.getItemId());
                if (item != null) { vo.setReferenceProductCode(item.getCode()); vo.setReferenceProductName(item.getName()); }
            });
        }
        return success(response);
    }
 
    @GetMapping("/simple-list")
    @Operation(summary = "获得工艺路线精简列表", description = "只包含被开启的工艺路线,主要用于前端的下拉选项")
    public CommonResult<List<MesProRouteRespVO>> getRouteSimpleList() {
        List<MesProRouteDO> list = routeService.getRouteListByStatus(CommonStatusEnum.ENABLE.getStatus());
        return success(convertList(list, route -> new MesProRouteRespVO()
                .setId(route.getId()).setName(route.getName()).setCode(route.getCode())));
    }
 
    @GetMapping("/export-excel")
    @Operation(summary = "导出工艺路线 Excel")
    @PreAuthorize("@ss.hasPermission('mes:pro-route:export')")
    @ApiAccessLog(operateType = EXPORT)
    public void exportRouteExcel(@Valid MesProRoutePageReqVO pageReqVO,
                                  HttpServletResponse response) throws IOException {
        pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE);
        List<MesProRouteDO> list = routeService.getRoutePage(pageReqVO).getList();
        List<MesProRouteRespVO> data = BeanUtils.toBean(list, MesProRouteRespVO.class);
        ExcelUtils.write(response, "工艺路线.xls", "数据", MesProRouteRespVO.class, data);
    }
 
    @GetMapping("/get-full-import-template")
    @Operation(summary = "下载指定工艺路线参考产品、工序、产出和投料的完整模板")
    @PreAuthorize("@ss.hasPermission('mes:pro-route:import')")
    public void fullImportTemplate(@RequestParam("routeId") Long routeId, HttpServletResponse response) throws IOException {
        List<MesProRouteFullExcelVO> rows = fullExcelService.exportRouteReference(routeId);
        routeWorkbookService.write(response, rows);
    }
 
    @PostMapping("/import-full")
    @Operation(summary = "按路线事务导入完整工艺流程")
    @PreAuthorize("@ss.hasPermission('mes:pro-route:import')")
    public CommonResult<MesProRouteImportRespVO> importFull(@RequestParam("file") MultipartFile file,
            @RequestParam(value = "updateSupport", required = false, defaultValue = "false") Boolean updateSupport) throws IOException {
        return success(fullImportService.importRows(routeWorkbookService.read(file), updateSupport));
    }
 
    @GetMapping("/get-import-template")
    @Operation(summary = "获得工艺路线导入模板")
    public void importTemplate(HttpServletResponse response) throws IOException {
        // 手动创建导出 demo
        List<MesProRouteImportExcelVO> list = Collections.singletonList(
                MesProRouteImportExcelVO.builder()
                        .code("ROUTE001").name("示例工艺路线").description("").remark("").build()
        );
        // 输出
        ExcelUtils.write(response, "工艺路线导入模板.xls", "工艺路线列表", MesProRouteImportExcelVO.class, list);
    }
 
    @PostMapping("/import")
    @Operation(summary = "导入工艺路线")
    @Parameters({
            @Parameter(name = "file", description = "Excel 文件", required = true),
            @Parameter(name = "updateSupport", description = "是否支持更新,默认为 false", example = "true")
    })
    @PreAuthorize("@ss.hasPermission('mes:pro-route:import')")
    public CommonResult<MesProRouteImportRespVO> importExcel(@RequestParam("file") MultipartFile file,
                                                             @RequestParam(value = "updateSupport", required = false,
                                                                     defaultValue = "false") Boolean updateSupport) throws Exception {
        List<MesProRouteImportExcelVO> list = ExcelUtils.read(file, MesProRouteImportExcelVO.class);
        return success(routeService.importRouteList(list, updateSupport));
    }
 
}