元谋二期后端软件系统
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
wuzeyu
2024-02-27 a60332d51fec0ae9f1afecc8c7a018c77e4ac101 
 pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/cardOperate/CardOperateSv.java


@@ -1,5 +1,6 @@


package com.dy.pipIrrSell.cardOperate;




import com.alibaba.fastjson2.JSON;


import com.alibaba.fastjson2.JSONArray;


import com.alibaba.fastjson2.JSONObject;


import com.dy.common.webUtil.BaseResponse;


@@ -8,6 +9,7 @@


import com.dy.pipIrrGlobal.daoSe.SeCardOperateMapper;


import com.dy.pipIrrGlobal.daoSe.SeClientCardMapper;


import com.dy.pipIrrGlobal.daoSe.SeClientMapper;


import com.dy.pipIrrGlobal.daoSe.SeGeneralMapper;


import com.dy.pipIrrGlobal.pojoSe.SeCardOperate;


import com.dy.pipIrrGlobal.pojoSe.SeClientCard;


import com.dy.pipIrrGlobal.voSe.*;


@@ -22,8 +24,7 @@


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;




import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.text.DecimalFormat;


import java.util.*;




/**


@@ -47,6 +48,9 @@




    @Autowired


    private ClientCardSv clientCardSv;




    @Autowired


    private SeGeneralMapper seGeneralMapper;






    /**


@@ -219,24 +223,13 @@


        Long itemTotal = seCardOperateMapper.getRecordCount(params);




        QueryResultVo<List<VoRecharge>> rsVo = new QueryResultVo<>() ;


        Integer pageCurr = 0;


        Integer pageSize = 10000;


        rsVo.pageCurr = 1;


        rsVo.pageSize = 10000;


        if(queryVo.pageSize != null && queryVo.pageCurr != null) {


            rsVo.pageSize = queryVo.pageSize ;


            rsVo.pageCurr = queryVo.pageCurr;


            pageSize = queryVo.pageSize ;


            pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString());


        }


        params.put("pageCurr", pageCurr);


        params.put("pageSize", pageSize);




        rsVo.calculateAndSet(itemTotal, params);


        rsVo.obj = seCardOperateMapper.getRecharges(params);


        return rsVo ;


    }






    /**


     * 根据指定条件获取交易记录


@@ -244,6 +237,7 @@


     * @return


     */


    public Map getTransactions(QoTransaction vo){


        DecimalFormat df = new DecimalFormat("0.00");


        // 补齐查询时间


        String operateTimeStart = vo.operateTimeStart;


        String operateTimeStop = vo.operateTimeStop;


@@ -259,132 +253,34 @@


        // 生成查询参数


        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(vo) ;




        // 获取汇总的购水金额、购卡金额


        Float waterCost = 0f;


        Float cardCost = 0f;


        Map map_sum = Optional.ofNullable(seCardOperateMapper.getTransactionSums(params)).orElse(new HashMap());


        if(map_sum.size() > 0) {


            waterCost = Float.parseFloat(map_sum.get("waterCost").toString());


            cardCost = Float.parseFloat(map_sum.get("cardCost").toString());


        // 获取符合条件的记录数


        Long itemTotal = Optional.ofNullable(seCardOperateMapper.getTransactionRecordCount(params)).orElse(0L);




        List<VoTradeDetails> list = seCardOperateMapper.getTransactions(params);


        if(list.size() == 0) {


            return new HashMap();


        }




        // 获取符合条件的记录数


        Long itemTotal = seCardOperateMapper.getTransactionRecordCount(params);


        // 遍历交易明细记录，汇总购水金额、购卡金额


        Double totalWaterCost = 0.0;


        Double totalCardCost = 0.0;


        JSONArray array= JSONArray.parseArray(JSON.toJSONString(list));


        for(int i = 0; i < array.size(); i++) {


            JSONObject job = array.getJSONObject(i);


            Double waterCost = Optional.ofNullable(job.getDouble("waterCost")).orElse(0.0);


            Double cardCost = Optional.ofNullable(job.getDouble("cardCost")).orElse(0.0);


            totalWaterCost = totalWaterCost + waterCost;


            totalCardCost = totalCardCost + cardCost;


        }




        Integer pageSize = vo.getPageSize();


        // 计算总页数


        Integer pageTotal ;


        pageTotal = (int)Math.ceil((itemTotal==null?0.0D:itemTotal.doubleValue())/pageSize);




        // 根据当前页码及每页数量计算偏移量


        Integer pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString());


        params.put("pageCurr", pageCurr);




        List<VoTransaction> lit = seCardOperateMapper.getTransactions(params);


        Map map_record = new HashMap();


        map_record.put("itemTotal", itemTotal);


        map_record.put("pageCurr", vo.pageCurr);


        map_record.put("pageSize", pageSize);


        map_record.put("pageTotal", pageTotal);


        map_record.put("list", lit);




        Map map_result = new HashMap();


        map_result.put("waterCost", waterCost);


        map_result.put("cardCost", cardCost);


        map_result.put("records", map_record);




        return map_result;


    }




    /**


     * 获取交易统计记录


     * 1.交易统计记录


     * 2.笔数合计、实收金额合计、赠送金额合计


     * 3.每一天、各种支付方式实收金额合计


     * @param vo


     * @return


     */


    public Map getTransactionStatistics(QoTransactionStatistics vo) throws ParseException {


        /**


         * 遍历查询日期，取出每天三种支付方式（现金、扫码、转账）实收金额


         * 每天一个对象


         * 对象组成JSONArray添加到返回对象中


         */


        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");


        Date startDate = dateFormat.parse(vo.getOperateTimeStart());


        Date stopDate = dateFormat.parse(vo.getOperateTimeStop());


        Calendar calendar = Calendar.getInstance();


        calendar.setTime(startDate);




        JSONArray array_paymentSums = new JSONArray();


        while (calendar.getTime().before(stopDate) || calendar.getTime().equals(stopDate)) {


            String tradeDate = dateFormat.format(calendar.getTime()) ;


            Float receivedCash = Optional.ofNullable(seCardOperateMapper.getPaymentSums(tradeDate ,1L)).orElse(0f);


            Float receivedQRCode = Optional.ofNullable(seCardOperateMapper.getPaymentSums(tradeDate,2L)).orElse(0f);


            Float receivedTransfer = Optional.ofNullable(seCardOperateMapper.getPaymentSums(tradeDate, 3L)).orElse(0f);


            JSONObject job = new JSONObject();


            job.put("tradeDate", tradeDate);


            job.put("receivedCash", receivedCash);


            job.put("receivedQRCode", receivedQRCode);


            job.put("receivedTransfer", receivedTransfer);




            array_paymentSums.add(job);


            calendar.add(Calendar.DAY_OF_MONTH, 1);


        }






        // 补齐查询时间


        String operateTimeStart = vo.operateTimeStart;


        String operateTimeStop = vo.operateTimeStop;


        if(operateTimeStart != null) {


            operateTimeStart = operateTimeStart + " 00:00:00";


            vo.setOperateTimeStart(operateTimeStart);


        }


        if(operateTimeStop != null) {


            operateTimeStop = operateTimeStop + " 23:59:59";


            vo.setOperateTimeStop(operateTimeStop);


        }




        // 生成查询参数


        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(vo) ;




        //获取笔数合计、实收金额合计、赠送金额合计


        Integer totalCount = 0;


        Float totalReceived = 0f;


        Float totalGift = 0f;


        Map map_sum = Optional.ofNullable(seCardOperateMapper.getTransactionStatisticsSums(params)).orElse(new HashMap());


        if(map_sum.size() > 0) {


            totalCount = Integer.parseInt(map_sum.get("totalCount").toString());


            totalReceived = Float.parseFloat(map_sum.get("totalReceived").toString());


            totalGift = Float.parseFloat(map_sum.get("totalGift").toString());


        }




        // 获取符合条件的记录数


        Long itemTotal = seCardOperateMapper.getTransactionStatisticsRecordCount(params);




        Integer pageSize = vo.getPageSize();


        // 计算总页数


        Integer pageTotal ;


        pageTotal = (int)Math.ceil((itemTotal==null?0.0D:itemTotal.doubleValue())/pageSize);




        // 根据当前页码及每页数量计算偏移量


        Integer pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString());


        params.put("pageCurr", pageCurr);




        List<VoTransactionStatistics> list = seCardOperateMapper.getTransactionStatistics(params);


        Map map_record = new HashMap();


        map_record.put("itemTotal", itemTotal);


        map_record.put("pageCurr", vo.pageCurr);


        map_record.put("pageSize", pageSize);


        map_record.put("pageTotal", pageTotal);


        map_record.put("list", list);




        Map map_result = new HashMap();


        map_result.put("totalCount", totalCount);


        map_result.put("totalReceived", totalReceived);


        map_result.put("totalGift", totalGift);


        map_result.put("waterCost", df.format(totalWaterCost));


        map_result.put("cardCost", df.format(totalCardCost));


        map_result.put("records", map_record);


        map_result.put("paymentSums", array_paymentSums);




        return map_result;


    }


