吉安感知网项目-后端
linwei
5 days ago 8edf0004e4bd8b758b0fc5940a8a83f0f7948f74
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
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
/*
 *      Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
 *
 *  Redistribution and use in source and binary forms, with or without
 *  modification, are permitted provided that the following conditions are met:
 *
 *  Redistributions of source code must retain the above copyright notice,
 *  this list of conditions and the following disclaimer.
 *  Redistributions in binary form must reproduce the above copyright
 *  notice, this list of conditions and the following disclaimer in the
 *  documentation and/or other materials provided with the distribution.
 *  Neither the name of the dreamlu.net developer nor the names of its
 *  contributors may be used to endorse or promote products derived from
 *  this software without specific prior written permission.
 *  Author: Chill 庄骞 (smallchill@163.com)
 */
package org.sxkj.gd.workorder.controller;
 
import com.alibaba.fastjson.JSON;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
import lombok.AllArgsConstructor;
import javax.validation.Valid;
 
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.secure.BladeUser;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.Func;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.core.metadata.IPage;
import org.sxkj.gd.workorder.entity.GdClueEventEntity;
import org.sxkj.gd.workorder.param.GdClueDisposeRecordAddParam;
import org.sxkj.gd.workorder.param.GdClueEventRejectParam;
import org.sxkj.gd.workorder.param.GdClueEventStatusUpdateParam;
import org.sxkj.gd.workorder.vo.*;
import org.sxkj.gd.workorder.excel.GdClueEventExcel;
import org.sxkj.gd.workorder.service.IGdClueDisposeRecordService;
import org.sxkj.gd.workorder.service.IGdClueEventService;
import org.sxkj.gd.workorder.service.IGdClueEventStatusFlowService;
import org.springblade.core.boot.ctrl.BladeController;
import org.springblade.core.tool.utils.DateUtil;
import org.springblade.core.excel.util.ExcelUtil;
import org.springblade.core.tool.constant.BladeConstant;
import springfox.documentation.annotations.ApiIgnore;
import java.util.Map;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
 
/**
 * 事件表(线索事件) 控制器
 *
 * @author lw
 * @since 2026-01-14
 */
@Slf4j
@RestController
@AllArgsConstructor
@RequestMapping("workOrder/gdClueEvent")
@Api(value = "事件表(线索事件)", tags = "事件表(线索事件)接口")
public class GdClueEventController extends BladeController {
 
    private final IGdClueEventService gdClueEventService;
    private final IGdClueDisposeRecordService gdClueDisposeRecordService;
    private final IGdClueEventStatusFlowService gdClueEventStatusFlowService;
 
    /**
     * 事件表(线索事件) 详情
     */
    @GetMapping("/detail")
    @ApiOperationSupport(order = 1)
    @ApiOperation(value = "详情", notes = "传入事件ID")
    public R<GdClueEventVO> detail(@ApiParam(value = "事件ID", required = true) @RequestParam Long id) {
        return R.data(gdClueEventService.getGdClueEventDetail(id));
    }
 
    /**
     * 事件表(线索事件) 列表
     */
    @GetMapping("/list")
    @ApiOperationSupport(order = 2)
    @ApiOperation(value = "列表", notes = "固定过滤本部门,onlyMine=1时仅我的数据")
    public R<List<GdClueEventListVO>> list(@ApiParam(value = "是否仅我的数据,1为是,0为否")
            @RequestParam(value = "onlyMine", required = false, defaultValue = "0") Integer onlyMine,
            @ApiParam(value = "事件编号关键字")
            @RequestParam(value = "keyword", required = false) String keyword) {
        List<GdClueEventListVO> list = gdClueEventService.listGdClueEventByDept(onlyMine, keyword);
        return R.data(list);
    }
 
    /**
     * 事件表(线索事件) 数量统计
     */
    @GetMapping("/count")
    @ApiOperationSupport(order = 3)
    @ApiOperation(value = "数量统计", notes = "返回全部工单与我的工单数量")
    public R<GdClueEventCountVO> count(@ApiParam(value = "事件编号关键字")
            @RequestParam(value = "keyword", required = false) String keyword) {
        return R.data(gdClueEventService.getGdClueEventCount(keyword));
    }
 
    /**
     * 事件表(线索事件) 自定义分页
     */
    @GetMapping("/page")
    @ApiOperationSupport(order = 4)
    @ApiOperation(value = "分页", notes = "传入gdClueEvent")
    public R<IPage<GdClueEventVO>> page(GdClueEventVO gdClueEvent, Query query) {
        IPage<GdClueEventVO> pages = gdClueEventService.selectGdClueEventPage(Condition.getPage(query), gdClueEvent);
        return R.data(pages);
    }
//
//    /**
//     * 事件表(线索事件) 新增
//     */
//    @PostMapping("/save")
//    @ApiOperationSupport(order = 4)
//    @ApiOperation(value = "新增", notes = "传入gdClueEvent")
//    public R save(@Valid @RequestBody GdClueEventEntity gdClueEvent) {
//        return R.status(gdClueEventService.save(gdClueEvent));
//    }
//
//    /**
//     * 事件表(线索事件) 修改
//     */
//    @PostMapping("/update")
//    @ApiOperationSupport(order = 5)
//    @ApiOperation(value = "修改", notes = "传入gdClueEvent")
//    public R update(@Valid @RequestBody GdClueEventEntity gdClueEvent) {
//        return R.status(gdClueEventService.updateById(gdClueEvent));
//    }
 
