From 6b4fb1ac60dae6f968c5cb2bc8e0edb02657750b Mon Sep 17 00:00:00 2001 From: zhouxiunai <154707516@qq.com> Date: Tue, 8 Jan 2019 11:02:18 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84SEQN=20=E7=94=9F=E6=88=90?= =?UTF-8?q?=E7=AE=97=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gzzn/omms/msgexchangeapi/dao/CmoutmsgDao.java | 8 +++++++- .../msgexchangeapi/service/CmoutmsgServiceImpl.java | 12 +++++++++++- 2 files changed, 18 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/dao/CmoutmsgDao.java b/src/main/java/com/gzzn/omms/msgexchangeapi/dao/CmoutmsgDao.java index b42194c0..a03416af 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/dao/CmoutmsgDao.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/dao/CmoutmsgDao.java @@ -1,5 +1,6 @@ package com.gzzn.omms.msgexchangeapi.dao; +import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.CrudRepository; import com.gzzn.omms.msgexchangeapi.entity.Cmoutmsg; @@ -7,5 +8,10 @@ import com.gzzn.omms.msgexchangeapi.entity.Cmoutmsg; public interface CmoutmsgDao extends CrudRepository { - + /** + * 获取最大的id值 + * @return + */ + @Query("select max(coutmsgsId) from Cmoutmsg") + public Integer findMaxId(); } diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java b/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java index 230893bc..1118f291 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/service/CmoutmsgServiceImpl.java @@ -30,6 +30,16 @@ public class CmoutmsgServiceImpl implements ICmoutmsgService { public Boolean sendSchdGetMsg(Date startDate,Date endDate) { String nowtime = DateTimeUtil.gtFormatStr(new Date(), "yyMMddhhmmss", Locale.ENGLISH); + String seqn = "1"; + + // + Integer maxId = cmoutmsgDao.findMaxId(); + if(maxId != null) + { + seqn = String.valueOf(maxId + 1); + } + + //构造消息 MSG rqfdMsg = new MSGBuilder(). setMETA( @@ -38,7 +48,7 @@ public class CmoutmsgServiceImpl implements ICmoutmsgService { .setTYPE(MESSAGETYPES.RQFD) .setSTYP(MESSAGESUBTYPES.NONE) .setDTTM(new BigInteger(nowtime)) - .setSEQN(new BigInteger(nowtime)) + .setSEQN(new BigInteger(seqn)) .build() ) .build();