wujianwei
4 天以前 03c59a351565fe1b00c852bc821d7695b39084fc
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
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
package com.ruoyi.cwgl.service.impl;
 
import java.util.List;
 
import com.ruoyi.common.utils.DateUtils;
import javax.annotation.Resource;
 
import com.ruoyi.cwgl.domain.*;
import com.ruoyi.cwgl.domain.vo.ReceivableBillAgingAnalysisVo;
import com.ruoyi.cwgl.domain.vo.ReceivableBillAccountAnalysisVo;
import com.ruoyi.cwgl.mapper.*;
import com.ruoyi.cwgl.service.IAgingLogService;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
import org.springframework.scheduling.annotation.Async;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.ruoyi.common.utils.PageUtils;
import com.ruoyi.common.constant.Constants;
import com.ruoyi.common.annotation.DataSource;
import com.ruoyi.common.enums.DataSourceType;
import com.ruoyi.common.core.service.BaseService;
 
import com.ruoyi.cwgl.service.IReceivableBillManagementService;
import com.ruoyi.common.core.text.Convert;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
 
/**
 * 应收账单管理Service业务层处理
 *
 * @author ruoyi
 * @date 2025-12-17
 */
@Service
@Transactional(rollbackFor = Exception.class)
public class ReceivableBillManagementServiceImpl  extends BaseService<ReceivableBillManagementMapper, ReceivableBillManagement> implements IReceivableBillManagementService
{
    protected final Logger logger = LoggerFactory.getLogger(getClass());
    @Resource
    private ReceivableBillManagementMapper receivableBillManagementMapper;
    @Resource
    private ReceivableFeeManagementMapper receivableFeeManagementMapper;
    
