package org.dromara.eims.job;
|
|
import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
|
import com.aizuda.snailjob.client.job.core.dto.JobArgs;
|
import com.aizuda.snailjob.client.model.ExecuteResult;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import lombok.RequiredArgsConstructor;
|
import lombok.SneakyThrows;
|
import org.dromara.common.core.constant.DictConstants;
|
import org.dromara.common.core.utils.DateUtils;
|
import org.dromara.eims.domain.EimsRepairRes;
|
import org.dromara.eims.domain.EimsRepairFb;
|
import org.dromara.eims.mapper.EimsRepairResMapper;
|
import org.dromara.eims.mapper.EimsRepairFbMapper;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
import java.util.List;
|
|
@Component
|
@RequiredArgsConstructor
|
@JobExecutor(name = "autoApproveRepairJob")
|
public class AutoApproveRepairJob {
|
|
private final EimsRepairResMapper repairResMapper;
|
private final EimsRepairFbMapper repairFbMapper;
|
|
@SneakyThrows
|
@Transactional(rollbackFor = Exception.class)
|
public ExecuteResult jobExecute(JobArgs jobArgs) {
|
// 查询已完成（status等于3）且结束时间超过三天以上的维修单
|
Date threeDaysAgo = DateUtils.addDays(DateUtils.getNowDate(), -3);
|
LambdaQueryWrapper<EimsRepairRes> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(EimsRepairRes::getStatus, DictConstants.REPAIR_RES_STATUS_DETAIL.WANCHENG)
|
.le(EimsRepairRes::getEndTime, threeDaysAgo);
|
|
List<EimsRepairRes> repairOrders = repairResMapper.selectList(queryWrapper);
|
|
for (EimsRepairRes order : repairOrders) {
|
// 检查是否已经存在好评反馈
|
LambdaQueryWrapper<EimsRepairFb> fbQueryWrapper = new LambdaQueryWrapper<>();
|
fbQueryWrapper.eq(EimsRepairFb::getResId, order.getId())
|
.eq(EimsRepairFb::getRepairSatisfaction, 1);
|
Long count = repairFbMapper.selectCount(fbQueryWrapper);
|
|
// 将维修单状态更新为已评价
|
order.setStatus(DictConstants.REPAIR_RES_STATUS_DETAIL.PINGJIA);
|
repairResMapper.updateById(order);
|
|
if (count == 0) {
|
// 插入一条repairSatisfaction为1的反馈数据
|
EimsRepairFb feedback = new EimsRepairFb();
|
feedback.setResId(order.getId());
|
feedback.setRepairSatisfaction("1"); // 默认好评
|
feedback.setRemark("系统自动好评"); // 可以根据需要设置反馈内容
|
feedback.setCreateTime(DateUtils.getNowDate());
|
repairFbMapper.insert(feedback);
|
}
|
}
|
|
return ExecuteResult.success("自动好评维修单任务执行成功");
|
}
|
}
|
