淘淘商城第三天

浅浅的花香味﹌ 2022-05-31 13:12 178阅读 0赞

# 淘淘商城NO.3 #

> ## 1. 商品类目选择 ##

### 1.1 功能分析 ###

展示商品分类列表，使用EasyUI的tree控件展示。  
初始化tree请求的url：/item/cat/list  
参数：  
初始化tree时只需要把第一级节点展示，子节点异步加载。  
返回值：json。数据格式

[{    
        "id": 1,    
        "text": "Node 1",    
        "state": "closed" },{    
        "id": 2,    
        "text": "Node 2",    
        "state": "closed" }]

state：如果节点下有子节点“closed”，如果没有子节点“open”  
创建一个pojo来描述tree的节点信息，包含三个属性id、text、state。放到taotao-common工程中。

### 1.2 创建pojo类 ###

###### taotao\\taotao-common\\src\\main\\java\\com\\taotao\\common\\pojo\\EasyUITreeNode.java ######

public class EasyUITreeNode implements Serializable { 
        private long id;
        private String text;
        private String state;
    
        public long getId() {
            return id;
        }
    
        public void setId(long id) {
            this.id = id;
        }
    
        public String getText() {
            return text;
        }
    
        public void setText(String text) {
            this.text = text;
        }
    
        public String getState() {
            return state;
        }
    
        public void setState(String state) {
            this.state = state;
        }
    }

查询的表：tb\_item\_cat  
查询列：Id、name、isparent  
查询条件parentId

### 1.3 业务层 ###

参数：long parentId  
业务逻辑：  
\- 1、根据parentId查询节点列表  
\- 2、转换成EasyUITreeNode列表。  
\- 3、返回

返回值：List

#### 1.3.1 接口 ####

###### taotao\\taotao-manager\\taotao-manager-interface\\src\\main\\java\\com\\taotao\\service\\TbItemCatServiceI.java ######

public interface TbItemCatServiceI {
 List<EasyUITreeNode> getItemCatList(long parentId);
 }

#### 1.3.2 实现类 ####

###### taotao\\taotao-manager\\taotao-manager-service\\src\\main\\java\\com\\taotao\\service\\impl\\TbItemServiceImpl.java ######

@Service
 public class TbItemCatServiceImpl implements TbItemCatServiceI { 
 @Autowired
 private TbItemCatMapper tbItemCatMapper;
 
 @Override
 public List<EasyUITreeNode> getItemCatList(long parentId) {
 //设置查询条件
 TbItemCatExample example = new TbItemCatExample();
 //根据parentId查询节点列表
 example.createCriteria().andParentIdEqualTo(parentId);
 List<TbItemCat> tbItemCats = tbItemCatMapper.selectByExample(example);
 //转换成EasyUITreeNode列表
 List<EasyUITreeNode> treeNodes = new ArrayList<>();
 for (TbItemCat list : tbItemCats) {
 EasyUITreeNode easyUITreeNode = new EasyUITreeNode();
 easyUITreeNode.setId(list.getId());
 easyUITreeNode.setText(list.getName());
 easyUITreeNode.setState(list.getIsParent() ? "closed" : "open");
 //添加到列表
 treeNodes.add(easyUITreeNode);
 }
 //返回
 return treeNodes;
 }
 }

#### 1.3.3 发布服务 ####

###### taotao\\taotao-manager\\taotao-manager-service\\src\\main\\resources\\spring\\appicationContext-service.xml ######

<dubbo:service interface="com.taotao.service.TbItemCatServiceI" ref="tbItemCatServiceImpl" timeout="300000"/>

### 1.4 表现层 ###

#### 1.4.1 引用服务 ####

###### taotao\\taotao-manager-web\\src\\main\\resources\\spring\\springmvc.xml ######

<dubbo:reference interface="com.taotao.service.TbItemCatServiceI" id="itemCatServiceI"/>

#### 1.4.2 Controller ####

###### taotao\\taotao-manager-web\\src\\main\\java\\com\\taotao\\controller\\TbItemCatController.java ######

