Wizzer | Wizzer.cn

package com.hits.core;


import com.hits.modules.cms.task.LoadTask;
import org.nutz.log.Log;
import org.nutz.log.Logs;
import org.nutz.mvc.NutConfig;
import org.nutz.mvc.Setup;

import com.hits.common.config.Globals;
import org.quartz.SchedulerException;
import org.quartz.impl.StdSchedulerFactory;

/**
 * 类描述： 创建人：Wizzer 联系方式：www.wizzer.cn 创建时间：2013-11-26 下午2:11:13
 */
public class StartSetup implements Setup {
    private final static Log log = Logs.get();

    @Override
    public void destroy(NutConfig config) {

    }

    @Override
    public void init(NutConfig config) {
        try {
            //初始化Quartz任务
            Globals.SCHEDULER = StdSchedulerFactory.getDefaultScheduler();
            new Thread(config.getIoc().get(LoadTask.class)).start();
        } catch (SchedulerException e) {
            log.error(e);
        } catch (Exception e) {
            log.error(e);
        }
    }

}

LoadTask.java 从任务表中加载任务，定时执行类方法：

package com.hits.modules.cms.task;

import com.hits.common.action.BaseAction;
import com.hits.common.config.Globals;
import com.hits.modules.cms.task.bean.Cms_task;
import org.apache.commons.lang.StringUtils;
import org.nutz.dao.Cnd;
import org.nutz.dao.Dao;
import org.nutz.integration.quartz.NutQuartzJobFactory;
import org.nutz.ioc.loader.annotation.Inject;
import org.nutz.ioc.loader.annotation.IocBean;
import org.nutz.log.Log;
import org.nutz.log.Logs;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.*;

/**
 * Created by Wizzer on 14-3-4.
 */
@IocBean
public class LoadTask extends BaseAction implements Runnable {
    @Inject
    protected Dao dao;
    private final static Log log = Logs.get();

    public void run() {
        List<Cms_task> tasks = daoCtl.list(dao, Cms_task.class, Cnd.where("is_enable", "=", 0));
        Globals.SCHEDULER.setJobFactory(new NutQuartzJobFactory());
        for (int i = 0; i < tasks.size(); i++) {
            Cms_task task = tasks.get(i);
            try {
                Map<String, String> map = new HashMap<String, String>();
                if (task.getTask_type() == 2 || task.getTask_type() == 3) {
                    map.put("site_id", task.getSite_id());
                    map.put("channel_id", task.getParam_value());
                } else if (task.getTask_type() == 1) {
                    map.put("site_id", task.getSite_id());
                }
                JobBuilder jobBuilder = JobBuilder.newJob(getClassByTask(task.getJob_class()));
                jobBuilder.setJobData(getJobDataMap(map));
                TriggerBuilder triggerBuilder = TriggerBuilder.newTrigger();
                if (StringUtils.isNotBlank(task.getTask_code())) {
                    jobBuilder.withIdentity(task.getTask_code(), Scheduler.DEFAULT_GROUP);
                    triggerBuilder.withIdentity(task.getTask_code(), Scheduler.DEFAULT_GROUP);
                } else {
                    UUID uuid = UUID.randomUUID();
                    jobBuilder.withIdentity(uuid.toString(), Scheduler.DEFAULT_GROUP);
                    triggerBuilder.withIdentity(uuid.toString(), Scheduler.DEFAULT_GROUP);
                    task.setTask_code(uuid.toString());
                    daoCtl.update(dao, task);
                }
                triggerBuilder.withSchedule(getCronScheduleBuilder(getCronExpressionFromDB(task)));
                //调度任务
                
                Globals.SCHEDULER.scheduleJob(jobBuilder.build(), triggerBuilder.build());
                
            } catch (SchedulerException e) {
                log.error(e);
            } catch (ClassNotFoundException e) {
                log.error(e);
            } catch (Exception e) {
                log.error(e);
            }
        }
        if(tasks.size()>0){
            Globals.SCHEDULER.start();
        }
        

    }

