fileredelivery.java

java阿里巴巴代码

package com.saas.biz.fileredeliveryMgr;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

import com.saas.biz.commen.commMethodMgr;
import com.saas.biz.dao.fileredeliveryDao.FileredeliveryExt;
import com.saas.biz.departMgr.DepartInfo;
import com.saas.sys.buffer.Buffers;
import com.saas.sys.dbm.Dbtable;
import com.saas.sys.exp.SaasApplicationException;
import com.saas.sys.log.Logger;

public class Fileredelivery{

	Logger log;

	Buffers inBuffer;

	Buffers outBuffer;

	Dbtable tradeQuery;

	commMethodMgr commen;

	ArrayList queryResult = new ArrayList();

	public Fileredelivery() {
		log = new Logger(this);
		tradeQuery = new Dbtable();
		commen = new commMethodMgr();
		outBuffer = new Buffers();
	}

	public void setOutBuffer(Buffers outBuffer) {
		this.outBuffer = outBuffer;
	}

	public Buffers getOutBuffer() {
		return this.outBuffer;
	}

	public void setTradeQuery(Dbtable tradeQuery) {
		this.tradeQuery = tradeQuery;
	}

	public Dbtable getTradeQuery() {
		return this.tradeQuery;
	}

	public ArrayList getQueryResult() {
		return this.queryResult;
	}

	public void setQueryResult(ArrayList queryResult) {
		this.queryResult = queryResult;
	}

	// 新增文件下发
	public void addFileDelivery(Buffers inbuffer) {
		this.outBuffer = inbuffer;
		this.inBuffer = inbuffer;
		log.LOG_INFO("进入addReportsDelivery方法...");
		int iResult = -1;
		String title = inbuffer.getString("TITLE");
		String idx = inbuffer.getString("IDX");
		String content = inbuffer.getString("CONTENT");
		String user = inbuffer.getString("SESSION_USER_NAME");
		String part = inbuffer.getString("PART");
		String rpart = inbuffer.getString("RPART");
		String path = inbuffer.getString("PATH");
		try {
			iResult = addFileDelivery(idx, title, content, user, part, rpart, path);
		}
		catch (Exception e) {
			iResult = -1;
		}
		if (iResult != 0) {
			this.outBuffer.setInt("RESULT_CODE", -1);
			this.outBuffer.setString("RESULT_INFO", "业务处理失败！");
		}
		else {
			this.outBuffer.setInt("RESULT_CODE", 0);
			this.outBuffer.setString("RESULT_INFO", "业务处理成功！");
		}
		log.LOG_INFO("退出addReportsDelivery方法...");
	}

	public int addFileDelivery(String idx, String title, String content, String user, String part, String rpart, String path) throws SaasApplicationException {

		if (rpart == "all" || rpart.equals("all")) {
			Map departMap = new HashMap();
			departMap = new DepartInfo().getDepartByParentCode(part);
			if (departMap != null && departMap.size() > 0) {
				Iterator it = departMap.entrySet().iterator();
				while (it.hasNext()) {
					Map.Entry entry = (Map.Entry) it.next();
					Object key = entry.getKey();
					FileredeliveryExt repExt = new FileredeliveryExt();
					repExt.setParam(":VID", idx);
					repExt.setParam(":VCONTENT", content);
					repExt.setParam(":VTITLE", title);
					repExt.setParam(":VPATH", path);
					repExt.setParam(":VPART", part);
					repExt.setParam(":VUSER", user);
					repExt.setParam(":VRPART", key);
					repExt.setParam(":VXCHECKED", "0");
					tradeQuery.executeBy(repExt.insBy("INS_BY_ALL"));
				}
			}
		}
		else {
			FileredeliveryExt repExt = new FileredeliveryExt();
			repExt.setParam(":VID", commen.GenTradeId());
			repExt.setParam(":VCONTENT", content);
			repExt.setParam(":VTITLE", title);
			repExt.setParam(":VPATH", path);
			repExt.setParam(":VPART", part);
			repExt.setParam(":VUSER", user);
			repExt.setParam(":VRPART", rpart);
			repExt.setParam(":VXCHECKED", "0");
			tradeQuery.executeBy(repExt.insBy("INS_BY_ALL"));
		}
		return 0;
	}

	public ArrayList getFilesDeliveryByPart(int iStart, String depart_code) throws SaasApplicationException {
		ArrayList reportList = new ArrayList();
		try {
			if (iStart == 0) {
				iStart = 0;
			}
			else {
				iStart = (iStart - 1) * 20;
			}
			FileredeliveryExt repExt = new FileredeliveryExt();
			repExt.setParam(":VRPART", depart_code);
			repExt.setParam(":VXCHECKED", "0");
			reportList = repExt.selByList("SEL_BY_RPART", iStart, 20);
		}
		catch (Exception e) {
			log.LOG_INFO(e.getMessage());
		}
		return reportList;
	}

	public int getFilesDeliveryByPartCT(String depart_code) throws SaasApplicationException {
		ArrayList reportList = new ArrayList();
		int size = 0;
		try {
			FileredeliveryExt repExt = new FileredeliveryExt();
			repExt.setParam(":VRPART", depart_code);
			repExt.setParam(":VXCHECKED", "0");
			reportList = repExt.selByList("SEL_BY_RPART_COUNT");
			if (reportList != null && reportList.size() > 0) {
				HashMap map = (HashMap) reportList.get(0);
				if (map.get("ct") != null) {
					size = Integer.parseInt(map.get("ct").toString());
				}
			}
		}
		catch (Exception e) {
			log.LOG_INFO(e.getMessage());
		}
		return size;
	}

	public ArrayList getFileDeliveryById(String id) throws SaasApplicationException {
		ArrayList reportList = new ArrayList();
		try {
			FileredeliveryExt repExt = new FileredeliveryExt();
			repExt.setParam(":VID", id);
			repExt.setParam(":VXCHECKED", "0");
			reportList = repExt.selByList("SEL_BY_ID");
		}
		catch (Exception e) {
			log.LOG_INFO(e.getMessage());
		}
		return reportList;
	}

}