package com.dy.pipIrrSell.general;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.alibaba.fastjson2.JSONArray;
|
import com.alibaba.fastjson2.JSONObject;
|
import com.dy.common.webUtil.QueryResultVo;
|
import com.dy.pipIrrGlobal.daoSe.*;
|
import com.dy.pipIrrGlobal.pojoSe.SeAudits;
|
import com.dy.pipIrrGlobal.pojoSe.SeGeneral;
|
import com.dy.pipIrrGlobal.pojoSe.SePaymentMethod;
|
import com.dy.pipIrrGlobal.voSe.VoGeneral;
|
import com.dy.pipIrrGlobal.voSe.VoTradeDetails;
|
import com.dy.pipIrrGlobal.voSe.VoTransactionStatistics;
|
import com.dy.pipIrrSell.general.qo.QoGeneral;
|
import com.dy.pipIrrSell.general.qo.QoSummary;
|
import com.dy.pipIrrSell.general.qo.QoToAudit;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.dubbo.common.utils.PojoUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.text.DecimalFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* @author ZhuBaoMin
|
* @date 2024-01-24 19:02
|
* @LastEditTime 2024-01-24 19:02
|
* @Description
|
*/
|
|
@Slf4j
|
@Service
|
public class GeneralSv {
|
@Autowired
|
private SeGeneralMapper seGeneralMapper;
|
|
@Autowired
|
private SeAuditsMapper seAuditsMapper;
|
|
@Autowired
|
private SeCardOperateMapper seCardOperateMapper;
|
|
@Autowired
|
private SeWalletRechargeMapper seWalletRechargeMapper;
|
|
@Autowired
|
private SeRefundMapper seRefundMapper;
|
|
@Autowired
|
private SePaymentMethodMapper sePaymentMethodMapper;
|
|
/**
|
* 获取未生成总账的交易日期列表（当天的交易记录不生成总账）
|
* @return
|
*/
|
public List<Map<String, Object>> getDatesOfNotInGenerals() {
|
return seGeneralMapper.getDatesOfNotInGenerals();
|
}
|
|
/**
|
* 添加总账
|
* @param po 总账对象
|
* @return
|
*/
|
public Integer addGeneral(SeGeneral po) {
|
return seGeneralMapper.insert(po);
|
}
|
|
/**
|
* 根据交易日期获取总账记录列表（待生成的）
|
* @param operateDate 交易日期
|
* @return 取总账记录列表
|
*/
|
public List<SeGeneral> getGeneralByOperateDate(String operateDate) {
|
return seGeneralMapper.getGeneralByOperateDate(operateDate);
|
}
|
|
/**
|
* 根据指定条件获取总账记录
|
* @param queryVo
|
* @return
|
*/
|
public QueryResultVo<List<VoGeneral>> getGenerals(QoGeneral queryVo) {
|
Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
|
|
Long itemTotal = seGeneralMapper.getRecordCount(params);
|
|
QueryResultVo<List<VoGeneral>> rsVo = new QueryResultVo<>() ;
|
rsVo.pageSize = queryVo.pageSize ;
|
rsVo.pageCurr = queryVo.pageCurr ;
|
|
rsVo.calculateAndSet(itemTotal, params);
|
rsVo.obj = seGeneralMapper.getGenerals(params);
|
return rsVo ;
|
}
|
|
/**
|
* 导出指定条件的总账记录
|
* @param queryVo
|
* @return
|
*/
|
public QueryResultVo<List<VoGeneral>> exportGenerals(QoGeneral queryVo) {
|
Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
|
|
Long itemTotal = seGeneralMapper.getRecordCount(params);
|
QueryResultVo<List<VoGeneral>> rsVo = new QueryResultVo<>() ;
|
|
rsVo.calculateAndSet(itemTotal, params);
|
params.remove("start");
|
params.remove("count");
|
rsVo.obj = seGeneralMapper.getGenerals(params);
|
return rsVo ;
|
}
|
|
/**
|
* 修改总账审核意见
|
* @param po
|
* @return
|
*/
|
public Integer updateGeneral(SeGeneral po) {
|
return seGeneralMapper.updateByPrimaryKeySelective(po);
|
}
|
|
/**
|
* 根据编号查询总账
|
* @param id
|
* @return
|
*/
|
public SeGeneral getGeneralById(Long id) {
|
return seGeneralMapper.selectByPrimaryKey(id);
|
}
|
|
/**
|
* 添加总账审核记录
|
* @param po
|
* @return
|
*/
|
public Integer addAudits(SeAudits po) {
|
return seAuditsMapper.insert(po);
|
}
|
|
|
/**
|
* 开卡系统交易汇总查询与对账系统交易汇总查询共用服务实现类
|
* @param vo
|
* @return
|
* @throws ParseException
|
*/
|
public Map getSummaries(QoSummary vo) throws ParseException {
|
DecimalFormat df = new DecimalFormat("0.00");
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
|
Integer pageSize = vo.getPageSize();
|
Integer pageCurr = vo.getPageCurr();
|
// 起始索引位置
|
Integer startIndex = (pageCurr - 1) * pageSize;
|
|
// 获取各支付方式ID
|
Long paymentId_cash = 0L;
|
Long paymentId_wechat = 0L;
|
Long paymentId_alipay = 0L;
|
Long paymentId_transfer = 0L;
|
List<SePaymentMethod> list_payment = sePaymentMethodMapper.getPaymentMethods();
|
for (int i = 0; i < list_payment.size(); i++) {
|
SePaymentMethod paymentMethod = list_payment.get(i);
|
if(paymentMethod.getName().equals("现金")) {
|
paymentId_cash = paymentMethod.getId();
|
}
|
if(paymentMethod.getName().equals("微信支付")) {
|
paymentId_wechat = paymentMethod.getId();
|
}
|
if(paymentMethod.getName().equals("支付宝支付")) {
|
paymentId_alipay = paymentMethod.getId();
|
}
|
if(paymentMethod.getName().equals("银行转账")) {
|
paymentId_transfer = paymentMethod.getId();
|
}
|
|
}
|
|
// 接收传入参数：交易起止日期、收银员ID
|
JSONArray array_paymentSums = new JSONArray();
|
Date timeStart = dateFormat.parse(vo.getTimeStart());
|
Date timeStop = dateFormat.parse(vo.getTimeStop());
|
Long cashierId = vo.cashierId;
|
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(timeStart);
|
while (calendar.getTime().before(timeStop) || calendar.getTime().equals(timeStop)) {
|
String tradeDate = dateFormat.format(calendar.getTime()) ;
|
if(cashierId != 1000000L) {
|
Float receivedCash = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId, paymentId_cash)).orElse(0f);
|
Float receivedWechat = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId,paymentId_wechat)).orElse(0f);
|
Float receivedAlipay = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId,paymentId_alipay)).orElse(0f);
|
Float receivedTransfer = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId, paymentId_transfer)).orElse(0f);
|
|
JSONObject job = new JSONObject();
|
job.put("tradeDate", tradeDate);
|
job.put("receivedCash", receivedCash);
|
job.put("receivedWechat", receivedWechat);
|
job.put("receivedAlipay", receivedAlipay);
|
job.put("receivedTransfer", receivedTransfer);
|
array_paymentSums.add(job);
|
|
}else {
|
// 分级计算指定日期微信收退款合计，再计算实收金额
|
Double rechargeWeChat = Optional.ofNullable(seWalletRechargeMapper.getRechargeSum(tradeDate)).orElse(0.0);
|
Double refundWeChat = Optional.ofNullable(seRefundMapper.getRefundSum(tradeDate)).orElse(0.0);
|
Double receiveWeChat = rechargeWeChat - refundWeChat;
|
|
// 微信实收金额写入返回对象（写入前格式化）
|
JSONObject job = new JSONObject();
|
job.put("receiveWeChat", df.format(receiveWeChat));
|
array_paymentSums.add(job);
|
}
|
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
}
|
|
// 生成查询参数
|
Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(vo) ;
|
|
// 获取符合条件的记录数(代码全部注释掉了，没删)
|
//Long itemTotal = seGeneralMapper.getToAuditRecordCount(params);
|
|
/**
|
* 根据收银员编号、交易日期查询汇总记录
|
* 遍历汇总记录查询结果，计算笔数合计、实收金额合计、赠送金额合计、返还金额合计
|
*/
|
List<VoTransactionStatistics> list = Optional.ofNullable(seGeneralMapper.getSummaries(params)).orElse(new ArrayList<>());
|
if(list.size() == 0) {
|
return new HashMap();
|
}
|
|
Integer totalCount = 0;
|
Float totalReceived = 0f;
|
Float totalGift = 0f;
|
Float totalRefund = 0f;
|
JSONArray array= JSONArray.parseArray(JSON.toJSONString(list));
|
for(int i = 0; i < array.size(); i++) {
|
JSONObject job_summary = array.getJSONObject(i);
|
totalCount = totalCount + Optional.ofNullable(job_summary.getInteger("count")).orElse(0);
|
totalReceived = totalReceived + Optional.ofNullable(job_summary.getFloat("received")).orElse(0f);
|
totalGift = totalGift + Optional.ofNullable(job_summary.getFloat("gift")).orElse(0f);
|
totalRefund = totalRefund + Optional.ofNullable(job_summary.getFloat("refundAmount")).orElse(0f);
|
}
|
|
Map map_result = new HashMap();
|
map_result.put("totalCount", totalCount);
|
map_result.put("totalReceived", totalReceived);
|
map_result.put("totalGift", totalGift);
|
map_result.put("totalRefund", totalRefund);
|
|
// 分页格式组装记录列表
|
Map map_record = new HashMap();
|
map_record.put("itemTotal", list.size());
|
map_record.put("pageCurr", pageCurr);
|
map_record.put("pageSize", pageSize);
|
map_record.put("pageTotal", (int)Math.ceil((double)list.size() / pageSize));
|
JSONArray array_record = (JSONArray) JSON.toJSON(list);
|
JSONArray array_record_page = (JSONArray)JSON.toJSON(array_record.subList(startIndex, Math.min(startIndex + pageSize, array_record.size())));
|
map_record.put("list", array_record_page);
|
|
// 分页格式组装支付方式列表
|
Map map_paymentSums = new HashMap();
|
map_paymentSums.put("itemTotal", array_paymentSums.size());
|
map_paymentSums.put("pageCurr", pageCurr);
|
map_paymentSums.put("pageSize", pageSize);
|
map_paymentSums.put("pageTotal", (int)Math.ceil((double)array_paymentSums.size() / pageSize));
|
JSONArray array_paymentSums_page = (JSONArray) JSON.toJSON(array_paymentSums.subList(startIndex, Math.min(startIndex + pageSize, array_paymentSums.size())));
|
map_paymentSums.put("list", array_paymentSums_page);
|
|
|
map_result.put("records", map_record);
|
map_result.put("paymentSums", map_paymentSums);
|
|
return map_result;
|
}
|
|
/**
|
* 根据收银员ID及日期获取财务对账_交易明细记录
|
* @param queryVo
|
* @return
|
*/
|
public Map getTradeDetails(QoToAudit queryVo) {
|
DecimalFormat df = new DecimalFormat("0.00");
|
Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
|
|
Long itemTotal = seGeneralMapper.getTradeDetailsRecordCount(params);
|
|
QueryResultVo<List<VoTradeDetails>> rsVo = new QueryResultVo<>() ;
|
rsVo.pageSize = queryVo.pageSize ;
|
rsVo.pageCurr = queryVo.pageCurr ;
|
|
rsVo.calculateAndSet(itemTotal, params);
|
List<VoTradeDetails> list = Optional.ofNullable(seGeneralMapper.getTradeDetails(params)).orElse(new ArrayList<>());
|
if(list.size() == 0) {
|
return new HashMap();
|
}
|
|
// 遍历交易明细记录，汇总交易金额
|
Double totalTradeAmount = 0.0;
|
JSONArray array= JSONArray.parseArray(JSON.toJSONString(list));
|
for(int i = 0; i < array.size(); i++) {
|
JSONObject job = array.getJSONObject(i);
|
Double tradeAmount = Optional.ofNullable(job.getDouble("tradeAmount")).orElse(0.0);
|
totalTradeAmount = totalTradeAmount + tradeAmount;
|
}
|
|
Map map_record = new HashMap();
|
map_record.put("itemTotal", rsVo.itemTotal);
|
map_record.put("pageCurr", rsVo.pageCurr);
|
map_record.put("pageSize", rsVo.pageSize);
|
map_record.put("pageTotal", rsVo.pageTotal);
|
map_record.put("list", list);
|
|
Map map_result = new HashMap();
|
|
map_result.put("totalTradeAmount", df.format(totalTradeAmount));
|
map_result.put("records", map_record);
|
|
return map_result;
|
|
}
|
|
/**
|
* 导出交易明细记录
|
* @param queryVo
|
* @return
|
*/
|
public Map exportTradeDetails(QoToAudit queryVo) {
|
DecimalFormat df = new DecimalFormat("0.00");
|
Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);
|
|
Long itemTotal = seGeneralMapper.getTradeDetailsRecordCount(params);
|
|
QueryResultVo<List<VoTradeDetails>> rsVo = new QueryResultVo<>() ;
|
rsVo.pageSize = queryVo.pageSize ;
|
rsVo.pageCurr = queryVo.pageCurr ;
|
|
rsVo.calculateAndSet(itemTotal, params);
|
params.remove("start");
|
params.remove("count");
|
List<VoTradeDetails> list = Optional.ofNullable(seGeneralMapper.getTradeDetails(params)).orElse(new ArrayList<>());
|
if(list.size() == 0) {
|
return new HashMap();
|
}
|
|
// 遍历交易明细记录，汇总交易金额
|
Double totalTradeAmount = 0.0;
|
JSONArray array= JSONArray.parseArray(JSON.toJSONString(list));
|
for(int i = 0; i < array.size(); i++) {
|
JSONObject job = array.getJSONObject(i);
|
Double tradeAmount = Optional.ofNullable(job.getDouble("tradeAmount")).orElse(0.0);
|
totalTradeAmount = totalTradeAmount + tradeAmount;
|
}
|
|
Map map_record = new HashMap();
|
map_record.put("itemTotal", rsVo.itemTotal);
|
map_record.put("pageCurr", rsVo.pageCurr);
|
map_record.put("pageSize", rsVo.pageSize);
|
map_record.put("pageTotal", rsVo.pageTotal);
|
map_record.put("list", list);
|
|
Map map_result = new HashMap();
|
|
map_result.put("totalTradeAmount", df.format(totalTradeAmount));
|
map_result.put("records", map_record);
|
|
return map_result;
|
|
}
|
}
|
