新增商品详情接口（1.4.0）

喻健

2018-11-08 a94b7685716096afb867716c96065a60db7b9564

新增商品详情接口（1.4.0）

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

@@ -9,12 +9,36 @@
import java.util.List;

import java.util.Map;













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;

import org.yeshi.utils.IPUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.NumberUtil;





import org.yeshi.utils.taobao.TbImgUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

@@ -22,6 +46,7 @@
import com.yeshi.fanli.entity.accept.AcceptData;

import com.yeshi.fanli.entity.bus.homemodule.Special;

import com.yeshi.fanli.entity.bus.homemodule.SuperSpecial;

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

import com.yeshi.fanli.entity.bus.recommend.Honest;

import com.yeshi.fanli.entity.bus.recommend.RecommendBanner;

import com.yeshi.fanli.entity.bus.recommend.RecommendBannerV2;

@@ -34,6 +59,7 @@
import com.yeshi.fanli.entity.bus.su.recommend.SuperRecommendSpecial;

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

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

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

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

import com.yeshi.fanli.entity.common.ImageInfo;

import com.yeshi.fanli.entity.common.JumpDetail;

@@ -47,6 +73,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

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

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

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

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

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

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

@@ -74,6 +101,7 @@
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;

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

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

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

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

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

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

@@ -87,12 +115,6 @@
import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

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

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

import org.yeshi.utils.IPUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.NumberUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Controller

@RequestMapping("api/v1/user")

@@ -184,6 +206,10 @@


    @Resource

    private SuperRecommendBannerV2Service superRecommendBannerV2Service;

	
    @Resource

    private ShamUserService shamUserService;

	


    @RequestMapping(value = "getrecommendsection")

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

@@ -1185,10 +1211,7 @@
            for (TaoBaoGoodsBrief taoBaoGoodsBrief : recommendGoodsList) {

                if (taoBaoGoodsBrief == null)

                    continue;

                if (taoBaoGoodsBrief.getBiz30day() != null)

                    taoBaoGoodsBrief.setSalesCount(0 + "");

                else

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

				
                re.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion, fcRate, ""));

            }

        out.print(JsonUtil.loadTrueResult(JsonUtil.getApiCommonGson().toJson(re)));

@@ -1455,8 +1478,9 @@
                RecommendBannerV2 recommendBanner = superRecommendBanner.getRecommendBanner();

                // 淘特价暂时修改

                if (system.getId() == 7) {

                    recommendBanner.getJumpDetail().setActivity(recommendBanner.getJumpDetail().getActivity()

                            .replace("com.yeshi.ec.rebate.myapplication", "com.yeshi.ec.taospecial"));

                    recommendBanner.getJumpDetail().setActivity(

                            recommendBanner.getJumpDetail().getActivity()

                                    .replace("com.yeshi.ec.rebate.myapplication", "com.yeshi.ec.taospecial"));

                }



                listBanner.add(recommendBanner);

