save.java

文件的上传和下载的实现,用JAva编写,非常简单

package edu.whut.cwts.hc;

import edu.whut.cwts.hc.Assert;
import edu.whut.cwts.hc.ConnectDB;

public class Save {
	public static int insertGnhc(String pzhm, String pzzl, String cjdjh,
			String hwmc, String qsg, String ddg, float hwzl, float yf,
			float jfje, String yxqq, String yxqz, String dpr, String fhr,
			String zddm, String bzbj, String znts, float znje, String sfzf)
			throws java.sql.SQLException {// 对国内航次票业务数据的保存
		// 此处开票日期从javabean中获取，那么不需要在里面带参数了。
		ConnectDB conndb = new ConnectDB();
		String kprq = new java.util.Date().toLocaleString();
		String sql = "insert into gnhc(pzhm,pzzl,cjdjh,hwmc,qsg,ddg,hwzl,yf,jfje,yxqq,yxqz,dpr,fhr,zddm,bzbj,znts,znje,sfzf,kprq)values('"
				+ pzhm.trim()
				+ "','"
				+ pzzl.trim()
				+ "','"
				+ cjdjh.trim()
				+ "','"
				+ hwmc.trim()
				+ "','"
				+ qsg.trim()
				+ "','"
				+ ddg.trim()
				+ "',"
				+ hwzl
				+ ","
				+ yf
				+ ","
				+ jfje
				+ ",'"
				+ yxqq.trim()
				+ "','"
				+ yxqz.trim()
				+ "','"
				+ dpr.trim()
				+ "','"
				+ fhr.trim()
				+ "','"
				+ zddm.trim()
				+ "','"
				+ bzbj.trim()
				+ "','"
				+ znts.trim()
				+ "',"
				+ znje
				+ ",'"
				+ sfzf.trim() + "','" + kprq.trim() + "')";
		Assert.pl(sql);
		int flag = conndb.executeUpdate(sql);
		conndb.close();
		return flag;
	}

	public static int insertGjhc(String pzhm, String pzzl, String cjdjh,
			String cmch, String gsdm, String qsg, String ddg, String hx,
			String zsbz, float jdhqw, float jfje, String jcgrq, String dpr,
			String fhr, String zddm, String zph, String dhcbj, String bzbj,
			int znts, float znje, String sfzf, String dzbj, String dzrq,
			String dzjbr, String syzt) throws java.sql.SQLException {
		// 对国际航次票业务数据的保存（25个字段），有一个参数用于票据状态表中的操作
		// 此处开票日期从javabean中获取，那么不需要在里面带参数了。
		// 在这里我妄图改进下保存功能（先保存业务数据，然后修改票据状态表）可以先试下再说。
		ConnectDB conndb = new ConnectDB();
		String kprq = new java.util.Date().toLocaleString();
		String sql1 = "insert into gjhc(pzhm,pzzl,cjdjh,cmch,gsdm,qsg,ddg,hx,zsbz,jdhqw,jfje,jcgrq,dpr,fhr,zddm,kprq,zph,dhcbj,bzbj,znts,znje,sfzf,dzbj,dzrq,dzjbr)values('"
				+ pzhm.trim()
				+ "','"
				+ pzzl.trim()
				+ "','"
				+ cjdjh.trim()
				+ "','"
				+ cmch.trim()
				+ "','"
				+ gsdm.trim()
				+ "','"
				+ qsg.trim()
				+ "','"
				+ ddg.trim()
				+ "','"
				+ hx.trim()
				+ "','"
				+ zsbz.trim()
				+ "',"
				+ jdhqw
				+ ","
				+ jfje
				+ ",'"
				+ jcgrq.trim()
				+ "','"
				+ dpr.trim()
				+ "','"
				+ fhr.trim()
				+ "','"
				+ zddm.trim()
				+ "','"
				+ kprq.trim()
				+ "','"
				+ zph.trim()
				+ "','"
				+ dhcbj.trim()
				+ "','"
				+ bzbj.trim()
				+ "',"
				+ znts
				+ ","
				+ znje
				+ ",'"
				+ sfzf.trim()
				+ "','"
				+ dzbj.trim()
				+ "','"
				+ dzrq.trim()
				+ "','"
				+ dzjbr.trim()
				+ "')";
		String sql2 = "update pjztb set syzt='" + syzt.trim()
				+ "' where pzzl='" + pzzl.trim() + "' and pzhm='" + pzhm.trim()
				+ "'";
		Assert.pl(sql1);
		Assert.pl(sql2);
		int flag = 0;
		int flag1 = conndb.executeUpdate(sql1);
		int flag2 = conndb.executeUpdate(sql2);
		conndb.close();
		if (flag1 == 1 && flag2 == 1) {
			flag = 1;
		} else {
			flag = 0;
		}
		return flag;
	}

	public static int updatePjztb(String pzzl, String pzhm, String syzt)
			throws java.sql.SQLException {
		// 接下来要对pjztb表进行使用状态修改 ,使用后syzt变为5，pzzl国际航线为1，国内航线为2
		ConnectDB conndb = new ConnectDB();
		String sql = "update pjztb set syzt='" + syzt + "' where pzzl='"
				+ pzzl.trim() + "' and pzhm='" + pzhm.trim() + "'";
		Assert.pl(sql);
		int flag = conndb.executeUpdate(sql);
		conndb.close();
		return flag;
	}

	public static int insertHcxxdjb(String cjdjh, String hwmc, String qsg,
			String ddg, float lc, float hwzl, float yf, String qygrq,
			String djrdm, String zddm) throws java.sql.SQLException {
		ConnectDB conndb = new ConnectDB();
		String djrq = new java.util.Date().toLocaleString();
		String sql = "insert into hcxxdjb(cjdjh,hwmc,qsg,ddg,lc,hwzl,yf,qygrq,djrdm,zddm,djrq)values('"
				+ cjdjh.trim()
				+ "','"
				+ hwmc.trim()
				+ "','"
				+ qsg.trim()
				+ "','"
				+ ddg.trim()
				+ "',"
				+ lc
				+ ","
				+ hwzl
				+ ","
				+ yf
				+ ",'"
				+ qygrq.trim()
				+ "','"
				+ djrdm.trim()
				+ "','"
				+ zddm.trim() + "','" + djrq.trim() + "')";
		Assert.pl(sql);
		int flag = 0;
		flag = conndb.executeUpdate(sql);
		conndb.close();
		return flag;
	}

	/** **************************************************************** */
	/** ****************国际航票据达帐的处理**************** */
	/** **************************************************************** */
	public static int updateGjhc(String pzhm, String dzbj, String dzjbr,
			float znts, float znje) throws java.sql.SQLException {

		ConnectDB conndb = new ConnectDB();
		String dzrq = new java.util.Date().toLocaleString();

		String sql = "update gjhc set dzbj='" + dzbj.trim() + "', dzjbr='"
				+ dzjbr.trim() + "', znts=" + znts + " , znje=" + znje
				+ " , dzrq='" + dzrq.trim() + "'where pzhm='" + pzhm.trim()
				+ "'";
		Assert.pl(sql);
		int flag = conndb.executeUpdate(sql);
		conndb.close();
		return flag;
	}
}