📄 infget.java
字号:
package edu.whut.cwts.hc;
import java.sql.*;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.*;
import edu.whut.cwts.hc.Assert;
import edu.whut.cwts.hc.ConnectDB;
import edu.whut.cwts.hc.Gjhc;
import edu.whut.cwts.hc.Lcxx;
import edu.whut.cwts.hc.StrUtil;
public class InfGet{
public static ArrayList findGk() throws java.sql.SQLException {
//获取干流港口名称列表
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT * from lcxxb";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(new Lcxx(rs.getString("gkdm"), rs.getString("gkmc"), rs.getInt("lc"), rs.getFloat("fl")));
}
conndb.close();
return result;
}
public static ArrayList findZlGk() throws java.sql.SQLException {
//获取支流港口名称列表
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT * from zllcxxb";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(new Zllcxx(rs.getString("zldm"), rs.getString("zlmc"),rs.getString("sydm"),rs.getInt("sylc"),rs.getString("xydm"),rs.getInt("xylc")));
}
conndb.close();
return result;
}
public static ArrayList findHl() throws java.sql.SQLException{
//获取货物名称列表
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT * from hwxxb";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(rs.getString("hwmc"));
}
conndb.close();
return result;
}
public static Cbxxb findByCjdjh(String cjdjh) throws java.sql.SQLException{
//按船检登记号获取国内船舶基本信息（返回Cbxxb类型单条记录）
Cbxxb cbxxb=null;
ConnectDB conndb=new ConnectDB();
String sql="SELECT * from cbxxb where cjdjh='"+cjdjh+"'";
Assert.pl(sql);
ResultSet rs=conndb.executeQuery(sql);
if(rs.next()){
cbxxb=new Cbxxb(rs.getString("cjdjh"),rs.getString("cmch"),rs.getString("gsdm"),rs.getString("cz"),rs.getString("czsfzh"),rs.getFloat("gl"),rs.getFloat("jd"),rs.getFloat("zd"),rs.getFloat("zzd"),rs.getString("cjg"),rs.getString("sfyy"),rs.getString("yyzh"),rs.getString("xgsj"));
}
conndb.close();
return cbxxb;
}
/* public static Cbxxb findByCmchOnlyone(String cmch) throws java.sql.SQLException{
//按船名船号获取国内船舶基本信息（返回Cbxxb类型单条记录,此为已知数据库中只有单条记录的情况下大胆写）
Cbxxb cbxxb=null;
ConnectDB conndb=new ConnectDB();
String sql="SELECT * from cbxxb where cmch='"+cmch+"'";
Assert.pl(sql);
ResultSet rs=conndb.executeQuery(sql);
if(rs.next()){
cbxxb=new Cbxxb(rs.getString("cjdjh"),rs.getString("cmch"),rs.getString("gsdm"),rs.getString("cz"),rs.getString("czsfzh"),rs.getFloat("gl"),rs.getFloat("jd"),rs.getFloat("zd"),rs.getFloat("zzd"),rs.getString("cjg"),rs.getString("sfyy"),rs.getString("yyzh"),rs.getString("xgsj"));
}
conndb.close();
return cbxxb;
}
*/
public static Cbxxb findByCmchOnlyone(String cmch)
//按船名船号获取国内船舶基本信息（返回Cbxxb类型单条记录,此为已知数据库中只有单条记录的情况下大胆写）
{
Cbxxb cbxxb = new Cbxxb();
ConnectDB conndb = new ConnectDB();
ResultSet rs = null;
String sql1 = "select cjdjh,cmch,gsdm,cz,czsfzh,gl,jd,zd,zzd,cjg,sfyy,yyzh,xgsj from cbxxb where cmch='"+cmch.trim()+"'";
try {
rs = conndb.executeQuery(sql1);
if (rs.next()) {
cbxxb.setCjdjh(StrUtil.donull(rs.getString(1)));
cbxxb.setCmch(StrUtil.donull(rs.getString(2)));
cbxxb.setGsdm(StrUtil.donull(rs.getString(3)));
cbxxb.setCz(StrUtil.donull(rs.getString(4)));
cbxxb.setCzsfzh(StrUtil.donull(rs.getString(5)));
cbxxb.setGl(rs.getFloat(6));
cbxxb.setJd(rs.getFloat(7));
cbxxb.setZd(rs.getFloat(8));
cbxxb.setZzd(rs.getFloat(9));
cbxxb.setCjg(StrUtil.donull(rs.getString(10)));
cbxxb.setSfyy(StrUtil.donull(rs.getString(11)));
cbxxb.setYyzh(StrUtil.donull(rs.getString(12)));
cbxxb.setXgsj(StrUtil.donull(rs.getString(13)));
}
} catch (Exception e) {
e.printStackTrace();
}
conndb.close();
return cbxxb;
}
public static ArrayList findByCmchList(String cmch) throws java.sql.SQLException{
//按船名船号获取国内船舶基本信息（返回ArrayList类型多条记录）
ArrayList result = new ArrayList();
ConnectDB conndb=new ConnectDB();
String sql="SELECT * from cbxxb where cmch='"+cmch.trim()+"'";
Assert.pl(sql);
ResultSet rs=conndb.executeQuery(sql);
if(rs==null)
return null;
while(rs.next()){
result.add(new Cbxxb(rs.getString("cjdjh"),rs.getString("cmch"),rs.getString("gsdm"),rs.getString("cz"),rs.getString("czsfzh"),rs.getFloat("gl"),rs.getFloat("jd"),rs.getFloat("zd"),rs.getFloat("zzd"),rs.getString("cjg"),rs.getString("sfyy"),rs.getString("yyzh"),rs.getString("xgsj")));
}
conndb.close();
return result;
}
public static String findGsmc(String gsdm) throws java.sql.SQLException{
//按照公司代码获取公司名称
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT gsmc from gsxxb where gsdm='"+gsdm.trim()+"'";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(rs.getString("gsmc"));
}
conndb.close();
String mc=(String) result.get(0);
return mc;
}
public static String findGkdm(String gkdm) throws java.sql.SQLException{
//按照港口代码获取港口名称
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT gkmc from lcxxb where gkdm='"+gkdm.trim()+"'";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(rs.getString("gkmc"));
}
conndb.close();
String mc=(String) result.get(0);
return mc;
}
public static String findzlGkdm(String gkdm) throws java.sql.SQLException{
//按照港口代码获取港口名称
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT zlmc from zllcxxb where zldm='"+gkdm.trim()+"'";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(rs.getString("zlmc"));
}
conndb.close();
String mc=(String) result.get(0);
return mc;
}
public static Lcxx findFl(String gkdm) throws java.sql.SQLException {
//根据港口代码获取港口（用于费率获取问题）也可以顺便获取里程
Lcxx lcxx = null;
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "SELECT * from lcxxb where gkdm='"+gkdm.trim()+"'";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(new Lcxx(rs.getString("gkdm"), rs.getString("gkmc"), rs.getInt("lc"), rs.getFloat("fl")));
}
conndb.close();
lcxx=(Lcxx)result.get(0);
return lcxx;
}
/*******************************************************************/
/******************国际航线船舶信息的提取*****************/
/*******************************************************************/
public static Gjcbb findByCmchGj(String cmch) throws java.sql.SQLException{
//按船名船号获取国际船舶基本信息（返回Gjcbb类型单条记录）
Gjcbb gjcbb=null;
ConnectDB conndb=new ConnectDB();
String sql="SELECT * from gjcbb where cmch='"+cmch.trim()+"'";
Assert.pl(sql);
ResultSet rs=conndb.executeQuery(sql);
if(rs.next()){
gjcbb=new Gjcbb(rs.getString("cjdjh"),rs.getString("cmch"),rs.getFloat("gl"),rs.getFloat("jd"),rs.getFloat("zd"),rs.getFloat("zzd"),rs.getString("cjg"),rs.getString("sfyy"),rs.getString("yyzh"),rs.getString("xgsj"),rs.getString("xgrdm"));
}
conndb.close();
return gjcbb;
}
public static ArrayList findDlgsGj(String cmch)throws java.sql.SQLException{
//按照船名船号获取国际航线船舶代理公司列表（从视图dzs1中查询出，代理公司代码和代理公司名称可以组合）
ArrayList result = new ArrayList();
ConnectDB conndb = new ConnectDB();
String sql = "select * from dzs1 where cmch='"+cmch.trim()+"'";
Assert.pl(sql);
ResultSet rs = conndb.executeQuery(sql);
if (rs == null)
return null;
while (rs.next()) {
result.add(rs.getString("gsdm").trim()+"-"+rs.getString("gsmc"));
}
conndb.close();
return result;
}
public static Gjhc findBypzhmGjhc(String pzhm) throws java.sql.SQLException{
//按国际票据号码获取国际航线票据基本信息（返回Gjhc类型单条记录）
Gjhc gjhc=null;
ConnectDB conndb=new ConnectDB();
String sql="SELECT * from gjhc where pzhm='"+pzhm.trim()+"'";
Assert.pl(sql);
ResultSet rs=conndb.executeQuery(sql);
if(rs.next()){
gjhc = new Gjhc(rs.getString("pzhm").trim(),rs.getString("pzzl").trim(),rs.getString("cjdjh").trim(),rs.getString("cmch").trim(),rs.getString("gsdm").trim(),rs.getString("qsg").trim(),rs.getString("ddg").trim(),rs.getString("hx").trim(),rs.getString("zsbz").trim(),rs.getFloat("jdhqw"),rs.getFloat("jfje"),rs.getString("jcgrq").trim().substring(0,10),rs.getString("dpr").trim(),rs.getString("fhr").trim(),rs.getString("zddm").trim(),rs.getString("kprq").trim().substring(0,10),rs.getString("zph").trim(),rs.getString("dhcbj").trim(),rs.getString("bzbj").trim(),rs.getFloat("znts"),rs.getFloat("znje"),rs.getString("sfzf").trim(),rs.getString("dzbj"),rs.getString("dzrq").trim(),rs.getString("dzjbr").trim());
}
conndb.close();
return gjhc;
}
public static long zntsGet(String kprq) throws ParseException{
//滞纳天数的计算：现在时间减去开票日期获取的天数，再减去30（30天为限缴期限）
Date dateBegin = new SimpleDateFormat("yyyy-MM-dd").parse(kprq);
Date dateEnd = new SimpleDateFormat("yyyy-MM-dd").parse(new java.util.Date().toLocaleString());
long znDay0 = (dateEnd.getTime() - dateBegin.getTime()) / (24 * 60 * 60 * 1000) > 0 ? (dateEnd
.getTime() - dateBegin.getTime())
/ (24 * 60 * 60 * 1000)
: (dateBegin.getTime() - dateEnd.getTime()) / (24 * 60 * 60 * 1000);
long znDay = znDay0-30;
return znDay ;
}
}⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -