From c568a328a8c273531773710fe814ac429bafc48f Mon Sep 17 00:00:00 2001 From: liurunyu <lry9898@163.com> Date: 星期一, 29 一月 2024 14:09:12 +0800 Subject: [PATCH] Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV --- pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/general/GeneralSv.java | 178 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 178 insertions(+), 0 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/general/GeneralSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/general/GeneralSv.java new file mode 100644 index 0000000..76d9be0 --- /dev/null +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-sell/src/main/java/com/dy/pipIrrSell/general/GeneralSv.java @@ -0,0 +1,178 @@ +package com.dy.pipIrrSell.general; + +import com.alibaba.fastjson2.JSONArray; +import com.alibaba.fastjson2.JSONObject; +import com.dy.common.webUtil.QueryResultVo; +import com.dy.pipIrrGlobal.daoSe.SeAuditsMapper; +import com.dy.pipIrrGlobal.daoSe.SeCardOperateMapper; +import com.dy.pipIrrGlobal.daoSe.SeGeneralMapper; +import com.dy.pipIrrGlobal.pojoSe.SeAudits; +import com.dy.pipIrrGlobal.pojoSe.SeGeneral; +import com.dy.pipIrrGlobal.voSe.VoGeneral; +import com.dy.pipIrrGlobal.voSe.VoTransactionStatistics; +import com.dy.pipIrrSell.general.qo.QoGeneral; +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.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; + + /** + * 鑾峰彇鏈敓鎴愭�昏处鐨勪氦鏄撴棩鏈熷垪琛紙褰撳ぉ鐨勪氦鏄撹褰曚笉鐢熸垚鎬昏处锛� + * @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<>() ; + 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 = 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); + } + + /** + * t娣诲姞鎬昏处瀹℃牳璁板綍 + * @param po + * @return + */ + public Integer addAudits(SeAudits po) { + return seAuditsMapper.insert(po); + } + + /** + * 璐㈠姟瀵硅处瀹℃牳椤碉紝鏀堕摱鍛�+鏃ユ湡鍒嗙粍锛屾帓闄や氦鏄撶被鍨嬪垎缁� + * @param vo + * @return + */ + public Map getToAudit(QoToAudit vo) { + /** + * 鍙栧嚭鎸囧畾鏃ユ湡涓夌鏀粯鏂瑰紡锛堢幇閲戙�佹壂鐮併�佽浆璐︼級瀹炴敹閲戦 + */ + JSONArray array_paymentSums = new JSONArray(); + String tradeDate = vo.getTradeDate(); + Long cashierId = vo.cashierId; + + Float receivedCash = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId, 1L)).orElse(0f); + Float receivedQRCode = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId,2L)).orElse(0f); + Float receivedTransfer = Optional.ofNullable(seGeneralMapper.getPaymentSums(tradeDate, cashierId, 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); + + // 鐢熸垚鏌ヨ鍙傛暟 + Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(vo) ; + + //鑾峰彇绗旀暟鍚堣銆佸疄鏀堕噾棰濆悎璁°�佽禒閫侀噾棰濆悎璁� + Integer totalCount = 0; + Float totalReceived = 0f; + Float totalGift = 0f; + Map map_sum = Optional.ofNullable(seGeneralMapper.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 = seGeneralMapper.getToAuditRecordCount(params); + + List<VoTransactionStatistics> list = seGeneralMapper.getToAudit(params); + Map map_record = new HashMap(); + map_record.put("itemTotal", itemTotal); + map_record.put("pageCurr", vo.pageCurr); + 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("records", map_record); + map_result.put("paymentSums", array_paymentSums); + + return map_result; + } +} -- Gitblit v1.8.0