去除老版本收藏

admin

2018-12-04 57b80e02ce56e3cacff75ba789fc633ab46b911a

去除老版本收藏

 fanli/src/main/java/com/yeshi/fanli/controller/apph5/AppH5QualityGoodsController.java

@@ -6,12 +6,11 @@


import javax.annotation.Resource;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.taobao.TbImgUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

@@ -19,13 +18,13 @@
import com.yeshi.fanli.entity.bus.lable.Label;

import com.yeshi.fanli.entity.bus.lable.MergeClass;

import com.yeshi.fanli.entity.bus.lable.QualityFactory;

import com.yeshi.fanli.entity.bus.user.CollectionGoods;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.entity.taobao.TaobaoMeterial;

import com.yeshi.fanli.goods.CollectionGoodsV2;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.goods.GoodsClassService;

import com.yeshi.fanli.service.inter.goods.TaoBaoClassService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

@@ -39,8 +38,9 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.taobao.TbImgUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Controller

@RequestMapping("api/apph5/v1/quality")

@@ -80,10 +80,7 @@
    private QualityFlashSaleService qualityFlashSaleService;

    

    @Resource

    private CollectionGoodsService collectionGoodsService;

	
	
	
    private CollectionGoodsV2Service collectionGoodsV2Service;

    

    /**

     * 9.9商品

@@ -95,7 +92,6 @@
    public void get9k9(String callback, Integer page, Long mcid, PrintWriter out) {

        get9k9ClassGoods("9.9", callback, page, mcid, out);

    }

	


    /**

     * 19.9商品

@@ -130,13 +126,15 @@
        get9k9ClassGoods("49.9", callback, page, mcid, out);

    }



	
    /**

     *  9k9类型的商品查询

     * @param labName 标签名称

     * 
     * @param labName

     *            标签名称

     * @param callback

     * @param page

     * @param mcid 对应类目id

     * @param mcid

     *            对应类目id

     * @param out

     */

    public void get9k9ClassGoods(String labName, String callback, Integer page, Long mcid, PrintWriter out) {

@@ -196,7 +194,8 @@
        }



        // 根据标签id 查询数据

        List<QualityFactory> listQuery = qualityGoodsService.listQuerySmallAmount((page - 1) * pageSize, pageSize, null, labId, mergeCids);

        List<QualityFactory> listQuery = qualityGoodsService.listQuerySmallAmount((page - 1) * pageSize, pageSize, null,

                labId, mergeCids);



        // 总条数

        long count = qualityGoodsService.countQuerySmallAmount(null, labId, mergeCids);

@@ -205,7 +204,8 @@
        }



        JSONArray array = new JSONArray();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



        Map<String, String> map = manageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

@@ -244,10 +244,6 @@


        return data;

    }

	
	
	
	
    

    /**

     * 9.9商品-每日必抢

@@ -293,9 +289,9 @@
        get9k9ClassToDayRob("49.9", callback, page, mcid, out, 1.0, 50.0);

    }





    /**

     * 9k9类型商品对应的每日必抢

     * 
     * @param labName

     * @param callback

     * @param page

@@ -335,7 +331,6 @@
        }

    }

    

	
    /**

     * 每日必抢

     * 

@@ -345,32 +340,35 @@
     * @return

     * @throws Exception

     */

    public JSONObject queryEverydayRob(Integer page, Long labId, int sortField, Double startCouponAmount, Double endCouponAmount) throws Exception {

    public JSONObject queryEverydayRob(Integer page, Long labId, int sortField, Double startCouponAmount,

            Double endCouponAmount) throws Exception {



        if (page == null)

            page = 1;



        int pageSize = Constant.PAGE_SIZE;

        

		
        if (page > 3 ) {

            return null;// 20 条一页请求到3页结束今日新品

        }

        

        // 根据标签id 查询数据

        List<QualityFactory> listQuery = qualityGoodsService.listQueryEverydayRob((page - 1) * pageSize, pageSize, null, labId, sortField, startCouponAmount, endCouponAmount);

        List<QualityFactory> listQuery = qualityGoodsService.listQueryEverydayRob((page - 1) * pageSize, pageSize, null,

                labId, sortField, startCouponAmount, endCouponAmount);



        //  只取前50条数

        long count = 50;

        

        //long count = qualityGoodsService.countQueryEverydayRob(null, labId, startCouponAmount, endCouponAmount);

        // long count = qualityGoodsService.countQueryEverydayRob(null, labId,

        // startCouponAmount, endCouponAmount);



        if (listQuery == null || listQuery.size() == 0) {

            return null;

        }



        JSONArray array = new JSONArray();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



        Map<String, String> map = manageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

@@ -410,7 +408,6 @@
        return data;

    }





    /**

     * 品牌购 （官方推荐【品牌券】接口）

     * 

@@ -447,7 +444,6 @@
                JsonUtil.printMode(out, callback,JsonUtil.loadFalseResult(2, "没有更多了"));

                return;

            }

			
            

            JsonUtil.printMode(out, callback,JsonUtil.loadTrueResult(jsonObject));



@@ -497,7 +493,6 @@
                JsonUtil.printMode(out, callback,JsonUtil.loadFalseResult(2, "没有更多了"));

                return;

            }

			
            

            JsonUtil.printMode(out, callback,JsonUtil.loadTrueResult(jsonObject));



@@ -570,7 +565,8 @@


        try {



            List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null, "有好货");

            List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null,

                    "有好货");



            if (taobaoMeterials == null || taobaoMeterials.size() == 0) {

                out.print(JsonUtil.loadFalseResult("暂无数据"));

@@ -607,12 +603,12 @@
        }

    }

    

	
    /**

     * 今日新品【（官方推荐【好券直播】接口）

     * 

     * @param page

     * @param subName 子类名称

     * @param subName

     *            子类名称

     */

    @RequestMapping(value = "todayNew")

    public void todayNew(String callback, Integer page, String subName, String uid, PrintWriter out) {

@@ -638,7 +634,6 @@


            int pageSize = Constant.PAGE_SIZE;





            List<TaoBaoGoodsBrief> listMaterial = taoKeGoodsService.listByMaterial(materialId, page, pageSize);



            if (listMaterial == null || listMaterial.size() == 0) {

@@ -647,7 +642,8 @@
            }



            JSONArray array = new JSONArray();

            Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

            Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                    .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



            Map<String, String> map = manageService.convertMap();

            String proportion = map.get("hongbao_goods_proportion");

@@ -673,14 +669,15 @@
                int collected = 0;

                // 判断收藏

                if (!StringUtil.isNullOrEmpty(uid)) {

                    CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid),

                            taoBaoGoodsBrief.getAuctionId());

                    CollectionGoodsV2 collectionGoods = collectionGoodsV2Service

                            .findByUidAndAuctionId(Long.parseLong(uid), taoBaoGoodsBrief.getAuctionId());

                    if (collectionGoods != null) {

                        collected = 1;

                    }

                }

                

                TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion, fcRate, null);

                TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief,

                        proportion, fcRate, null);

                taoBaoGoodsBriefExtra.setCollected(collected);

                

                array.add(gson.toJson(taoBaoGoodsBriefExtra));

