jialh
昨天 dd6687b118561100e1677e88a9c2f5842a54c531
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
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
package com.java110.fee.api.contract;
 
import com.alibaba.fastjson.JSONObject;
import com.java110.dto.contract.ContractCollectionDetailDto;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.vo.ResultVo;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
 
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
/**
 * 合同收款明细信息接口
 * 适配 contract_collection_detail 表
 * @author dev
 * @date 2025-12-24
 */
@RestController
@RequestMapping(value = "/contractCollectionDetail")
public class ContractCollectionDetailApi {
 
    @Autowired
    protected SqlSessionTemplate sqlSessionTemplate;
 
    /**
     * 保存合同收款明细信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /contractCollectionDetail/saveContractCollectionDetail
     * @path /app/contractCollectionDetail/saveContractCollectionDetail
     */
    @RequestMapping(value = "/saveContractCollectionDetail", method = RequestMethod.POST)
    public ResponseEntity<String> saveContractCollectionDetail(@RequestBody JSONObject reqJson) {
        // 核心参数校验
        Assert.hasKeyAndValue(reqJson, "contractId", "请求报文中未包含合同ID");
 
        // 转换为DTO
        ContractCollectionDetailDto dto = BeanConvertUtil.covertBean(reqJson, ContractCollectionDetailDto.class);
 
        // 调用Mapper保存方法
        int insert = sqlSessionTemplate.insert("contractCollectionDetailDaoImpl.saveContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(dto));
 
        // 构造响应结果
        JSONObject resJson = new JSONObject();
        if (insert > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "保存合同收款明细信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "保存合同收款明细信息失败");
        }
        resJson.put("count", insert);
        return ResponseEntity.ok(resJson.toJSONString());
    }
 
    /**
     * 重载保存方法(入参为DTO)
     */
    public ResponseEntity<String> saveContractCollectionDetail(ContractCollectionDetailDto dto) {
        int insert = sqlSessionTemplate.insert("contractCollectionDetailDaoImpl.saveContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(dto));
 
        JSONObject resJson = new JSONObject();
        if (insert > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "保存合同收款明细信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "保存合同收款明细信息失败");
        }
        resJson.put("count", insert);
        return ResponseEntity.ok(resJson.toJSONString());
    }
 
    /**
     * 修改合同收款明细信息
     *
     * @param reqJson 请求参数
     * @return 响应结果
     * @serviceCode /contractCollectionDetail/updateContractCollectionDetail
     * @path /app/contractCollectionDetail/updateContractCollectionDetail
     */
    @RequestMapping(value = "/updateContractCollectionDetail", method = RequestMethod.POST)
    public ResponseEntity<String> updateContractCollectionDetail(@RequestBody JSONObject reqJson) {
        // 主键/合同ID校验(二选一)
        Assert.hasKey(reqJson, "id", "请求报文中未包含主键ID");
        Assert.hasKey(reqJson, "contractId", "请求报文中未包含合同ID");
 
        ContractCollectionDetailDto dto = BeanConvertUtil.covertBean(reqJson, ContractCollectionDetailDto.class);
 
        // 调用Mapper修改方法
        int update = sqlSessionTemplate.update("contractCollectionDetailDaoImpl.updateContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(dto));
 
        JSONObject resJson = new JSONObject();
        if (update > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "修改合同收款明细信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "修改合同收款明细信息失败,未找到对应记录");
        }
        resJson.put("count", update);
        return ResponseEntity.ok(resJson.toJSONString());
    }
 
    @RequestMapping(value = "/deleteContractCollectionDetail", method = RequestMethod.POST)
    public ResponseEntity<String> deleteContractCollectionDetail(@RequestBody JSONObject reqJson) {
        // 主键/合同ID校验(二选一)
        Assert.hasKey(reqJson, "id", "请求报文中未包含主键ID");
//        Assert.hasKey(reqJson, "contractId", "请求报文中未包含合同ID");
 
        ContractCollectionDetailDto dto = BeanConvertUtil.covertBean(reqJson, ContractCollectionDetailDto.class);
 
        // 调用Mapper修改方法
        int update = sqlSessionTemplate.delete("contractCollectionDetailDaoImpl.deleteContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(dto));
 
        JSONObject resJson = new JSONObject();
        if (update > 0) {
            resJson.put("code", "0000");
            resJson.put("msg", "删除合同收款明细信息成功");
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "删除合同收款明细信息失败,未找到对应记录");
        }
        resJson.put("count", update);
        return ResponseEntity.ok(resJson.toJSONString());
    }
    /**
     * 分页查询合同收款明细信息列表
     *
     * @param id                    主键ID(可选)
     * @param contractId            合同ID(可选)
     * @param contractIdsStr           合同ID数组(可选,多个用逗号分隔)
     * @param collectionPeriodStart 收款周期开始时间(可选)
     * @param collectionPeriodEnd   收款周期结束时间(可选)
     * @param receivableMoney       应收金额(可选)
     * @param collectionDate        收款日期(可选)
     * @param collectionAmount      已收金额(可选)
     * @param specialReduction      特殊减免(可选)
     * @param unpaidMoney           未付金额(可选)
     * @param page                  页码(默认1)
     * @param row                   每页条数(默认10)
     * @return 响应结果
     * @serviceCode /contractCollectionDetail/queryContractCollectionDetail
     * @path /app/contractCollectionDetail/queryContractCollectionDetail
     */
    @RequestMapping(value = "/queryContractCollectionDetail", method = RequestMethod.GET)
    public ResponseEntity<String> queryContractCollectionDetail(
            @RequestParam(value = "id", required = false) String id,
            @RequestParam(value = "contractId", required = false) String contractId,
            // 前端传逗号分隔字符串(如"1001,1002,1003"),接收后转数组
            @RequestParam(value = "contractIds", required = false) String contractIdsStr,
            @RequestParam(value = "collectionPeriodStart", required = false) String collectionPeriodStart,
            @RequestParam(value = "collectionPeriodEnd", required = false) String collectionPeriodEnd,
            @RequestParam(value = "receivableMoney", required = false) String receivableMoney,
            @RequestParam(value = "collectionDate", required = false) String collectionDate,
            @RequestParam(value = "collectionAmount", required = false) String collectionAmount,
            @RequestParam(value = "specialReduction", required = false) String specialReduction,
            @RequestParam(value = "unpaidMoney", required = false) String unpaidMoney,
            @RequestParam(value = "page", defaultValue = "1") int page,
            @RequestParam(value = "row", defaultValue = "10") int row) {
 
        // 封装查询参数
        ContractCollectionDetailDto queryDto = new ContractCollectionDetailDto();
        if (id != null && !id.isEmpty()) {
            queryDto.setId(Integer.parseInt(id));
        }
        queryDto.setContractId(contractId);
        queryDto.setCollectionPeriodStart(collectionPeriodStart);
        queryDto.setCollectionPeriodEnd(collectionPeriodEnd);
        queryDto.setReceivableMoney(receivableMoney);
        queryDto.setCollectionDate(collectionDate);
        queryDto.setCollectionAmount(collectionAmount);
        queryDto.setSpecialReduction(specialReduction);
        queryDto.setUnpaidMoney(unpaidMoney);
        queryDto.setPage((page - 1) * row);
        queryDto.setRow(row);
 
        // 处理contractIds:字符串转数组(兼容前端传参)
        if (contractIdsStr != null && !contractIdsStr.isEmpty()) {
            // 按逗号分割为数组
            String[] contractIds = contractIdsStr.split(",");
            queryDto.setContractIds(contractIds);
        }
 
        // 查询列表数据(MyBatis自动识别String[]并遍历)
        List<ContractCollectionDetailDto> list = BeanConvertUtil.covertBeanList(sqlSessionTemplate.selectList(
                "contractCollectionDetailDaoImpl.getContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(queryDto)), ContractCollectionDetailDto.class);
 
        // 查询总数
        Object total = ((HashMap) sqlSessionTemplate.selectOne(
                "contractCollectionDetailDaoImpl.queryContractCollectionDetailCount",
                BeanConvertUtil.beanCovertMap(queryDto))).get("count");
 
 
 
        // 构造分页响应
        ResultVo resultVo = new ResultVo();
        resultVo.setCode(0000);
        resultVo.setMsg("查询合同收款明细信息成功");
        resultVo.setPage(page);
        resultVo.setRows(row);
        resultVo.setTotal(Integer.parseInt(total.toString()));
        resultVo.setData(list);
 
//        ResultVo resultVo = new ResultVo((int) Math.ceil((double) count / (double) payFeeAuditDto.getRow()), count, payFeeAuditDtos);
        ResponseEntity<String> responseEntity = new ResponseEntity<String>(resultVo.toString(), HttpStatus.OK);
        return responseEntity;
    }
 
    /**
     * 根据ID查询单条合同收款明细信息
     *
     * @param id 主键ID
     * @return 响应结果
     * @serviceCode /contractCollectionDetail/getContractCollectionDetailById
     * @path /app/contractCollectionDetail/getContractCollectionDetailById
     */
    @RequestMapping(value = "/getContractCollectionDetailById", method = RequestMethod.GET)
    public ResponseEntity<String> getContractCollectionDetailById(@RequestParam(value = "id") Integer id) {
        // 主键校验
        Assert.notNull(id, "主键ID不能为空");
 
        ContractCollectionDetailDto queryDto = new ContractCollectionDetailDto();
        queryDto.setId(id);
 
        // 查询单条数据
        Map<String, Object> result = sqlSessionTemplate.selectOne(
                "contractCollectionDetailDaoImpl.getContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(queryDto));
 
        JSONObject resJson = new JSONObject();
        if (result != null) {
            resJson.put("code", "0000");
            resJson.put("msg", "查询合同收款明细信息成功");
            resJson.put("data", result);
        } else {
            resJson.put("code", "0001");
            resJson.put("msg", "未找到对应合同收款明细记录");
        }
 
        return ResponseEntity.ok(resJson.toJSONString());
    }
 
    /**
     * 根据合同ID查询合同收款明细信息
     *
     * @param contractId 合同ID
     * @return 响应结果
     * @serviceCode /contractCollectionDetail/getContractCollectionDetailByContractId
     * @path /app/contractCollectionDetail/getContractCollectionDetailByContractId
     */
    @RequestMapping(value = "/getContractCollectionDetailByContractId", method = RequestMethod.GET)
    public ResponseEntity<String> getContractCollectionDetailByContractId(@RequestParam(value = "contractId") String contractId) {
        Assert.hasLength(contractId, "合同ID不能为空");
 
        ContractCollectionDetailDto queryDto = new ContractCollectionDetailDto();
        queryDto.setContractId(contractId);
 
        List<Map<String, Object>> result = sqlSessionTemplate.selectList(
                "contractCollectionDetailDaoImpl.getContractCollectionDetail",
                BeanConvertUtil.beanCovertMap(queryDto));
 
        JSONObject resJson = new JSONObject();
        resJson.put("code", "0000");
        resJson.put("msg", "查询合同收款明细信息成功");
        resJson.put("data", result);
 
        return ResponseEntity.ok(resJson.toJSONString());
    }
}