package com.ibeetl.admin.console.service;
|
|
import cn.hutool.core.lang.Snowflake;
|
import cn.hutool.core.util.IdUtil;
|
import com.ibeetl.admin.console.dao.MoneyConsoleDao;
|
import com.ibeetl.admin.console.dao.PayConsoleDao;
|
import com.ibeetl.admin.console.model.AccountLogModel;
|
import com.ibeetl.admin.console.model.MoneyModel;
|
import com.ibeetl.admin.core.entity.PayLog;
|
import com.ibeetl.admin.core.util.payutil.WxConfig;
|
import com.ibeetl.admin.core.util.payutil.WxRequestParam;
|
import com.ibeetl.admin.core.util.payutil.WxUtil;
|
import com.ibeetl.admin.core.web.JsonResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.beetl.ext.fn.Json;
|
import org.beetl.sql.core.SQLManager;
|
import org.beetl.sql.core.db.KeyHolder;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service
|
@Slf4j
|
public class PayConsoleService {
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
@Autowired
|
PayConsoleDao dao;
|
|
@Autowired
|
MoneyConsoleDao moneyConsoleDao;
|
|
@Autowired
|
WxUtil wxUtil;
|
|
@Autowired
|
WxRequestParam wxRequestParam;
|
|
public JsonResult wxXcxPay(Map<String, String> m, String payFlag){
|
try {
|
// 添加账户log请求前信息
|
PayLog payLog = new PayLog();
|
payLog.setId(IdUtil.getSnowflake(1, 3).nextId());
|
payLog.setAccountBeforeMoney(Double.parseDouble(m.get("accountBeforeMoney")));
|
payLog.setUserId(m.get("userId"));
|
payLog.setAccountId(m.get("accountId"));
|
payLog.setWxOpenid(m.get("reOpenid"));
|
payLog.setCreateTime(sdf.format(new Date()));
|
payLog.setPayStatus("0");
|
payLog.setMoney(Double.parseDouble(m.get("totalAmount")));
|
payLog.setWithdrawBeforeMoney(Double.parseDouble(m.get("withdrawBeforeMoney")));
|
payLog.setMchBillno(m.get("payOrderId"));
|
|
Map<String, String> mx = new HashMap<>();
|
|
if(payFlag.equals("1")){
|
String param = wxRequestParam.getXcxParam(m);
|
payLog.setRequestParams(param);
|
if(dao.insertPaylog(payLog) == 0){
|
return JsonResult.failMessage("添加账号日志失败");
|
}
|
// 小程序红包支付
|
mx = wxUtil.sendWxXcxPay(WxConfig.WX_SENDMIIPROGRAMHB_URL, param);
|
}else if(payFlag.equals("2")){
|
String param = wxRequestParam.getQiyePayParam(m);
|
payLog.setRequestParams(param);
|
if(dao.insertPaylog(payLog) == 0){
|
return JsonResult.failMessage("添加账号日志失败");
|
}
|
// 微信企业支付
|
mx = wxUtil.sendWxXcxPay(WxConfig.WX_QIYE_PAY_URL, param);
|
}else{
|
return JsonResult.failMessage("payFlag错误");
|
}
|
|
payLog.setResponseData(mx.toString());
|
if(mx == null){
|
payLog.setPayStatus("2");
|
dao.updatePaylogResponseData(payLog);
|
return JsonResult.failMessage("支付返回结果为空");
|
}
|
return updateAccount(mx, payLog);
|
}catch (Exception e){
|
e.printStackTrace();
|
return JsonResult.failMessage(e.getMessage());
|
}
|
}
|
|
@Transactional
|
JsonResult updateAccount(Map<String, String> map, PayLog payLog){
|
if(map.toString().indexOf("FAIL")!=-1){
|
payLog.setPayStatus("2");
|
dao.updatePaylogResponseData(payLog);
|
return JsonResult.failMessage(map.get("return_msg"));
|
}
|
|
// 更新账号余额
|
if(dao.updateAccountMoney(payLog) > 0){
|
// 更新订单表的状态
|
MoneyModel moneyModel = new MoneyModel();
|
moneyModel.setOrderId(map.get("payOrderId"));
|
moneyModel.setPayFlag("2");
|
moneyConsoleDao.updateMoney(moneyModel);
|
|
payLog.setPayStatus("1");
|
payLog.setAccountAfterMoney(payLog.getAccountBeforeMoney() - payLog.getMoney());
|
payLog.setWithdrawBeforeMoney(payLog.getWithdrawBeforeMoney() - payLog.getMoney());
|
dao.updatePaylogMoney(payLog);
|
return JsonResult.successMessage(map.toString());
|
}else{
|
payLog.setRemark("支付成功,但是余额未扣除成功,原因待查");
|
dao.updatePaylogRemark(payLog);
|
}
|
return JsonResult.failMessage("账户余额更新失败");
|
|
}
|
|
public void insertAccountLog(AccountLogModel log){
|
dao.insertAccountLog(log);
|
}
|
|
}
|
