package com.hollywood.applet.service.impl;
|
import java.io.PrintWriter;
|
import java.time.LocalDateTime;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.hollywood.applet.dto.ScriptPayDto;
|
import com.hollywood.applet.dto.TScriptQuery;
|
import com.hollywood.applet.dto.TScriptVO;
|
import com.hollywood.applet.mapper.TOrderMapper;
|
import com.hollywood.applet.mapper.TScriptMapper;
|
import com.hollywood.applet.mapper.TUserMapper;
|
import com.hollywood.applet.service.TOrderService;
|
import com.hollywood.applet.service.TScriptService;
|
import com.hollywood.common.basic.ApiResult;
|
import com.hollywood.common.basic.PageInfo;
|
import com.hollywood.common.exception.ServiceException;
|
import com.hollywood.common.model.TOrder;
|
import com.hollywood.common.model.TScript;
|
import com.hollywood.common.model.TUser;
|
import com.hollywood.common.utils.PayMoneyUtil;
|
import com.hollywood.common.utils.UUIDUtil;
|
import io.swagger.annotations.Api;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import sun.font.Script;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* <p>
|
* 剧本管理 服务实现类
|
* </p>
|
*
|
* @author xiaochen
|
* @since 2024-02-29
|
*/
|
@Service
|
public class TScriptServiceImpl extends ServiceImpl<TScriptMapper, TScript> implements TScriptService {
|
|
@Autowired
|
private TOrderMapper orderMapper;
|
|
@Resource
|
private PayMoneyUtil payMoneyUtil;
|
@Override
|
public PageInfo<TScriptVO> pageList(TScriptQuery query,List<Long> ids) {
|
PageInfo<TScriptVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
|
List<TScriptVO> list = this.baseMapper.pageList(query,pageInfo,ids);
|
pageInfo.setRecords(list);
|
return pageInfo;
|
}
|
|
@Override
|
public ApiResult pay(ScriptPayDto scriptPayDto,Long userId) throws Exception {
|
//判断当前用户是否购买
|
List<TOrder> tOrders = orderMapper.selectList(Wrappers.lambdaQuery(TOrder.class).
|
eq(TOrder::getProductId, scriptPayDto.getScriptId())
|
.eq(TOrder::getProductType, 1)
|
.eq(TOrder::getIsPay, 1).eq(TOrder::getUserId,userId)
|
);
|
if (!tOrders.isEmpty()){
|
throw new ServiceException(-1,"您已购买该剧本");
|
}
|
TScript scrpt = this.baseMapper.selectById(scriptPayDto.getScriptId());
|
//进行支付操作
|
if(scriptPayDto.getPayType() == 1){//微信支付
|
return weChatPaymentScript(userId,scrpt);
|
}
|
if (scriptPayDto.getPayType()==2){
|
return aliPayScript(userId,scrpt);
|
}
|
return ApiResult.failed("请选择支付方式");
|
}
|
|
public ApiResult aliPayScript(Long userId, TScript script) throws Exception{
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5);
|
TOrder order = new TOrder();
|
order.setUserId(userId);
|
order.setProductType(1);
|
order.setProductName(script.getScriptName());
|
order.setProductId(script.getId());
|
order.setReleasePerson(script.getReleasePerson());
|
order.setReleasePhone(script.getReleasePhone());
|
order.setProductDeposit(script.getScriptDeposit());
|
order.setPayTime(LocalDateTime.now());
|
if (script.getScriptDeposit()==null|| script.getScriptDeposit().equals(new BigDecimal(0))){
|
order.setIsPay(1);
|
}else {
|
order.setIsPay(2);
|
}
|
order.setPayMoney(script.getScriptDeposit());
|
order.setCode(code);
|
orderMapper.insert(order);
|
ApiResult alipay = payMoneyUtil.alipay("购买剧本", "购买剧本", code, script.getScriptDeposit().toString(), "/base/script/alicallback");
|
return alipay;
|
}
|
|
@Override
|
public void wxcallback(String code, String transaction_id) {
|
try {
|
|
TOrder order = orderMapper.selectOne(Wrappers.lambdaQuery(TOrder.class).eq(TOrder::getCode, code));
|
if(order.getIsPay() == 1){
|
order.setIsPay(2);
|
order.setOrderNum(transaction_id);
|
orderMapper.updateById(order);
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
@Resource
|
private TUserMapper userMapper;
|
@Override
|
public void alicallback(String code, String tradeNo) {
|
try {
|
TOrder order = orderMapper.selectOne(Wrappers.lambdaQuery(TOrder.class).eq(TOrder::getCode, code));
|
if(order.getIsPay() == 2){
|
order.setIsPay(1);
|
order.setOrderNum(tradeNo);
|
orderMapper.updateById(order);
|
|
TUser byId = userMapper.selectById(order.getUserId());
|
byId.setHasPay(byId.getHasPay()==null? order.getPayMoney() :byId.getHasPay().add(order.getPayMoney()));
|
userMapper.updateById(byId);
|
|
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
|
|
public ApiResult weChatPaymentScript(Long userId, TScript script) throws Exception{
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
|
String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5);
|
TOrder order = new TOrder();
|
order.setUserId(userId);
|
order.setProductType(1);
|
order.setProductName(script.getScriptName());
|
order.setProductId(script.getId());
|
order.setReleasePerson(script.getReleasePerson());
|
order.setReleasePhone(script.getReleasePhone());
|
order.setProductDeposit(script.getScriptDeposit());
|
order.setPayTime(LocalDateTime.now());
|
if (script.getScriptDeposit()==null|| script.getScriptDeposit().equals(new BigDecimal(0))){
|
order.setIsPay(2);
|
}else {
|
order.setIsPay(1);
|
}
|
|
order.setPayMoney(script.getScriptDeposit());
|
order.setCode(code);
|
orderMapper.insert(order);
|
|
|
ApiResult weixinpay = payMoneyUtil.weixinpay("购买剧本", "", code, script.getScriptDeposit().toString(), "/base/script/callback", "APP");
|
if(weixinpay.getCode() == 200){
|
new Thread(new Runnable() {
|
@Override
|
public void run() {
|
try {
|
int num = 1;
|
int wait = 0;
|
while (num <= 10){
|
int min = 5000;
|
wait += (min * num);
|
Thread.sleep(wait);
|
TOrder order1 = orderMapper.selectById(order.getId());
|
|
if(order1.getIsPay() == 2){
|
break;
|
}
|
ApiResult<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, "");
|
if(resultUtil.getCode() == 200 && order1.getIsPay() == 1){
|
/**
|
* SUCCESS—支付成功，
|
* REFUND—转入退款，
|
* NOTPAY—未支付，
|
* CLOSED—已关闭，
|
* REVOKED—已撤销（刷卡支付），
|
* USERPAYING--用户支付中，
|
* PAYERROR--支付失败(其他原因，如银行返回失败)
|
*/
|
Map<String, String> data1 = resultUtil.getData();
|
String s = data1.get("trade_state");
|
String transaction_id = data1.get("transaction_id");
|
if("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10){
|
|
break;
|
}
|
if("SUCCESS".equals(s)){
|
wxcallback(code,transaction_id);
|
break;
|
}
|
if("USERPAYING".equals(s)){
|
num++;
|
}
|
}
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
}).start();
|
}
|
return weixinpay;
|
}
|
}
|
