动态/品牌商品添加到重要商品更新库，推荐记录列表返回结果跳转任意更改

admin

2019-08-09 7384fd794b9bcb38cef7853cb55e56e810775678

动态/品牌商品添加到重要商品更新库，推荐记录列表返回结果跳转任意更改

 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/PushController.java

@@ -214,7 +214,8 @@
                    // 统计商品数量

                    long totalgoods = 0;

                    // 商品id

                    Long auctionId = null;

                    CommonGoods commonGoods = null;



                    if (StringUtil.isNullOrEmpty(picture)) {

                        try {

                            List<PushGoodsGroup> listGroup = pushGoodsGroupService.getAllInfoByPushId(pushId);

@@ -225,10 +226,9 @@


                                PushGoodsGroup pushGoodsGroup = listGroup.get(0);

                                if (pushGoodsGroup != null) {

                                    CommonGoods commonGoods = pushGoodsGroup.getCommonGoods();

                                    commonGoods = pushGoodsGroup.getCommonGoods();

                                    if (commonGoods != null) {

                                        picture = commonGoods.getPicture();

                                        auctionId = commonGoods.getGoodsId();

                                    }

                                }

                            }

@@ -265,8 +265,8 @@


                    JumpDetailV2 jumpDetail = null;

                    if (totalgoods == 1) {



                        params = JumpDetailParamsFactory.createGoodsParams(auctionId);

                        params = JumpDetailParamsFactory.createGoodsParams(commonGoods.getGoodsId(),

                                commonGoods.getGoodsType());

                        // 单个商品跳转商品详情

                        jumpDetail = jumpDetailV2Service.getByTypeCache("goodsdetail",

                                Constant.getPlatformCode(acceptData.getPlatform()),


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/BrandControllerV2.java

@@ -26,6 +26,7 @@
import com.yeshi.fanli.service.inter.brand.TaoBaoShopHistoryService;

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

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

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

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

import com.yeshi.fanli.service.inter.taobao.dataoke.DaTaoKeGoodsService;

import com.yeshi.fanli.util.Constant;

@@ -64,6 +65,9 @@
    @Resource

    private DaTaoKeGoodsService daTaoKeGoodsService;



    @Resource

    private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;



    /**

     * 店铺列表

     * 

@@ -83,7 +87,8 @@
     * 店铺足迹

     * 

     * @param acceptData

     * @param type       精选1， 足迹列表2

     * @param type

     *            精选1， 足迹列表2

     * @param out

     */

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

@@ -298,6 +303,8 @@
        data.put("count", array.size());

        data.put("list", array);

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

        // 添加到更新列表

        taoBaoGoodsUpdateService.addUpdateQueueAsync(listGoodsBrief);

    }



}


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/GoodsClassControllerV2.java

@@ -141,8 +141,8 @@


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



        // 精选库数据为空时，网络进行查询

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

        // 精选库数据小于10时，网络进行查询

        if (listQuery == null || listQuery.size() < 10) {

            long count = qualityGoodsService.countQueryClassId(gcid);

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

            page = page - totalPage;


 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/SearchControllerV2.java

@@ -123,10 +123,7 @@
        // 去除前后空格

        text = text.trim();



        if (text.length() > 256) {

            out.print(JsonUtil.loadFalseResult("值过长"));

            return;

        }

	


        TaoBaoGoodsBrief tb = null;

        String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?";

@@ -134,6 +131,10 @@
        Pattern p = Pattern.compile(URL_REGEX);

        Matcher matcher = p.matcher(text);

        if (!matcher.find()) {// 不包含链接

            if (text.length() > 256) {

                out.print(JsonUtil.loadFalseResult("值过长"));

                return;

            }

            String pattern = "^[A-Za-z0-9-]+$";

            if (Pattern.matches(pattern, text.replace(" ", ""))) {//删除空格

                out.println(JsonUtil.loadFalseResult("不支持推荐"));


 fanli/src/main/java/com/yeshi/fanli/mapping/order/CommonOrderCountMapper.xml

@@ -65,7 +65,7 @@
            FROM  (SELECT ho.`ho_id` FROM yeshi_ec_hongbao_order ho 
                LEFT JOIN ( 
                    SELECT * FROM yeshi_ec_hongbao_v2 v2 
                    WHERE v2.`hb_uid`= ${uid} AND (v2.`hb_type` = 1 OR v2.`hb_type` = 2)
                    WHERE v2.`hb_uid`= ${uid} and v2.hb_state!=4 AND (v2.`hb_type` = 1 OR v2.`hb_type` = 2)
                    ) hb  ON hb.hb_id=ho.`ho_hongbao_id` <!-- 自购订单 -->
            LEFT JOIN yeshi_ec_common_order co ON co.`co_id`=ho.`ho_order_id`
            WHERE hb.hb_id IS NOT NULL 
@@ -95,11 +95,11 @@
            FROM  (SELECT ho.`ho_id` FROM yeshi_ec_hongbao_order ho 
                    LEFT JOIN ( 
                        SELECT * FROM yeshi_ec_hongbao_v2 v2 
                        WHERE v2.`hb_uid`= ${uid} AND v2.`hb_type` = 20
                        WHERE v2.`hb_uid`= ${uid} AND v2.`hb_type` = 20 and v2.hb_state!=4
                    ) hb  ON hb.hb_id=ho.`ho_hongbao_id`  <!-- 分享订单 -->
    
                LEFT JOIN yeshi_ec_common_order co ON co.`co_id`=ho.`ho_order_id`
                WHERE hb.hb_id IS NOT NULL
                WHERE hb.hb_id IS NOT NULL and hb.hb_state!=4
                    <if test="state != null"> 
                        AND co.`co_state` = ${state} 
                    </if>
@@ -128,10 +128,10 @@
                    SELECT * FROM yeshi_ec_hongbao_v2 v2 
                    WHERE v2.`hb_uid`= ${uid}
                         AND (v2.`hb_type` = 5 OR v2.`hb_type` = 6 OR v2.`hb_type` = 7
                               OR v2.`hb_type` = 21 OR v2.`hb_type` = 22 )
                               OR v2.`hb_type` = 21 OR v2.`hb_type` = 22 ) and v2.hb_state!=4
                    ) hbp  ON hbp.hb_pid=ho.`ho_hongbao_id`
                LEFT JOIN yeshi_ec_common_order co ON co.`co_id`=ho.`ho_order_id`
                WHERE  hbp.hb_id IS NOT NULL 
                WHERE  hbp.hb_id IS NOT NULL and hbp.hb_state!=4
                    <if test="state != null"> 
                        AND co.`co_state` = ${state} 
                    </if>

 fanli/src/main/java/com/yeshi/fanli/mapping/order/CommonOrderMapper.xml

@@ -484,7 +484,7 @@
        hb.hb_id=ho.`ho_hongbao_id`
        <!-- 自购订单 -->
        LEFT JOIN yeshi_ec_common_order co ON co.`co_id`=ho.`ho_order_id`
        WHERE hb.hb_id IS NOT NULL
        WHERE hb.hb_id IS NOT NULL and hb.hb_state!=4
        <if test="day != null and day == 1">
            <!-- 今天 -->
            AND TO_DAYS(co.`co_third_create_time`) = TO_DAYS(NOW())
@@ -517,7 +517,7 @@
        = 20 ) hb ON hb.hb_id=ho.`ho_hongbao_id`
        <!-- 分享订单 -->
        LEFT JOIN yeshi_ec_common_order co ON co.`co_id`=ho.`ho_order_id`
        WHERE hb.hb_id IS NOT NULL
        WHERE hb.hb_id IS NOT NULL  and hb.hb_state!=4
        <if test="day != null and day == 1">
            <!-- 今天 -->
            AND TO_DAYS(co.`co_third_create_time`) = TO_DAYS(NOW())
@@ -550,7 +550,7 @@
        (v2.`hb_type` = 5 OR v2.`hb_type` = 6 OR v2.`hb_type` = 7 OR
        v2.`hb_type` = 21 OR v2.`hb_type` = 22 ) ) hbp ON
        hbp.hb_pid=ho.`ho_hongbao_id` LEFT JOIN yeshi_ec_common_order co ON
        co.`co_id`=ho.`ho_order_id` WHERE hbp.hb_id IS NOT NULL
        co.`co_id`=ho.`ho_order_id` WHERE hbp.hb_id IS NOT NULL  and hbp.hb_state!=4
        <if test="day != null and day == 1">
            <!-- 今天 -->
            AND TO_DAYS(co.`co_third_create_time`) = TO_DAYS(NOW())

 fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandClassShopServiceImpl.java

@@ -29,6 +29,7 @@
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

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

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

@@ -63,6 +64,9 @@


    @Resource

    private TaoBaoGoodsBriefService taoBaoGoodsBriefService;



    @Resource

    private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;



    @Override

    public List<BrandClassShop> getExistByShopIds(List<Long> list) {

@@ -128,8 +132,8 @@


    @Override

    @Transactional

    public void changeShopInfo(MultipartFile file, Long id, Long cid, String shopName, Integer state, Integer top,String key)

            throws BrandClassShopException {

    public void changeShopInfo(MultipartFile file, Long id, Long cid, String shopName, Integer state, Integer top,

            String key) throws BrandClassShopException {



        if (id == null) {

            throw new BrandClassShopException(1, "数据为空：请选择店铺");

@@ -170,7 +174,8 @@
        for (BrandClassShop brandClassShop : listQuery) {

            TaoBaoShop shop = brandClassShop.getShop();

            if (shop != null) {

                long couponNum = commonGoodsService.countBySellerIdAndHasCoupon(shop.getId(), Constant.SOURCE_TYPE_TAOBAO);

                long couponNum = commonGoodsService.countBySellerIdAndHasCoupon(shop.getId(),

                        Constant.SOURCE_TYPE_TAOBAO);

                brandClassShop.setCouponNum(couponNum);



                String shopLink = shop.getShopLink();

@@ -337,8 +342,6 @@
        return data;

    }



	
	
    @Override

    @Cacheable(value = "brandCache", key = "'listEffectiveCacheV2-'+#page+'-'+#cid")

    public JSONObject listEffectiveCacheV2(int page, Long cid) {

@@ -430,8 +433,11 @@


            List<GoodsDetailVO> listGoods = new ArrayList<GoodsDetailVO>();

            List<TaoBaoGoodsBrief> listGoodsBrief = taoBaoShopVO.getListGoodsBrief();

            // 商品添加到更新队列

            taoBaoGoodsUpdateService.addUpdateQueueAsync(listGoodsBrief);

            for (TaoBaoGoodsBrief taoBaoGoodsBrief : listGoodsBrief) {

                GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertTaoBao(taoBaoGoodsBrief, null, fanLiRate, shareRate);

                GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertTaoBao(taoBaoGoodsBrief, null, fanLiRate,

                        shareRate);

                listGoods.add(goodsDetailVO);

            }

            taoBaoShopVO.setListGoodsVO(listGoods);

@@ -441,8 +447,6 @@


        return data;

    }

	
	
    

    @Override

    public void addClick(Long shopId) {


 fanli/src/main/java/com/yeshi/fanli/service/impl/dynamic/DynamicInfoServiceImpl.java

@@ -482,8 +482,8 @@
        

        TaoBaoGoodsBrief taoBaoGoodsBrief = TaoBaoUtil.convert(daTaoKe);

        BigDecimal proportion = hongBaoManageService.getFanLiRate();

        TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief,

                proportion.toString(), null);

        TaoBaoGoodsBriefExtra goodsExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(taoBaoGoodsBrief, proportion.toString(),

                null);

        

        if (!goodsExtra.isCoupon() || (goodsExtra.getState() != null && goodsExtra.getState() == 1)) {

            return addSuccess;  // 已下架 、无券 不加入

@@ -916,12 +916,13 @@
        return list;

    }

    

	
    @Override

    @Cacheable(value = "dynamicCache", key = "'queryV2-'+#platform+'-'+#version+'-'+#start+'-'+#count+'-'+#cid+'-'+#subId")

    public List<DynamicInfo> queryV2(int platform, int version, int start, int count, Long cid, Long subId) {

        List<DynamicInfo> listNew = new ArrayList<DynamicInfo>();

        List<DynamicInfo> list = dynamicInfoDao.query(start, count, cid, subId);

        // 需要更新的商品

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

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

            BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

            BigDecimal shareRate = hongBaoManageService.getShareRate();

@@ -963,6 +964,8 @@
                            continue;

                        }

                        

                        taoBaoGoodsUpdateList.add(goods);



                        GoodsPicture goodsNew = new GoodsPicture();

                        try {

                            PropertyUtils.copyProperties(goodsNew, goodsPicture);

@@ -971,13 +974,15 @@
                            continue;

                        }

                        

                        GoodsDetailVO detailVO = GoodsDetailVOFactory.convertTaoBaoGoodsBriefExtra(goods, fanLiRate, shareRate);

                        GoodsDetailVO detailVO = GoodsDetailVOFactory.convertTaoBaoGoodsBriefExtra(goods, fanLiRate,

                                shareRate);

                        goodsNew.setGoodsVO(detailVO);

                        goodsNew.setGoods(null);

                        

                        JumpDetailV2 jumpDetail = goodsNew.getJumpDetail();

                        if (jumpDetail != null) {

                            JumpDetailV2 jumpDetailV2 = jumpDetailV2Service.getByTypeCache(jumpDetail.getType(), platform, version);

                            JumpDetailV2 jumpDetailV2 = jumpDetailV2Service.getByTypeCache(jumpDetail.getType(),

                                    platform, version);

                            if (jumpDetailV2 != null) {

                                goodsNew.setJumpDetail(jumpDetailV2);

                            }

@@ -998,9 +1003,10 @@
                updateGoodInfo(list);

            }

        });



        taoBaoGoodsUpdateService.addUpdateQueueAsync(taoBaoGoodsUpdateList);

        return listNew;

    }

	


    /**

     * 更新商品信息


 fanli/src/main/java/com/yeshi/fanli/service/impl/push/PushServiceImpl.java

@@ -64,7 +64,6 @@
    @Resource

    private AppVersionService appVersionService;

    

	
    @Override

    public void pushGoods(Long uid,  String title, String content, String url, List<String> listIOS,

            List<String> listAndroid) throws PushException {

@@ -76,7 +75,6 @@
            throw new PushException(1, "请填写推送标题");

        if (StringUtil.isNullOrEmpty(content))

            throw new PushException(1, "请填写推送内容"); 

		
        

        /* IOS端推送   (注明：list等于 'null' 时全推， size等于0 不做推送) */

        if (listIOS == null || listIOS.size() > 0) {

@@ -94,8 +92,14 @@
            if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {

                xmPushService.pushGoods(uid, Long.parseLong(gid), title, content, versions);

            }

            // 华为推送

            if (listAndroid == null || listAndroid.size() > 0) {

                List<Integer> versionCodeList = null;

                if (listAndroid != null)

                    versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);

                hwPushService.pushGoods(uid, Long.parseLong(gid), title, content, versionCodeList);

        }

		
        }

        

        PushRecord pushRecord = new PushRecord();

        pushRecord.setUid(uid);

@@ -109,7 +113,6 @@
        pushRecordMapper.insertSelective(pushRecord);

    }



	
    @Override

    public void pushUrl(Long uid, String title, String content, String url, List<String> listIOS,

            List<String> listAndroid) throws PushException {

@@ -120,7 +123,6 @@
            throw new PushException(1, "无推送标题");

        if (StringUtil.isNullOrEmpty(content))

            throw new PushException(1, "无推送内容");

		
        

        /* IOS端推送   (注明：list等于 'null' 时全推， size等于0 不做推送) */

        if (listIOS == null || listIOS.size() > 0) {

@@ -138,8 +140,15 @@
            if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {

                xmPushService.pushUrl(uid, url, title, content, versions);

            }

        }

        

            // 华为推送

            if (listAndroid == null || listAndroid.size() > 0) {

                List<Integer> versionCodeList = null;

                if (listAndroid != null)

                    versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);

                hwPushService.pushUrl(uid, url, title, content, versionCodeList);

            }

        }

        

        PushRecord pushRecord = new PushRecord();

        pushRecord.setUid(uid);

@@ -152,10 +161,9 @@
        pushRecordMapper.insertSelective(pushRecord);

    }



	
    @Override

    public void pushZNX(Long uId, String title, String content, List<String> listIOS,

            List<String> listAndroid) throws PushException {

    public void pushZNX(Long uId, String title, String content, List<String> listIOS, List<String> listAndroid)

            throws PushException {

        if (StringUtil.isNullOrEmpty(title))

            throw new PushException(1, "无推送标题");

        if (StringUtil.isNullOrEmpty(content))

@@ -182,7 +190,6 @@
            accountMessageMapper.insertSelective(accountMessage);

        }

        

		
        /* IOS端推送   (注明：list等于 'null' 时全推， size等于0 不做推送) */

        if (listIOS == null || listIOS.size() > 0) {

            // 限制推送版本号：0

@@ -199,8 +206,15 @@
            if(listAndroid == null || (listAndroid.size() > 0 && versions != null && versions.trim().length() > 0)) {

                xmPushService.pushZNX(uId, accountMessage, systemZnx, versions);

            }

        }

        

            // 华为推送

            if (listAndroid == null || listAndroid.size() > 0) {

                List<Integer> versionCodeList = null;

                if (listAndroid != null)

                    versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);

                hwPushService.pushZNX(uId, title, content, versionCodeList);

            }

        }

        

        // 插入推送记录

        PushRecord pushRecord = new PushRecord();