@@ -689,7 +686,6 @@
            JSONObject data = new JSONObject();

            data.put("result_list", array);

            data.put("count", 1000);



            

            JsonUtil.printMode(out, callback,JsonUtil.loadTrueResult(data));



@@ -703,9 +699,6 @@
        }

    }



	
	
	
    /**

     * 潮品热卖（官方推荐中的【潮流范】）

     * 

@@ -717,8 +710,8 @@


        try {



			
            List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null, "潮流范");

            List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(null,

                    "潮流范");



            if (taobaoMeterials == null || taobaoMeterials.size() == 0) {

                JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));

@@ -769,7 +762,8 @@


        try {

            

            List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(subName, "母婴主题");

            List<TaobaoMeterial> taobaoMeterials = taobaoMeterialService.selectByClassNameAndSuperNameCache(subName,

                    "母婴主题");



            if (taobaoMeterials == null || taobaoMeterials.size() == 0) {

                JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));

@@ -825,7 +819,8 @@
        }



        JSONArray array = new JSONArray();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



        Map<String, String> map = manageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

@@ -860,10 +855,9 @@


    }



	
	
    /**

     * 限时抢购

     * 
     * @param callback

     * @param page

     * @param out

@@ -889,7 +883,8 @@
        

         // 精选库数据处理返回 前端 

        JSONArray array = new JSONArray();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



        Map<String, String> map = manageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

@@ -930,9 +925,9 @@
        JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

    }



	
    /**

     * 大额券（券面值范围）

     * 
     * @param callback

     * @param amount

     * @param page

@@ -941,12 +936,10 @@
    @RequestMapping("choiceCouponAmount")

    public void choiceCouponAmount(String callback, Integer amount, Integer page, PrintWriter out) {

        

	
        if (page == null)

            page = 1;

        

        int pageSize = Constant.PAGE_SIZE;

		
        

        Integer startAmount = null;

        Integer endAmount =  null ;

@@ -966,20 +959,20 @@
        

        Integer startPropor = 20;

        

        List<QualityFactory> listQuery = qualityGoodsService.listQueryByCouponAmount((page - 1) * pageSize,

                pageSize, startAmount, endAmount, startPropor);

        List<QualityFactory> listQuery = qualityGoodsService.listQueryByCouponAmount((page - 1) * pageSize, pageSize,

                startAmount, endAmount, startPropor);

        

        if (listQuery == null || listQuery.size() == 0) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(2, "没有更多了"));

            return;

        }

        

		
        long count = qualityGoodsService.countQueryByCouponAmount(startAmount, endAmount, startPropor);

        

         // 精选库数据处理返回 前端 

        JSONArray array = new JSONArray();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



        Map<String, String> map = manageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

@@ -1018,10 +1011,9 @@
        JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

    }

    

	
	
    /**

     * 超高奖金

     * 
     * @param callback

     * @param page

     * @param type

@@ -1034,7 +1026,6 @@
            page = 1;

        

        int pageSize = Constant.PAGE_SIZE;

		
        

        Integer startAmount = null;

        Integer endAmount =  null ;

@@ -1066,13 +1057,12 @@
            return;

        }

        

		
        long count = qualityGoodsService.countQueryByRebateAmount(proportion, startAmount, endAmount, tkRate);

        

         // 精选库数据处理返回 前端 

        JSONArray array = new JSONArray();

        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()).excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();



        Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

                .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

        

         //遍历列表数据 

        for (QualityFactory quality : listQuery) {

@@ -1110,6 +1100,7 @@
    

    /**

     * 超高奖金

     * 
     * @param callback

     * @param page

     * @param type

@@ -1123,13 +1114,11 @@
        

        int pageSize = Constant.PAGE_SIZE;

        

		
        Map<String, String> map = manageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

        String fcRate = map.get("hongbao_fc_ratio");

        

        JSONArray array = qualityGoodsService.getRecommendToIndex((page - 1) * pageSize, pageSize,

                proportion, fcRate);

        JSONArray array = qualityGoodsService.getRecommendToIndex((page - 1) * pageSize, pageSize, proportion, fcRate);

        

        if (array == null) {

            out.print(JsonUtil.loadFalseResult("没有更多了"));


 fanli/src/main/java/com/yeshi/fanli/controller/client/RecommendController.java

@@ -12,9 +12,6 @@
import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

@@ -62,13 +59,16 @@
import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException;

import com.yeshi.fanli.goods.CollectionGoodsV2;

import com.yeshi.fanli.goods.CommonGoods;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.JumpDetailService;

import com.yeshi.fanli.service.inter.config.SystemClientParamsService;

import com.yeshi.fanli.service.inter.config.SystemConfigService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.goods.HonestService;

import com.yeshi.fanli.service.inter.goods.RecommendBannerService;

import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;

@@ -103,6 +103,9 @@
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Controller

@RequestMapping("api/v1/user")

@@ -160,7 +163,7 @@
    private HonestService honestService;



    @Resource

    private CollectionGoodsService collectionGoodsService;

    private CollectionGoodsV2Service collectionGoodsV2Service;



    @Resource

    private HongBaoManageMapper hongBaoManageMapper;

@@ -206,6 +209,9 @@


    @Resource

    private MonitorService monitorService;



    @Resource

    private CommonGoodsService commonGoodsService;



    @RequestMapping(value = "getrecommendsection")

    public void getRecommendSection(AcceptData acceptData, int index, PrintWriter out) {

@@ -689,7 +695,7 @@
                taoBaoGoodsBriefExtra.getTaoBaoQuanInfo().setCouponLink(tb.getCouponLink());

            taoBaoGoodsBriefExtra.setAuctionUrl(tb.getAuctionUrl());

            if (uid != null && !"".equals(uid.trim())) {

                CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid),

                CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid),

                        Long.parseLong(id));

                data.put("collection", collectionGoods != null ? true : false);

            }

@@ -977,7 +983,7 @@


        // 判断收藏

        if (!StringUtil.isNullOrEmpty(uid)) {

            CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid),

            CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid),

                    Long.parseLong(id));

            data.put("collected", collectionGoods != null ? true : false);

        } else

@@ -1169,7 +1175,9 @@
            if (goods == null)// 商品下线

            {

                // 从我们的商品库搜索

                CollectionGoods cgoods = collectionGoodsService.findByAuctionId(id);

                CommonGoods cgoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(id,

                        CommonGoods.GOODS_TYPE_TB);



                if (cgoods != null) {// 商品有本地缓存

                    // 按名字搜索商品

                    SearchFilter sf = new SearchFilter();

@@ -1890,7 +1898,7 @@
        if (StringUtil.isNullOrEmpty(uid)) {

            data.put("collected", false);

        } else {

            CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid),

            CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid),

                    Long.parseLong(id));

            data.put("collected", collectionGoods != null ? true : false);

        }

@@ -2082,8 +2090,8 @@


            if (goods == null) {

                // 从我们的商品库搜索

                CollectionGoods cgoods = collectionGoodsService.findByAuctionId(id);



                CommonGoods cgoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(id,

                        CommonGoods.GOODS_TYPE_TB);

                // 商品有本地缓存

                if (cgoods != null) {

                    // 按名字搜索商品

@@ -2101,9 +2109,7 @@
                            }

                            goodsList.add(gds);

                        }



                    }



                }

            }




 fanli/src/main/java/com/yeshi/fanli/controller/client/UserAccountController.java

@@ -9,6 +9,7 @@


import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.yeshi.utils.JsonUtil;



import com.alipay.api.AlipayApiException;

import com.yeshi.fanli.entity.accept.AcceptData;

@@ -29,7 +30,6 @@
import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.InviteGetMoneyService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

@@ -49,13 +49,11 @@
import com.yeshi.fanli.service.inter.user.TBPidService;

import com.yeshi.fanli.service.inter.user.UserAccountService;

import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.WxDownService;

import com.yeshi.fanli.util.GsonUtil;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.account.UserUtil;

import com.yeshi.fanli.util.wx.WXLoginUtil;

import org.yeshi.utils.JsonUtil;



import net.sf.json.JSONObject;



@@ -118,12 +116,7 @@
    private AccountMessageService accountMessageService;



    @Resource

    private CollectionGoodsService collectionGoodsService;

    @Resource

    private HongBaoManageService hongBaoManageService;



    @Resource

    private WxDownService wxDownService;



    @Resource

    private UserAccountService userAccountService;


 fanli/src/main/java/com/yeshi/fanli/controller/client/UserInfoController.java

@@ -15,9 +15,6 @@
import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.apache.commons.beanutils.PropertyUtils;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

@@ -38,7 +35,6 @@
import com.yeshi.fanli.entity.bus.user.AccountDetails;

import com.yeshi.fanli.entity.bus.user.AccountMessage;

import com.yeshi.fanli.entity.bus.user.BindingAccount;

import com.yeshi.fanli.entity.bus.user.CollectionGoods;

import com.yeshi.fanli.entity.bus.user.Extract;

import com.yeshi.fanli.entity.bus.user.ExtractRecord;

import com.yeshi.fanli.entity.bus.user.HongBao;

@@ -59,10 +55,13 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.exception.BindingAccountException;

import com.yeshi.fanli.exception.ObjectStateException;

import com.yeshi.fanli.exception.goods.CollectionGoodsException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.goods.CollectionGoodsV2;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

@@ -94,6 +93,9 @@
import com.yeshi.fanli.util.account.UserUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.wx.WXLoginUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Controller

@RequestMapping("api/v1/customer")

@@ -151,8 +153,6 @@
    private AccountMessageService accountMessageService;



    @Resource

    private CollectionGoodsService collectionGoodsService;

    @Resource

    private HongBaoManageService hongBaoManageService;



    @Resource

@@ -169,6 +169,9 @@


    @Resource

    private UserActiveLogService userActiveLogService;



    @Resource

    private CollectionGoodsV2Service collectionGoodsV2Service;



    private static final String PASSWORD_MAX_ERROR = "password_max_error";

    private static final String EXTRACT_MIN_MONEY = "extract_min_money";

@@ -1419,24 +1422,32 @@


    @RequestMapping("collectionGoods")

    public void collectionGoods(AcceptData acceptData, long uid, long auctionId, int type, PrintWriter out) {

        CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId);

        CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId);

        if (type == 1) {

            if (find != null) {

                out.print(JsonUtil.loadFalseResult(""));

                return;

            }

            CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid));

            collectionGoodsService.save(cg);

            try {

                TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);

                collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief);

            out.print(JsonUtil.loadTrueResult("收藏成功"));

            return;

            } catch (TaobaoGoodsDownException e) {

                out.print(JsonUtil.loadFalseResult(1, "商品已下架"));

            } catch (CollectionGoodsException e1) {

                out.print(JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg()));

            }

        } else {

            if (find == null) {

                out.print(JsonUtil.loadTrueResult("取消收藏成功"));

                return;

            } else {

                collectionGoodsService.delete(find);

                try {

                    collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId);

                out.print(JsonUtil.loadTrueResult("取消收藏成功"));

                return;

                } catch (CollectionGoodsException e) {

                    out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));

                }

            }

        }



@@ -1459,37 +1470,51 @@
            return;

        }



        CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId);

        CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId);



        if (find == null) {

            // 添加收藏

            CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid));

            collectionGoodsService.save(cg);

            try {

                TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);

                collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief);

            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(1));

            } catch (TaobaoGoodsDownException e) {

                JsonUtil.printMode(out, callback, (JsonUtil.loadFalseResult(1, "商品已下架")));

            } catch (CollectionGoodsException e1) {

                JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg()));

            }

        } else {

            // 取消收藏

            collectionGoodsService.delete(find);

            JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(0));

            try {

                collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId);

                JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("取消收藏成功"));

            } catch (CollectionGoodsException e) {

                JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));

            }

        }



    }



    @RequestMapping("collectionGoodsList")

    public void collectionGoodsList(AcceptData acceptData, long uid, int page, PrintWriter out) {

        List<CollectionGoods> coList = collectionGoodsService.findCollectionGoods(uid, page + 1);

        int count = collectionGoodsService.getCount(uid);



        List<CollectionGoodsV2> collectionGoodsList = collectionGoodsV2Service.getCollectionGoodsList(uid, page + 1,

                Constant.PAGE_SIZE);



        // List<CollectionGoods> coList =

        // collectionGoodsService.findCollectionGoods(uid, page + 1);

        long count = collectionGoodsV2Service.getCollectionGoodsCount(uid);

        JSONObject data = new JSONObject();

        Map<String, String> map = hongBaoManageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

        String fcRate = map.get("hongbao_fc_ratio");

        List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>();

        coList.parallelStream().forEachOrdered(cg -> {

            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.getTaoBaoGoodsBrief(cg);

        collectionGoodsList.parallelStream().forEachOrdered(cg -> {

            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(cg.getCommonGoods());

            goodsBrief.setSalesCount(TaoBaoUtil.getSaleCount(goodsBrief.getBiz30day()));

            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion,

                    fcRate, "");

            taoBaoGoodsBriefExtra.setCreatetime(new Date(cg.getCreateTime()));



            taoBaoGoodsBriefExtra.setCreatetime(cg.getCreateTime());

            list.add(taoBaoGoodsBriefExtra);

        });

        GsonBuilder builder = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {

@@ -1517,7 +1542,11 @@
        } else {

            if (!StringUtil.isNullOrEmpty(ids)) {

                Arrays.asList(ids.split(",")).parallelStream().forEach(auctionIdStr -> {

                    collectionGoodsService.delete(Long.parseLong(auctionIdStr), uid);

                    try {

                        collectionGoodsV2Service.cancelCollectionByAuctionId(uid, Long.parseLong(auctionIdStr));

                    } catch (Exception e) {

                        e.printStackTrace();

                    }

                });

            }

        }

@@ -1526,7 +1555,12 @@


    @RequestMapping("clearConllectionGoods")

    public void clearConllectionGoods(AcceptData acceptData, long uid, PrintWriter out) {

        collectionGoodsService.clear(uid);

        try {

            collectionGoodsV2Service.cancelCollectionByUid(uid);

        } catch (CollectionGoodsException e) {

            e.printStackTrace();

            out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMessage()));

        }

        out.print(JsonUtil.loadTrueResult("删除成功"));

    }



@@ -1590,9 +1624,9 @@
                .loadTrueResult(String.format("%s?id=" + id, Constant.systemCommonConfig.getAppShareInfoUrl())));

    }



	
    /**

     * 用户队员列表查询 1.4.1

     * 
     * @param acceptData

     * @param id

     * @param out

@@ -1614,6 +1648,7 @@
    

    /**

     * 用户队员统计 1.4.1

     * 
     * @param acceptData

     * @param id

     * @param out

@@ -1643,7 +1678,6 @@
            bossData.put("inviteTime", "邀请时间: " + sdf.format(inviteTime));

        }

        

		
        JSONObject resultData = new JSONObject();

        

        String helpLink = configService.get("team_help_url");

@@ -1662,9 +1696,11 @@
    

    /**

     * 用户队员信息保存 1.4.1

     * 
     * @param acceptData

     * @param uid

     * @param inviteId 邀请id

     * @param inviteId

     *            邀请id

     * @param nickname

     * @param out

     */

