diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/domain/SettleOrderReport.java b/jsowell-pile/src/main/java/com/jsowell/pile/domain/SettleOrderReport.java index 380e8a8f7..609683708 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/domain/SettleOrderReport.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/domain/SettleOrderReport.java @@ -1,233 +1,100 @@ package com.jsowell.pile.domain; -import com.jsowell.common.annotation.Excel; -import com.jsowell.common.core.domain.BaseEntity; -import org.apache.commons.lang3.builder.ToStringBuilder; -import org.apache.commons.lang3.builder.ToStringStyle; - import java.math.BigDecimal; +import java.util.Date; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Getter; +import lombok.NoArgsConstructor; +import lombok.Setter; /** - * 结算订单报对象 settle_order_report - * - * @author jsowell - * @date 2023-06-05 + * 结算订单报表 */ -public class SettleOrderReport extends BaseEntity { +@Getter +@Setter +@Builder +@AllArgsConstructor +@NoArgsConstructor +public class SettleOrderReport { private static final long serialVersionUID = 1L; - /** * 主键 */ - private Long id; + private Integer id; /** * 运营商id */ - @Excel(name = "运营商id") private String merchantId; /** * 站点id */ - @Excel(name = "站点id") private String stationId; + /** + * 包含订单编号 + */ + private String orderCodes; + /** * 用电度数 */ - @Excel(name = "用电度数") private BigDecimal useElectricity; /** * 充电次数 */ - @Excel(name = "充电次数") private String chargeNum; /** * 充电时长 */ - @Excel(name = "充电时长") private String chargeTime; /** * 电费金额 */ - @Excel(name = "电费金额") private BigDecimal electricityAmount; /** * 服务费金额 */ - @Excel(name = "服务费金额") private BigDecimal serviceAmount; /** * 收入金额 */ - @Excel(name = "收入金额") private BigDecimal totalAmount; /** * 虚拟金额 */ - @Excel(name = "虚拟金额") private BigDecimal virtualAmount; /** * 交易日期 */ - @Excel(name = "交易日期") private String tradeDate; /** * 交易金额 */ - @Excel(name = "交易金额") private BigDecimal tradeAmount; /** * 交易手续费 */ - @Excel(name = "交易手续费") private BigDecimal tradeFee; + /** + * 创建时间 + */ + private Date createTime; + /** * 删除标识(0-正常;1-删除) */ private String delFlag; - - public void setId(Long id) { - this.id = id; - } - - public Long getId() { - return id; - } - - public void setMerchantId(String merchantId) { - this.merchantId = merchantId; - } - - public String getMerchantId() { - return merchantId; - } - - public void setStationId(String stationId) { - this.stationId = stationId; - } - - public String getStationId() { - return stationId; - } - - public void setUseElectricity(BigDecimal useElectricity) { - this.useElectricity = useElectricity; - } - - public BigDecimal getUseElectricity() { - return useElectricity; - } - - public void setChargeNum(String chargeNum) { - this.chargeNum = chargeNum; - } - - public String getChargeNum() { - return chargeNum; - } - - public void setChargeTime(String chargeTime) { - this.chargeTime = chargeTime; - } - - public String getChargeTime() { - return chargeTime; - } - - public void setElectricityAmount(BigDecimal electricityAmount) { - this.electricityAmount = electricityAmount; - } - - public BigDecimal getElectricityAmount() { - return electricityAmount; - } - - public void setServiceAmount(BigDecimal serviceAmount) { - this.serviceAmount = serviceAmount; - } - - public BigDecimal getServiceAmount() { - return serviceAmount; - } - - public void setTotalAmount(BigDecimal totalAmount) { - this.totalAmount = totalAmount; - } - - public BigDecimal getTotalAmount() { - return totalAmount; - } - - public void setVirtualAmount(BigDecimal virtualAmount) { - this.virtualAmount = virtualAmount; - } - - public BigDecimal getVirtualAmount() { - return virtualAmount; - } - - public void setTradeDate(String tradeDate) { - this.tradeDate = tradeDate; - } - - public String getTradeDate() { - return tradeDate; - } - - public void setTradeAmount(BigDecimal tradeAmount) { - this.tradeAmount = tradeAmount; - } - - public BigDecimal getTradeAmount() { - return tradeAmount; - } - - public void setTradeFee(BigDecimal tradeFee) { - this.tradeFee = tradeFee; - } - - public BigDecimal getTradeFee() { - return tradeFee; - } - - public void setDelFlag(String delFlag) { - this.delFlag = delFlag; - } - - public String getDelFlag() { - return delFlag; - } - - @Override - public String toString() { - return new ToStringBuilder(this, ToStringStyle.JSON_STYLE) - .append("id", getId()) - .append("merchantId", getMerchantId()) - .append("stationId", getStationId()) - .append("useElectricity", getUseElectricity()) - .append("chargeNum", getChargeNum()) - .append("chargeTime", getChargeTime()) - .append("electricityAmount", getElectricityAmount()) - .append("serviceAmount", getServiceAmount()) - .append("totalAmount", getTotalAmount()) - .append("virtualAmount", getVirtualAmount()) - .append("tradeDate", getTradeDate()) - .append("tradeAmount", getTradeAmount()) - .append("tradeFee", getTradeFee()) - .append("createTime", getCreateTime()) - .append("delFlag", getDelFlag()) - .toString(); - } -} +} \ No newline at end of file diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SettleOrderReportMapper.java b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SettleOrderReportMapper.java index 9a429e7c3..9b0eef767 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SettleOrderReportMapper.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/mapper/SettleOrderReportMapper.java @@ -4,25 +4,75 @@ import com.jsowell.pile.domain.SettleOrderReport; import com.jsowell.pile.dto.MerchantOrderReportDTO; import com.jsowell.pile.vo.web.SettleOrderReportVO; import org.apache.ibatis.annotations.Param; -import org.springframework.stereotype.Repository; import java.util.List; -/** - * 结算订单报Mapper接口 - * - * @author jsowell - * @date 2023-06-05 - */ -@Repository public interface SettleOrderReportMapper { + /** + * delete by primary key + * + * @param id primaryKey + * @return deleteCount + */ + int deleteByPrimaryKey(Integer id); + + /** + * insert record to table + * + * @param record the record + * @return insert count + */ + int insert(SettleOrderReport record); + + int insertOrUpdate(SettleOrderReport record); + + int insertOrUpdateSelective(SettleOrderReport record); + + /** + * insert record to table selective + * + * @param record the record + * @return insert count + */ + int insertSelective(SettleOrderReport record); + + /** + * select by primary key + * + * @param id primary key + * @return object by primary key + */ + SettleOrderReport selectByPrimaryKey(Integer id); + + /** + * update record selective + * + * @param record the updated record + * @return update count + */ + int updateByPrimaryKeySelective(SettleOrderReport record); + + /** + * update record + * + * @param record the updated record + * @return update count + */ + int updateByPrimaryKey(SettleOrderReport record); + + int updateBatch(List list); + + int updateBatchSelective(List list); + + int batchInsert(@Param("list") List list); + /** * 查询结算订单报 * * @param id 结算订单报主键 * @return 结算订单报 */ - public SettleOrderReport selectSettleOrderReportById(Long id); + SettleOrderReport selectSettleOrderReportById(Long id); /** * 查询结算订单报列表 @@ -30,7 +80,7 @@ public interface SettleOrderReportMapper { * @param settleOrderReport 结算订单报 * @return 结算订单报集合 */ - public List selectSettleOrderReportList(SettleOrderReport settleOrderReport); + List selectSettleOrderReportList(SettleOrderReport settleOrderReport); /** * 新增结算订单报 @@ -38,7 +88,7 @@ public interface SettleOrderReportMapper { * @param settleOrderReport 结算订单报 * @return 结果 */ - public int insertSettleOrderReport(SettleOrderReport settleOrderReport); + int insertSettleOrderReport(SettleOrderReport settleOrderReport); /** * 修改结算订单报 @@ -46,7 +96,7 @@ public interface SettleOrderReportMapper { * @param settleOrderReport 结算订单报 * @return 结果 */ - public int updateSettleOrderReport(SettleOrderReport settleOrderReport); + int updateSettleOrderReport(SettleOrderReport settleOrderReport); /** * 删除结算订单报 @@ -54,7 +104,7 @@ public interface SettleOrderReportMapper { * @param id 结算订单报主键 * @return 结果 */ - public int deleteSettleOrderReportById(Long id); + int deleteSettleOrderReportById(Long id); /** * 批量删除结算订单报 @@ -62,14 +112,29 @@ public interface SettleOrderReportMapper { * @param ids 需要删除的数据主键集合 * @return 结果 */ - public int deleteSettleOrderReportByIds(Long[] ids); + int deleteSettleOrderReportByIds(Long[] ids); /** * 根据运营商id查询订单报表 + * * @param dto * @return */ List getMerchantOrderReport(@Param("dto") MerchantOrderReportDTO dto); + /** + * 根据站点id和日期查询订单日报 + * + * @param stationId 站点id + * @param date 交易日期 + */ SettleOrderReport selectByStationIdAndDate(@Param("stationId") String stationId, @Param("date") String date); -} + + /** + * 根据运营商id和日期查询订单日报 + * + * @param merchantId 运营商id + * @param date 交易日期 + */ + List selectByMerchantIdAndDate(@Param("merchantId") String merchantId, @Param("date") String date); +} \ No newline at end of file diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/ISettleOrderReportService.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/ISettleOrderReportService.java index 3dc963f82..8d3aebe74 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/ISettleOrderReportService.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/ISettleOrderReportService.java @@ -23,6 +23,8 @@ public interface ISettleOrderReportService { SettleOrderReport selectByStationIdAndDate(String stationId, String date); + List selectByMerchantIdAndDate(String merchantId, String date); + /** * 查询结算订单报列表 * @@ -69,4 +71,26 @@ public interface ISettleOrderReportService { * @return */ MerchantOrderReportVO getMerchantOrderReport(MerchantOrderReportDTO dto); + + int deleteByPrimaryKey(Integer id); + + int insert(SettleOrderReport record); + + int insertOrUpdate(SettleOrderReport record); + + int insertOrUpdateSelective(SettleOrderReport record); + + int insertSelective(SettleOrderReport record); + + SettleOrderReport selectByPrimaryKey(Integer id); + + int updateByPrimaryKeySelective(SettleOrderReport record); + + int updateByPrimaryKey(SettleOrderReport record); + + int updateBatch(List list); + + int updateBatchSelective(List list); + + int batchInsert(List list); } diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/AdapayMemberAccountServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/AdapayMemberAccountServiceImpl.java index 171d8da68..93745a245 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/AdapayMemberAccountServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/AdapayMemberAccountServiceImpl.java @@ -118,6 +118,9 @@ public class AdapayMemberAccountServiceImpl implements IAdapayMemberAccountServi @Override public AdapayMemberAccount selectByMerchantId(String merchantId) { + if (StringUtils.isBlank(merchantId)) { + return null; + } String redisKey = CacheConstants.ADAPAY_MEMBER_ACCOUNT + merchantId; AdapayMemberAccount adapayMemberAccount = redisCache.getCacheObject(redisKey); if (adapayMemberAccount == null) { diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java index b9a0259e2..5786a628a 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java @@ -870,16 +870,29 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService { /** * 订单分账逻辑 + * orderSplittingOperations * 只有开通结算账户的运营商才走分账逻辑 */ - private void ledgerAccount(OrderBasicInfo orderBasicInfo) throws BaseAdaPayException { + private void orderSplittingOperations(String merchantId, String tradeDate) { // 查询运营商有没有开通结算账户 - String merchantId = orderBasicInfo.getMerchantId(); AdapayMemberAccount adapayMemberAccount = adapayMemberAccountService.selectByMerchantId(merchantId); if (adapayMemberAccount == null) { + logger.error("订单分账逻辑error, 运营商id:{}, 未配置结算账户", merchantId); throw new BusinessException(ReturnCodeEnum.CODE_ADAPAY_MEMBER_IS_NULL_ERROR); } + // 根据交易日期查询运营商下面所有站点的交易日报 + List orderReports = settleOrderReportService.selectByMerchantIdAndDate(merchantId, tradeDate); + + } + + /** + * 交易确认 + * @param orderBasicInfo 订单 + * @param adapayMemberAccount 结算账户 + * @throws BaseAdaPayException + */ + private void doPaymentConfirm(OrderBasicInfo orderBasicInfo, AdapayMemberAccount adapayMemberAccount) throws BaseAdaPayException { // 查询订单的交易id AdapayCallbackRecord adapayCallbackRecord = adapayCallbackRecordService.selectByOrderCode(orderBasicInfo.getOrderCode()); if (adapayCallbackRecord == null) { diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java index bb5b829be..a8b9046cc 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/SettleOrderReportServiceImpl.java @@ -46,6 +46,11 @@ public class SettleOrderReportServiceImpl implements ISettleOrderReportService { return settleOrderReportMapper.selectByStationIdAndDate(stationId, date); } + @Override + public List selectByMerchantIdAndDate(String merchantId, String date) { + return settleOrderReportMapper.selectByMerchantIdAndDate(merchantId, date); + } + /** * 查询结算订单报列表 * @@ -104,6 +109,7 @@ public class SettleOrderReportServiceImpl implements ISettleOrderReportService { /** * 根据运营商id查询订单报表 + * * @param dto * @return */ @@ -161,4 +167,60 @@ public class SettleOrderReportServiceImpl implements ISettleOrderReportService { vo.setMerchantOrderReport(report); return vo; } + + @Override + public int deleteByPrimaryKey(Integer id) { + return settleOrderReportMapper.deleteByPrimaryKey(id); + } + + @Override + public int insert(SettleOrderReport record) { + return settleOrderReportMapper.insert(record); + } + + @Override + public int insertOrUpdate(SettleOrderReport record) { + return settleOrderReportMapper.insertOrUpdate(record); + } + + @Override + public int insertOrUpdateSelective(SettleOrderReport record) { + return settleOrderReportMapper.insertOrUpdateSelective(record); + } + + @Override + public int insertSelective(SettleOrderReport record) { + return settleOrderReportMapper.insertSelective(record); + } + + @Override + public SettleOrderReport selectByPrimaryKey(Integer id) { + return settleOrderReportMapper.selectByPrimaryKey(id); + } + + @Override + public int updateByPrimaryKeySelective(SettleOrderReport record) { + return settleOrderReportMapper.updateByPrimaryKeySelective(record); + } + + @Override + public int updateByPrimaryKey(SettleOrderReport record) { + return settleOrderReportMapper.updateByPrimaryKey(record); + } + + @Override + public int updateBatch(List list) { + return settleOrderReportMapper.updateBatch(list); + } + + @Override + public int updateBatchSelective(List list) { + return settleOrderReportMapper.updateBatchSelective(list); + } + + @Override + public int batchInsert(List list) { + return settleOrderReportMapper.batchInsert(list); + } } + diff --git a/jsowell-pile/src/main/resources/mapper/pile/SettleOrderReportMapper.xml b/jsowell-pile/src/main/resources/mapper/pile/SettleOrderReportMapper.xml index 1e8e5ce6a..7fc6c0ef1 100644 --- a/jsowell-pile/src/main/resources/mapper/pile/SettleOrderReportMapper.xml +++ b/jsowell-pile/src/main/resources/mapper/pile/SettleOrderReportMapper.xml @@ -1,37 +1,694 @@ - - + + + + + + + + + + + + + + + + + + + + + + + + + id, merchant_id, station_id, order_codes, use_electricity, charge_num, charge_time, + electricity_amount, service_amount, total_amount, virtual_amount, trade_date, trade_amount, + trade_fee, create_time, del_flag + + + + + delete from settle_order_report + where id = #{id,jdbcType=INTEGER} + + + + insert into settle_order_report (merchant_id, station_id, order_codes, + use_electricity, charge_num, charge_time, + electricity_amount, service_amount, total_amount, + virtual_amount, trade_date, trade_amount, + trade_fee, create_time, del_flag + ) + values (#{merchantId,jdbcType=VARCHAR}, #{stationId,jdbcType=VARCHAR}, #{orderCodes,jdbcType=LONGVARCHAR}, + #{useElectricity,jdbcType=DECIMAL}, #{chargeNum,jdbcType=VARCHAR}, #{chargeTime,jdbcType=VARCHAR}, + #{electricityAmount,jdbcType=DECIMAL}, #{serviceAmount,jdbcType=DECIMAL}, #{totalAmount,jdbcType=DECIMAL}, + #{virtualAmount,jdbcType=DECIMAL}, #{tradeDate,jdbcType=VARCHAR}, #{tradeAmount,jdbcType=DECIMAL}, + #{tradeFee,jdbcType=DECIMAL}, #{createTime,jdbcType=TIMESTAMP}, #{delFlag,jdbcType=VARCHAR} + ) + + + + insert into settle_order_report + + + merchant_id, + + + station_id, + + + order_codes, + + + use_electricity, + + + charge_num, + + + charge_time, + + + electricity_amount, + + + service_amount, + + + total_amount, + + + virtual_amount, + + + trade_date, + + + trade_amount, + + + trade_fee, + + + create_time, + + + del_flag, + + + + + #{merchantId,jdbcType=VARCHAR}, + + + #{stationId,jdbcType=VARCHAR}, + + + #{orderCodes,jdbcType=LONGVARCHAR}, + + + #{useElectricity,jdbcType=DECIMAL}, + + + #{chargeNum,jdbcType=VARCHAR}, + + + #{chargeTime,jdbcType=VARCHAR}, + + + #{electricityAmount,jdbcType=DECIMAL}, + + + #{serviceAmount,jdbcType=DECIMAL}, + + + #{totalAmount,jdbcType=DECIMAL}, + + + #{virtualAmount,jdbcType=DECIMAL}, + + + #{tradeDate,jdbcType=VARCHAR}, + + + #{tradeAmount,jdbcType=DECIMAL}, + + + #{tradeFee,jdbcType=DECIMAL}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{delFlag,jdbcType=VARCHAR}, + + + + + + update settle_order_report + + + merchant_id = #{merchantId,jdbcType=VARCHAR}, + + + station_id = #{stationId,jdbcType=VARCHAR}, + + + order_codes = #{orderCodes,jdbcType=LONGVARCHAR}, + + + use_electricity = #{useElectricity,jdbcType=DECIMAL}, + + + charge_num = #{chargeNum,jdbcType=VARCHAR}, + + + charge_time = #{chargeTime,jdbcType=VARCHAR}, + + + electricity_amount = #{electricityAmount,jdbcType=DECIMAL}, + + + service_amount = #{serviceAmount,jdbcType=DECIMAL}, + + + total_amount = #{totalAmount,jdbcType=DECIMAL}, + + + virtual_amount = #{virtualAmount,jdbcType=DECIMAL}, + + + trade_date = #{tradeDate,jdbcType=VARCHAR}, + + + trade_amount = #{tradeAmount,jdbcType=DECIMAL}, + + + trade_fee = #{tradeFee,jdbcType=DECIMAL}, + + + create_time = #{createTime,jdbcType=TIMESTAMP}, + + + del_flag = #{delFlag,jdbcType=VARCHAR}, + + + where id = #{id,jdbcType=INTEGER} + + + + update settle_order_report + set merchant_id = #{merchantId,jdbcType=VARCHAR}, + station_id = #{stationId,jdbcType=VARCHAR}, + order_codes = #{orderCodes,jdbcType=LONGVARCHAR}, + use_electricity = #{useElectricity,jdbcType=DECIMAL}, + charge_num = #{chargeNum,jdbcType=VARCHAR}, + charge_time = #{chargeTime,jdbcType=VARCHAR}, + electricity_amount = #{electricityAmount,jdbcType=DECIMAL}, + service_amount = #{serviceAmount,jdbcType=DECIMAL}, + total_amount = #{totalAmount,jdbcType=DECIMAL}, + virtual_amount = #{virtualAmount,jdbcType=DECIMAL}, + trade_date = #{tradeDate,jdbcType=VARCHAR}, + trade_amount = #{tradeAmount,jdbcType=DECIMAL}, + trade_fee = #{tradeFee,jdbcType=DECIMAL}, + create_time = #{createTime,jdbcType=TIMESTAMP}, + del_flag = #{delFlag,jdbcType=VARCHAR} + where id = #{id,jdbcType=INTEGER} + + + + update settle_order_report + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.merchantId,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.stationId,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.orderCodes,jdbcType=LONGVARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.useElectricity,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.chargeNum,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.chargeTime,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.electricityAmount,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.serviceAmount,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.totalAmount,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.virtualAmount,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.tradeDate,jdbcType=VARCHAR} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.tradeAmount,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.tradeFee,jdbcType=DECIMAL} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.createTime,jdbcType=TIMESTAMP} + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.delFlag,jdbcType=VARCHAR} + + + + where id in + + #{item.id,jdbcType=INTEGER} + + + + + update settle_order_report + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.merchantId,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.stationId,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.orderCodes,jdbcType=LONGVARCHAR} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.useElectricity,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.chargeNum,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.chargeTime,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.electricityAmount,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.serviceAmount,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.totalAmount,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.virtualAmount,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.tradeDate,jdbcType=VARCHAR} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.tradeAmount,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.tradeFee,jdbcType=DECIMAL} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.createTime,jdbcType=TIMESTAMP} + + + + + + + when id = #{item.id,jdbcType=INTEGER} then #{item.delFlag,jdbcType=VARCHAR} + + + + + where id in + + #{item.id,jdbcType=INTEGER} + + + + + insert into settle_order_report + (merchant_id, station_id, order_codes, use_electricity, charge_num, charge_time, + electricity_amount, service_amount, total_amount, virtual_amount, trade_date, trade_amount, + trade_fee, create_time, del_flag) + values + + (#{item.merchantId,jdbcType=VARCHAR}, #{item.stationId,jdbcType=VARCHAR}, #{item.orderCodes,jdbcType=LONGVARCHAR}, + #{item.useElectricity,jdbcType=DECIMAL}, #{item.chargeNum,jdbcType=VARCHAR}, #{item.chargeTime,jdbcType=VARCHAR}, + #{item.electricityAmount,jdbcType=DECIMAL}, #{item.serviceAmount,jdbcType=DECIMAL}, + #{item.totalAmount,jdbcType=DECIMAL}, #{item.virtualAmount,jdbcType=DECIMAL}, #{item.tradeDate,jdbcType=VARCHAR}, + #{item.tradeAmount,jdbcType=DECIMAL}, #{item.tradeFee,jdbcType=DECIMAL}, #{item.createTime,jdbcType=TIMESTAMP}, + #{item.delFlag,jdbcType=VARCHAR}) + + + + + insert into settle_order_report + + + id, + + merchant_id, + station_id, + order_codes, + use_electricity, + charge_num, + charge_time, + electricity_amount, + service_amount, + total_amount, + virtual_amount, + trade_date, + trade_amount, + trade_fee, + create_time, + del_flag, + + values + + + #{id,jdbcType=INTEGER}, + + #{merchantId,jdbcType=VARCHAR}, + #{stationId,jdbcType=VARCHAR}, + #{orderCodes,jdbcType=LONGVARCHAR}, + #{useElectricity,jdbcType=DECIMAL}, + #{chargeNum,jdbcType=VARCHAR}, + #{chargeTime,jdbcType=VARCHAR}, + #{electricityAmount,jdbcType=DECIMAL}, + #{serviceAmount,jdbcType=DECIMAL}, + #{totalAmount,jdbcType=DECIMAL}, + #{virtualAmount,jdbcType=DECIMAL}, + #{tradeDate,jdbcType=VARCHAR}, + #{tradeAmount,jdbcType=DECIMAL}, + #{tradeFee,jdbcType=DECIMAL}, + #{createTime,jdbcType=TIMESTAMP}, + #{delFlag,jdbcType=VARCHAR}, + + on duplicate key update + + + id = #{id,jdbcType=INTEGER}, + + merchant_id = #{merchantId,jdbcType=VARCHAR}, + station_id = #{stationId,jdbcType=VARCHAR}, + order_codes = #{orderCodes,jdbcType=LONGVARCHAR}, + use_electricity = #{useElectricity,jdbcType=DECIMAL}, + charge_num = #{chargeNum,jdbcType=VARCHAR}, + charge_time = #{chargeTime,jdbcType=VARCHAR}, + electricity_amount = #{electricityAmount,jdbcType=DECIMAL}, + service_amount = #{serviceAmount,jdbcType=DECIMAL}, + total_amount = #{totalAmount,jdbcType=DECIMAL}, + virtual_amount = #{virtualAmount,jdbcType=DECIMAL}, + trade_date = #{tradeDate,jdbcType=VARCHAR}, + trade_amount = #{tradeAmount,jdbcType=DECIMAL}, + trade_fee = #{tradeFee,jdbcType=DECIMAL}, + create_time = #{createTime,jdbcType=TIMESTAMP}, + del_flag = #{delFlag,jdbcType=VARCHAR}, + + + + + insert into settle_order_report + + + id, + + + merchant_id, + + + station_id, + + + order_codes, + + + use_electricity, + + + charge_num, + + + charge_time, + + + electricity_amount, + + + service_amount, + + + total_amount, + + + virtual_amount, + + + trade_date, + + + trade_amount, + + + trade_fee, + + + create_time, + + + del_flag, + + + values + + + #{id,jdbcType=INTEGER}, + + + #{merchantId,jdbcType=VARCHAR}, + + + #{stationId,jdbcType=VARCHAR}, + + + #{orderCodes,jdbcType=LONGVARCHAR}, + + + #{useElectricity,jdbcType=DECIMAL}, + + + #{chargeNum,jdbcType=VARCHAR}, + + + #{chargeTime,jdbcType=VARCHAR}, + + + #{electricityAmount,jdbcType=DECIMAL}, + + + #{serviceAmount,jdbcType=DECIMAL}, + + + #{totalAmount,jdbcType=DECIMAL}, + + + #{virtualAmount,jdbcType=DECIMAL}, + + + #{tradeDate,jdbcType=VARCHAR}, + + + #{tradeAmount,jdbcType=DECIMAL}, + + + #{tradeFee,jdbcType=DECIMAL}, + + + #{createTime,jdbcType=TIMESTAMP}, + + + #{delFlag,jdbcType=VARCHAR}, + + + on duplicate key update + + + id = #{id,jdbcType=INTEGER}, + + + merchant_id = #{merchantId,jdbcType=VARCHAR}, + + + station_id = #{stationId,jdbcType=VARCHAR}, + + + order_codes = #{orderCodes,jdbcType=LONGVARCHAR}, + + + use_electricity = #{useElectricity,jdbcType=DECIMAL}, + + + charge_num = #{chargeNum,jdbcType=VARCHAR}, + + + charge_time = #{chargeTime,jdbcType=VARCHAR}, + + + electricity_amount = #{electricityAmount,jdbcType=DECIMAL}, + + + service_amount = #{serviceAmount,jdbcType=DECIMAL}, + + + total_amount = #{totalAmount,jdbcType=DECIMAL}, + + + virtual_amount = #{virtualAmount,jdbcType=DECIMAL}, + + + trade_date = #{tradeDate,jdbcType=VARCHAR}, + + + trade_amount = #{tradeAmount,jdbcType=DECIMAL}, + + + trade_fee = #{tradeFee,jdbcType=DECIMAL}, + + + create_time = #{createTime,jdbcType=TIMESTAMP}, + + + del_flag = #{delFlag,jdbcType=VARCHAR}, + + + - - - - - - - - - - - - - - - - + + + + + + + + + + + + + + + + - select id, merchant_id, station_id, use_electricity, charge_num, charge_time, electricity_amount, service_amount, total_amount, virtual_amount, trade_date, trade_amount, trade_fee, create_time, del_flag from settle_order_report - - - - id, merchant_id, station_id, use_electricity, charge_num, charge_time, electricity_amount, service_amount, total_amount, virtual_amount, trade_date, trade_amount, trade_fee, create_time, del_flag + select + + from settle_order_report @@ -119,7 +776,7 @@ delete from settle_order_report where id in - + #{id} @@ -157,10 +814,18 @@ + + \ No newline at end of file