ZZJ_淘淘商城项目:day03(淘淘商城02 - 后台系统功能实现)
阅读原文时间:2023年07月12日阅读:3

1.   今日大纲

1、  学习Nginx的使用

2、  实现商品的管理

a)       新增商品

b)       查询商品列表

c)       编辑商品

d)       删除商品

e)       上架和下架商品


SwitchHosts!_win_x64_3.5.0(5486)

https://oldj.github.io/SwitchHosts/

使用SwitchHosts!修改本地hosts文件,实现ip地址和域名的解析。

Win10系统的hosts目录为:

C:\Windows\System32\drivers\etc

Linux下的hosts文件所在路径: /etc/hosts

# taotao2016 开发环境
127.0.0.1 www.taotao.com
127.0.0.1 manage.taotao.com
127.0.0.1 image.taotao.com

修改配置conf/nginx.conf

#user nobody;
worker_processes ;

#error_log logs/error.log;
#error_log logs/error.log notice;
#error_log logs/error.log info;

#pid logs/nginx.pid;

events {
worker_connections ;
}

http {
include mime.types;
default_type application/octet-stream;

sendfile        on;

keepalive\_timeout  ;

gzip  on;

server {  
    listen       ;  
    server\_name  manage.taotao.com;

    #charset koi8-r;

    proxy\_set\_header X-Forwarded-Host $host;  
    proxy\_set\_header X-Forwarded-Server $host;  
    proxy\_set\_header X-Forwarded-For $proxy\_add\_x\_forwarded\_for;

    location / {  
        proxy\_pass http://127.0.0.1:8081;  
        proxy\_connect\_timeout ;  
        proxy\_read\_timeout ;  
    }  
}  
server {  
    listen       ;  
    server\_name  image.taotao.com;

    #charset koi8-r;

    proxy\_set\_header X-Forwarded-Host $host;  
    proxy\_set\_header X-Forwarded-Server $host;  
    proxy\_set\_header X-Forwarded-For $proxy\_add\_x\_forwarded\_for;

    location / {  
        root  F:\\\\javaweb\\\\taotao-upload;  
    }  
}  

}

taotao2016.conf

使用nginx实现反向代理监听端口

Shift+鼠标右键启动Powershell
ls
F:\javaweb\nginx-1.16.

#powershell启动和关闭nginx.exe服务

.\nginx -c conf\taotao2016.conf

.\nginx -s stop

.\nginx -s reload


Spring4.3.25版本集成使用通用Mapper,可以使用泛型注入的新特性。

package com.taotao.manage.service;

import java.util.Date;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.taotao.manage.pojo.BasePojo;

import tk.mybatis.mapper.common.Mapper;
import tk.mybatis.mapper.entity.Example;

