package com.ld.igds.timer;
|
|
import com.bstek.bdf2.core.model.DefaultCompany;
|
import com.bstek.bdf2.core.model.DefaultDept;
|
import com.ld.igds.common.CoreCommonService;
|
import com.ld.igds.m.dto.AppointParam;
|
import com.ld.igds.m.view.AppointPR;
|
import com.ld.igds.sys.service.SysDeptService;
|
import com.ld.igds.util.DateUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 预约信息定时管理
|
* 1、出入库预约信息
|
* 2、就餐预约信息
|
*
|
* @author: czt
|
* @update-time: 2023-04-13 09:20
|
*/
|
@Slf4j
|
@Component(AppointScheduled.BEAN_ID)
|
public class AppointScheduled {
|
|
public static final String BEAN_ID = "basic.appointScheduled";
|
|
@Resource
|
private CoreCommonService commonService;
|
@Autowired
|
private SysDeptService sysDeptService;
|
@Autowired
|
private AppointPR appointPR;
|
|
/**
|
* 每天晚上11:10分同步第二天的预约信息
|
*/
|
@Scheduled(cron = "0 10 23 * * ?")
|
public void scheduled() {
|
|
log.info("----------系统自动同步预约信息----------");
|
List<DefaultCompany> listCompany = commonService.getCompanyList();
|
if (null == listCompany) {
|
return;
|
}
|
|
List<DefaultDept> list;
|
AppointParam param = new AppointParam();
|
param.setStartTime(new Date());
|
param.setEndTime(DateUtil.getNewByDay(new Date(), 1));
|
for (DefaultCompany company : listCompany) {
|
list = sysDeptService.getCacheDept(company.getId());
|
if(null == list || list.isEmpty()){
|
log.warn("----------未获取到该组织{}下库区信息，预约信息不同步----------", company.getId());
|
continue;
|
}
|
|
//同步出入库预约信息
|
syncInoutAppoint(list, param);
|
//同步就餐预约信息
|
syncEatAppoint(list, param);
|
}
|
|
}
|
|
|
/**
|
* 同步出入库预约信息
|
*/
|
private void syncInoutAppoint(List<DefaultDept> list, AppointParam param) {
|
String s;
|
//遍历获取库区的出入库预约信息
|
for (DefaultDept dept : list) {
|
param.setDeptId(dept.getId());
|
param.setCompanyId(dept.getCompanyId());
|
s = appointPR.syncInout(param);
|
log.warn("----------库区={}出入库预约信息同步结果={}----------", dept.getName(), s);
|
}
|
}
|
|
/**
|
* 同步就餐预约信息
|
*/
|
private void syncEatAppoint(List<DefaultDept> list, AppointParam param) {
|
//遍历获取库区的出入库预约信息
|
for (DefaultDept dept : list) {
|
param.setDeptId(dept.getId());
|
param.setCompanyId(dept.getCompanyId());
|
//TODO 就餐预约同步
|
}
|
}
|
}
|
