大淘客新版数据修正

admin

2019-08-13 f77b296544517db3f2cb56aab9c754d4810cc35d

大淘客新版数据修正

 fanli/src/main/java/com/yeshi/fanli/dao/goods/taobao/dataoke/DaTaoKeGoodsDetailV2Dao.java

@@ -160,4 +160,21 @@
        return mongoTemplate.find(query, getEntityClass());

    }



    /**

     * 查询删除更新时间超过一段时间的

     * 
     * @param minUpdateTime

     * @param start

     * @param count

     * @return

     */

    public int listAndRemoveByMinUpdateTime(Date minUpdateTime, int start, int count) {

        Query query = new Query();

        query.addCriteria(Criteria.where("updateTime").lt(minUpdateTime));

        query.skip(start);

        query.limit(count);

        List<DaTaoKeDetailV2> list = mongoTemplate.findAllAndRemove(query, DaTaoKeDetailV2.class);

        return list.size();

    }



}


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

@@ -1,5 +1,7 @@
package com.yeshi.fanli.job;



import java.util.Date;



import javax.annotation.Resource;



import org.springframework.scheduling.annotation.Scheduled;

@@ -120,4 +122,14 @@
        }

    }



    /**

     * 删除过期数据（每10分钟删除一次）

     */

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

    public void doDeleteOutOfDate() {

        if (!Constant.IS_TASK)

            return;

        daTaoKeGoodsDetailV2Service.deleteOutOfDate(new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L));

    }



}


 fanli/src/main/java/com/yeshi/fanli/mapping/hongbao/HongBaoV2Mapper.xml

@@ -100,7 +100,7 @@
        h.`hb_pre_get_time` IS NOT
        NULL AND h.`hb_pre_get_time`
        <![CDATA[ <]]>
        NOW() limit #{count}
        NOW()  order by hb_pre_get_time desc limit #{count}
    </select>

    <!-- 获取用户奖金列表 -->

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java

@@ -228,7 +228,7 @@
    @Override

    public void fanli() {

        // 获取主红包

        List<HongBaoV2> hongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByType(HongBao.TYPE_TAOBAO, 1000);

        List<HongBaoV2> hongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByType(HongBaoV2.TYPE_ZIGOU, 1000);

        //

        // /**

        // * 需要实时更新待返利的订单


 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/dataoke/DaTaoKeGoodsDetailV2ServiceImpl.java

@@ -43,7 +43,6 @@


        int totalCount = 0;

        try {



            DaTaoKeGoodsResult result = DaTaoKeApiUtil.listAll("1");

            int page = 0;



@@ -69,6 +68,8 @@
                    e.printStackTrace();

                }

            }

        } catch (Exception e) {

            LogHelper.errorDetailInfo(e, "大淘客全量数据出错", "");

        } finally {

            LogHelper.test("大淘客新版商品同步数量:" + totalCount);

        }

@@ -271,4 +272,9 @@
            return new ArrayList<>();

    }



    @Override

    public void deleteOutOfDate(Date minTime) {

        daTaoKeGoodsDetailV2Dao.listAndRemoveByMinUpdateTime(minTime, 0, 3000);

    }



}


 fanli/src/main/java/com/yeshi/fanli/service/inter/taobao/dataoke/DaTaoKeGoodsDetailV2Service.java

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



import java.util.Date;

import java.util.List;



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

@@ -114,9 +115,17 @@
    

    /**

     * 拉取自购立减备选商品

     * 
     * @param page

     * @return

     */

    public List<DaTaoKeDetailV2> listPreTLJBuyGoods(int page);



    /**

     * 删除过期数据

     * 
     * @param minTime

     */

    public void deleteOutOfDate(Date minTime);



}


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

@@ -1689,7 +1689,7 @@
    public static void taoKeContent() {

        Map<String, String> map = new HashMap<>();

        map.put("method", "taobao.tbk.content.get");

        map.put("adzone_id", TaoBaoConstant.TAOBAO_SPECIAL_PID_DEFAULT.split("_")[3]);

        map.put("adzone_id", TaoBaoConstant.TAOBAO_RELATION_PID_DEFAULT.split("_")[3]);

        map.put("type", "1");

        map.put("count", "100");