package com.ruoyi.system.service.impl;
|
|
import com.aizuda.bpm.engine.entity.FlwHisTask;
|
import com.aizuda.bpm.mybatisplus.mapper.FlwHisTaskMapper;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.ruoyi.common.basic.PageInfo;
|
import com.ruoyi.common.constant.DictConstants;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.enums.ProcessCategoryEnum;
|
import com.ruoyi.common.utils.DictUtils;
|
import com.ruoyi.common.utils.bean.BeanUtils;
|
import com.ruoyi.system.bo.ProcessStartBO;
|
import com.ruoyi.system.dto.SignContractDTO;
|
import com.ruoyi.system.dto.TerminateContractDTO;
|
import com.ruoyi.system.mapper.TBillMapper;
|
import com.ruoyi.system.mapper.TCheckAcceptRecordMapper;
|
import com.ruoyi.system.mapper.TContractMapper;
|
import com.ruoyi.system.mapper.THouseMapper;
|
import com.ruoyi.system.model.*;
|
import com.ruoyi.system.query.TContractAppletQuery;
|
import com.ruoyi.system.query.TContractBillQuery;
|
import com.ruoyi.system.query.TContractQuery;
|
import com.ruoyi.system.service.StateProcessTemplateService;
|
import com.ruoyi.system.service.TBillService;
|
import com.ruoyi.system.service.TContractRentTypeService;
|
import com.ruoyi.system.service.TContractService;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.system.vo.BillVO;
|
import com.ruoyi.system.vo.CheckAcceptRecordVO;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.time.LocalDate;
|
import java.time.LocalDateTime;
|
import java.time.temporal.ChronoUnit;
|
import java.time.temporal.TemporalAdjusters;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 合同管理 服务实现类
|
* </p>
|
*
|
* @author xiaochen
|
* @since 2025-01-17
|
*/
|
@Service
|
public class TContractServiceImpl extends ServiceImpl<TContractMapper, TContract> implements TContractService {
|
@Resource
|
private TCheckAcceptRecordMapper checkAcceptRecordMapper;
|
@Resource
|
private THouseMapper houseMapper;
|
@Resource
|
private TBillMapper billMapper;
|
@Resource
|
private TBillService billService;
|
@Resource
|
private TContractMapper contractMapper;
|
@Autowired
|
private StateProcessTemplateService stateProcessTemplateService;
|
@Autowired
|
private FlwHisTaskMapper flwHisTaskMapper;
|
|
@Override
|
public PageInfo<TContract> contractList(TContractQuery query) {
|
PageInfo<TContract> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
|
List<TContract> list = this.baseMapper.contractList(query,pageInfo);
|
for (TContract tContract : list) {
|
tContract.setPayType(DictUtils.getDictLabel(DictConstants.DICT_TYPE_CONTRACT_PAY_TYPE,tContract.getPayType()));
|
tContract.setStatus(DictUtils.getDictLabel(DictConstants.DICT_TYPE_CONTRACT_STATUS,tContract.getStatus()));
|
}
|
pageInfo.setRecords(list);
|
return pageInfo;
|
|
}
|
|
@Override
|
public PageInfo<TContract> contractAppletList(TContractAppletQuery query) {
|
PageInfo<TContract> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
|
List<TContract> list = this.baseMapper.contractAppletList(query,pageInfo);
|
for (TContract tContract : list) {
|
tContract.setPayType(DictUtils.getDictLabel(DictConstants.DICT_TYPE_CONTRACT_PAY_TYPE,tContract.getPayType()));
|
tContract.setStatus(DictUtils.getDictLabel(DictConstants.DICT_TYPE_CONTRACT_STATUS,tContract.getStatus()));
|
FlwHisTask flwHisTask = flwHisTaskMapper.selectOne(new LambdaQueryWrapper<FlwHisTask>()
|
.like(FlwHisTask::getVariable, tContract.getId())
|
.last("LIMIT 1"));
|
if (Objects.nonNull(flwHisTask)){
|
tContract.setInstanceId(flwHisTask.getInstanceId());
|
}
|
}
|
pageInfo.setRecords(list);
|
return pageInfo;
|
}
|
|
@Override
|
public PageInfo<BillVO> contractBillList(TContractBillQuery query) {
|
PageInfo<BillVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
|
List<BillVO> list = this.baseMapper.contractBillList(query,pageInfo);
|
for (BillVO billVO : list) {
|
if (billVO.getPayFeesStatus().equals("4")){
|
billVO.setPayFeesMoneyString((billVO.getPayFeesMoney().add(billVO.getPayableFeesPenalty()))+"【"+billVO.getPayFeesMoney()+"+"+billVO.getPayableFeesPenalty()+"】");
|
}
|
billVO.setPayFeesStatus(DictUtils.getDictLabel(DictConstants.DICT_TYPE_PAY_FEES_STATUS,billVO.getPayFeesStatus()));
|
}
|
pageInfo.setRecords(list);
|
return pageInfo;
|
}
|
@Override
|
public void terminateContract(TerminateContractDTO dto) {
|
TContract contract = this.baseMapper.selectById(dto.getId());
|
contract.setTerminateRemark(dto.getTerminateRemark());
|
this.baseMapper.updateById(contract);
|
|
// 进入合同提前终止审批流程
|
ProcessStartBO processStartBO = new ProcessStartBO();
|
processStartBO.setCategory(ProcessCategoryEnum.CATEGORY3.getValue().toString());
|
processStartBO.setModuleName("合同提前终止审批");
|
processStartBO.setName(contract.getContractName());
|
processStartBO.setRemark("");
|
Map<String, Object> variable = new HashMap<>();
|
variable.put("projectId", dto.getId());
|
processStartBO.setVariable(variable);
|
//开启工作流程
|
stateProcessTemplateService.start(processStartBO);
|
|
|
}
|
|
public static void main(String[] args) {
|
String t = "1000438";
|
System.err.println("XN" + String.valueOf(t).substring(1));
|
}
|
@Override
|
public CheckAcceptRecordVO getCheckByContractId(String id) {
|
CheckAcceptRecordVO checkAcceptRecordVO = new CheckAcceptRecordVO();
|
TCheckAcceptRecord tCheckAcceptRecord = checkAcceptRecordMapper.selectOne(new LambdaQueryWrapper<TCheckAcceptRecord>()
|
.eq(TCheckAcceptRecord::getContractId, id));
|
if (tCheckAcceptRecord==null)return checkAcceptRecordVO;
|
BeanUtils.copyProperties(tCheckAcceptRecord,checkAcceptRecordVO);
|
THouse tHouse = houseMapper.selectById(tCheckAcceptRecord.getHouseId());
|
tHouse.setLeaseStatus(DictUtils.getDictLabel(DictConstants.DICT_TYPE_LEASE_STATUS,tHouse.getLeaseStatus()));
|
tHouse.setBusinessAttributes(DictUtils.getDictLabel(DictConstants.DICT_TYPE_BUSINESS_ATTRIBUTES,tHouse.getBusinessAttributes()));
|
checkAcceptRecordVO.setHouse(tHouse);
|
return checkAcceptRecordVO;
|
}
|
@Autowired
|
private TContractRentTypeService contractRentTypeService;
|
@Override
|
public R signContract(SignContractDTO dto) {
|
TContract contract = contractMapper.selectById(dto.getId());
|
if (contract==null)return R.fail("合同不存在");
|
if (contract.getStatus().equals("4"))return R.fail("该合同已签订");
|
contract.setSignature(dto.getSignature());
|
contract.setFirstPayTime(contract.getStartTime().plusDays(10));
|
contractMapper.updateById(contract);
|
|
// 进入签订审批流程
|
ProcessStartBO processStartBO = new ProcessStartBO();
|
processStartBO.setCategory(ProcessCategoryEnum.CATEGORY2.getValue().toString());
|
processStartBO.setModuleName("合同签订审批");
|
processStartBO.setName(contract.getContractName());
|
processStartBO.setRemark("");
|
Map<String, Object> variable = new HashMap<>();
|
variable.put("projectId", dto.getId());
|
processStartBO.setVariable(variable);
|
//开启工作流程
|
stateProcessTemplateService.startApplet(processStartBO);
|
|
|
|
return R.ok();
|
}
|
|
@Override
|
public void export(TContractQuery query) {
|
|
}
|
|
@Override
|
public List<TContract> contractExportList(TContractQuery query) {
|
List<TContract> list = this.baseMapper.contractExportList(query);
|
|
return list;
|
}
|
|
@Override
|
public Boolean updateContractAuditStatus(String projectId, Integer status) {
|
LambdaUpdateWrapper<TContract> contractLambdaUpdateWrapper = new LambdaUpdateWrapper<>();
|
contractLambdaUpdateWrapper.eq(TContract::getId, projectId).set(TContract::getStatus, status);
|
return this.update(contractLambdaUpdateWrapper);
|
}
|
}
|
