From 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 20 十一月 2019 14:53:34 +0800 Subject: [PATCH] RocketMQ的消息整改 --- fanli/src/main/java/com/yeshi/fanli/service/inter/order/LostOrderService.java | 62 ++++++++++++++++++++++++++++--- 1 files changed, 56 insertions(+), 6 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/inter/order/LostOrderService.java b/fanli/src/main/java/com/yeshi/fanli/service/inter/order/LostOrderService.java index bd8d90d..f641c17 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/inter/order/LostOrderService.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/inter/order/LostOrderService.java @@ -1,23 +1,24 @@ package com.yeshi.fanli.service.inter.order; import java.util.List; +import java.util.Map; import java.util.concurrent.locks.ReentrantReadWriteLock; +import com.yeshi.fanli.dto.ChartTDO; import com.yeshi.fanli.entity.bus.user.LostOrder; public interface LostOrderService { static final ReentrantReadWriteLock lostOrderLock = new ReentrantReadWriteLock(true); + + + void saveLostOrder(LostOrder lostOrder); int addLostOrder(LostOrder lostOrder); void pass(LostOrder lostOrder); void reject(LostOrder lostOrder); - - List<LostOrder> findLostOrderList(String key, int page); - - int getCount(String key); LostOrder getOne(long id); @@ -44,14 +45,14 @@ * * @param orderId */ - void processSuceess(String orderId); + void processSuceess(String orderId,int orderType); /** * 璁㈠崟澶勭悊澶辫触 * * @param orderId */ - void processFail(String orderId); + void processFail(String orderId,int orderType); /** * 璁㈠崟澶勭悊澶辫触鎵归噺澶勭悊 @@ -72,4 +73,53 @@ */ void deleteLostOrderByUid(long uid); + /** + * 缁熻鐢ㄦ埛鐢宠瘔娆℃暟 + * + * @param uid + * @return + */ + public Map<String, Object> countByUid(long uid); + + /** + * 鍚庣鏌ヨ + * + * @param start + * @param count + * @param key + * @param state + * @param handleType + * @return + */ + public List<LostOrder> listQuery(long start, int count, String key, Integer state, Integer handleType, Integer type); + + public long countQuery(String key, Integer state, Integer handleType, Integer type); + + /** + * 鏈湀鐢宠瘔璁㈠崟鏁� 缁熻 + * + * @param dateType + * @param resultCode + * 锛堟湭澶勭悊锛� 鎴愬姛 澶辫触锛� + * @param year + * @param startTime + * @param endTime + * @return + * @throws Exception + */ + public List<ChartTDO> countLostNum(Integer dateType, Integer resultCode, String year, String startTime, + String endTime) throws Exception; + + public List<ChartTDO> countAppealMoney(Integer dateType, String year, String startTime, String endTime) + throws Exception; + + /** + * 鏍规嵁鐘舵�佷笌澶勭悊缁撴灉杩囧幓鍊� + * + * @param state + * @param resultCode + * @return + */ + public List<LostOrder> listByStateAndResultCode(int state, int resultCode, int page, int pageSize); + } -- Gitblit v1.8.0