|
|
|
@ -249,8 +249,8 @@ public class TerminalScheduleRuleServiceImpl implements TerminalScheduleRuleServ
|
|
|
|
|
|
|
|
|
|
Map<Integer, Terminals> terminalMap = cacheService.getTerminalMap();
|
|
|
|
|
ArrayList<GetScheduleRequestIdListModel.RequestBean> requestIdList = new ArrayList<>();
|
|
|
|
|
ArrayList<TerminalSchedulesTemp> templist = new ArrayList<>();
|
|
|
|
|
for (int i = 0; i < termlist.size(); i++) {
|
|
|
|
|
ArrayList<TerminalSchedulesTemp> templist = new ArrayList<>();
|
|
|
|
|
String cmdid = null;
|
|
|
|
|
RelateTerminalListRuleIdVo.Items items = termlist.get(i);
|
|
|
|
|
Integer termid = items.getTermid();
|
|
|
|
@ -270,10 +270,6 @@ public class TerminalScheduleRuleServiceImpl implements TerminalScheduleRuleServ
|
|
|
|
|
String timestr = ScheduleListUtils.relateTime(timelist);
|
|
|
|
|
int requestId = Constants.REQUEST_ID.addAndGet(1);
|
|
|
|
|
|
|
|
|
|
String cmd = CmaUtil.relateSchelduleRule(timelist, cmdid, requestId, channelid, timestr);
|
|
|
|
|
ProcessExecUtils.exec(cmd);
|
|
|
|
|
log.info("cma下发时间表命令", cmd);
|
|
|
|
|
|
|
|
|
|
GetScheduleRequestIdListModel.RequestBean requestBean = new GetScheduleRequestIdListModel.RequestBean();
|
|
|
|
|
requestBean.setTermid(termid);
|
|
|
|
|
requestBean.setChannelid(channelid);
|
|
|
|
@ -295,11 +291,14 @@ public class TerminalScheduleRuleServiceImpl implements TerminalScheduleRuleServ
|
|
|
|
|
temp.setOffset(offset);
|
|
|
|
|
templist.add(temp);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (CollectionUtil.isNotEmpty(templist)) {
|
|
|
|
|
terminalSchedulesTempDao.deleteByTermidAndChannelid(templist);
|
|
|
|
|
Date date = new Date();
|
|
|
|
|
terminalSchedulesTempDao.insertList(templist, CommonStatus.DELETE.value(), date, date);
|
|
|
|
|
if (CollectionUtil.isNotEmpty(templist)) {
|
|
|
|
|
terminalSchedulesTempDao.deleteByTermidAndChannelid(templist);
|
|
|
|
|
Date date = new Date();
|
|
|
|
|
terminalSchedulesTempDao.insertList(templist, CommonStatus.DELETE.value(), date, date);
|
|
|
|
|
String cmd = CmaUtil.relateSchelduleRule(timelist, cmdid, requestId, channelid, timestr);
|
|
|
|
|
ProcessExecUtils.exec(cmd);
|
|
|
|
|
log.info("cma下发时间表命令", cmd);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
model.setList(requestIdList);
|
|
|
|
|
return Asserts.success(model);
|
|
|
|
|