|
|
@ -157,7 +157,7 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
if(StringUtils.isNotBlank(cityId)){ |
|
|
|
page1 = popularizeActivityService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeActivity::getAddress,cityId) |
|
|
|
.eq(PopularizeActivity::getCityId,cityId) |
|
|
|
.eq(PopularizeActivity::getState,state) |
|
|
|
.orderByDesc(PopularizeActivity::getCreateTime) |
|
|
|
.page(page); |
|
|
@ -193,7 +193,7 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
public Result<?> getActivityInfo(String activityId){ |
|
|
|
public Result<?> getActivityInfo(String token,String activityId){ |
|
|
|
Map<String,Object> map = new HashMap<>(); |
|
|
|
PopularizeActivity byId = popularizeActivityService.getById(activityId); |
|
|
|
map.put("activityInfo",byId); |
|
|
@ -207,6 +207,26 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
.eq(PopularizeAuthentication::getState, "1") |
|
|
|
.one(); |
|
|
|
map.put("adminUser",one); |
|
|
|
|
|
|
|
//如果token不为空 |
|
|
|
if(StringUtils.isNotBlank(token)){ |
|
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//查询是否收藏了 |
|
|
|
PopularizeCollect one1 = popularizeCollectService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeCollect::getUserId, member.getId()) |
|
|
|
.eq(PopularizeCollect::getActivityId, activityId) |
|
|
|
.one(); |
|
|
|
if(one1!=null){ |
|
|
|
map.put("collect",true); |
|
|
|
}else{ |
|
|
|
map.put("collect",false); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return Result.OK(map); |
|
|
|
} |
|
|
|
|
|
|
@ -237,6 +257,14 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
.orderByDesc(PopularizeTravel::getCreateTime) |
|
|
|
.page(page); |
|
|
|
} |
|
|
|
//如果状态不为空 |
|
|
|
if(StringUtils.isNotBlank(state)){ |
|
|
|
page1 = popularizeTravelService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeTravel::getState,state) |
|
|
|
.orderByDesc(PopularizeTravel::getCreateTime) |
|
|
|
.page(page); |
|
|
|
} |
|
|
|
|
|
|
|
//得到集合 |
|
|
|
List<PopularizeTravel> records = page1.getRecords(); |
|
|
@ -255,18 +283,14 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
recruitObj.setNum(recruitObj.getOrderList().size()); |
|
|
|
recruitList.add(recruitObj); |
|
|
|
} |
|
|
|
|
|
|
|
page1.setRecords(recruitList); |
|
|
|
|
|
|
|
return Result.OK(page1); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
public Result<?> getTravelInfo(String travelId){ |
|
|
|
|
|
|
|
|
|
|
|
public Result<?> getTravelInfo(String token,String travelId){ |
|
|
|
Map<String,Object> map = new HashMap<>(); |
|
|
|
PopularizeTravel byId = popularizeTravelService.getById(travelId); |
|
|
|
map.put("travel",byId); |
|
|
@ -280,7 +304,21 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
.eq(PopularizeAuthentication::getState, "1") |
|
|
|
.one(); |
|
|
|
map.put("adminUser",one); |
|
|
|
|
|
|
|
//如果token不为空 |
|
|
|
if(StringUtils.isNotBlank(token)){ |
|
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//查询是否收藏了 |
|
|
|
PopularizeCollect one1 = popularizeCollectService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeCollect::getUserId, member.getId()) |
|
|
|
.eq(PopularizeCollect::getTravelId, travelId) |
|
|
|
.one(); |
|
|
|
if(one1!=null){ |
|
|
|
map.put("collect",true); |
|
|
|
}else{ |
|
|
|
map.put("collect",false); |
|
|
|
} |
|
|
|
} |
|
|
|
return Result.OK(map); |
|
|
|
} |
|
|
|
|
|
|
@ -289,20 +327,38 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
@Override |
|
|
|
public Result<?> getCollectPageList(String token,String type, PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<PopularizeOrder> page = new Page<PopularizeOrder>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
Page<PopularizeOrder> page1 = popularizeOrderService |
|
|
|
Page<PopularizeCollect> page = new Page<PopularizeCollect>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
//必须传入type |
|
|
|
if(StringUtils.isBlank(type)){ |
|
|
|
return Result.error("类型不能为空"); |
|
|
|
} |
|
|
|
Page<PopularizeCollect> page1 = popularizeCollectService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeOrder::getUserId,hanHaiMember.getId()) |
|
|
|
.orderByDesc(PopularizeOrder::getCreateTime) |
|
|
|
.eq(PopularizeCollect::getUserId,hanHaiMember.getId()) |
|
|
|
.eq(PopularizeCollect::getType,type) |
|
|
|
.orderByDesc(PopularizeCollect::getCreateTime) |
|
|
|
.page(page); |
|
|
|
if(StringUtils.isNotBlank(type)){ |
|
|
|
page1 = popularizeOrderService |
|
|
|
page1 = popularizeCollectService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeOrder::getUserId,hanHaiMember.getId()) |
|
|
|
.eq(PopularizeOrder::getType,type) |
|
|
|
.orderByDesc(PopularizeOrder::getCreateTime) |
|
|
|
.eq(PopularizeCollect::getUserId,hanHaiMember.getId()) |
|
|
|
.eq(PopularizeCollect::getType,type) |
|
|
|
.orderByDesc(PopularizeCollect::getCreateTime) |
|
|
|
.page(page); |
|
|
|
} |
|
|
|
List<PopularizeCollect> records = page1.getRecords(); |
|
|
|
//创建一个新的集合 |
|
|
|
List<PopularizeCollect> collectList = new ArrayList<>(); |
|
|
|
for (PopularizeCollect collect : records) { |
|
|
|
if(collect.getType().equals("1")){ |
|
|
|
collect.setTravelObject(popularizeTravelService.getById(collect.getTravelId())); |
|
|
|
} |
|
|
|
if(collect.getType().equals("0")){ |
|
|
|
collect.setActivityObject(popularizeActivityService.getById(collect.getActivityId())); |
|
|
|
} |
|
|
|
collectList.add(collect); |
|
|
|
} |
|
|
|
page1.setRecords(collectList); |
|
|
|
return Result.OK(page1); |
|
|
|
} |
|
|
|
|
|
|
@ -349,8 +405,44 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
@Override |
|
|
|
public Result<?> getOrderInfo(String token,String orderId){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Map map = new HashMap(); |
|
|
|
PopularizeOrder byId = popularizeOrderService.getById(orderId); |
|
|
|
return Result.OK(byId); |
|
|
|
map.put("orderDetails",byId); |
|
|
|
//获取订单类型 |
|
|
|
PopularizeActivity activity = new PopularizeActivity(); |
|
|
|
PopularizeTravel travel = new PopularizeTravel(); |
|
|
|
//获取主理人信息 |
|
|
|
PopularizeAuthentication authentication = new PopularizeAuthentication(); |
|
|
|
HanHaiMember byId1 = new HanHaiMember(); |
|
|
|
PopularizeAuthentication one = new PopularizeAuthentication(); |
|
|
|
if(byId.getType().equals("0")){ |
|
|
|
activity = popularizeActivityService.getById(byId.getActivityOrderId()); |
|
|
|
//根据活动中主理人用户标识查询用户信息 |
|
|
|
byId1 = hanHaiMemberService.getById(activity.getAdminUser()); |
|
|
|
|
|
|
|
one = popularizeAuthenticationService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeAuthentication::getUserId, byId1.getId()) |
|
|
|
.eq(PopularizeAuthentication::getState, "1") |
|
|
|
.one(); |
|
|
|
}else{ |
|
|
|
travel = popularizeTravelService.getById(byId.getTravelOrderId()); |
|
|
|
//根据活动中主理人用户标识查询用户信息 |
|
|
|
byId1 = hanHaiMemberService.getById(travel.getAdminUser()); |
|
|
|
|
|
|
|
one = popularizeAuthenticationService |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeAuthentication::getUserId, byId1.getId()) |
|
|
|
.eq(PopularizeAuthentication::getState, "1") |
|
|
|
.one(); |
|
|
|
} |
|
|
|
map.put("activity",activity); |
|
|
|
map.put("travel",travel); |
|
|
|
map.put("adminUserInfo",byId1); |
|
|
|
map.put("adminUser",one); |
|
|
|
|
|
|
|
|
|
|
|
return Result.OK(map); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -581,15 +673,16 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
.one(); |
|
|
|
if(one!=null){ |
|
|
|
//审核成功 |
|
|
|
if(one.getState().equals("1")){ |
|
|
|
if(one.getState() == 1){ |
|
|
|
return Result.OK("您已经成为了主理人,请不要重复提交"); |
|
|
|
}else if(one.getState().equals("2")){ |
|
|
|
}else if(one.getState()==2){ |
|
|
|
authentication.setId(one.getId()); |
|
|
|
authentication.setUserId(hanHaiMember.getId()); |
|
|
|
boolean save = popularizeAuthenticationService.updateById(authentication); |
|
|
|
return Result.OK("参与成功"); |
|
|
|
}else{ |
|
|
|
authentication.setId(one.getId()); |
|
|
|
authentication.setState(0); |
|
|
|
authentication.setUserId(hanHaiMember.getId()); |
|
|
|
boolean save = popularizeAuthenticationService.updateById(authentication); |
|
|
|
return Result.OK("您已经提交了,请等待审核"); |
|
|
@ -597,6 +690,7 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
|
|
|
|
}else{ |
|
|
|
authentication.setUserId(hanHaiMember.getId()); |
|
|
|
authentication.setState(0); |
|
|
|
boolean save = popularizeAuthenticationService.saveOrUpdate(authentication); |
|
|
|
} |
|
|
|
return Result.OK("参与成功"); |
|
|
@ -634,7 +728,10 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
@Override |
|
|
|
public Result<?> getSignInUserPageList(String token, String recruitId, PageBean pageBean){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
Page<PopularizeSignLog> page = new Page<PopularizeSignLog>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
// Page<PopularizeSignLog> page = new Page<PopularizeSignLog>(pageBean.getPageNo(), pageBean.getPageSize()); |
|
|
|
Page<PopularizeSignLog> page = popularizeSignLogService |
|
|
|
.lambdaQuery() |
|
|
|
.page(new Page<>(pageBean.getPageNo(), pageBean.getPageSize())); |
|
|
|
return Result.OK(page); |
|
|
|
} |
|
|
|
|
|
|
@ -705,6 +802,49 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//创建订单支付 |
|
|
|
@Override |
|
|
|
public Result<?> createOrderPay(String token, String id,Integer num){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//标识不能为空 |
|
|
|
if(StringUtils.isBlank(id)){ |
|
|
|
return Result.error("标识不能为空"); |
|
|
|
} |
|
|
|
|
|
|
|
//数量不能为空 |
|
|
|
if(num == null){ |
|
|
|
return Result.error("数量不能为空"); |
|
|
|
} |
|
|
|
PopularizeOrder order = popularizeOrderService.getById(id); |
|
|
|
//修改订单数量 |
|
|
|
order.setNum(num); |
|
|
|
if(order.getType().equals("0")){ |
|
|
|
//修改订单价格 |
|
|
|
order.setPayPrice(order.getPayPrice().multiply(new BigDecimal(num))); |
|
|
|
}else{ |
|
|
|
order.setPayPrice(order.getPrice().multiply(new BigDecimal(num))); |
|
|
|
} |
|
|
|
|
|
|
|
popularizeOrderService.updateById(order); |
|
|
|
BigDecimal payPrice = order.getPayPrice(); |
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
"购买"+order.getTitle(), |
|
|
|
"127.0.0.1", |
|
|
|
order.getId(), |
|
|
|
i1, |
|
|
|
order.getId(), |
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
order.toString()); |
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public Result<?> createOrderTravel(String token, String id){ |
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
//判断活动标识不能为空 |
|
|
@ -729,6 +869,9 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeOrder::getTravelOrderId, id) |
|
|
|
.eq(PopularizeOrder::getUserId, hanHaiMember.getId()) |
|
|
|
//状态不等于0,3 |
|
|
|
.ne(PopularizeOrder::getState, "0") |
|
|
|
.ne(PopularizeOrder::getState, "3") |
|
|
|
.one(); |
|
|
|
if(order!=null){ |
|
|
|
return Result.error("已报名该旅行,请不要重复报名!"); |
|
|
@ -749,13 +892,15 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
PopularizeOrder popularizeOrder = new PopularizeOrder(); |
|
|
|
popularizeOrder.setId(orderId); |
|
|
|
popularizeOrder.setActivityOrderId(id); |
|
|
|
popularizeOrder.setTravelOrderId(id); |
|
|
|
popularizeOrder.setUserId(hanHaiMember.getId()); |
|
|
|
popularizeOrder.setType("0"); //0活动1旅行 |
|
|
|
popularizeOrder.setType("1"); //0活动1旅行 |
|
|
|
popularizeOrder.setTitle(byId.getTitle()); |
|
|
|
popularizeOrder.setImage(byId.getImage()); |
|
|
|
popularizeOrder.setStartTime(byId.getStartTime()); |
|
|
|
popularizeOrder.setAddress(byId.getAddress()); |
|
|
|
popularizeOrder.setPrice(byId.getPrice()); //活动价格 |
|
|
|
popularizeOrder.setPayPrice(payPrice); |
|
|
|
popularizeOrder.setNum(1); |
|
|
|
popularizeOrder.setState("0"); |
|
|
|
popularizeOrder.setCreateTime(new Date()); |
|
|
@ -765,19 +910,23 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
popularizeOrderService.save(popularizeOrder); |
|
|
|
|
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
"购买"+popularizeOrder.getTitle(), |
|
|
|
"127.0.0.1", |
|
|
|
orderId, |
|
|
|
i1, |
|
|
|
orderId, |
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
popularizeOrder.toString()); |
|
|
|
// //吊起微信支付 |
|
|
|
// String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
// int i1 = Double.valueOf(s).intValue(); |
|
|
|
// Object appOrder = mpWxPayService.createOrder( |
|
|
|
// "购买"+popularizeOrder.getTitle(), |
|
|
|
// "127.0.0.1", |
|
|
|
// orderId, |
|
|
|
// i1, |
|
|
|
// orderId, |
|
|
|
// hanHaiMember.getAppletOpenid(), |
|
|
|
// popularizeOrder.toString()); |
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
return Result.OK("订单创建成功",popularizeOrder); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
@ -810,6 +959,9 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
.lambdaQuery() |
|
|
|
.eq(PopularizeOrder::getActivityOrderId, id) |
|
|
|
.eq(PopularizeOrder::getUserId, hanHaiMember.getId()) |
|
|
|
//状态不等于0,3 |
|
|
|
.ne(PopularizeOrder::getState, "0") |
|
|
|
.ne(PopularizeOrder::getState, "3") |
|
|
|
.one(); |
|
|
|
if(order!=null){ |
|
|
|
return Result.error("已报名该活动,请不要重复报名!"); |
|
|
@ -840,6 +992,7 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
//如果typePrice=0为早鸟价 1为单人价 2为尊享价 |
|
|
|
if(typePrice==0){ |
|
|
|
popularizeOrder.setPayPrice(byId.getBirdPrice()); |
|
|
|
|
|
|
|
payPrice = byId.getBirdPrice(); |
|
|
|
}else if(typePrice==1){ |
|
|
|
popularizeOrder.setPayPrice(byId.getPersonPrice()); |
|
|
@ -848,6 +1001,7 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
popularizeOrder.setPayPrice(byId.getExpensivePrice()); |
|
|
|
payPrice = byId.getExpensivePrice(); |
|
|
|
} |
|
|
|
popularizeOrder.setTypePrice(typePrice); |
|
|
|
popularizeOrder.setNum(1); |
|
|
|
popularizeOrder.setState("0"); |
|
|
|
popularizeOrder.setCreateTime(new Date()); |
|
|
@ -858,19 +1012,19 @@ public class ApiIndexServiceImpl implements ApiIndexService { |
|
|
|
popularizeOrderService.save(popularizeOrder); |
|
|
|
|
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
"购买"+popularizeOrder.getTitle(), |
|
|
|
"127.0.0.1", |
|
|
|
orderId, |
|
|
|
i1, |
|
|
|
orderId, |
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
popularizeOrder.toString()); |
|
|
|
// //吊起微信支付 |
|
|
|
// String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
// int i1 = Double.valueOf(s).intValue(); |
|
|
|
// Object appOrder = mpWxPayService.createOrder( |
|
|
|
// "购买"+popularizeOrder.getTitle(), |
|
|
|
// "127.0.0.1", |
|
|
|
// orderId, |
|
|
|
// i1, |
|
|
|
// orderId, |
|
|
|
// hanHaiMember.getAppletOpenid(), |
|
|
|
// popularizeOrder.toString()); |
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
return Result.OK("订单创建成功",popularizeOrder); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|