public abstract class BaseService {
/**
* 方法:
1、 queryById
2、 queryAll
3、 queryOne
4、 queryListByWhere
5、 queryPageListByWhere
6、 save
7、 update
8、 deleteById
9、 deleteByIds
10、 deleteByWhere
*/

// public abstract Mapper<T> getMapper();  
// spring4.3.25支持泛型注入新特性  
@Autowired  
private Mapper<T> mapper;

/\*\*  
 \* 根据id查询数据  
 \* @param id  
 \* @return  
 \*/  
public T queryById(Long id) {  
    return this.mapper.selectByPrimaryKey(id);  
}  
/\*\*  
 \* 查询所有数据  
 \* @return  
 \*/  
public List<T> queryAll(){  
    return this.mapper.selectAll();  
}  
/\*\*  
 \* 根据条件查询一条数据  
 \* 如果该条件所查询的数据为多条会抛出异常  
 \* @param record  
 \* @return  
 \*/  
public T queryOne(T record) {  
    return this.mapper.selectOne(record);  
}  
/\*\*  
 \* 根据条件查询多条数据  
 \* @param record  
 \* @return  
 \*/  
public List<T> queryListByWhere(T record){  
    return this.mapper.select(record);  
}  
/\*\*  
 \* 根据条件分页查询数据  
 \* @param record  
 \* @param pageNum  
 \* @param pageSize  
 \* @return  
 \*/  
public PageInfo<T> queryPageListByWhere(T record,Integer pageNum,Integer pageSize){  
    //设置分页参数  
    PageHelper.startPage(pageNum, pageSize);  
    List<T> list = this.mapper.select(record);  
    return new PageInfo<T>(list);  
}  
/\*\*  
 \* 新增数据,未设置的值为null  
 \* @param t  
 \* @return  
 \*/  
public Integer save(T t) {

    t.setCreated(new Date());  
    t.setUpdated(t.getCreated());  
    return this.mapper.insert(t);  
}  
/\*\*  
 \* 选择不为null的字段作为插入更新数据  
 \* @param t  
 \* @return  
 \*/  
public Integer saveSelective(T t) {  
    t.setCreated(new Date());  
    t.setUpdated(t.getCreated());  
    return this.mapper.insertSelective(t);  
}

/\*\*  
 \* 更新数据,未设置的字段值为null  
 \* @param t  
 \* @return  
 \*/  
public Integer update(T id) {  
    id.setUpdated(new Date());  
    return this.mapper.updateByPrimaryKey(id);  
}  
/\*\*  
 \* 更新不为null的字段作为更新的字段  
 \* @param t  
 \* @return  
 \*/  
public Integer updateSelective(T id) {  
    id.setUpdated(new Date());  
    id.setCreated(null); //强制设置创建时间为null,永远不会被更新  
    return this.mapper.updateByPrimaryKeySelective(id);  
}

/\*\*  
 \* 根据主键id删除数据(物理删除)  
 \* @param id  
 \* @return  
 \*/  
public Integer deleteById(Long id) {  
    return this.mapper.deleteByPrimaryKey(id);  
}  
/\*\*  
 \* 根据主键ids批量删除数据(物理删除)  
 \* @param ids  
 \* @param clazz  
 \* @param property  
 \* @return  
 \*/  
public Integer deleteByIds(List<Object> ids ,Class<T> clazz,String property) {  
    Example example = new Example(clazz);  
    //设置条件,andIn(数据库字段,12345)  
    example.createCriteria().andIn(property, ids);  
    return this.mapper.deleteByExample(example);  
}  
/\*\*  
 \* 根据条件删除数据  
 \* @param record  
 \* @return  
 \*/  
public Integer  deleteByWhere(T record) {  
    return this.mapper.delete(record);  
}  

}

public abstract class BaseService

mysql数据库的bigint类型对应JAVA中的Long

item-add.jps的第115行修改restful风格的ajax请求:

    //提交到后台的RESTful  
    $.ajax({  
       type: "POST",  
       url: "/rest/item",  
       data: $("#itemAddForm").serialize(),  
        statusCode: {  
              201: function() {  
              $.messager.alert('提示','新增商品成功!');  
              },  
              400: function() {  
              $.messager.alert('提示','提交的参数不合法!');  
              },  
              500: function() {  
              $.messager.alert('提示','新增商品失败!');  
              }  
       }  
    });

通过日志查看操作Item表和ItemDesc表,由于在Service层的:同一个类、同一个方法,并且已经配置好了spring的AOP管理事务。