@@ -1709,9 +1745,11 @@
    

    /**

     * 删除队员关系

     * 
     * @param acceptData

     * @param uid

     * @param inviteId 邀请id

     * @param inviteId

     *            邀请id

     * @param out

     */

    @RequestMapping(value = "removethreesale", method = RequestMethod.POST)


 fanli/src/main/java/com/yeshi/fanli/controller/h5/H5RecommendController.java

@@ -11,6 +11,7 @@
import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.JsonUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

@@ -32,7 +33,6 @@
import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.SystemConfigService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;

import com.yeshi.fanli.service.inter.goods.ShareGoodsService;

import com.yeshi.fanli.service.inter.goods.SuperRecommendBannerService;

@@ -49,7 +49,6 @@
import com.yeshi.fanli.util.Utils;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import org.yeshi.utils.JsonUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

@@ -78,9 +77,6 @@


    @Resource

    private SystemService systemService;



    @Resource

    private CollectionGoodsService collectionGoodsService;



    @Resource

    private ConfigService configService;


 fanli/src/main/java/com/yeshi/fanli/controller/web/WebRecommendController.java

@@ -11,6 +11,7 @@
import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.JsonUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

@@ -20,17 +21,17 @@
import com.yeshi.fanli.entity.bus.recommend.RecommendSectionGoods;