@@ -212,7 +226,6 @@
        pushRecord.setCreatetime(java.lang.System.currentTimeMillis());

        pushRecordMapper.insertSelective(pushRecord);

    }



    

    @Override

    public void pushWEEX(Long uid, String title, String content, String weexUrl, List<String> listIOS,

@@ -242,6 +255,13 @@
            }

        }

        

        // 华为推送

        if (listAndroid == null || listAndroid.size() > 0) {

            List<Integer> versionCodeList = null;

            if (listAndroid != null)

                versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);

            hwPushService.pushWEEX(uid, title, content, weexUrl, versionCodeList);

        }

        

        // 插入推送记录

        PushRecord pushRecord = new PushRecord();

@@ -253,7 +273,6 @@
        pushRecord.setCreatetime(java.lang.System.currentTimeMillis());

        pushRecordMapper.insertSelective(pushRecord);

    }



    

    @Override

    public void pushBaiChuanUrl(Long uid, String title, String content, String url, List<String> listIOS,

@@ -284,6 +303,13 @@
            }

        }

        

        // 华为推送

        if (listAndroid == null || listAndroid.size() > 0) {

            List<Integer> versionCodeList = null;

            if (listAndroid != null)

                versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);

            hwPushService.pushBaiChuanUrl(uid, title, content, url, versionCodeList);

        }

        

        // 插入推送记录

        PushRecord pushRecord = new PushRecord();

