电商项目总结-低调大师

电商项目总结

2017-03-24 778

最近一段时间刚刚学习了一些新的知识，就想拿个项目练练手，然后就在网上找了一个培训的电商项目练习了一下，做了之后学到了很多，学到了项目的很多流程，在这里总结一下。

一、项目介绍：
网上商城项目，用于建立网上终端、营销案在线销售及相关辅助功能，后台包含商品管理、订单管理、类目管理、客户管理、合作商管理、客服管理、支付平台、内容管理等，很大程度上分担了人工的压力，前台包括个人中心，购物车，商城首页，频道页，商品详情页，提交订单页，支付页面等页面构成，对提高客户服务效率和客户满意度能够起到较好的作用。

二、项目所用技术：
1、Jsp,freemarker,jQuery,css+div,jstl标签，fckEditor, struts-menu
2、Springmvc,spring,mybatis
3、Webservice框架cxf
4、Jersey搭建图片服务器
5、Maven,svn,hudson
6、Oracle

三、开发环境：
1、Eclipse4.3
2、Tomcat7.0
3、Jdk1.7
4、Oracle10g
5、Maven3.1.5
6、Svn
7、hudson

四、系统架构：
这里使用maven进行依赖管理

接下来，我把这里面比较核心的模块分析一下，进行总结，里面包括：

后台：

1、品牌管理：包括简单的增删改查
2、商品管理：里面有一个比较核心的商品添加到前台的功能，主要的业务包括操作商品表、商品大字段表、商品属性表、商品的特殊属性表
3、订单管理：订单的增删改查，商品的上架，商品的发布（通过webService）。

前台：
1、商品的首页展示：通过多表查询进行分页查询显示
2、商品的单品页展示：利用freemaker技术对页面进行静态化处理，在后台进行静态化的发布，这样的好处是查询的时候只需查询一次数据库，静态化之后不需要再查询，大大的提高了系统的效率。
3、购物车：使用cookie技术，好处:用户不需要登录即可操作购物车。
4、订单流程：这里使用工作流activiti，这里对工作流的使用进行了加强。

五、核心模块的总结：

6.1、商品的添加：

操作商品表、商品大字段表、商品属性表、商品的特殊属性表

aaction层：

@RequestMapping("/addItem.do")
    public String addItem(EbItem item, EbItemClob itemClob, HttpServletRequest request,Integer divNum){
        item.setItemNo(new SimpleDateFormat("yyyyMMddHHmmssSSS").format(new Date()));
        List<EbFeature> commList = featureService.selectCommFeature();
        List<EbParaValue> paraList = new ArrayList<EbParaValue>();        for(EbFeature feature: commList){            //获得属性的id也就是普通属性在页面上的name
            Long featureId = feature.getFeatureId();            if(feature.getInputType() == 3){                String [] paraArr = request.getParameterValues(featureId+"");                if(paraArr != null && paraArr.length > 0){                    String paraVals = "";                    for(String val : paraArr){
                        paraVals = paraVals + val + ",";
                    }
                    paraVals = paraVals.substring(0, paraVals.length() - 1);
                    EbParaValue pv = new EbParaValue();
                    pv.setFeatureId(featureId);
                    pv.setParaValue(paraVals);
                    paraList.add(pv);
                }

            }else{                String paraVal = request.getParameter(featureId+"");                if(StringUtils.isNotBlank(paraVal)){
                    EbParaValue pv = new EbParaValue();
                    pv.setFeatureId(featureId);
                    pv.setParaValue(paraVal);
                    paraList.add(pv);
                }
            }
        }
        List<EbSku> skuList = new ArrayList<EbSku>();
        List<EbFeature> specList = featureService.selectSpecFeature();        //skuType1   showStatus1   sort1     skuPrice1  marketPrice1  stockInventory1  skuUpperLimit1  sku1  location1
        //遍历div数量
        for(int i = 1; i <= divNum; i++){            //获得商城价和库存，他们是必填的字段
            String skuPrice = request.getParameter("skuPrice"+i);            String stock = request.getParameter("stockInventory"+i);            //如果上面的必填字段不是空说明数据有效
            if(StringUtils.isNotBlank(skuPrice) && StringUtils.isNotBlank(stock)){                String skuType = request.getParameter("skuType"+i);                String showStatus = request.getParameter("showStatus"+i);                String sort = request.getParameter("sort"+i);                String marketPrice = request.getParameter("marketPrice"+i);                String skuUpperLimit = request.getParameter("skuUpperLimit"+i);                String sku = request.getParameter("sku"+i);                String location = request.getParameter("location"+i);                //创建最小销售单元的对象，并且赋值
                EbSku skuObj = new EbSku();
                skuObj.setSkuPrice(new BigDecimal(skuPrice));
                skuObj.setStockInventory(new Integer(stock));                if(StringUtils.isNotBlank(skuType) && !StringUtils.equals(skuType, "")){
                    skuObj.setSkuType(new Short(skuType));
                }                if(StringUtils.isNotBlank(showStatus) && !StringUtils.equals(showStatus, "")){
                    skuObj.setShowStatus(new Short(showStatus));
                }                if(StringUtils.isNotBlank(sort) && !StringUtils.equals(sort, "")){
                    skuObj.setSkuSort(new Integer(sort));
                }                if(StringUtils.isNotBlank(marketPrice) && !StringUtils.equals(marketPrice, "")){
                    skuObj.setMarketPrice(new BigDecimal(marketPrice));
                }                if(StringUtils.isNotBlank(skuUpperLimit) && !StringUtils.equals(skuUpperLimit, "")){
                    skuObj.setSkuUpperLimit(new Integer(skuUpperLimit));
                }
                skuObj.setSku(sku);
                skuObj.setLocation(location);

                List<EbSpecValue> specValList = new ArrayList<EbSpecValue>();                //获得每个最小销售单元所拥有的规格属性值，
                //遍历规格属性
                for(EbFeature feature : specList){
                    Long featureId = feature.getFeatureId();                    //获得所选规格属性的值
                    String specVal = request.getParameter(featureId+"specradio"+i);                    //创建规格对象
                    EbSpecValue spec = new EbSpecValue();
                    spec.setFeatureId(featureId);
                    spec.setSpecValue(specVal);
                    specValList.add(spec);
                }
                skuObj.setSpecList(specValList);
                skuList.add(skuObj);
            }

        }
        itemService.saveItem(item, itemClob, paraList, skuList);        return "redirect:listItem.do?showStatus=1&auditStatus=1";
    }12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091921234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192

