java项目：进销存管理系统_获取所有商品信息的(4)

spInfo.setSpname(rs.getString("spname").trim());
}
} catch (SQLException e) {
e.printStackTrace();
}
return spInfo;
}
// 获取所有商品信息
public static List getSpInfos() {
List list = findForList("select * from tb_spinfo");
return list;
}
// 获取库存商品信息
public static TbKucun getKucun(Item item) {
String where = "spname='" + item.getName() + "'";
if (item.getId() != null)
where = "id='" + item.getId() + "'";
ResultSet rs = findForResultSet("select * from tb_kucun where " + where);
TbKucun kucun = new TbKucun();
try {
if (rs.next()) {
kucun.setId(rs.getString("id"));
kucun.setSpname(rs.getString("spname"));
kucun.setJc(rs.getString("jc"));
kucun.setBz(rs.getString("bz"));
kucun.setCd(rs.getString("cd"));
kucun.setDj(rs.getDouble("dj"));
kucun.setDw(rs.getString("dw"));
kucun.setGg(rs.getString("gg"));
kucun.setKcsl(rs.getInt("kcsl"));
}
} catch (SQLException e) {
e.printStackTrace();
}
return kucun;
}
// 获取入库单的最大ID，即最大入库票号
public static String getRuKuMainMaxId(Date date) {
return getMainTypeTableMaxId(date, "tb_ruku_main", "RK", "rkid");
}
// 在事务中添加入库信息
public static boolean insertRukuInfo(TbRukuMain ruMain) {
try {
boolean autoCommit = conn.getAutoCommit();
conn.setAutoCommit(false);
// 添加入库主表记录
insert("insert into tb_ruku_main values('" + ruMain.getRkId()
+ "','" + ruMain.getPzs() + "'," + ruMain.getJe() + ",'"
+ ruMain.getYsjl() + "','" + ruMain.getGysname() + "','"
+ ruMain.getRkdate() + "','" + ruMain.getCzy() + "','"
+ ruMain.getJsr() + "','" + ruMain.getJsfs() + "')");
Set<TbRukuDetail> rkDetails = ruMain.getTabRukuDetails();
for (Iterator<TbRukuDetail> iter = rkDetails.iterator(); iter
.hasNext();) {
TbRukuDetail details = iter.next();
// 添加入库详细表记录
insert("insert into tb_ruku_detail values('" + ruMain.getRkId()
+ "','" + details.getTabSpinfo() + "',"
+ details.getDj() + "," + details.getSl() + ")");
// 添加或修改库存表记录
Item item = new Item();
item.setId(details.getTabSpinfo());
TbSpinfo spInfo = getSpInfo(item);
if (spInfo.getId() != null && !spInfo.getId().isEmpty()) {
TbKucun kucun = getKucun(item);
if (kucun.getId() == null || kucun.getId().isEmpty()) {
insert("insert into tb_kucun values('" + spInfo.getId()
+ "','" + spInfo.getSpname() + "','"
+ spInfo.getJc() + "','" + spInfo.getCd()
+ "','" + spInfo.getGg() + "','"
+ spInfo.getBz() + "','" + spInfo.getDw()
+ "'," + details.getDj() + ","
+ details.getSl() + ")");
} else {
int sl = kucun.getKcsl() + details.getSl();
update("update tb_kucun set kcsl=" + sl + ",dj="
+ details.getDj() + " where id='"
+ kucun.getId() + "'");
}
}
}
conn.commit();
conn.setAutoCommit(autoCommit);
} catch (SQLException e) {
e.printStackTrace();
}
return true;
}
public static ResultSet findForResultSet(String sql) {
if (conn == null)
return null;
long time = System.currentTimeMillis();
ResultSet rs = null;
try {
Statement stmt = null;