定时任务

单号生成规则

modules/i3plus-pojo-platform/src/main/java/cn/estsh/i3plus/pojo/platform/bean/SysOrderNoRule.java

@@ -1,6 +1,8 @@
 package cn.estsh.i3plus.pojo.platform.bean;
 
 import cn.estsh.i3plus.pojo.base.bean.BaseBean;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiParam;
 import lombok.Data;
@@ -24,7 +26,7 @@ import javax.persistence.Table;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="SYS_NUMBER_RULE")
+@Table(name="SYS_ORDER_RULE")
 @Api(value="单号规则",description = "单号规则")
 public class SysOrderNoRule extends BaseBean {
 
@@ -36,36 +38,39 @@ public class SysOrderNoRule extends BaseBean {
     @ApiParam(value = "规则代码")
     private String orderNoRuleCode;
 
-
     @Column(name = "numberRule")
     @ApiParam(value = "单号规则")
     private String orderNoRule;
 
     @Column(name = "SERIAL_NO_SEED")
     @ApiParam(value = "流水号种子",example = "-1")
-    private Integer serialNoSeed;
+    @JsonSerialize(using = ToStringSerializer.class)
+    private Long serialNoSeed;
 
     @Column(name = "ORDER_NO_INCREMENT")
     @ApiParam(value = "流水号步长",example = "-1")
-    private Integer serialNoIncrement;
+    @JsonSerialize(using = ToStringSerializer.class)
+    private Long serialNoIncrement;
 
     @Column(name = "SERIAL_NO_LENGTH")
     @ApiParam(value = "流水号长度",example = "-1")
-    private Integer serialNoLength;
+    @JsonSerialize(using = ToStringSerializer.class)
+    private Long serialNoLength;
 
     @Column(name = "IS_CYCLE")
     @ApiParam(value = "达到最大值后是否循环",example = "1")
     private Integer isCycle;
 
-    @Column(name = "LAST_MAKE_SERIAL_NO")
+    @Column(name = "SERIAL_NO")
-    @ApiParam(value = "上次新增流水号",example = "-1")
+    @ApiParam(value = "当前流水号",example = "-1")
-    private Integer lastMakeSerialNo;
+    @JsonSerialize(using = ToStringSerializer.class)
+    private Long serialNo;
 
-    @Column(name = "LAST_MAKE_ORDER_NO")
+    @Column(name = "ORDER_NO")
-    @ApiParam(value = "上次新增单号")
+    @ApiParam(value = "当前单号")
-    private String lastMakeOrderNo;
+    private String orderNo;
 
-    @Column(name = "LAST_MAKE_DATE")
+    @Column(name = "ORDER_NO_RULE_STATUS")
-    @ApiParam(value = "上次新增时间")
+    @ApiParam(value = "单号规则状态")
-    private String lastMakeDatetime;
+    private Integer orderNoRuleStatus;
 }

modules/i3plus-pojo-platform/src/main/java/cn/estsh/i3plus/pojo/platform/bean/SysRefUserMessage.java

@@ -43,6 +43,10 @@ public class SysRefUserMessage extends BaseBean {
     @ApiParam(value ="冗余消息类型")
     private Integer messageTypeRdd;
 
+    @Column(name="MESSAGE_SENDER_NAME_RDD")
+    @ApiParam(value ="冗余发件人名称")
+    private String messageSenderNameRdd;
+
     @Column(name="RECEIVER_ID")
     @ApiParam(value ="接收者ID" ,example = "-1")
     @JsonSerialize(using = ToStringSerializer.class)

modules/i3plus-pojo-platform/src/main/java/cn/estsh/i3plus/pojo/platform/bean/SysTaskTimeExpression.java

@@ -33,10 +33,6 @@ public class SysTaskTimeExpression extends BaseBean {
     @ApiParam(value ="名称")
     private String name;
 
-    @Column(name="GROUP_NAME")
-    @ApiParam(value ="组名称")
-    private String groupName;
-
     @Column(name="EXPRESSION_CONTENT")
     @ApiParam(value ="表达式内容")
     private String expressionContent;

modules/i3plus-pojo-platform/src/main/java/cn/estsh/i3plus/pojo/platform/sqlpack/CoreHqlPack.java

@@ -243,11 +243,10 @@ public class CoreHqlPack {
         // hql拼接
         HqlPack.getStringLikerPack(message.getMessageTitle(),"messageTitle",result);
         HqlPack.getStringLikerPack(message.getMessageContent(),"messageContent",result);
-//        HqlPack.getNumLikerPack(sysMessage.getMessageStatusId(),"messageStatusId",result);
+        HqlPack.getNumEqualPack(message.getMessageType(),"messageType",result);
-//        HqlPack.getNumLikerPack(sysMessage.getMessageTypeId(),"messageTypeId",result);
+        HqlPack.getStringLikerPack(message.getMessageSenderNameRdd(),"messageSenderNameRdd",result);
-//        HqlPack.getNumEqualPack(sysMessage.getMessageRecipientId(),"messageRecipientId",result);
+        HqlPack.getStringLikerPack(message.getMessageReceiversNameRdd(),"messageReceiversNameRdd",result);
-//        HqlPack.getNumEqualPack(sysMessage.getMessageSendId(),"messageSendId",result);
+        HqlPack.timeBuilder(message.getMessageSendTime(),"messageSendTime", result, false,false);
-        HqlPack.timeBuilder(message.getCreateDatetime(),"createDatetime", result, false,false);
 
         return  result.toString();
     }
@@ -395,7 +394,7 @@ public class CoreHqlPack {
         StringBuffer result = new StringBuffer();
 
         // and
-        HqlPack.getStringEqualPack(sysOrderNoRule.getOrderNoRuleCode(),"dictionaryCode",result);
+        HqlPack.getStringEqualPack(sysOrderNoRule.getOrderNoRuleCode(),"orderNoRuleCode",result);
         // not
         HqlPack.getNumNOEqualPack(sysOrderNoRule.getId(),"id",result);
 
@@ -415,4 +414,19 @@ public class CoreHqlPack {
 
         return result.toString();
     }
+
+    /**
+     * 用户消息关系表负责查询
+     * @param sysRefUserMessage
+     * @return
+     */
+    public static String packHqlSysRefUserMessage(SysRefUserMessage sysRefUserMessage){
+        StringBuffer result =  new StringBuffer();
+
+        HqlPack.getStringLikerPack(sysRefUserMessage.getMessageTitleRdd(),"messageTitleRdd",result);
+        HqlPack.getStringLikerPack(sysRefUserMessage.getMessageSenderNameRdd(),"messageSenderNameRdd",result);
+        HqlPack.getStringLikerPack(sysRefUserMessage.getReceiverTime(),"receiverTime",result);
+
+        return result.toString();
+    }
 }