@@ -297,7 +323,6 @@
        pushRecordMapper.insertSelective(pushRecord);

    }



	
    @Override

    public void pushWelfareCenter(Long uid, String title, String content, List<String> listIOS,

            List<String> listAndroid) throws PushException {

@@ -306,7 +331,6 @@
            throw new PushException(1, "无推送标题");

        if (StringUtil.isNullOrEmpty(content))

            throw new PushException(1, "无推送内容");

		
        

        /* IOS端推送   (注明：list等于 'null' 时全推， size等于0 不做推送) */

        if (listIOS == null || listIOS.size() > 0) {

@@ -326,6 +350,13 @@
            }

        }

        

        // 华为推送

        if (listAndroid == null || listAndroid.size() > 0) {

            List<Integer> versionCodeList = null;

            if (listAndroid != null)

                versionCodeList = appVersionService.listVersionCodeByVersions("android", listAndroid);

            hwPushService.pushWelfareCenter(uid, title, content, versionCodeList);

        }

        

        // 插入推送记录

        PushRecord pushRecord = new PushRecord();

@@ -338,10 +369,9 @@
        pushRecordMapper.insertSelective(pushRecord);

    }



	
	
    /**

     * 查询能推送版本号

     * 
     * @param versionCode

     * @param listVersion

     * @return

@@ -379,9 +409,9 @@
        return versions;

    }

    

	
    /**

     * 查询能推送版本号code

     * 
     * @param versionCode

     * @param listVersion

     * @return


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

@@ -70,9 +70,11 @@
     * @param auctionId

     * @return

     */

    public static String createGoodsParams(Long auctionId) {

    public static String createGoodsParams(Long auctionId, Integer goodsType) {

        JSONObject data = new JSONObject();

        data.put("id", auctionId);

        if (goodsType != null)

            data.put("goodsType", goodsType);

        return data.toString();

    }




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

@@ -77,7 +77,7 @@
        ca.setTime(time);

        ca.add(Calendar.MONTH, -1);



        String timeF = TimeUtil.getGernalTime(ca.getTimeInMillis(), "yyyy年MM月");

        String timeF = TimeUtil.getGernalTime(ca.getTimeInMillis(), "yyyy.M");



        UserMoneyDetail detail = new UserMoneyDetail();

        detail.setCreateTime(new Date());

@@ -119,7 +119,7 @@
        ca.setTime(time);

        ca.add(Calendar.MONTH, -1);



        String timeF = TimeUtil.getGernalTime(ca.getTimeInMillis(), "yyyy年MM月");

        String timeF = TimeUtil.getGernalTime(ca.getTimeInMillis(), "yyyy.M");



        UserMoneyDetail detail = new UserMoneyDetail();

        detail.setCreateTime(new Date());


 fanli/src/main/java/com/yeshi/fanli/util/jd/JDUtil.java

@@ -544,14 +544,20 @@
    }



    static String jdGoodsJs = null;



    public static String getJDGoodsId(String url) {

    static ScriptEngine engine = null;

    static {

        if (jdGoodsJs == null)

            jdGoodsJs = getJDGoodsJS();

        ScriptEngineManager manager = new ScriptEngineManager();

        ScriptEngine engine = manager.getEngineByName("javascript");

        engine = manager.getEngineByName("javascript");

        try {

            engine.eval(jdGoodsJs);

        } catch (Exception e) {

        }

    }



    public static String getJDGoodsId(String url) {

        try {

            if (engine instanceof Invocable) {

                Invocable in = (Invocable) engine;

                String goodsId = in.invokeFunction("getGoodsId", url).toString();


 fanli/src/main/java/com/yeshi/fanli/util/pinduoduo/PinDuoDuoUtil.java

@@ -13,6 +13,7 @@
import javax.script.Invocable;

import javax.script.ScriptEngine;

import javax.script.ScriptEngineManager;

import javax.script.ScriptException;



import org.apache.commons.httpclient.HttpClient;

import org.apache.commons.httpclient.methods.PostMethod;

@@ -496,14 +497,23 @@
    }



    static String jdGoodsJs = null;



    public static String getPDDGoodsId(String url) {

    static ScriptEngine engine = null;

    static {

        if (jdGoodsJs == null)

            jdGoodsJs = getJDGoodsJS();

        ScriptEngineManager manager = new ScriptEngineManager();

        ScriptEngine engine = manager.getEngineByName("javascript");

        engine = manager.getEngineByName("javascript");

        try {

            engine.eval(jdGoodsJs);

        } catch (ScriptException e) {

            e.printStackTrace();

        }



    }



    public static String getPDDGoodsId(String url) {



        try {

            if (engine instanceof Invocable) {

                Invocable in = (Invocable) engine;

                String goodsId = in.invokeFunction("getGoodsId", url).toString();