|
|
@ -1,10 +1,18 @@ |
|
|
|
package org.jeecg.api.service.impl; |
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON; |
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker; |
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|
|
|
import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult; |
|
|
|
import lombok.extern.log4j.Log4j; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.apache.commons.lang.StringUtils; |
|
|
|
import org.jeecg.api.service.ApiRiceService; |
|
|
|
import org.jeecg.bean.PageBean; |
|
|
|
import org.jeecg.common.api.vo.Result; |
|
|
|
import org.jeecg.config.shiro.ShiroRealm; |
|
|
|
import org.jeecg.modules.commonAddress.entity.CommonAddress; |
|
|
|
import org.jeecg.modules.commonAddress.service.ICommonAddressService; |
|
|
|
import org.jeecg.modules.commonBanner.entity.CommonBanner; |
|
|
@ -16,6 +24,7 @@ import org.jeecg.modules.commonClass.service.ICommonClassService; |
|
|
|
import org.jeecg.modules.commonConfig.service.ICommonConfigService; |
|
|
|
import org.jeecg.modules.commonIconImage.entity.CommonIconImage; |
|
|
|
import org.jeecg.modules.commonIconImage.service.ICommonIconImageService; |
|
|
|
import org.jeecg.modules.commonMoney.entity.CommonMoney; |
|
|
|
import org.jeecg.modules.commonMoney.service.ICommonMoneyService; |
|
|
|
import org.jeecg.modules.commonMoneyLog.entity.CommonMoneyLog; |
|
|
|
import org.jeecg.modules.commonMoneyLog.service.ICommonMoneyLogService; |
|
|
@ -25,23 +34,27 @@ import org.jeecg.modules.commonNotice.entity.CommonNotice; |
|
|
|
import org.jeecg.modules.commonNotice.service.ICommonNoticeService; |
|
|
|
import org.jeecg.modules.commonOrder.entity.CommonOrder; |
|
|
|
import org.jeecg.modules.commonOrder.service.ICommonOrderService; |
|
|
|
import org.jeecg.modules.commonOrderSku.entity.CommonOrderSku; |
|
|
|
import org.jeecg.modules.commonOrderSku.service.ICommonOrderSkuService; |
|
|
|
import org.jeecg.modules.commonShop.entity.CommonShop; |
|
|
|
import org.jeecg.modules.commonShop.service.ICommonShopService; |
|
|
|
import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; |
|
|
|
import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService; |
|
|
|
import org.jeecg.modules.pay.MpWxPayService; |
|
|
|
import org.jeecg.modules.riceNews.entity.RiceNews; |
|
|
|
import org.jeecg.modules.riceNews.service.IRiceNewsService; |
|
|
|
import org.jeecg.modules.riceVip.entity.RiceVip; |
|
|
|
import org.jeecg.modules.riceVip.service.IRiceVipService; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.web.bind.annotation.RequestHeader; |
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
|
import java.util.Date; |
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Map; |
|
|
|
import java.math.BigDecimal; |
|
|
|
import java.util.*; |
|
|
|
|
|
|
|
|
|
|
|
@Slf4j |
|
|
|
@Service |
|
|
|
public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
|
|
|
@ -69,6 +82,8 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
@Resource |
|
|
|
private ICommonOrderService commonOrderService; |
|
|
|
@Resource |
|
|
|
private ICommonOrderSkuService commonOrderSkuService; |
|
|
|
@Resource |
|
|
|
private ICommonShopService commonShopService; |
|
|
|
@Resource |
|
|
|
private IRiceVipService riceVipService; |
|
|
@ -76,6 +91,12 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
private IHanHaiMemberService hanHaiMemberService; |
|
|
|
@Resource |
|
|
|
private IRiceNewsService riceNewsService; |
|
|
|
//权限配置 |
|
|
|
@Resource |
|
|
|
private ShiroRealm shiroRealm; |
|
|
|
//支付接口 |
|
|
|
@Autowired |
|
|
|
private MpWxPayService mpWxPayService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -138,6 +159,7 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
IPage<CommonShop> pageList = |
|
|
|
commonShopService.lambdaQuery() |
|
|
|
.eq(CommonShop::getClassId,classId) |
|
|
|
.eq(CommonShop::getType,2) |
|
|
|
.orderByDesc(CommonShop::getCreateTime) |
|
|
|
.page(page); |
|
|
|
return Result.OK(pageList); |
|
|
@ -185,61 +207,344 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
|
|
|
|
//创建订单 |
|
|
|
@Override |
|
|
|
public Result<?> createOrder(String token,String productId,Integer num) { |
|
|
|
public Result<?> createOrder(String token,String productId,Integer num,String addressId) { |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//商品标识不能为空 |
|
|
|
if (productId==null){ |
|
|
|
return Result.error("商品标识不能为空"); |
|
|
|
} |
|
|
|
//数量不能为空 |
|
|
|
if (num==null){ |
|
|
|
return Result.error("数量不能为空"); |
|
|
|
} |
|
|
|
//查询商品信息 |
|
|
|
CommonShop commonShop = commonShopService.getById(productId); |
|
|
|
//商品不能为空 |
|
|
|
if (commonShop==null){ |
|
|
|
return Result.error("商品不存在"); |
|
|
|
} |
|
|
|
//地址标识不能为空 |
|
|
|
if (addressId==null){ |
|
|
|
return Result.error("地址标识不能为空"); |
|
|
|
} |
|
|
|
//查询地址是否存在 |
|
|
|
CommonAddress commonAddress = commonAddressService.getById(addressId); |
|
|
|
if (commonAddress==null){ |
|
|
|
return Result.error("地址不存在"); |
|
|
|
} |
|
|
|
//创建订单标识 |
|
|
|
String orderId = IdWorker.getIdStr(); |
|
|
|
//创建订单 |
|
|
|
BigDecimal price = commonShop.getPrice().multiply(new BigDecimal(num)); |
|
|
|
//生成订单信息 |
|
|
|
CommonOrder commonOrder = new CommonOrder(); |
|
|
|
|
|
|
|
commonOrder.setId(orderId); |
|
|
|
commonOrder.setTitle(commonShop.getTitle()); |
|
|
|
commonOrder.setShopId(commonShop.getId()); |
|
|
|
commonOrder.setImage(commonShop.getImage()); |
|
|
|
commonOrder.setCreateTime(new Date()); |
|
|
|
commonOrder.setState("0"); |
|
|
|
|
|
|
|
commonOrder.setState(1); |
|
|
|
commonOrder.setPrice(price); |
|
|
|
commonOrder.setNum(num); |
|
|
|
commonOrder.setSku(commonShop.getSku()); |
|
|
|
commonOrder.setName(commonAddress.getName()); |
|
|
|
commonOrder.setPhone(commonAddress.getPhone()); |
|
|
|
commonOrder.setAddress(commonAddress.getAddress()); |
|
|
|
commonOrder.setAddressDetails(commonAddress.getAddressDetails()); |
|
|
|
commonOrder.setUserId(hanHaiMember.getId()); |
|
|
|
commonOrder.setAddressId(addressId); |
|
|
|
commonOrderService.save(commonOrder); |
|
|
|
|
|
|
|
//创建订单详情 |
|
|
|
CommonOrderSku commonOrderSku = new CommonOrderSku(); |
|
|
|
commonOrderSku.setOrderId(orderId); |
|
|
|
commonOrderSku.setShopId(commonShop.getId()); |
|
|
|
commonOrderSku.setTitle(commonShop.getTitle()); |
|
|
|
commonOrderSku.setImage(commonShop.getImage()); |
|
|
|
commonOrderSku.setPrice(price); |
|
|
|
commonOrderSku.setNum(num); |
|
|
|
commonOrderSku.setSku(commonShop.getSku()); |
|
|
|
commonOrderSku.setCreateTime(new Date()); |
|
|
|
commonOrderSkuService.save(commonOrderSku); |
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
String s = price.multiply(new BigDecimal(100)).toString(); |
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
"购买"+ commonShop.getTitle() , |
|
|
|
"127.0.0.1", |
|
|
|
orderId, |
|
|
|
i1, |
|
|
|
orderId, |
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
commonOrder.toString()); |
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//生成流水数据 |
|
|
|
CommonMoneyLog commonMoneyLog = new CommonMoneyLog(); |
|
|
|
commonMoneyLog.setCreateTime(new Date()); |
|
|
|
commonMoneyLog.setTitle("测试收入"); |
|
|
|
commonMoneyLog.setMoney(commonShop.getPrice()); |
|
|
|
commonMoneyLog.setType(1); |
|
|
|
commonMoneyLogService.save(commonMoneyLog); |
|
|
|
//商城-立即购买多少商品 |
|
|
|
@Override |
|
|
|
public Result<?> createSumOrder(String token,String list,String addressId){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//用户地址不能为空 |
|
|
|
if(StringUtils.isBlank(addressId)){ |
|
|
|
return Result.error("请选择收货地址"); |
|
|
|
} |
|
|
|
//查询地址是否存在 |
|
|
|
CommonAddress commonAddress = commonAddressService.getById(addressId); |
|
|
|
if (commonAddress==null){ |
|
|
|
return Result.error("地址不存在"); |
|
|
|
} |
|
|
|
//把list转为对象 list = [{"shopId":"1","num":1},{"shopId":"2","num":2}] |
|
|
|
List<CommonOrderSku> list1 = JSON.parseArray(list, CommonOrderSku.class); |
|
|
|
//创建订单标识 |
|
|
|
String orderId = IdWorker.getIdStr(); |
|
|
|
if(null!=list1 && list1.size()>0){ |
|
|
|
//订单总额 |
|
|
|
BigDecimal totalPrice = new BigDecimal(0); |
|
|
|
//订单商品数量 |
|
|
|
Integer totalNum = 0; |
|
|
|
|
|
|
|
//创建订单详情 |
|
|
|
for (CommonOrderSku sku : list1) { |
|
|
|
//查询商品信息 |
|
|
|
CommonShop commonShop = commonShopService.getById(sku.getShopId()); |
|
|
|
//商品不能为空 |
|
|
|
if (commonShop==null){ |
|
|
|
return Result.error("商品不存在"); |
|
|
|
} |
|
|
|
//创建订单 |
|
|
|
BigDecimal price = commonShop.getPrice().multiply(new BigDecimal(sku.getNum())); |
|
|
|
|
|
|
|
sku.setOrderId(orderId); |
|
|
|
sku.setShopId(commonShop.getId()); |
|
|
|
sku.setTitle(commonShop.getTitle()); |
|
|
|
sku.setImage(commonShop.getImage()); |
|
|
|
sku.setPrice(price); |
|
|
|
sku.setNum(sku.getNum()); |
|
|
|
sku.setSku(commonShop.getSku()); |
|
|
|
sku.setCreateTime(new Date()); |
|
|
|
sku.setPrice(price); |
|
|
|
|
|
|
|
sku.setImage(commonShop.getImage()); |
|
|
|
sku.setCreateTime(new Date()); |
|
|
|
sku.setOrderId(orderId); |
|
|
|
commonOrderSkuService.save(sku); |
|
|
|
|
|
|
|
//计算总价格 |
|
|
|
totalPrice = totalPrice.add(price); |
|
|
|
|
|
|
|
totalNum = totalNum + sku.getNum(); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//创建主订单 |
|
|
|
CommonOrder cityOrder = new CommonOrder(); |
|
|
|
cityOrder.setId(orderId); |
|
|
|
cityOrder.setUserId(hanHaiMember.getId()); |
|
|
|
cityOrder.setShopId(null); |
|
|
|
cityOrder.setNum(totalNum); |
|
|
|
cityOrder.setAddress(commonAddress.getAddress()); |
|
|
|
cityOrder.setName(commonAddress.getName()); |
|
|
|
cityOrder.setPhone(commonAddress.getPhone()); |
|
|
|
cityOrder.setAddressDetails(commonAddress.getAddressDetails()); |
|
|
|
cityOrder.setName("店铺订单"); |
|
|
|
cityOrder.setPrice(totalPrice); |
|
|
|
|
|
|
|
cityOrder.setImage(null); |
|
|
|
cityOrder.setState(0); |
|
|
|
cityOrder.setCreateTime(new Date()); |
|
|
|
|
|
|
|
commonOrderService.save(cityOrder); |
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
String s = totalPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
"购买"+ "店铺订单" , |
|
|
|
"127.0.0.1", |
|
|
|
orderId, |
|
|
|
i1, |
|
|
|
orderId, |
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
cityOrder.toString()); |
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
} |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
CommonMoneyLog commonMoneyLog2 = new CommonMoneyLog(); |
|
|
|
commonMoneyLog2.setCreateTime(new Date()); |
|
|
|
commonMoneyLog2.setTitle("测试支出"); |
|
|
|
commonMoneyLog2.setMoney(commonShop.getPrice()); |
|
|
|
commonMoneyLog2.setType(0); |
|
|
|
commonMoneyLogService.save(commonMoneyLog); |
|
|
|
|
|
|
|
//商城-加入购物车之后一次下多个订单 - 再次下单 |
|
|
|
@Override |
|
|
|
public Result<?> createSumOrderAgain(String token,String list,String addressId,String order){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//根据订单标识查询订单是否存在 |
|
|
|
CommonOrder commonOrder = commonOrderService.getById(order); |
|
|
|
if (commonOrder==null){ |
|
|
|
return Result.error("订单不存在"); |
|
|
|
} |
|
|
|
//根据订单标识查询订单详情列表 |
|
|
|
List<CommonOrderSku> commonOrderSkuList = commonOrderSkuService.lambdaQuery() |
|
|
|
.eq(CommonOrderSku::getOrderId,order) |
|
|
|
.list(); |
|
|
|
if (commonOrderSkuList==null || commonOrderSkuList.size()==0){ |
|
|
|
return Result.error("订单详情不存在"); |
|
|
|
} |
|
|
|
|
|
|
|
//如果集合存在循环删除 |
|
|
|
commonOrderSkuService.remove(new QueryWrapper<CommonOrderSku>().eq("order_id",order)); |
|
|
|
|
|
|
|
|
|
|
|
return Result.OK("创建成功"); |
|
|
|
//用户地址不能为空 |
|
|
|
if(StringUtils.isBlank(addressId)){ |
|
|
|
return Result.error("请选择收货地址"); |
|
|
|
} |
|
|
|
//查询地址是否存在 |
|
|
|
CommonAddress commonAddress = commonAddressService.getById(addressId); |
|
|
|
if (commonAddress==null){ |
|
|
|
return Result.error("地址不存在"); |
|
|
|
} |
|
|
|
//把list转为对象 list = [{"shopId":"1","num":1},{"shopId":"2","num":2}] |
|
|
|
List<CommonOrderSku> list1 = JSON.parseArray(list, CommonOrderSku.class); |
|
|
|
//创建订单标识 |
|
|
|
String orderId = IdWorker.getIdStr(); |
|
|
|
if(null!=list1 && list1.size()>0){ |
|
|
|
//订单总额 |
|
|
|
BigDecimal totalPrice = new BigDecimal(0); |
|
|
|
//订单商品数量 |
|
|
|
Integer totalNum = 0; |
|
|
|
|
|
|
|
//创建订单详情 |
|
|
|
for (CommonOrderSku sku : list1) { |
|
|
|
//查询商品信息 |
|
|
|
CommonShop commonShop = commonShopService.getById(sku.getShopId()); |
|
|
|
//商品不能为空 |
|
|
|
if (commonShop==null){ |
|
|
|
return Result.error("商品不存在"); |
|
|
|
} |
|
|
|
//创建订单 |
|
|
|
BigDecimal price = commonShop.getPrice().multiply(new BigDecimal(sku.getNum())); |
|
|
|
|
|
|
|
sku.setOrderId(orderId); |
|
|
|
sku.setShopId(commonShop.getId()); |
|
|
|
sku.setTitle(commonShop.getTitle()); |
|
|
|
sku.setImage(commonShop.getImage()); |
|
|
|
sku.setPrice(price); |
|
|
|
sku.setNum(sku.getNum()); |
|
|
|
sku.setSku(commonShop.getSku()); |
|
|
|
sku.setCreateTime(new Date()); |
|
|
|
sku.setPrice(price); |
|
|
|
|
|
|
|
sku.setImage(commonShop.getImage()); |
|
|
|
sku.setCreateTime(new Date()); |
|
|
|
sku.setOrderId(orderId); |
|
|
|
commonOrderSkuService.save(sku); |
|
|
|
|
|
|
|
//计算总价格 |
|
|
|
totalPrice = totalPrice.add(price); |
|
|
|
|
|
|
|
totalNum = totalNum + sku.getNum(); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//创建主订单 |
|
|
|
CommonOrder cityOrder = new CommonOrder(); |
|
|
|
cityOrder.setId(orderId); |
|
|
|
cityOrder.setUserId(hanHaiMember.getId()); |
|
|
|
cityOrder.setShopId(null); |
|
|
|
cityOrder.setNum(totalNum); |
|
|
|
cityOrder.setAddress(commonAddress.getAddress()); |
|
|
|
cityOrder.setName(commonAddress.getName()); |
|
|
|
cityOrder.setPhone(commonAddress.getPhone()); |
|
|
|
cityOrder.setAddressDetails(commonAddress.getAddressDetails()); |
|
|
|
cityOrder.setName("店铺订单"); |
|
|
|
cityOrder.setPrice(totalPrice); |
|
|
|
|
|
|
|
cityOrder.setImage(null); |
|
|
|
cityOrder.setState(0); |
|
|
|
cityOrder.setCreateTime(new Date()); |
|
|
|
|
|
|
|
commonOrderService.save(cityOrder); |
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
String s = totalPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
"购买"+ "店铺订单" , |
|
|
|
"127.0.0.1", |
|
|
|
orderId, |
|
|
|
i1, |
|
|
|
orderId, |
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
cityOrder.toString()); |
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
} |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//商城-支付回调 |
|
|
|
@Override |
|
|
|
public Result<?> payNotify(String requestBody){ |
|
|
|
WxPayOrderNotifyResult notify = mpWxPayService.notify(requestBody); |
|
|
|
String outTradeNo = notify.getOutTradeNo(); |
|
|
|
log.info("支付回调订单号码:"+outTradeNo); |
|
|
|
//查询订单信息 |
|
|
|
CommonOrder commonOrder = commonOrderService.getById(outTradeNo); |
|
|
|
//如果订单存在则修改订单状态 |
|
|
|
if (commonOrder!=null){ |
|
|
|
commonOrder.setState(1); |
|
|
|
commonOrderService.updateById(commonOrder); |
|
|
|
} |
|
|
|
|
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
//加入购物车 |
|
|
|
@Override |
|
|
|
public Result<?> addCart(String token,String productId,Integer num){ |
|
|
|
public Result<?> addCart(String token,String shopId,Integer num){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//根据商品标识查询商品信息 |
|
|
|
CommonShop commonShop = commonShopService.getById(productId); |
|
|
|
CommonShop commonShop = commonShopService.getById(shopId); |
|
|
|
if (commonShop==null){ |
|
|
|
return Result.error("商品不存在"); |
|
|
|
} |
|
|
|
|
|
|
|
CommonCat commonCat = new CommonCat(); |
|
|
|
commonCat.setTitle(commonShop.getTitle()); |
|
|
|
commonCat.setShopId(commonShop.getId()); |
|
|
|
commonCat.setImage(commonShop.getImage()); |
|
|
|
commonCat.setSku(commonShop.getSku()); |
|
|
|
commonCat.setPrice(commonShop.getPrice()); |
|
|
|
commonCat.setUserId(hanHaiMember.getId()); |
|
|
|
commonCat.setNum(num); |
|
|
|
commonCat.setCreateTime(new Date()); |
|
|
|
commonCatService.save(commonCat); |
|
|
|
return Result.OK("加入成功"); |
|
|
|
} |
|
|
|
|
|
|
|
//删除购物车信息 |
|
|
|
@Override |
|
|
|
public Result<?> deleteCart(String token,String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonCatService.removeById(id); |
|
|
|
return Result.OK("删除成功"); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//修改购物车信息数量 |
|
|
|
@Override |
|
|
|
public Result<?> updateCartNum(String token,String id,Integer num){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
CommonCat commonCat = commonCatService.getById(id); |
|
|
|
commonCat.setNum(num); |
|
|
|
commonCatService.updateById(commonCat); |
|
|
|
return Result.OK("修改成功"); |
|
|
|
} |
|
|
|
|
|
|
|
//获取会员权益信息列表 |
|
|
|
@Override |
|
|
|
public Result<?> getRiceVipList(){ |
|
|
@ -251,47 +556,109 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
//申请成为会员 |
|
|
|
@Override |
|
|
|
public Result<?> applyRiceVip(String token){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
|
//获取流水记录带分页 |
|
|
|
@Override |
|
|
|
public Result<?> getWaterPageList(){ |
|
|
|
Page<CommonMoneyLog> page = commonMoneyLogService.page(new Page<>(1, 10)); |
|
|
|
public Result<?> getWaterPageList(String token,PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<CommonMoneyLog> page = commonMoneyLogService.lambdaQuery() |
|
|
|
.orderByDesc(CommonMoneyLog::getCreateTime) |
|
|
|
.page(new Page<>(1, 10)); |
|
|
|
return Result.OK(page); |
|
|
|
} |
|
|
|
|
|
|
|
//获取订单列表带分页 |
|
|
|
@Override |
|
|
|
public Result<?> getOrderPageList(){ |
|
|
|
Page<CommonOrder> page = commonOrderService.page(new Page<>(1, 10)); |
|
|
|
return Result.OK(page); |
|
|
|
public Result<?> getOrderPageList(String token, PageBean bean,Integer state){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<CommonOrder> page = new Page<CommonOrder>(bean.getPageNo(), bean.getPageSize()); |
|
|
|
Page<CommonOrder> page1 = commonOrderService.lambdaQuery() |
|
|
|
.eq(CommonOrder::getUserId,hanHaiMember.getId()) |
|
|
|
.orderByDesc(CommonOrder::getCreateTime) |
|
|
|
.page(page); |
|
|
|
//如果订单状态不为空 |
|
|
|
if(null!=state){ |
|
|
|
page1 = commonOrderService.lambdaQuery() |
|
|
|
.eq(CommonOrder::getUserId,hanHaiMember.getId()) |
|
|
|
.eq(CommonOrder::getState,state) |
|
|
|
.orderByDesc(CommonOrder::getCreateTime) |
|
|
|
.page(page); |
|
|
|
} |
|
|
|
//拿出订单集合 |
|
|
|
List<CommonOrder> records = page1.getRecords(); |
|
|
|
//创建新集合 |
|
|
|
List<CommonOrder> newRecords = new ArrayList<>(); |
|
|
|
for (CommonOrder cityOrder : records) { |
|
|
|
//根据订单id查询订单详情 |
|
|
|
List<CommonOrderSku> commonOrderSkuList = commonOrderSkuService.lambdaQuery() |
|
|
|
.eq(CommonOrderSku::getOrderId,cityOrder.getId()) |
|
|
|
.list(); |
|
|
|
cityOrder.setCommonOrderSkuList(commonOrderSkuList); |
|
|
|
newRecords.add(cityOrder); |
|
|
|
} |
|
|
|
page1.setRecords(newRecords); |
|
|
|
return Result.OK(page1); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//获取订单详情 |
|
|
|
@Override |
|
|
|
public Result<?> getOrderDetail(@RequestHeader("X-Access-Token") String token, String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
CommonOrder cityOrder = commonOrderService.getById(id); |
|
|
|
//根据订单id查询订单详情 |
|
|
|
List<CommonOrderSku> commonOrderSkuList = commonOrderSkuService.lambdaQuery() |
|
|
|
.eq(CommonOrderSku::getOrderId,cityOrder.getId()) |
|
|
|
.list(); |
|
|
|
cityOrder.setCommonOrderSkuList(commonOrderSkuList); |
|
|
|
return Result.OK(cityOrder); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//获取粉丝列表带分页 |
|
|
|
@Override |
|
|
|
public Result<?> getFansPageList(){ |
|
|
|
Page<HanHaiMember> page = hanHaiMemberService.page(new Page<>(1, 10)); |
|
|
|
public Result<?> getFansPageList(String token,PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<HanHaiMember> page = hanHaiMemberService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(HanHaiMember::getShareId,hanHaiMember.getId()) |
|
|
|
.page(new Page<>(1, 10)); |
|
|
|
return Result.OK(page); |
|
|
|
} |
|
|
|
|
|
|
|
//获取购物车信息列表带分页 |
|
|
|
@Override |
|
|
|
public Result<?> getCartPageList(PageBean pageBean){ |
|
|
|
Page<CommonCat> page = commonCatService.page(new Page<>(1, 10)); |
|
|
|
public Result<?> getCartPageList(String token,PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<CommonCat> page = commonCatService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(CommonCat::getUserId,hanHaiMember.getId()) |
|
|
|
.page(new Page<>(1, 10)); |
|
|
|
return Result.OK(page); |
|
|
|
} |
|
|
|
|
|
|
|
//获取地址列表带分页 |
|
|
|
@Override |
|
|
|
public Result<?> getAddressPageList(){ |
|
|
|
Page<CommonAddress> page = commonAddressService.page(new Page<>(1, 10)); |
|
|
|
public Result<?> getAddressPageList(String token,PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<CommonAddress> page = commonAddressService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(CommonAddress::getUserId,hanHaiMember.getId()) |
|
|
|
.page(new Page<>(1, 10)); |
|
|
|
return Result.OK(page); |
|
|
|
} |
|
|
|
|
|
|
|
//获取个人邀请码 |
|
|
|
@Override |
|
|
|
public Result<?> getInviteCode(){ |
|
|
|
public Result<?> getInviteCode(String token){ |
|
|
|
return null; |
|
|
|
} |
|
|
|
|
|
|
@ -316,12 +683,44 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
|
|
|
|
//增加或者修改地址 |
|
|
|
@Override |
|
|
|
public Result<?> addOrUpdateAddress(CommonAddress commonAddress){ |
|
|
|
public Result<?> addOrUpdateAddress(String token,CommonAddress commonAddress){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonAddressService.saveOrUpdate(commonAddress); |
|
|
|
return Result.OK("增加成功"); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//删除地址 |
|
|
|
@Override |
|
|
|
public Result<?> deleteAddress(String token,String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
commonAddressService.removeById(id); |
|
|
|
return Result.OK("删除成功"); |
|
|
|
} |
|
|
|
|
|
|
|
//修改默认地址 |
|
|
|
@Override |
|
|
|
public Result<?> updateDefaultAddress(String token,String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//查询是否有默认地址 |
|
|
|
List<CommonAddress> list = commonAddressService.lambdaQuery() |
|
|
|
.eq(CommonAddress::getDefaultFlag,1) |
|
|
|
.list(); |
|
|
|
//如果有全部改为不默认 |
|
|
|
if (list!=null && list.size()>0){ |
|
|
|
for (CommonAddress commonAddress : list) { |
|
|
|
commonAddress.setDefaultFlag(0); |
|
|
|
commonAddressService.updateById(commonAddress); |
|
|
|
} |
|
|
|
} |
|
|
|
//查询当前这个地址信息 |
|
|
|
CommonAddress commonAddress = commonAddressService.getById(id); |
|
|
|
commonAddress.setDefaultFlag(1); |
|
|
|
commonAddressService.updateById(commonAddress); |
|
|
|
|
|
|
|
return Result.OK("修改成功"); |
|
|
|
} |
|
|
|
|
|
|
|
//查询个人信息相关 |
|
|
|
@Override |
|
|
|
public Result<?> getRiceInfo(String token){ |
|
|
@ -336,4 +735,29 @@ public class ApiRiceServiceImpl implements ApiRiceService { |
|
|
|
map.put("memberNum",10); |
|
|
|
return Result.OK(map); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//充值 |
|
|
|
@Override |
|
|
|
public Result<?> recharge(String token,BigDecimal money){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//查询当前用户余额 |
|
|
|
CommonMoney commonMoney = commonMoneyService.lambdaQuery() |
|
|
|
.eq(CommonMoney::getUserId,hanHaiMember.getId()) |
|
|
|
.one(); |
|
|
|
|
|
|
|
return Result.OK("充值成功"); |
|
|
|
} |
|
|
|
|
|
|
|
//提现 |
|
|
|
@Override |
|
|
|
public Result<?> withdraw(String token,BigDecimal money){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//查询当前用户余额 |
|
|
|
CommonMoney commonMoney = commonMoneyService.lambdaQuery() |
|
|
|
.eq(CommonMoney::getUserId,hanHaiMember.getId()) |
|
|
|
.one(); |
|
|
|
return Result.OK("提现成功"); |
|
|
|
} |
|
|
|
} |