import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendBanner;

import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendSection;

import com.yeshi.fanli.entity.bus.user.CollectionGoods;

import com.yeshi.fanli.entity.system.System;

import com.yeshi.fanli.entity.taobao.ScanHistory;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.entity.taobao.TaoBaoUnionConfig;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.goods.CollectionGoodsV2;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.SystemConfigService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;

import com.yeshi.fanli.service.inter.goods.SuperRecommendBannerService;

import com.yeshi.fanli.service.inter.goods.SuperRecommendSectionService;

@@ -44,7 +45,6 @@
import com.yeshi.fanli.util.ThreadUtil;

import com.yeshi.fanli.util.Utils;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import org.yeshi.utils.JsonUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

@@ -75,7 +75,7 @@
    private SystemService systemService;



    @Resource

    private CollectionGoodsService collectionGoodsService;

    private CollectionGoodsV2Service collectionGoodsV2Service;



    @Resource

    private ConfigService configService;

@@ -290,7 +290,7 @@
                taoBaoGoodsBriefExtra.getTaoBaoQuanInfo().setCouponLink(tb.getCouponLink());



            if (uid != null && !"".equals(uid.trim())) {

                CollectionGoods collectionGoods = collectionGoodsService.findByUidAndAuctionId(Long.parseLong(uid),

                CollectionGoodsV2 collectionGoods = collectionGoodsV2Service.findByUidAndAuctionId(Long.parseLong(uid),

                        Long.parseLong(id));

                data.put("collection", collectionGoods != null ? true : false);

            }


 fanli/src/main/java/com/yeshi/fanli/controller/xcx/XcxRecommendController.java

@@ -8,6 +8,7 @@
import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.JsonUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

@@ -21,7 +22,6 @@
import com.yeshi.fanli.service.inter.config.JumpDetailService;

import com.yeshi.fanli.service.inter.config.SystemConfigService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.HonestService;

import com.yeshi.fanli.service.inter.goods.RecommendBannerService;

import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;

@@ -43,7 +43,6 @@
import com.yeshi.fanli.util.taobao.DaTaoKeUtil;

import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import org.yeshi.utils.JsonUtil;



import net.sf.json.JSONObject;



@@ -108,8 +107,7 @@
    @Resource

    private HonestService honestService;



    @Resource

    private CollectionGoodsService collectionGoodsService;





    @Resource

    private HongBaoManageMapper hongBaoManageMapper;


 fanli/src/main/java/com/yeshi/fanli/controller/xcx/XcxUserInfoController.java

@@ -11,22 +11,26 @@
import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import net.sf.json.JSONObject;



import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.IPUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import com.yeshi.fanli.entity.accept.AcceptData;

import com.yeshi.fanli.entity.bus.user.CollectionGoods;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.WeiXinUser;

import com.yeshi.fanli.entity.system.System;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

import com.yeshi.fanli.exception.goods.CollectionGoodsException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.goods.CollectionGoodsV2;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

@@ -45,14 +49,13 @@
import com.yeshi.fanli.service.inter.user.WxDownService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.GsonUtil;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.wx.WXLoginUtil;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.IPUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import net.sf.json.JSONObject;



@Controller

@RequestMapping("api/xcx/v1/XcxCustomer")

@@ -107,12 +110,15 @@
    private AccountMessageService accountMessageService;



    @Resource

    private CollectionGoodsService collectionGoodsService;

    private CollectionGoodsV2Service collectionGoodsV2Service;

    @Resource

    private HongBaoManageService hongBaoManageService;



    @Resource

    private WxDownService wxDownService;



    @Resource

    private RedisManager redisManager;



    /**

     * 获取用户信息

@@ -194,9 +200,10 @@
            // 查询到的用户信息为空,那么需要填充一些用户信息

            if (loginType == Constant.WEIXIN) {

                form.setPortrait(weiXinUser.getHeadimgurl());

                String wxHeadImg = COSManager.getInstance().uploadFile(

                        HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()),

                        Constant.WXHEADURL + UUID.randomUUID().toString()).getUrl();

                String wxHeadImg = COSManager.getInstance()

                        .uploadFile(HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()),

                                Constant.WXHEADURL + UUID.randomUUID().toString())

                        .getUrl();

                form.setWxPic(wxHeadImg);

                form.setNickName(weiXinUser.getNickname());

                form.setWxName(weiXinUser.getNickname());

@@ -259,9 +266,10 @@
                form.setPortrait(xinUser.getHeadimgurl());

                form.setNickName(xinUser.getNickname());

                form.setWxName(xinUser.getNickname());

                String wxHeadImg = COSManager.getInstance().uploadFile(

                        HttpUtil.getAsInputStream(xinUser.getHeadimgurl()),

                        Constant.WXHEADURL + UUID.randomUUID().toString()).getUrl();

                String wxHeadImg = COSManager.getInstance()

                        .uploadFile(HttpUtil.getAsInputStream(xinUser.getHeadimgurl()),

                                Constant.WXHEADURL + UUID.randomUUID().toString())

                        .getUrl();

                form.setWxPic(wxHeadImg);

            } else if (formLoginType == Constant.TAOBAO) {

                form.setTbName(form.getNickName());

@@ -348,24 +356,32 @@
     */

    @RequestMapping("collectionGoods")

    public void collectionGoods(long uid, long auctionId, int type, PrintWriter out) {

        CollectionGoods find = collectionGoodsService.findByUidAndAuctionId(uid, auctionId);

        CollectionGoodsV2 find = collectionGoodsV2Service.findByUidAndAuctionId(uid, auctionId);

        if (type == 1) {

            if (find != null) {

                out.print(JsonUtil.loadFalseResult("您已收藏"));

                out.print(JsonUtil.loadFalseResult(""));

                return;

            }

            CollectionGoods cg = TaoBaoUtil.getCollectionGoods(auctionId, new UserInfo(uid));

            collectionGoodsService.save(cg);

            try {

                TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);

                collectionGoodsV2Service.addCollection(uid, taoBaoGoodsBrief);

            out.print(JsonUtil.loadTrueResult("收藏成功"));

            return;

            } catch (TaobaoGoodsDownException e) {

                out.print(JsonUtil.loadFalseResult(1, "商品已下架"));

            } catch (CollectionGoodsException e1) {

                out.print(JsonUtil.loadFalseResult(e1.getCode(), e1.getMsg()));

            }

        } else {

            if (find == null) {

                out.print(JsonUtil.loadTrueResult("取消收藏成功"));

                return;

            } else {

                collectionGoodsService.delete(find);

                try {

                    collectionGoodsV2Service.cancelCollectionByAuctionId(uid, auctionId);

                out.print(JsonUtil.loadTrueResult("取消收藏成功"));

                return;

                } catch (CollectionGoodsException e) {

                    out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));

                }

            }

        }

    }