    @Resource
    private ReceivableBillManagementLogMapper receivableBillManagementLogMapper;
    @Resource
    private AgingLogMapper agingLogMapper;
    @Resource
    private AccountLogMapper accountLogMapper;
 
 
    /**
     * 查询应收账单管理
     *
     * @param id 应收账单管理ID
     * @return 应收账单管理
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public ReceivableBillManagement selectReceivableBillManagementById(Integer id)
    {
        return receivableBillManagementMapper.selectReceivableBillManagementById(id);
    }
 
    /**
     * 查询应收账单管理 记录数
     *
     * @param receivableBillManagement 应收账单管理
     * @return 应收账单管理集合
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public int selectReceivableBillManagementCount(ReceivableBillManagement receivableBillManagement)
    {
        return receivableBillManagementMapper.selectReceivableBillManagementCount(receivableBillManagement);
    }
 
    /**
     * 查询应收账单管理列表
     *
     * @param receivableBillManagement 应收账单管理
     * @return 应收账单管理
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public List<ReceivableBillManagement> selectReceivableBillManagementList(ReceivableBillManagement receivableBillManagement)
    {
        return receivableBillManagementMapper.selectReceivableBillManagementList(receivableBillManagement);
    }
 
    /**
     * 查询应收账单管理列表 异步 导出
     *
     * @param receivableBillManagement 应收账单管理
     * @param exportKey 导出功能的唯一标识
     * @return 应收账单管理集合
     */
    @DataSource(DataSourceType.SLAVE)
    @Async
    @Override
    public void export(ReceivableBillManagement receivableBillManagement,String exportKey) {
 
        super.export(ReceivableBillManagement.class,exportKey,"receivableBillManagementData",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillManagementList(receivableBillManagement);
        });
    }   /**
     * 查询应收账单管理列表 异步 导出
     *
     * @param receivableBillManagement 应收账单管理
     * @param exportKey 导出功能的唯一标识
     * @return 应收账单管理集合
     */
    @DataSource(DataSourceType.SLAVE)
    @Async
    @Override
    public void customerSummaryExport(ReceivableBillManagement receivableBillManagement,String exportKey) {
 
        super.export2(ReceivableBillCustomerSummary.class,exportKey,"应收账款分析管理",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillCustomerSummaryList(receivableBillManagement);
        });
    }  @DataSource(DataSourceType.SLAVE)
    @Async
    @Override
    public void agingAnalysisExport(ReceivableBillManagement receivableBillManagement,String exportKey) {
 
        super.export2(ReceivableBillAgingAnalysisVo.class,exportKey,"应收账款分析管理",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillAgingAnalysisList(receivableBillManagement);
        });
    }
 
    @Async
    @Override
    public void accountAnalysisExport(ReceivableBillManagement receivableBillManagement,String exportKey) {
 
        super.export2(ReceivableBillAccountAnalysisVo.class,exportKey,"应收账款分析管理",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillAccountAnalysisList(receivableBillManagement);
        });
    }
 
 
    /**
     * 新增应收账单管理
     *
     * @param receivableBillManagement 应收账单管理
     * @return 结果
     */
    @Override
    public int insertReceivableBillManagement(ReceivableBillManagement receivableBillManagement)
    {
        receivableBillManagement.setCreateTime(DateUtils.getNowDate());
        return receivableBillManagementMapper.insertReceivableBillManagement(receivableBillManagement);
    }
 
    /**
     * 新增应收账单管理[批量]
     *
     * @param receivableBillManagements 应收账单管理
     * @return 结果
     */
    @Override
    public int insertReceivableBillManagementBatch(List<ReceivableBillManagement> receivableBillManagements)
    {
        int rows = receivableBillManagementMapper.insertReceivableBillManagementBatch(receivableBillManagements);
        return rows;
    }
 
    /**
     * 修改应收账单管理
     *
     * @param receivableBillManagement 应收账单管理
     * @return 结果
     */
    @Override
    public int updateReceivableBillManagement(ReceivableBillManagement receivableBillManagement)
    {
        receivableBillManagement.setUpdateTime(DateUtils.getNowDate());
        int result = receivableBillManagementMapper.updateReceivableBillManagement(receivableBillManagement);
        
        // 记录操作日志
        if (result > 0) {
            ReceivableBillManagementLog log = new ReceivableBillManagementLog();
            log.setBillId(receivableBillManagement.getId());
            log.setCreateBy(SecurityUtils.getUsername());
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("修改应收账单,账单编号:" + receivableBillManagement.getSystemNo());
            receivableBillManagementLogMapper.insertReceivableBillManagementLog(log);
        }
        
        return result;
    } @Override
    public int aging(ReceivableBillManagement receivableBillManagement)
    {
        receivableBillManagement.setUpdateTime(DateUtils.getNowDate());
        int result = receivableBillManagementMapper.updateReceivableBillManagement(receivableBillManagement);
 
        // 记录操作日志
        if (result > 0) {
            AgingLog log = new AgingLog();
            log.setHeadId(receivableBillManagement.getId());
            log.setCreateBy(SecurityUtils.getUsername());
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("编辑账龄分析信息");
            agingLogMapper.insertAgingLog(log);
        }
 
        return result;
    }
    @Override
    public int account(ReceivableBillManagement receivableBillManagement)
    {
        receivableBillManagement.setUpdateTime(DateUtils.getNowDate());
        int result = receivableBillManagementMapper.updateReceivableBillManagement(receivableBillManagement);
 
        // 记录操作日志
        if (result > 0) {
            AccountLog log = new AccountLog();
            log.setHeadId(receivableBillManagement.getId());
            log.setCreateBy(SecurityUtils.getUsername());
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("编辑账款分析信息");
            accountLogMapper.insertAccountLog(log);
        }
 
        return result;
    }
 
    /**
     * 修改应收账单管理[批量]
     *
     * @param receivableBillManagements 应收账单管理
     * @return 结果
     */
    @Override
    public int updateReceivableBillManagementBatch(List<ReceivableBillManagement> receivableBillManagements){
        return receivableBillManagementMapper.updateReceivableBillManagementBatch(receivableBillManagements);
    }
 
    /**
     * 删除应收账单管理对象
     *
     * @param ids 需要删除的数据ID
     * @return 结果
     */
    @Override
    public int deleteReceivableBillManagementByIds(String ids)
    {
        return deleteReceivableBillManagementByIds(Convert.toIntArray(ids));
    }
 
    /**
     * 删除应收账单管理对象
     *
     *
     * @param ids 需要删除的数据ID
     * @return 结果
     */
    @Override
    public int deleteReceivableBillManagementByIds(Integer[] ids)
    {
        return receivableBillManagementMapper.deleteReceivableBillManagementByIds(ids);
    }
 
    /**
     * 删除应收账单管理信息
     *
     * @param id 应收账单管理ID
     * @return 结果
     */
    @Override
    public int deleteReceivableBillManagementById(Integer id)
    {
        return receivableBillManagementMapper.deleteReceivableBillManagementById(id);
    }
    
    /**
     * 作废应收账单管理记录
     *
     * @param id 应收账单管理ID
     * @return 结果
     */
    @Override
    public int voidReceivableBillManagement(Integer id) {
        // 1. 查询应收账单记录
        ReceivableBillManagement billManagement = receivableBillManagementMapper.selectReceivableBillManagementById(id);
        if (billManagement == null) {
            throw new ServiceException("应收账单记录不存在");
        }
        
        // 2. 判断状态是否为0(未结算),只有状态为0才能作废
        if (!"0".equals(billManagement.getStatus())) {
            throw new ServiceException("只有状态为未结算的账单才能作废");
        }
        
        // 3. 设置状态为作废
        billManagement.setStatus("2");
        billManagement.setUpdateTime(DateUtils.getNowDate());
        
        // 4. 更新应收账单记录
        int result = receivableBillManagementMapper.updateReceivableBillManagement(billManagement);
        
        // 5. 如果更新成功,清除关联应收费用的账单编号并更新状态
        if (result > 0) {
            // 获取账单系统编号
            String billSystemNo = billManagement.getSystemNo();
            if (billSystemNo != null && !billSystemNo.trim().isEmpty()) {
                // 查询关联该账单的应收费用记录
//                ReceivableFeeManagement queryFee = new ReceivableFeeManagement();
//                queryFee.setRelatedBillNo(billSystemNo);
//                List<ReceivableFeeManagement> feeList = receivableFeeManagementMapper.selectReceivableFeeManagementList(queryFee);
                
                // 清除关联账单编号并将状态改为0(待生成账单)
                receivableFeeManagementMapper.updateReceivableFeeManagementByRelatedBillNo(billSystemNo);
            }
            
            // 记录作废操作日志
            ReceivableBillManagementLog log = new ReceivableBillManagementLog();
            log.setBillId(id);
            try {
                log.setCreateBy(SecurityUtils.getUsername());
            } catch (Exception e) {
                // 远程调用时没有登录信息,使用api作为创建人
                log.setCreateBy("api");
            }
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("作废应收账单,账单编号:" + billManagement.getSystemNo());
            receivableBillManagementLogMapper.insertReceivableBillManagementLog(log);
        }
        
        return result;
    }
    
    /**
     * 根据系统编号查询应收账单管理
     * 
     * @param systemNo 系统编号
     * @return 应收账单管理
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public ReceivableBillManagement selectReceivableBillManagementBySystemNo(String systemNo)
    {
        return receivableBillManagementMapper.selectReceivableBillManagementBySystemNo(systemNo);
    }
    
    /**
     * 查询应收账单客户汇总列表
     *
     * @param receivableBillManagement 查询条件
     * @return 应收账单客户汇总列表
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public List<ReceivableBillCustomerSummary> selectReceivableBillCustomerSummaryList(ReceivableBillManagement receivableBillManagement)
    {
        return receivableBillManagementMapper.selectReceivableBillCustomerSummaryList(receivableBillManagement);
    }
 
    /**
     * 查询应收账单账龄分析列表
     *
     * @param receivableBillManagement 查询条件
     * @return 应收账单账龄分析列表
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public List<ReceivableBillAgingAnalysisVo> selectReceivableBillAgingAnalysisList(ReceivableBillManagement receivableBillManagement)
    {
        // 直接查询数据库中的预计算账龄数据
        List<ReceivableBillAgingAnalysisVo> result = receivableBillManagementMapper.selectReceivableBillAgingAnalysisList(receivableBillManagement);
        
        return result;
    }
 
    /**
     * 批量更新应收账单账龄分析数据
     * 直接在数据库层面计算账龄分段,避免查询大量数据到应用层
     *
     * @return 更新的记录数
     */
    @Override
    public int batchUpdateAgingAnalysisData()
    {
        return receivableBillManagementMapper.batchUpdateAgingAnalysisData();
    }
 
    /**
     * 查询应收账单账款分析列表
     *
     * @param receivableBillManagement 查询条件
     * @return 应收账单账款分析列表
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public List<ReceivableBillAccountAnalysisVo> selectReceivableBillAccountAnalysisList(ReceivableBillManagement receivableBillManagement)
    {
        // 直接查询数据库中的账款分析数据
        List<ReceivableBillAccountAnalysisVo> result = receivableBillManagementMapper.selectReceivableBillAccountAnalysisList(receivableBillManagement);
        
        return result;
    }
}