package com.dy.pipIrrSell.cardOperate; import com.dy.common.webUtil.BaseResponse; import com.dy.common.webUtil.BaseResponseUtils; import com.dy.pipIrrGlobal.daoSe.SeCardOperateMapper; import com.dy.pipIrrGlobal.daoSe.SeClientCardMapper; import com.dy.pipIrrGlobal.daoSe.SeClientMapper; import com.dy.pipIrrGlobal.pojoSe.SeCardOperate; import com.dy.pipIrrGlobal.pojoSe.SeClientCard; import com.dy.pipIrrSell.cardOperate.dto.DtoRecharge; import com.dy.pipIrrSell.cardOperate.enums.OperateTypeENUM; import com.dy.pipIrrSell.clientCard.ClientCardSv; import com.dy.pipIrrSell.clientCard.LastOperateENUM; import com.dy.pipIrrSell.result.SellResultCode; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.Date; import java.util.HashMap; import java.util.Map; import java.util.Optional; /** * @author ZhuBaoMin * @date 2024-01-18 19:36 * @LastEditTime 2024-01-18 19:36 * @Description */ @Slf4j @Service public class CardOperateSv { @Autowired private SeCardOperateMapper seCardOperateMapper; @Autowired private SeClientCardMapper seClientCardMapper; @Autowired private SeClientMapper seClientMapper; @Autowired private ClientCardSv clientCardSv; /** * 添加开卡记录 * @param po 水卡操作对象 * @return 开卡记录主键 */ public Long activeCard(SeCardOperate po) { seCardOperateMapper.insert(po); return po.getId(); } /** * 根据农户编号获取5级行政区划代码,开卡使用 * @param clientNum 农户编号 * @return 5级行政区划代码 */ public Long getAreaCodeByNum(String clientNum) { return seClientMapper.getAreaCodeByNum(clientNum); } /** * 根据行政区划串模块查询水卡编号,开卡使用 * @param areaCode * @return */ String getCardNumOfMax(String areaCode) { return seClientCardMapper.getCardNumOfMax(areaCode); } /** * 根据农户编号获取农户ID,开卡使用 * @param clientNum * @return */ public Long getClientIdByNum(String clientNum) { return seClientMapper.getClientIdByNum(clientNum); } /** * 添加水卡操作对象,各操作都使用 * @param po 水卡操作对象 * @return 操作记录主键 */ public Long add(SeCardOperate po) { seCardOperateMapper.insert(po); return po.getId(); } /** * 添加充值记录 * 修改农户信息、添加充值记录 * @param po * @return */ public BaseResponse addRecharge(DtoRecharge po){ /** * cardId 水卡编号(依据水卡编号获取) * clientId 农户编号(依据水卡编号获取) * cardNum 水卡编号 * money 卡片余额 * amount 充值金额 * gift 赠送金额 * afterRecharge 充值后余额 * paymentId 支付方式编号 * price 水价 * remarks 备注 * operator 操作人编号 * rechargeTime 充值时间 */ Long cardId = 0L; Long clientId = 0L; String cardNum = po.getCardNum(); Float money = po.getMoney(); Float amount = po.getAmount(); Float gift = po.getGift(); Float afterRecharge = money + amount + gift; Long paymentId = po.getPaymentId(); Float price = po.getPrice(); String remarks = po.getRemarks(); Long operator = po.getOperator(); Date rechargeTime = new Date(); /** * 依据水卡编号获取水卡表主键及农户编号 */ Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); if(map == null || map.size() <= 0) { return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); } cardId = Long.parseLong(map.get("cardId").toString()); clientId = Long.parseLong(map.get("clientId").toString()); /** * 修改农户卡信息: * 补卡时间 * 最后操作类型-2 */ SeClientCard seClientCard = new SeClientCard(); seClientCard.setId(cardId); seClientCard.setMoney(afterRecharge); seClientCard.setRechargedt(rechargeTime); seClientCard.setLastoper(LastOperateENUM.RECHARGE.getCode ()); Integer rec_updateClientCard = Optional.ofNullable(clientCardSv.UpdateClientCard(seClientCard)).orElse(0); if(rec_updateClientCard == 0) { return BaseResponseUtils.buildFail(SellResultCode.RECHARGE_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); } /** * 添加充值记录 */ SeCardOperate seCardOperate = new SeCardOperate(); seCardOperate.setCardId(cardId); seCardOperate.setClientId(clientId); seCardOperate.setMoney(money); seCardOperate.setTradeAmount(amount); seCardOperate.setGift(gift); seCardOperate.setOperateType(OperateTypeENUM.RECHARGE.getCode()); seCardOperate.setPaymentId(paymentId); seCardOperate.setPrice(price); seCardOperate.setRemarks(remarks); seCardOperate.setOperator(operator); seCardOperate.setOperateDt(rechargeTime); seCardOperateMapper.insert(seCardOperate); Long rec = Optional.ofNullable(seCardOperate.getId()).orElse(0L); if(rec == 0) { return BaseResponseUtils.buildFail(SellResultCode.REPLACE_FAIL_WRITE_RECHARGE_ERROR.getMessage()); } return BaseResponseUtils.buildSuccess(true) ; } }