    /**
     * 事件表(线索事件) 新增或修改
     */
    @PostMapping("/submit")
    @ApiOperationSupport(order = 6)
    @ApiOperation(value = "新增或修改", notes = "传入gdClueEvent")
    public R submit(@Valid @RequestBody GdClueEventEntity gdClueEvent) {
        return R.status(gdClueEventService.saveOrUpdate(gdClueEvent));
    }
 
    /**
     * 事件表(线索事件) 新增或修改-对外接口
     */
    @PostMapping("/submitExternal")
    @ApiOperationSupport(order = 6)
    @ApiOperation(value = "新增或修改", notes = "传入gdClueEvent")
    public R submitExternal(@Valid @RequestBody GdClueEventEntity gdClueEvent) {
        log.info("submitExternal-gdClueEvent:{}", JSON.toJSONString(gdClueEvent));
        return R.status(gdClueEventService.saveOrUpdateExternal(gdClueEvent));
    }
 
    /**
     * 事件表(线索事件) 删除
     */
    @PostMapping("/remove")
    @ApiOperationSupport(order = 7)
    @ApiOperation(value = "逻辑删除", notes = "传入ids")
    public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) {
        return R.status(gdClueEventService.deleteLogic(Func.toLongList(ids)));
    }
 
    /**
     * 事件处理
     */
    @PostMapping("/handle")
    @ApiOperationSupport(order = 8)
    @ApiOperation(value = "处理", notes = "传入事件ID与事件状态")
    public R handle(@Valid @RequestBody GdClueEventRejectParam rejectParam) {
        return R.status(gdClueEventService.handleClueEvent(rejectParam));
    }
 
    /**
     * 事件详情(包含处置记录和状态流转)
     */
    @GetMapping("/detailFull")
    @ApiOperationSupport(order = 9)
    @ApiOperation(value = "事件详情(包含处置记录和状态流转)", notes = "传入事件ID")
    public R<GdClueEventDetailVO> detailFull(@ApiParam(value = "事件ID", required = true) @RequestParam Long id) {
        // 1. 查询事件基本信息
        GdClueEventVO eventInfo = gdClueEventService.getGdClueEventDetail(id);
 
        // 2. 查询处置记录时间线
        List<GdClueDisposeRecordVO> disposeRecords = gdClueDisposeRecordService.getDisposeRecordsByEventId(id);
 
        // 3. 查询状态流转时间线
        List<GdClueEventStatusFlowVO> statusFlows = gdClueEventStatusFlowService.getStatusFlowsByEventId(id);
 
        // 4. 组装返回数据
        GdClueEventDetailVO detailVO = new GdClueEventDetailVO();
        detailVO.setEventInfo(eventInfo);
        detailVO.setDisposeRecords(disposeRecords);
        detailVO.setStatusFlows(statusFlows);
 
        return R.data(detailVO);
    }
 
    /**
     * 查询处置记录列表
     */
    @GetMapping("/disposeRecords")
    @ApiOperationSupport(order = 10)
    @ApiOperation(value = "查询处置记录列表", notes = "传入事件ID")
    public R<List<GdClueDisposeRecordVO>> getDisposeRecords(@ApiParam(value = "事件ID", required = true) @RequestParam Long eventId) {
        return R.data(gdClueDisposeRecordService.getDisposeRecordsByEventId(eventId));
    }
 
    /**
     * 新增处置记录
     */
    @PostMapping("/addDisposeRecord")
    @ApiOperationSupport(order = 11)
    @ApiOperation(value = "新增处置记录", notes = "传入处置记录参数,可同步更新事件状态")
    public R addDisposeRecord(@Valid @RequestBody GdClueDisposeRecordAddParam addParam) {
        return R.status(gdClueDisposeRecordService.addDisposeRecord(addParam));
    }
 
    /**
     * 查询状态流转记录列表
     */
    @GetMapping("/statusFlows")
    @ApiOperationSupport(order = 12)
    @ApiOperation(value = "查询状态流转记录列表", notes = "传入事件ID")
    public R<List<GdClueEventStatusFlowVO>> getStatusFlows(@ApiParam(value = "事件ID", required = true) @RequestParam Long eventId) {
        return R.data(gdClueEventStatusFlowService.getStatusFlowsByEventId(eventId));
    }
 
    /**
     * 更新事件状态
     */
    @PostMapping("/updateStatus")
    @ApiOperationSupport(order = 13)
    @ApiOperation(value = "更新事件状态", notes = "传入事件ID和目标状态,必须符合状态流转矩阵")
    public R updateStatus(@Valid @RequestBody GdClueEventStatusUpdateParam updateParam) {
        return R.status(gdClueEventService.updateEventStatus(updateParam));
    }
 
//    /**
//     * 导出数据
//     */
//    @GetMapping("/export-gdClueEvent")
//    @ApiOperationSupport(order = 9)
//    @ApiOperation(value = "导出数据", notes = "传入gdClueEvent")
//    public void exportGdClueEvent(@ApiIgnore @RequestParam Map<String, Object> gdClueEvent, BladeUser bladeUser, HttpServletResponse response) {
//        QueryWrapper<GdClueEventEntity> queryWrapper = Condition.getQueryWrapper(gdClueEvent, GdClueEventEntity.class);
//        //if (!AuthUtil.isAdministrator()) {
//        //    queryWrapper.lambda().eq(GdClueEvent::getTenantId, bladeUser.getTenantId());
//        //}
//        queryWrapper.lambda().eq(GdClueEventEntity::getIsDeleted, BladeConstant.DB_NOT_DELETED);
//        List<GdClueEventExcel> list = gdClueEventService.exportGdClueEvent(queryWrapper);
//        ExcelUtil.export(response, "事件表(线索事件)数据" + DateUtil.time(), "事件表(线索事件)数据表", list, GdClueEventExcel.class);
//    }
 
}