service层：

public void saveItem(EbItem item, EbItemClob itemClob,
            List<EbParaValue> paraList, List<EbSku> skuList) {
        itemDao.saveItem(item);
        paraValueDao.saveParaValue(paraList, item.getItemId());
        itemClobDao.saveItemClob(itemClob, item.getItemId());
        skuDao.saveSku(skuList, item.getItemId());

    }1234567812345678

6.2、商品分页sql

<!-- 

    分页查询的结果集

   -->

  <select id="selectItemByCondition" parameterType="com.rl.ecps.model.QueryCondition" resultMap="BaseResultMap">

  select *

  from (select rownum rw, a.*

          from (

          select * from eb_item t          <where>

            <if test="brandId != null">

                t.brand_id = #{brandId}            </if>

            <if test="auditStatus != null">

                and t.audit_status = #{auditStatus}            </if>

            <if test="showStatus != null">

                and t.show_status = #{showStatus}            </if>

            <if test="itemName != null">

                and t.item_name like '%${itemName}%'            </if>

          </where>

          order by t.item_id desc          <![CDATA[

          ) a

         where rownum < #{endNum}) b

 where b.rw > #{startNum}

 ]]>

  </select>1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575812345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758

6.3、商品的首页查询筛选

6.3.1、sql

<!-- 

    map.put("minPrice", 4000);

    map.put("maxPrice", 4999);

    map.put("brandId", 1003);

    map.put("paraList", String[] paraList)

   -->

  <select id="listItem" parameterType="map" resultMap="listItemRM">

    select min(es.sku_price) sku_price, ei.*

  from eb_item ei, eb_sku es

  <where>

    ei.item_id = es.item_id

    <if test="minPrice != null">        and es.sku_price between #{minPrice} and #{maxPrice}

    </if>

    <if test="brandId != null">         and ei.brand_id = #{brandId}

    </if>

    <if test="paraList != null">

        <foreach collection="paraList" item="paraValue">            and exists (select *

              from eb_para_value t

             where ei.item_id = t.item_id               and t.para_value = #{paraValue})

        </foreach>

    </if>

  </where>

 group by ei.ITEM_ID,

          ei.ITEM_NAME,

          ei.ITEM_NO,

          ei.BRAND_ID,

          ei.CAT_ID,

          ei.TAG_IMG_ID,

          ei.TAG_IMG,

          ei.IS_NEW,

          ei.IS_GOOD,

          ei.IS_HOT,

          ei.PROMOTION,

          ei.AUDIT_STATUS,

          ei.SHOW_STATUS,

          ei.IMGS,

          ei.KEYWORDS,

          ei.PAGE_DESC,

          ei.ITEM_RECYCLE,

          ei.ON_SALE_TIME,

          ei.CHECK_TIME,

          ei.UPDATE_TIME,

          ei.UPDATE_USER_ID,

          ei.CREATE_TIME,

          ei.CHECKER_USER_ID,

          ei.FULL_PATH_DEPLOY,

         ei.FULL_PATH_DEPLOY_OFFER,

          ei.ORIGINAL_ITEM_ID,

          ei.LAST_STATUS,

          ei.MERCHANT_ID,

          ei.ITEM_SORT,

          ei.SALES,

          ei.CREATE_USER_ID,

          ei.SIM_LEVEL,

          ei.GIFT_DESC,

          ei.GIFT_IMG,

          ei.GIFT_SHOW_TYPE,

          ei.IMG_SIZE1

          order by ei.item_id desc

  </select>123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127

7、商品页静态化
主要将jsp改为静态的html页面，利用freemaker语法。

8、购物车
购物车利用cookie存储在浏览器，在后台拿到cookie进行数据操作。

购物车模块：
接口:

/**
     * 查询购物车所有商品
     * @param request 
     * @param response
     * @return
     */
    public List<EbCart> listCart(HttpServletRequest request, HttpServletResponse response);    /**
     * 添加购物车
     * @param request
     * @param response
     * @param skuId 最小销售单元id
     * @param quantity 商品数量
     */
    public void addCart(HttpServletRequest request, HttpServletResponse response, Long skuId, Integer quantity);    /**
     * 根据商品id商品数量加一
     * @param request
     * @param response
     * @param skuId 最小销售单元id
     */
    public void addNum(HttpServletRequest request, HttpServletResponse response, Long skuId);    /**
     * 根据商品id商品数量减一
     * @param request
     * @param response
     * @param skuId 最小销售单元id
     */
    public void reduceNum(HttpServletRequest request, HttpServletResponse response, Long skuId);    public void deleteCart(HttpServletRequest request, HttpServletResponse response, Long skuId);    public void clearCart(HttpServletRequest request, HttpServletResponse response);    public String validCookie(HttpServletRequest request, HttpServletResponse response);    public String validCar(HttpServletRequest request, HttpServletResponse response);1234567891011121314151617181920212223242526272829303132333435363738394012345678910111213141516171819202122232425262728293031323334353637383940

实现类：

public List<EbCart> listCart(HttpServletRequest request,
            HttpServletResponse response) {
        List<EbCart> cartList = new ArrayList<EbCart>();        //获取浏览器所有cookie
        Cookie[] cookies = request.getCookies();        //[{skuId:1,quantity:2},{}]
        if(cookies != null && cookies.length > 0){            for (Cookie cookie : cookies) {                String code = ECPSUtils.readProp("cookie_ecps_code");                String name = cookie.getName();                if(StringUtils.equals(name, code)){                    String result = cookie.getValue();                    //对其进行解码，防止中文乱码
                    result = URLDecoder.decode(result);
                    JSONArray ja = JSONArray.fromObject(result);
                    JsonConfig jc = new JsonConfig();                    //设置要转换的类
                    jc.setRootClass(EbCart.class);                    //排除类里面的属性
                    jc.setExcludes(new String[]{"sku"});
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);                    //根据skuid设置购物车对象的EbSku对象
                    for (EbCart cart : cartList) {
                        EbSku sku = skuDao.getSkuDetailById(cart.getSkuId());
                        cart.setSku(sku);
                    }
                }
            }
        }        return cartList;
    }

    public void addCart(HttpServletRequest request,
            HttpServletResponse response, Long skuId, Integer quantity) {
        List<EbCart> cartList = new ArrayList<EbCart>();        //json的配置对象
        JsonConfig jc = new JsonConfig();        //设置要转换的类
        jc.setRootClass(EbCart.class);        //设置不需要转换的属性
        jc.setExcludes(new String[]{"sku"});
        Cookie[] cookies = request.getCookies();        if(cookies != null&&cookies.length > 0){            for(Cookie cookie : cookies){                String name = cookie.getName();                String cookieKey = ECPSUtils.readProp("cookie_ecps_code");                if(StringUtils.equals(name, cookieKey)){                    //获得cookie的值
                    String result = cookie.getValue();                    //[{skuId:1002, quantity:2}, {skuId:1003, quantity:3},....]
                    result = URLDecoder.decode(result);                    //把json格式的字符串转换成json数组对象
                    JSONArray ja = JSONArray.fromObject(result);                    //把json的数组转换成java集合
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);

                    boolean isExsits = false;                    //1.如果存在对应商品，则在基础上数量加一
                    for(EbCart cart: cartList){                        if(cart.getSkuId().longValue() == skuId.longValue()){
                            cart.setQuantity(cart.getQuantity() + quantity);
                            isExsits = true;
                        }
                    }                    //2.如果不存在，则创建新的对象
                    if(!isExsits){
                        EbCart cartObj = new EbCart();
                        cartObj.setSkuId(skuId);
                        cartObj.setQuantity(quantity);
                        cartList.add(cartObj);
                    }

                }
            }
        }        //3.如果没有创建过cookie对象，则创建
        if(cartList.size() == 0){
            EbCart cartObj = new EbCart();
            cartObj.setSkuId(skuId);
            cartObj.setQuantity(quantity);
            cartList.add(cartObj);
        }        //将java对象再次转换为字符串存到cookie中
        JSONArray ja = JSONArray.fromObject(cartList, jc);        String result = ja.toString();
        result = URLEncoder.encode(result);
        Cookie cookie = new Cookie("cookie_ecps_code", result);
        cookie.setMaxAge(Integer.MAX_VALUE);
        cookie.setPath("/");
        response.addCookie(cookie);
    }

    public void addNum(HttpServletRequest request,
            HttpServletResponse response, Long skuId) {
        List<EbCart> cartList = new ArrayList<EbCart>();        //json的配置对象
        JsonConfig jc = new JsonConfig();        //设置要转换的类
        jc.setRootClass(EbCart.class);        //设置不需要转换的属性
        jc.setExcludes(new String[]{"sku"});
        Cookie[] cookies = request.getCookies();        if(cookies != null&&cookies.length > 0){            for(Cookie cookie : cookies){                String name = cookie.getName();                String cookieKey = ECPSUtils.readProp("cookie_ecps_code");                if(StringUtils.equals(name, cookieKey)){                    //获得cookie的值
                    String result = cookie.getValue();                    //[{skuId:1002, quantity:2}, {skuId:1003, quantity:3},....]
                    result = URLDecoder.decode(result);                    //把json格式的字符串转换成json数组对象
                    JSONArray ja = JSONArray.fromObject(result);                    //把json的数组转换成java集合
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);                    for(EbCart cart: cartList){                        if(cart.getSkuId().longValue() == skuId.longValue()){
                            cart.setQuantity(cart.getQuantity() + 1);
                        }
                    }

                }
            }
        }        //将java对象再次转换为字符串存到cookie中
        JSONArray ja = JSONArray.fromObject(cartList, jc);        String result = ja.toString();
        result = URLEncoder.encode(result);
        Cookie cookie = new Cookie("cookie_ecps_code", result);
        cookie.setMaxAge(Integer.MAX_VALUE);
        cookie.setPath("/");
        response.addCookie(cookie);
    }

    @SuppressWarnings("deprecation")
    public void reduceNum(HttpServletRequest request,
            HttpServletResponse response, Long skuId) {
        List<EbCart> cartList = new ArrayList<EbCart>();
        Cookie[] cookies = request.getCookies();
        JsonConfig jc = new JsonConfig();
        jc.setRootClass(EbCart.class);
        jc.setExcludes(new String[]{"sku"});        if(cookies != null && cookies.length > 0){            for (Cookie cookie : cookies) {                String name = cookie.getName();                String code = ECPSUtils.readProp("cookie_ecps_code");                if(StringUtils.equals(name, code)){                    String result = cookie.getValue();                    //将html编码解码
                    result = URLDecoder.decode(result);
                    JSONArray ja = JSONArray.fromObject(result);
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);                    for(EbCart cart : cartList){                        if(cart.getSkuId().longValue() == skuId.longValue()){
                            cart.setQuantity(cart.getQuantity() - 1);
                        }
                    }
                }
            }
        }        //将java对象再次转换为字符串存到cookie中
        JSONArray ja = JSONArray.fromObject(cartList, jc);        String result = ja.toString();
        result = URLEncoder.encode(result);
        Cookie cookie = new Cookie("cookie_ecps_code", result);
        cookie.setMaxAge(Integer.MAX_VALUE);
        cookie.setPath("/");
        response.addCookie(cookie);
    }

    public void deleteCart(HttpServletRequest request,
            HttpServletResponse response, Long skuId) {
        List<EbCart> cartList = new ArrayList<EbCart>();        //json的配置对象
        JsonConfig jc = new JsonConfig();        //设置要转换的类
        jc.setRootClass(EbCart.class);        //设置不需要转换的属性
        jc.setExcludes(new String[]{"sku"});
        Cookie[] cookies = request.getCookies();        if(cookies != null&&cookies.length > 0){            for(Cookie cookie : cookies){                String name = cookie.getName();                String cookieKey = ECPSUtils.readProp("cookie_ecps_code");                if(StringUtils.equals(name, cookieKey)){                    //获得cookie的值
                    String result = cookie.getValue();                    //[{skuId:1002, quantity:2}, {skuId:1003, quantity:3},....]
                    result = URLDecoder.decode(result);                    //把json格式的字符串转换成json数组对象
                    JSONArray ja = JSONArray.fromObject(result);                    //把json的数组转换成java集合
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);                    for(EbCart cart: cartList){                        if(cart.getSkuId().longValue() == skuId.longValue()){
                            cartList.remove(cart);
                        }
                    }

                }
            }
        }        //将java对象再次转换为字符串存到cookie中
        JSONArray ja = JSONArray.fromObject(cartList, jc);        String result = ja.toString();
        result = URLEncoder.encode(result);
        Cookie cookie = new Cookie("cookie_ecps_code", result);
        cookie.setMaxAge(Integer.MAX_VALUE);
        cookie.setPath("/");
        response.addCookie(cookie);
    }

    public void clearCart(HttpServletRequest request,
            HttpServletResponse response) {
        List<EbCart> cartList = new ArrayList<EbCart>();        //json的配置对象
        JsonConfig jc = new JsonConfig();        //设置要转换的类
        jc.setRootClass(EbCart.class);        //设置不需要转换的属性
        jc.setExcludes(new String[]{"sku"});
        Cookie[] cookies = request.getCookies();        if(cookies != null&&cookies.length > 0){            for(Cookie cookie : cookies){                String name = cookie.getName();                String cookieKey = ECPSUtils.readProp("cookie_ecps_code");                if(StringUtils.equals(name, cookieKey)){                    //获得cookie的值
                    String result = cookie.getValue();                    //[{skuId:1002, quantity:2}, {skuId:1003, quantity:3},....]
                    result = URLDecoder.decode(result);                    //把json格式的字符串转换成json数组对象
                    JSONArray ja = JSONArray.fromObject(result);                    //把json的数组转换成java集合
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);
                    cartList.clear();
                }
            }
        }

        JSONArray ja = JSONArray.fromObject(cartList, jc);        String result = ja.toString();
        result = URLEncoder.encode(result);
        Cookie cookie = new Cookie("cookie_ecps_code", result);
        cookie.setMaxAge(Integer.MAX_VALUE);
        cookie.setPath("/");
        response.addCookie(cookie);
    }

    public String validCookie(HttpServletRequest request,
            HttpServletResponse response) {        /**
         * 1.创建cookie设置到浏览器
         * 2.取cookie，看是否能拿到，如果拿到，说明浏览器cookie正常，否则，关闭了
         */
        Cookie cookie = new Cookie("test", "test");
        response.addCookie(cookie);
        Cookie[] cookies = request.getCookies();        String result = "yes";//默认为cookie可用
        if(cookies != null && cookies.length > 0){            for (Cookie cookie2 : cookies) {                String name = cookie2.getName();                String value = cookie2.getValue();
                System.out.println(name+"="+value);                if((StringUtils.equals("test", name) && StringUtils.equals("test", value))){
                    result = "no";
                }
            }
        }
        System.out.println(result);        return "yes";
    }

    public String validCar(HttpServletRequest request,
            HttpServletResponse response) {        String result1 = "success";
        List<EbCart> cartList = new ArrayList<EbCart>();        //获得当前网站的cookie
        Cookie[] cookies = request.getCookies();        if(cookies != null&&cookies.length > 0){            for(Cookie cookie : cookies){                String name = cookie.getName();                String cookieKey = ECPSUtils.readProp("cart_key");                if(StringUtils.equals(name, cookieKey)){                    //获得cookie的值
                    String result = cookie.getValue();                    //[{skuId:1002, quantity:2}, {skuId:1003, quantity:3},....]
                    result = URLDecoder.decode(result);                    //把json格式的字符串转换成json数组对象
                    JSONArray ja = JSONArray.fromObject(result);                    //json的配置对象
                    JsonConfig jc = new JsonConfig();                    //设置要转换的类
                    jc.setRootClass(EbCart.class);                    //设置不需要转换的属性
                    jc.setExcludes(new String[]{"sku"});                    //把json的数组转换成java集合
                    cartList = (List<EbCart>) JSONSerializer.toJava(ja, jc);                    for (EbCart cart : cartList) {                        //判断库存商品数量是否大于购买数量
                        EbSku sku = skuDao.getSkuDetailById(cart.getSkuId());                        if(sku.getStockInventory().intValue() < cart.getQuantity().intValue()){                            //提示信息：哪个商品什么规格不足多少
                            result1 = sku.getItem().getItemName();//哪个商品
                            for(EbSpecValue spec : sku.getSpecList()){
                                result1 = result1 + spec.getSpecValue();//哪个规格
                            }
                            result1 = result1 + "不足" + cart.getQuantity();//不足多少
                            break;//循环到库存不足的商品就跳出
                        }
                    }
                }
            }
        }        return result1;
    }123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324

