完善SEQN 生成算法

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<Cmoutmsg, Long> {
 
-	
+	/**
+	 * 获取最大的id值
+	 * @return
+	 */
+	@Query("select max(coutmsgsId) from Cmoutmsg")
+	public Integer findMaxId();
 }

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();