package com.dy.pipIrrSell.cancel; 
 | 
  
 | 
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.pojoSe.SeCancel; 
 | 
import com.dy.pipIrrGlobal.pojoSe.SeClientCard; 
 | 
import com.dy.pipIrrGlobal.voSe.VoCancel; 
 | 
import com.dy.pipIrrSell.clientCard.CardStateENUM; 
 | 
import com.dy.pipIrrSell.clientCard.ClientCardSv; 
 | 
import com.dy.pipIrrSell.clientCard.LastOperateENUM; 
 | 
import com.dy.pipIrrSell.result.SellResultCode; 
 | 
import io.swagger.v3.oas.annotations.Operation; 
 | 
import io.swagger.v3.oas.annotations.media.Content; 
 | 
import io.swagger.v3.oas.annotations.media.Schema; 
 | 
import io.swagger.v3.oas.annotations.responses.ApiResponse; 
 | 
import io.swagger.v3.oas.annotations.responses.ApiResponses; 
 | 
import io.swagger.v3.oas.annotations.tags.Tag; 
 | 
import jakarta.validation.Valid; 
 | 
import lombok.RequiredArgsConstructor; 
 | 
import lombok.extern.slf4j.Slf4j; 
 | 
import org.springframework.http.MediaType; 
 | 
import org.springframework.transaction.annotation.Transactional; 
 | 
import org.springframework.validation.BindingResult; 
 | 
import org.springframework.web.bind.annotation.*; 
 | 
  
 | 
import java.time.format.DateTimeFormatter; 
 | 
import java.util.*; 
 | 
  
 | 
/** 
 | 
 * @author ZhuBaoMin 
 | 
 * @date 2023/12/6 14:27 
 | 
 * @LastEditTime 2023/12/6 14:27 
 | 
 * @Description 
 | 
 */ 
 | 
  
 | 
@Slf4j 
 | 
@Tag(name = "注销管理", description = "注销操作") 
 | 
@RestController 
 | 
@RequestMapping(path="cancel") 
 | 
@RequiredArgsConstructor 
 | 
public class CancelCtrl { 
 | 
    private final CancelSv cancelSv; 
 | 
    private final ClientCardSv clientCardSv; 
 | 
  
 | 
    @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 = VoCancel.class))} 
 | 
            ) 
 | 
    }) 
 | 
    @GetMapping(path = "/getCancels") 
 | 
    @SsoAop() 
 | 
    public BaseResponse<QueryResultVo<List<VoCancel>>> getCancels(QueryVo vo){ 
 | 
        try { 
 | 
            QueryResultVo<List<VoCancel>> res = cancelSv.getCancels(vo); 
 | 
            return BaseResponseUtils.buildSuccess(res); 
 | 
        } catch (Exception e) { 
 | 
            log.error("获取注销记录异常", e); 
 | 
            return BaseResponseUtils.buildException(e.getMessage()) ; 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @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 = "add", consumes = MediaType.APPLICATION_JSON_VALUE) 
 | 
    @Transactional(rollbackFor = Exception.class) 
 | 
    @SsoAop() 
 | 
    public BaseResponse<Boolean> add(@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()); 
 | 
        } 
 | 
  
 | 
        /** 
 | 
         * cardId           水卡编号(非传入参数,由cardAddr反查,修改农户卡使用) 
 | 
         * clientId         农户编号(非传入参数,由cardNum反查) 
 | 
         * cardNum          水卡编号 
 | 
         * refund           退款金额 
 | 
         * refundType       退款方式 
 | 
         * remarks          备注 
 | 
         * operator         操作人编号 
 | 
         * cancelTime       挂失时间 
 | 
         */ 
 | 
        Long cardId = 0L; 
 | 
        String cardNum = po.getCardNum(); 
 | 
        Long clientId = 0L; 
 | 
        Float refund = po.getRefund(); 
 | 
        Byte refundType = po.getRefundType(); 
 | 
        String remarks = po.getRemarks(); 
 | 
        Long operator = po.getOperator(); 
 | 
        Date cancelTime = 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()); 
 | 
  
 | 
        /** 
 | 
         * 修改农户卡信息: 
 | 
         *      注销时间 
 | 
         *      最后操作类型-4 
 | 
         */ 
 | 
        SeClientCard seClientCard = new SeClientCard(); 
 | 
        seClientCard.setId(cardId); 
 | 
        seClientCard.setCanceldt(cancelTime); 
 | 
        seClientCard.setMoney(0f); 
 | 
        seClientCard.setState(CardStateENUM.CANCELLED.getCode()); 
 | 
        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()); 
 | 
        } 
 | 
  
 | 
        /** 
 | 
         * 添加注销记录 
 | 
         */ 
 | 
        SeCancel seCancel = new SeCancel(); 
 | 
        //seCancel.setCardnum(cardNum); 
 | 
        //seCancel.setClientnum(clientNum); 
 | 
        seCancel.setCardid(cardId); 
 | 
        seCancel.setClientid(clientId); 
 | 
        seCancel.setRefund(refund); 
 | 
        seCancel.setRefundtype(refundType); 
 | 
        seCancel.setRemarks(remarks); 
 | 
        seCancel.setOperator(operator); 
 | 
        seCancel.setOperatedt(cancelTime); 
 | 
        Long rec = Optional.ofNullable(cancelSv.add(seCancel)).orElse(0L); 
 | 
        if(rec == 0) { 
 | 
            return BaseResponseUtils.buildFail(SellResultCode.CANCEL_FAIL_WRITE_CANCELL_ERROR.getMessage()); 
 | 
        } 
 | 
  
 | 
        return BaseResponseUtils.buildSuccess(true) ; 
 | 
    } 
 | 
} 
 |