| 
					
				 | 
			
			
				@ -4,6 +4,7 @@ import com.fasterxml.jackson.databind.ObjectMapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.fasterxml.jackson.databind.node.ArrayNode; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.common.Services; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.core.datatype.CollectionUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.core.datatype.StringUtil; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.datacollect.model.RsJobConfig; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.datacollect.service.DatacollectManager; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.resource.service.StdService; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -14,6 +15,9 @@ import com.yihu.hos.web.framework.model.ActionResult; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.web.framework.model.Result; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import com.yihu.hos.web.framework.util.controller.BaseController; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.apache.commons.beanutils.BeanUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.joda.time.DateTime; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.joda.time.format.DateTimeFormat; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.joda.time.format.DateTimeFormatter; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.springframework.beans.factory.annotation.Autowired; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.springframework.stereotype.Controller; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				import org.springframework.ui.Model; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -80,7 +84,7 @@ public class DataCollectController extends BaseController { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            //获取方案列表 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            List data = stdService.getSchemeVersion(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String jsonlist = objectMapper.writeValueAsString(data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            ArrayNode jsonArray = objectMapper.readValue(jsonlist,ArrayNode.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            ArrayNode jsonArray = objectMapper.readValue(jsonlist, ArrayNode.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            model.addAttribute("schemeList", "{\"detailModelList\":" + (CollectionUtil.isEmpty(data) ? "[]" : jsonArray) + "}"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            model.addAttribute("contentPage", "/datacollect/editorJob"); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -108,16 +112,15 @@ public class DataCollectController extends BaseController { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    @RequestMapping("compareServeTime") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    @ResponseBody 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    public Result getJob(String time){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    public Result getJob(String time) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        try { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if(df.parse(time).before(new Date())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if (df.parse(time).before(new Date())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                return Result.success("beforeServeTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            else 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } else 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                return Result.error("afterServeTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        }catch (Exception ex){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        } catch (Exception ex) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            return Result.error(ex.getMessage()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				    } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -161,9 +164,9 @@ public class DataCollectController extends BaseController { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            BeanUtils.populate(obj, request.getParameterMap()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            obj.setValid("1"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            obj.setJobCron(cron); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String time=request.getParameter("jobNextTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String time = request.getParameter("jobNextTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if(df.parse(time).before(new Date())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if (df.parse(time).before(new Date())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                return Result.error("任务开始时间不能小于当前时间"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@ -188,12 +191,26 @@ public class DataCollectController extends BaseController { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            obj.setJobCron(cron); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				//            ConvertUtils.register(new DateLocaleConverter(), Date.class); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            BeanUtils.populate(obj, request.getParameterMap()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String time=request.getParameter("jobNextTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String time = request.getParameter("jobNextTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if(df.parse(time).before(new Date())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if (df.parse(time).before(new Date())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                return Result.error("任务开始时间不能小于当前时间"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String delayTime = request.getParameter("delayTime");//延迟时间 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String startTime = request.getParameter("repeatStartTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            String endTime = request.getParameter("repeatEndTime"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            DateTimeFormatter dateTimeFormat = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if (StringUtil.isBlank(endTime)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                endTime = DateTime.now().toString(dateTimeFormat); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            DateTime beginDate = DateTime.parse(startTime, dateTimeFormat); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            DateTime endDate = DateTime.parse(endTime, dateTimeFormat); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            beginDate = beginDate.plusDays(Integer.valueOf(delayTime));//开始时间+延迟时间 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            if (beginDate.isAfter(endDate)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                return Result.error("任务开始时间加延迟时间不能大于结束时间"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            return datacollect.updateJob(obj, cron, jobDataset); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        } catch (Exception ex) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            ex.printStackTrace(); 
			 |