@@ -1531,5 +1555,514 @@


        out.print(JsonUtil.loadTrueResult(root));

    }

	
	
    /**

     * 商品基本详情 (1.4.0)

     * @param acceptData

     * @param id

     * @param uid

     * @param out

     */

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

    public void getGoodsInfo(AcceptData acceptData, String id, String uid, PrintWriter out) {

		
        if ("0".equalsIgnoreCase(uid)){

            uid = "";

        }

		
        if (StringUtil.isNullOrEmpty(id)) {

            out.print(JsonUtil.loadFalseResult(1, "请上传id"));

            return;

        }

		
        System system = systemService.getSystemCache(acceptData.getPlatform(), acceptData.getPackages());

        if (system == null) {

            out.print(JsonUtil.loadFalseResult(1, "系统不存在"));

            return;

        }

		
        JSONObject data = new JSONObject();

        data.put("invalid", false);

		
        // IOS是否正在上线

        if ("ios".equalsIgnoreCase(acceptData.getPlatform())) {

            String version = acceptData.getVersion();

            data.put("iosOnling", configService.iosOnLining(Integer.parseInt(version)));

        }



        long startTime = java.lang.System.currentTimeMillis();



        // 获取淘客参数

        ClientTBPid clientTBPid = null;

		
		
        if (StringUtil.isNullOrEmpty(uid)) {

            // 用户未登录

            if (acceptData.getPlatform().equalsIgnoreCase("android")) {

                clientTBPid = tbPidService.getAndroidDefault();

            } else {

                clientTBPid = tbPidService.getIOSDefault();

            }

			
        } else {

			
            // 用户已经登录

            TBPid tbPid = null;

            if (acceptData.getPlatform().equalsIgnoreCase("android")) {

				
                tbPid = tbPidService.getTBPid(Long.parseLong(uid),PidUser.TYPE_FANLI_ANDROID);

				
                if (tbPid == null) {

                    clientTBPid = tbPidService.getAndroidDefault();

                } else {

                    String siteId = tbPid.getPid().split("_")[2];

                    String adzoneId = tbPid.getPid().split("_")[3];

                    TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(siteId);

                    clientTBPid = new ClientTBPid(config.getAppKey(),tbPid.getPid(), siteId, adzoneId);

                }



            } else {

				
                tbPid = tbPidService.getTBPid(Long.parseLong(uid), PidUser.TYPE_FANLI_IOS);

				
                if (tbPid == null) {

                    clientTBPid = tbPidService.getIOSDefault();

                } else {

                    String siteId = tbPid.getPid().split("_")[2];

                    String adzoneId = tbPid.getPid().split("_")[3];

                    TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(siteId);

                    clientTBPid = new ClientTBPid(config.getAppKey(), tbPid.getPid(), siteId, adzoneId);

                }

            }

        }



        LogHelper.test("获取PID耗时："    + (java.lang.System.currentTimeMillis() - startTime));



		
        final String clientPid = clientTBPid.getPid();

        final List<TaoBaoGoodsBrief> goodsList = new ArrayList<>();

        // 是否在服务端进行转链

        boolean convertInServer = configService.isConvertTaoBaoLinkInServer();

		
        List<String> taskList = new ArrayList<>();

        // 获取商品基本信息

        taskList.add("goods");

		
        taskList.stream().parallel().forEach(task -> {

            if (task.equalsIgnoreCase("goods")) {

                    JSONObject ticket = new JSONObject();

                    TaoBaoGoodsBrief goods = null;

					
                    if (!convertInServer) {

						
                        try {

                            goods = redisManager.getTaoBaoGoodsBrief(Long.parseLong(id));

                        } catch (TaobaoGoodsDownException e) {

                            // 商品下架

                            ThreadUtil.run(new Runnable() {

                                public void run() {

                                    taoBaoGoodsUpdateService.deleteTaoBaoGoods(Long.parseLong(id));

                                }

                            });



                        }

						
                    } else {

                        String appId = clientPid.split("_")[2];

                        TaoBaoUnionConfig config = taoBaoUnionConfigService.getConfigByAppIdCache(appId);

                        TaoKeAppInfo app = new TaoKeAppInfo();

                        app.setAdzoneId(clientPid.split("_")[3]);

                        app.setAppKey(config.getAppKey());

                        app.setAppSecret(config.getAppSecret());

                        app.setPid(clientPid);

						
                        try {

                            goods = TaoKeApiUtil.searchGoodsDetail(Long.parseLong(id), app);

                            if (goods != null) {

                                ticket.put("clickUrl", goods.getAuctionUrl());

                                // 测试使用

                                ticket.put("couponUrl", goods.getCouponLink());

                                data.put("ticket", ticket);

                            }



                        } catch (NumberFormatException e) {

                            e.printStackTrace();

                        } catch (TaobaoGoodsDownException e) {

                            e.printStackTrace();

                        }

						
                    }



                    if (goods != null) {

                        goodsList.add(goods);

                        final TaoBaoGoodsBrief newGoods = goods;

                        ThreadUtil.run(new Runnable() {

                            public void run() {

                                try {

                                    // 更新商品

                                    LogHelper.test("更新商品详情:" + newGoods.getAuctionId());

                                    taoBaoGoodsUpdateService.updateTaoBaoGoods(newGoods);

                                } catch (TaobaoGoodsUpdateException e) {



                                }

                            }

                        });

                    }

                }

            });



        TaoBaoGoodsBrief tb = null;

        if (goodsList.size() > 0){

            tb = goodsList.get(0);

        }



        if (tb == null) {

            out.print(JsonUtil.loadFalseResult(2, "商品不存在"));

            return;

        }

		
        if (tb.getImgList() == null) {

            tb.setImgList(new ArrayList<>());

        }

		
        tb.getImgList().add(0, tb.getPictUrl());



        List<String> finalImgList = new ArrayList<>();

        for (String img : tb.getImgList()) {

            finalImgList.add(img);

        }

		
		
        JSONObject goods = new JSONObject();

        goods.put("auctionId", tb.getAuctionId());

        goods.put("imgList", finalImgList);

        goods.put("title", tb.getTitle());

        goods.put("userType", tb.getUserType() == 1 ? 2 : 1);

        goods.put("price", tb.getReservePrice().toString());

        goods.put("zkPrice", tb.getZkPrice().toString());



		
        // 红包

        String rateStr = hongBaoManageService.get("hongbao_goods_proportion");

        String hongBao = TaoBaoUtil.getGoodsHongBaoInfo(tb, new BigDecimal(rateStr));

        goods.put("hongBao", hongBao);

        // 30天销量

        goods.put("saleCount", TaoBaoUtil.getSaleCount(tb.getBiz30day()));

		
        // 分享赚

        BigDecimal shareMoney = taoBaoGoodsBriefService.getShareGoodsUserHongBao(tb);

        data.put("shareMoney","¥" + shareMoney);

        // 分享赚人提示

        List<ShamUser> listShareUser = shamUserService.listRandShareUser(10, shareMoney, 1, 5);



        // 判断收藏

        if (StringUtil.isNullOrEmpty(uid)) {

            data.put("collected", false);

        } else {

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

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

        }



        // 测试

        SystemClientParams params = 
                systemClientParamsService.getSystemClientParamsBySystemAndKey(system, "goods_detail_jump_taobao");

        if ("1".equalsIgnoreCase((params.getValue() + "").trim())) {

            data.put("native", true);

        } else {

            data.put("native", false);

        }

		
        // 获取PID

        String pid = clientTBPid.getPid();

        LogHelper.test(String.format("PID: uid-%s  pid-%s", uid + "", pid));

		
        // 是否有券

        goods.put("coupon",    StringUtil.isNullOrEmpty(tb.getCouponInfo()) ? false : true);

		
        // 领券人列表

        List<ShamUser> listCouponUser = null;

		
        // 获取券信息

        if (!StringUtil.isNullOrEmpty(tb.getCouponInfo())) {

            BigDecimal quanPrice = TaoBaoUtil.getAfterUseCouplePrice(tb);

            JSONObject couponInfo = new JSONObject();

            couponInfo.put("couponPrice", quanPrice.toString());

			
            // 服务端转链

            if (convertInServer    && !StringUtil.isNullOrEmpty(tb.getCouponLink())) {

                couponInfo.put("couponUrl", tb.getCouponLink());

            } else {

                couponInfo.put("couponUrl",    TaoBaoCouponUtil.getCoupleUrl(tb.getCouponActivityId() + "", pid, tb.getAuctionId() + ""));

            }

			
            couponInfo.put("couponAmount", NumberUtil.subZeroAndDot(tb.getCouponAmount().toString()));

            couponInfo.put("couponTime", "使用期限："    + tb.getCouponEffectiveStartTime().replace("-", ".") + "-" + tb.getCouponEffectiveEndTime().replace("-", "."));

            goods.put("couponInfo", couponInfo);

			
            // 领券人列表

            listCouponUser = shamUserService.listRandCouponUser(5, 1, 300);

        }



        data.put("tbPidInfo", clientTBPid);



        String jumpUrl = "https://item.taobao.com/item.htm?id="    + tb.getAuctionId();

		
        if (!StringUtil.isNullOrEmpty(tb.getCouponActivityId())) {// 有券，跳转券链接

            jumpUrl = TaoBaoCouponUtil.getCoupleUrl(tb.getCouponActivityId(), clientTBPid.getPid(), "" + tb.getAuctionId());

        }



        // 设置跳转链接

        if (convertInServer) {

            if (!StringUtil.isNullOrEmpty(tb.getCouponLink()))

                jumpUrl = tb.getCouponLink();

            else

                jumpUrl = tb.getAuctionUrl();

        }

        goods.put("jumpUrl", jumpUrl);

		
        TaoBaoShopInfo tbShopInfo = redisManager.getTBShopInfo(tb.getShopTitle(), tb.getSellerId(), tb.getAuctionId());

        if (tbShopInfo != null) {

            String shopType = tbShopInfo.getShopType();

            if (!StringUtil.isNullOrEmpty(shopType) && shopType.contains("tm.png")) {

                tbShopInfo.setUserType("1");

            } else {

                tbShopInfo.setUserType("0");

            }

        }

        // 店铺

        goods.put("shopInfo", tbShopInfo);

		
        // 分享路径

        String shareUrl = String.format("%s?id=" + tb.getAuctionId(), Constant.systemCommonConfig.getAppShareInfoUrl());

		
        data.put("shareUrl", shareUrl);

        data.put("goods", goods);

        data.put("shareUsers", listShareUser);

        data.put("couponUsers", listCouponUser);



        out.print(JsonUtil.loadTrueResult(data));



        final String tempUid = uid;

        final TaoBaoGoodsBrief goodsInfo = tb;

        ThreadUtil.run(new Runnable() {

            public void run() {

                // 添加浏览记录

                ScanHistory sh = TaoBaoUtil.getScanHistory(goodsInfo);

                sh.setId(0);

                sh.setDevice(acceptData.getDevice());

                sh.setSystem(systemService.getSystem(acceptData.getPlatform(),

                        acceptData.getPackages()));

                sh.setCreatetime(new Date());

                if (!StringUtil.isNullOrEmpty(tempUid)) {

                    sh.setUid(Long.parseLong(tempUid));

                }

                try {

                    scanHistoryService.addScanHistory(sh);

                } catch (Exception e) {

                    e.printStackTrace();

                }

            }

        });

    }



	
    /**

     * 获取图文详情(1.4.0)

     * @param acceptData

     * @param id

     * @param out

     */

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

    public void getgoodsdetailimgs(AcceptData acceptData, String id,  PrintWriter out) {



        if (StringUtil.isNullOrEmpty(id)) {

            out.print(JsonUtil.loadFalseResult(1, "请上传id"));

            return;

        }

		
        List<String> detailImgs = new ArrayList<>();

        JSONArray detailImgsSize = new JSONArray();



        List<ImageInfo> imgs = redisManager.getTaoBaoGoodsDetailImgs(Long.parseLong(id));



        if (imgs != null && imgs.size() > 0) {



            for (ImageInfo imgInfo : imgs) {

                detailImgs.add(imgInfo.getPicture());

            }



            for (ImageInfo imgInfo : imgs) {



                if (imgInfo.getWidth() <= 0) {

                    detailImgsSize.clear();

                    break;

                }



                JSONObject size = new JSONObject();

                size.put("w", imgInfo.getWidth());

                size.put("h", imgInfo.getHeight());

                detailImgsSize.add(size);

            }



        }



        JSONObject data = new JSONObject();

        data.put("detailImgs", detailImgs);

        data.put("detailImgsSize", detailImgsSize);

		
        out.print(JsonUtil.loadTrueResult(data));

    }

	
    /**

     * 商品详情推荐1.4.0

     * @param acceptData

     * @param id

     * @param out

     */

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

    public void getRecommendGoods(AcceptData acceptData, long id, PrintWriter out) {



        System system = systemService.getSystemCache(acceptData.getPlatform(), acceptData.getPackages());

        if (system == null) {

            out.print(JsonUtil.loadFalseResult(1, "系统不存在"));

            return;

        }



        List<TaoBaoGoodsBrief> goodsList = TaoKeApiUtil.getRelationGoodsRecommend(id, 10);

		
        // 重新做推荐

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

			
            goodsList = new ArrayList<>();

			
            TaoBaoGoodsBrief goods = null;

			
            try {

                goods = redisManager.getTaoBaoGoodsBrief(id);

            } catch (TaobaoGoodsDownException e) {

                e.printStackTrace();

            }

			
            if (goods == null){

                // 从我们的商品库搜索

                CollectionGoods cgoods = collectionGoodsService.findByAuctionId(id);

				
                // 商品有本地缓存

                if (cgoods != null) {

                    // 按名字搜索商品

                    SearchFilter sf = new SearchFilter();

                    sf.setKey(cgoods.getTitle().substring(0, cgoods.getTitle().length() / 2));

					
                    TaoBaoSearchResult result = TaoBaoUtil.search(sf);

					
                    if (result != null && result.getTaoBaoGoodsBriefs() != null

                            && result.getTaoBaoGoodsBriefs().size() > 0){

						
                        for (TaoBaoGoodsBrief gds : result.getTaoBaoGoodsBriefs()) {

                            if (goodsList.size() == 10) {

                                break;

                            }

                            goodsList.add(gds);

                        }

						
                    }

					
                }

            }



            // 需要另做推荐

            if (goodsList.size() < 2) {

                try {

                    List<RecommendSectionGoods> list = recommendSectionGoodsService.getSectionGoods(10);

                    if (list != null) {

                        for (int i = 0; i < list.size(); i++) {

                            if (i == 10) {

                                break;

                            }

                            goodsList.add(list.get(i).getTaoBaoGoodsBrief());

                        }

                    }

                } catch (Exception e2) {

                    e2.printStackTrace();

                }

				
            }

        }



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

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

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

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

		
        goodsList.parallelStream().forEach(goods -> {

            // 获取详情

            TaoBaoGoodsBrief taoBaoGoodsBrief = null;

            try {

                taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(goods.getAuctionId());

            } catch (Exception e) {

                e.printStackTrace();

            }

			
            if (taoBaoGoodsBrief != null) {

                listExtra.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion, fcRate, ""));

            }

				
        });



		
        List<TaoBaoGoodsBrief> listQuality = new ArrayList<TaoBaoGoodsBrief>();

		
        try {

            List<QualityFactory> listRecommend = qualityGoodsService.recommendByAuctionId(id);

			
            if (listRecommend != null && listRecommend.size() > 1) {

                for (QualityFactory quality : listRecommend) {



                    TaoBaoGoodsBrief taoBaoGoodsBrief = quality.getTaoBaoGoodsBrief();

                    if (taoBaoGoodsBrief == null) {

                        continue;

                    }



                    int biz30day = taoBaoGoodsBrief.getBiz30day();

                    if (biz30day >= 10000) {

                        double sales = biz30day;

                        String salesCountMidea = String.format("%.1f", sales / 10000);

                        taoBaoGoodsBrief.setSalesCount(salesCountMidea + "万");

                    } else {

                        taoBaoGoodsBrief.setSalesCount(biz30day + "");

                    }



                    // 改变图片尺寸

                    String pictUrl = taoBaoGoodsBrief.getPictUrl();

                    if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) {

                        taoBaoGoodsBrief.setPictUrl(TbImgUtil.getTBSize320Img(pictUrl));

                    }



                    listQuality.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion, fcRate, null));

                }

            }

        } catch (Exception e2) {

            e2.printStackTrace();

        }

		
		
        // 取偶数个数据

        if (listExtra.size() % 2 != 0) {

            listExtra.remove(listExtra.size() - 1);

        }

		
        if (listQuality.size() % 2 != 0) {

            listQuality.remove(listQuality.size() - 1);

        }

		
        JSONObject data = new JSONObject();

        data.put("listGuess", JsonUtil.getApiCommonGson().toJson(listExtra));

        data.put("listQuality", JsonUtil.getApiCommonGson().toJson(listQuality));

		
        out.print(JsonUtil.loadTrueResult(data));

    }



}


 fanli/src/main/java/com/yeshi/fanli/dao/mybatis/lable/QualityFactoryMapper.java

