package cn.jbit.easybuy.biz.impl;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import cn.jbit.easybuy.biz.ProductService;
import cn.jbit.easybuy.dao.CommentDao;
import cn.jbit.easybuy.dao.ProductCategoryDao;
import cn.jbit.easybuy.dao.ProductDao;
import cn.jbit.easybuy.dao.impl.CommentDaoImpl;
import cn.jbit.easybuy.dao.impl.ProductCategoryDaoImpl;
import cn.jbit.easybuy.dao.impl.ProductDaoImpl;
import cn.jbit.easybuy.entity.Pager;
import cn.jbit.easybuy.entity.Product;
import cn.jbit.easybuy.entity.ProductCategory;
import cn.jbit.easybuy.util.DataSourceUtil;
import cn.jbit.easybuy.util.Validator;
public class ProductServiceImpl implements ProductService {
public void delete(String id) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
productDao.delete(Long.parseLong(id));
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public void deleteCategory(String id) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
productCategoryDao.delete(Long.parseLong(id));
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public Product findById(String id) {
Connection connection = null;
Product product = null;
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
product = productDao.findById(Long.parseLong(id));
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return product;
}
public ProductCategory findCategoryById(String id) {
Connection connection = null;
ProductCategory productCategory = null;
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
productCategory = productCategoryDao.findById(Long.parseLong(id));
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return productCategory;
}
public List<ProductCategory> getProductCategories(String parentId) {
Connection connection = null;
Long id = null;
if (!Validator.isEmpty(parentId))
id = Long.parseLong(parentId);
List<ProductCategory> rtn = new ArrayList<ProductCategory>();
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
rtn = productCategoryDao.getProductCategories(id);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return rtn;
}
public List<Product> getProductsByCategory(String categoryId, Pager pager) {
Connection connection = null;
List<Product> rtn = new ArrayList<Product>();
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
if (categoryId == null)
rtn = productDao.getProductsByCategoryLevelTwo(null, pager);
else
rtn = productDao.getProductsByCategoryLevelTwo(Long
.parseLong(categoryId), pager);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return rtn;
}
public void save(Product product) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
productDao.save(product);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public void saveCategory(ProductCategory productCategory) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
productCategoryDao.save(productCategory);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public void update(Product product) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
productDao.update(product);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public void updateCategory(ProductCategory productCategory, String type) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
ProductDao productDao = new ProductDaoImpl(connection);
String sql = null;
if (type.equals("ModifyParent")) {
sql = " UPDATE easybuy_product SET epc_id="
+ productCategory.getParentId()
+ " where epc_child_id=" + productCategory.getId();
} else {
sql = " UPDATE easybuy_product SET epc_child_id = null,epc_id="
+ productCategory.getId() + " where epc_child_id="
+ productCategory.getId();
}
connection.setAutoCommit(false);
try {
productCategoryDao.update(productCategory);
productDao.modifyCategoryOfProductBySql(sql);
connection.commit();
} catch (SQLException e) {
e.printStackTrace();
} finally {
connection.rollback();
connection.setAutoCommit(true);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public List<ProductCategory> getRootCategories() {
Connection connection = null;
List<ProductCategory> rtn = new ArrayList<ProductCategory>();
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
rtn = productCategoryDao.getRootCategories();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return rtn;
}
public void updateCategoryName(ProductCategory productCategory) {
Connection connection = null;
try {
connection = DataSourceUtil.openConnection();
ProductCategoryDao productCategoryDao = new ProductCategoryDaoImpl(
connection);
productCategoryDao.update(productCategory);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
}
public long getProductRowCount(String categoryId) {
Connection connection = null;
long rtn = 0;
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
Long id = null;
if (categoryId != null)
id = Long.parseLong(categoryId);
rtn = productDao.getProductRowCountByCategoryLevelTwo(id);
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return rtn;
}
public Long getNewProductId() {
Connection connection = null;
long rtn = 0;
try {
connection = DataSourceUtil.openConnection();
ProductDao productDao = new ProductDaoImpl(connection);
rtn = productDao.getNewProductId();
} catch (SQLException e) {
e.printStackTrace();
} finally {
DataSourceUtil.closeConnection(connection);
}
return rtn;
}
}
JSP/servlet/ajax购物网站源码easybuy
5星 · 超过95%的资源 需积分: 10 41 浏览量
2012-05-28
13:40:40
上传
评论 2
收藏 2.11MB RAR 举报 
JSP/servlet/ajax购物网站源码easybuy （165个子文件） 
ProductUploadServlet.class 8KB UserServlet.class 8KB ProductServiceImpl.class 8KB CartServlet.class 7KB NewsServlet.class 7KB ProductServlet.class 7KB ProductDaoImpl.class 7KB OrderDaoImpl.class 6KB CommentServlet.class 6KB OrderServlet.class 6KB CategoryServlet.class 6KB OrderServiceImpl.class 6KB HomeServlet.class 6KB FacilityServiceImpl.class 6KB UserDaoImpl.class 6KB Validator.class 5KB ProductCategoryDaoImpl.class 5KB CommentDaoImpl.class 5KB NewsDaoImpl.class 4KB RegisterServlet.class 4KB UserServiceImpl.class 4KB LoginServlet.class 3KB BaseDaoImpl.class 3KB Order.class 3KB User.class 3KB Product.class 3KB Pager.class 3KB ShoppingCart.class 2KB Comment.class 2KB OrderDetail.class 1KB DataSourceUtil.class 1KB News.class 1KB ProductService.class 1KB ShoppingCartItem.class 1KB ProductDao.class 1KB ProductCategory.class 1KB ActionResult.class 1023B FacilityService.class 865B OrderDao.class 773B ProductCategoryDao.class 691B OrderService.class 675B UserDao.class 651B CommentDao.class 615B NewsDao.class 581B UserService.class 559B UniqueConstraintException.class 479B .classpath 661B org.eclipse.wst.common.component 420B org.eclipse.wst.jsdt.ui.superType.container 49B style.css 13KB Thumbs.db 6KB
0_tiny.gif 2KB logo.gif 1KB
ojdbc14.jar 1.47MB standard.jar 384KB commons-io-1.3.2.jar 86KB commons-fileupload-1.2.1.jar 56KB jstl.jar 20KB ProductServiceImpl.java 8KB UserServlet.java 7KB CartServlet.java 6KB NewsServlet.java 6KB CategoryServlet.java 6KB ProductUploadServlet.java 6KB ProductDaoImpl.java 5KB FacilityServiceImpl.java 5KB ProductServlet.java 5KB CommentServlet.java 5KB OrderServlet.java 5KB OrderServiceImpl.java 5KB OrderDaoImpl.java 5KB HomeServlet.java 5KB UserDaoImpl.java 4KB Validator.java 4KB ProductCategoryDaoImpl.java 4KB CommentDaoImpl.java 3KB NewsDaoImpl.java 3KB UserServiceImpl.java 3KB RegisterServlet.java 3KB Pager.java 2KB LoginServlet.java 2KB Order.java 2KB User.java 2KB Product.java 2KB BaseDaoImpl.java 2KB Comment.java 1KB ShoppingCart.java 930B ProductDao.java 904B ProductService.java 888B OrderDetail.java 844B DataSourceUtil.java 815B OrderDao.java 734B News.java 730B ActionResult.java 696B FacilityService.java 671B ShoppingCartItem.java 656B ProductCategoryDao.java 585B OrderService.java 547B ProductCategory.java 540B CommentDao.java 524B共 165 条
- 1
- 2
- 1
- 2
- 3
前往页