@@ -394,7 +290,7 @@


     * @param queryVo


     * @return


     */


    public QueryResultVo<List<VoActiveCardNew>> getActiveCards(QoActiveCard queryVo) {


    public QueryResultVo<List<VoActiveCard>> getActiveCards(QoActiveCard queryVo) {


        //完善查询充值记录的起止时间


        String activeTimeStart = queryVo.activeTimeStart;


        String activeTimeStop = queryVo.activeTimeStop;


@@ -411,19 +307,10 @@




        Long itemTotal = seCardOperateMapper.getActiveCardRecordCount(params);




        QueryResultVo<List<VoActiveCardNew>> rsVo = new QueryResultVo<>() ;


        Integer pageCurr = 0;


        Integer pageSize = 10000;


        rsVo.pageCurr = 1;


        rsVo.pageSize = 10000;


        if(queryVo.pageSize != null && queryVo.pageCurr != null) {


        QueryResultVo<List<VoActiveCard>> rsVo = new QueryResultVo<>() ;




            rsVo.pageSize = queryVo.pageSize ;


            rsVo.pageCurr = queryVo.pageCurr;


            pageSize = queryVo.pageSize ;


            pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString());


        }


        params.put("pageCurr", pageCurr);


        params.put("pageSize", pageSize);




        rsVo.calculateAndSet(itemTotal, params);


        rsVo.obj = seCardOperateMapper.getActiveCards(params);


@@ -453,21 +340,80 @@


        Long itemTotal = seCardOperateMapper.getReissueCardRecordCount(params);




        QueryResultVo<List<VoReissueCard>> rsVo = new QueryResultVo<>() ;


        Integer pageCurr = 0;


        Integer pageSize = 10000;


        rsVo.pageCurr = 1;


        rsVo.pageSize = 10000;


        if(queryVo.pageSize != null && queryVo.pageCurr != null) {




            rsVo.pageSize = queryVo.pageSize ;


            rsVo.pageCurr = queryVo.pageCurr;


            pageSize = queryVo.pageSize ;


            pageCurr = (Integer.parseInt(params.get("pageCurr").toString()) - 1) * Integer.parseInt(params.get("pageSize").toString());


        }


        params.put("pageCurr", pageCurr);


        params.put("pageSize", pageSize);




        rsVo.calculateAndSet(itemTotal, params);


        rsVo.obj = seCardOperateMapper.getReissueCards(params);


        return rsVo ;


    }




    /**


     * 根据指定条件获取IC卡注销记录


     * @param queryVo


     * @return


     */


    public QueryResultVo<List<VoOperate>> getCommonOperations(QoCommonOperate queryVo) {


        //完善查询充值记录的起止时间


        String timeStart = queryVo.getTimeStart();


        String timeStop = queryVo.getTimeStop();


        if(timeStart != null) {


            timeStart = timeStart + " 00:00:00";


            queryVo.setTimeStart(timeStart);


        }


        if(timeStop != null) {


            timeStop = timeStop + " 23:59:59";


            queryVo.setTimeStop(timeStop);


        }




        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);




        Long itemTotal = Optional.ofNullable(seCardOperateMapper.getCommonOperationRecordCount(params)).orElse(0L);




        QueryResultVo<List<VoOperate>> rsVo = new QueryResultVo<>() ;




        rsVo.pageSize = queryVo.pageSize ;


        rsVo.pageCurr = queryVo.pageCurr ;




        rsVo.calculateAndSet(itemTotal, params);


        rsVo.obj = seCardOperateMapper.getCommonOperations(params);


        return rsVo ;


    }




    /**


     * 根据指定条件获取收据列表


     * @param queryVo


     * @return


     */


    public Map getReceipts(QoReceipt queryVo) {


        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryVo);




        DecimalFormat df = new DecimalFormat("#.00");


        Double totalAmount = Optional.ofNullable(seCardOperateMapper.getTotalAmount(params)).orElse(0.0);




        Long itemTotal = seCardOperateMapper.getReceiptsRecordCount(params);




        QueryResultVo<List<VoReceipt>> rsVo = new QueryResultVo<>() ;


        rsVo.pageSize = queryVo.pageSize ;


        rsVo.pageCurr = queryVo.pageCurr ;




        rsVo.calculateAndSet(itemTotal, params);


        //rsVo.obj = seCardOperateMapper.getReceipts(params);


        //return rsVo ;




        List<VoReceipt> list = seCardOperateMapper.getReceipts(params);


        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("totalAmount", df.format(totalAmount));


        map_result.put("records", map_record);




        return map_result;


    }


}