@@ -381,20 +397,20 @@
     */

    @RequestMapping("collectionGoodsList")

    public void collectionGoodsList(long uid, int page, int pageSize, PrintWriter out) {

        List<CollectionGoods> coList = collectionGoodsService.findCollectionGoods(uid, page);

        int count = collectionGoodsService.getCount(uid);

        List<CollectionGoodsV2> coList = collectionGoodsV2Service.getCollectionGoodsList(uid, page, pageSize);

        long count = collectionGoodsV2Service.getCollectionGoodsCount(uid);

        JSONObject data = new JSONObject();

        Map<String, String> map = hongBaoManageService.convertMap();

        String proportion = map.get("hongbao_goods_proportion");

        String fcRate = map.get("hongbao_fc_ratio");

        List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>();

        coList.parallelStream().forEachOrdered(cg -> {

            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.getTaoBaoGoodsBrief(cg);

            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(cg.getCommonGoods());

            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion,

                    fcRate,"");

            list.add(taoBaoGoodsBriefExtra);

        });

        int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;

        int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);

        data.put("totalPage", totalPage);

        data.put("list", GsonUtil.toJsonExpose(list));

        data.put("count", count);

@@ -414,7 +430,11 @@
    public void deleteCollectionGoods(String ids, long uid, PrintWriter out) {

        if (ids != null) {

            Arrays.asList(ids.split(",")).parallelStream().forEach(auctionIdStr -> {

                collectionGoodsService.delete(Long.parseLong(auctionIdStr), uid);

                try {

                    collectionGoodsV2Service.cancelCollection(uid, Long.parseLong(auctionIdStr));

                } catch (Exception e) {

                    e.printStackTrace();

                }

            });



        }

@@ -431,7 +451,11 @@
     */

    @RequestMapping("clearConllectionGoods")

    public void clearConllectionGoods(long uid, PrintWriter out) {

        collectionGoodsService.clear(uid);

        try {

            collectionGoodsV2Service.cancelCollectionByUid(uid);

        } catch (CollectionGoodsException e) {

            e.printStackTrace();

        }

        out.print(JsonUtil.loadTrueResult("删除成功"));

    }




 fanli/src/main/java/com/yeshi/fanli/dao/mybatis/goods/CollectionGoodsV2Mapper.java

@@ -46,6 +46,25 @@
     * @param uid
     * @return
     */
    List<CollectionGoodsV2> selectCountByUid(@Param("uid") Long uid);
    long selectCountByUid(@Param("uid") Long uid);

    /**
     * 根据用户ID,商品ID，商品类型查询商品
     * 
     * @param id
     * @param goodsType
     * @param goodsId
     * @return
     */
    CollectionGoodsV2 selectByUidAndGoodsTypeAndGoodsId(@Param("uid") Long uid, @Param("goodsType") int goodsType,
            @Param("goodsId") Long goodsId);

    /**
     * 根据UID删除收藏
     * 
     * @param uid
     * @return
     */
    int deleteByUid(@Param("uid") Long uid);

}

 fanli/src/main/java/com/yeshi/fanli/mapping/goods/CollectionGoodsV2Mapper.xml

