爬取订单规则修改 事务添加

admin

2019-01-30 e9b8461ed03f2548be58733309689e61f7d6f6cc

爬取订单规则修改
事务添加

 fanli/src/main/java/com/yeshi/fanli/controller/AuthCallBackController.java

@@ -44,6 +44,7 @@
    public void tb(String code, String state, HttpServletRequest request, HttpServletResponse response) {

        LogHelper.test("淘宝授权回调:" + code+"："+state);

        if (StringUtil.isNullOrEmpty(code) || StringUtil.isNullOrEmpty(state)) {

            LogHelper.error("淘宝授权回调出错");

            try {

                response.sendRedirect("http://apph5.yeshitv.com/apppage/flq_bonusState.html?code=1");

            } catch (IOException e1) {


 fanli/src/main/java/com/yeshi/fanli/job/UpdateRelationAndSpecialOrderJob.java

@@ -35,6 +35,11 @@
    @Resource

    private RedisManager redisManager;



    /**

     * 更新渠道订单(最多20分钟)

     * 
     * @param startTime

     */

    private void updateRelationOrder(long startTime) {

        String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");

        List<TaoBaoOrder> orderList = TaoKeApiUtil.getTaoBaoRelationOrder(startTimeStr, Constant.TAOBAO_AUTH_APPKEY,

@@ -42,11 +47,40 @@
        addRelationAndSpecialOrder(orderList);

    }



    /**

     * 按天更新

     * 
     * @param day

     */

    private void updateRelationOrderByDay(String day) {

        long timestamp = TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd");

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

            updateRelationOrder(timestamp + 1000 * 60 * 20L * i);

        }

    }



    /**

     * 更新会员订单(最多20分钟)

     * 
     * @param startTime

     */

    private void updateSpecialOrder(long startTime) {

        String startTimeStr = TimeUtil.getGernalTime(startTime, "yyyy-MM-dd HH:mm:ss");

        List<TaoBaoOrder> orderList = TaoKeApiUtil.getTaoBaoSpecialOrder(startTimeStr, Constant.TAOBAO_AUTH_APPKEY,

                Constant.TAOBAO_AUTH_APPSECRET);

        addRelationAndSpecialOrder(orderList);

    }



    /**

     * 按天更新

     * 
     * @param day

     */

    private void updateSpecialOrderByDay(String day) {

        long timestamp = TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd");

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

            updateSpecialOrder(timestamp + 1000 * 60 * 20L * i);

        }

    }



    private void addRelationAndSpecialOrder(List<TaoBaoOrder> orderList) {

@@ -108,4 +142,34 @@
        updateSpecialOrder(currentTime - 1000 * 60 * 20L);

    }



    // 每16分钟更新一次一天的（每天可更新近90天的数据）

    @Scheduled(cron = "0 0/16 * * * ? ")

    public void doJob2() {

        if (!Constant.IS_TASK)

            return;

        long currentTime = System.currentTimeMillis();

        long dayStartTime = TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(currentTime, "yyyy-MM-dd"), "yyyy-MM-dd");

        int pos = (int) ((currentTime - dayStartTime) / 1000 * 60 * 16L);



        long time = dayStartTime - (pos + 1) * 1000 * 60 * 60 * 24L;



        // 只能更新最近90天的

        if (currentTime - time > 1000 * 60 * 60 * 24L * 90)

            return;

        updateRelationOrderByDay(TimeUtil.getGernalTime(time, "yyyy-MM-dd"));

        updateSpecialOrderByDay(TimeUtil.getGernalTime(time, "yyyy-MM-dd"));

    }



    // 每个小时更新最近1天的数据

    @Scheduled(cron = "0 0 0/1 * * ? ")

    public void doJob3() {

        if (!Constant.IS_TASK)

            return;

        long startTime = System.currentTimeMillis() - 1000 * 60 * 60 * 24L;

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

            updateRelationOrder(startTime + 1000 * 60 * 20L * i);

            updateSpecialOrder(startTime + 1000 * 60 * 20L * i);

        }

    }



}


 fanli/src/main/java/com/yeshi/fanli/service/impl/activity/ActivityServiceImpl.java

@@ -13,6 +13,7 @@


import org.springframework.cache.annotation.Cacheable;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.entity.FileUploadResult;

import org.yeshi.utils.taobao.TbImgUtil;



@@ -306,6 +307,7 @@
        return activityUserMapper.selectList();

    }



    @Transactional

    @Override

    public RecommendActivity addShareGoodsRecommendActivity(Long activityUid, String title, List<Long> goodsList,

            boolean top, int shareCount) throws ActivityException {

@@ -369,9 +371,12 @@
        return activity;

    }



    @Transactional

    @Override

    public RecommendActivity addInviteImgRecommendActivity(Long activityUid, String title, String url, boolean top,

            int shareCount, int px, int py, int erCodeSize) throws ActivityException {

        if (StringUtil.isNullOrEmpty(url))

            throw new ActivityException(1, "图片为空");

        RecommendActivity activity = new RecommendActivity();

        activity.setActivityUser(new ActivityUser(activityUid));

        activity.setCreateTime(new Date());

@@ -401,11 +406,11 @@
        recommendActivityInviteInfo.setRecommendActivity(activity);

        recommendActivityInviteInfo.setSize(erCodeSize);

        recommendActivityInviteInfoMapper.insertSelective(recommendActivityInviteInfo);



        recommendActivityImgMapper.insertSelective(img);

        return activity;

    }



    @Transactional

    @Override

    public RecommendActivity addTextAndImgRecommendActivity(Long activityUid, String title, List<String> imgList,

            boolean top, int shareCount) throws ActivityException {

@@ -436,6 +441,7 @@
        return activity;

    }



    @Transactional

    @Override

    public void deleteRecommendActivity(long[] ids) {

        recommendActivityMapper.batchDeleteByPrimaryKey(ids);

@@ -449,6 +455,7 @@
        return recommendActivityMapper.selectByPrimaryKey(id);

    }



    @Transactional

    @Override

    public RecommendActivity updateShareGoodsRecommendActivity(Long id, Long activityUid, String title,

            List<Long> goodsList, boolean top, int shareCount) throws ActivityException {

@@ -503,6 +510,7 @@
        return activity;

    }



    @Transactional

    @Override

    public RecommendActivity updateInviteImgRecommendActivity(Long id, Long activityUid, String title, String url,

            boolean top, int shareCount, int px, int py, int erCodeSize) throws ActivityException {

@@ -545,6 +553,7 @@
        return activity;

    }



    @Transactional

    @Override

    public RecommendActivity updateTextAndImgRecommendActivity(Long id, Long activityUid, String title,

            List<String> imgList, boolean top, int shareCount) throws ActivityException {

@@ -601,6 +610,7 @@
        return getRecommendActivityCount();

    }



    @Transactional

    @Override

    public void upgradeShareGoodsRecommendActivity(Long id) throws ActivityException {

        // 获取商品

@@ -706,6 +716,7 @@
        return activityUserMapper.selectByPrimaryKey(id);

    }



    @Transactional

    @Override

    public void updateRecommendActivityGoods(TaoBaoGoodsBrief goods) {

        List<RecommendActivityTaoBaoGoods> list = recommendActivityTaoBaoGoodsMapper