9、订单提交
订单提交的时候，注意每一次提交都要验证库存是否足够

页面：

//订单提交function trueBuy(){
    $.ajax({
        url:"${path}/user/getUser.do",
        type:"post",
        dataType:"text",
        success:function(responseText){
            var userObj  = $.parseJSON(responseText);            if(userObj.user != null){                var result = validCar();                if(result == "success"){
                    window.location.href = "${path}/order/toSubmitOrder.do";
                }else{
                    alert(result);
                }
            }else{
                tipShow("#loginAlert");
            }
        },
        error:function(){
            alert("系统错误");
        }
    })
}//购买数量减一function reduceNum(skuId, quantity){

    var jsonObj = validStock(skuId, quantity);    if(jsonObj.result == "no"){        var newQuantity = quantity - 1;
        alert("当前的库存数量不足"+newQuantity+"个,仅有"+jsonObj.stock+"个");        return;
    }    if(quantity == 1){        if(confirm("是否把该商品从购物车中删除?")){
            window.location.href = "${path}/cart/deleteCart.do?skuId="+skuId;
        }
    }else{
        window.location.href = "${path}/cart/reduceNum.do?skuId="+skuId;
    }
}//验证库存数量function validStock(skuId, quantity){
    quantity--;    var jsonObj = null;
    $.ajax({
        url:"${path}/cart/validStockCar.do",
        type:"post",
        dataType:"text",
        async:false,
        data:{
            skuId:skuId,
            quantity:quantity
        },
        success:function(responseText){
            jsonObj = $.parseJSON(responseText);
        },
        error:function(){
            alert("系统错误");
        }

    })    return jsonObj;
}function changeImage(){
    var path = "${path}/user/getImage.do?date="+new Date();
    $("#captchaImage").attr("src", path);
}//提交订单异步登录function loginAjax(){
    var username = $("#username").val();    var password = $("#password").val();    var captcha = $("#captcha").val();
    $.ajax({
        url:"${path}/user/loginAjax.do",
        type:"post",
        dataType:"text",
        data:{
            username:username,
            password:password,
            captcha:captcha
        },
        success:function(responseText){
            if(responseText == "caperror"){
                $("#errorName").html("验证码错误");
                $("#errorName").show(500);
            }else if(responseText == "userpasserror"){
                $("#errorName").html("用户名或者密码错误");
                $("#errorName").show(500);
            }else if(responseText == "success"){
                $("#loginAlertIs").html(username);
                tipHide("#loginAlert");                //校验库存
                var result = validCar();                if(result == "success"){
                    window.location.href = "${path}/order/toSubmitOrder.do";
                }else{
                    alert(result);
                }
            }
        },
        error:function(){
            alert("系统错误");
        }

    })
}//验证库存是否足够function validCar(){
    var result = "success";
    $.ajax({
        url:"${path}/cart/validCar.do",
        type:"post",
        dataType:"text",
        async:false,
        success:function(responseText){
            result = responseText;
        },
        error:function(){
            alert("系统错误");
        }

    })    return result;
}123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130

