package com.panzhihua.service_equipment.service.impl;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.panzhihua.common.model.dtos.equipment.UnionExchangeRecordDto;
|
import com.panzhihua.common.model.dtos.equipment.UnionIntegralRecordDto;
|
import com.panzhihua.common.model.dtos.equipment.UnionIntegralSummarizeDto;
|
import com.panzhihua.common.model.dtos.equipment.UnionStoreDto;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.common.utlis.Snowflake;
|
import com.panzhihua.common.utlis.StringUtils;
|
import com.panzhihua.service_equipment.dao.UnionExchangeRecordMapper;
|
import com.panzhihua.service_equipment.model.dos.UnionExchangeRecord;
|
import com.panzhihua.service_equipment.model.dos.UnionIntegralSummarize;
|
import com.panzhihua.service_equipment.model.dos.UnionStore;
|
import com.panzhihua.service_equipment.service.UnionExchangeRecordService;
|
import com.panzhihua.service_equipment.service.UnionIntegralRecordService;
|
import com.panzhihua.service_equipment.service.UnionIntegralSummarizeService;
|
import com.panzhihua.service_equipment.service.UnionStoreService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
|
|
@Service
|
@Slf4j
|
public class UnionExchangeRecordServiceImpl extends ServiceImpl<UnionExchangeRecordMapper, UnionExchangeRecord>
|
implements UnionExchangeRecordService
|
{
|
@Resource
|
private UnionStoreService unionStoreService;
|
|
@Resource
|
private UnionIntegralSummarizeService unionIntegralSummarizeService;
|
|
@Resource
|
private UnionIntegralRecordService unionIntegralRecordService;
|
|
@Override
|
public R getList(int pageNum,int pageSize, String communityId, String userId,String orderType)
|
{
|
Page page=new Page(pageNum,pageSize);
|
return R.ok(baseMapper.getList(page,communityId,userId,orderType));
|
}
|
|
@Override
|
public R getData(String id) {
|
return R.ok(baseMapper.getData(id));
|
}
|
|
@Override
|
public R insert(UnionExchangeRecordDto item)
|
{
|
if(StringUtils.isEmpty(item.getConsignee()))
|
{
|
return R.fail("收货信息不能为空");
|
}
|
|
R<UnionIntegralSummarize> unionIntegralSummarizeR=unionIntegralSummarizeService.getUserData(item.getUserId(),null);
|
//设置站点id
|
item.setCommunityId(unionIntegralSummarizeR.getData().getCommunityId());
|
|
R<UnionStore> unionStoreR = unionStoreService.getData(item.getGoodsId());
|
//库存
|
int stock = Integer.valueOf(unionStoreR.getData().getStock());
|
//购买数量
|
int goodNum = Integer.valueOf(item.getGoodsNum());
|
//单价
|
int conversionPrice = Integer.valueOf(unionStoreR.getData().getConversionPrice());
|
|
if (stock<goodNum)
|
{
|
return R.fail("商品库存不足！");
|
}
|
|
int allPrice=goodNum*conversionPrice;
|
|
if(Integer.valueOf(unionIntegralSummarizeR.getData().getAllIntegral())<allPrice)
|
{
|
return R.fail("用户积分不足！");
|
}
|
|
//扣除用户积分
|
int num1=Integer.valueOf(unionIntegralSummarizeR.getData().getAllIntegral())-allPrice;
|
UnionIntegralSummarizeDto dto=new UnionIntegralSummarizeDto();
|
dto.setId(unionIntegralSummarizeR.getData().getId());
|
dto.setAllIntegral(num1+"");
|
unionIntegralSummarizeService.update(dto);
|
|
|
//修改商品库存
|
UnionStoreDto unionStoreDto=new UnionStoreDto();
|
unionStoreDto.setId(unionStoreR.getData().getId());
|
stock=stock-goodNum;
|
unionStoreDto.setStock(stock+"");
|
unionStoreService.update(unionStoreDto);
|
|
//新增积分明细记录
|
UnionIntegralRecordDto unionIntegralRecordDto=new UnionIntegralRecordDto();
|
unionIntegralRecordDto.setIntegral(allPrice+"");
|
unionIntegralRecordDto.setIntegralType("2");
|
unionIntegralRecordDto.setUserId(item.getUserId());
|
unionIntegralRecordDto.setCommunityId(unionIntegralSummarizeR.getData().getCommunityId());
|
unionIntegralRecordDto.setType("0");
|
unionIntegralRecordService.insert(unionIntegralRecordDto);
|
|
|
item.setOrderNum(Snowflake.getId()+"");
|
//判断是否是邮寄
|
if(StringUtils.equals("1",item.getPickUpMethod()))
|
{
|
item.setOrderType("1");
|
}
|
else
|
{
|
item.setOrderType("3");
|
}
|
item.setPlayIntegral(allPrice+"");
|
|
int num= baseMapper.insert(item);
|
if(num>0)
|
{
|
return R.ok();
|
}
|
return R.fail("操作失败");
|
}
|
|
@Override
|
public R update(UnionExchangeRecordDto item)
|
{
|
int num= baseMapper.update(item);
|
if(num>0)
|
{
|
return R.ok();
|
}
|
return R.fail("操作失败");
|
}
|
|
@Override
|
public R delete(String id)
|
{
|
UnionExchangeRecord unionExchangeRecord=baseMapper.getData(id);
|
|
if(StringUtils.equals("3",unionExchangeRecord.getOrderType())
|
|| StringUtils.equals("4",unionExchangeRecord.getOrderType()) )
|
{
|
return R.fail("订单不能删除");
|
}
|
|
int num= baseMapper.delete(id);
|
if(num>0)
|
{
|
return R.ok();
|
}
|
return R.fail("操作失败");
|
}
|
}
|
