B2C商城项目源码,基于Java开发的高可用分布式B2C商城系统,Java+Spring MVC+Dubbo+Zookeeper+MySQL+Redis+FastDFS+Nginx+Solr
目录
前言
B2C商城-AIYOU
一、项目总体架构
二、系统软硬件设施总体规划
1、系统服务规划
2、应用服务规划
3、应用系统域名规划
三、系统运行环境构建
四、项目数据库创建
五、项目拉取
六、系统服务启动与停止
七、应用程序服务启动
1、首先需要启动后台服务
2、再启动前端WEB服务
八、B2C商城示例代码演示
九、项目页面最终效果图展示
1、商城后台管理界面效果展示
2、商城门户网站界面效果展示
十、结束语
前言
这个类似于电商的项目为什么说是B2C项目,是个人取的,何为电商,全称为电子商务,是指在互联网(Internet)、内部网(Intranet)和增值网(VAN,Value Added Network)上以电子交易方式进行交易活动和相关服务活动,是传统商业活动各环节的电子化、网络化。
当然,电商涵盖的范围很广,一般以三大电商模式为代表,即企业对企业(B2B/Business-to-Business)、企业对消费者(B2C/Business-to-Consumer)、消费者对消费者(C2C/Consumer-to-Consumer)。
随着国民经济网络化、社会生活信息化,国内互联网使用人数的爆发式增长,利用互联网进行网络购物消费,网上交易的方式已渐趋流行,所以,各种类型的电商网站也将层出不穷。迸发了包括:线上到线下(O2O/Online To Offline)、消费者对企业(C2B/Consumer-to-Business)、企业对市场营销(B2M/Business-to-Marketing)、生产厂家对消费者(M2C/Manufacturers-to-Consumer)、企业对行政机构(B2A/Business-to-Administration)、消费者对行政机构(C2A/Consumer-to-Administration)等电商模式。
本B2C商城,基于Java开发的高可用分布式B2C商城系统,技术架构:Java、JSP、CSS、JQuery、Spring MVC、Dubbo、Zookeeper、MySQL、Redis、FastDFS、Nginx、Solr。本项目的所有源码均已上传到GitHub开源,仅供学习交流,如果有什么问题欢迎留言讨论,如果有不足的地方,欢迎指正。
*注意:该项目只提供学习,切勿用于商业用途,
B2C商城-AIYOU
一、项目总体架构
本B2C商城通过三层架构实现,分别为:表现层、服务层、持久层。
表现层包括:后台管理系统、B2C商城门户网站系统、搜索系统、商品详情系统、单点登录系统、购物车系统、订单系统;
服务层包括:商品服务、内容服务、单点登录服务、购物车服务、订单服务、搜索服务、图片服务;
持久层包括:Redis 集群、MySQL 集群、Solr 集群、FastDFS 集群;
二、系统软硬件设施总体规划
1、系统服务规划
类目 | 名称 | 服务器数量 | 虚拟机数量 | IP地址 | 端口号 |
---|---|---|---|---|---|
MySQL | RDBMS,关系型数据库 | 2 | 1 | 192.168.159.128 | 3306~3307 |
Redis | NoSQL,非关系型数据库 | 6 | 1 | 192.168.159.129 | 6001~6006 |
FastDFS | 文件服务器 | 2 | 1 | 192.168.159.130 |
Tracker: 22122~22123 Storage: 23000~23001 Http_Port: 8888~8889 |
Nginx | WEB服务器 | 2 | 1 | 192.168.159.131 | 80 |
ActiveMQ | 消息中间件 | 2 | 1 | 192.168.159.132 | 8161~8162 |
Zookeeper | 服务注册中心 | 3 | 1 | 192.168.159.133 | 2181~2183 |
Solr | 文档索引库 | 6 | 1 | 192.168.159.134 | 2001~2006 |
2、应用服务规划
应用名称 | 说明 | 服务器数量 | 虚拟数量 | IP地址 | 端口号 |
---|---|---|---|---|---|
aiyou-manager | 商品后台管理服务 | 2 | 1 | 192.168.159.135 | 8001~8002 |
aiyou-content | 内容后台管理服务 | 2 | 1 | 192.168.159.136 | 8001~8002 |
aiyou-search | 索引库内容搜索服务 | 2 | 1 | 192.168.159.137 | 8001~8002 |
aiyou-manager-web | 商城后台管理系统 | 2 | 1 | 192.168.159.138 | 8001~8002 |
aiyou-portal-web | 商城门户网站系统 | 2 | 1 | 192.168.159.139 | 8001~8002 |
aiyou-search-web | 内容搜索系统 | 2 | 1 | 192.168.159.140 | 8001~8002 |
aiyou-item-web | 商品详情系统 | 2 | 1 | 192.168.159.141 | 8001~8002 |
aiyou-sso | 单点登录后台服务 | 2 | 1 | 192.168.159.142 | 8001~8002 |
aiyou-sso-web | 单点系统 | 2 | 1 | 192.168.159.143 | 8001~8002 |
aiyou-cart | 购物车后台服务 | 2 | 1 | 192.168.159.144 | 8001~8002 |
aiyou-cart-web | 购物车系统 | 2 | 1 | 192.168.159.145 | 8001~8002 |
aiyou-order | 订单后台服务 | 2 | 1 | 192.168.159.146 | 8001~8002 |
aiyou-order-web | 订单系统 | 2 | 1 | 192.168.159.147 | 8001~8002 |
3、应用系统域名规划
系统名称 | 说明 | 一级域名 | 二级域名 |
---|---|---|---|
aiyou-manager-web | 商城后台管理系统 | aiyou.cn | manager.aiyou.cn |
aiyou-portal-web | 商城门户网站系统 | aiyou.cn | portal.aiyou.cn |
aiyou-search-web | 内容搜索系统 | aiyou.cn | search.aiyou.cn |
aiyou-item-web | 商品详情系统 | aiyou.cn | item.aiyou.cn |
aiyou-sso-web | 单点系统 | aiyou.cn | passport.aiyou.cn |
aiyou-cart-web | 购物车系统 | aiyou.cn | cart.aiyou.cn |
aiyou-order-web | 订单系统 | aiyou.cn | order.aiyou.cn |
三、系统运行环境构建
1、MySQL数据库服务构建
请参考:《 MySQL数据库环境构建宝典 》
2、Zookeeper注册中心服务构建
请参考:《 Zookeeper分布式应用协调服务环境构建宝典 》
3、ActiveMQ消息中间件构建
因为AcitveMQ是基于Java的运行环境,所以,只要在ActiveMQ同一个服务器下存在Java运行环境就可以了,具体步骤如下:
1、安装Java运行环境;
2、下载ActiveMQ软件包;
3、将下载的ActiveMQ软件包上传的Linux系统;
4、解压ActiveMQ到指定目录(为了便于软件包的管理,需要规范软件包目录);
5、通过ActiveMQ特有的指令,配置,启动,使用;
4、Redis非关系型数据库构建
请参考:《 Redis非关系型数据库构建宝典 》
5、FastDFS文件服务构建
请参考:《 FastDFS文件服务器构建宝典 》
6、Nginx反向代理,负载均衡服务构建
请参考:《 Nginx Web服务器构建宝典 》
7、Solr文档内容索引库服务构建
请参考:《 Solr 索引库服务器构建宝典 》
四、项目数据库创建
>从aiyou_common项目中拿sql进行导入到已创建的b2c_aiyou数据库中(如果不存在,则自行创建一个)
文件路径:aiyou-common\src\main\resources\sql\b2c_aiyou.sql
五、项目拉取
拉取项目顺序
1、aiyou-parent
项目地址:《 GitHub aiyou-parent 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-parent.git
2、aiyou-common
项目地址:《 GitHub aiyou-common 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-common.git
3、aiyou-manager
项目地址:《 GitHub aiyou-manager 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-manager.git
4、aiyou-content
项目地址:《 GitHub aiyou-content 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-content.git
5、aiyou-manager-web
项目地址:《 GitHub aiyou-manager-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-manager-web.git
6、aiyou-portal-web
项目地址:《 GitHub aiyou-portal-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-portal-web.git
7、aiyou-search
项目地址:《 GitHub aiyou-search 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-search.git
8、aiyou-search-web
项目地址:《 GitHub aiyou-search-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-search-web.git
9、aiyou-item-web
项目地址:《 GitHub aiyou-item-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-item-web.git
10、aiyou-sso
项目地址:《 GitHub aiyou-sso 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-sso.git
11、aiyou-sso-web
项目地址:《 GitHub aiyou-sso-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-sso-web.git
12、aiyou-cart
项目地址:《 GitHub aiyou-cart 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-cart.git
13、aiyou-cart-web
项目地址:《 GitHub aiyou-cart-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-cart-web.git
14、aiyou-order
项目地址:《 GitHub aiyou-order 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-order.git
15、aiyou-order-web
项目地址:《 GitHub aiyou-order-web 项目地址 》
项目拉取地址:https://github.com/Jackson-AndyLau/aiyou-order-web.git
项目拉取完成后,工程目录如下图:
六、系统服务启动与停止
启动服务顺序
1、启动zookeeper
/usr/local/zookeeper/bin/zkServer.sh start
2、启动activemq
/usr/local/activemq/bin/activemq start
3、启动redis
./redis-server redis.conf
4、启动Nginx
./nginx
5、启动fastdfs
启动/重启/停止 tracker服务
/usr/bin/fdfs_trackerd /etc/fdfs/tracker.conf start/restart/stop
启动/重启/停止 storage服务
/usr/bin/fdfs_storaged /etc/fdfs/storage.conf start/restart/stop
检测服务心跳
/usr/bin/fdfs_monitor /etc/fdfs/storage.conf start
6、启动Solr
启动solr: /usr/local/solr/bin/solr start -p 6060 -force
停止solr:/usr/local/solr/bin/solr stop -p 6060 -force
重启solr: /usr/local/solr/bin/solr restart -p 6060 -force
停止服务顺序
1、停止solr集群
2、停止zookeeper集群
3、停止redis集群
4、停止高可用Web服务Nginx
5、停止FastDFS集群
6、停止Solr集群
七、应用程序服务启动
1、首先需要启动后台服务
1、aiyou-manager
2、aiyou-content
3、aiyou-search
4、aiyou-sso
5、aiyou-cart
6、aiyou-order
2、再启动前端WEB服务
1、aiyou-manager-web
2、aiyou-portal-web
3、aiyou-search-web
4、aiyou-item-web
5、aiyou-sso-web
6、aiyou-cart-web
7、aiyou-order-web
八、B2C商城示例代码演示
本项目所有代码均按照统一规范编写,严格遵循MVC三层架构设计模式实现,风格统一,代码整洁、美观、大方,重要的一点,注释多多,关键节点都有注释注明,方便阅读代码,示例代码如下:
Controller 控制层:
package com.huazai.aiyou.manager.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Description;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;import com.huazai.aiyou.common.module.EasyUIDataGrid;
import com.huazai.aiyou.common.response.AiyouResultData;
import com.huazai.aiyou.manager.pojo.TbItem;
import com.huazai.aiyou.manager.service.TbItemDescService;
import com.huazai.aiyou.manager.service.TbItemService;/*** * @author HuaZai* @contact who.seek.me@java98k.vip* <ul>* @description 商品信息controller层* </ul>* @className TbItemController* @package com.huazai.b2c.aiyou.controller* @createdTime 2017年06月09日** @version V1.0.0*/
@Controller
@RequestMapping(value = "/item")
public class TbItemController
{@Autowiredprivate TbItemService tbItemService;@Autowiredprivate TbItemDescService tbItemDescService;@Description(value = "获取商品列表")@RequestMapping(value = "/list", method = RequestMethod.GET)@ResponseBodypublic EasyUIDataGrid getItemList(@RequestParam(value = "page", defaultValue = "1") Integer page,@RequestParam(value = "row", defaultValue = "30") Integer rows){EasyUIDataGrid easyUIDataGrid = tbItemService.getTbItemList(page, rows, null);return easyUIDataGrid;}@Description(value = "添加商品")@RequestMapping(value = "/save", method = RequestMethod.POST)@ResponseBodypublic AiyouResultData addTbItem(TbItem item, String desc){AiyouResultData resultData = tbItemService.addTbItem(item, desc);return resultData;}@Description(value = "删除商品")@RequestMapping(value = "/delete", method = RequestMethod.POST)@ResponseBodypublic AiyouResultData deleteTbItem(String ids){AiyouResultData resultData = tbItemService.deleteTbItem(ids);return resultData;}@Description(value = "下架商品")@RequestMapping(value = "/instock", method = RequestMethod.POST)@ResponseBodypublic AiyouResultData instockTbItem(String ids){AiyouResultData resultData = tbItemService.instockTbItem(ids);return resultData;}@Description(value = "上架商品")@RequestMapping(value = "/reshelf", method = RequestMethod.POST)@ResponseBodypublic AiyouResultData reshelfTbItem(String ids){AiyouResultData resultData = tbItemService.reshelfTbItem(ids);return resultData;}@Description(value = "查询商品参数")@RequestMapping(value = "/param/item/query/{itemId}")@ResponseBodypublic AiyouResultData queryTbItemParam(@PathVariable(value = "itemId") Long itemId){AiyouResultData resultData = tbItemService.findTbItemById(itemId);return resultData;}@Description(value = "查询商品描述信息")@RequestMapping(value = "/query/item/desc/{itemId}")@ResponseBodyprivate AiyouResultData queryTbItemDesc(@PathVariable(value = "itemId") Long itemId){AiyouResultData resultData = tbItemDescService.findTbItemDescById(itemId);return resultData;}@Description(value = "修改商品信息")@RequestMapping(value = "/update", method = RequestMethod.POST)@ResponseBodypublic AiyouResultData updateTbItem(TbItem tbItem, String desc){AiyouResultData resultData = tbItemService.updateTbItem(tbItem, desc);return resultData;}}
Service 接口层:
package com.huazai.aiyou.manager.service;import com.huazai.aiyou.common.module.EasyUIDataGrid;
import com.huazai.aiyou.common.response.AiyouResultData;
import com.huazai.aiyou.manager.pojo.TbItemDesc;/*** * @author HuaZai* @contact who.seek.me@java98k.vip* <ul>* @description 商品描述接口* </ul>* @className TbItemDescService* @package com.huazai.b2c.aiyou.service* @createdTime 2017年06月09日** @version V1.0.0*/
public interface TbItemDescService {/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title getItemDescList* <ul>* @description 获取商品描述列表* </ul>* @createdTime 2017年06月11日* @param pageNum 当前页码* @param pageSize 页大小* @param tbItemDesc 查询条件* @return EasyUIDataGrid 数据列表** @version : V1.0.0*/public EasyUIDataGrid getItemDescList(Integer pageNum, Integer pageSize, TbItemDesc tbItemDesc);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title findTbItemDescById* <ul>* @description 根据商品ID获取商品描述* </ul>* @createdTime 2017年06月11日* @param itemId 商品ID* @return AiyouResultData 商品数据** @version : V1.0.0*/public AiyouResultData findTbItemDescById(long itemId);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title geTbItemDescById* <ul>* @description 通过商品Id,获取商品描述* </ul>* @createdTime 2017年06月18日* @param itemId 商品ID* @return TbItemDesc 商品描述** @version : V1.0.0*/public TbItemDesc geTbItemDescById(Long itemId);
}
package com.huazai.aiyou.manager.service;import com.huazai.aiyou.common.module.EasyUIDataGrid;
import com.huazai.aiyou.common.response.AiyouResultData;
import com.huazai.aiyou.manager.pojo.TbItem;/*** * @author HuaZai* @contact who.seek.me@java98k.vip* <ul>* @description 商品接口类* </ul>* @className ItemService* @package com.huazai.b2c.aiyou.service* @createdTime 2017年06月09日** @version V1.0.0*/
public interface TbItemService {/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title getItemList* <ul>* @description 获取商品列表* </ul>* @createdTime 2017年06月11日* @param pageNum 当前页码* @param pageSize 页大小* @param item 查询条件* @return EasyUIDataGrid 返回数据载体** @version : V1.0.0*/public EasyUIDataGrid getTbItemList(Integer pageNum, Integer pageSize, TbItem item);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title saveTbItem* <ul>* @description 添加商品* </ul>* @createdTime 2017年06月11日* @param item 商品实体* @param desc 商品描述* @return AiyouResultData 相应数据载体** @version : V1.0.0*/public AiyouResultData addTbItem(TbItem item, String itemDesc);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title deleteTbItem* <ul>* @description 删除商品信息* </ul>* @createdTime 2017年06月11日* @param ids 商品ID集合* @return AiyouResultData 数据载体** @version : V1.0.0*/public AiyouResultData deleteTbItem(String ids);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title instockTbItem* <ul>* @description 下架商品* </ul>* @createdTime 2017年06月11日* @param ids 商品ID集合* @return AiyouResultData 数据载体** @version : V1.0.0*/public AiyouResultData instockTbItem(String ids);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title reshelfTbItem* <ul>* @description 上架商品* </ul>* @createdTime 2017年06月11日* @param ids 商品ID集合* @return AiyouResultData 数据载体** @version : V1.0.0*/public AiyouResultData reshelfTbItem(String ids);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title findTbItemById* <ul>* @description 根据商品ID获取商品信息* </ul>* @createdTime 2017年06月11日* @param itemId 商品ID* @return AiyouResultData 数据载体** @version : V1.0.0*/public AiyouResultData findTbItemById(Long itemId);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title updateTbItem* <ul>* @description 修改商品信息* </ul>* @createdTime 2017年06月11日* @param item 商品信息实体* @param desc 商品描述* @return AiyouResultData 数据载体** @version : V1.0.0*/public AiyouResultData updateTbItem(TbItem item, String desc);/*** * @author HuaZai* @contact who.seek.me@java98k.vip* @title getTbItemById* <ul>* @description 根据商品Id,查询商品详情* </ul>* @createdTime 2017年06月18日* @param itemId 商品ID* @return TbItem 商品信息** @version : V1.0.0*/public TbItem getTbItemById(Long itemId);}
Service 实现层:
package com.huazai.aiyou.manager.service.impl;import java.util.List;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;import com.alibaba.dubbo.common.utils.CollectionUtils;
import com.huazai.aiyou.common.module.EasyUIDataGrid;
import com.huazai.aiyou.common.response.AiyouResultData;
import com.huazai.aiyou.common.utils.JsonUtils;
import com.huazai.aiyou.manager.mapper.TbItemDescMapper;
import com.huazai.aiyou.manager.pojo.TbItemDesc;
import com.huazai.aiyou.manager.pojo.TbItemDescExample;
import com.huazai.aiyou.manager.pojo.TbItemDescExample.Criteria;
import com.huazai.aiyou.manager.service.TbItemDescService;
import com.huazai.aiyou.manager.service.TbJedisClientService;/*** * @author HuaZai* @contact who.seek.me@java98k.vip* <ul>* @description 商品描述实现类* </ul>* @className TbItemDescServiceImpl* @package com.huazai.b2c.aiyou.service.impl* @createdTime 2017年06月09日** @version V1.0.0*/
@Service
public class TbItemDescServiceImpl implements TbItemDescService
{@Autowiredprivate TbItemDescMapper tbItemDescMapper;@Autowiredprivate TbJedisClientService tbJedisClientService;@Value("${AIYOU_TB_SERVICE_ITEM_INFO_KEY}")private String AIYOU_TB_SERVICE_ITEM_INFO_KEY;@Value("${AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE}")private Integer AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE;@Overridepublic EasyUIDataGrid getItemDescList(Integer pageNum, Integer pageSize, TbItemDesc tbItemDesc){// TODOreturn null;}@Overridepublic AiyouResultData findTbItemDescById(long itemId){TbItemDesc itemDesc = null;try{// 查询商品信息TbItemDescExample example = new TbItemDescExample();Criteria criteria = example.createCriteria();criteria.andItemIdEqualTo(itemId);List<TbItemDesc> list = tbItemDescMapper.selectByExampleWithBLOBs(example);if(CollectionUtils.isNotEmpty(list)){itemDesc = list.get(0);}} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "商品描述查询异常");}return AiyouResultData.ok(itemDesc);}@Overridepublic TbItemDesc geTbItemDescById(Long itemId){try{// 从缓存中获取数据if (itemId != null){// 获取数据String str = tbJedisClientService.get(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE");if (!StringUtils.isEmpty(str)){// 重置数据的有效时间tbJedisClientService.expire(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE",AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE);// 解析数据并返回TbItemDesc tbItemDesc = JsonUtils.jsonToPojo(str, TbItemDesc.class);return tbItemDesc;}}} catch (Exception e){e.printStackTrace();}TbItemDesc tbItemDesc = tbItemDescMapper.selectByPrimaryKey(itemId);try{// 新增缓存tbJedisClientService.set(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE",JsonUtils.objectToJson(tbItemDesc));// 设置过期时间tbJedisClientService.expire(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE",AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE);} catch (Exception e){e.printStackTrace();}return tbItemDesc;}}
package com.huazai.aiyou.manager.service.impl;import java.util.Date;
import java.util.List;import javax.annotation.Resource;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.huazai.aiyou.common.constant.TbConstant;
import com.huazai.aiyou.common.module.EasyUIDataGrid;
import com.huazai.aiyou.common.response.AiyouResultData;
import com.huazai.aiyou.common.utils.IDUtils;
import com.huazai.aiyou.common.utils.JsonUtils;
import com.huazai.aiyou.manager.mapper.TbItemDescMapper;
import com.huazai.aiyou.manager.mapper.TbItemMapper;
import com.huazai.aiyou.manager.pojo.TbItem;
import com.huazai.aiyou.manager.pojo.TbItemDesc;
import com.huazai.aiyou.manager.pojo.TbItemExample;
import com.huazai.aiyou.manager.pojo.TbItemExample.Criteria;
import com.huazai.aiyou.manager.service.TbItemService;
import com.huazai.aiyou.manager.service.TbJedisClientService;/*** * @author HuaZai* @contact who.seek.me@java98k.vip* <ul>* @description 商品实现类* </ul>* @className TbItemServiceImpl* @package com.huazai.b2c.aiyou.service.impl* @createdTime 2017年06月09日** @version V1.0.0*/
@Service
public class TbItemServiceImpl implements TbItemService
{@Autowiredprivate TbItemMapper tbItemMapper;@Autowiredprivate TbItemDescMapper tbItemDescMapper;@Autowiredprivate JmsTemplate jmsTemplate;@Autowiredprivate TbJedisClientService tbJedisClientService;@Resource(name = "itemTopicDestination")private Destination itemTopicDestination;@Value("${AIYOU_TB_SERVICE_ITEM_INFO_KEY}")private String AIYOU_TB_SERVICE_ITEM_INFO_KEY;@Value("${AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE}")private Integer AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE;@Overridepublic EasyUIDataGrid getTbItemList(Integer pageNum, Integer pageSize, TbItem item){// 初始化数据载体EasyUIDataGrid resultData = new EasyUIDataGrid();try{// 通过PageHelper设置分页信息PageHelper.startPage(pageNum, pageSize);// 设置查询条件获得查询结果TbItemExample example = new TbItemExample();Criteria criteria = example.createCriteria();if (!StringUtils.isEmpty(item) && item.getCid() != null)criteria.andCidEqualTo(item.getCid());criteria.andStatusNotEqualTo(Byte.valueOf("3"));List<TbItem> list = tbItemMapper.selectByExample(example);// 获取分页信息PageInfo<TbItem> pageInfo = new PageInfo<>(list);// 封装数据resultData.setRows(list);resultData.setTotal(pageInfo.getTotal());resultData.setPageSize(pageInfo.getPageSize());resultData.setPageNum(pageInfo.getPageNum());resultData.setPages(pageInfo.getPages());} catch (Exception e){e.printStackTrace();}return resultData;}@Transactional@Overridepublic AiyouResultData addTbItem(TbItem item, String itemDesc){// 获取生成商品IDfinal long itemId = IDUtils.genItemId();// 初始化系统时间Date date = new Date();// 补全商品信息item.setId(itemId);item.setStatus(TbConstant.TB_ITEM_STATUS_RESHELF);item.setCreated(date);item.setUpdated(date);// 初始化 TbItemDesc 对象TbItemDesc tbItemDesc = new TbItemDesc();// 补全商品描述信息tbItemDesc.setItemId(itemId);tbItemDesc.setItemDesc(itemDesc);tbItemDesc.setCreated(date);tbItemDesc.setUpdated(date);try{// 添加商品数据tbItemMapper.insertSelective(item);// 添加商品描述tbItemDescMapper.insertSelective(tbItemDesc);// 同步更新索引库jmsTemplate.send(itemTopicDestination, new MessageCreator(){@Overridepublic Message createMessage(Session session) throws JMSException{TextMessage textMessage = session.createTextMessage(String.valueOf(String.valueOf(itemId)));return textMessage;}});} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "添加商品失败");}return AiyouResultData.ok();}@Transactionalprivate void optByTbItemId(String ids, Byte status) throws Exception{String[] idStrings = ids.split(",");for (int i = 0; i < idStrings.length; i++){// 在一般的实际应用中,都是进行的是逻辑操作TbItem tbItem = tbItemMapper.selectByPrimaryKey(Long.valueOf(idStrings[i]));tbItem.setStatus(status);tbItemMapper.updateByPrimaryKey(tbItem);// 同步更新索引库// TODO}}@Transactional@Overridepublic AiyouResultData deleteTbItem(String ids){try{optByTbItemId(ids, TbConstant.TB_ITEM_STATUS_DELETE);} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "商品删除异常");}return AiyouResultData.ok();}@Overridepublic AiyouResultData instockTbItem(String ids){try{optByTbItemId(ids, TbConstant.TB_ITEM_STATUS_INSTOCK);} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "商品下架异常");}return AiyouResultData.ok();}@Overridepublic AiyouResultData reshelfTbItem(String ids){try{optByTbItemId(ids, TbConstant.TB_ITEM_STATUS_RESHELF);} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "商品上架异常");}return AiyouResultData.ok();}@Overridepublic AiyouResultData findTbItemById(Long itemId){TbItem tbItem;try{tbItem = tbItemMapper.selectByPrimaryKey(itemId);} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "商品信息查询异常");}return AiyouResultData.ok(tbItem);}@Transactional@Overridepublic AiyouResultData updateTbItem(TbItem item, String desc){try{// 修改商品信息TbItem tbItem = tbItemMapper.selectByPrimaryKey(item.getId());// 补全信息Date date = new Date();tbItem.setCid(item.getCid());tbItem.setTitle(item.getTitle());tbItem.setSellPoint(item.getSellPoint());tbItem.setPrice(item.getPrice());tbItem.setNum(item.getNum());tbItem.setBarcode(item.getBarcode());tbItem.setImage(item.getImage());tbItem.setUpdated(date);tbItemMapper.updateByPrimaryKey(tbItem);// 修改商品描述TbItemDesc tbItemDesc = tbItemDescMapper.selectByPrimaryKey(item.getId());// 补全信息tbItemDesc.setItemDesc(desc);tbItemDesc.setUpdated(date);tbItemDescMapper.updateByPrimaryKeyWithBLOBs(tbItemDesc);// 同步更新索引库// TODO} catch (Exception e){e.printStackTrace();return AiyouResultData.build(-1, "修改商品信息异常");}return AiyouResultData.ok();}@Overridepublic TbItem getTbItemById(Long itemId){try{// 从缓存中获取数据if (itemId != null){// 获取数据String str = tbJedisClientService.get(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE");if (!StringUtils.isEmpty(str)){// 重置数据的有效时间tbJedisClientService.expire(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE",AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE);// 解析数据并返回TbItem tbItemCache = JsonUtils.jsonToPojo(str, TbItem.class);return tbItemCache;}}} catch (Exception e){e.printStackTrace();}// 从数据库中获取数据TbItem tbItem = tbItemMapper.selectByPrimaryKey(itemId);try{// 新增缓存tbJedisClientService.set(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE",JsonUtils.objectToJson(tbItem));// 设置过期时间tbJedisClientService.expire(AIYOU_TB_SERVICE_ITEM_INFO_KEY + ":" + itemId + ":BASE",AIYOU_TB_SERVICE_ITEM_INFO_KEY_EXPIRE);} catch (Exception e){e.printStackTrace();}return tbItem;}}
补充说明:
本项目中关于键的定义规范说明,举例:
AIYOU_TB_SERVICE_ITEM_INFO_KEY
主题:AIYOU
前缀:TB
服务端/本地:SERVICE/LOCAL
键的具体表示内容/作用:ITEM_INFO_KEY
更多规范:参考 《 Java 工程师开发规范,我看行! 》
九、项目页面最终效果图展示
1、商城后台管理界面效果展示
后台管理系统-菜单栏展示
后台管理系统-新增商品
后台管理系统-商品管理界面展示
后台管理系统-内容分类管理界面展示
后台管理系统-内容管理界面展示
后台管理系统-新增内容界面展示
2、商城门户网站界面效果展示
门户网站-商城首页展示
门户网站-商品搜索页展示
门户网站-商品详情页面展示
门户网站-登录页面展示
门户网站-注册页面展示
十、结束语
技术在不断的进步,要想走技术的这条道路,站稳脚跟,就要保持持续的学习态度,好好学习,天天向上。
————不积跬步,无以至千里;不积小流,无以成江海。
好了,关于 B2C商城项目源码,基于Java开发的高可用分布式B2C商城系统,Java+Spring MVC+Dubbo+Zookeeper+MySQL+Redis+FastDFS+Nginx+Solr 就写到这儿了,如果还有什么疑问或遇到什么问题欢迎扫码提问,也可以给我留言哦,我会一一详细的解答的。
歇后语:“ 共同学习,共同进步 ”,也希望大家多多关注CSND的IT社区。
作 者: | 华 仔 |
联系作者: | who.seek.me@java98k.vip |
来 源: | CSDN (Chinese Software Developer Network) |
原 文: | https://blog.csdn.net/Hello_World_QWP/article/details/106919419 |
版权声明: | 本文为博主原创文章,请在转载时务必注明博文出处! |
B2C商城项目源码,基于Java开发的高可用分布式B2C商城系统,Java+Spring MVC+Dubbo+Zookeeper+MySQL+Redis+FastDFS+Nginx+Solr相关推荐
- thinkphp开发app商城项目源码下载(thinkphp)
thinkphp开发app商城项目源码下载(thinkphp) 本项目由比谷网络团队基于thinkphp 与VUe开发的wap端.app(暂无PC端)的开源商城系统,数年工作大牛开发,如有兴趣可以加群 ...
- 微信小程序宠物商城项目源码来了~
微信小程序蒙服汇项目源码来了~ 微信小程序垃圾分类项目源码来了~ 微信小程序校园社团管理系统项目源码来了~ 团队承接各类小程序定制,需要加微 code_gg_boy .小商城,购物,公司的一些管理,流 ...
- 全民直播时代——直播平台源码基于WebRTC开发实时通信服务
全民直播时代--直播平台源码基于WebRTC开发实时通信服务 摘要 本次分享基于 WEBRTC 技术的实时通信服务的开发经验,希望通过这次分享能让大家对这方面更有兴趣. 什么是互动直播? 互动直播是多 ...
- Struts2增删改查 myeclipse开发文档加项目源码及eclipse开发项目源码
Struts2增删改查 myeclipse开发文档加项目源码及eclipse开发项目源码 git里只有myeclipse开发的项目 文档及项目github下载地址:https://github.com ...
- 项目名称:基于Docker Swarm的高可用Web集群
文章目录 项目名称:基于Docker Swarm的高可用Web集群 网络拓扑图 数据流程图 项目环境:Docker 20.10.3,CentOS 8.2(8台 1核1G),Ansible 2.9.17 ...
- vue商城项目源码_CMS全栈项目之Vue和React篇(下)(含源码)
今天给大家介绍的主要是我们全栈CMS系统的未讲解完的后台部分和前台部分,如果对项目背景和技术栈不太了解,可以查看我之前的文章 基于nodeJS从0到1实现一个CMS全栈项目(上) 基于nodeJS从0 ...
- 手把手教你调试构建一个Vue/小程序商城项目源码
下面将详细的介绍weiphp5.0商城项目的调试打包上线的流程: 安装NodeJs/NPM 安装CNPM(可忽略) 运行项目 打包上线项目 1. 安装NodeJs 推荐到NodeJS的官网下载安装包 ...
- 批量删除微信好友,清粉源码,基于autojs开发的免root自动化脚本
说明 本文提供的代码仅供参考.不建议用于生产环境. 可能有些地方在最新版本的Auto.js上面需要做修改,才能运行. Auto.js简介 Auto.js是利用安卓系统的"辅助功能" ...
- 移动商城html 源码,基于weui的移动商城html5模板
[实例简介] 基于weui开发的一整套移动端商城,包括首页,购物车,订单管理,评价,分类,会员中心等 [实例截图] [核心代码] web └── web ├── add_card.html ├── a ...
最新文章
- matlab常见用法汇总,包括绘制二维、三维曲线、圆、读取、保存图片/数据、数值精度、绘制圆、绘制角度等
- Spring 数据访问那些事儿(一)spring + jdbc
- Windows窗口分析
- 【Python】1054 求平均值(Python异常处理练习)
- 【完美解决】Could not process result for mapping: ResultMapping{property=‘null‘, column=‘xxx‘, javaType=
- TC SRM 593 DIV2 1000
- 在恰当的地方使用MongoDB的WriteConcern.SAFE参数
- 最详细的企业级可视化大屏教程,90%的需求看这一篇就足够了
- 优化浏览器默认scroll样式小技巧
- 中国移动全球通寻宝第四期攻略
- java中打开特定编码的文本_指定编码写入和读取文件内容
- 四轮驱动(SSMR)移动机器人运动模型及应用分析
- 对Javascript异步执行的理解
- 图像复原——维纳滤波
- 关于网站mdb数据库管理员MD5密码解密
- python获取鼠标指针坐标_JS获取鼠标指针的位置(坐标)
- sumo学习——sumo的路网介绍
- Mysql按天数据统计
- 迅雷推阅读产品 市场容不下生力军
- Canvas实用库收藏
热门文章
- 有了这家公司,谁还去餐馆吃饭
- Android 拍摄(横 \ 竖屏)视频的懒人之路
- 移动端判断手机横竖屏状态及加载相应样式或内容的解决方案
- 0xc0000225无法进系统_U盘装win10后无法进系统错误代码0xc0000225怎么修复
- 如何恢复计算机我的电脑工具栏,电脑任务栏怎么还原 电脑任务栏的还原方法...
- 校园网络设备巡检的准备工作
- 《Python自然语言处理》——1.1 语言计算:文本和词汇
- Taven教授:解决失眠的好办法
- android 照片变油画,最近很火照片变油画Glaze软件
- 修己,以清心为要。涉世,以慎言为先。