From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 16 十月 2024 14:28:37 +0800 Subject: [PATCH] 将CMQ替换为rabbitmq --- fanli/src/main/java/com/yeshi/fanli/service/inter/goods/ScanHistoryV2Service.java | 248 ++++++++++++++++++++++++++++++------------------- 1 files changed, 150 insertions(+), 98 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/inter/goods/ScanHistoryV2Service.java b/fanli/src/main/java/com/yeshi/fanli/service/inter/goods/ScanHistoryV2Service.java index 99fa359..e8d447e 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/inter/goods/ScanHistoryV2Service.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/inter/goods/ScanHistoryV2Service.java @@ -1,98 +1,150 @@ -package com.yeshi.fanli.service.inter.goods; - -import java.util.List; - -import com.yeshi.fanli.dto.pdd.PDDGoodsDetail; -import com.yeshi.fanli.entity.goods.ScanHistoryV2; -import com.yeshi.fanli.entity.jd.JDGoods; -import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; -import com.yeshi.fanli.exception.goods.CommonGoodsException; -import com.yeshi.fanli.exception.goods.ScanHistoryException; - -public interface ScanHistoryV2Service { - /** - * 娣诲姞娴忚璁板綍 - * - * @param uid - * @param device - * @param goods - */ - public void addScanHistory(Long uid, String device, TaoBaoGoodsBrief goods) - throws CommonGoodsException, ScanHistoryException; - - /** - * 娣诲姞娴忚璁板綍 - * - * @param history - * @throws CommonGoodsException - * @throws ScanHistoryException - */ - public void addScanHistory(ScanHistoryV2 history) throws CommonGoodsException, ScanHistoryException; - - /** - * 鏍规嵁璁惧鎴栬�呯敤鎴稩D鑾峰彇娴忚璁板綍 - * - * @param uid - * @param device - * @param page - * @param pageSize - * @return - */ - public List<ScanHistoryV2> getScanHistoryByDeviceOrUid(Long uid, String device, int page, int pageSize, - Integer source, boolean notBackSuVip); - - /** - * 鏍规嵁璁惧鎴栬�呯敤鎴稩D鑾峰彇娴忚璁板綍鏁伴噺 - * - * @param uid - * @param device - * @return - */ - public long getCountByDeviceOrUid(Long uid, String device, Integer source, boolean notBackSuVip); - - /** - * 鏍规嵁鐢ㄦ埛鎴栬�呰澶囧垹闄ゆ祻瑙堣褰� - * - * @param uid - * @param device - */ - public void deleteByDeviceOrUid(Long uid, String device); - - /** - * 鏍规嵁鐢ㄦ埛鎴栬�呰澶囧拰娣樺疂鍟嗗搧ID鍒犻櫎娴忚璁板綍 - * - * @param uid - * @param device - * @param auctionId - */ - public void deleteByAuctionIdAndDeviceOrUid(Long uid, String device, Long auctionId); - - /** - * 娣诲姞浜笢鍟嗗搧瓒宠抗璁板綍 - * @param uid - * @param device - * @param goods - * @throws CommonGoodsException - * @throws ScanHistoryException - */ - public void addJDScanHistory(Long uid, String device, JDGoods goods) throws CommonGoodsException, ScanHistoryException; - - /** - * 娣诲姞鎷煎澶氬晢鍝佽冻杩硅褰� - * @param uid - * @param device - * @param pddGoods - * @throws CommonGoodsException - * @throws ScanHistoryException - */ - public void addPDDScanHistory(Long uid, String device, PDDGoodsDetail pddGoods) - throws CommonGoodsException, ScanHistoryException; - - /** - * 鏍规嵁绠�鐗堝晢鍝両D鍒犻櫎 - * @param uid - * @param device - * @param commonId - */ - public void deleteByCommonIdAndDeviceOrUid(Long uid, String device, Long commonId); -} +package com.yeshi.fanli.service.inter.goods; + +import java.util.List; + +import com.yeshi.fanli.dto.pdd.PDDGoodsDetail; +import com.yeshi.fanli.dto.suning.SuningGoodsInfo; +import com.yeshi.fanli.dto.vip.goods.VIPGoodsInfo; +import com.yeshi.fanli.entity.goods.ScanHistoryV2; +import com.yeshi.fanli.entity.jd.JDGoods; +import com.yeshi.fanli.util.goods.douyin.vo.DYGoodsDetail; +import com.yeshi.goods.facade.entity.taobao.TaoBaoGoodsBrief; +import com.yeshi.fanli.exception.goods.CommonGoodsException; +import com.yeshi.fanli.exception.goods.ScanHistoryException; + +public interface ScanHistoryV2Service { + /** + * 娣诲姞娴忚璁板綍 + * + * @param uid + * @param device + * @param goods + */ + public void addScanHistory(Long uid, String device, TaoBaoGoodsBrief goods) + throws CommonGoodsException, ScanHistoryException; + + /** + * 娣诲姞娴忚璁板綍 + * + * @param history + * @throws CommonGoodsException + * @throws ScanHistoryException + */ + public void addScanHistory(ScanHistoryV2 history) throws CommonGoodsException, ScanHistoryException; + + /** + * 鏍规嵁璁惧鎴栬�呯敤鎴稩D鑾峰彇娴忚璁板綍 + * + * @param uid + * @param device + * @param page + * @param pageSize + * @return + */ + public List<ScanHistoryV2> getScanHistoryByDeviceOrUid(Long uid, String device, int page, int pageSize, + Integer source, boolean notBackSuVip); + + /** + * 鏍规嵁璁惧鎴栬�呯敤鎴稩D鑾峰彇娴忚璁板綍鏁伴噺 + * + * @param uid + * @param device + * @return + */ + public long getCountByDeviceOrUid(Long uid, String device, Integer source, boolean notBackSuVip); + + /** + * 鏍规嵁鐢ㄦ埛鎴栬�呰澶囧垹闄ゆ祻瑙堣褰� + * + * @param uid + * @param device + */ + public void deleteByDeviceOrUid(Long uid, String device); + + /** + * 鏍规嵁鐢ㄦ埛鎴栬�呰澶囧拰娣樺疂鍟嗗搧ID鍒犻櫎娴忚璁板綍 + * + * @param uid + * @param device + * @param auctionId + */ + public void deleteByAuctionIdAndDeviceOrUid(Long uid, String device, String auctionId); + + /** + * 娣诲姞浜笢鍟嗗搧瓒宠抗璁板綍 + * @param uid + * @param device + * @param goods + * @throws CommonGoodsException + * @throws ScanHistoryException + */ + public void addJDScanHistory(Long uid, String device, JDGoods goods) throws CommonGoodsException, ScanHistoryException; + + /** + * 娣诲姞鎷煎澶氬晢鍝佽冻杩硅褰� + * @param uid + * @param device + * @param pddGoods + * @throws CommonGoodsException + * @throws ScanHistoryException + */ + public void addPDDScanHistory(Long uid, String device, PDDGoodsDetail pddGoods) + throws CommonGoodsException, ScanHistoryException; + + + /** + * 鍞搧浼氭祻瑙堣褰� + * @Title: addVIPScanHistory + * @Description: + * @param uid + * @param device + * @param pddGoods + * @throws CommonGoodsException + * @throws ScanHistoryException + * void 杩斿洖绫诲瀷 + * @throws + */ + public void addVIPScanHistory(Long uid, String device, VIPGoodsInfo pddGoods) + throws CommonGoodsException, ScanHistoryException; + + + /** + * 鑻忓畞娴忚璁板綍 + * @Title: addSuningScanHistory + * @Description: + * @param uid + * @param device + * @param suningGoods + * @throws CommonGoodsException + * @throws ScanHistoryException + * void 杩斿洖绫诲瀷 + * @throws + */ + public void addSuningScanHistory(Long uid, String device, SuningGoodsInfo suningGoods) + throws CommonGoodsException, ScanHistoryException; + + + /** + * 鎶栭煶娴忚璁板綍 + * @Title: addSuningScanHistory + * @Description: + * @param uid + * @param device + * @param dyGoods + * @throws CommonGoodsException + * @throws ScanHistoryException + * void 杩斿洖绫诲瀷 + * @throws + */ + public void addDYScanHistory(Long uid, String device, DYGoodsDetail dyGoods) + throws CommonGoodsException, ScanHistoryException; + + + /** + * 鏍规嵁绠�鐗堝晢鍝両D鍒犻櫎 + * @param uid + * @param device + * @param commonId + */ + public void deleteByCommonIdAndDeviceOrUid(Long uid, String device, Long commonId); +} -- Gitblit v1.8.0