Examples of ProcessResult

com.serotonin.m2m2.i18n.ProcessResult
@author Matthew Lohbihler
cu.shell.ProcessResult
@author Markus Jevring @since 2007-dec-06 : 22:37:45 @version $Id: ProcessResult.java 258 2008-10-26 12:47:23Z jevring $
org.apache.commons.scaffold.util.ProcessResult
org.archive.modules.ProcessResult
Returned by a Processor's process method to indicate the status of the process. @contributor pjack
org.arquillian.spacelift.process.ProcessResult
An abstraction for process execution result. Allows to get process output and exit value @author Karel Piwko
org.zeroturnaround.exec.ProcessResult
Exit value and output of a finished process. @author Rein Raudjärv @see ProcessExecutor

Examples of com.serotonin.m2m2.i18n.ProcessResult

            int fromMonth, int fromDay, int fromHour, int fromMinute, boolean toNone, int toYear, int toMonth,
            int toDay, int toHour, int toMinute, boolean schedule, int schedulePeriod, int runDelayMinutes,
            String scheduleCron, boolean email, boolean includeData, boolean zipData,
            List<RecipientListEntryBean> recipients) {


        ProcessResult response = new ProcessResult();


        // Basic validation
        validateData(response, name, points, dateRangeType, relativeDateType, previousPeriodCount, pastPeriodCount);


        if (schedule) {
            if (schedulePeriod == ReportVO.SCHEDULE_CRON) {
                // Check the cron pattern.
                try {
                    new CronTimerTrigger(scheduleCron);
                }
                catch (Exception e) {
                    response.addContextualMessage("scheduleCron", "reports.validate.cron", e.getMessage());
                }
            }
            else {
                if (runDelayMinutes < 0)
                    response.addContextualMessage("runDelayMinutes", "reports.validate.lessThan0");
                else if (runDelayMinutes > 59)
                    response.addContextualMessage("runDelayMinutes", "reports.validate.greaterThan59");
            }
        }


        if (schedule && email && recipients.isEmpty())
            response.addContextualMessage("recipients", "reports.validate.needRecip");


        if (response.getHasMessages())
            return response;


        User user = Common.getUser();
        ReportDao reportDao = new ReportDao();
        ReportVO report;
        if (id == Common.NEW_ID) {
            report = new ReportVO();
            report.setUserId(user.getId());
        }
        else
            report = reportDao.getReport(id);
        
        ReportCommon.ensureReportPermission(user, report);


        // Update the new values.
        report.setXid(xid);
        report.setName(name);
        report.setPoints(points);
        report.setTemplate(template);
        report.setIncludeEvents(includeEvents);
        report.setIncludeUserComments(includeUserComments);
        report.setDateRangeType(dateRangeType);
        report.setRelativeDateType(relativeDateType);
        report.setPreviousPeriodCount(previousPeriodCount);
        report.setPreviousPeriodType(previousPeriodType);
        report.setPastPeriodCount(pastPeriodCount);
        report.setPastPeriodType(pastPeriodType);
        report.setFromNone(fromNone);
        report.setFromYear(fromYear);
        report.setFromMonth(fromMonth);
        report.setFromDay(fromDay);
        report.setFromHour(fromHour);
        report.setFromMinute(fromMinute);
        report.setToNone(toNone);
        report.setToYear(toYear);
        report.setToMonth(toMonth);
        report.setToDay(toDay);
        report.setToHour(toHour);
        report.setToMinute(toMinute);
        report.setSchedule(schedule);
        report.setSchedulePeriod(schedulePeriod);
        report.setRunDelayMinutes(runDelayMinutes);
        report.setScheduleCron(scheduleCron);
        report.setEmail(email);
        report.setIncludeData(includeData);
        report.setZipData(zipData);
        report.setRecipients(recipients);


        // Save the report
        reportDao.saveReport(report);


        // Conditionally schedule the report.
        ReportJob.scheduleReportJob(report);


        // Send back the report id in case this was new.
        response.addData("reportId", report.getId());
        response.addData("report", report);
        return response;
    }

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

            boolean includeUserComments, int dateRangeType, int relativeDateType, int previousPeriodCount,
            int previousPeriodType, int pastPeriodCount, int pastPeriodType, boolean fromNone, int fromYear,
            int fromMonth, int fromDay, int fromHour, int fromMinute, boolean toNone, int toYear, int toMonth,
            int toDay, int toHour, int toMinute, boolean email, boolean includeData, boolean zipData,
            List<RecipientListEntryBean> recipients) {
        ProcessResult response = new ProcessResult();


        // Basic validation
        //TODO Replace with vo.validate()
        validateData(response, name, points, dateRangeType, relativeDateType, previousPeriodCount, pastPeriodCount);


        if (!response.getHasMessages()) {
            ReportVO report = new ReportVO();
            report.setXid(xid);
            report.setName(name);
            report.setUserId(Common.getUser().getId());
            report.setPoints(points);

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

        return StringEscapeUtils.escapeJava(ds.getMessageTerminator());
      }
      
      @DwrPermission(user = true)
      public ProcessResult testString(String raw) {
        ProcessResult pr = new ProcessResult();
        String msg = StringEscapeUtils.unescapeJava(raw);
        SerialDataSourceVO ds = (SerialDataSourceVO) Common.getUser().getEditDataSource();
        if(ds.getId() == -1) {
          pr.addContextualMessage("testString", "serial.test.needsSave");
          return pr;
        }
        DataPointDao dpd = new DataPointDao();
        List<DataPointVO> points = dpd.getDataPoints(ds.getId(), null);
        if(ds.getUseTerminator()) { 
          if(msg.indexOf(ds.getMessageTerminator()) != -1) {
            msg = msg.substring(0, msg.indexOf(ds.getMessageTerminator())+1);
            Pattern p = Pattern.compile(ds.getMessageRegex());
            Matcher m = p.matcher(msg);
            if(!m.matches()) {
              pr.addContextualMessage("testString", "serial.test.noMessageMatch");
              return pr;
            }
            String identifier = m.group(ds.getPointIdentifierIndex());
            for(DataPointVO pnt : points) {
              SerialPointLocatorVO plVo = (SerialPointLocatorVO) pnt.getPointLocator();
              if(identifier.equals(plVo.getPointIdentifier())) {
                Pattern v = Pattern.compile(plVo.getValueRegex());
                Matcher vm = v.matcher(msg);
                if(vm.find())
                  pr.addContextualMessage("testString", "serial.test.consumed", pnt.getName(), vm.group(0));
              }
                
            }
          }
          else {
            pr.addContextualMessage("testString", "serial.test.noTerminator");
            return pr;
          }
        }
        else {
          for(DataPointVO pnt : points) {
            SerialPointLocatorVO plVo = (SerialPointLocatorVO) pnt.getPointLocator();
            Pattern p = Pattern.compile(plVo.getValueRegex());
            Matcher m = p.matcher(msg); 
            if(m.find())
              pr.addContextualMessage("testString", "serial.test.consumed", pnt.getName(), m.group(0));          
          }
        }
        return pr;
      }

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

        se.setInactiveHour(inactiveHour);
        se.setInactiveMinute(inactiveMinute);
        se.setInactiveSecond(inactiveSecond);
        se.setInactiveCron(inactiveCron);


        ProcessResult response = new ProcessResult();
        ScheduledEventDao scheduledEventDao = new ScheduledEventDao();


        if (StringUtils.isBlank(xid))
            response.addContextualMessage("xid", "validate.required");
        else if (!scheduledEventDao.isXidUnique(xid, id))
            response.addContextualMessage("xid", "validate.xidUsed");


        se.validate(response);


        // Save the scheduled event
        if (!response.getHasMessages())
            RTMDefinition.instance.saveScheduledEvent(se);


        response.addData("seId", se.getId());
        return response;
    }

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

    ds.setName("Test Virtual");
    ds.setEnabled(true);
    ds.setUpdatePeriods(5);
    ds.setUpdatePeriodType(TimePeriods.SECONDS);
    
    ProcessResult response = new ProcessResult();
    ds.validate(response);
    if(!response.getHasMessages())
      Common.runtimeManager.saveDataSource(ds);
    else
      throw new RuntimeException("Invalid data!");
    
    
    DataPointDao dpDao = new DataPointDao();
    //Create Test Points
    for(int i=0; i<10; i++){
      VirtualPointLocatorVO pointLocator = ds.createPointLocator();
      //Create a Random Points
      pointLocator.setDataTypeId(DataTypes.NUMERIC);
      pointLocator.setChangeTypeId(ChangeTypeVO.Types.RANDOM_ANALOG);
      pointLocator.getRandomAnalogChange().setMin(0);
      pointLocator.getRandomAnalogChange().setMax(100);
      pointLocator.getRandomAnalogChange().setStartValue("1");
      pointLocator.setSettable(true);
      
      
      DataPointVO dp = new DataPointVO();
      dp.setXid(dpDao.generateUniqueXid());
      dp.setName("Virtual Random " + i);
            dp.setDataSourceId(ds.getId());
            dp.setDataSourceTypeName(ds.getDefinition().getDataSourceTypeName());
            dp.setDeviceName(ds.getName());
            dp.setEventDetectors(new ArrayList<PointEventDetectorVO>(0));
            dp.defaultTextRenderer();
            //Setup the Chart Renderer
            ImageChartRenderer chartRenderer = new ImageChartRenderer(TimePeriods.DAYS,5);
            dp.setChartRenderer(chartRenderer);
      
            dp.setPointLocator(pointLocator);
      dp.setEnabled(true);
      dp.setSettable(true);
      dp.setDefaultCacheSize(0);      
      
      dp.validate(response);
      if(!response.getHasMessages())
        Common.runtimeManager.saveDataPoint(dp);
      else
        throw new RuntimeException("Invalid data!");
      
    }

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

 * @author Matthew Lohbihler
 */