    public static CronScheduleBuilder getCronScheduleBuilder(String cronExpression) {
        return CronScheduleBuilder.cronSchedule(cronExpression);
    }
    public String getCronExpressionFromDB(Cms_task task) {
        if (task.getExecycle() == 2) {
            return task.getCron_expression();
        } else {
            int execycle = task.getTask_interval_unit();
            String excep = "";
            if (execycle == 5) {//月
                excep = "0  " + task.getMinute() + " " + task.getHour() + " " + task.getDay_of_month() + " * ?";
            } else if (execycle == 4) {//周
                excep = "0  " + task.getMinute() + " " + task.getHour() + " " + " ? " + " * " + task.getDay_of_week();
            } else if (execycle == 3) {//日
                excep = "0  " + task.getMinute() + " " + task.getHour() + " " + " * * ?";
            } else if (execycle == 2) {//时
                excep = "0 0 */" + task.getInterval_hour() + " * * ?";
            } else if (execycle == 1) {//分
                excep = "0  */" + task.getInterval_minute() + " * * * ?";
            }
            return excep;
        }
    }

    /**
     * @param params 任务参数
     * @return
     */
    private JobDataMap getJobDataMap(Map<String, String> params) {
        JobDataMap jdm = new JobDataMap();
        Set<String> keySet = params.keySet();
        Iterator<String> it = keySet.iterator();
        while (it.hasNext()) {
            String key = it.next();
            jdm.put(key, params.get(key));
        }
        return jdm;
    }

    /**
     * @param taskClassName 任务执行类名
     * @return
     * @throws ClassNotFoundException
     */
    @SuppressWarnings("unchecked")
    private Class getClassByTask(String taskClassName) throws ClassNotFoundException {
        return Class.forName(taskClassName);
    }
}

quartz-2.2.1 配置文件：

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#
# 跳过版本检查 #
org.quartz.scheduler.skipUpdateCheck=true
org.quartz.scheduler.instanceName = DefaultQuartzScheduler
org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false
# 用NutIoc接管Quartz的JobFactory,实现用户需要的注入功能 #
org.quartz.scheduler.jobFactory.class=org.nutz.integration.quartz.NutQuartzJobFactory

org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

org.quartz.jobStore.misfireThreshold = 60000
# 使用内存JobStore #
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

NutQuartzJobFactory.java 下载地址：

https://github.com/nutzam/nutzmore/blob/master/src/org/nutz/integration/quartz/NutQuartzJobFactory.java

2014一月2

swfupload：动态传递参数的方法

编程学习 swfupload 0 Comments

SWFUpload.prototype.setPostParams = function (paramsObject) {
this.settings.post_params = paramsObject;
this.callFlash(“SetPostParams”, [paramsObject]);
};

