| | |
|---|
| | | import com.dy.pipIrrGlobal.pojoSe.SeClient; |
|---|
| | | import com.dy.pipIrrGlobal.voSe.VoClient; |
|---|
| | | import com.dy.pipIrrGlobal.voSe.VoOperate; |
|---|
| | | import com.dy.pipIrrGlobal.voSe.VoStatistics; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.dubbo.common.utils.PojoUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据指定条件获取统计记录 |
|---|
| | | * @param vo 交易汇总查询条件 |
|---|
| | | * @return 交易汇总记录 |
|---|
| | | */ |
|---|
| | | public Map getStatistics(QueryStatistic vo){ |
|---|
| | | // 补齐查询时间 |
|---|
| | | 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 count = 0; |
|---|
| | | Float money = 0f; |
|---|
| | | Map map_sum = Optional.ofNullable(seClientMapper.getStatisticSums(params)).orElse(new HashMap()); |
|---|
| | | if(map_sum.size() > 0) { |
|---|
| | | count = Integer.parseInt(map_sum.get("count").toString()); |
|---|
| | | money = Float.parseFloat(map_sum.get("money").toString()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 获取符合条件的记录数 |
|---|
| | | Long itemTotal = seClientMapper.getStatisticRecordCount(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<VoStatistics> lit = seClientMapper.getStatistics(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("count", count); |
|---|
| | | map_result.put("money", money); |
|---|
| | | map_result.put("records", map_record); |
|---|
| | | |
|---|
| | | return map_result; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据主键获取农户对象 |
|---|
| | | * @param id 农户主键 |
|---|
| | | * @return 农户对象 |
|---|
