广州市综治平台后端
xusd
1 days ago 3feed5879e5a9b794862bf46d38c7f66cfe41d50
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
package cn.huge.module.cases.controller.web;
 
import cn.huge.base.common.utils.ReturnFailUtils;
import cn.huge.base.common.utils.ReturnSucUtils;
import cn.huge.base.config.CurrentUser;
import cn.huge.module.cases.domain.po.CaseSupervise;
import cn.huge.module.cases.domain.po.CaseUrging;
import cn.huge.module.cases.service.CaseUrgingService;
import com.google.common.collect.Maps;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.web.bind.annotation.*;
 
import javax.servlet.http.HttpServletRequest;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;
 
/**
 * @title: 纠纷催办信息表接口api-web端
 * @description: 纠纷催办信息表接口api-web端
 * @company: hugeinfo
 * @author: zhouxt
 * @time: 2024-09-08 10:39:38
 * @version: 1.0.0
 */
@Slf4j
@RestController
@RequestMapping("/api/web/caseUrging")
public class CaseUrgingWebController {
 
    @Autowired(required = false)
    private HttpServletRequest request;
 
    @Autowired
    private CaseUrgingService service;
 
    /**
    * 获取请求URL参数
    * @return Map<String, Object>
    */
    private Map<String, Object> getParameter(){
        Map<String, Object> terms = Maps.newHashMap();
        // 主键编号
        String id = request.getParameter("id");
        if (StringUtils.isNotBlank(id)){
            terms.put("id", id);
        }
        // 纠纷编号
        String caseId = request.getParameter("caseId");
        if (StringUtils.isNotBlank(caseId)){
            terms.put("caseId", caseId);
        }
        // 催办意见
        String urgingContent = request.getParameter("urgingContent");
        if (StringUtils.isNotBlank(urgingContent)){
            terms.put("urgingContent", urgingContent);
        }
        // 催办人编号
        String urgingUserId = request.getParameter("urgingUserId");
        if (StringUtils.isNotBlank(urgingUserId)){
            terms.put("urgingUserId", urgingUserId);
        }
        // 催办人名称
        String urgingUserName = request.getParameter("urgingUserName");
        if (StringUtils.isNotBlank(urgingUserName)){
            terms.put("urgingUserName", urgingUserName);
        }
        // 催办时间
        String urgingTime = request.getParameter("urgingTime");
        if (StringUtils.isNotBlank(urgingTime)){
            terms.put("urgingTime", urgingTime);
        }
        // 催办状态
        String urgingStatus = request.getParameter("urgingStatus");
        if (StringUtils.isNotBlank(urgingStatus)){
            terms.put("urgingStatus", urgingStatus);
        }
        // 回复期限
        String replyTerm = request.getParameter("replyTerm");
        if (StringUtils.isNotBlank(replyTerm)){
            terms.put("replyTerm", replyTerm);
        }
        // 回复内容
        String replyContent = request.getParameter("replyContent");
        if (StringUtils.isNotBlank(replyContent)){
            terms.put("replyContent", replyContent);
        }
        // 回复人编号
        String replyUserId = request.getParameter("replyUserId");
        if (StringUtils.isNotBlank(replyUserId)){
            terms.put("replyUserId", replyUserId);
        }
        // 回复人名称
        String replyUserName = request.getParameter("replyUserName");
        if (StringUtils.isNotBlank(replyUserName)){
            terms.put("replyUserName", replyUserName);
        }
        // 回复时间
        String replyTime = request.getParameter("replyTime");
        if (StringUtils.isNotBlank(replyTime)){
            terms.put("replyTime", replyTime);
        }
        // 删除状态
        String deleteStatus = request.getParameter("deleteStatus");
        if (StringUtils.isNotBlank(deleteStatus)){
            terms.put("deleteStatus", deleteStatus);
        }
        // 客户编号
        String custId = request.getParameter("custId");
        if (StringUtils.isNotBlank(custId)){
            terms.put("custId", custId);
        }
        // 创建时间区间
        String createStart = request.getParameter("createStart");
        String createEnd = request.getParameter("createEnd");
        if(StringUtils.isNotBlank(createStart) && StringUtils.isNotBlank(createEnd)) {
            terms.put("createStart", createStart);
            terms.put("createEnd", createEnd);
        }
        // 更新时间区间
        String updateStart = request.getParameter("updateStart");
        String updateEnd = request.getParameter("updateEnd");
        if(StringUtils.isNotBlank(updateStart) && StringUtils.isNotBlank(updateEnd)) {
            terms.put("updateStart", updateStart);
            terms.put("updateEnd", updateEnd);
        }
        return terms;
    }
 
    /**
    * 条件查询多个
    * @url {ctx}/api/web/caseUrging/listQuery
    * @return Object
    */
    @GetMapping("/listQuery")
    public Object listQuery() {
        try {
            Map<String, Object> terms = getParameter();
            return ReturnSucUtils.getRepInfo(service.listTerms(terms));
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }
 
    /**
    * 条件分页查询
    * @url {ctx}/api/web/caseUrging/pageQuery
    * @param page 页码
    * @param size 每页数量
    * @return Object
    */
    @GetMapping("/pageQuery")
    public Object pageQuery(@RequestParam(value = "page") int page, @RequestParam(value = "size") int size) {
        try {
            Map<String, Object> terms = getParameter();
            Sort sort = Sort.by(Sort.Direction.DESC, "create_time");
            PageRequest pageRequest = PageRequest.of(page-1, size, sort);
            Page<CaseUrging> caseUrgingPage = service.pageQuery(pageRequest, terms);
            return ReturnSucUtils.getRepInfo( "处理成功", caseUrgingPage);
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }
 
    /**
    * 根据编号查询单个
    * @url {ctx}/api/web/caseUrging/getById
    * @param id 主键编号
    * @return Object
    */
    @GetMapping("/getById")
    public Object getById(@RequestParam(value = "id") String id) {
        try {
            return ReturnSucUtils.getRepInfo(service.getById(id));
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }
 
    /**
    * 根据主键单个
    * @url {ctx}/api/web/caseUrging/deleteById
    * @param id 主键编号
    * @return Object
    */
    @GetMapping("/deleteById")
    public Object deleteById(@RequestParam(value = "id") String id) {
        try {
            service.removeById(id);
            return ReturnSucUtils.getRepInfo();
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }
 
    /**
    * 新增或更新对象
    * @url {ctx}/api/web/caseUrging/saveCaseUrging
    * @param caseUrging 实体对象
    * @return Object
    */
    @PostMapping("/saveCaseUrging")
    public Object saveCaseUrging(@RequestBody CaseUrging caseUrging) {
        try {
            service.saveCaseUrging(caseUrging);
            return ReturnSucUtils.getRepInfo();
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }
 
    /**
     * 回复督办
     * @url {ctx}/api/web/caseSupervise/replyCaseSupervise
     * @param caseUrging 实体对象
     * @return Object
     */
    @PostMapping("/replyCaseUrging")
    public Object replyCaseUrging(@CurrentUser String userId, @RequestBody CaseUrging caseUrging) {
        try {
            service.replyCaseUrging(caseUrging, userId);
            return ReturnSucUtils.getRepInfo();
        } catch (Exception e) {
            return ReturnFailUtils.getRepInfo();
        }
    }
}