用友NC57定时任务编写

1.在开发环境eclipse 的test目录下，将nchome/modules/uapqe/lib/pubuapqequeryengine.jar包中的TaskExecutor.java拷贝至test中新建的对应的包中



效果如下图：



 

2.在该类的方法executeTask中修改 下图位置的代码，把需要测试的任务名字替换 。



3.上面只是完成第一步，下面需要写对应的定时任务的java类文件。

一般位于private 中，建立对应的包名和类名，需要注意的是，类需要实现IBackgroundWorkPlugin 接口 。

示例如下：

public class DingJiasys implements IBackgroundWorkPlugin {

该接口方法executeTask中写入定时任务要执行的逻辑，出于人性化考虑，在renturn的时候返回字符串应该能够让客户明白该定时任务的执行情况，以前项目中有些同事的定时任务往往没返回任务成功或失败的提示，以至于客户一直认为系统在健康的运行着。

完整代码如下：

package nc.bs.hn.wl.dj;

import java.math.BigDecimal;
import java.util.ArrayList;

import nc.bs.dao.BaseDAO;
import nc.bs.hn.wl.pub.SuperDMO;
import nc.bs.pub.taskcenter.BgWorkingContext;
import nc.bs.pub.taskcenter.IBackgroundWorkPlugin;
import nc.jdbc.framework.processor.BeanListProcessor;
import nc.jdbc.framework.processor.ColumnProcessor;
import nc.vo.bd.invdoc.Invbasdocdjlljvo;
import nc.vo.bd.invdoc.Invbasdocdjlljwlvo;
import nc.vo.pub.BusinessException;
import nc.vo.pub.lang.UFDouble;
import nc.vo.xhfx.pub.Toolkit;
/**
* 非正式定时任务，，定价更新
* @auther 李林君
* Date: 2013-12-8
* @version 1.0
* @since NC5.7
*/
public class DingJiasys implements IBackgroundWorkPlugin {

private SuperDMO wldao;

private SuperDMO getWLDao() {
if (wldao == null) {
wldao = new SuperDMO();
}
return wldao;
}

private BaseDAO dao;

private BaseDAO getDao() {
if (dao == null) {
dao = new BaseDAO();
}
return dao;
}

public String executeTask(BgWorkingContext bgwc) throws BusinessException {
String sql2 = "select * from BD_INVBASDOCllj where nprice is null fetch first 5000 row only";

ArrayList<Invbasdocdjlljvo> vos =
(ArrayList<Invbasdocdjlljvo>) getDao().executeQuery(sql2, new BeanListProcessor(Invbasdocdjlljvo.class));
//
if(Toolkit.isEmpty(vos))
return "null";

for (Invbasdocdjlljvo vo : vos) {
String sqltemp = "select  dj from t_kcsm_dz where  sl_id ='"
+ vo.getPk_invbasdoc()
+ "'";
BigDecimal djj = (BigDecimal) getWLDao().executeQuery(sqltemp, new ColumnProcessor());
if (Toolkit.isEmpty(djj)) {
String updatesql2 = "update BD_INVBASDOCllj set nprice="
+ 99999
+ " where PK_INVBASDOC='"
+ vo.getPk_invbasdoc()
+ "'";

getDao().executeUpdate(updatesql2);

} else {
String updatesql = "update BD_INVBASDOCllj set nprice="
+ new UFDouble((BigDecimal) djj)
+ " where PK_INVBASDOC='"
+ vo.getPk_invbasdoc()
+ "'";

getDao().executeUpdate(updatesql);
}

}
return "success";
}
}