| | |
| | | package com.stylefeng.guns.modular.taxi.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.service.impl.ServiceImpl; |
| | | import com.stylefeng.guns.modular.system.util.RedisUtil; |
| | | import com.stylefeng.guns.modular.taxi.dao.PaymentRecordMapper; |
| | | import com.stylefeng.guns.modular.taxi.model.PaymentRecord; |
| | | import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService; |
| | |
| | | |
| | | @Resource |
| | | private PaymentRecordMapper paymentRecordMapper; |
| | | |
| | | @Resource |
| | | private RedisUtil redisUtil; |
| | | |
| | | |
| | | |
| | |
| | | @Override |
| | | public Integer saveData(Integer category, Integer userId, Integer type, Integer orderId, Integer orderType, Integer payType, |
| | | Double amount, String code, Integer state, String serialNumber) throws Exception { |
| | | //先删除现有数据避免重复 |
| | | PaymentRecord query = paymentRecordMapper.query(category, userId, type, orderId, orderType, payType, state); |
| | | if(null != query){ |
| | | this.deleteById(query.getId()); |
| | | } |
| | | PaymentRecord paymentRecord = new PaymentRecord(); |
| | | paymentRecord.setCategory(category); |
| | | paymentRecord.setUserId(userId); |
| | |
| | | paymentRecord.setInsertTime(new Date()); |
| | | paymentRecord.setSerialNumber(serialNumber); |
| | | this.insert(paymentRecord); |
| | | if(state == 1){ |
| | | redisUtil.setStrValue(orderId + "_status_" + orderType, "7", 3600); |
| | | } |
| | | return paymentRecord.getId(); |
| | | } |
| | | |