action：

//订单提交
    @RequestMapping("/submitOrder.do")
    public String submitOrder(HttpServletResponse response, HttpServletRequest request,EbOrder order,
            HttpSession session, String address, Model model) throws Exception{
        TsPtlUser user = (TsPtlUser) session.getAttribute("user");
        if(user != null){
            order.setPtlUserId(user.getPtlUserId());
            order.setUsername(user.getUsername());
        }
        order.setOrderNum(new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()));
        //1.如果不是新添加的地址，則通過地址的id查詢當前的地址
        //2.新添加的地址，會自動的賦值給order對象
        if(!StringUtils.equals("add", address)){
            EbShipAddr addr = shipAddrService.selectAddrByShipAddrId(new Long(address));
            BeanUtils.copyProperties(order, addr);
        }
        List<EbCart> cartList = cartService.listCart(request, response);
        List<EbOrderDetail> detailList = new ArrayList<EbOrderDetail>();
        for(EbCart cart:cartList){
            EbOrderDetail detail = new EbOrderDetail();
            detail.setItemId(cart.getSku().getItem().getItemId());
            detail.setItemName(cart.getSku().getItem().getItemName());
            detail.setItemNo(cart.getSku().getItem().getItemNo());
            detail.setSkuId(cart.getSkuId());
            String specVal = "";
            List<EbSpecValue> specList = cart.getSku().getSpecList();
            for(EbSpecValue spec : specList){
                specVal = specVal + spec.getSpecValue()+",";
            }
            specVal = specVal.substring(0, specVal.length() - 1);
            detail.setSkuSpec(specVal);
            detail.setQuantity(cart.getQuantity());
            detail.setSkuPrice(cart.getSku().getSkuPrice());
            detail.setMarketPrice(cart.getSku().getMarketPrice());
            detailList.add(detail);
        }
        try {
            String processInstanceId = orderService.saveOrder(response, request, order, detailList);
            model.addAttribute("order", order);
            model.addAttribute("processInstanceId", processInstanceId);
        } catch (Exception e) {
            if(e instanceof EbStockException){
                model.addAttribute("tip", "stock_error");
            }
        }
        return "shop/confirmProductCase2";
    }    /**
     * 订单支付
     */
    @RequestMapping("/pay.do")
    public void pay(String processInstanceId, Long orderId, PrintWriter out){
        orderService.pay(processInstanceId, orderId);
        out.write("success");
    }12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455561234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556

