|  |  |  | 
|---|
|  |  |  | package com.dy.pipIrrSell.cardOperate; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.alibaba.fastjson2.JSON; | 
|---|
|  |  |  | import com.alibaba.fastjson2.JSONObject; | 
|---|
|  |  |  | import com.dy.common.aop.SsoAop; | 
|---|
|  |  |  | import com.dy.common.webUtil.BaseResponse; | 
|---|
|  |  |  | import com.dy.common.webUtil.BaseResponseUtils; | 
|---|
|  |  |  | import com.dy.common.webUtil.QueryResultVo; | 
|---|
|  |  |  | import com.dy.common.webUtil.ResultCodeMsg; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoBa.BaClient; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoSe.SeCardOperate; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoSe.SeClientCard; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.pojoSe.SeManagerCard; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.util.AmountToChinese; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.util.Constant; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoActiveCard; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoActiveCardNew; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoRecharge; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoReissueCard; | 
|---|
|  |  |  | import com.dy.pipIrrSell.cardOperate.converter.RechargeDtoMapper; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voRm.VoExpend; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.*; | 
|---|
|  |  |  | import com.dy.pipIrrSell.cardOperate.dto.*; | 
|---|
|  |  |  | import com.dy.pipIrrSell.cardOperate.enums.OperateTypeENUM; | 
|---|
|  |  |  | import com.dy.pipIrrSell.cardOperate.qo.*; | 
|---|
|  |  |  | 
|---|
|  |  |  | import jakarta.validation.Valid; | 
|---|
|  |  |  | import lombok.RequiredArgsConstructor; | 
|---|
|  |  |  | import lombok.extern.slf4j.Slf4j; | 
|---|
|  |  |  | import org.springframework.beans.factory.annotation.Value; | 
|---|
|  |  |  | import org.springframework.http.MediaType; | 
|---|
|  |  |  | import org.springframework.transaction.annotation.Transactional; | 
|---|
|  |  |  | import org.springframework.validation.BindingResult; | 
|---|
|  |  |  | import org.springframework.web.bind.annotation.*; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import java.math.BigDecimal; | 
|---|
|  |  |  | import java.time.format.DateTimeFormatter; | 
|---|
|  |  |  | import java.util.*; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | private final CardOperateSv cardOperateSv; | 
|---|
|  |  |  | private final ClientCardSv clientCardSv; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Value("${project.divisionCode}") | 
|---|
|  |  |  | private String divisionCode; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Value("${project.projectNo}") | 
|---|
|  |  |  | private Integer projectNo; | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 开卡 | 
|---|
|  |  |  | * @param po 开卡传入对象 | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return 水卡编号 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "开卡", description = "新开农户卡") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "active", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_active(@RequestBody @Valid DtoActiveCard po, BindingResult bindingResult){ | 
|---|
|  |  |  | public BaseResponse<Boolean> add_active(@RequestBody @Valid ActiveCard po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 依据水卡地址判断该卡是否可以开卡,未开过卡或不是正常状态、挂失状态的可开卡 | 
|---|
|  |  |  | if(!cardOperateSv.canActiveCard(po.getCardAddr())) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.ACTIVE_FAIL_CARD_ESIST.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Long clientId = po.getClientId(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 获取5级行政区划串areaCode | 
|---|
|  |  |  | String areaCode = String.valueOf(cardOperateSv.getAreaCodeByNum(po.getClientNum())); | 
|---|
|  |  |  | Long areaCodeL = cardOperateSv.getAreaCodeById(clientId); | 
|---|
|  |  |  | if(areaCodeL == null) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.AREA_CODE_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | String areaCode = String.valueOf(areaCodeL); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据行政区划串(areaCode)在水卡表中针对水卡编号(cardNum)进行模糊查询 | 
|---|
|  |  |  | * 如果4位顺序号已经达到最大值,提示用户联系系统管理员 | 
|---|
|  |  |  | * 如果4位顺序号未达到最大值,则加1 | 
|---|
|  |  |  | * 如果顺序号已经达到最大值,提示用户联系系统管理员 | 
|---|
|  |  |  | * 如果顺序号未达到最大值,则加1 | 
|---|
|  |  |  | * cardNum为新的卡号 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | String cardNum = Optional.ofNullable(cardOperateSv.getCardNumOfMax(areaCode)).orElse(""); | 
|---|
|  |  |  | if(cardNum != null && cardNum.trim().length() > 0) { | 
|---|
|  |  |  | Integer number = Integer.parseInt(cardNum.substring(12)); | 
|---|
|  |  |  | number = number + 1; | 
|---|
|  |  |  | if(number > 9999) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_OVERRUN.getMessage()); | 
|---|
|  |  |  | if(number > 65535) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_OVERRUN.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = cardNum.substring(0, 12) + String.format("%04d", number); | 
|---|
|  |  |  | cardNum = cardNum.substring(0, 12) + String.format("%05d", number); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | cardNum = areaCode + "0001"; | 
|---|
|  |  |  | cardNum = areaCode + "00001"; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * cardAddr         水卡地址(仅仅写入,无业务) | 
|---|
|  |  |  | * clientNum        农户编号 | 
|---|
|  |  |  | * cardCost         卡片费用 | 
|---|
|  |  |  | * amount           充值金额 | 
|---|
|  |  |  | * originalCardId   原水卡ID | 
|---|
|  |  |  | * amount           充值金额,充值接口为输入参数,补卡接口为原卡退还金额 | 
|---|
|  |  |  | * reissueAmount    补卡金额,补卡时使用 | 
|---|
|  |  |  | * paymentId        支付方式编号 | 
|---|
|  |  |  | * remarks          备注 | 
|---|
|  |  |  | * operator         操作人编号 | 
|---|
|  |  |  | * activeTime       开卡时间 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | String protocol = po.getProtocol(); | 
|---|
|  |  |  | String cardAddr = po.getCardAddr(); | 
|---|
|  |  |  | String clientNum = po.getClientNum(); | 
|---|
|  |  |  | Integer cardCost = po.getCardCost(); | 
|---|
|  |  |  | Long originalCardId = po.getOriginalCardId(); | 
|---|
|  |  |  | Float amount = po.getAmount(); | 
|---|
|  |  |  | Long paymentId = po.getPaymentId(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | 
|---|
|  |  |  | Date activeTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据农户编号获取农户ID | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long clientId = cardOperateSv.getClientIdByNum(clientNum); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加农户卡记录 | 
|---|
|  |  |  | * 添加农户卡记录,退还金额作为当前余额 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeClientCard seClientCard = new SeClientCard(); | 
|---|
|  |  |  | seClientCard.setProtocol(protocol); | 
|---|
|  |  |  | seClientCard.setCardaddr(cardAddr); | 
|---|
|  |  |  | seClientCard.setCardnum(cardNum); | 
|---|
|  |  |  | seClientCard.setClientid(clientId); | 
|---|
|  |  |  | seClientCard.setMoney(0f); | 
|---|
|  |  |  | seClientCard.setMoney(amount); | 
|---|
|  |  |  | seClientCard.setState(CardStateENUM.NORMAL.getCode()); | 
|---|
|  |  |  | if(originalCardId != null) { | 
|---|
|  |  |  | seClientCard.setOriginalCardId(originalCardId); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | seClientCard.setCreatedt(activeTime); | 
|---|
|  |  |  | //if(cardCost == 0) { | 
|---|
|  |  |  | //    // 换卡 | 
|---|
|  |  |  | //    seClientCard.setLastoper(LastOperateENUM.CHANGE_CARD.getCode()); | 
|---|
|  |  |  | //}else { | 
|---|
|  |  |  | //    // 开卡 | 
|---|
|  |  |  | //    seClientCard.setLastoper(LastOperateENUM.ACTIVE.getCode()); | 
|---|
|  |  |  | //} | 
|---|
|  |  |  | seClientCard.setLastoper(LastOperateENUM.ACTIVE.getCode()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Long cardId = Optional.ofNullable(clientCardSv.add(seClientCard)).orElse(0L) ; | 
|---|
|  |  |  | if(cardId == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.ACTIVE_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.ACTIVE_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加开卡记录 | 
|---|
|  |  |  | * 添加开卡操作记录,退还金额作为充值金额 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeCardOperate seCardOperate = new SeCardOperate(); | 
|---|
|  |  |  | seCardOperate.setCardId(cardId); | 
|---|
|  |  |  | seCardOperate.setClientId(clientId); | 
|---|
|  |  |  | seCardOperate.setMoney(0f); | 
|---|
|  |  |  | seCardOperate.setCardCost(cardCost); | 
|---|
|  |  |  | seCardOperate.setPaymentId(paymentId); | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.ACTIVE.getCode()); | 
|---|
|  |  |  | if(originalCardId != null) { | 
|---|
|  |  |  | // 补卡 | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.REISSUE.getCode()); | 
|---|
|  |  |  | }else { | 
|---|
|  |  |  | // 开新卡或换卡 | 
|---|
|  |  |  | //if(cardCost > 0) { | 
|---|
|  |  |  | //    seCardOperate.setOperateType(OperateTypeENUM.ACTIVE.getCode()); | 
|---|
|  |  |  | //}else { | 
|---|
|  |  |  | //    seCardOperate.setOperateType(OperateTypeENUM.CHANGE_CARD.getCode()); | 
|---|
|  |  |  | //} | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.ACTIVE.getCode()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | seCardOperate.setRemarks(remarks); | 
|---|
|  |  |  | seCardOperate.setOperator(operator); | 
|---|
|  |  |  | seCardOperate.setOperateDt(activeTime); | 
|---|
|  |  |  | Long rec = Optional.ofNullable(cardOperateSv.add(seCardOperate)).orElse(0L); | 
|---|
|  |  |  | if(rec == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.ACTIVE_FAIL_WRITE_ACTIVE_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.ACTIVE_FAIL_WRITE_ACTIVE_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 如果操作人员开卡时输入了充值金额,则开卡后调用充值功能 | 
|---|
|  |  |  | * 补卡除外,补卡的退还金额是从挂失卡中转移过来的,没有实际金钱交易 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | po.setCardNum(cardNum); | 
|---|
|  |  |  | if(amount != null && amount > 0) { | 
|---|
|  |  |  | po.setClientId(clientId); | 
|---|
|  |  |  | DtoRecharge dtoRecharge = RechargeDtoMapper.INSTANCT.po2vo(po); | 
|---|
|  |  |  | if(amount != null && amount > 0 && originalCardId == null) { | 
|---|
|  |  |  | DtoRecharge dtoRecharge = new DtoRecharge(); | 
|---|
|  |  |  | dtoRecharge.setCardNum(Long.parseLong(cardNum)); | 
|---|
|  |  |  | dtoRecharge.setAmount(amount); | 
|---|
|  |  |  | dtoRecharge.setPaymentId(paymentId); | 
|---|
|  |  |  | dtoRecharge.setRemarks(remarks); | 
|---|
|  |  |  | dtoRecharge.setOperator(operator); | 
|---|
|  |  |  | dtoRecharge.setMoney(0f); | 
|---|
|  |  |  | dtoRecharge.setGift(0f); | 
|---|
|  |  |  | dtoRecharge.setPrice(0f); | 
|---|
|  |  |  | BaseResponse<Boolean> job = cardOperateSv.addRecharge(dtoRecharge); | 
|---|
|  |  |  | if(!job.getCode().equals("0001")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.ACTIVE_FAIL_RECHARGE_EXCEPTION.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.ACTIVE_FAIL_RECHARGE_EXCEPTION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Map map = new HashMap(); | 
|---|
|  |  |  | map.put("projectCode", Constant.projectCode_ym); | 
|---|
|  |  |  | //        map.put("projectNo", String.format("%02x", Integer.parseInt(cardOperateSv.getProjectNo()))); | 
|---|
|  |  |  | map.put("projectNo", String.format("%02x", projectNo)); | 
|---|
|  |  |  | map.put("orderNumber", rec); | 
|---|
|  |  |  | map.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "补卡", description = "补卡") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "reissue", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_reissue(@RequestBody @Valid DtoReissue po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * cardAddr         新的水卡地址(仅仅写入,无业务) | 
|---|
|  |  |  | * clientNum        农户编号,开新卡使用,通过老卡号获取 | 
|---|
|  |  |  | * cardNum          水卡编号,传入的是老卡号,返回的是新卡号 | 
|---|
|  |  |  | * cardId           原水卡(挂失水卡)ID,转移余额后需要更新卡余额为0 | 
|---|
|  |  |  | * moeny            余额,挂失时使用 | 
|---|
|  |  |  | * cardCost         卡片费用 | 
|---|
|  |  |  | * reissueAmount    退还金额 | 
|---|
|  |  |  | * paymentId        支付方式编号 | 
|---|
|  |  |  | * remarks          备注 | 
|---|
|  |  |  | * operator         操作人编号 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String protocol; | 
|---|
|  |  |  | String cardAddr = po.getCardAddr(); | 
|---|
|  |  |  | String clientNum = ""; | 
|---|
|  |  |  | String cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float money = po.getMoney(); | 
|---|
|  |  |  | Integer cardCost = po.getCardCost(); | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Integer cardCost = Optional.ofNullable(po.getCardCost()).orElse(0); | 
|---|
|  |  |  | Float reissueAmount = po.getReissueAmount(); | 
|---|
|  |  |  | Long paymentId = po.getPaymentId(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(Long.parseLong(cardNum))).orElse(""); | 
|---|
|  |  |  | if(stateName.length() == 0 || !stateName.equals("正常")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | // 判断当前水卡是否为挂失状态且未补卡,仅已经挂失且未补卡的可以补卡 | 
|---|
|  |  |  | if(!cardOperateSv.isLostAndUnreplaced(cardNum)) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入了退还金额,需要判断老卡(被挂失的水卡)挂失时是否已经退款,无论退款多少都提示用户挂失时已退款 | 
|---|
|  |  |  | if(reissueAmount != null && reissueAmount > 0) { | 
|---|
|  |  |  | Double tradeAmount = cardOperateSv.getTradeAmountByCardNo(cardNum); | 
|---|
|  |  |  | if(tradeAmount != null && tradeAmount > 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.THE_FEE_CANNOT_BE_REFUNDED.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); | 
|---|
|  |  |  | if(map == null || map.size() <= 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | clientNum = map.get("clientNum").toString(); | 
|---|
|  |  |  | cardId = Long.parseLong(map.get("cardId").toString()); | 
|---|
|  |  |  | clientId = Long.parseLong(map.get("clientId").toString()); | 
|---|
|  |  |  | protocol = map.get("protocol").toString(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加挂失记录 | 
|---|
|  |  |  | * 如果是补卡调用的开卡且转移了退还金额,需修改挂失卡余额为0 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | DtoLoss dtoLoss = new DtoLoss(); | 
|---|
|  |  |  | dtoLoss.setCardNum(cardNum); | 
|---|
|  |  |  | dtoLoss.setMoney(money); | 
|---|
|  |  |  | dtoLoss.setRefund(0f); | 
|---|
|  |  |  | dtoLoss.setRemarks(remarks); | 
|---|
|  |  |  | dtoLoss.setOperator(operator); | 
|---|
|  |  |  | BaseResponse<java.lang.Boolean> baseResponse_addLoss = this.add_loss(dtoLoss, null); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(!baseResponse_addLoss.getCode().equals("0001")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.REPLACE_FAIL_WRITE_RECHARGE_ERROR.getMessage()); | 
|---|
|  |  |  | if(reissueAmount != null) { | 
|---|
|  |  |  | SeClientCard seClientCard = new SeClientCard(); | 
|---|
|  |  |  | seClientCard.setId(cardId); | 
|---|
|  |  |  | seClientCard.setMoney(0f); | 
|---|
|  |  |  | cardOperateSv.updateClientCard(seClientCard); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加开卡记录 | 
|---|
|  |  |  | * 添加开卡记录,退还金额冲到新卡中 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | DtoActiveCard dtoActiveCard = new DtoActiveCard(); | 
|---|
|  |  |  | dtoActiveCard.setCardAddr(cardAddr); | 
|---|
|  |  |  | dtoActiveCard.setClientNum(clientNum); | 
|---|
|  |  |  | dtoActiveCard.setCardCost(cardCost); | 
|---|
|  |  |  | dtoActiveCard.setAmount(0f); | 
|---|
|  |  |  | dtoActiveCard.setPaymentId(paymentId); | 
|---|
|  |  |  | dtoActiveCard.setRemarks(remarks); | 
|---|
|  |  |  | dtoActiveCard.setOperator(operator); | 
|---|
|  |  |  | BaseResponse<java.lang.Boolean> baseResponse_addActive = add_active(dtoActiveCard, null); | 
|---|
|  |  |  | ActiveCard activeCard = new ActiveCard(); | 
|---|
|  |  |  | activeCard.setProtocol(protocol); | 
|---|
|  |  |  | activeCard.setCardAddr(cardAddr); | 
|---|
|  |  |  | activeCard.setClientId(clientId); | 
|---|
|  |  |  | activeCard.setOriginalCardId(cardId); | 
|---|
|  |  |  | activeCard.setCardCost(cardCost); | 
|---|
|  |  |  | activeCard.setAmount(reissueAmount); | 
|---|
|  |  |  | activeCard.setPaymentId(paymentId); | 
|---|
|  |  |  | activeCard.setRemarks(remarks); | 
|---|
|  |  |  | activeCard.setOperator(operator); | 
|---|
|  |  |  | BaseResponse<java.lang.Boolean> baseResponse_addActive = add_active(activeCard, null); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(!baseResponse_addActive.getCode().equals("0001")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.REPLACE_FAIL_WRITE_RECHARGE_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.REPLACE_FAIL_WRITE_RECHARGE_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String theContent = String.valueOf(baseResponse_addActive.getContent()); | 
|---|
|  |  |  | cardNum = theContent.substring(theContent.indexOf("=") + 1, theContent.indexOf(",")); | 
|---|
|  |  |  | JSONObject job_content = (JSONObject) JSON.toJSON( baseResponse_addActive.getContent()); | 
|---|
|  |  |  | cardNum = job_content.getLong("cardNum"); | 
|---|
|  |  |  | String orderNumber = job_content.getString("orderNumber"); | 
|---|
|  |  |  | String projectNo = job_content.getString("projectNo"); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Map map_response = new HashMap(); | 
|---|
|  |  |  | map_response.put("projectCode", Constant.projectCode_ym); | 
|---|
|  |  |  | map_response.put("projectNo", projectNo); | 
|---|
|  |  |  | map_response.put("orderNumber", orderNumber); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | map_response.put("protocol", protocol); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "充值", description = "充值") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "recharge", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_recharge(@RequestBody @Valid DtoRecharge po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return cardOperateSv.addRecharge(po); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "添加注销记录", description = "添加注销记录") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "cancel", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_cancel(@RequestBody @Valid DtoCancel po, BindingResult bindingResult){ | 
|---|
|  |  |  | DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | String cardNum = po.getCardNum(); | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float refund = po.getRefund(); | 
|---|
|  |  |  | Byte refundType = po.getRefundType(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | 
|---|
|  |  |  | Date cancelTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(Long.parseLong(cardNum))).orElse(""); | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | if(stateName.length() == 0 || !stateName.equals("正常")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); | 
|---|
|  |  |  | if(map == null || map.size() <= 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardId = Long.parseLong(map.get("cardId").toString()); | 
|---|
|  |  |  | clientId = Long.parseLong(map.get("clientId").toString()); | 
|---|
|  |  |  | 
|---|
|  |  |  | seClientCard.setLastoper(LastOperateENUM.CANCEL.getCode()); | 
|---|
|  |  |  | Integer rec_updateClientCard = Optional.ofNullable(clientCardSv.UpdateClientCard(seClientCard)).orElse(0); | 
|---|
|  |  |  | if(rec_updateClientCard == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CANCEL_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CANCEL_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加注销记录 | 
|---|
|  |  |  | * 添加注销操作记录 | 
|---|
|  |  |  | * 支付方式为现金 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeCardOperate seCardOperate = new SeCardOperate(); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Long rec = Optional.ofNullable(cardOperateSv.add(seCardOperate)).orElse(0L); | 
|---|
|  |  |  | if(rec == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CANCEL_FAIL_WRITE_CANCELL_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CANCEL_FAIL_WRITE_CANCELL_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(true) ; | 
|---|
|  |  |  | Map map_response = new HashMap(); | 
|---|
|  |  |  | map_response.put("projectNo", String.format("%02x", projectNo)); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "添加挂失记录", description = "添加挂失记录") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "loss", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_loss(@RequestBody @Valid DtoLoss po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * cardId           水卡编号(非传入参数,由cardNum反查) | 
|---|
|  |  |  | * clientId         农户编号(非传入参数,由cardNum反查) | 
|---|
|  |  |  | * cardNum          水卡编号 | 
|---|
|  |  |  | * cardNum          要挂失的水卡编号 | 
|---|
|  |  |  | * money            余额 | 
|---|
|  |  |  | * refund           退款金额 | 
|---|
|  |  |  | * remarks          备注 | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | String cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float money = po.getMoney(); | 
|---|
|  |  |  | Float refund = po.getRefund(); | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float money = Optional.ofNullable(po.getMoney()).orElse(0f); | 
|---|
|  |  |  | Float refund = Optional.ofNullable(po.getRefund()).orElse(0f); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date lossTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(Long.parseLong(cardNum))).orElse(""); | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | if(stateName.length() == 0 || !stateName.equals("正常")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); | 
|---|
|  |  |  | if(map == null || map.size() <= 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardId = Long.parseLong(map.get("cardId").toString()); | 
|---|
|  |  |  | clientId = Long.parseLong(map.get("clientId").toString()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 修改农户卡信息: | 
|---|
|  |  |  | *      挂失时间 | 
|---|
|  |  |  | *      最后操作类型-4 | 
|---|
|  |  |  | *  余额 | 
|---|
|  |  |  | *  挂失时间 | 
|---|
|  |  |  | *  状态 | 
|---|
|  |  |  | *  最后操作类型-6 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeClientCard seClientCard = new SeClientCard(); | 
|---|
|  |  |  | seClientCard.setId(cardId); | 
|---|
|  |  |  | 
|---|
|  |  |  | seClientCard.setLastoper(LastOperateENUM.LOSS.getCode()); | 
|---|
|  |  |  | Integer rec_updateClientCard = Optional.ofNullable(clientCardSv.UpdateClientCard(seClientCard)).orElse(0); | 
|---|
|  |  |  | if(rec_updateClientCard == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.LOSS_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.LOSS_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加挂失记录 | 
|---|
|  |  |  | * 如果退款金额不为空,则传入负值 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeCardOperate seCardOperate = new SeCardOperate(); | 
|---|
|  |  |  | seCardOperate.setCardId(cardId); | 
|---|
|  |  |  | seCardOperate.setClientId(clientId); | 
|---|
|  |  |  | seCardOperate.setMoney(money); | 
|---|
|  |  |  | seCardOperate.setTradeAmount(-refund); | 
|---|
|  |  |  | seCardOperate.setPaymentId(1L); | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.LOSS.getCode()); | 
|---|
|  |  |  | seCardOperate.setRemarks(remarks); | 
|---|
|  |  |  | seCardOperate.setOperator(operator); | 
|---|
|  |  |  | seCardOperate.setOperateDt(lossTime); | 
|---|
|  |  |  | Long rec = Optional.ofNullable(cardOperateSv.add(seCardOperate)).orElse(0L); | 
|---|
|  |  |  | if(rec == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.LOSS_FAIL_WRITE_LOSS_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.LOSS_FAIL_WRITE_LOSS_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(true) ; | 
|---|
|  |  |  | Map map_response = new HashMap(); | 
|---|
|  |  |  | map_response.put("projectNo", String.format("%02x", projectNo)); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "添加冲正记录", description = "添加冲正记录") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "reversal", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_reversal(@RequestBody @Valid DtoReversal po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | String cardNum = po.getCardNum(); | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float cardBalance = po.getCardBalance(); | 
|---|
|  |  |  | Float systemBalance = po.getSystemBalance(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | 
|---|
|  |  |  | Date reversalTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(Long.parseLong(cardNum))).orElse(""); | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | if(stateName.length() == 0 || !stateName.equals("正常")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); | 
|---|
|  |  |  | if(map == null || map.size() <= 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardId = Long.parseLong(map.get("cardId").toString()); | 
|---|
|  |  |  | clientId = Long.parseLong(map.get("clientId").toString()); | 
|---|
|  |  |  | 
|---|
|  |  |  | seClientCard.setLastoper(LastOperateENUM.REVERSAL.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()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.RECHARGE_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | seCardOperate.setOperateDt(reversalTime); | 
|---|
|  |  |  | Long rec = Optional.ofNullable(cardOperateSv.add(seCardOperate)).orElse(0L); | 
|---|
|  |  |  | if(rec == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.REVERSAL_FAIL_WRITE_REVERSAL_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.REVERSAL_FAIL_WRITE_REVERSAL_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(true) ; | 
|---|
|  |  |  | Map map_response = new HashMap(); | 
|---|
|  |  |  | map_response.put("projectNo", String.format("%02x", projectNo)); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "补扣", description = "补扣") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "refund", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_refund(@RequestBody @Valid DtoRefund po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | String cardNum = po.getCardNum(); | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float money = po.getMoney(); | 
|---|
|  |  |  | Float refund = po.getRefund(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | 
|---|
|  |  |  | Date refundTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(Long.parseLong(cardNum))).orElse(""); | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | if(stateName.length() == 0 || !stateName.equals("正常")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); | 
|---|
|  |  |  | if(map == null || map.size() <= 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardId = Long.parseLong(map.get("cardId").toString()); | 
|---|
|  |  |  | clientId = Long.parseLong(map.get("clientId").toString()); | 
|---|
|  |  |  | 
|---|
|  |  |  | seClientCard.setLastoper(LastOperateENUM.REFUND.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()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.RECHARGE_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加补扣记录 | 
|---|
|  |  |  | * 添加补扣操作记录 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeCardOperate seCardOperate = new SeCardOperate(); | 
|---|
|  |  |  | seCardOperate.setCardId(cardId); | 
|---|
|  |  |  | seCardOperate.setClientId(clientId); | 
|---|
|  |  |  | seCardOperate.setMoney(money); | 
|---|
|  |  |  | //seCardOperate.setNoTradeAmount(refund); | 
|---|
|  |  |  | seCardOperate.setRefundAmount(refund); | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.REFUND.getCode()); | 
|---|
|  |  |  | seCardOperate.setRemarks(remarks); | 
|---|
|  |  |  | 
|---|
|  |  |  | seCardOperate.setOperateDt(refundTime); | 
|---|
|  |  |  | Long rec = Optional.ofNullable(cardOperateSv.add(seCardOperate)).orElse(0L); | 
|---|
|  |  |  | if(rec == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.REFUND_FAIL_WRITE_REFUND_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.REFUND_FAIL_WRITE_REFUND_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(true) ; | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "添加解锁记录", description = "添加解锁记录") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "操作结果:true:成功,false:失败(BaseResponse.content)", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = Boolean.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @PostMapping(path = "unlock", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_unlock(@RequestBody @Valid DtoUnlock po, BindingResult bindingResult){ | 
|---|
|  |  |  | DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * cardId           水卡编号(非传入参数,由cardAddr反查,修改农户卡使用) | 
|---|
|  |  |  | * cardId           水卡主键(非传入参数,由cardNum反查,修改农户卡使用) | 
|---|
|  |  |  | * clientId         农户编号(非传入参数,由cardNum反查) | 
|---|
|  |  |  | * cardNum          水卡地址 | 
|---|
|  |  |  | * cardNum          水卡编号 | 
|---|
|  |  |  | * money            余额 | 
|---|
|  |  |  | * remarks          备注 | 
|---|
|  |  |  | * operator         操作人编号 | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | String cardNum = po.getCardNum(); | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Float money = po.getMoney(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date unlockTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(Long.parseLong(cardNum))).orElse(""); | 
|---|
|  |  |  | if(stateName.length() == 0 || !stateName.equals("已挂失")) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(stateName + ", " + SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | // 判断当前水卡是否为挂失状态且未补卡,仅已经挂失其未补卡的可以解锁 | 
|---|
|  |  |  | if(!cardOperateSv.isLostAndUnreplaced(cardNum)) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.THE_CARD_NOT_SUPPORT_THIS_OPERATION.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Map map = Optional.ofNullable(clientCardSv.getCardIdAndClientNum(cardNum)).orElse(new HashMap()); | 
|---|
|  |  |  | if(map == null || map.size() <= 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardId = Long.parseLong(map.get("cardId").toString()); | 
|---|
|  |  |  | clientId = Long.parseLong(map.get("clientId").toString()); | 
|---|
|  |  |  | 
|---|
|  |  |  | seClientCard.setLastoper(LastOperateENUM.UNLOCK.getCode()); | 
|---|
|  |  |  | Integer rec_updateClientCard = Optional.ofNullable(clientCardSv.UpdateClientCard(seClientCard)).orElse(0); | 
|---|
|  |  |  | if(rec_updateClientCard == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.UNLOCK_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.UNLOCK_FAIL_WRITE_CLIENT_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | seCardOperate.setOperateDt(unlockTime); | 
|---|
|  |  |  | Long rec = Optional.ofNullable(cardOperateSv.add(seCardOperate)).orElse(0L); | 
|---|
|  |  |  | if(rec == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.UNLOCK_FAIL_WRITE_UNLOCK_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.UNLOCK_FAIL_WRITE_UNLOCK_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(true) ; | 
|---|
|  |  |  | Map map_response = new HashMap(); | 
|---|
|  |  |  | map_response.put("projectNo", String.format("%02x", projectNo)); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 创建管理卡 | 
|---|
|  |  |  | * @param po | 
|---|
|  |  |  | * @param bindingResult | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @PostMapping(path = "create_manager_card", consumes = MediaType.APPLICATION_JSON_VALUE) | 
|---|
|  |  |  | @Transactional(rollbackFor = Exception.class) | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> createManagerCard(@RequestBody @Valid ManagerCard po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据行政区划串(divisionCode)在管理卡表中针对卡片编号(cardNum)进行模糊查询 | 
|---|
|  |  |  | * 如果顺序号已经达到最大值,提示用户联系系统管理员 | 
|---|
|  |  |  | * 如果顺序号未达到最大值,则加1 | 
|---|
|  |  |  | * cardNum为新的卡号 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | String cardNum = Optional.ofNullable(cardOperateSv.getManagerCardNumOfMax(divisionCode)).orElse(""); | 
|---|
|  |  |  | if(cardNum != null && cardNum.trim().length() > 0) { | 
|---|
|  |  |  | Integer number = Integer.parseInt(cardNum.substring(12)); | 
|---|
|  |  |  | number = number + 1; | 
|---|
|  |  |  | if(number > 65535) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CARD_NUMBER_OVERRUN.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = cardNum.substring(0, 12) + String.format("%05d", number); | 
|---|
|  |  |  | } else { | 
|---|
|  |  |  | cardNum = divisionCode + "00001"; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | SeManagerCard seManagerCard = new SeManagerCard(); | 
|---|
|  |  |  | seManagerCard.setCardAddr(po.getCardAddr()); | 
|---|
|  |  |  | seManagerCard.setCardNum(cardNum); | 
|---|
|  |  |  | seManagerCard.setCardType(po.getCardType()); | 
|---|
|  |  |  | seManagerCard.setCreateTime(new Date()); | 
|---|
|  |  |  | seManagerCard.setRemarks(po.getRemarks()); | 
|---|
|  |  |  | Long managerCardId = cardOperateSv.addManagerCard(seManagerCard); | 
|---|
|  |  |  | if(managerCardId == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CREATE_MANAGER_CARD_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(cardNum); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //Map map = new HashMap(); | 
|---|
|  |  |  | //map.put("cardNum", cardNum); | 
|---|
|  |  |  | //return BaseResponseUtils.buildSuccess(map) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 获取充值记录 | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 获取充值记录,管理平台充值列表使用,APP未使用 | 
|---|
|  |  |  | * @param vo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @GetMapping(path = "/getRechargesNew") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoRechargeNew>>> getRechargesNew(QoRecharge vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoRechargeNew>> res = cardOperateSv.getRechargesNew(vo); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取充值记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 获取返还记录,管理平台充值列表使用 | 
|---|
|  |  |  | * @param vo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @GetMapping(path = "/refunds") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoRefund>>> getRefunds(QoRecharge vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoRefund>> res = cardOperateSv.getRefunds(vo); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取返还记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 获取水卡消费记录,管理平台使用 | 
|---|
|  |  |  | * @param vo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @GetMapping(path = "/expends") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoExpend>>> getExpends(QoRecharge vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoExpend>> res = cardOperateSv.getExpends(vo); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取消费记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据指定条件获取交易明细 | 
|---|
|  |  |  | * @param vo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "获得交易记录明细", description = "返回交易记录明细") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "返回一页农户数据(BaseResponse.content:QueryResultVo[{}])", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = BaClient.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @GetMapping(path = "getTransactions") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Map> getOperates(QoTransaction vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | Map res = cardOperateSv.getTransactions(vo); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(cardOperateSv.getTransactions(vo)); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("查询交易记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据指定条件获取开卡记录 | 
|---|
|  |  |  | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @GetMapping(path = "/getActiveCards") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoActiveCardNew>>> getActiveCards(QoActiveCard vo){ | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoActiveCard>>> getActiveCards(QoActiveCard vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoActiveCardNew>> res = cardOperateSv.getActiveCards(vo); | 
|---|
|  |  |  | if(res.itemTotal == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_ActiveCards.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | QueryResultVo<List<VoActiveCard>> res = cardOperateSv.getActiveCards(vo); | 
|---|
|  |  |  | //            if(res.itemTotal == 0) { | 
|---|
|  |  |  | //                return BaseResponseUtils.buildErrorMsg(SellResultCode.No_ActiveCards.getMessage()); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取开卡记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据指定条件获取补卡记录 | 
|---|
|  |  |  | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoReissueCard>>> getReissueCards(QoReissueCard vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoReissueCard>> res = cardOperateSv.getReissueCards(vo); | 
|---|
|  |  |  | if(res.itemTotal == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_ReissueCards.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //            if(res.itemTotal == 0) { | 
|---|
|  |  |  | //                return BaseResponseUtils.buildErrorMsg(SellResultCode.No_ReissueCards.getMessage()); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取补卡记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据指定条件获取通用操作记录 | 
|---|
|  |  |  | * 注销、挂失、冲正、解锁通用 | 
|---|
|  |  |  | * 注销-3,挂失-6,冲正-7,解锁-8 | 
|---|
|  |  |  | * @param vo | 
|---|
|  |  |  | * @return | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Operation(summary = "获取通用操作记录", description = "返回通用操作记录") | 
|---|
|  |  |  | @ApiResponses(value = { | 
|---|
|  |  |  | @ApiResponse( | 
|---|
|  |  |  | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, | 
|---|
|  |  |  | description = "返回一页开卡数据(BaseResponse.content:QueryResultVo[{}])", | 
|---|
|  |  |  | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, | 
|---|
|  |  |  | schema = @Schema(implementation = VoActiveCard.class))} | 
|---|
|  |  |  | ) | 
|---|
|  |  |  | }) | 
|---|
|  |  |  | @GetMapping(path = "/getOptions") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoOperate>>> getCommonOperations(QoCommonOperate vo){ | 
|---|
|  |  |  | // 验证操作类型是否正确 | 
|---|
|  |  |  | Integer operateType = Optional.ofNullable(vo.getOperateType()).orElse(0); | 
|---|
|  |  |  | if(operateType != 3 && operateType != 6 && operateType != 7 && operateType != 8) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.PARAMS_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoOperate>> res = cardOperateSv.getCommonOperations(vo); | 
|---|
|  |  |  | //            if(res.itemTotal == 0) { | 
|---|
|  |  |  | //                return BaseResponseUtils.buildErrorMsg(SellResultCode.No_CANCELS.getMessage()); | 
|---|
|  |  |  | //            } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取开卡记录异常", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Map> getReceipts(QoReceipt vo){ | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | Map res = Optional.ofNullable(cardOperateSv.getReceipts(vo)).orElse(new HashMap()); | 
|---|
|  |  |  | if(res.size() == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_RECEIPTS.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | //    Map res = Optional.ofNullable(cardOperateSv.getReceipts(vo)).orElse(new HashMap()); | 
|---|
|  |  |  | //    if(res.size() == 0) { | 
|---|
|  |  |  | //        return BaseResponseUtils.buildErrorMsg(SellResultCode.No_RECEIPTS.getMessage()); | 
|---|
|  |  |  | //    } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(cardOperateSv.getReceipts(vo)); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | log.error("获取电子钱包账户记录", e); | 
|---|
|  |  |  | return BaseResponseUtils.buildException(e.getMessage()) ; | 
|---|