From d42097429a1a54f375cbf1bf9d416fb7cdfd2f75 Mon Sep 17 00:00:00 2001 From: "autumn.g@foxmail.com" Date: Wed, 9 Aug 2023 16:55:22 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=9A=E5=91=98=E6=B1=87=E4=BB=98=E6=94=AF?= =?UTF-8?q?=E4=BB=98=E8=AE=B0=E5=BD=95=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pile/domain/MemberAdapayRecord.java | 81 ++++ .../pile/mapper/MemberAdapayRecordMapper.java | 36 ++ .../service/MemberAdapayRecordService.java | 22 + .../impl/MemberAdapayRecordServiceImpl.java | 50 +++ .../mapper/pile/MemberAdapayRecordMapper.xml | 401 ++++++++++++++++++ 5 files changed, 590 insertions(+) create mode 100644 jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberAdapayRecord.java create mode 100644 jsowell-pile/src/main/java/com/jsowell/pile/mapper/MemberAdapayRecordMapper.java create mode 100644 jsowell-pile/src/main/java/com/jsowell/pile/service/MemberAdapayRecordService.java create mode 100644 jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberAdapayRecordServiceImpl.java create mode 100644 jsowell-pile/src/main/resources/mapper/pile/MemberAdapayRecordMapper.xml diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberAdapayRecord.java b/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberAdapayRecord.java new file mode 100644 index 000000000..099945643 --- /dev/null +++ b/jsowell-pile/src/main/java/com/jsowell/pile/domain/MemberAdapayRecord.java @@ -0,0 +1,81 @@ +package com.jsowell.pile.domain; + +import java.math.BigDecimal; +import java.util.Date; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Getter; +import lombok.NoArgsConstructor; +import lombok.Setter; + +/** + * 会员汇付支付记录表 + */ +@Getter +@Setter +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class MemberAdapayRecord { + private Integer id; + + /** + * 会员id + */ + private String memberId; + + /** + * 场景类型(order, balance) + */ + private String scenarioType; + + /** + * 汇付支付id + */ + private String paymentId; + + /** + * 汇付支付单号 + */ + private String paymentOrderNo; + + /** + * 支付金额 + */ + private BigDecimal payAmt; + + /** + * 退款金额 + */ + private BigDecimal refundAmt; + + /** + * 消费金额 + */ + private BigDecimal spendAmt; + + /** + * 创建人 + */ + private String createBy; + + /** + * 创建时间 + */ + private Date createTime; + + /** + * 更新人 + */ + private String updateBy; + + /** + * 更新时间 + */ + private Date updateTime; + + /** + * 删除标识 + */ + private String delFlag; +} \ No newline at end of file diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/MemberAdapayRecordMapper.java b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/MemberAdapayRecordMapper.java new file mode 100644 index 000000000..75fbe6cb4 --- /dev/null +++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/MemberAdapayRecordMapper.java @@ -0,0 +1,36 @@ +package com.jsowell.pile.mapper; + +import com.jsowell.pile.domain.MemberAdapayRecord; +import java.util.List; +import org.apache.ibatis.annotations.Param; + +public interface MemberAdapayRecordMapper { + /** + * insert record to table selective + * @param record the record + * @return insert count + */ + int insertSelective(MemberAdapayRecord record); + + /** + * select by primary key + * @param id primary key + * @return object by primary key + */ + MemberAdapayRecord selectByPrimaryKey(Integer id); + + /** + * update record selective + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(MemberAdapayRecord record); + + int updateBatch(List list); + + int batchInsert(@Param("list") List list); + + int insertOrUpdate(MemberAdapayRecord record); + + int insertOrUpdateSelective(MemberAdapayRecord record); +} \ No newline at end of file diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/MemberAdapayRecordService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/MemberAdapayRecordService.java new file mode 100644 index 000000000..fcb4fe404 --- /dev/null +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/MemberAdapayRecordService.java @@ -0,0 +1,22 @@ +package com.jsowell.pile.service; + +import java.util.List; +import com.jsowell.pile.domain.MemberAdapayRecord; +public interface MemberAdapayRecordService{ + + + int insertSelective(MemberAdapayRecord record); + + MemberAdapayRecord selectByPrimaryKey(Integer id); + + int updateByPrimaryKeySelective(MemberAdapayRecord record); + + int updateBatch(List list); + + int batchInsert(List list); + + int insertOrUpdate(MemberAdapayRecord record); + + int insertOrUpdateSelective(MemberAdapayRecord record); + +} diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberAdapayRecordServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberAdapayRecordServiceImpl.java new file mode 100644 index 000000000..a93b04338 --- /dev/null +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/MemberAdapayRecordServiceImpl.java @@ -0,0 +1,50 @@ +package com.jsowell.pile.service.impl; + +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.jsowell.pile.domain.MemberAdapayRecord; +import com.jsowell.pile.mapper.MemberAdapayRecordMapper; +import com.jsowell.pile.service.MemberAdapayRecordService; +@Service +public class MemberAdapayRecordServiceImpl implements MemberAdapayRecordService{ + + @Resource + private MemberAdapayRecordMapper memberAdapayRecordMapper; + + @Override + public int insertSelective(MemberAdapayRecord record) { + return memberAdapayRecordMapper.insertSelective(record); + } + + @Override + public MemberAdapayRecord selectByPrimaryKey(Integer id) { + return memberAdapayRecordMapper.selectByPrimaryKey(id); + } + + @Override + public int updateByPrimaryKeySelective(MemberAdapayRecord record) { + return memberAdapayRecordMapper.updateByPrimaryKeySelective(record); + } + + @Override + public int updateBatch(List list) { + return memberAdapayRecordMapper.updateBatch(list); + } + + @Override + public int batchInsert(List list) { + return memberAdapayRecordMapper.batchInsert(list); + } + + @Override + public int insertOrUpdate(MemberAdapayRecord record) { + return memberAdapayRecordMapper.insertOrUpdate(record); + } + + @Override + public int insertOrUpdateSelective(MemberAdapayRecord record) { + return memberAdapayRecordMapper.insertOrUpdateSelective(record); + } + +} diff --git a/jsowell-pile/src/main/resources/mapper/pile/MemberAdapayRecordMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/MemberAdapayRecordMapper.xml new file mode 100644 index 000000000..f4ec2a99e --- /dev/null +++ b/jsowell-pile/src/main/resources/mapper/pile/MemberAdapayRecordMapper.xml @@ -0,0 +1,401 @@ + + + + + + + + + + + + + + + + + + + + + + + id, member_id, scenario_type, payment_id, payment_order_no, pay_amt, refund_amt, + spend_amt, create_by, create_time, update_by, update_time, del_flag + + + + + insert into member_adapay_record + + + id, + + + member_id, + + + scenario_type, + + + payment_id, + + + payment_order_no, + + + pay_amt, + + + refund_amt, + + + spend_amt, + + + create_by, + + + create_time, + + + update_by, + + + update_time, + + + del_flag, + + + + + #{id,jdbcType=INTEGER}, + + + #{memberId,jdbcType=VARCHAR}, + + + #{scenarioType,jdbcType=VARCHAR}, + + + #{paymentId,jdbcType=VARCHAR}, + + + #{paymentOrderNo,jdbcType=VARCHAR}, + + + #{payAmt,jdbcType=DECIMAL}, + + + #{refundAmt,jdbcType=DECIMAL}, + + + #{spendAmt,jdbcType=DECIMAL}, + + + #{createBy,jdbcType=VARCHAR}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{updateBy,jdbcType=VARCHAR}, + + + #{updateTime,jdbcType=TIMESTAMP}, + + + #{delFlag,jdbcType=VARCHAR}, + + + + + + update member_adapay_record + + + member_id = #{memberId,jdbcType=VARCHAR}, + + + scenario_type = #{scenarioType,jdbcType=VARCHAR}, + + + payment_id = #{paymentId,jdbcType=VARCHAR}, + + + payment_order_no = #{paymentOrderNo,jdbcType=VARCHAR}, + + + pay_amt = #{payAmt,jdbcType=DECIMAL}, + + + refund_amt = #{refundAmt,jdbcType=DECIMAL}, + + + spend_amt = #{spendAmt,jdbcType=DECIMAL}, + + + create_by = #{createBy,jdbcType=VARCHAR}, + + + create_time = #{createTime,jdbcType=TIMESTAMP}, + + + update_by = #{updateBy,jdbcType=VARCHAR}, + + + update_time = #{updateTime,jdbcType=TIMESTAMP}, + + + del_flag = #{delFlag,jdbcType=VARCHAR}, + + + where id = #{id,jdbcType=INTEGER} + + + + update member_adapay_record + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.memberId,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.scenarioType,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.paymentId,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.paymentOrderNo,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.payAmt,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.refundAmt,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.spendAmt,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.createBy,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.createTime,jdbcType=TIMESTAMP} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.updateBy,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.updateTime,jdbcType=TIMESTAMP} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.delFlag,jdbcType=VARCHAR} + + + + where id in + + #{item.id,jdbcType=INTEGER} + + + + + insert into member_adapay_record + (id, member_id, scenario_type, payment_id, payment_order_no, pay_amt, refund_amt, + spend_amt, create_by, create_time, update_by, update_time, del_flag) + values + + (#{item.id,jdbcType=INTEGER}, #{item.memberId,jdbcType=VARCHAR}, #{item.scenarioType,jdbcType=VARCHAR}, + #{item.paymentId,jdbcType=VARCHAR}, #{item.paymentOrderNo,jdbcType=VARCHAR}, #{item.payAmt,jdbcType=DECIMAL}, + #{item.refundAmt,jdbcType=DECIMAL}, #{item.spendAmt,jdbcType=DECIMAL}, #{item.createBy,jdbcType=VARCHAR}, + #{item.createTime,jdbcType=TIMESTAMP}, #{item.updateBy,jdbcType=VARCHAR}, #{item.updateTime,jdbcType=TIMESTAMP}, + #{item.delFlag,jdbcType=VARCHAR}) + + + + + insert into member_adapay_record + (id, member_id, scenario_type, payment_id, payment_order_no, pay_amt, refund_amt, + spend_amt, create_by, create_time, update_by, update_time, del_flag) + values + (#{id,jdbcType=INTEGER}, #{memberId,jdbcType=VARCHAR}, #{scenarioType,jdbcType=VARCHAR}, + #{paymentId,jdbcType=VARCHAR}, #{paymentOrderNo,jdbcType=VARCHAR}, #{payAmt,jdbcType=DECIMAL}, + #{refundAmt,jdbcType=DECIMAL}, #{spendAmt,jdbcType=DECIMAL}, #{createBy,jdbcType=VARCHAR}, + #{createTime,jdbcType=TIMESTAMP}, #{updateBy,jdbcType=VARCHAR}, #{updateTime,jdbcType=TIMESTAMP}, + #{delFlag,jdbcType=VARCHAR}) + on duplicate key update + id = #{id,jdbcType=INTEGER}, + member_id = #{memberId,jdbcType=VARCHAR}, + scenario_type = #{scenarioType,jdbcType=VARCHAR}, + payment_id = #{paymentId,jdbcType=VARCHAR}, + payment_order_no = #{paymentOrderNo,jdbcType=VARCHAR}, + pay_amt = #{payAmt,jdbcType=DECIMAL}, + refund_amt = #{refundAmt,jdbcType=DECIMAL}, + spend_amt = #{spendAmt,jdbcType=DECIMAL}, + create_by = #{createBy,jdbcType=VARCHAR}, + create_time = #{createTime,jdbcType=TIMESTAMP}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = #{updateTime,jdbcType=TIMESTAMP}, + del_flag = #{delFlag,jdbcType=VARCHAR} + + + + insert into member_adapay_record + + + id, + + + member_id, + + + scenario_type, + + + payment_id, + + + payment_order_no, + + + pay_amt, + + + refund_amt, + + + spend_amt, + + + create_by, + + + create_time, + + + update_by, + + + update_time, + + + del_flag, + + + values + + + #{id,jdbcType=INTEGER}, + + + #{memberId,jdbcType=VARCHAR}, + + + #{scenarioType,jdbcType=VARCHAR}, + + + #{paymentId,jdbcType=VARCHAR}, + + + #{paymentOrderNo,jdbcType=VARCHAR}, + + + #{payAmt,jdbcType=DECIMAL}, + + + #{refundAmt,jdbcType=DECIMAL}, + + + #{spendAmt,jdbcType=DECIMAL}, + + + #{createBy,jdbcType=VARCHAR}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{updateBy,jdbcType=VARCHAR}, + + + #{updateTime,jdbcType=TIMESTAMP}, + + + #{delFlag,jdbcType=VARCHAR}, + + + on duplicate key update + + + id = #{id,jdbcType=INTEGER}, + + + member_id = #{memberId,jdbcType=VARCHAR}, + + + scenario_type = #{scenarioType,jdbcType=VARCHAR}, + + + payment_id = #{paymentId,jdbcType=VARCHAR}, + + + payment_order_no = #{paymentOrderNo,jdbcType=VARCHAR}, + + + pay_amt = #{payAmt,jdbcType=DECIMAL}, + + + refund_amt = #{refundAmt,jdbcType=DECIMAL}, + + + spend_amt = #{spendAmt,jdbcType=DECIMAL}, + + + create_by = #{createBy,jdbcType=VARCHAR}, + + + create_time = #{createTime,jdbcType=TIMESTAMP}, + + + update_by = #{updateBy,jdbcType=VARCHAR}, + + + update_time = #{updateTime,jdbcType=TIMESTAMP}, + + + del_flag = #{delFlag,jdbcType=VARCHAR}, + + + + \ No newline at end of file