@@ -341,4 +341,10 @@
    
    long countRecommendBykey(@Param("key") String key, @Param("hasQuan") Integer hasQuan,  
            @Param("userType") Integer userType,@Param("startprice") Double startprice, @Param("endprice") Double endprice);


    List<QualityFactory> listQueryBylabIDs(@Param("start") long start, @Param("count") int count, 
            @Param("list") List<Long> list, @Param("gid") Long gid,@Param("systemCid") Long systemCid);


}

 fanli/src/main/java/com/yeshi/fanli/dao/mybatis/user/ShamUserMapper.java

@@ -31,4 +31,7 @@
    
    List<ShamUser> listByDistinctPicUrl(@Param("start")long start, @Param("count")int count);
    
    // 随机取出数据
    List<ShamUser> listRand(@Param("count") int count);
	
}

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/ShamUser.java

@@ -6,21 +6,36 @@
import javax.persistence.GenerationType;

import javax.persistence.Id;

import javax.persistence.Table;

import javax.persistence.Transient;



//假用户

@Entity

@Table(name="yeshi_ec_sham_user")//@com.yeshi.utils.mybatis.Table("yeshi_ec_demouser")

@Table(name = "yeshi_ec_sham_user")

@org.yeshi.utils.mybatis.Table("yeshi_ec_sham_user")

