From e6a9e6f750115579c8cc90d7e6d5bf1eebe79b90 Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期二, 05 十一月 2024 15:26:24 +0800 Subject: [PATCH] 获取农户数据去掉重复记录,微信支付的传参、返回值、接口、数据库表金额都以元为单位 --- pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/virtualCard/VirtualCardSv.java | 106 ++++++++++++++++++++++++++++++++++++++--------------- 1 files changed, 76 insertions(+), 30 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/virtualCard/VirtualCardSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/virtualCard/VirtualCardSv.java index 1b25e36..7cd6de0 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/virtualCard/VirtualCardSv.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/virtualCard/VirtualCardSv.java @@ -4,23 +4,20 @@ import com.dy.common.webUtil.BaseResponseUtils; import com.dy.common.webUtil.QueryResultVo; import com.dy.pipIrrGlobal.daoSe.*; -import com.dy.pipIrrGlobal.pojoSe.SeVcRecharge; -import com.dy.pipIrrGlobal.pojoSe.SeVcRefund; -import com.dy.pipIrrGlobal.pojoSe.SeVcRefundItem; -import com.dy.pipIrrGlobal.pojoSe.SeVirtualCard; +import com.dy.pipIrrGlobal.pojoSe.*; import com.dy.pipIrrGlobal.voSe.VoOrders; +import com.dy.pipIrrGlobal.voSe.VoRechargeProfile; import com.dy.pipIrrGlobal.voSe.VoVcRecharge; import com.dy.pipIrrGlobal.voSe.VoVirtualCard; - -import com.dy.pipIrrSell.result.SellResultCode; -import com.dy.pipIrrSell.virtualCard.dto.DtoVcRecharge; -import com.dy.pipIrrSell.virtualCard.dto.DtoVirtualCard; -import com.dy.pipIrrSell.virtualCard.enums.LastOperateENUM; -import com.dy.pipIrrSell.virtualCard.enums.OrderStateENUM; - +import com.dy.pipIrrWechat.result.WechatResultCode; +import com.dy.pipIrrWechat.virtualCard.dto.DtoVirtualCard; +import com.dy.pipIrrWechat.virtualCard.enums.LastOperateENUM; +import com.dy.pipIrrWechat.virtualCard.enums.OrderStateENUM; +import com.dy.pipIrrWechat.virtualCard.qo.QoVcRecharge; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.common.utils.PojoUtils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -30,8 +27,8 @@ /** * @author ZhuBaoMin - * @date 2024-07-11 15:49 - * @LastEditTime 2024-07-11 15:49 + * @date 2024-07-15 9:39 + * @LastEditTime 2024-07-15 9:39 * @Description */ @@ -53,6 +50,15 @@ @Autowired private SeClientMapper seClientMapper; + @Autowired + private SeVcOperateMapper seVcOperateMapper; + + @Autowired + private SeRechargeProfileMapper seRechargeProfileMapper; + + @Value("${vc.alarmValue}") + private Integer alarmValue; + /** * 鏍规嵁鍐滄埛ID鑾峰彇5绾ц鏀垮尯鍒掍唬鐮侊紝娉ㄥ唽铏氭嫙鍗′娇鐢� * @param clientId 鍐滄埛ID @@ -67,7 +73,7 @@ * @return */ public List<VoVirtualCard> getVCs(Long clientId) { - return seVirtualCardMapper.getVCs(clientId); + return seVirtualCardMapper.getVCs(alarmValue, clientId); } /** @@ -87,6 +93,26 @@ public Long insertVirtualCard(SeVirtualCard po) { seVirtualCardMapper.insert(po); return po.getId(); + } + + /** + * 鏍规嵁鍐滄埛ID鍙婅櫄鎷熷崱ID鑾峰彇姝e父鐘舵�佺殑铏氭嫙鍗″璞� + * @param clientId + * @param vcId + * @return + */ + public SeVirtualCard getVcByClientIdAndVcId (Long clientId, Long vcId) { + return seVirtualCardMapper.getVcByClientIdAndVcId(clientId, vcId); + } + + /** + * 鏍规嵁铏氭嫙鍗D娉ㄩ攢铏氭嫙鍗� + * @param clientId + * @param vcId + * @return + */ + public Integer cancelVc(Long clientId, Long vcId) { + return seVirtualCardMapper.cancelVc(clientId, vcId); } /** @@ -130,18 +156,20 @@ * 娣诲姞铏氭嫙鍗″厖鍊艰褰� * JSAPI涓嬪崟鍚庣敓鎴愰儴鍒嗗厖鍊艰褰� * @param po - * @return + * @return -1锛氳櫄鎷熷崱涓嶅瓨鍦紝0锛氭坊鍔犲厖鍊艰褰曞け璐� */ - public BaseResponse<Boolean> insertVCRecharge(DtoVirtualCard po) { + //public BaseResponse<Boolean> insertVCRecharge(DtoVirtualCard po) { + public Long insertVCRecharge(DtoVirtualCard po) { String orderNumber = po.getOrderNumber(); Long virtualId = po.getVirtualId(); Long clientId = po.getClientId(); - Integer rechargeAmount = po.getRechargeAmount(); + Double rechargeAmount = po.getRechargeAmount(); // 楠岃瘉璇ヨ櫄鎷熷崱璐︽埛鏄惁瀛樺湪骞跺彇鍑哄綋鍓嶈处鎴蜂綑棰� SeVirtualCard seVirtualCard = seVirtualCardMapper.selectByPrimaryKey(virtualId); + if(seVirtualCard == null) { - return BaseResponseUtils.buildFail(SellResultCode.NO_ACCOUNT.getMessage()); + return -1L; } Double money = seVirtualCard.getMoney(); @@ -154,11 +182,12 @@ seVcRecharge.setRechargeAmount(rechargeAmount); seVcRecharge.setOrderTime(new Date()); seVcRecharge.setOrderState(OrderStateENUM.NON_PAYMENT.getCode()); - Integer rec = seVcRechargeMapper.insert(seVcRecharge); - if(rec == null) { - return BaseResponseUtils.buildFail(SellResultCode.RECHARGE_FAIL.getMessage()); + seVcRechargeMapper.insert(seVcRecharge); + Long rechargeId = seVcRecharge.getId(); + if(rechargeId == null) { + return 0L; } - return BaseResponseUtils.buildSuccess(true) ; + return rechargeId; } /** @@ -182,12 +211,12 @@ public BaseResponse<Boolean> updateVCRecharge(String orderNumber, Date rechargeTime) { SeVcRecharge seVcRecharge = seVcRechargeMapper.getVCRechargeByorderNumber(orderNumber); if(seVcRecharge == null) { - return BaseResponseUtils.buildFail(SellResultCode.RECHARGE_NOT_EXIST.getMessage()); + return BaseResponseUtils.buildFail(WechatResultCode.RECHARGE_NOT_EXIST.getMessage()); } Long virtualId = seVcRecharge.getVcId(); Double money = seVcRecharge.getMoney(); - Integer rechargeAmount = seVcRecharge.getRechargeAmount(); + Double rechargeAmount = seVcRecharge.getRechargeAmount(); Double afterRrecharge = money + rechargeAmount; seVcRecharge.setAfterRecharge(afterRrecharge); @@ -195,19 +224,19 @@ seVcRecharge.setOrderState(OrderStateENUM.PAID.getCode()); Integer rec = seVcRechargeMapper.updateByPrimaryKeySelective(seVcRecharge); if(rec == null) { - return BaseResponseUtils.buildFail(SellResultCode.RECHARGE_FAIL.getMessage()); + return BaseResponseUtils.buildFail(WechatResultCode.RECHARGE_FAIL.getMessage()); } SeVirtualCard seVirtualCard = seVirtualCardMapper.selectByPrimaryKey(virtualId); if(seVirtualCard == null) { - return BaseResponseUtils.buildFail(SellResultCode.VIRTUAL_CARD_NOT_EXIST.getMessage()); + return BaseResponseUtils.buildFail(WechatResultCode.VIRTUAL_CARD_NOT_EXIST.getMessage()); } seVirtualCard.setMoney(afterRrecharge); seVirtualCard.setLastOperate(LastOperateENUM.RECHARGE.getCode()); seVirtualCard.setLastOperateTime(new Date()); Integer rec2 = seVirtualCardMapper.updateByPrimaryKeySelective(seVirtualCard); if(rec2 == null) { - return BaseResponseUtils.buildFail(SellResultCode.RECHARGE_FAIL.getMessage()); + return BaseResponseUtils.buildFail(WechatResultCode.RECHARGE_FAIL.getMessage()); } return BaseResponseUtils.buildSuccess(true) ; } @@ -310,7 +339,7 @@ * @param orderNumber * @return */ - public Integer getRechargeAmountByOrderNumber(String orderNumber) { + public Double getRechargeAmountByOrderNumber(String orderNumber) { return seVcRechargeMapper.getRechargeAmountByOrderNumber(orderNumber); } @@ -338,7 +367,7 @@ * @param dtoVcRecharge * @return */ - public QueryResultVo<List<VoVcRecharge>> getVcRechargeRecords(DtoVcRecharge dtoVcRecharge){ + public QueryResultVo<List<VoVcRecharge>> getVcRechargeRecords(QoVcRecharge dtoVcRecharge){ Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(dtoVcRecharge); Long itemTotal = seVirtualCardMapper.getRechargeRecordCount(params); @@ -351,5 +380,22 @@ return rsVo; } -} + /** + * 娣诲姞铏氭嫙鍗℃搷浣滆褰� + * @param po + * @return + */ + public Long insertVcOperate(SeVcOperate po) { + seVcOperateMapper.insert(po); + return po.getId(); + } + + /** + * 鑾峰彇铏氭嫙鍗″父鐢ㄥ厖鍊奸噾棰濋厤缃� + * @return + */ + public List<VoRechargeProfile> gerRechargeProfiles() { + return seRechargeProfileMapper.gerRechargeProfiles(); + } +} \ No newline at end of file -- Gitblit v1.8.0