|
@ -7,6 +7,8 @@ import org.jeecg.common.api.vo.Result; |
|
|
import org.jeecg.config.shiro.ShiroRealm; |
|
|
import org.jeecg.config.shiro.ShiroRealm; |
|
|
import org.jeecg.modules.apiBean.PageBean; |
|
|
import org.jeecg.modules.apiBean.PageBean; |
|
|
import org.jeecg.modules.apiService.OrderService; |
|
|
import org.jeecg.modules.apiService.OrderService; |
|
|
|
|
|
import org.jeecg.modules.employAmountLog.entity.EmployAmountLog; |
|
|
|
|
|
import org.jeecg.modules.employAmountLog.service.IEmployAmountLogService; |
|
|
import org.jeecg.modules.employAuthenticationCompany.entity.EmployAuthenticationCompany; |
|
|
import org.jeecg.modules.employAuthenticationCompany.entity.EmployAuthenticationCompany; |
|
|
import org.jeecg.modules.employAuthenticationCompany.service.IEmployAuthenticationCompanyService; |
|
|
import org.jeecg.modules.employAuthenticationCompany.service.IEmployAuthenticationCompanyService; |
|
|
import org.jeecg.modules.employAuthenticationPerson.entity.EmployAuthenticationPerson; |
|
|
import org.jeecg.modules.employAuthenticationPerson.entity.EmployAuthenticationPerson; |
|
@ -22,6 +24,7 @@ import org.jeecg.modules.employResume.service.IEmployResumeService; |
|
|
import org.jeecg.modules.employSeek.entity.EmploySeek; |
|
|
import org.jeecg.modules.employSeek.entity.EmploySeek; |
|
|
import org.jeecg.modules.employSeek.service.IEmploySeekService; |
|
|
import org.jeecg.modules.employSeek.service.IEmploySeekService; |
|
|
import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; |
|
|
import org.jeecg.modules.hanHaiMember.entity.HanHaiMember; |
|
|
|
|
|
import org.jeecg.modules.hanHaiMember.service.IHanHaiMemberService; |
|
|
import org.jeecg.modules.pay.MpWxPayService; |
|
|
import org.jeecg.modules.pay.MpWxPayService; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
import org.springframework.stereotype.Service; |
|
|
import org.springframework.stereotype.Service; |
|
@ -40,10 +43,16 @@ public class OrderServiceImpl implements OrderService { |
|
|
//权限验证 |
|
|
//权限验证 |
|
|
@Resource |
|
|
@Resource |
|
|
private ShiroRealm shiroRealm; |
|
|
private ShiroRealm shiroRealm; |
|
|
|
|
|
@Resource |
|
|
|
|
|
private IHanHaiMemberService hanHaiMemberService; |
|
|
|
|
|
|
|
|
@Resource |
|
|
@Resource |
|
|
private IEmployOrderService employOrderService; |
|
|
private IEmployOrderService employOrderService; |
|
|
|
|
|
|
|
|
|
|
|
@Resource |
|
|
|
|
|
private IEmployAmountLogService employAmountLogService; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Resource |
|
|
@Resource |
|
|
private IEmployJobService employJobService; |
|
|
private IEmployJobService employJobService; |
|
|
|
|
|
|
|
@ -227,25 +236,46 @@ public class OrderServiceImpl implements OrderService { |
|
|
|
|
|
|
|
|
//订单信息-立即支付 |
|
|
//订单信息-立即支付 |
|
|
@Override |
|
|
@Override |
|
|
public Result<?> payOrder(String token, String orderId){ |
|
|
|
|
|
|
|
|
public Result<?> payOrder(String token, String orderId,Integer payType){ |
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
//根据订单标识查询订单信息 |
|
|
//根据订单标识查询订单信息 |
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
BigDecimal payPrice = order.getPayMoney(); |
|
|
BigDecimal payPrice = order.getPayMoney(); |
|
|
|
|
|
|
|
|
//吊起微信支付 |
|
|
|
|
|
String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
|
|
"购买"+order.getTitle(), |
|
|
|
|
|
"127.0.0.1", |
|
|
|
|
|
System.currentTimeMillis()+"", |
|
|
|
|
|
i1, |
|
|
|
|
|
System.currentTimeMillis()+"", |
|
|
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
|
|
order.toString()); |
|
|
|
|
|
|
|
|
|
|
|
return Result.OK("支付成功",appOrder); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if(payType == 1){ |
|
|
|
|
|
//余额支付 |
|
|
|
|
|
if(hanHaiMember.getPrice().compareTo(payPrice)==-1){ |
|
|
|
|
|
return Result.error("余额不足"); |
|
|
|
|
|
} |
|
|
|
|
|
hanHaiMember.setPrice(hanHaiMember.getPrice().subtract(payPrice)); |
|
|
|
|
|
hanHaiMemberService.updateById(hanHaiMember); |
|
|
|
|
|
//增加金额明细 |
|
|
|
|
|
EmployAmountLog amountLog = new EmployAmountLog(); |
|
|
|
|
|
amountLog.setTitle(order.getTitle()); |
|
|
|
|
|
amountLog.setAmount(payPrice); |
|
|
|
|
|
amountLog.setType("0"); |
|
|
|
|
|
amountLog.setUserId(hanHaiMember.getId()); |
|
|
|
|
|
employAmountLogService.save(amountLog); |
|
|
|
|
|
|
|
|
|
|
|
return Result.OK("余额支付成功",order); |
|
|
|
|
|
}else{ |
|
|
|
|
|
//吊起微信支付 |
|
|
|
|
|
String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
|
|
"购买"+order.getTitle(), |
|
|
|
|
|
"127.0.0.1", |
|
|
|
|
|
System.currentTimeMillis()+"", |
|
|
|
|
|
i1, |
|
|
|
|
|
System.currentTimeMillis()+"", |
|
|
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
|
|
order.toString()); |
|
|
|
|
|
return Result.OK("微信支付成功",appOrder); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -257,6 +287,7 @@ public class OrderServiceImpl implements OrderService { |
|
|
public Result<?> addOrderJob(String token, String jobId){ |
|
|
public Result<?> addOrderJob(String token, String jobId){ |
|
|
//校验信息 |
|
|
//校验信息 |
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
|
|
|
//招聘订单不能为空 |
|
|
//招聘订单不能为空 |
|
|
if(StringUtils.isBlank(jobId)){ |
|
|
if(StringUtils.isBlank(jobId)){ |
|
|
return Result.error("求职订单不能为空"); |
|
|
return Result.error("求职订单不能为空"); |
|
@ -270,15 +301,27 @@ public class OrderServiceImpl implements OrderService { |
|
|
String toUser = employSeek.getUserId(); |
|
|
String toUser = employSeek.getUserId(); |
|
|
//根据发布人用户标识查询用户的简历信息 |
|
|
//根据发布人用户标识查询用户的简历信息 |
|
|
EmployResume resume = employResumeService.lambdaQuery().eq(EmployResume::getUserId, toUser).one(); |
|
|
EmployResume resume = employResumeService.lambdaQuery().eq(EmployResume::getUserId, toUser).one(); |
|
|
|
|
|
if(resume==null){ |
|
|
|
|
|
return Result.error("请先进行个人简历填写"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
//根据订单里面关联公司标识查询认证信息 |
|
|
//根据订单里面关联公司标识查询认证信息 |
|
|
EmployAuthenticationCompany company = employAuthenticationCompanyService |
|
|
EmployAuthenticationCompany company = employAuthenticationCompanyService |
|
|
.lambdaQuery().eq(EmployAuthenticationCompany::getUserId, member.getId()).one(); |
|
|
.lambdaQuery().eq(EmployAuthenticationCompany::getUserId, member.getId()).one(); |
|
|
|
|
|
|
|
|
|
|
|
//公司信息为空 |
|
|
|
|
|
if(company==null){ |
|
|
|
|
|
return Result.error("请先进行公司认证"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
//根据订单里面关联个人标识查询认证信息 |
|
|
//根据订单里面关联个人标识查询认证信息 |
|
|
EmployAuthenticationPerson person = employAuthenticationPersonService |
|
|
EmployAuthenticationPerson person = employAuthenticationPersonService |
|
|
.lambdaQuery().eq(EmployAuthenticationPerson::getUserId, member.getId()).one(); |
|
|
.lambdaQuery().eq(EmployAuthenticationPerson::getUserId, member.getId()).one(); |
|
|
|
|
|
|
|
|
|
|
|
//个人信息为空 |
|
|
|
|
|
if(person==null){ |
|
|
|
|
|
return Result.error("请先进行个人认证"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
//查询该用户是否已经存在订单 |
|
|
//查询该用户是否已经存在订单 |
|
|
EmployOrder order = employOrderService.lambdaQuery() |
|
|
EmployOrder order = employOrderService.lambdaQuery() |
|
@ -352,4 +395,131 @@ public class OrderServiceImpl implements OrderService { |
|
|
return Result.OK("取消成功", order); |
|
|
return Result.OK("取消成功", order); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//订单信息-增加订单 |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result<?> addOrder(String token,EmployOrder employOrder) { |
|
|
|
|
|
//校验信息 |
|
|
|
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
if(employOrder==null){ |
|
|
|
|
|
return Result.error("订单不能为空"); |
|
|
|
|
|
} |
|
|
|
|
|
employOrder.setUserId(member.getId()); |
|
|
|
|
|
employOrderService.save(employOrder); |
|
|
|
|
|
return Result.OK("添加成功", employOrder); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//订单信息-企业确认订单 |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result<?> confirmOrder(String token, String orderId) { |
|
|
|
|
|
//校验信息 |
|
|
|
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
if(StringUtils.isBlank(orderId)){ |
|
|
|
|
|
return Result.error("订单不能为空"); |
|
|
|
|
|
} |
|
|
|
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
|
|
|
if(order==null){ |
|
|
|
|
|
return Result.error("订单不存在"); |
|
|
|
|
|
} |
|
|
|
|
|
if(order.getStatus()>1){ |
|
|
|
|
|
return Result.error("订单进行,不能确认"); |
|
|
|
|
|
} |
|
|
|
|
|
if(order.getStatus()==6){ |
|
|
|
|
|
return Result.error("订单已经取消,不能确认"); |
|
|
|
|
|
} |
|
|
|
|
|
order.setStatus(1); |
|
|
|
|
|
employOrderService.updateById(order); |
|
|
|
|
|
return Result.OK("确认成功", order); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//订单信息-确认试工完成 |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result<?> confirmOrderTry(String token, String orderId){ |
|
|
|
|
|
//校验信息 |
|
|
|
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
|
|
|
if(order==null){ |
|
|
|
|
|
return Result.error("订单不存在", null); |
|
|
|
|
|
} |
|
|
|
|
|
order.setStatus(2); |
|
|
|
|
|
employOrderService.updateById(order); |
|
|
|
|
|
return Result.OK("订单确认成功", order); |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//订单信息-确认试工通过 |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result<?> confirmOrderTryCompany(String token, String orderId){ |
|
|
|
|
|
//校验信息 |
|
|
|
|
|
HanHaiMember member = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
|
|
|
if(order==null){ |
|
|
|
|
|
return Result.error("订单不存在", null); |
|
|
|
|
|
} |
|
|
|
|
|
order.setStatus(3); |
|
|
|
|
|
employOrderService.updateById(order); |
|
|
|
|
|
return Result.OK("操作成功"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//企业支付 |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result<?> payOrderCompany(String token, String orderId,Integer payType){ |
|
|
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
//根据订单标识查询订单信息 |
|
|
|
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
|
|
|
BigDecimal payPrice = order.getPayMoney(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if(payType == 1){ |
|
|
|
|
|
//余额支付 |
|
|
|
|
|
if(hanHaiMember.getPrice().compareTo(payPrice)==-1){ |
|
|
|
|
|
return Result.error("余额不足"); |
|
|
|
|
|
} |
|
|
|
|
|
hanHaiMember.setPrice(hanHaiMember.getPrice().subtract(payPrice)); |
|
|
|
|
|
hanHaiMemberService.updateById(hanHaiMember); |
|
|
|
|
|
//增加金额明细 |
|
|
|
|
|
EmployAmountLog amountLog = new EmployAmountLog(); |
|
|
|
|
|
amountLog.setTitle(order.getTitle()); |
|
|
|
|
|
amountLog.setAmount(payPrice); |
|
|
|
|
|
amountLog.setType("0"); |
|
|
|
|
|
amountLog.setUserId(hanHaiMember.getId()); |
|
|
|
|
|
employAmountLogService.save(amountLog); |
|
|
|
|
|
|
|
|
|
|
|
//修改订单状态 |
|
|
|
|
|
order.setStatus(4); |
|
|
|
|
|
employOrderService.updateById(order); |
|
|
|
|
|
|
|
|
|
|
|
return Result.OK("余额支付成功",order); |
|
|
|
|
|
}else{ |
|
|
|
|
|
//吊起微信支付 |
|
|
|
|
|
String s = payPrice.multiply(new BigDecimal(100)).toString(); |
|
|
|
|
|
int i1 = Double.valueOf(s).intValue(); |
|
|
|
|
|
Object appOrder = mpWxPayService.createOrder( |
|
|
|
|
|
"支付"+order.getTitle(), |
|
|
|
|
|
"127.0.0.1", |
|
|
|
|
|
System.currentTimeMillis()+"", |
|
|
|
|
|
i1, |
|
|
|
|
|
System.currentTimeMillis()+"", |
|
|
|
|
|
hanHaiMember.getAppletOpenid(), |
|
|
|
|
|
order.toString()); |
|
|
|
|
|
return Result.OK("微信支付成功",appOrder); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//确认企业已结款 |
|
|
|
|
|
@Override |
|
|
|
|
|
public Result<?> confirmOrderTryCompanyOk(String token, String orderId) { |
|
|
|
|
|
HanHaiMember hanHaiMember = shiroRealm.checkUserTokenIsEffectHanHaiOpenId(token); |
|
|
|
|
|
EmployOrder order = employOrderService.getById(orderId); |
|
|
|
|
|
//修改订单状态 |
|
|
|
|
|
order.setStatus(5); |
|
|
|
|
|
employOrderService.updateById(order); |
|
|
|
|
|
return Result.ok("确认成功"); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
} |
|
|
} |