public class ShamUser {

    @Id

    @GeneratedValue(strategy=GenerationType.AUTO)

    @Column(name="`id`")

    @GeneratedValue(strategy = GenerationType.AUTO)

    @Column(name = "`id`")

    private long id;

    @Column(name="`name`")



    @Column(name = "`name`")

    private String name;



    @Column(name = "`picUrl`")

    private String picUrl;



    @Transient

    private String msg;



    @Transient

    private String showId;



    @Transient

    private String shareBonusPic;



    public ShamUser() {

    }

	


    public ShamUser(long id) {

        super();

        this.id = id;

@@ -29,20 +44,49 @@
    public long getId() {

        return id;

    }



    public void setId(long id) {

        this.id = id;

    }



    public String getName() {

        return name;

    }



    public void setName(String name) {

        this.name = name;

    }



    public String getPicUrl() {

        return picUrl;

    }



    public void setPicUrl(String picUrl) {

        this.picUrl = picUrl;

    }

	


    public String getMsg() {

        return msg;

    }



    public void setMsg(String msg) {

        this.msg = msg;

    }



    public String getShowId() {

        return showId;

    }



    public void setShowId(String showId) {

        this.showId = showId;

    }



    public String getShareBonusPic() {

        return shareBonusPic;

    }



    public void setShareBonusPic(String shareBonusPic) {

        this.shareBonusPic = shareBonusPic;

    }



}


