清空配置并失效所有定时任务
This commit is contained in:
@@ -79,4 +79,8 @@ public interface SchedulerDao extends CrudDao<ScheduleCfg> {
|
|||||||
*/
|
*/
|
||||||
int updateScheduleExceNew(ScheduleExceInfo exceInfo);
|
int updateScheduleExceNew(ScheduleExceInfo exceInfo);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 失效所有定时任务
|
||||||
|
*/
|
||||||
|
void inValidAllSchedule();
|
||||||
}
|
}
|
||||||
@@ -364,6 +364,12 @@
|
|||||||
compile_Id = #{compileId} and issue_status = #{issueStatus}
|
compile_Id = #{compileId} and issue_status = #{issueStatus}
|
||||||
</update>
|
</update>
|
||||||
|
|
||||||
|
<update id="inValidAllSchedule">
|
||||||
|
update schedule_cfg
|
||||||
|
<set>
|
||||||
|
del_flag = 0
|
||||||
|
</set>
|
||||||
|
WHERE del_flag =1
|
||||||
|
</update>
|
||||||
|
|
||||||
</mapper>
|
</mapper>
|
||||||
@@ -35,6 +35,7 @@ import com.nis.util.IpUtil;
|
|||||||
import com.nis.util.ServiceConfigTemplateUtil;
|
import com.nis.util.ServiceConfigTemplateUtil;
|
||||||
import com.nis.util.TimeConstants;
|
import com.nis.util.TimeConstants;
|
||||||
import com.nis.util.httpclient.ClientUtil;
|
import com.nis.util.httpclient.ClientUtil;
|
||||||
|
import com.nis.web.dao.SchedulerDao;
|
||||||
import com.nis.web.dao.SrcIpDao;
|
import com.nis.web.dao.SrcIpDao;
|
||||||
import com.nis.web.dao.SysOfficeDao;
|
import com.nis.web.dao.SysOfficeDao;
|
||||||
import com.nis.web.dao.UserDao;
|
import com.nis.web.dao.UserDao;
|
||||||
@@ -63,6 +64,9 @@ public class SystemService extends BaseService{
|
|||||||
@Autowired
|
@Autowired
|
||||||
private CommonPolicyDao commonPolicyDao;
|
private CommonPolicyDao commonPolicyDao;
|
||||||
|
|
||||||
|
@Autowired
|
||||||
|
private SchedulerDao schedulerDao;
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private SrcIpDao srcIpDao;
|
private SrcIpDao srcIpDao;
|
||||||
private RedisSerializer keySerializer = new StringSerializer();
|
private RedisSerializer keySerializer = new StringSerializer();
|
||||||
@@ -196,6 +200,8 @@ public class SystemService extends BaseService{
|
|||||||
}
|
}
|
||||||
// 初始化分组
|
// 初始化分组
|
||||||
asnGroupInfoService.reLoadGroupInfo();
|
asnGroupInfoService.reLoadGroupInfo();
|
||||||
|
// 失效定时任务
|
||||||
|
schedulerDao.inValidAllSchedule();
|
||||||
}else {
|
}else {
|
||||||
throw new RuntimeException();
|
throw new RuntimeException();
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user