swfu.setPostParams({ path:$(“#path”).val() });

2013十二月25

Nutz：上传文件的配置项扩展，实现对文件类型的限制及分类

编程学习 nutz, 文件上传 0 Comments

upload.json 配置文件，增加扩展配置项extOption，内容可以由用户自定义，返回一个Map对象。

我要实现功能是，用户在相册里只允许上传图片文件、视频里只允许上传视频格式的文件等，

结合上传控件和JS，实现在页面级和代码级的文件类型分类限制、分类保存等功能。

Nutz issue 提交需求不被接纳所以只好自己实现了，大家如需要的话可以提issue，希望以后Nutz能内置：

https://github.com/nutzam/nutz/issues/568

upload.json：

var ioc = {
		upload : {
			type : "org.nutz.mvc.upload.UploadAdaptor",
			args : [{refer : "uploadCtx"}]
		},
		uploadCtx : {
			type : "org.nutz.mvc.upload.UploadingContext",
			args : [{refer: "filePool"}],
			fields : {
				ignoreNull : true,
				maxFileSize : 10485760,
				nameFilter : ".+(jpg|gif|png|jpeg|doc|docx|xls|xlsx|ppt|pptx|wps|pdf|txt|chm|mp3|mp4|3gp|rm|swf|flv|asf|wmv|wma|z|zip|rar|ios|jar)",
				extOption: {
					"images":"jpg,gif,png,jpeg",
					"document":"doc,docx,xls,xlsx,ppt,pptx,wps,pdf,txt,chm",
				    "music":"mp3",
				    "video":"mp4,3gp,rm,swf,flv,asf,wmv,wma",
				    "archive":"z,zip,rar,ios,jar"			            
				   }
			}
		},
		filePool : {
			type : "com.hits.common.file.FilePool",
			args : ["/temp/", 2000]
		}
};

改写Nutz源码：

org.nutz.mvc.upload.UploadingContext 类，增加代码：

    /**
     * 一个扩展配置项，用户可自定义内容
     */
    private Map<String, String> extOption;

    public Map<String, String> getExtOption() {
        return extOption;
    }

    public UploadingContext setExtOption(String extOption) {
        this.extOption = Json.fromJsonAsMap(String.class,extOption);
        return this;
    }

增加一个调用类：

FileType.java

/** 
 * 类描述： 
 * 创建人：Wizzer 
 * 联系方式：www.wizzer.cn
 * 创建时间：2013-12-25 下午1:13:30 
 * @version 
 */
public class FileType { 
	/**
	 * 根据文件名获取文件类型，默认返回other
	 * @param upload
	 * @param suffixname
	 * @return
	 */
	public static String getFileType(UploadAdaptor upload,String suffixname) {
		Map<String,String> hm=upload.getContext().getExtOption();
		String str = StringUtil.null2String(suffixname).toLowerCase();
		Set<Map.Entry<String, String>> set = hm.entrySet();
        for (Iterator<Map.Entry<String, String>> it = set.iterator(); it.hasNext();) {
            Map.Entry<String, String> entry = (Map.Entry<String, String>) it.next();
            if(entry.getValue().toLowerCase().indexOf(str)>-1)
            	return entry.getKey();
        }
		return "other";
	}
	/**
	 * 根据文件类型获取文件后缀名，默认返回nameFilter配置
	 * @param upload
	 * @param filetype
	 * @return
	 */
	public static String getSuffixname(UploadAdaptor upload,String filetype) {
		Map<String,String> hm=upload.getContext().getExtOption();
		String str = StringUtil.null2String(filetype).toLowerCase();
		if(!"".equals(str)){
			Set<Map.Entry<String, String>> set = hm.entrySet();
	        for (Iterator<Map.Entry<String, String>> it = set.iterator(); it.hasNext();) {
	            Map.Entry<String, String> entry = (Map.Entry<String, String>) it.next();
	            if(entry.getKey().toLowerCase().equals(str))
	            	return entry.getValue();
	        }
		}
        String name=upload.getContext().getNameFilter(); 
		return name.substring(name.indexOf("(")+1,name.lastIndexOf(")")).replace("|", ",");
	}
}

使用示例：

	@Inject
	protected UploadAdaptor upload;

	@At
	@Ok("->:/private/file/uploadOne.html")
	public void uploadOne(@Param("filetype") String filetype,HttpServletRequest req){
		req.setAttribute("filetype", filetype);
		req.setAttribute("allowExtensions", FileType.getSuffixname(upload, filetype));

	}

如上所述，在限制文件上传类型的同时，还可以将文件分类保存在不同类型的目录下。

2013十二月25

CDMA iPhone 4 iOS7.0.4/7.1 越狱并解决联系人括号问题的办法

手机数码 CDMA, iphone4 0 Comments

1、先使用evasi0n7越狱；
2、进入Cydia按照提示更新Cydia到最新版；
3、Cydia软件源添加 http://apt.weiphone.com；
4、Cydia搜索afc2add选择威锋源安装；
5、使用同步助手或其他工具浏览iPhone文件系统：
浏览至目录 /System/Library/PrivateFrameworks/AppSupport.framework
用压缩包里的 Default.phoneformat 替换之，重启后即可。
为防万一最好备份此文件。

绿色evasi0n7及Default.phoneformat 文件下载：http://pan.baidu.com/s/1nt16UgD

PS：CDMA iPhone 4 用了快三年了，有些毛病，坚持到明年iPhone6再换。。

2013十二月20

Nutz：通过URL路径查找对应的类及入口函数

编程学习 nutz, 源码 1 Comment

由于Nutz是零配置的，所以通过URL找到处理类以及跳转的页面，就显得很麻烦，不方便维护。

于是，我在大神兽的指导下，实现如下功能：在项目启动时，将URL路径、类、方法、以及跳转页面写入项目中的一个文件中，方便查看。

@UrlMappingBy(value=UrlMappingSet.class)
public class MainModule { 
}

在Nutz入口类，加入 @UrlMappingBy。

UrlMappingSet.java 实现在 /WEB-INF/ 目录下生成 paths.txt 文件，记录路径，文件格式如下：

UrlMappingSet.java 源码：

package com.hits.core;

import java.io.File;
import java.lang.reflect.Method;

import org.nutz.lang.Files;
import org.nutz.lang.Lang;
import org.nutz.mvc.ActionChainMaker;
import org.nutz.mvc.ActionInfo;
import org.nutz.mvc.Mvcs;
import org.nutz.mvc.NutConfig;
import org.nutz.mvc.impl.UrlMappingImpl;

/**
 * 类描述： 创建人：Wizzer 联系方式：www.wizzer.cn 创建时间：2013-12-19 下午10:36:17
 * 
 * @version
 */
public class UrlMappingSet extends UrlMappingImpl {
	private static int count = 0;

	public void add(ActionChainMaker maker, ActionInfo ai, NutConfig config) {
		super.add(maker, ai, config);
		printActionMappingThis(ai);

	}

	protected void printActionMappingThis(ActionInfo ai) {

		String[] paths = ai.getPaths();
		StringBuilder sb = new StringBuilder();
		if (null != paths && paths.length > 0) {
			sb.append(paths[0]);
			for (int i = 1; i < paths.length; i++)
				sb.append(",").append(paths[i]);
		} else {
			throw Lang.impossible();
		}
		sb.append("\n");
		// 打印方法名
		Method method = ai.getMethod();
		String str;
		if (null != method)
			str = String.format("%-30s : %-10s", Lang.simpleMetodDesc(method),
					method.getReturnType().getSimpleName());
		else
			throw Lang.impossible();

		sb.append("\t" + ai.getModuleType().getName());
		sb.append("\n\r");
		sb.append("\t" + str);
		sb.append("\n");
		String filepath = Mvcs.getServletContext().getRealPath("/WEB-INF/")
				+ "/paths.txt";
		File f = new File(filepath);
		if (count == 0) {
			Files.write(f, sb.toString());
		} else {

			Files.appendWrite(f, sb.toString());
		}
		count++;
	}
}

2013十二月15

Nutz：自定义取值区间（可分页查询）

编程学习 nutz 0 Comments

使用示例：

			/**
			你可以自定义取数据区间的值，如下：

			offset=0,count=5     取0到5的记录
			offset=5,count=10    取5到15的记录
			page=3, offset=15,count=20   取15到35的记录
			**/
			int offset=0;
			int count=5;
			ExplicitPager pager=new ExplicitPager(offset,count);
			QueryResult file=daoCtl.listPage(dao, Oa_doc_file.class, cri,pager);

ExplicitPager 类源码：

package com.hits.common.page;

import org.nutz.dao.pager.Pager;

/** 
 * 类描述： 
 * 创建人：Wizzer 
 * 联系方式：www.wizzer.cn
 * 创建时间：2013-12-12 下午3:16:21 
 * @version 
 */
public class ExplicitPager extends Pager {

	private static final long serialVersionUID = 1L;
	int offset;
	int count;

	public ExplicitPager(int offset, int count) {
		super();
		this.offset = offset;
		this.count = count;
	}

	public void setOffset( int offset) {
		this.offset = offset;
	}

	public void setSelectCount( int count) {
		this.count = count;
	}

	@Override
	public int getPageSize() {
		return count;
	}

	@Override
	public int getOffset() {
		return offset;
	}

}

分页源代码（可参考上一篇文章，实现自定义SQL多表分页区间取值）：

	/**
	 * 根据查询条件分页,返回封装好的QueryResult对象
	 * 
	 * @param dao
	 * @param obj
	 * @param cnd
	 * @param pager
	 * @return
	 */
	public <T> QueryResult listPage(Dao dao, Class<T> obj, Condition cnd,Pager pager) { 
		List<T> list = dao.query(obj, cnd, pager);
		pager.setRecordCount(dao.count(obj, cnd));// 记录数需手动设置
		return new QueryResult(list, pager);
	}
	/**
	 * 根据自定义SQL分页,返回封装好的QueryResult对象
	 * @param dao
	 * @param sql
	 * @param pager
	 * @return
	 */
        public  QueryResult listPageSql(Dao dao, Sql sql, Pager pager) {
		if(pager==null)
			return null;
		pager.setRecordCount(Daos.queryCount(dao, sql.getSourceSql()));// 记录数需手动设置
		sql.setPager(pager);
		sql.setCallback(Sqls.callback.records());
		dao.execute(sql);  
		return new QueryResult(sql.getList(Map.class), pager);
	}

上一页 10 11 12 131415 16 17 18 下一页最后

Wizzer.cn

吃巧克力

基于Nutz的CMS内容管理系统大功告成

领导在门外用门夹核桃

Nutz：结合quartz-2.2.1实现定时任务

Nutz：使用第三方JS控件实现多文件上传的方法

swfupload：动态传递参数的方法

Nutz：上传文件的配置项扩展，实现对文件类型的限制及分类

CDMA iPhone 4 iOS7.0.4/7.1 越狱并解决联系人括号问题的办法

Nutz：通过URL路径查找对应的类及入口函数

Nutz：自定义取值区间（可分页查询）

联系方式

分类目录

文章归档

热门标签

近期评论

Links

打赏 Reward