 fanli/src/main/java/com/yeshi/fanli/entity/taobao/TaoBaoShopInfo.java

@@ -19,6 +19,9 @@
    private String sellerNick;// 卖家昵称

    private String pictureUrl;// 店铺图标

    private String shopUrl;// 店铺地址

	
    private String userType;// 店铺类型  1-天猫  0-淘宝()

	


    public TaoBaoShopInfo() {



@@ -83,4 +86,12 @@
        this.shopUrl = shopUrl;

    }



    public String getUserType() {

        return userType;

    }



    public void setUserType(String userType) {

        this.userType = userType;

    }



}


 fanli/src/main/java/com/yeshi/fanli/mapping/lable/QualityFactoryMapper.xml

@@ -57,7 +57,34 @@
            javaType="com.yeshi.fanli.entity.common.AdminUser">
            <id column="sg_update_aid" property="id" jdbcType="BIGINT" />
    </association>
 
  </resultMap>
  
  <resultMap id="GoodsResultMap" type="com.yeshi.fanli.entity.bus.lable.QualityFactory">
    <id column="sg_id" property="id" jdbcType="BIGINT"/>
    <result column="sg_class_id" property="systemCid" jdbcType="BIGINT"/>
    <result column="sg_entry_mode" property="entryMode" jdbcType="INTEGER"/>
    <result column="sg_goods_source" property="goodsSource" jdbcType="INTEGER"/>
    <result column="sg_source_calss" property="sourceCalss" jdbcType="VARCHAR"/>
    <result column="sg_weight" property="weight" jdbcType="INTEGER"/>
    <result column="sg_createtime" property="createtime" jdbcType="TIMESTAMP"/>
    <result column="sg_updatetime" property="updatetime" jdbcType="TIMESTAMP"/>
    
      <association property="boutiqueAutoRule" column="sg_rule_id" 
        javaType="com.yeshi.fanli.entity.bus.lable.BoutiqueAutoRule">
            <id column="sg_rule_id" property="id" jdbcType="BIGINT" />
    </association>
 	
     <association property="taoBaoGoodsBrief" column="sg_goods_id"
      resultMap="com.yeshi.fanli.dao.mybatis.taobao.TaoBaoGoodsBriefMapper.BaseResultMap"/>
 	
      <association property="createUser" column="sg_create_aid" 
        javaType="com.yeshi.fanli.entity.common.AdminUser">
            <id column="sg_create_aid" property="id" jdbcType="BIGINT" />
    </association>
    <association property="updateUser" column="sg_update_aid"
            javaType="com.yeshi.fanli.entity.common.AdminUser">
            <id column="sg_update_aid" property="id" jdbcType="BIGINT" />
    </association>
  </resultMap>
  
  <sql id="Base_Column_List">sg_id,sg_class_id,sg_goods_id,sg_entry_mode,sg_goods_source,sg_source_calss,sg_rule_id,sg_weight,sg_create_aid,sg_createtime,sg_update_aid,sg_updatetime</sql>