public class ReportsDwr extends ModuleDwr {
    @DwrPermission(user = true)
    public ProcessResult init() {
        ProcessResult response = new ProcessResult();
        ReportDao reportDao = new ReportDao();
        User user = Common.getUser();


        response.addData("points", getReadablePoints());
        response.addData("mailingLists", new MailingListDao().getMailingLists());
        response.addData("users", new UserDao().getUsers());
        if(user.isAdmin()) {
          response.addData("reports", reportDao.getReports());
          response.addData("instances", getReportInstances(user));
      }
        else {
          response.addData("reports", reportDao.getReports(user.getId()));
          response.addData("instances", getReportInstances(user));
      }
        response.addData("templates", getTemplateList());


        return response;
    }

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

        try {
            importContext.getReader().readInto(view, viewJson);


            // Now validate it. Use a new response object so we can distinguish errors in this view from other
            // errors.
            ProcessResult viewResponse = new ProcessResult();
            view.validate(viewResponse);
            if (viewResponse.getHasMessages())
                // Too bad. Copy the errors into the actual response.
                importContext.copyValidationMessages(viewResponse, "emport.view.prefix", xid);
            else {
                // Sweet. Save it.
                boolean isnew = view.isNew();

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult


        try {
            importContext.getReader().readInto(vo, scheduledEvent);


            // Now validate it. Use a new response object so we can distinguish errors in this vo from other errors.
            ProcessResult voResponse = new ProcessResult();
            vo.validate(voResponse);
            if (voResponse.getHasMessages())
                // Too bad. Copy the errors into the actual response.
                importContext.copyValidationMessages(voResponse, "emport.scheduledEvent.prefix", xid);
            else {
                // Sweet. Save it.
                boolean isnew = vo.isNew();

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

        user.setDataExportDefinition(def);
    }
    
    @DwrPermission(user = true)
    public ProcessResult exportCurrentWatchlist(){
      ProcessResult result = new ProcessResult();
      WatchList wl = getWatchList();
      
      //TODO Could check for null, probably unlikely though
      
      Map<String, Object> data = new LinkedHashMap<String, Object>();
        //Get the Full VO for the export
        List<WatchList> vos = new ArrayList<WatchList>();
      vos.add(wl);
        data.put(WatchListEmportDefinition.elementId, vos);
        
        result.addData("json", EmportDwr.export(data, 3));
        
      return result;
    }

View Full Code Here

Examples of com.serotonin.m2m2.i18n.ProcessResult

        try {
            importContext.getReader().readInto(watchList, watchListJson);


            // Now validate it. Use a new response object so we can distinguish errors in this user from other
            // errors.
            ProcessResult watchListResponse = new ProcessResult();
            watchList.validate(watchListResponse);
            if (watchListResponse.getHasMessages())
                // Too bad. Copy the errors into the actual response.
                importContext.copyValidationMessages(watchListResponse, "emport.watchList.prefix", xid);
            else {
                // Sweet. Save it.
                boolean isnew = watchList.getId() == Common.NEW_ID;

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.