package com.yeshi.fanli.dao.goods.taobao.dataoke;
|
|
import java.lang.reflect.Field;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.regex.Pattern;
|
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.domain.Sort.Direction;
|
import org.springframework.data.domain.Sort.Order;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
import org.springframework.data.mongodb.core.query.Update;
|
import org.springframework.stereotype.Repository;
|
|
import com.yeshi.fanli.dao.MongodbBaseDao;
|
import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.StringUtil;
|
|
@Repository
|
public class DaTaoKeGoodsDetailV2Dao extends MongodbBaseDao<DaTaoKeDetailV2> {
|
|
public void updateSelective(DaTaoKeDetailV2 v2) {
|
// 计算佣金
|
DaTaoKeDetailV2 old = get(v2.getId());
|
if (old != null) {// 更新
|
Query query = new Query();
|
query.addCriteria(Criteria.where("id").is(v2.getId()));
|
Field[] fields = DaTaoKeDetailV2.class.getDeclaredFields();
|
|
Update update = new Update();
|
for (Field f : fields) {
|
f.setAccessible(true);
|
String name = f.getName();
|
Object value = null;
|
try {
|
value = f.get(v2);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
if (value != null)
|
update.set(name, value);
|
}
|
update(query, update);
|
}
|
}
|
|
public void saveWithCommision(DaTaoKeDetailV2 v2) {
|
v2.setUpdateTime(new Date());
|
BigDecimal commision = MoneyBigDecimalUtil
|
.div(MoneyBigDecimalUtil.mul(v2.getActualPrice(), v2.getCommissionRate()), new BigDecimal(100));
|
int commissionInt = commision.multiply(new BigDecimal(100)).intValue();
|
v2.setCommission(commissionInt);
|
save(v2);
|
}
|
|
public DaTaoKeDetailV2 selectLatest() {
|
Query query = new Query();
|
List<Order> orders = new ArrayList<>();
|
orders.add(new Order(Direction.DESC, "createTime"));
|
query.with(new Sort(orders));
|
query.limit(1);
|
List<DaTaoKeDetailV2> list = mongoTemplate.find(query, getEntityClass());
|
if (list != null && list.size() > 0)
|
return list.get(0);
|
else
|
return null;
|
}
|
|
public List<DaTaoKeDetailV2> listByGoodsIds(List<Long> goodsIdList) {
|
if (goodsIdList == null || goodsIdList.size() == 0)
|
return null;
|
Query query = new Query();
|
Criteria[] criterias = new Criteria[goodsIdList.size()];
|
for (int i = 0; i < goodsIdList.size(); i++) {
|
criterias[i] = Criteria.where("goodsId").is(goodsIdList.get(i));
|
}
|
query.addCriteria(new Criteria().orOperator(criterias));
|
return mongoTemplate.find(query, getEntityClass());
|
}
|
|
public List<DaTaoKeDetailV2> listByIds(List<Long> idsList) {
|
if (idsList == null || idsList.size() == 0)
|
return null;
|
Query query = new Query();
|
Criteria[] criterias = new Criteria[idsList.size()];
|
for (int i = 0; i < idsList.size(); i++) {
|
criterias[i] = Criteria.where("id").is(idsList.get(i));
|
}
|
|
query.addCriteria(new Criteria().orOperator(criterias));
|
return mongoTemplate.find(query, getEntityClass());
|
}
|
|
public List<DaTaoKeDetailV2> listByDtitle(String dtitle) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("dtitle").is(dtitle));
|
return mongoTemplate.find(query, getEntityClass());
|
}
|
|
public List<DaTaoKeDetailV2> listSearchByTitleWithCid(String key, Long cid, int start, int count) {
|
Pattern pattern = Pattern.compile("^.*" + key + ".*$", Pattern.CASE_INSENSITIVE);
|
List<Criteria> criteriasList = new ArrayList<>();
|
criteriasList.add(Criteria.where("dtitle").regex(pattern));
|
criteriasList.add(Criteria.where("title").regex(pattern));
|
Criteria[] criterias = new Criteria[criteriasList.size()];
|
Query query = new Query();
|
if (cid != null)
|
query.addCriteria(new Criteria().andOperator(Criteria.where("cid").is(Integer.parseInt(cid + "")),
|
new Criteria().orOperator(criteriasList.toArray(criterias))));
|
else
|
query.addCriteria(new Criteria().orOperator(criteriasList.toArray(criterias)));
|
query.skip(start);
|
query.limit(count);
|
return mongoTemplate.find(query, getEntityClass());
|
}
|
|
public long countSearchByTitleWithCid(String key, Long cid) {
|
Pattern pattern = Pattern.compile("^.*" + key + ".*$", Pattern.CASE_INSENSITIVE);
|
List<Criteria> criteriasList = new ArrayList<>();
|
criteriasList.add(Criteria.where("dtitle").regex(pattern));
|
criteriasList.add(Criteria.where("title").regex(pattern));
|
Criteria[] criterias = new Criteria[criteriasList.size()];
|
Query query = new Query();
|
if (cid != null)
|
query.addCriteria(new Criteria().andOperator(Criteria.where("cid").is(Integer.parseInt(cid + "")),
|
new Criteria().orOperator(criteriasList.toArray(criterias))));
|
else
|
query.addCriteria(new Criteria().orOperator(criteriasList.toArray(criterias)));
|
return mongoTemplate.count(query, getEntityClass());
|
}
|
|
public List<DaTaoKeDetailV2> getGoodsNotInList(Long cid, List<Long> listId, int count) {
|
List<Criteria> criteriasList = new ArrayList<>();
|
if (cid != null)
|
criteriasList.add(Criteria.where("cid").is(Integer.parseInt(cid + "")));
|
if (listId != null)
|
for (Long id : listId)
|
criteriasList.add(Criteria.where("id").ne(id));
|
// 更新时间倒序
|
List<Order> orders = new ArrayList<>();
|
orders.add(new Order(Direction.DESC, "updateTime"));
|
|
Criteria[] criterias = new Criteria[criteriasList.size()];
|
Query query = new Query();
|
query.with(new Sort(orders));
|
query.addCriteria(new Criteria().andOperator(criteriasList.toArray(criterias)));
|
query.limit(count);
|
return mongoTemplate.find(query, getEntityClass());
|
}
|
|
/**
|
* 爆款商品备选库
|
*
|
* @return
|
*/
|
public List<DaTaoKeDetailV2> listPreShareHotGoods(int start, int count, String sortName, BigDecimal minCommission) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("commission").gt(minCommission.multiply(new BigDecimal(100)).intValue()));
|
List<Order> orders = new ArrayList<>();
|
orders.add(new Order(Direction.DESC, sortName));
|
query.with(new Sort(orders)).skip(start);
|
query.limit(count);
|
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();
|
}
|
|
public long countByMinUpdateTime(Date minUpdateTime) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("updateTime").gt(minUpdateTime));
|
return mongoTemplate.count(query, DaTaoKeDetailV2.class);
|
}
|
|
public List<DaTaoKeDetailV2> listByMaxPrice(Integer cid, BigDecimal maxPrice, String sortName, int start,
|
int count) {
|
Query query = new Query();
|
if (cid != null)
|
query.addCriteria(Criteria.where("actualPrice").lt(maxPrice).andOperator(Criteria.where("cid").is(cid)));
|
else
|
query.addCriteria(Criteria.where("actualPrice").lt(maxPrice));
|
|
if (!StringUtil.isNullOrEmpty(sortName)) {
|
List<Order> orders = new ArrayList<>();
|
orders.add(new Order(Direction.DESC, sortName));
|
query.with(new Sort(orders));
|
}
|
query.skip(start);
|
query.limit(count);
|
return mongoTemplate.find(query, getEntityClass());
|
}
|
|
public long countByMaxPrice(Integer cid, BigDecimal maxPrice) {
|
Query query = new Query();
|
if (cid != null)
|
query.addCriteria(Criteria.where("actualPrice").lt(maxPrice).andOperator(Criteria.where("cid").is(cid)));
|
else
|
query.addCriteria(Criteria.where("actualPrice").lt(maxPrice));
|
return mongoTemplate.count(query, getEntityClass());
|
}
|
|
/**
|
*
|
* @Title: listBySellerId @Description: 根据商家ID查询商品 @param start @param
|
* count @param sellerId @return List<DaTaoKeDetailV2> 返回类型 @throws
|
*/
|
public List<DaTaoKeDetailV2> listBySellerId(int start, int count, Long sellerId) {
|
Query query = new Query();
|
query.addCriteria(Criteria.where("sellerId").is(sellerId));
|
query.skip(start);
|
query.limit(count);
|
return mongoTemplate.find(query, DaTaoKeDetailV2.class);
|
}
|
|
}
|
