| | |
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void startSyncGoods() {
|
|---|
| | |
|
|---|
| | | // 判断是否有正在进行的更新
|
|---|
| | | String key1 = "dataoke-updating";
|
|---|
| | | // if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key1)))
|
|---|
| | | // return;
|
|---|
| | |
|
|---|
| | | // 开始更新
|
|---|
| | | redisManager.cacheCommonString(key1, "1", 60 * 20);
|
|---|
| | | long firstTime = System.currentTimeMillis() - 1000 * 60 * 5L;
|
|---|
| | | int totalCount = 0;
|
|---|
| | | for (int p = 1; p <= 2000; p++) {// 10W数据
|
|---|
| | |
|---|
| | | DaTaoKeApiResult result = DaTaoKeApiUtil.goodsList(p);
|
|---|
| | | if (result.getDetailList().size() < 50)// 更新完成
|
|---|
| | | {
|
|---|
| | | redisManager.removeCommonString(key1);
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | | addGoodsList(result.getDetailList());
|
|---|
| | |
|---|
| | | } catch (Exception e) {
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | LogHelper.test("大淘客总共更新数据数量:" + totalCount);
|
|---|
| | | // 清除过期数据
|
|---|
| | | if (totalCount > 50000)// 保证有5w数据再清除过期
|
|---|
