唯一查询和自增id
This commit is contained in:
parent
4af59cccb1
commit
afee8e3df2
@ -128,7 +128,7 @@ public class QueryStartChargeController {
|
|||||||
emptyHorder.setType(1);
|
emptyHorder.setType(1);
|
||||||
emptyHorder.setState(2);
|
emptyHorder.setState(2);
|
||||||
emptyHorder.setChargingStationId(REDIS.getCacheMapValue("pile:".concat(connectorId.substring(0, 14)), "stationId"));
|
emptyHorder.setChargingStationId(REDIS.getCacheMapValue("pile:".concat(connectorId.substring(0, 14)), "stationId"));
|
||||||
emptyHorder.setTerminalId(xhpcTerminalRepository.findOneBySerialNumber(connectorId).get().getTerminalId());
|
emptyHorder.setTerminalId(xhpcTerminalRepository.queryDbId(connectorId));
|
||||||
xhpcHistoryOrderRepository.save(emptyHorder);
|
xhpcHistoryOrderRepository.save(emptyHorder);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@ -25,6 +25,8 @@ public interface XhpcTerminalRepository extends JpaRepository<XhpcTerminal, Inte
|
|||||||
*/
|
*/
|
||||||
Optional<XhpcTerminal> findOneBySerialNumber(String serialNumber);
|
Optional<XhpcTerminal> findOneBySerialNumber(String serialNumber);
|
||||||
|
|
||||||
|
@Query("select t.terminalId from XhpcTerminal as t where t.delFlag = 0 and t.serialNumber = ?1")
|
||||||
|
Long queryDbId(String serialNumber);
|
||||||
|
|
||||||
@Query("select t.pileSerialNumber from XhpcTerminal as t where t.delFlag = 0 and t.serialNumber = ?1")
|
@Query("select t.pileSerialNumber from XhpcTerminal as t where t.delFlag = 0 and t.serialNumber = ?1")
|
||||||
String selectBySql(String serialNumber);
|
String selectBySql(String serialNumber);
|
||||||
|
|||||||
@ -3,10 +3,7 @@ package com.xhpc.order.domain;
|
|||||||
import com.xhpc.common.core.web.domain.BaseEntity;
|
import com.xhpc.common.core.web.domain.BaseEntity;
|
||||||
import com.xhpc.evcs.domain.XhpcStatisticsTimeInterval;
|
import com.xhpc.evcs.domain.XhpcStatisticsTimeInterval;
|
||||||
|
|
||||||
import javax.persistence.Entity;
|
import javax.persistence.*;
|
||||||
import javax.persistence.Id;
|
|
||||||
import javax.persistence.Table;
|
|
||||||
import javax.persistence.Transient;
|
|
||||||
import java.math.BigDecimal;
|
import java.math.BigDecimal;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
@ -25,6 +22,7 @@ public class XhpcHistoryOrder extends BaseEntity {
|
|||||||
* 历史订单id
|
* 历史订单id
|
||||||
*/
|
*/
|
||||||
@Id
|
@Id
|
||||||
|
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||||
private Long historyOrderId;
|
private Long historyOrderId;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user