@@ -1113,4 +1140,24 @@
        </if>
    </select>
    
    <select id="listQueryBylabIDs" resultMap="GoodsResultMap"> 
          SELECT * FROM (
            SELECT DISTINCT( tt.`sg_id`) AS tbid  FROM yeshi_ec_quality_factory tt 
			
            LEFT JOIN yeshi_ec_taobao_goods tb ON tt.`sg_goods_id`= tb.`id` 
			
            LEFT JOIN yeshi_ec_label_goods lg ON tt.`sg_goods_id` = lg.`lg_goods_id` 
				
                WHERE tb.`id` != #{gid} 
                    <if test='systemCid != null'>
                           AND  tt.`sg_class_id` = #{systemCid}  
                    </if>
                     AND  lg.`lg_label_id` IN
                <foreach collection="list" item="item" open="(" close=")"
                    separator=",">#{item}</foreach>
              LIMIT ${start},${count}
         ) a LEFT JOIN yeshi_ec_quality_factory ts ON ts.`sg_id`=a.tbid 
             LEFT JOIN yeshi_ec_taobao_goods tbb ON ts.`sg_goods_id`= tbb.`id`
   </select> 
	
</mapper>

 fanli/src/main/java/com/yeshi/fanli/mapping/taobao/TaoBaoGoodsBriefMapper.xml