信息: Starting ProtocolHandler ["http-bio-8081"]
-- ::, [http-bio--exec-] [com.alibaba.druid.pool.DruidDataSource]-[INFO] {dataSource-} inited
-- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Creating a new SqlSession
-- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Registering transaction synchronization for SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4]
-- ::, [http-bio--exec-] [org.mybatis.spring.transaction.SpringManagedTransaction]-[DEBUG] JDBC Connection [com.mysql.jdbc.JDBC4Connection@1e0b3b6e] will be managed by Spring
-- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemMapper.insert]-[DEBUG] ==> Preparing: INSERT INTO tb_item ( created,updated,id,title,sell_point,price,num,barcode,image,cid,status ) VALUES( ?,?,?,?,?,?,?,?,?,?,? )
-- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemMapper.insert]-[DEBUG] ==> Parameters: -- ::59.17(Timestamp), -- ::59.17(Timestamp), null, Z7(String), 970M(String), (Long), (Integer), (String), (String), (Long), (Integer)
-- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemMapper.insert]-[DEBUG] <== Updates: -- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemMapper.insert!selectKey]-[DEBUG] ==> Executing: SELECT LAST_INSERT_ID()
-- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemMapper.insert!selectKey]-[DEBUG] <== Total: -- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4] -- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Fetched SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4] from current transaction -- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemDescMapper.insert]-[DEBUG] ==> Preparing: INSERT INTO tb_item_desc ( created,updated,item_id,item_desc ) VALUES( ?,?,?,? )
-- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemDescMapper.insert]-[DEBUG] ==> Parameters: -- ::59.332(Timestamp), -- ::59.332(Timestamp), (Long), qq(String)
-- ::, [http-bio--exec-] [com.taotao.manage.mapper.ItemDescMapper.insert]-[DEBUG] <== Updates:
-- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Releasing transactional SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4]
-- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Transaction synchronization committing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4]
-- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Transaction synchronization deregistering SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4]
-- ::, [http-bio--exec-] [org.mybatis.spring.SqlSessionUtils]-[DEBUG] Transaction synchronization closing SqlSession [org.apache.ibatis.session.defaults.DefaultSqlSession@4be7a5c4]

1.导入 commons-fileupload 的依赖坐标

    <!-- 文件上传组件 -->  
    <dependency>  
        <groupId>commons-fileupload</groupId>  
        <artifactId>commons-fileupload</artifactId>  
    </dependency>

2.配置文件上传解析器在springmvc.xml

<!-- 定义文件上传解析器 -->  
<bean id="multipartResolver"  
    class="org.springframework.web.multipart.commons.CommonsMultipartResolver">  
    <!-- 设定默认编码 -->  
    <property name="defaultEncoding" value="UTF-8"></property>  
    <!-- 设定文件上传的最大值5MB,5\*1024\*1024 -->  
    <property name="maxUploadSize" value="5242880"></property>  
</bean>

3.PicUploadController使用了配置文件中的路径,读取配置文件用Service层spring父容器的一个“读取配置文件的类” 的 public关键字修饰的成员属性

package com.taotao.manage.controller;

import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;
import java.util.Date;

import javax.imageio.ImageIO;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.lang3.RandomUtils;
import org.apache.commons.lang3.StringUtils;
import org.joda.time.DateTime;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.taotao.common.bean.PicUploadResult;
import com.taotao.manage.service.PropertieService;

/**
* 图片上传
*/
@Controller
@RequestMapping("/pic")
public class PicUploadController {