@@ -12,8 +12,7 @@
        </association>

        <association property="commonGoods" column="cg_common_goods_id"
            javaType="com.yeshi.fanli.goods.CommonGoods"
            resultMap="com.yeshi.fanli.dao.mybatis.goods.CommonGoodsMapper.BaseResultMap">
            select="com.yeshi.fanli.dao.mybatis.goods.CommonGoodsMapper.selectByPrimaryKey">
        </association>

    </resultMap>
@@ -47,7 +46,7 @@


    <!-- 获取收藏的数量 -->
    <select id="selectCountByUid" resultMap="BaseResultMap"
    <select id="selectCountByUid" resultType="java.lang.Long"
        parameterType="java.lang.Long">
        select
        count(cg_id)
@@ -55,6 +54,26 @@
        where cg_uid = #{uid}
    </select>


    <select id="selectByUidAndGoodsTypeAndGoodsId" resultMap="BaseResultMap">
        select
        v2.*
        from yeshi_ec_collection_goods_v2 v2 left join
        yeshi_ec_common_goods g
        on g.cg_id=v2.cg_common_goods_id
        where v2.cg_uid
        = #{uid} and
        g.cg_goods_id=#{goodsId} and g.cg_goods_type=#{goodsType}
        limit 1
    </select>



    <!-- 根据UID删除收藏 -->
    <delete id="deleteByUid" parameterType="java.lang.Long">delete from
        yeshi_ec_collection_goods_v2 where cg_uid = #{uid}
    </delete>

    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">delete from
        yeshi_ec_collection_goods_v2 where cg_id = #{id,jdbcType=BIGINT}
    </delete>

 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsServiceImpl.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java

