package com.ibeetl.admin.console.service.pay;
|
|
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.*;
|
import com.ibeetl.admin.console.rabbitmq.MqConstants;
|
import com.ibeetl.admin.console.rabbitmq.MqUtil;
|
import com.ibeetl.admin.console.service.CuserConsoleService;
|
import com.ibeetl.admin.console.service.XzxAccountInfoService;
|
import com.ibeetl.admin.console.service.pay.utils.WechatpayUtil;
|
import com.ibeetl.admin.console.service.pay.utils.entity.ResultEntity;
|
import com.ibeetl.admin.console.service.pay.utils.entity.TransfersDto;
|
import com.ibeetl.admin.core.entity.CoreUser;
|
import com.ibeetl.admin.core.entity.PayLog;
|
import com.ibeetl.admin.core.entity.XzxAccountInfo;
|
import com.ibeetl.admin.core.service.CorePlatformService;
|
import com.ibeetl.admin.core.util.payutil.WxRequestParam;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.DecimalFormat;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service
|
@Slf4j
|
public class PayService {
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
@Autowired
|
PayConsoleDao dao;
|
|
@Autowired
|
MoneyConsoleDao moneyConsoleDao;
|
|
@Autowired
|
WxRequestParam wxRequestParam;
|
@Autowired
|
CuserConsoleService cuserConsoleService;
|
/*@Autowired
|
MqUtil mqUtil;*/
|
@Autowired
|
XzxAccountInfoService xzxAccountInfoService;
|
@Autowired
|
CorePlatformService platformService;
|
|
public Map<String,Object> sendWxPay(String url,String path,TransfersDto dto, UserAccountModel userAccount,String mobilePhone,String oldMoney){
|
Map<String,Object> map = new HashMap<>();
|
String param=WechatpayUtil.getStringBuild(dto);
|
PayLog payLog =insertLog(dto,userAccount,param);
|
ResultEntity iResult = WechatpayUtil.doTransfers(url,path,dto,userAccount,param);
|
payLog.setResponseData(iResult.getMsg());
|
if(!"执行成功".equals(iResult.getMsg())){
|
payLog.setPayStatus("2");
|
dao.updatePaylogResponseData(payLog);
|
map.put("code",-1);
|
}else{
|
map.put("code",0);
|
}
|
map.put("data",iResult.getMsg());
|
String ua = updateAccount(iResult, payLog,dto.getPayOrderId(),mobilePhone,oldMoney);
|
System.out.println(dto.getUserId()+"=== 提现单号==="+dto.getPayOrderId()+"提现操作结果======"+ua);
|
return map;
|
}
|
|
/**
|
* 企业提现零钱接口
|
* @param dto
|
* @param userAccount
|
*/
|
private PayLog insertLog(TransfersDto dto, UserAccountModel userAccount, String param){
|
// 添加账户log请求前信息
|
PayLog payLog = new PayLog();
|
payLog.setId(IdUtil.getSnowflake(1, 3).nextId());
|
payLog.setAccountBeforeMoney(userAccount.getMoney());
|
payLog.setUserId(dto.getUserId());
|
payLog.setAccountId(userAccount.getAccountId());
|
payLog.setWxOpenid(dto.getOpenid());
|
payLog.setCreateTime(sdf.format(new Date()));
|
payLog.setPayStatus("0");
|
//因为接口使用的是以分为单位，所以需要转为元
|
String a = new BigDecimal(dto.getAmount()).divide(new BigDecimal("100"),2, RoundingMode.HALF_UP).toString();
|
payLog.setMoney(Double.valueOf(a));
|
payLog.setWithdrawBeforeMoney(Double.parseDouble("0"));
|
payLog.setMchBillno(dto.getPayOrderId());
|
|
payLog.setRequestParams(param);
|
if(dao.insertPaylog(payLog) == 0){
|
return null;
|
}else{
|
return payLog;
|
}
|
|
}
|
|
public static double subDouble(double m1, double m2) {
|
BigDecimal p1 = new BigDecimal(Double.toString(m1));
|
BigDecimal p2 = new BigDecimal(Double.toString(m2));
|
BigDecimal p3 =p1.subtract(p2);
|
return p3.setScale(2, BigDecimal.ROUND_DOWN).doubleValue();
|
}
|
|
public static void main(String[] args) {
|
|
|
}
|
@Transactional
|
String updateAccount(ResultEntity entity, PayLog payLog,String payOrderId,String mobilePhone,String oldMoney){
|
if(!"执行成功".equals(entity.getMsg())){
|
payLog.setPayStatus("2");
|
dao.updatePaylogResponseData(payLog);
|
|
MoneyModel moneyModel = new MoneyModel();
|
moneyModel.setPayOrderId(payOrderId);
|
moneyModel.setPayFlag("3");
|
moneyModel.setUnpassReason(entity.getMsg());
|
moneyConsoleDao.updateMoneyApi(moneyModel);
|
return entity.getMsg();
|
}
|
UserAccountModel userAccountModel1 = cuserConsoleService.queryAccountInfo(payLog.getUserId(), mobilePhone);
|
double mm = subDouble(userAccountModel1.getMoney(),payLog.getMoney());
|
PayLog newPl = new PayLog();
|
newPl.setAccountId(payLog.getAccountId());
|
newPl.setMoney(mm);
|
// 更新账号余额
|
if(dao.updateAccountMoneyDouble(newPl) > 0){
|
|
// 更新订单表的状态
|
MoneyModel moneyModel = new MoneyModel();
|
moneyModel.setPayOrderId(payOrderId);
|
moneyModel.setPayFlag("2");
|
moneyModel.setUnpassReason("提现成功");
|
moneyConsoleDao.updateMoneyApi(moneyModel);
|
payLog.setPayStatus("1");
|
payLog.setAccountAfterMoney(Double.parseDouble("0"));
|
dao.updatePaylogMoney(payLog);
|
|
//写入消息列表中
|
String message = "您的提现已经到了："+payLog.getMoney()+"元，提现单号："+payOrderId+",请注意查收.";
|
dao.insertMessage(message,payLog.getUserId(),"","1","提现",sdf.format(new Date()));
|
|
//写入账户日志表 xzx_account_log
|
//dao.insertAccountLog();
|
UserAccountModel userAccountModel = cuserConsoleService.queryAccountInfo(payLog.getUserId(), mobilePhone);
|
//BigDecimal oldMoney = new BigDecimal(userAccountModel.getMoney()).add(new BigDecimal(payLog.getMoney()));
|
AccountLogModel model = new AccountLogModel();
|
model.setAccountId(userAccountModel.getAccountId());
|
model.setChannelType("2");
|
model.setCreateTime(sdf.format(new Date()));
|
model.setCreateUserId(userAccountModel.getUserId());
|
model.setNewFixedLimit(userAccountModel.getFixedLimit());
|
model.setNewLimit(userAccountModel.getOverdraftLimit());
|
model.setNewMoney(String.valueOf(userAccountModel.getMoney()));
|
model.setOldFixedLimit(userAccountModel.getFixedLimit());
|
model.setOldLimit(userAccountModel.getOverdraftLimit());
|
model.setOldMoney(oldMoney.toString());
|
model.setOrderId(payOrderId);
|
dao.insertAccountLog(model);
|
return entity.getMsg();
|
}else{
|
payLog.setRemark("支付成功,但是余额未扣除成功,原因待查");
|
dao.updatePaylogRemark(payLog);
|
}
|
return "账户余额更新失败";
|
}
|
|
private XzxAccountLogModel getAccountLog(XzxAccountInfo accountInfo,String money){
|
XzxAccountLogModel model = new XzxAccountLogModel();
|
model.setOrderId("");
|
model.setChannelType(9);
|
model.setCreateTime(sdf.format(new Date()));
|
CoreUser user = platformService.getCurrentUser();
|
model.setCreateUserId(Long.toString(user.getId()));
|
model.setAccountId(accountInfo.getAccountId());
|
model.setOldMoney(accountInfo.getMoney());
|
model.setNewMoney(new BigDecimal(accountInfo.getMoney()).add(new BigDecimal(money)).toString());
|
model.setOldLimit(accountInfo.getOverdraftLimit());
|
model.setNewLimit(accountInfo.getOverdraftLimit());
|
model.setOldFixedLimit(accountInfo.getFixedLimit());
|
model.setNewFixedLimit(accountInfo.getFixedLimit());
|
return model;
|
}
|
|
|
public Map<String, Object> queryPayInfoDetail(String payOrderId){
|
Map<String, Object> map = moneyConsoleDao.queryPayInfoDetail(payOrderId);
|
if(!"1".equals(map.get("usertype"))){
|
String roleName = moneyConsoleDao.queryPayInfoUserRole(map.get("usertype").toString());
|
map.put("roleName",roleName);
|
}else{
|
map.put("roleName","普通用户");
|
}
|
|
if(map.get("status").equals("2")){
|
map.put("statusName","已审核");
|
}else if(map.get("status").equals("3")){
|
map.put("statusName","审核未通过");
|
}else{
|
map.put("statusName","待审核");
|
}
|
return map;
|
}
|
|
|
public int addReason(String payOrderId, String userId, String reason){
|
return dao.addReason(payOrderId,userId,reason);
|
}
|
}
|