    //创建日志对象  
private static final Logger LOGGER = LoggerFactory.getLogger(PicUploadController.class);

@Autowired  
private PropertieService propertieService;

private static final ObjectMapper mapper = new ObjectMapper();

// 允许上传的格式  
private static final String\[\] IMAGE\_TYPE = new String\[\] { ".bmp", ".jpg", ".jpeg", ".gif", ".png" };

@PostMapping(value = "/upload", produces = MediaType.TEXT\_PLAIN\_VALUE)  
@ResponseBody  
public String upload(@RequestParam("uploadFile") MultipartFile uploadFile , HttpServletResponse response) throws Exception {

    // 校验图片格式  
    boolean isLegal = false;  
    for (String type : IMAGE\_TYPE) {  
                //忽略大小写比较字符串的末尾  
        if (StringUtils.endsWithIgnoreCase(uploadFile.getOriginalFilename(), type)) {  
            isLegal = true;  
            break;  
        }  
    }

    // 封装Result对象,并且将文件的byte数组放置到result对象中  
    PicUploadResult fileUploadResult = new PicUploadResult();

    // 状态  
    fileUploadResult.setError(isLegal ? 0 : 1);

    // 文件新路径  
    String filePath = getFilePath(uploadFile.getOriginalFilename());

    if (LOGGER.isDebugEnabled()) {  
        LOGGER.debug("Pic file upload .\[{}\] to \[{}\] .", uploadFile.getOriginalFilename(), filePath);  
    }

    // 生成图片的绝对引用地址  
    String picUrl = StringUtils.replace(StringUtils.substringAfter(filePath, propertieService.REPOSITORY\_PATH), "\\\\", "/");  
    fileUploadResult.setUrl(propertieService.IMAGE\_BASE\_URL + picUrl);

    File newFile = new File(filePath);

    // 写文件到磁盘  
    uploadFile.transferTo(newFile);

    // 校验图片是否合法  
    isLegal = false;  
    try {  
        BufferedImage image = ImageIO.read(newFile);  
        if (image != null) {  
            fileUploadResult.setWidth(image.getWidth() + "");  
            fileUploadResult.setHeight(image.getHeight() + "");  
            isLegal = true;  
        }  
    } catch (IOException e) {  
    }

    // 状态  
    fileUploadResult.setError(isLegal ? 0 : 1);

    if (!isLegal) {  
        // 不合法,将磁盘上的文件删除  
        newFile.delete();  
    }

    response.setContentType(MediaType.TEXT\_HTML\_VALUE);  
    //将java对象序列化成json数据  
    return mapper.writeValueAsString(fileUploadResult);  
}

private String getFilePath(String sourceFileName) {  
    String baseFolder = propertieService.REPOSITORY\_PATH + File.separator + "images";  
    Date nowDate = new Date();  
    // yyyy/MM/dd  
    String fileFolder = baseFolder + File.separator + new DateTime(nowDate).toString("yyyy") + File.separator + new DateTime(nowDate).toString("MM") + File.separator  
            + new DateTime(nowDate).toString("dd");  
    File file = new File(fileFolder);  
    if (!file.isDirectory()) {  
        // 如果目录不存在,则创建目录  
        file.mkdirs();  
    }  
    // 生成新的文件名  
    String fileName = new DateTime(nowDate).toString("yyyyMMddhhmmssSSSS") + RandomUtils.nextInt(100, 9999) + "." + StringUtils.substringAfterLast(sourceFileName, ".");  
    return fileFolder + File.separator + fileName;  
}

}

Spring容器  --  父容器

SpringMVC容器  -- 子容器

父子容器的关系:

1、  子容器能够访问父容器的资源(bean)

a)       示例:Controller可以注入Service

2、  父容器不能访问子容器的资源(bean)

package com.taotao.manage.service;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

@Service
public class PropertieService {
// 加载spring父容器中配置文件内容
@Value("${REPOSITORY_PATH}")
public String REPOSITORY_PATH;

@Value("${IMAGE\_BASE\_URL}")  
public String IMAGE\_BASE\_URL;  

}

对文件做校验:

1、 类型,通过文件的后缀名

2、 大小

3、 上传文件的内容做校验

 a)   通过获取文件的宽和高来判断是否是图片

7.   日志的书写

总结:

1、  方法的入参处需要将参数打印出

2、  业务执行的状态发生变化时,需要打印

3、  异常处需要打印


6.   查询商品列表

EasyUI的datagrid的格式化输出。

默认情况下,会直接显示返回的数据,但是有些情况下不能直接显示,如:价格、日期、性别,需要指定formatter函数。

@Service
public class ItemListService extends BaseService {

@Autowired  
ItemMapper itemMapper;

//根据商品更新时间降序排序  
public EasyUIResult queryItemList(Integer page, Integer rows) {  
    //第三个参数:是否count查询  
    PageHelper.startPage(page, rows, true);

    //设置查询条件  
    Example example = new Example(Item.class);  
    example.setOrderByClause("updated DESC");  
    List<Item> list = itemMapper.selectByExample(example);

    PageInfo<Item> pageInfo = new PageInfo<>(list);  
    // 返回给视图层一个包装好的EasyUIResult对象  
    return new EasyUIResult(pageInfo.getTotal(), pageInfo.getList());  
}

}

=====================================

end