parent
5f60a06c06
commit
dc22ecc896
@ -1,190 +0,0 @@
|
||||
package com.rabbiter.market.service.sale_management.exchange_point_products.impl;
|
||||
|
||||
import com.rabbiter.market.common.redis.service.RedisTemplateService;
|
||||
import com.rabbiter.market.domain.goods_management.goods.Goods;
|
||||
import com.rabbiter.market.domain.goods_management.point_products.PointProducts;
|
||||
import com.rabbiter.market.domain.member_management.member.Member;
|
||||
import com.rabbiter.market.domain.personnel_management.employee.Employee;
|
||||
import com.rabbiter.market.domain.sale_management.exchange_point_products.ExchangePointProducts;
|
||||
import com.rabbiter.market.mapper.sale_management.exchange_point_products.ExchangePointProductsMapper;
|
||||
import com.rabbiter.market.qo.exchange_point_products_records.QueryExchangePointProductsRecords;
|
||||
import com.rabbiter.market.service.goods_management.goods.IGoodsService;
|
||||
import com.rabbiter.market.service.goods_management.point_products.IPointProductsService;
|
||||
import com.rabbiter.market.service.member_management.member.IMemberService;
|
||||
import com.rabbiter.market.service.sale_management.exchange_point_products.IExchangePointProductsService;
|
||||
import com.alibaba.fastjson.JSONObject;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
||||
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.util.StringUtils;
|
||||
|
||||
import java.util.*;
|
||||
|
||||
@Service
|
||||
public class ExchangePointProductsServiceImpl extends ServiceImpl<ExchangePointProductsMapper, ExchangePointProducts> implements IExchangePointProductsService {
|
||||
@Autowired
|
||||
private IMemberService memberService;
|
||||
@Autowired
|
||||
private IPointProductsService pointProductsService;
|
||||
@Autowired
|
||||
private RedisTemplateService redisTemplateService;
|
||||
@Autowired
|
||||
private IGoodsService goodsService;
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> queryPointProductBymemberId(Long memberId) {
|
||||
Member member = memberService.getById(memberId);
|
||||
|
||||
QueryWrapper<PointProducts> pointProductsQueryWrapper = new QueryWrapper<PointProducts>();
|
||||
if (memberId == null) {
|
||||
pointProductsQueryWrapper.gt("integral", 0L);
|
||||
} else {
|
||||
pointProductsQueryWrapper.le("integral", member.getIntegral());
|
||||
}
|
||||
|
||||
List<PointProducts> list = pointProductsService.list(pointProductsQueryWrapper);
|
||||
List<Map<String, Object>> mapArrayList = new ArrayList<>();
|
||||
for (PointProducts pointProducts : list) {
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
map.put("id", pointProducts.getGoodsId());
|
||||
map.put("name", pointProducts.getGoodsName());
|
||||
mapArrayList.add(map);
|
||||
}
|
||||
return mapArrayList;
|
||||
}
|
||||
|
||||
@Override
|
||||
public PointProducts queryPointProductByGoodsId(Long goodsId) {
|
||||
PointProducts pointProducts = pointProductsService.getOne(new QueryWrapper<PointProducts>().eq(goodsId != null, "goods_id", goodsId));
|
||||
return pointProducts;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void saveExchangePointProductRecords(ExchangePointProducts exchangePointProducts, String token) {
|
||||
Employee employee = JSONObject.parseObject(redisTemplateService.getCacheObject(token), Employee.class);
|
||||
exchangePointProducts.setCn(IdWorker.getIdStr());//生成订单号
|
||||
exchangePointProducts.setUpdateby(employee.getNickName());
|
||||
exchangePointProducts.setUpdateId(employee.getId());
|
||||
exchangePointProducts.setUpdateTime(new Date());
|
||||
exchangePointProducts.setState(ExchangePointProducts.STATE_NORMAL);
|
||||
/*修改会员的积分*/
|
||||
Member member = memberService.getById(exchangePointProducts.getMemberId());
|
||||
member.setIntegral(member.getIntegral() - exchangePointProducts.getIntegral());
|
||||
memberService.updateById(member);
|
||||
super.save(exchangePointProducts);
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> queryOptionsMemberPhone() {
|
||||
QueryWrapper<ExchangePointProducts> wrapper = new QueryWrapper<ExchangePointProducts>()
|
||||
.select("member_id")
|
||||
.eq("state", ExchangePointProducts.STATE_NORMAL)
|
||||
.groupBy("member_id");
|
||||
List<ExchangePointProducts> list = super.list(wrapper);
|
||||
List<Long> memberIds = new ArrayList<>();
|
||||
for (ExchangePointProducts exchangePointProducts : list) {
|
||||
memberIds.add(exchangePointProducts.getMemberId());
|
||||
}
|
||||
if (memberIds==null || memberIds.size()<=0){
|
||||
return null;
|
||||
}
|
||||
List<Member> members = memberService.listByIds(memberIds);
|
||||
List<Map<String, Object>> vos = new ArrayList<>();
|
||||
for (Member member : members) {
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
map.put("id", member.getId());
|
||||
map.put("name", member.getPhone());
|
||||
vos.add(map);
|
||||
}
|
||||
|
||||
return vos;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void delExchangePointProducts(String cn) {
|
||||
UpdateWrapper<ExchangePointProducts> wrapper = new UpdateWrapper<ExchangePointProducts>()
|
||||
.set("state", ExchangePointProducts.STATE_DEL)
|
||||
.eq("cn", cn);
|
||||
super.update(wrapper);
|
||||
}
|
||||
|
||||
@Override
|
||||
public Page<ExchangePointProducts> queryPageByQoExchangePointProducts(QueryExchangePointProductsRecords qo) {
|
||||
Page<ExchangePointProducts> page = new Page<>(qo.getCurrentPage(), qo.getPageSize());
|
||||
QueryWrapper<ExchangePointProducts> queryWrapper = new QueryWrapper<ExchangePointProducts>()
|
||||
.eq("state", ExchangePointProducts.STATE_NORMAL)
|
||||
.eq(qo.getMemberId() != null, "member_id", qo.getMemberId())
|
||||
.ge(StringUtils.hasText(qo.getStartTime()), "update_time", qo.getStartTime())
|
||||
.le(StringUtils.hasText(qo.getEndTime()), "update_time", qo.getEndTime())
|
||||
.likeRight(StringUtils.hasText(qo.getCn()), "cn", qo.getCn());
|
||||
super.page(page, queryWrapper);
|
||||
for (ExchangePointProducts record : page.getRecords()) {
|
||||
Member member = memberService.getById(record.getMemberId());
|
||||
record.setMemberPhone(member.getPhone());
|
||||
Goods goods = goodsService.getById(record.getGoodsId());
|
||||
record.setGoodsCoverUrl(goods.getCoverUrl());
|
||||
record.setGoodsName(goods.getName());
|
||||
}
|
||||
return page;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> queryOptionsPointProducts() {
|
||||
QueryWrapper<PointProducts> wrapper = new QueryWrapper<PointProducts>()
|
||||
.eq("state", PointProducts.STATE_NORMAL);
|
||||
List<PointProducts> list = pointProductsService.list(wrapper);
|
||||
List<Map<String, Object>> vos = new ArrayList<>();
|
||||
for (PointProducts pointProducts : list) {
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
map.put("id", pointProducts.getGoodsId());
|
||||
map.put("name", pointProducts.getGoodsName());
|
||||
vos.add(map);
|
||||
}
|
||||
return vos;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> queryOptionsMember() {
|
||||
List<Map<String, Object>> vos = new ArrayList<>();
|
||||
QueryWrapper<Member> wrapper = new QueryWrapper<Member>()
|
||||
.groupBy("id")
|
||||
.eq("state", Member.STATE_NORMAL);
|
||||
List<Member> list = memberService.list(wrapper);
|
||||
for (Member member : list) {
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
map.put("id", member.getId());
|
||||
map.put("name", member.getPhone());
|
||||
vos.add(map);
|
||||
}
|
||||
return vos;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<Map<String, Object>> queryMemberByGoodsId(Long goodsId) {
|
||||
List<Member> members = new ArrayList<>();
|
||||
QueryWrapper<Member> memberQueryWrapper = new QueryWrapper<Member>();
|
||||
memberQueryWrapper.eq("state", Member.STATE_NORMAL);
|
||||
if (goodsId != null) {
|
||||
PointProducts pointProducts = pointProductsService.getOne(new QueryWrapper<PointProducts>()
|
||||
.eq("goods_id", goodsId)
|
||||
.eq("state", PointProducts.STATE_NORMAL));
|
||||
memberQueryWrapper.ge("integral", pointProducts.getIntegral());
|
||||
} else {
|
||||
memberQueryWrapper.gt("integral", 0);
|
||||
}
|
||||
members = memberService.list(memberQueryWrapper);
|
||||
List<Map<String, Object>> vos = new ArrayList<>();
|
||||
for (Member member : members) {
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
map.put("id", member.getId());
|
||||
map.put("name", member.getPhone());
|
||||
vos.add(map);
|
||||
}
|
||||
return vos;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in new issue