service：

public String saveOrder(HttpServletResponse response, HttpServletRequest request,
            EbOrder order, List<EbOrderDetail> detailList)throws EbStockException {
        orderDao.saveOrder(order);        Map<String,Object> map = new HashMap<String,Object>();
        for(EbOrderDetail detail : detailList){            //給訂單詳情設置訂單id
            detail.setOrderId(order.getOrderId());
            detailDao.saveOrderDetail(detail);            /*EbSku sku = skuDao.getSkuById(detail.getSkuId());

            sku.setStockInventory(sku.getStockInventory() - detail.getQuantity());
            skuDao.update(sku);*/
            map.put("skuId", detail.getSkuId());            map.put("quantity", detail.getQuantity());            //為了防止并发问题，这里可以使用：
            //1.悲观锁：对查询语句进行锁，即for update
            //2.乐观锁：对修改语句进行锁，即条件加判断条件：会返回影响数量
            int flag = skuDao.updateStock(map);            if(flag == 0){
                throw new EbStockException("库存不足");
            }

        }        //保存订单时，开启一个流程实例
        String processInstanceId = flowService.startProcess(order.getOrderId());
        cartService.clearCart(request, response);        return processInstanceId;
    }    public void pay(String processInstanceId, Long orderId){        //修改订单支付状态
        EbOrder order = new EbOrder();        order.setOrderId(orderId);        order.setIsPaid((short)1);
        orderDao.updateOrder(order);        //完成订单支付节点
        flowService.completeTaskByPId(processInstanceId, "支付");
    }    public List<TaskBean> listNoPayOrder(Short isCall, String assignee) {        /**
         * 1.根据办理人查询到task和businesskey
         * 2.根据businesskey查询订单
         * 3.根据iscall查询未支付的订单
         */
        List<TaskBean> tbList1 = new ArrayList<TaskBean>();        List<TaskBean> tbList = flowService.selectTaskBeanByAssignee(assignee);
        for (TaskBean tb : tbList) {
            EbOrder order = orderDao.selectOrderById(tb.getBusinessKey());            //查询没有付款的订单
            if(order.getIsCall().shortValue() == isCall.shortValue()){
                tb.setOrder(order);
                tbList1.add(tb);
            }
        }        return tbList1;
    }    public EbOrder selectOrderAndDetailById(Long orderId) {        return orderDao.selectOrderAndDetailById(orderId);
    }    public void updateOrder(Long orderId) {
        EbOrder order = new EbOrder();        order.setOrderId(orderId);        order.setIsCall((short)1);
        orderDao.updateOrder(order);
    }    public List<TaskBean> listPaidOrder(String assignee) {        /**
         * 1.根据办理人查询到task和businesskey
         * 2.根据businesskey查询订单
         * 3.根据iscall查询未支付的订单
         */
        List<TaskBean> tbList = flowService.selectTaskBeanByAssignee(assignee);
        for (TaskBean tb : tbList) {
            EbOrder order = orderDao.selectOrderById(tb.getBusinessKey());            //查询没有付款的订单
            tb.setOrder(order);
        }        return tbList;
    }    public TaskBean selectTaskBeanByOrderIdAndTaskId(Long orderId, String taskId) {
        EbOrder order = orderDao.selectOrderAndDetailById(orderId);
        TaskBean tb = flowService.selectTaskBeanByTaskId(taskId);
        tb.setOrder(order);        return tb;
    }    public void compeleTask(String taskId, String outcome, Long orderId) {
        EbOrder order = new EbOrder();        order.setOrderId(orderId);        order.setUpdateTime(new Date());
        flowService.compeleTaskByTaskId(taskId, outcome);
    }123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100

