package com.ibeetl.admin.console.api;
|
|
import cn.hutool.core.lang.Snowflake;
|
import cn.hutool.core.util.IdUtil;
|
import com.ibeetl.admin.console.dao.PayConsoleDao;
|
import com.ibeetl.admin.console.model.*;
|
import com.ibeetl.admin.console.service.*;
|
import com.ibeetl.admin.console.service.pay.utils.entity.TransfersDto;
|
import com.ibeetl.admin.console.util.DoubleUtil;
|
import com.ibeetl.admin.core.entity.CoreUser;
|
import com.ibeetl.admin.core.entity.XzxAccountInfo;
|
import com.ibeetl.admin.core.entity.XzxCityPartner;
|
import com.ibeetl.admin.core.service.CorePlatformService;
|
import com.ibeetl.admin.core.web.JsonResult;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiImplicitParam;
|
import io.swagger.annotations.ApiImplicitParams;
|
import io.swagger.annotations.ApiOperation;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.PostMapping;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@RestController
|
@Api(value = "资金管理接口类")
|
public class FundManagementApi {
|
private static final String MODEL = "/admin/front/fund";
|
private final Logger log = LoggerFactory.getLogger(this.getClass());
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
@Autowired
|
FundManagementApiService service;
|
@Autowired
|
MoneyConsoleService moneyConsoleService;
|
|
@Autowired
|
CuserConsoleService cuserConsoleService;
|
@Autowired
|
SettingConsoleService settingConsoleService;
|
@Autowired
|
CorePlatformService platformService;
|
@Autowired
|
PayConsoleService payLogService;
|
@Autowired
|
XzxCityPartnerService cityPartnerService;
|
|
@PostMapping(MODEL + "/queryFundManagementList.do")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-提现审核", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "nickName", value = "昵称", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "审核状态(1为待审核,2为已审核,3为审核不通过)", required = true, dataType = "String")
|
|
})
|
public JsonResult<Map<String, Object>> queryFundManagementList(@RequestBody MoneyModel moneyModel) {
|
moneyModel.setPayType("4");
|
return service.queryFundManagementList(moneyModel);
|
}
|
|
@PostMapping(MODEL + "/queryPayInfoDetail.json")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-提现审核详情", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "payOrderId", value = "金钱表ID", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "userType", value = "身份类别", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryPayInfoDetail(@RequestBody MoneyModel moneyModel) {
|
moneyModel.setPayType("4");
|
return service.queryPayInfoDetailApi(moneyModel);
|
}
|
|
@PostMapping(MODEL + "/queryRechangeApiList.do")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-充值记录", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "nickName", value = "昵称", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "支付状态(0为合伙人保存充值状态，1为待支付,2为已支付,3为已审核,4为已提现,5为待审核，6审核不通过)", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryRechangeApiList(@RequestBody MoneyModel moneyModel) {
|
|
Map<String, Object> map = service.queryRechangeApiList(moneyModel);
|
return JsonResult.success(map);
|
}
|
|
@PostMapping(MODEL + "/queryRechangeApiDetail.json")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-充值记录（查看详情）", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "payOrderId", value = "充值记录Id", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryRechangeApiDetail(@RequestBody PayInfoModel payInfoModel) {
|
|
Map<String, Object> map = service.queryRechangeApiDetail(payInfoModel);
|
return JsonResult.success(map);
|
}
|
|
|
@PostMapping(MODEL + "/quotaList.do")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-额度申请", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "nickName", value = "昵称", required = true, dataType = "String")
|
|
})
|
public JsonResult<Map<String, Object>> quotaList(@RequestBody MoneyModel moneyModel) {
|
moneyModel.setPayType("7");
|
return service.queryFundManagementList(moneyModel);
|
}
|
|
@PostMapping(MODEL + "/quota.json")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-额度申请（通过）", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "payOrderId", value = "额度申请Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "userId", value = "用户Id", required = true, dataType = "String")
|
})
|
public JsonResult<String> quota(@RequestBody TransfersDto dto) {
|
Map<String, Object> result = new HashMap<>();
|
MoneyModel moneyModel = new MoneyModel();
|
moneyModel.setPayOrderId(dto.getPayOrderId());
|
moneyModel = moneyConsoleService.queryMoney(moneyModel);
|
//
|
UserModel userModel = cuserConsoleService.queryUserById(moneyModel.getCreateUserId());
|
if (userModel == null) {
|
if (moneyModel.getPayType().equals("9")) {
|
userModel = cuserConsoleService.queryRecoveryById(moneyModel.getCreateUserId(), "4");
|
} else {
|
userModel = cuserConsoleService.queryRecoveryById(moneyModel.getCreateUserId(), "2");
|
}
|
}
|
|
if (null != userModel) {
|
UserAccountModel userAccountModel = cuserConsoleService.queryAccountInfo(moneyModel.getCreateUserId(), userModel.getMobilePhone());
|
if (userAccountModel == null) {
|
return JsonResult.success("此用户未查询到账户信息");
|
} else {
|
String money = moneyModel.getMoney();
|
String type = "";
|
if (moneyModel.getPayType().equals("9")) {
|
type = "9";
|
BigDecimal money1 = new BigDecimal(userAccountModel.getFixedLimit()).subtract(new BigDecimal(userAccountModel.getOverdraftLimit()));
|
money = DoubleUtil.roundTwo(money1.toString());
|
settingConsoleService.updateLimitByUserId(userAccountModel.getAccountId(), moneyModel.getMoney());
|
} else {
|
type = "8";
|
settingConsoleService.updateOverdrawPriceByUserId(userAccountModel.getAccountId(), moneyModel.getMoney());
|
}
|
//此处需要扣除合伙人的钱
|
String partnerId = userModel.getPartnerId();
|
XzxCityPartner partner = cityPartnerService.queryById(partnerId);
|
if (partner.getPartnerType().equals("2")) {
|
partner = cityPartnerService.queryById(partner.getPackingStation());
|
}
|
UserAccountModel partnerAccount = cityPartnerService.queryPartnerAccountByUserId(partner.getUserId());
|
PartnerAccountModel partnerAccountModel = cityPartnerService.getPartnerAccountByUserId(partner.getUserId());
|
Snowflake snowflake = IdUtil.getSnowflake(0, 3);
|
String payOrderId = "ZF" + snowflake.nextIdStr();
|
cityPartnerService.insertPartnerAccountLog(partnerAccount, type, new BigDecimal(money), payOrderId, null);
|
System.out.println("=========合伙人人原有环保币======" + partnerAccountModel.getHbb());
|
BigDecimal newPartnerMoney = new BigDecimal(partnerAccountModel.getHbb()).subtract(new BigDecimal(money));
|
if (newPartnerMoney.compareTo(BigDecimal.ZERO) == -1) {
|
return JsonResult.failMessage("所属合伙人需要充值！余额不够分配！");
|
}
|
System.out.println("=========合伙人人现有环保币======" + newPartnerMoney.toString());
|
partnerAccount.setMoney(newPartnerMoney.doubleValue());
|
partnerAccountModel.setMoney(DoubleUtil.roundTwo(newPartnerMoney.toString()));
|
partnerAccountModel.setHbb(DoubleUtil.roundTwo(newPartnerMoney.toString()));
|
cityPartnerService.updateAccountPartner(partnerAccount);
|
cityPartnerService.updatePartnerAccount(partnerAccountModel);
|
CoreUser user = platformService.getCurrentUser();
|
//修改申请状态
|
moneyModel.setStatus("2");
|
moneyModel.setUpdateTime(sdf.format(new Date()));
|
moneyModel.setCreateUserId(String.valueOf(user.getId()));
|
moneyModel.setUnpassReason("");
|
moneyConsoleService.updateMoney(moneyModel);
|
//写入日志
|
AccountLogModel log = new AccountLogModel();
|
log.setAccountId(userAccountModel.getAccountId());
|
log.setChannelType("2");
|
log.setCreateTime(sdf.format(new Date()));
|
log.setCreateUserId(userAccountModel.getUserId());
|
BigDecimal oldFixedLimit = new BigDecimal(String.valueOf(userAccountModel.getFixedLimit()));
|
BigDecimal oldLimit = new BigDecimal(String.valueOf(userAccountModel.getOverdraftLimit()));
|
if(moneyModel.getPayType().equals("9")){
|
log.setNewFixedLimit(oldFixedLimit.toString());
|
|
}else{
|
log.setNewFixedLimit(oldFixedLimit.add(new BigDecimal(moneyModel.getMoney())).toString());
|
|
}
|
log.setNewLimit(oldLimit.add(new BigDecimal(moneyModel.getMoney())).toString());
|
log.setNewMoney(String.valueOf(userAccountModel.getMoney()));
|
log.setOldFixedLimit(oldFixedLimit.toString());
|
log.setOldLimit(oldLimit.toString());
|
log.setOldMoney(String.valueOf(userAccountModel.getMoney()));
|
log.setOrderId(dto.getPayOrderId());
|
//model.setOrderId(payOrderId);
|
payLogService.insertAccountLog(log);
|
|
return JsonResult.success("完成审核");
|
}
|
} else {
|
return JsonResult.success("查不到对应的申请人");
|
}
|
|
}
|
|
@PostMapping(MODEL + "/queryStorageMoneyApi.do")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-支出明细", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "storageUserName", value = "入库员", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "storageUserPhone", value = "入库员手机号", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> queryStorageMoneyApi(@RequestBody PayStorageModel model) {
|
Map<String, Object> map = service.queryStorageMoneyApi(model);
|
return JsonResult.success(map);
|
}
|
|
@PostMapping(MODEL + "/queryStorageMoneyDetailApi.json")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-支出明细详情", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "storageId", value = "入库Id", required = true, dataType = "String"),
|
})
|
public JsonResult<Map<String, Object>> queryStorageMoneyDetailApi(@RequestBody PayStorageModel model) {
|
Map<String, Object> map = service.queryStorageMoneyDetailApi(model);
|
return JsonResult.success(map);
|
}
|
|
@PostMapping(MODEL + "/quotaCancel.json")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-额度申请(拒绝)", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "payOrderId", value = "额度申请Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "userId", value = "用户Id", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "unpassReason", value = "未通过原因", required = true, dataType = "String")
|
})
|
public JsonResult<String> quotaCancel(@RequestBody TransfersDto dto) {
|
Map<String, Object> result = new HashMap<>();
|
MoneyModel moneyModel = new MoneyModel();
|
moneyModel.setPayOrderId(dto.getPayOrderId());
|
moneyModel = moneyConsoleService.queryMoney(moneyModel);
|
moneyModel.setStatus("3");
|
moneyModel.setUnpassReason(dto.getUnpassReason());
|
moneyConsoleService.updateMoney(moneyModel);
|
return JsonResult.success("完成审核");
|
}
|
|
@PostMapping(MODEL + "/quotaDetail.json")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-额度申请(详情)", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "userId", value = "回收员Id", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> quotaDetail(@RequestBody StorageUserModel storageUserModel) {
|
Map<String, Object> map = service.quotaDetail(storageUserModel);
|
return JsonResult.success(map);
|
}
|
|
@PostMapping(MODEL + "/quotaRecoveryList.do")
|
@ResponseBody
|
@ApiOperation(value = "资金管理-额度恢复(通过接口和拒绝接口与额度审核接口相同)", notes = "test: 仅0有正确返回")
|
@ApiImplicitParams({
|
@ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = true, dataType = "int"),
|
@ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "nickName", value = "昵称", required = true, dataType = "String"),
|
@ApiImplicitParam(paramType = "query", name = "status", value = "审核状态(1为待审核,2为已审核,3为审核不通过)", required = true, dataType = "String")
|
})
|
public JsonResult<Map<String, Object>> quotaRecoveryList(@RequestBody MoneyModel moneyModel) {
|
moneyModel.setPayType("9");
|
return service.queryFundManagementList(moneyModel);
|
}
|
}
|