@@ -183,7 +183,7 @@
            <if test="tkMktStatus != null">tkMktStatus,</if>
            <if test="updatetime != null">updatetime,</if>
            <if test="state != null">state,</if>
            <if test="state != null">totalSales,</if>
            <if test="totalSales != null">totalSales,</if>
        </trim>
        values
        <trim prefix="(" suffix=")" suffixOverrides=",">

 fanli/src/main/java/com/yeshi/fanli/mapping/user/ShamUserMapper.xml

@@ -61,5 +61,8 @@
        LEFT JOIN yeshi_ec_demouser B ON  A.id = B.id
    </select>

 
     <select id="listRand" resultMap="BaseResultMap">
        SELECT <include refid="Base_Column_List" /> FROM yeshi_ec_sham_user ORDER BY  RAND() LIMIT #{count}
    </select>
    
</mapper>

 fanli/src/main/java/com/yeshi/fanli/service/impl/lable/QualityGoodsServiceImpl.java

@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.impl.lable;



import java.util.ArrayList;

import java.util.List;



import javax.annotation.Resource;

@@ -16,6 +17,8 @@
import com.yeshi.fanli.dao.mybatis.lable.QualityFactoryMapper;

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

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

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

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

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

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

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

@@ -25,6 +28,7 @@
import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

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



import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.taobao.TbImgUtil;



@@ -334,5 +338,42 @@
        return countRecommend(pop, commision, couponAmount, tkRate, couponRatio);

    }

    

	
    @Override

    public List<QualityFactory> recommendByAuctionId(Long auctionId){

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

        list.add(auctionId);

        List<QualityFactory> listTaoBaoGoods = qualityFactoryMapper.listQueryByAuctionId(list);

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

            return null;

        }

		
        QualityFactory qualityFactory = listTaoBaoGoods.get(0);

        TaoBaoGoodsBrief goodsBrief = qualityFactory.getTaoBaoGoodsBrief();

        if (goodsBrief == null) {

            return null;

        }

		
        List<LabelGoods> listLab = labelGoodsMapper.queryByGoodsId(0, 200, goodsBrief.getId());

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

            return null;

        }

		
        // 标签id

        List<Long> listId = new ArrayList<Long>();

        for (LabelGoods labelGoods: listLab) {

            Label label = labelGoods.getLabel();

            if (label != null) {

                listId.add(label.getId());

            }

        }

		
        if (listId.size() == 0) {

            return null;

        }

		
        return qualityFactoryMapper.listQueryBylabIDs(0, 10, listId, goodsBrief.getId(),qualityFactory.getSystemCid());

    }

}


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

@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.impl.user;



import java.math.BigDecimal;

import java.text.DecimalFormat;

import java.util.ArrayList;

import java.util.Collections;

@@ -8,7 +9,8 @@


import javax.annotation.Resource;



import org.apache.ibatis.annotations.Param;

import net.sf.json.JSONArray;



import org.hibernate.HibernateException;