10、订单流程

这里采用工作流activiti整合ssm

10.1、业务流程图

10.3、service层

public void deployFlow() {
        DeploymentBuilder db = repositoryService.createDeployment();
        db.addClasspathResource("com/sihai/ecps/diagrams/OrderFlow.bpmn")          .addClasspathResource("com/sihai/ecps/diagrams/OrderFlow.png");
        db.deploy();
    }    public String startProcess(Long orderId) {
        ProcessInstance pi = runtimeService.startProcessInstanceByKey("OrderFlow", orderId+"");        return pi.getId();
    }    public void completeTaskByPId(String processInstanceId, String outcome) {        Map<String, Object> map = new HashMap<String, Object>();        map.put("outcome", outcome);
        Task task = taskService.createTaskQuery().processInstanceId(processInstanceId).singleResult();
        taskService.complete(task.getId(), map);
    }    public List<TaskBean> selectTaskBeanByAssignee(String assignee) {        //根据办理人查询任务列表
        List<Task> tList = taskService.createTaskQuery()        .processDefinitionKey("OrderFlow")        .taskAssignee(assignee)        .orderByTaskCreateTime()        .desc()        .list();        List<TaskBean> tbList = new ArrayList<TaskBean>();
        for (Task task : tList) {            //设置任务和businesskey
            TaskBean tb = new TaskBean();
            tb.setTask(task);
            ProcessInstance pi = runtimeService.createProcessInstanceQuery()                    .processDefinitionKey("OrderFlow")                    .processInstanceId(task.getProcessInstanceId())                    .singleResult();            String businessKey = pi.getBusinessKey();
            tb.setBusinessKey(businessKey);
            tbList.add(tb);
        }        return tbList;
    }    public TaskBean selectTaskBeanByTaskId(String taskId) {
        Task task = taskService.createTaskQuery().processDefinitionKey("OrderFlow").taskId(taskId).singleResult();
        TaskBean tb = new TaskBean();
        tb.setTask(task);        List<String> outcomes = this.getOutcomes(task);
        tb.setOutcomes(outcomes);        return tb;
    }    public List<String> getOutcomes(Task task){        List<String> outcomes = new ArrayList<String>();        //获得流程定义的对象
        ProcessDefinitionEntity pe = (ProcessDefinitionEntity) repositoryService.getProcessDefinition(task.getProcessDefinitionId());        //获得流程实例对象
        ProcessInstance pi = runtimeService.createProcessInstanceQuery().processDefinitionKey("OrderFlow")        .processInstanceId(task.getProcessInstanceId()).singleResult();
        ActivityImpl ai = pe.findActivity(pi.getActivityId());        //获得往外面走的线路的对象
        List<PvmTransition> ptList = ai.getOutgoingTransitions();

        for(PvmTransition pt : ptList){            String name = (String) pt.getProperty("name");
            outcomes.add(name);
        }        return outcomes;
    }    public void compeleTaskByTaskId(String taskId, String outcome) {        Map<String,Object> map = new HashMap<String,Object>();        map.put("outcome", outcome);
        Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
        taskService.complete(task.getId(), map);
    }1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787912345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879

