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