|  |  |  | 
|---|
|  |  |  | 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.voSe.VoActiveCard; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoOperate; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoRecharge; | 
|---|
|  |  |  | import com.dy.pipIrrGlobal.voSe.VoReissueCard; | 
|---|
|  |  |  | import com.dy.pipIrrSell.cardOperate.converter.RechargeDtoMapper; | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  | 
|---|
|  |  |  | private final CardOperateSv cardOperateSv; | 
|---|
|  |  |  | private final ClientCardSv clientCardSv; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Value("${project.divisionCode}") | 
|---|
|  |  |  | private String divisionCode; | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 开卡 | 
|---|
|  |  |  | * @param po 开卡传入对象 | 
|---|
|  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Long clientId = po.getClientId(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 获取5级行政区划串areaCode | 
|---|
|  |  |  | String areaCode = cardOperateSv.getAreaCodeByNum(po.getClientNum()); | 
|---|
|  |  |  | if(areaCode.trim().length() == 0) { | 
|---|
|  |  |  | Long areaCodeL = cardOperateSv.getAreaCodeById(clientId); | 
|---|
|  |  |  | if(areaCodeL == null) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.AREA_CODE_MISTAKE.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // p206V1_0_1协议,将前6位行政区划改为100000 | 
|---|
|  |  |  | if(po.getProtocol().trim().equals("p206V1_0_1")) { | 
|---|
|  |  |  | areaCode = "100000" + areaCode.substring(6); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | String areaCode = String.valueOf(areaCodeL); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据行政区划串(areaCode)在水卡表中针对水卡编号(cardNum)进行模糊查询 | 
|---|
|  |  |  | * 如果4位顺序号已经达到最大值,提示用户联系系统管理员 | 
|---|
|  |  |  | * 如果4位顺序号未达到最大值,则加1 | 
|---|
|  |  |  | * 如果顺序号已经达到最大值,提示用户联系系统管理员 | 
|---|
|  |  |  | * 如果顺序号未达到最大值,则加1 | 
|---|
|  |  |  | * cardNum为新的卡号 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | String cardNum = Optional.ofNullable(cardOperateSv.getCardNumOfMax(areaCode)).orElse(""); | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * cardAddr         水卡地址(仅仅写入,无业务) | 
|---|
|  |  |  | * clientNum        农户编号 | 
|---|
|  |  |  | * cardCost         卡片费用 | 
|---|
|  |  |  | * originalCardId   原水卡ID | 
|---|
|  |  |  | * amount           充值金额,充值接口为输入参数,补卡接口为原卡退还金额 | 
|---|
|  |  |  | * reissueAmount    补卡金额,补卡时使用 | 
|---|
|  |  |  | * paymentId        支付方式编号 | 
|---|
|  |  |  | 
|---|
|  |  |  | * 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(); | 
|---|
|  |  |  | 
|---|
|  |  |  | Date activeTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 根据农户编号获取农户ID | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | Long clientId = cardOperateSv.getClientIdByNum(clientNum); | 
|---|
|  |  |  | if(clientId == null) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.CLIENT_NUM_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加农户卡记录,退还金额作为当前余额 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | SeClientCard seClientCard = new SeClientCard(); | 
|---|
|  |  |  | seClientCard.setProtocol(protocol); | 
|---|
|  |  |  | seClientCard.setCardaddr(cardAddr); | 
|---|
|  |  |  | seClientCard.setCardnum(cardNum); | 
|---|
|  |  |  | seClientCard.setClientid(clientId); | 
|---|
|  |  |  | 
|---|
|  |  |  | SeCardOperate seCardOperate = new SeCardOperate(); | 
|---|
|  |  |  | seCardOperate.setCardId(cardId); | 
|---|
|  |  |  | seCardOperate.setClientId(clientId); | 
|---|
|  |  |  | seCardOperate.setMoney(amount); | 
|---|
|  |  |  | seCardOperate.setMoney(0f); | 
|---|
|  |  |  | seCardOperate.setCardCost(cardCost); | 
|---|
|  |  |  | seCardOperate.setPaymentId(paymentId); | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.ACTIVE.getCode()); | 
|---|
|  |  |  | 
|---|
|  |  |  | * 如果操作人员开卡时输入了充值金额,则开卡后调用充值功能 | 
|---|
|  |  |  | * 补卡除外,补卡的退还金额是从挂失卡中转移过来的,没有实际金钱交易 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | po.setCardNum(Long.parseLong(cardNum)); | 
|---|
|  |  |  | if(amount != null && amount > 0 && originalCardId == null) { | 
|---|
|  |  |  | po.setClientId(clientId); | 
|---|
|  |  |  | DtoRecharge dtoRecharge = RechargeDtoMapper.INSTANCT.po2vo(po); | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if(po.getProtocol().trim().equals("p206V1_0_1")) { | 
|---|
|  |  |  | cardNum = cardNum.substring(6,12) + cardNum.substring(13); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | Map map = new HashMap(); | 
|---|
|  |  |  | map.put("projectNo", String.format("%02x", Integer.parseInt(cardOperateSv.getProjectNo()))); | 
|---|
|  |  |  | map.put("orderNumber", cardId); | 
|---|
|  |  |  | map.put("orderNumber", rec); | 
|---|
|  |  |  | map.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * operator         操作人编号 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | String protocol; | 
|---|
|  |  |  | String cardAddr = po.getCardAddr(); | 
|---|
|  |  |  | String clientNum = ""; | 
|---|
|  |  |  | Long clientId = 0L; | 
|---|
|  |  |  | Long cardNum = po.getCardNum(); | 
|---|
|  |  |  | Long cardId = 0L; | 
|---|
|  |  |  | Integer cardCost = Optional.ofNullable(po.getCardCost()).orElse(0); | 
|---|
|  |  |  | 
|---|
|  |  |  | Long paymentId = po.getPaymentId(); | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | String protocol = null; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | String cardNumS = String.valueOf(cardNum).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | protocol = "p206V1_0_1"; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = Long.valueOf(cardNumS); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 判断当前水卡是否为挂失状态且未补卡,仅已经挂失且未补卡的可以补卡 | 
|---|
|  |  |  | if(!cardOperateSv.isLostAndUnreplaced(cardNum)) { | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入了退还金额,需要判断老卡(被挂失的水卡)挂失时是否已经退款,无论退款多少都提示用户挂失时已退款 | 
|---|
|  |  |  | if(reissueAmount != null) { | 
|---|
|  |  |  | if(reissueAmount != null && reissueAmount > 0) { | 
|---|
|  |  |  | Double tradeAmount = cardOperateSv.getTradeAmountByCardNo(cardNum); | 
|---|
|  |  |  | if(tradeAmount != null) { | 
|---|
|  |  |  | if(tradeAmount != null && tradeAmount > 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.THE_FEE_CANNOT_BE_REFUNDED.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 | 
|---|
|  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 添加开卡记录,退还金额冲到新卡中 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | DtoActiveCard dtoActiveCard = new DtoActiveCard(); | 
|---|
|  |  |  | dtoActiveCard.setProtocol(protocol); | 
|---|
|  |  |  | dtoActiveCard.setCardAddr(cardAddr); | 
|---|
|  |  |  | dtoActiveCard.setClientNum(clientNum); | 
|---|
|  |  |  | dtoActiveCard.setOriginalCardId(cardId); | 
|---|
|  |  |  | //dtoActiveCard.setOriginalCardId(cardNum); | 
|---|
|  |  |  | dtoActiveCard.setCardCost(cardCost); | 
|---|
|  |  |  | dtoActiveCard.setAmount(reissueAmount); | 
|---|
|  |  |  | 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.buildErrorMsg(SellResultCode.REPLACE_FAIL_WRITE_RECHARGE_ERROR.getMessage()); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | @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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_cancel(@RequestBody @Valid DtoCancel po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date cancelTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | String cardNumS = String.valueOf(cardNum).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = Long.valueOf(cardNumS); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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", Integer.parseInt(cardOperateSv.getProjectNo()))); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date lossTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | String cardNumS = String.valueOf(cardNum).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = Long.valueOf(cardNumS); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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", Integer.parseInt(cardOperateSv.getProjectNo()))); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date reversalTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | String cardNumS = String.valueOf(cardNum).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = Long.valueOf(cardNumS); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | 
|---|
|  |  |  | 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", Integer.parseInt(cardOperateSv.getProjectNo()))); | 
|---|
|  |  |  | map_response.put("orderNumber", rec); | 
|---|
|  |  |  | map_response.put("cardNum", cardNum); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(map_response) ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | @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()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date refundTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | String cardNumS = String.valueOf(cardNum).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = Long.valueOf(cardNumS); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 验证水卡状态是否支持当前操作 | 
|---|
|  |  |  | String stateName = Optional.ofNullable(clientCardSv.getCardStateByCardNum(cardNum)).orElse(""); | 
|---|
|  |  |  | 
|---|
|  |  |  | seCardOperate.setCardId(cardId); | 
|---|
|  |  |  | seCardOperate.setClientId(clientId); | 
|---|
|  |  |  | seCardOperate.setMoney(money); | 
|---|
|  |  |  | //seCardOperate.setNoTradeAmount(refund); | 
|---|
|  |  |  | seCardOperate.setRefundAmount(refund); | 
|---|
|  |  |  | seCardOperate.setOperateType(OperateTypeENUM.REFUND.getCode()); | 
|---|
|  |  |  | seCardOperate.setRemarks(remarks); | 
|---|
|  |  |  | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<Boolean> add_unlock(@RequestBody @Valid DtoUnlock po, BindingResult bindingResult){ | 
|---|
|  |  |  | if(bindingResult != null && bindingResult.hasErrors()){ | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | String remarks = po.getRemarks(); | 
|---|
|  |  |  | Long operator = po.getOperator(); | 
|---|
|  |  |  | Date unlockTime = new Date(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | String cardNumS = String.valueOf(cardNum).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | cardNum = Long.valueOf(cardNumS); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 判断当前水卡是否为挂失状态且未补卡,仅已经挂失其未补卡的可以解锁 | 
|---|
|  |  |  | if(!cardOperateSv.isLostAndUnreplaced(cardNum)) { | 
|---|
|  |  |  | 
|---|
|  |  |  | 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", Integer.parseInt(cardOperateSv.getProjectNo()))); | 
|---|
|  |  |  | 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) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 获取充值记录 | 
|---|
|  |  |  | 
|---|
|  |  |  | @GetMapping(path = "/getRecharges") | 
|---|
|  |  |  | @SsoAop() | 
|---|
|  |  |  | public BaseResponse<QueryResultVo<List<VoRecharge>>> get(QoRecharge vo){ | 
|---|
|  |  |  | // 如果传入的是10位的水卡编号,升为17位水卡编号 | 
|---|
|  |  |  | if(vo != null && vo.getCardNum() != null) { | 
|---|
|  |  |  | String cardNumS = String.valueOf(vo.getCardNum()).trim(); | 
|---|
|  |  |  | if(cardNumS.length() == 10) { | 
|---|
|  |  |  | cardNumS = "100000" + cardNumS.substring(0,6) + "0" + cardNumS.substring(6); | 
|---|
|  |  |  | vo.setCardNum(Long.parseLong(cardNumS)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoRecharge>> res = cardOperateSv.getRecharges(vo); | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoActiveCard>> res = cardOperateSv.getActiveCards(vo); | 
|---|
|  |  |  | if(res.itemTotal == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_ActiveCards.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.No_ActiveCards.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoReissueCard>> res = cardOperateSv.getReissueCards(vo); | 
|---|
|  |  |  | if(res.itemTotal == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_ReissueCards.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.No_ReissueCards.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | 
|---|
|  |  |  | // 验证操作类型是否正确 | 
|---|
|  |  |  | Integer operateType = Optional.ofNullable(vo.getOperateType()).orElse(0); | 
|---|
|  |  |  | if(operateType != 3 && operateType != 6 && operateType != 7 && operateType != 8) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.PARAMS_ERROR.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.PARAMS_ERROR.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | QueryResultVo<List<VoOperate>> res = cardOperateSv.getCommonOperations(vo); | 
|---|
|  |  |  | if(res.itemTotal == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_CANCELS.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.No_CANCELS.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | Map res = Optional.ofNullable(cardOperateSv.getReceipts(vo)).orElse(new HashMap()); | 
|---|
|  |  |  | if(res.size() == 0) { | 
|---|
|  |  |  | return BaseResponseUtils.buildFail(SellResultCode.No_RECEIPTS.getMessage()); | 
|---|
|  |  |  | return BaseResponseUtils.buildErrorMsg(SellResultCode.No_RECEIPTS.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | return BaseResponseUtils.buildSuccess(res); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|