import org.hibernate.SQLQuery;

import org.hibernate.Session;

@@ -20,8 +22,10 @@
import com.yeshi.fanli.dao.user.ShamUserDao;

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

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.Utils;



@Service

@@ -32,6 +36,9 @@
    

    @Resource

    private ShamUserMapper shamUserMapper;

	
    @Resource

    private ConfigService configService;

    

    

    @Transactional

@@ -182,6 +189,84 @@
    public List<ShamUser> listDistinctPicUrl(long start, int count) {

        return shamUserMapper.listByDistinctPicUrl(start, count);

    }

	
	
    @Override

    public List<ShamUser> listRandCouponUser(int count, int smallTime, int largeTime) {

        List<Integer> listTime = new ArrayList<Integer>();



        while (listTime.size() < count) {

            int time = smallTime + (int) (Math.random() * (largeTime - smallTime + 1));

            if (!listTime.contains(Integer.valueOf(time))) {

                listTime.add(Integer.valueOf(time));

            }

        }



        Collections.sort(listTime);



        List<ShamUser> listRand = shamUserMapper.listRand(count);



        for (int i = 1; i <= count; i++) {

            ShamUser shamUser = (ShamUser) listRand.get(i - 1);



            transformId(shamUser);



            shamUser.setMsg(listTime.get(listTime.size() - i) + "秒前领券购买了这个商品");

        }



        return listRand;

    }



    @Override

    public List<ShamUser> listRandShareUser(int count, BigDecimal shareMoney, int small, int large) {

		
        List<Integer> listMultiple = new ArrayList<Integer>();



        while (listMultiple.size() < count) {

            int Multiple = small + (int) (Math.random() * (large - small + 1));

            listMultiple.add(Integer.valueOf(Multiple));

        }



        List<String> imgList = new ArrayList<String>();

        String value = configService.get("shareBonusPicture");



        if (!StringUtil.isNullOrEmpty(value)) {

            JSONArray array = JSONArray.fromObject(value);

            if (array != null) {

                for (int n = 0; n < array.size(); n++) {

                    imgList.add(array.optString(n));

                }

            }



        }



        List<ShamUser> listRand = shamUserMapper.listRand(count);



        for (int i = 0; i < count; i++) {

            ShamUser shamUser = (ShamUser) listRand.get(i);



            transformId(shamUser);



            if (imgList.size() > 0) {

                int randBonusPic = (int) (Math.random() * imgList.size());

                shamUser.setShareBonusPic((String) imgList.get(randBonusPic));

            }



            BigDecimal money = shareMoney.multiply(new BigDecimal(((Integer) listMultiple.get(i)).intValue())).setScale(2, 1);

            shamUser.setMsg("分享了这个商品,累计获得<font color=\"red\">奖金" + money + "</font>");

        }



        return listRand;

    }



    public void transformId(ShamUser shamUser) {

        String id = shamUser.getId() + "";

		
        if (id.length() == 1) {

            shamUser.setShowId("2****" + id);

        } else {

            shamUser.setShowId(id.substring(0, 1) + "****" + id.substring(id.length() - 2, id.length() - 1));

        }

    }



}


 fanli/src/main/java/com/yeshi/fanli/service/inter/lable/QualityGoodsService.java

@@ -173,5 +173,12 @@
    

    public long countRecommendToIndex(String proportion);

    

	
    /**

     * 单个商品根据标签推荐商品

     * @param paramLong

     * @param paramString1

     * @param paramString2

     * @return

     */

    public  List<QualityFactory> recommendByAuctionId(Long paramLong);

}


 fanli/src/main/java/com/yeshi/fanli/service/inter/user/ShamUserService.java

@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.inter.user;



import java.math.BigDecimal;

import java.util.List;



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

@@ -39,4 +40,24 @@
    public int updateByPrimaryKey(ShamUser record);



    public List<ShamUser> listDistinctPicUrl(long start, int count);



    /**

     * 领券提示

     * @param count

     * @param smallTime

     * @param largeTime

     * @return

     */

    public List<ShamUser> listRandCouponUser(int count, int smallTime, int largeTime);



    /**

     * 分享奖金

     * @param count

     * 
     * @param shareMoney

     * @param small

     * @param large

     * @return

     */

    public List<ShamUser> listRandShareUser(int count, BigDecimal shareMoney, int small, int large);

}