最后，写了好久，就把这些核心的写出来，总结总结一下，以后好看看

微信关注我们

原文链接：https://blog.51cto.com/sihai/1909878

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Python itchat模块在微信上的各种小应用

前两天在51cto看见某篇推荐博文，大概是一个Python的小程序可以读取微信撤回的信息。豆子比较感兴趣，在知乎和github上搜索了相关的源代码，发现原来实现起来非常的简单，他的核心是使用一个叫做itchat的模块，这个模块模拟微信网页版的登录过程，然后之后就可以很轻松读取和发送信息了。第一次使用的时候可能对他的格式有点疑惑，但是写两个小例子之后就比较熟悉这些模块里面的函数了，可以很容易地对好友，群聊和公众号的各种类型的信息进行读取，存储，写入。完全可以发挥想象在这个平台上做很多操作。网上有很多相关的简介和有趣的应用小程序，这些小程序大小不超过百行，但是功能都很有趣 http://itchat.readthedocs.io/zh/latest/#itchat 比较有趣的小程序有：图灵机器人自动对话，你甚至可以直接绑定这个API和某人甚至某群聊，这样对方和你交流的时候，图灵机器人都会替你自动回复啦 http://itchat.readthedocs.io/zh/latest/tutorial/tutorial0/ 网易云音乐播放器，消息群发，检测黑名单好友等等 https://i...