@@ -62,6 +62,26 @@
        collectionGoodsV2Mapper.insertSelective(collectionGoodsV2);

    }



    @Override

    public void addCollection(CollectionGoodsV2 goods) throws CollectionGoodsException {

        if (goods.getUserInfo() == null || goods.getCommonGoods() == null)

            throw new CollectionGoodsException(1, "数据不完整");

        try {

            CommonGoods commonGoods = commonGoodsService.addOrUpdateCommonGoods(goods.getCommonGoods());

            goods.setCommonGoods(commonGoods);

        } catch (CommonGoodsException e) {

            goods.setCommonGoods(null);

        }



        if (goods.getCommonGoods() == null)

            throw new CollectionGoodsException(3, "商品信息添加失败");



        CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper

                .selectByUidAndCommonGoodsId(goods.getUserInfo().getId(), goods.getCommonGoods().getId());

        if (collectionGoodsV2 != null)

            throw new CollectionGoodsException(4, "商品已被收藏");

        collectionGoodsV2Mapper.insertSelective(goods);

    }

    

    @Transactional

    @Override

@@ -82,12 +102,33 @@


    @Override

    public List<CollectionGoodsV2> getCollectionGoodsList(Long uid, int page, int pageSize) {

        return null;

        return collectionGoodsV2Mapper.selectByUidOrderByCreateTimeDesc(uid, (page - 1) * pageSize, pageSize);

    }



    @Override

    public long getCollectionGoodsCount(Long uid) {

        return 0;

        return collectionGoodsV2Mapper.selectCountByUid(uid);

    }



    @Override

    public void cancelCollectionByAuctionId(Long uid, Long auctionId) throws CollectionGoodsException {

        CollectionGoodsV2 goodsV2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid,

                CommonGoods.GOODS_TYPE_TB, auctionId);

        if (goodsV2 == null)

            throw new CollectionGoodsException(1, "无收藏");

        collectionGoodsV2Mapper.deleteByPrimaryKey(goodsV2.getId());

    }



    @Override

    public void cancelCollectionByUid(Long uid) throws CollectionGoodsException {

        collectionGoodsV2Mapper.deleteByUid(uid);

    }



    @Override

    public CollectionGoodsV2 findByUidAndAuctionId(Long uid, Long actionId) {

        CollectionGoodsV2 v2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid, CommonGoods.GOODS_TYPE_TB,

                actionId);

        return v2;

    }



}


 fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CommonGoodsServiceImpl.java

@@ -94,4 +94,9 @@
        commonGoodsMapper.updateByPrimaryKeySelective(update);

    }



    @Override

    public CommonGoods getCommonGoodsByGoodsIdAndGoodsType(Long goodsId, int goodsType) {

        return commonGoodsMapper.selectByGoodsIdAndGoodsType(goodsId, goodsType);

    }



}


 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoGoodsUpdateServiceImpl.java

@@ -13,15 +13,18 @@
import com.google.gson.Gson;

import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefMapper;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.exception.goods.CommonGoodsException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsUpdateException;

import com.yeshi.fanli.goods.CommonGoods;

import com.yeshi.fanli.service.inter.activity.ActivityService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsService;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.goods.RecommendSectionGoodsService;

import com.yeshi.fanli.service.inter.lable.QualityFactoryService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;

import com.yeshi.fanli.util.BeanUtil;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.factory.CommonGoodsFactory;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;



@Service

