package com.ruoyi.tms.service.impl;
|
|
import java.util.List;
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.ruoyi.common.utils.DateUtils;
|
import javax.annotation.Resource;
|
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.tms.domain.TmsArBill;
|
import com.ruoyi.tms.mapper.TmsArBillMapper;
|
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.tms.mapper.TmsArSettlementMapper;
|
import com.ruoyi.tms.domain.TmsArSettlement;
|
import com.ruoyi.tms.service.ITmsArSettlementService;
|
import com.ruoyi.common.core.text.Convert;
|
|
/**
|
* 结算单Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2025-12-13
|
*/
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class TmsArSettlementServiceImpl extends BaseService<TmsArSettlementMapper, TmsArSettlement> implements ITmsArSettlementService
|
{
|
protected final Logger logger = LoggerFactory.getLogger(getClass());
|
@Resource
|
private TmsArSettlementMapper tmsArSettlementMapper;
|
|
@Resource
|
private TmsArBillMapper tmsArBillMapper;
|
|
/**
|
* 查询结算单
|
*
|
* @param id 结算单ID
|
* @return 结算单
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public TmsArSettlement selectTmsArSettlementById(Integer id)
|
{
|
return tmsArSettlementMapper.selectTmsArSettlementById(id);
|
}
|
|
/**
|
* 查询结算单 记录数
|
*
|
* @param tmsArSettlement 结算单
|
* @return 结算单集合
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public int selectTmsArSettlementCount(TmsArSettlement tmsArSettlement)
|
{
|
return tmsArSettlementMapper.selectTmsArSettlementCount(tmsArSettlement);
|
}
|
|
/**
|
* 查询结算单列表
|
*
|
* @param tmsArSettlement 结算单
|
* @return 结算单
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public List<TmsArSettlement> selectTmsArSettlementList(TmsArSettlement tmsArSettlement)
|
{
|
return tmsArSettlementMapper.selectTmsArSettlementList(tmsArSettlement);
|
}
|
|
/**
|
* 查询结算单列表 异步 导出
|
*
|
* @param tmsArSettlement 结算单
|
* @param exportKey 导出功能的唯一标识
|
* @return 结算单集合
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Async
|
@Override
|
public void export(TmsArSettlement tmsArSettlement,String exportKey) {
|
|
super.export(TmsArSettlement.class,exportKey,"tmsArSettlementData",(pageNum)->{
|
PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
|
return selectTmsArSettlementList(tmsArSettlement);
|
});
|
}
|
|
|
/**
|
* 新增结算单
|
*
|
* @param tmsArSettlement 结算单
|
* @return 结果
|
*/
|
@Override
|
public int insertTmsArSettlement(TmsArSettlement tmsArSettlement)
|
{
|
tmsArSettlement.setCreateTime(DateUtils.getNowDate());
|
tmsArSettlement.setCreateBy(SecurityUtils.getUsername());
|
|
|
tmsArBillMapper.update(null,
|
new LambdaUpdateWrapper<TmsArBill>()
|
.setSql("settled_amount = settled_amount + " + tmsArSettlement.getSettleAmount())
|
.setSql(
|
"status = CASE " +
|
"WHEN settled_amount + " + tmsArSettlement.getSettleAmount() + " >= settle_amount THEN 2 " +
|
"ELSE 1 END"
|
)
|
.eq(TmsArBill::getId, tmsArSettlement.getBillId())
|
);
|
|
return tmsArSettlementMapper.insertTmsArSettlement(tmsArSettlement);
|
}
|
|
/**
|
* 新增结算单[批量]
|
*
|
* @param tmsArSettlements 结算单
|
* @return 结果
|
*/
|
@Override
|
public int insertTmsArSettlementBatch(List<TmsArSettlement> tmsArSettlements)
|
{
|
int rows = tmsArSettlementMapper.insertTmsArSettlementBatch(tmsArSettlements);
|
return rows;
|
}
|
|
/**
|
* 修改结算单
|
*
|
* @param tmsArSettlement 结算单
|
* @return 结果
|
*/
|
@Override
|
public int updateTmsArSettlement(TmsArSettlement tmsArSettlement)
|
{
|
tmsArSettlement.setUpdateTime(DateUtils.getNowDate());
|
return tmsArSettlementMapper.updateTmsArSettlement(tmsArSettlement);
|
}
|
|
/**
|
* 修改结算单[批量]
|
*
|
* @param tmsArSettlements 结算单
|
* @return 结果
|
*/
|
@Override
|
public int updateTmsArSettlementBatch(List<TmsArSettlement> tmsArSettlements){
|
return tmsArSettlementMapper.updateTmsArSettlementBatch(tmsArSettlements);
|
}
|
|
/**
|
* 删除结算单对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteTmsArSettlementByIds(String ids)
|
{
|
return deleteTmsArSettlementByIds(Convert.toIntArray(ids));
|
}
|
|
/**
|
* 删除结算单对象
|
*
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteTmsArSettlementByIds(Integer[] ids)
|
{
|
return tmsArSettlementMapper.deleteTmsArSettlementByIds(ids);
|
}
|
|
/**
|
* 删除结算单信息
|
*
|
* @param id 结算单ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteTmsArSettlementById(Integer id)
|
{
|
return tmsArSettlementMapper.deleteTmsArSettlementById(id);
|
}
|
}
|
