package com.ltkj.web.config.timer;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.ltkj.common.core.domain.entity.SysUser;
|
import com.ltkj.common.core.redis.RedisCache;
|
import com.ltkj.common.utils.SecurityUtils;
|
import com.ltkj.framework.config.UserHoder;
|
import com.ltkj.hosp.domain.*;
|
import com.ltkj.hosp.service.*;
|
import com.ltkj.system.domain.SysPost;
|
import com.ltkj.system.domain.SysUserPost;
|
import com.ltkj.system.service.ISysPostService;
|
import com.ltkj.system.service.ISysUserPostService;
|
import com.ltkj.system.service.ISysUserService;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Company: 西安路泰科技有限公司
|
* @Author: zjh
|
* @Date: 2023/3/22 11:48
|
*/
|
@Service
|
public class updateTjFinshTimeService {
|
@Resource
|
private ITjOrderService orderService;
|
@Resource
|
private ITjOrderDetailService tjOrderDetailService;
|
//定时器每分钟查询一次,所有项目完成后修改完成时间
|
void updateTjFinshTime(){
|
LambdaQueryWrapper<TjOrder> wq0 = new LambdaQueryWrapper<>();
|
wq0.eq(TjOrder::getCheckStatus,0);
|
wq0.isNull(TjOrder::getFinishTime);
|
List<TjOrder> orderList = orderService.list(wq0);
|
if(null !=orderList && orderList.size()>0){
|
for (TjOrder order : orderList) {
|
LambdaQueryWrapper<TjOrderDetail>wq=new LambdaQueryWrapper<>();
|
wq.eq(TjOrderDetail::getOrderId,order.getOrderId());
|
List<TjOrderDetail> detailList = tjOrderDetailService.list(wq);
|
LambdaQueryWrapper<TjOrderDetail>wq1=new LambdaQueryWrapper<>();
|
wq1.eq(TjOrderDetail::getOrderId,order.getOrderId());
|
wq1.eq(TjOrderDetail::getTjStatus,1);
|
List<TjOrderDetail> detais = tjOrderDetailService.list(wq1);
|
if(null !=detailList && detailList.size()>0 && null !=detais && detais.size()>0 && detais.size()==detailList.size()){
|
order.setFinishTime(new Date());
|
orderService.updateById(order);
|
}
|
}
|
}
|
}
|
}
|