@Controller
 public class TbItemCatController { 
 @Autowired
 private TbItemCatServiceI tbItemCatServiceI;
 
 @RequestMapping("/item/cat/list")
 @ResponseBody
 public List<EasyUITreeNode> getItemCatList(@RequestParam(value = "id",defaultValue = "0") long parentId){
 return tbItemCatServiceI.getItemCatList(parentId);
 }
 
 }

> ## 2. 图片服务器的搭建 ##

###### 详情见文档Linux/FastDFS/使用FastDFS搭建图片服务器 ######

[搭建图片服务器](http://blog.csdn.net/tzconn/article/details/79318511)

> ## 3. 图片上传功能 ##

### 3.1 功能分析 ###

使用的是KindEditor的多图片上传插件。  
请求的url：/pic/upload  
参数：MultiPartFile uploadFile  
返回值：JSON格式

业务逻辑：
    1、接收页面传递的图片信息uploadFile
    2、把图片上传到图片服务器。使用封装的工具类实现。需要取文件的内容和扩展名。
    3、图片服务器返回图片的url
    4、将图片的url补充完整，返回一个完整的url。
    5、把返回结果封装到一个Map对象中返回。

*  将fastdfs\_client打成jar包

###### taotao\\fastdfs\_client ######

*  在maven中添加该Jar包的依赖

<dependency>
 <groupId>fastdfs_client</groupId>
 <artifactId>fastdfs_client</artifactId>
 <version>1.25</version>
 </dependency>

*  需要把commons-io、fileupload 的jar包添加到工程中。

<dependency>
 <groupId>commons-fileupload</groupId>
 <artifactId>commons-fileupload</artifactId>
 <version>${commons-fileupload.version}</version>
 </dependency>

*  配置多媒体解析器。

<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
 
 <property name="defaultEncoding" value="UTF-8"></property>
 
 <property name="maxUploadSize" value="5242880"></property>
 </bean>

### 3.2 使用工具类上传 ###

###### taotao\\taotao-manager-web\\src\\main\\java\\com\\taotao\\utils\\FastDFSClient.java ######

public class FastDFSClient { 
 
 private TrackerClient trackerClient = null;
 private TrackerServer trackerServer = null;
 private StorageServer storageServer = null;
 private StorageClient1 storageClient = null;
 
 public FastDFSClient(String conf) throws Exception {
 if (conf.contains("classpath:")) {
 conf = conf.replace("classpath:", this.getClass().getResource("/").getPath());
 conf=conf.replace("%20"," ");
 }
 ClientGlobal.init(conf);
 trackerClient = new TrackerClient();
 trackerServer = trackerClient.getConnection();
 storageServer = null;
 storageClient = new StorageClient1(trackerServer, storageServer);
 }
 
 /** * 上传文件方法 * Title: uploadFile * Description: * @param fileName 文件全路径 * @param extName 文件扩展名，不包含（.） * @param metas 文件扩展信息 * @return * @throws Exception */
 public String uploadFile(String fileName, String extName, NameValuePair[] metas) throws Exception {
 String result = storageClient.upload_file1(fileName, extName, metas);
 return result;
 }
 
 public String uploadFile(String fileName) throws Exception {
 return uploadFile(fileName, null, null);
 }
 
 public String uploadFile(String fileName, String extName) throws Exception {
 return uploadFile(fileName, extName, null);
 }
 
 /** * 上传文件方法 * Title: uploadFile * Description: * @param fileContent 文件的内容，字节数组 * @param extName 文件扩展名 * @param metas 文件扩展信息 * @return * @throws Exception */
 public String uploadFile(byte[] fileContent, String extName, NameValuePair[] metas) throws Exception {
 
 String result = storageClient.upload_file1(fileContent, extName, metas);
 return result;
 }
 
 public String uploadFile(byte[] fileContent) throws Exception {
 return uploadFile(fileContent, null, null);
 }
 
 public String uploadFile(byte[] fileContent, String extName) throws Exception {
 return uploadFile(fileContent, extName, null);
 }
 }

### 3.3 表现层 ###

###### taotao\\taotao-manager-web\\src\\main\\java\\com\\taotao\\controller\\PictureController.java ######

@Controller
 public class PictureController { 
 @Value("${IMAGE_SERVER_URL}")
 private String IMAGE_SERVER_URL;
 
 @RequestMapping("/pic/upload")
 @ResponseBody
 public String picUpload(MultipartFile uploadFile) {
 try {
 //接收上传的文件
 //取扩展名
 String originalFilename = uploadFile.getOriginalFilename();
 String extName = originalFilename.substring(originalFilename.lastIndexOf(".") + 1);
 //上传到图片服务器
 FastDFSClient fastDFSClient = new FastDFSClient("classpath:resource/client.conf");
 String url = fastDFSClient.uploadFile(uploadFile.getBytes(), extName);
 url = IMAGE_SERVER_URL + url;
 //响应上传图片的url
 Map result = new HashMap<>();
 result.put("error", 0);
 result.put("url", url);
 return JsonUtils.objectToJson(result);
 } catch (Exception e) {
 e.printStackTrace();
 Map result = new HashMap<>();
 result.put("error", 1);
 result.put("message", "图片上传失败");
 return JsonUtils.objectToJson(result);
 }
 
 }
 }

> ## 4.商品添加功能实现 ##

### 4.1 功能分析 ###

请求的url：/item/save  
参数：TbItem item,String desc  
返回值:Json数据。

业务逻辑：
    - 生成商品id         UUID，字符串，不推荐使用。
            数值类型，不重复。日期+时间+随机数20160402151333123123
            可以直接去毫秒值+随机数。可以使用。
            使用redis。Incr。推荐使用。
    - 补全TbItem对象的属性 - 向商品表插入数据 - 创建一个TbItemDesc对象 - 补全TbItemDesc的属性 - 向商品描述表插入数据 - TaotaoResult.ok()

### 4.2 功能实现 ###

#### 4.2.1 Dao层 ####

添加公共POJO类TaotaoResult

###### taotao\\taotao-common\\src\\main\\java\\com\\taotao\\common\\pojo\\TaotaoResult.java ######

/** * 淘淘商城自定义响应结构 */
 public class TaotaoResult implements Serializable{ 
 
 // 定义jackson对象
 private static final ObjectMapper MAPPER = new ObjectMapper();
 
 // 响应业务状态
 private Integer status;
 
 // 响应消息
 private String msg;
 
 // 响应中的数据
 private Object data;
 
 public static TaotaoResult build(Integer status, String msg, Object data) {
 return new TaotaoResult(status, msg, data);
 }
 
 public static TaotaoResult ok(Object data) {
 return new TaotaoResult(data);
 }
 
 public static TaotaoResult ok() {
 return new TaotaoResult(null);
 }
 
 public TaotaoResult() {
 
 }
 
 public static TaotaoResult build(Integer status, String msg) {
 return new TaotaoResult(status, msg, null);
 }
 
 public TaotaoResult(Integer status, String msg, Object data) {
 this.status = status;
 this.msg = msg;
 this.data = data;
 }
 
 public TaotaoResult(Object data) {
 this.status = 200;
 this.msg = "OK";
 this.data = data;
 }
 
 // public Boolean isOK() { 
 // return this.status == 200;
 // }
 
 public Integer getStatus() {
 return status;
 }
 
 public void setStatus(Integer status) {
 this.status = status;
 }
 
 public String getMsg() {
 return msg;
 }
 
 public void setMsg(String msg) {
 this.msg = msg;
 }
 
 public Object getData() {
 return data;
 }
 
 public void setData(Object data) {
 this.data = data;
 }
 
 /** * 将json结果集转化为TaotaoResult对象 * * @param jsonData json数据 * @param clazz TaotaoResult中的object类型 * @return */
 public static TaotaoResult formatToPojo(String jsonData, Class<?> clazz) {
 try {
 if (clazz == null) {
 return MAPPER.readValue(jsonData, TaotaoResult.class);
 }
 JsonNode jsonNode = MAPPER.readTree(jsonData);
 JsonNode data = jsonNode.get("data");
 Object obj = null;
 if (clazz != null) {
 if (data.isObject()) {
 obj = MAPPER.readValue(data.traverse(), clazz);
 } else if (data.isTextual()) {
 obj = MAPPER.readValue(data.asText(), clazz);
 }
 }
 return build(jsonNode.get("status").intValue(), jsonNode.get("msg").asText(), obj);
 } catch (Exception e) {
 return null;
 }
 }
 
 /** * 没有object对象的转化 * * @param json * @return */
 public static TaotaoResult format(String json) {
 try {
 return MAPPER.readValue(json, TaotaoResult.class);
 } catch (Exception e) {
 e.printStackTrace();
 }
 return null;
 }
 
 /** * Object是集合转化 * * @param jsonData json数据 * @param clazz 集合中的类型 * @return */
 public static TaotaoResult formatToList(String jsonData, Class<?> clazz) {
 try {
 JsonNode jsonNode = MAPPER.readTree(jsonData);
 JsonNode data = jsonNode.get("data");
 Object obj = null;
 if (data.isArray() && data.size() > 0) {
 obj = MAPPER.readValue(data.traverse(),
 MAPPER.getTypeFactory().constructCollectionType(List.class, clazz));
 }
 return build(jsonNode.get("status").intValue(), jsonNode.get("msg").asText(), obj);
 } catch (Exception e) {
 return null;
 }
 }
 
 }

#### 4.2.2 业务层 ####

使用IDUtils生成商品id所以需要先到taotao.utils下添加IDUtils工具类

/** * 各种id生成策略 * Title: IDUtils * Description: * Company: www.itcast.com * @author Conn * @date 2018年2月23日20:40:03 * @version 1.0 */
 public class IDUtils { 
 
 /** * 图片名生成 */
 public static String genImageName() {
 //取当前时间的长整形值包含毫秒
 long millis = System.currentTimeMillis();
 //long millis = System.nanoTime();
 //加上三位随机数
 Random random = new Random();
 int end3 = random.nextInt(999);
 //如果不足三位前面补0
 String str = millis + String.format("%03d", end3);
 
 return str;
 }
 
 /** * 商品id生成 */
 public static long genItemId() {
 //取当前时间的长整形值包含毫秒
 long millis = System.currentTimeMillis();
 //long millis = System.nanoTime();
 //加上两位随机数
 Random random = new Random();
 int end2 = random.nextInt(99);
 //如果不足两位前面补0
 String str = millis + String.format("%02d", end2);
 long id = new Long(str);
 return id;
 }
 
 public static void main(String[] args) {
 for(int i=0;i< 100;i++)
 System.out.println(genItemId());
 }
 }

###### taotao\\taotao-manager\\taotao-manager-service\\src\\main\\java\\com\\taotao\\service\\impl\\TbItemServiceImpl.java ######

@Override
        public TaotaoResult addItem(TbItem item, TbItemDesc desc) {
            // 1、生成商品id
            long itemId = IDUtils.genItemId();
            // 2、补全TbItem对象的属性
            item.setId(itemId);
            //商品状态，1-正常，2-下架，3-删除
            item.setStatus((byte) 1);
            Date date = new Date();
            item.setCreated(date);
            item.setUpdated(date);
            // 3、向商品表插入数据
            tbItemMapper.insert(item);
    
    
            // 4、创建一个TbItemDesc对象
            TbItemDesc tbItemDesc = new TbItemDesc();
            // 5、补全TbItemDesc的属性
            tbItemDesc.setItemId(itemId);
            tbItemDesc.setCreated(date);
            tbItemDesc.setUpdated(date);
            tbItemDesc.setItemDesc(String.valueOf(desc));
            // 6、向商品描述表插入数据
            tbItemDescMapper.insert(tbItemDesc);
            // 7、TaotaoResult.ok()
            return TaotaoResult.ok();
        }

#### 4.2.3 表现层 ####

###### taotao\\taotao-manager-web\\src\\main\\java\\com\\taotao\\controller\\TbItemController.java ######

@RequestMapping(value = "/item/save",method = RequestMethod.POST)
        @ResponseBody
        public TaotaoResult addItem(TbItem item, TbItemDesc desc){
            return tbItemServiceI.addItem(item,desc);
        }