package com.ld.igds.timer.service;
|
|
import java.util.*;
|
|
import com.ld.igds.models.Device;
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.apache.commons.lang.StringUtils;
|
import org.hibernate.Session;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Repository;
|
import org.springframework.util.Assert;
|
|
import com.bstek.bdf2.core.orm.hibernate.HibernateDao;
|
import com.bstek.bdf2.job.model.JobCalendarRelation;
|
import com.bstek.bdf2.job.model.JobDefinition;
|
import com.bstek.bdf2.job.model.JobHistory;
|
import com.bstek.bdf2.job.model.JobParameter;
|
import com.bstek.bdf2.job.model.JobState;
|
import com.ld.igds.constant.BizType;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.models.Timing;
|
import com.ld.igds.models.TimingDepot;
|
import com.ld.igds.models.TimingDevice;
|
import com.ld.igds.timer.BdfJobService;
|
import com.ld.igds.timer.service.ITimerService;
|
import com.ld.igds.util.ContextUtil;
|
|
@Slf4j
|
@Repository(ITimerService.BEAN_ID)
|
public class TimperServiceImpl extends HibernateDao implements ITimerService {
|
|
@Autowired
|
private BdfJobService bdfJobService;
|
|
@Override
|
public List<Timing> getTiming(Map<String, Object> param) throws Exception {
|
StringBuilder hql = new StringBuilder();
|
hql.append(" from " + Timing.class.getName()
|
+ " where companyId = :companyId ");
|
Map<String, Object> arg = new HashMap<String, Object>();
|
if (null != param) {
|
bulidHql(hql, param, arg);
|
}
|
arg.put("companyId", ContextUtil.getCompanyId());
|
|
hql.append(" order by updateTime ");
|
|
List<Timing> list = this.query(hql.toString(), arg);
|
|
if (null == list || list.isEmpty())
|
return list;
|
|
// 添加job信息
|
for (Timing tim : list) {
|
tim.setJob(bdfJobService.getJobById(tim.getId()));
|
}
|
|
return list;
|
}
|
|
@Override
|
public List<TimingDevice> getDevieByTimerId(String timId) {
|
if (StringUtils.isEmpty(timId))
|
return null;
|
|
Map<String, Object> p = new HashMap<String, Object>();
|
String hql = " from "
|
+ TimingDevice.class.getName()
|
+ " where companyId = :companyId and timId =:timId order by depotId";
|
p.put("companyId", ContextUtil.getCompanyId());
|
p.put("timId", timId);
|
|
return this.query(hql, p);
|
}
|
|
private void bulidHql(StringBuilder hql, Map<String, Object> param,
|
Map<String, Object> arg) {
|
String depotId = (String) param.get("depotId");
|
if (StringUtils.isNotBlank(depotId)) {
|
hql.append(" and depotId = :depotId ");
|
arg.put("depotId", depotId);
|
}
|
|
String type = (String) param.get("type");
|
if (StringUtils.isNotBlank(type)) {
|
hql.append(" and type = :type ");
|
arg.put("type", type);
|
}
|
|
}
|
|
@Override
|
public void addTimer(Timing tim) throws Exception {
|
Session session = this.getSessionFactory().openSession();
|
try {
|
//更新定时规则
|
String cron = Constant.CRON_DAY;
|
if (tim.getTimType().equals(Constant.TIM_TYPE_DAY)) {
|
cron = cron.replace("H", tim.getHour() + "");
|
cron = cron.replace("M", tim.getMinute() + "");
|
}
|
|
if (tim.getTimType().equals(Constant.TIM_TYPE_WEEK)) {
|
cron = Constant.CRON_WEEK;
|
cron = cron.replace("H", tim.getHour() + "");
|
cron = cron.replace("M", tim.getMinute() + "");
|
cron = cron.replace("W", tim.getWeek());
|
}
|
|
if (tim.getTimType().equals(Constant.TIM_TYPE_HOUR)) {
|
cron = Constant.CRON_HOUR;
|
Calendar cal = Calendar.getInstance();
|
cal.setTime(tim.getAppointTime());
|
cron = cron.replace("S", cal.get(Calendar.SECOND) + "");
|
cron = cron.replace("M", cal.get(Calendar.MINUTE) + "");
|
cron = cron.replace("H", cal.get(Calendar.HOUR) + "");
|
cron = cron.replace("D", cal.get(Calendar.DATE) + "");
|
cron = cron.replace("&", cal.get(Calendar.MONTH) + 1 + "");
|
}
|
tim.setCron(cron);
|
|
tim.setUpdateTime(new Date());
|
tim.setUpdateUser(ContextUtil.getLoginUserCName());
|
|
// 新增数据
|
if (null == tim.getId()) {
|
tim.setId(ContextUtil.getCurTimeMillis());
|
tim.setCompanyId(ContextUtil.getCompanyId());
|
//新增job
|
tim.setJob(this.saveJob(tim, true));
|
session.save(tim);
|
log.info("==========" + tim.getUpdateUser() + "添加仓库定时配置……" + "==========");
|
} else { //更新数据
|
//更新job
|
tim.setJob(this.saveJob(tim, false));
|
session.update(tim);
|
log.info("==========" + tim.getUpdateUser() + "更新仓库定时配置……" + "==========");
|
}
|
|
this.updateTimDevice(tim, session);
|
|
} finally {
|
session.flush();
|
session.close();
|
}
|
}
|
|
// 处理定时任务中的设备信息
|
private void updateTimDevice(Timing tim, Session session) {
|
if (null == tim.getDevices())
|
return;
|
// 删除现有的设备信息
|
String hql = " delete " + TimingDevice.class.getName()
|
+ " where timId=:timId";
|
session.createQuery(hql).setString("timId", tim.getId())
|
.executeUpdate();
|
|
for (TimingDevice device : tim.getDevices()) {
|
device.setId(ContextUtil.getUUID());
|
device.setTimId(tim.getId());
|
device.setCompanyId(tim.getCompanyId());
|
device.setDepotId(tim.getDepotId());
|
session.save(device);
|
}
|
}
|
|
private JobDefinition saveJob(Timing tim, boolean flag) throws Exception {
|
String type = tim.getType();
|
if (StringUtils.isEmpty(type)) {
|
throw new Exception("没有获获取到检测类型，请重新刷新页面添加……");
|
}
|
JobDefinition job = new JobDefinition();
|
job.setId(tim.getId());
|
job.setCompanyId(tim.getCompanyId());
|
job.setCronExpression(tim.getCron());
|
job.setState(JobState.ready);
|
job.setDesc("业务人员配置，请勿操作！");
|
|
if (type.equals(BizType.GRAIN.getCode())) {
|
job.setBeanId(Constant.JOB_BEAN_GRAIN);
|
job.setName(tim.getName() + "-粮情定时检测");
|
}
|
|
if (type.equals(BizType.GAS.getCode())) {
|
job.setBeanId(Constant.JOB_BEAN_GAS);
|
job.setName(tim.getName() + "-气体定时检测");
|
}
|
|
if (type.equals(BizType.PEST.getCode())) {
|
job.setBeanId(Constant.JOB_BEAN_PEST);
|
job.setName(tim.getName() + "-虫害定时检测");
|
}
|
|
if ("lamp".equals(type)) {
|
job.setBeanId(Constant.JOB_BEAN_LAMP);
|
job.setName(tim.getName() + "-照明定时控制");
|
}
|
|
if(flag){ //新增
|
bdfJobService.saveJob(job);
|
}else { //更新
|
bdfJobService.updateJob(job);
|
}
|
return job;
|
}
|
|
@Override
|
public void delTimer(String id) {
|
Assert.notNull(id, "定时配置ID为空");
|
Session session = this.getSessionFactory().openSession();
|
try {
|
String hql = " delete " + Timing.class.getName() + " where id=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
hql = "delete " + JobDefinition.class.getName() + " where id=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
hql = "delete " + JobHistory.class.getName() + " where jobId=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
hql = "delete " + JobCalendarRelation.class.getName()
|
+ " where jobId=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
hql = "delete " + JobParameter.class.getName() + " where jobId=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
hql = " delete " + TimingDevice.class.getName()
|
+ " where timId=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
hql = " delete " + TimingDepot.class.getName() + " where timId=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
|
} finally {
|
session.flush();
|
session.close();
|
}
|
}
|
|
@Override
|
public List<TimingDepot> getDepotByTimerId(String timId) {
|
if (null == timId)
|
return null;
|
String hql = " from " + TimingDepot.class.getName()
|
+ " where timId = :timId";
|
Map<String, Object> args = new HashMap<String, Object>();
|
args.put("timId", timId);
|
return this.query(hql, args);
|
}
|
|
@Override
|
public void saveDepot(List<TimingDepot> items) {
|
if (null == items)
|
return;
|
Session session = this.getSessionFactory().openSession();
|
try {
|
for (TimingDepot item : items) {
|
if (null == item.getId()) {
|
item.setId(ContextUtil.getUUID());
|
session.save(item);
|
} else {
|
session.update(item);
|
}
|
}
|
} finally {
|
session.flush();
|
session.close();
|
}
|
}
|
|
@Override
|
public String delDepotById(String id) {
|
if (null == id)
|
return "没有获取到ID无法删除";
|
Session session = this.getSessionFactory().openSession();
|
try {
|
String hql = " delete " + TimingDepot.class.getName()
|
+ " where id=:id";
|
session.createQuery(hql).setString("id", id).executeUpdate();
|
} finally {
|
session.flush();
|
session.close();
|
}
|
return null;
|
}
|
|
@Override
|
public void delDeviceByTimerId(String timId, String depotId) {
|
Session session = null;
|
try {
|
session = this.getSessionFactory().openSession();
|
String hql = " delete from " + TimingDevice.class.getName()
|
+ " where timId=:timId and depotId=:depotId ";
|
session.createQuery(hql).setString("timId", timId)
|
.setString("depotId", depotId).executeUpdate();
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
session.flush();
|
session.close();
|
}
|
|
}
|
|
@Override
|
public void addTimingDevice(TimingDevice timingDevice) {
|
Session session = null;
|
try {
|
session = this.getSessionFactory().openSession();
|
session.save(timingDevice);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
session.flush();
|
session.close();
|
}
|
|
}
|
@Override
|
public String delSettings(List<TimingDevice> list) {
|
for (TimingDevice device : list) {
|
Session session = null;
|
try {
|
session = this.getSessionFactory().openSession();
|
session.delete(device);
|
} catch (Exception e) {
|
e.printStackTrace();
|
} finally {
|
session.flush();
|
session.close();
|
}
|
}
|
return null;
|
}
|
@Override
|
public String addSettings(List<Device> list, String timId) {
|
List<TimingDevice> timingDevices = new ArrayList<>();
|
String depotId = list.get(0).getDepotId();
|
// 首先过滤掉未操作数据
|
/*
|
* for (Device device : list) {
|
* if(device.getTargetStatus().equals("ZERO")){ list.remove(device); } }
|
*/
|
for (int i = 0; i < list.size(); i++) {
|
if (list.get(i).getTargetStatus() == null || list.get(i).getTargetStatus().equals("ZERO") || list.get(i).getTargetStatus().equals("")) {
|
//list.remove(list.get(i));
|
} else {
|
TimingDevice timingDevice = new TimingDevice();
|
timingDevice.setId(UUID.randomUUID().toString());
|
timingDevice.setDepotId(list.get(i).getDepotId());
|
timingDevice.setDeviceId(list.get(i).getId());
|
timingDevice.setTimId(timId);
|
timingDevice.setCompanyId(ContextUtil.getCompanyId());
|
timingDevice.setTargetStatus(list.get(i).getTargetStatus());
|
timingDevices.add(timingDevice);
|
}
|
}
|
//System.out.println(timingDevices.toString());
|
|
// 其次新增配置
|
for (TimingDevice timingDevice : timingDevices) {
|
//先删除已经有的，避免重复
|
delDeviceByTimerId(timId,timingDevice.getDeviceId());
|
addTimingDevice(timingDevice);
|
}
|
return null;
|
}
|
}
|