@@ -39,7 +42,7 @@
    private TaoBaoGoodsBriefMapper taoBaoGoodsBriefMapper;



    @Resource

    private CollectionGoodsService collectionGoodsService;

    private CommonGoodsService commonGoodsService;



    @Override

    public void startUpdate() {

@@ -103,7 +106,11 @@
            throw new TaobaoGoodsUpdateException(2, "商品ID为空");



        // 更新收藏信息

        collectionGoodsService.updateCollectionGoods(goods);

        try {

            commonGoodsService.updateCommonGoods(CommonGoodsFactory.create(goods));

        } catch (CommonGoodsException e) {

            e.printStackTrace();

        }



        List<TaoBaoGoodsBrief> goodsList = taoBaoGoodsBriefMapper.queryByAuctionId(goods.getAuctionId());

        if (goodsList != null)


 fanli/src/main/java/com/yeshi/fanli/service/impl/user/BindingAccountServiceImpl.java

@@ -246,7 +246,7 @@
    public boolean canVerifyAlipayAccount(Long uid) throws BindingAccountException {

        UserInfo userInfo = userInfoMapper.selectByPrimaryKeyForUpdate(uid);

        if (userInfo.getMyHongBao().compareTo(new BigDecimal("0")) <= 0)

            throw new BindingAccountException(1, "账户无余额");

            throw new BindingAccountException(1, "你的账户目前没有余额，无需绑定提现帐号。");



        AlipayAccountValidNormalHistory latest = alipayAccountValidNormalHistoryMapper.selectLatestByUid(uid);

        if (latest != null) {


 fanli/src/main/java/com/yeshi/fanli/service/inter/goods/CollectionGoodsService.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/service/inter/goods/CollectionGoodsV2Service.java

@@ -9,6 +9,7 @@
public interface CollectionGoodsV2Service {



    /**

     * 添加收藏

     * 

     * @param uid

     *            用户ID

@@ -17,6 +18,14 @@
     * @throws CollectionGoodsException

     */

    public void addCollection(Long uid, TaoBaoGoodsBrief goods) throws CollectionGoodsException;



    /**

     * 添加收藏

     * 
     * @param goods

     * @throws CollectionGoodsException

     */

    public void addCollection(CollectionGoodsV2 goods) throws CollectionGoodsException;



    /**

     * 取消收藏

@@ -28,6 +37,25 @@
     * @throws CollectionGoodsException

     */

    public void cancelCollection(Long uid, Long id) throws CollectionGoodsException;



    /**

     * 取消收藏

     * 
     * @param uid

     *            -用户编号

     * @param auctionId

     *            -商品ID

     * @throws CollectionGoodsException

     */

    public void cancelCollectionByAuctionId(Long uid, Long auctionId) throws CollectionGoodsException;



    /**

     * 取消收藏

     * 
     * @param uid

     * @throws CollectionGoodsException

     */

    public void cancelCollectionByUid(Long uid) throws CollectionGoodsException;



    /**

     * 获取收藏记录

@@ -47,4 +75,13 @@
     */

    public long getCollectionGoodsCount(Long uid);



    /**

     * 根据用户ID和淘宝商品ID查询是否收藏

     * 
     * @param uid

     * @param actionId

     * @return

     */

    public CollectionGoodsV2 findByUidAndAuctionId(Long uid, Long actionId);



}


 fanli/src/main/java/com/yeshi/fanli/service/inter/goods/CommonGoodsService.java

@@ -36,4 +36,13 @@
     */

    public void offlineCommonGoods(Long goodsId, int goodsType);



    /**

     * 根据商品ID和商品类型查询库商品

     * 
     * @param goodsId

     * @param goodsType

     * @return

     */

    CommonGoods getCommonGoodsByGoodsIdAndGoodsType(Long goodsId, int goodsType);



}


 fanli/src/main/java/com/yeshi/fanli/util/factory/CollectionGoodsFactory.java

@@ -1,12 +1,23 @@
package com.yeshi.fanli.util.factory;



import com.yeshi.fanli.entity.bus.user.CollectionGoods;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.goods.CollectionGoodsV2;

import com.yeshi.fanli.goods.CommonGoods;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;



public class CollectionGoodsFactory {



    public static CollectionGoods create(CollectionGoodsV2 collectionGoods) {

        if (collectionGoods == null)

        return null;

        CollectionGoods cg = null;

        CommonGoods commnonGoods = collectionGoods.getCommonGoods();

        TaoBaoGoodsBrief taoBaoGoods = TaoBaoUtil.convert(commnonGoods);

        cg = TaoBaoUtil.getCollectionGoods(taoBaoGoods, collectionGoods.getUserInfo());

        if (cg != null)

            cg.setId(collectionGoods.getId());

        return cg;

    }



}


 fanli/src/main/java/com/yeshi/fanli/util/taobao/TaoBaoUtil.java

@@ -1424,6 +1424,35 @@
        return collectionGoods;

    }



    public static CollectionGoods getCollectionGoods(TaoBaoGoodsBrief taoBaoGoodsBrief, UserInfo userInfo) {

        if (taoBaoGoodsBrief == null)

            return null;



        CollectionGoods collectionGoods = new CollectionGoods();

        Field[] fields = taoBaoGoodsBrief.getClass().getDeclaredFields();

        Field[] shFields = collectionGoods.getClass().getDeclaredFields();

        for (int i = 0; i < fields.length; i++) {

            Field field = fields[i];

            field.setAccessible(true);

            try {

                for (Field target : shFields) {

                    target.setAccessible(true);

                    if (target.getName().equalsIgnoreCase(field.getName())) {

                        if (!field.getName().equalsIgnoreCase("createTime"))

                            target.set(collectionGoods, field.get(taoBaoGoodsBrief));

                        break;

                    }

                }

            } catch (IllegalArgumentException e) {

                e.printStackTrace();

            } catch (IllegalAccessException e) {

                e.printStackTrace();

            }

        }

        collectionGoods.setUserInfo(userInfo);

        return collectionGoods;

    }



    /**

     * 获取商品的用户分成比例

     *