2017-03-24

473

轻松使用Fpm封装制作Rpm包 --Linux

关于FPM的介绍 https://docs.google.com/present/view?id=0Aa9liCTsAyzRZGNtd3dkOTRfMTdmczY2azlkcg&hl=en FPM功能简单说就是将一种类型的包转换成另一种类型。支持的源类型包：“dir”：将目录打包成所需要的类型，可以用于源码编译安装的软件包 “rpm”：对rpm进行转换 “gem”：对rubygem包进行转换 “python”：将python模块打包成相应的类型支持的目标类型包： “rpm”：转换为rpm包 “deb”：转换为deb包 “solaris”：转换为solaris包 “puppet”：转换为puppet模块这里主要介绍如何将源码安装的包转换为RPM/DEB包，其他功能感兴趣的可以试试。安装环境：系统Centos6.5 64位，默认的ruby为1.8.7版本；封装mysql5.6.29二进制安装包； FPM安装 FPM的安装非常简单，安装FPM前需要先安装ruby，rubygem # FPM是Ruby模块 yum-yinstallrubyrubygemsruby-deve...

2017-03-24

733

发表评论

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

Oracle

Oracle Database，又名Oracle RDBMS，或简称Oracle。是甲骨文公司的一款关系数据库管理系统。它是在数据库领域一直处于领先地位的产品。可以说Oracle数据库系统是目前世界上流行的关系数据库管理系统，系统可移植性好、使用方便、功能强，适用于各类大、中、小、微机环境。它是一种高效率、可靠性好的、适应高吞吐量的数据库方案。

JDK

JDK是 Java 语言的软件开发工具包，主要用于移动设备、嵌入式设备上的java应用程序。JDK是整个java开发的核心，它包含了JAVA的运行环境（JVM+Java系统类库）和JAVA工具。