| | |
| | | */ |
| | | @Transactional |
| | | public String addWarning(FieldSetEntity fse) throws BaseException, SchedulerException, TaskException { |
| | | fse.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id()); |
| | | fse.setValue(CmnConst.CREATED_UTC_DATETIME, new Date()); |
| | | if (fse.getString("type").equals("0")){ |
| | | FieldSetEntity fseJob = new FieldSetEntity(); |
| | | fseJob.setTableName("product_sys_timed_task"); |
| | | fseJob.setValue("concurrent", 1); |
| | |
| | | sysJobService.insertJob(fseJob); |
| | | |
| | | fse.setValue("time_task_uuid", fseJob.getUUID()); |
| | | fse.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id()); |
| | | fse.setValue(CmnConst.CREATED_UTC_DATETIME, new Date()); |
| | | |
| | | String uuid = baseDao.add(fse); |
| | | |
| | | fseJob.setValue("invoke_target", "warnTask.triggerSingleWarningTask('" + fse.getUUID() + "')"); |
| | | sysJobService.updateJob(fseJob); |
| | | |
| | | return uuid; |
| | | }else { |
| | | return baseDao.add(fse); |
| | | |
| | | } |
| | | } |
| | | |
| | | /** |