动态自动删除过期

yujian

2020-04-29 8b25dae4f4481a72a1adbb09a6628f2e001f45b1

动态自动删除过期

 fanli/src/main/java/com/yeshi/fanli/dao/dynamic/GoodsEvaluateDao.java

@@ -206,4 +206,19 @@
        query.with(new Sort(Sort.Direction.ASC,"createTime"));
        return mongoTemplate.find(query, GoodsEvaluate.class);
    }
	
	
    /**
     * 查询有效
     * @param start
     * @param count
     * @param key
     * @return
     */
    public List<GoodsEvaluate> removeDownGoods() {
        Query query = new Query();
        query.addCriteria(Criteria.where("type").is("single"));
        query.addCriteria(Criteria.where("goods.state").is(1));
        return mongoTemplate.find(query, GoodsEvaluate.class);
    }
}

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

@@ -1514,6 +1514,8 @@

                // 删除已过期
                removeOverdue();
				
                removeDownGoods();
            }
        });

@@ -1681,6 +1683,8 @@

                // 删除已过期
                removeOverdue();
				
                removeDownGoods();
            }
        });

@@ -2369,6 +2373,9 @@
    }
    

    /**
     * 删除已过期时间
     */
    private void removeOverdue() {
        List<GoodsEvaluate> list = goodsEvaluateDao.queryOverdue();
        if (list == null || list.size() == 0) {
@@ -2390,4 +2397,21 @@
        }
    }

    /**
     * 删除商品已下架-单品
     */
    private void removeDownGoods() {
        try {
            List<GoodsEvaluate> list = goodsEvaluateDao.removeDownGoods();
            if (list == null || list.size() == 0) {
                return;
            }

            for (GoodsEvaluate goodsEvaluate : list) {
                goodsEvaluateDao.remove(goodsEvaluate);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}