任务处理程序

modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/enumutil/WmsEnumUtil.java

@@ -11,6 +11,55 @@ import com.fasterxml.jackson.annotation.JsonFormat;
  **/
 public class WmsEnumUtil {
     /**
+     * 拆分规则
+     */
+    @JsonFormat(shape = JsonFormat.Shape.OBJECT)
+    public enum SPLIT_OR_MERGE_RULE {
+        WH(10, "WH", "仓库"), ZONE(20, "ZONE", "存储区"), PART(30, "PART", "物料");
+        private int value;
+        private String code;
+        private String description;
+
+        SPLIT_OR_MERGE_RULE(int value, String code, String description) {
+            this.value = value;
+            this.code = code;
+            this.description = description;
+        }
+
+        public int getValue() {
+            return value;
+        }
+
+        public String getDescription() {
+            return description;
+        }
+
+        public String getCode() {
+            return code;
+        }
+
+        public static String valueOf(int val) {
+            String tmp = null;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].value == val) {
+                    tmp = values()[i].description;
+                }
+            }
+            return tmp;
+        }
+
+        public static int descOf(String desc) {
+            int tmp = 1;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].description.equals(desc)) {
+                    tmp = values()[i].value;
+                }
+            }
+            return tmp;
+        }
+    }
+
+    /**
      * 订单明细信息 是否免费
      */
     @JsonFormat(shape = JsonFormat.Shape.OBJECT)
@@ -710,9 +759,14 @@ public class WmsEnumUtil {
      */
     @JsonFormat(shape = JsonFormat.Shape.OBJECT)
     public enum OUT_MOVEMENT_MASTER_LINK_ORDER_TYPE {
-        ASN(1, "ASN"),
-        PO(10, "PO"),
-        SO(20, "SO");
+        ASN(10, "ASN"),
+        PO(20, "PO"),
+        SO(30, "SO"),
+        MOVE(40, "MOVE"),
+        IN_STOCK(50, "IN_STOCK"),
+        SHIPPING(60, "SHIPPING"),
+        QC(70, "QC"),
+        CS(80, "CS");
 
         private int value;
         private String description;
@@ -776,6 +830,40 @@ public class WmsEnumUtil {
     }
 
     /**
+     * 单据是否生成任务状态
+     */
+    @JsonFormat(shape = JsonFormat.Shape.OBJECT)
+    public enum IS_GENERAL_TASK {
+        CREATE(10, "创建"), INIT(20, "初始化"), IS_GENERAL(30, "已生成"), NO_GENERAL(40, "不生成");
+
+        private int value;
+        private String description;
+
+        IS_GENERAL_TASK(int value, String description) {
+            this.value = value;
+            this.description = description;
+        }
+
+        public int getValue() {
+            return value;
+        }
+
+        public String getDescription() {
+            return description;
+        }
+
+        public static String valueOf(int val) {
+            String tmp = null;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].value == val) {
+                    tmp = values()[i].description;
+                }
+            }
+            return tmp;
+        }
+    }
+
+    /**
      * 业务表：库存条码状态
      * 1=创建，10=质检中，20=待入库，30=入库，40=配料，50=出库，60=报废，70=在途
      */
@@ -992,7 +1080,7 @@ public class WmsEnumUtil {
      */
     @JsonFormat(shape = JsonFormat.Shape.OBJECT)
     public enum CS_ITEM_STATUS {
-        CREATE(1, "创建"),FINISH(10, "已处理");
+        CREATE(1, "创建"), FINISH(10, "已处理");
 
         private int value;
         private String description;
@@ -1174,9 +1262,9 @@ public class WmsEnumUtil {
      */
     @JsonFormat(shape = JsonFormat.Shape.OBJECT)
     public enum ALD_EXECUTE_STATUS {
-        NORMAL(1, "创建"),
-        PROCESSING(10, "处理中"),
-        COMPLETED(20, "已完成");
+        NORMAL(10, "创建"),
+        PROCESSING(20, "处理中"),
+        COMPLETED(30, "已完成");
         private int value;
         private String description;
 
@@ -1497,9 +1585,10 @@ public class WmsEnumUtil {
             return tmp;
         }
     }
+
     /**
      * 流程明细动作类型
-     *  10=交互动作,20=后台动作,30=提交动作
+     * 10=交互动作,20=后台动作,30=提交动作
      */
     @JsonFormat(shape = JsonFormat.Shape.OBJECT)
     public enum GROUP_VALUE_TYPE {

modules/i3plus-pojo-wms/pom.xml

@@ -23,6 +23,10 @@
             <groupId>i3plus.pojo</groupId>
             <artifactId>i3plus-pojo-base</artifactId>
         </dependency>
+        <dependency>
+            <groupId>i3plus.platform</groupId>
+            <artifactId>i3plus-platform-common</artifactId>
+        </dependency>
     </dependencies>
 
 

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsASNMaster.java

@@ -7,10 +7,12 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.annotation.Transient;
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.Table;
+import java.util.List;
 
 /**
  * @Description : ASN订单主表
@@ -24,11 +26,11 @@ import javax.persistence.Table;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="WMS_DOC_ASN_MASTER")
+@Table(name = "WMS_DOC_ASN_MASTER")
 @Api("ASN主表信息")
 public class WmsASNMaster extends BaseBean {
 
-    @Column(name="ORDER_NO")
+    @Column(name = "ORDER_NO")
     @ApiParam("订单号")
     public String orderNo;
 
@@ -36,7 +38,7 @@ public class WmsASNMaster extends BaseBean {
      * 单据类型:REG=原物料采购,
      * SUB=委外采购,TAR=多角贸易采购,TAP=多角代采购
      */
-    @Column(name="ASN_TYPE")
+    @Column(name = "ASN_TYPE")
     @ApiParam("单据类型")
     public String asnType;
 
@@ -44,23 +46,23 @@ public class WmsASNMaster extends BaseBean {
      * 状态:1=新建,10=收货中,20=收货完成,
      * 30=入库中,40=入库完成,90=已关闭,91=已取消
      */
-    @Column(name="ASN_STATUS")
+    @Column(name = "ASN_STATUS")
     @ApiParam(value = "状态", example = "0")
     public Integer asnStatus;
 
-    @Column(name="VENDOR_NO")
+    @Column(name = "VENDOR_NO")
     @ApiParam("供应商编号")
     public String vendorNo;
 
-    @Column(name="VERSION")
+    @Column(name = "VERSION")
     @ApiParam("版本")
     public String version;
 
-    @Column(name="SRC")
+    @Column(name = "SRC")
     @ApiParam("单据来源")
     public String src;
 
-    @Column(name="PO_NO")
+    @Column(name = "PO_NO")
     @ApiParam("PO单号")
     public String poNo;
 
@@ -68,7 +70,11 @@ public class WmsASNMaster extends BaseBean {
     @ApiParam("集装箱号")
     public String containerNo;
 
-    @Column(name="IS_TASK")
+    @Column(name = "IS_TASK")
     @ApiParam(value = "是否生产任务", example = "1")
     public Integer isTask;
+
+    @Transient
+    @ApiParam(value = "单据明细集合")
+    public List<WmsASNMasterDetails> wmsASNMasterDetailsList;
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsASNMasterDetails.java

@@ -7,10 +7,12 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.annotation.Transient;
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.Table;
+import java.util.List;
 
 /**
  * @Description : ASN订单明细信息
@@ -109,4 +111,5 @@ public class WmsASNMasterDetails extends BaseBean {
     @Column(name="REC_QTY")
     @ApiParam(value = "已收数量", example = "0")
     public Double recQty;
+
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsCSOrderMaster.java

@@ -7,10 +7,12 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.annotation.Transient;
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.Table;
+import java.util.List;
 
 /**
  * @Description : 盘点单主表信息
@@ -24,11 +26,11 @@ import javax.persistence.Table;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="WMS_DOC_CS_ORDER")
+@Table(name = "WMS_DOC_CS_ORDER")
 @Api("盘点单主表信息")
 public class WmsCSOrderMaster extends BaseBean {
 
-    @Column(name="ORDER_NO")
+    @Column(name = "ORDER_NO")
     @ApiParam("单号")
     public String orderNo;
 
@@ -36,23 +38,28 @@ public class WmsCSOrderMaster extends BaseBean {
      * 单据类型:10=日常盘点,20=月度盘点,
      * 30=季度盘点,40=年度盘点
      */
-    @Column(name="ORDER_TYPE")
+    @Column(name = "ORDER_TYPE")
     @ApiParam(value = "单据类型", example = "10")
     public Integer orderType;
 
-    @Column(name="ORDER_STATUS")
-    @ApiParam(value = "状态 (1-创建 10-已冻结 20-盘点中  30-盘点完成  40-已解冻  50-已关闭)", example = "1" )
+    @Column(name = "ORDER_STATUS")
+    @ApiParam(value = "状态 (1-创建 10-已冻结 20-盘点中  30-盘点完成  40-已解冻  50-已关闭)", example = "1")
     public Integer orderStatus;
 
-    @Column(name="ACTION_PERSENT")
+    @Column(name = "ACTION_PERSENT")
     @ApiParam("盘点进度")
     public String actionPersent;
 
-    @Column(name="REMARK")
+    @Column(name = "REMARK")
     @ApiParam("备注")
     public String reMark;
 
-    @Column(name="IS_INVENTORY")
+    @Column(name = "IS_INVENTORY")
     @ApiParam(value = "是否允许清点", example = "1")
     public Integer isInventory;
+
+    @Transient
+    @ApiParam(value = "盘点明细集")
+    public List<WmsCSOrderDetails> wmsCSOrderDetailsList;
+
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsDocMovementDetails.java

@@ -13,7 +13,7 @@ import javax.persistence.Entity;
 import javax.persistence.Table;
 
 /**
- * @Description :移库单详情实体(用于转储类业务)
+ * @Description :移库单明细实体(用于转储类业务)
  * @Reference :
  * @Author : dragon.xu
  * @CreateDate : 2018-11-13 16:06
@@ -25,7 +25,7 @@ import javax.persistence.Table;
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
 @Table(name = "WMS_DOC_MOVEMENT_DETAILS")
-@Api("移库单详情表")
+@Api("移库单明细表")
 public class WmsDocMovementDetails extends BaseBean {
     @Column(name = "ORDER_NO")
     @ApiParam(value = "单号")
@@ -47,13 +47,29 @@ public class WmsDocMovementDetails extends BaseBean {
     @ApiParam(value = "单位")
     private String unit;
 
-    @Column(name = "SRC_WH")
-    @ApiParam(value = "发出库仓库")
-    private String srcWh;
+    @Column(name = "SRC_WH_NO")
+    @ApiParam("源仓库代码")
+    public String srcWhNo;
 
-    @Column(name = "DEST_WH")
-    @ApiParam(value = "接收库仓库")
-    private String destWh;
+    @Column(name = "SRC_ZONE_NO")
+    @ApiParam("源存储区代码")
+    public String srcZoneNo;
+
+    @Column(name = "SRC_LOCATE_NO")
+    @ApiParam("源库位代码")
+    public String srcLocateNo;
+
+    @Column(name = "DEST_WH_NO")
+    @ApiParam("目标仓库代码")
+    public String destWhNo;
+
+    @Column(name = "DEST_ZONE_NO")
+    @ApiParam("目标存储区代码")
+    public String destZoneNo;
+
+    @Column(name = "DEST_LOCATE_NO")
+    @ApiParam("目标库位代码")
+    public String destLocateNo;
 
     @Column(name = "QTY")
     @ApiParam(value = "需求数量", example = "1")

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsDocMovementMaster.java

@@ -7,10 +7,12 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.annotation.Transient;
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.Table;
+import java.util.List;
 
 /**
  * @Description :移库单实体(用于转储类业务)
@@ -99,12 +101,15 @@ public class WmsDocMovementMaster extends BaseBean {
     @ApiParam(value = "数量", example = "1")
     private Double qty;
 
-    @Column(name="IS_TASK")
+    @Column(name = "IS_TASK")
     @ApiParam(value = "是否生产任务", example = "1")
     public Integer isTask;
 
-    @Column(name="PRIORITY")
+    @Column(name = "PRIORITY")
     @ApiParam(value = "优先级", example = "1")
     public Integer priority;
 
+    @Transient
+    @ApiParam(value = "移库单明细集合")
+    private List<WmsDocMovementDetails> wmsDocMovementDetailsList;
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsMoveDetails.java

@@ -66,11 +66,11 @@ public class WmsMoveDetails extends BaseBean {
     public String unit;
 
     @Column(name="SRC_WH_NO")
-    @ApiParam("仓库代码")
+    @ApiParam("源仓库代码")
     public String srcWhNo;
 
     @Column(name="SRC_ZONE_NO")
-    @ApiParam("存储区代码")
+    @ApiParam("源存储区代码")
     public String srcZoneNo;
 
     @Column(name="SRC_LOCATE_NO")

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsMoveMaster.java

@@ -7,10 +7,12 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.annotation.Transient;
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.Table;
+import java.util.List;
 
 /**
  * @Description : 库存移动单主表信息
@@ -24,26 +26,27 @@ import javax.persistence.Table;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="WMS_MOVE_MASTER")
+@Table(name = "WMS_MOVE_MASTER")
 @Api("库存移动单主表信息")
 public class WmsMoveMaster extends BaseBean {
 
-    @Column(name="ORDER_NO")
+    @Column(name = "ORDER_NO")
     @ApiParam("单号")
     public String orderNo;
 
     /**
      * 状态:1=创建,10=待处理,20=已处理
      */
-    @Column(name="ORDER_STATUS")
+    @Column(name = "ORDER_STATUS")
     @ApiParam(value = "状态", example = "0")
     public Integer orderStatus;
 
-    @Column(name="REMARK")
+    @Column(name = "REMARK")
     @ApiParam("备注")
     public String reMark;
 
     @Column(name = "TRANS_TYPE_CODE")
     @ApiParam(value = "交易类型代码")
     private String transTypeCode;
+
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsOpType.java

@@ -9,11 +9,13 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
+import org.springframework.data.annotation.Transient;
 
 import javax.persistence.Column;
 import javax.persistence.Entity;
 import javax.persistence.Table;
-import javax.persistence.Transient;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @Description : 作业类型
@@ -27,15 +29,15 @@ import javax.persistence.Transient;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="WMS_OP_TYPE")
+@Table(name = "WMS_OP_TYPE")
 @Api("作业类型")
-public class WmsOpType extends BaseBean{
+public class WmsOpType extends BaseBean {
 
-    @Column(name="OP_TYPE_CODE")
+    @Column(name = "OP_TYPE_CODE")
     @ApiParam("类型编号")
     private String opTypeCode;
 
-    @Column(name="OP_TYPE_NAME")
+    @Column(name = "OP_TYPE_NAME")
     @ApiParam("类型名称")
     private String opTypeName;
 
@@ -43,61 +45,65 @@ public class WmsOpType extends BaseBean{
     @ApiParam(value = "序号", example = "0")
     private Integer seq;
 
-    @Column(name="TM_ID")
+    @Column(name = "TM_ID")
     @ApiParam(value = "交易处理组件ID", example = "0")
     private Integer tmId;
 
-    @Column(name="DATA_SRC")
+    @Column(name = "DATA_SRC")
     @ApiParam("数据来源")
     private String dataSrc;
 
-    @Column(name="ORDER_MIN")
+    @Column(name = "ORDER_MIN")
     @ApiParam(value = "单据处理下限", example = "0")
     private Integer orderMin;
 
-    @Column(name="ORDER_MAX")
+    @Column(name = "ORDER_MAX")
     @ApiParam(value = "单据处理上限", example = "0")
     private Integer orderMax;
 
-    @Column(name="CYCLE_MINS")
+    @Column(name = "CYCLE_MINS")
     @ApiParam(value = "处理周期(分钟)", example = "0")
     private Integer cycleMins;
 
-    @Column(name="LAST_TRANS_TIME")
+    @Column(name = "LAST_TRANS_TIME")
     @ApiParam(value = "末次处理时间")
     public String lastTransTime;
 
     @Transient
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
-    @ApiParam(value="末次处理时间",example = "2018-01-01 01:00:00")
+    @ApiParam(value = "末次处理时间", example = "2018-01-01 01:00:00")
     @AnnoOutputColumn(hidden = true)
     public String lastTransTimeStr;
 
-    @Column(name="IS_SPLIT")
+    @Column(name = "IS_SPLIT")
     @ApiParam(value = "是否拆分单据", example = "0")
     private Integer isSplit;
 
-    @Column(name="SPLIT_RULE")
+    @Column(name = "SPLIT_RULE")
     @ApiParam(value = "拆分规则")
     public String splitRule;
 
-    @Column(name="IS_MERGE")
+    @Column(name = "IS_MERGE")
     @ApiParam(value = "是否合并单据", example = "0")
     private Integer isMerge;
 
-    @Column(name="MERGE_RULE")
+    @Column(name = "MERGE_RULE")
     @ApiParam(value = "合并规则")
     public String mergeRule;
 
-    @Column(name="IS_AUTO_CLOSE")
+    @Column(name = "IS_AUTO_CLOSE")
     @ApiParam(value = "任务未完是否关闭", example = "0")
     private Integer isAutoClose;
 
-    @Column(name="USE_TIME")
+    @Column(name = "USE_TIME")
     @ApiParam(value = "标准工时(每箱)", example = "0")
     private Integer userTime;
 
-    @Column(name="IS_MULITI")
+    @Column(name = "IS_MULITI")
     @ApiParam(value = "是否允许多人操作", example = "0")
     private Integer isMuliti;
+
+    @Transient
+    @ApiParam(value = "单据集")
+    private List<Map<String, List>> orderList;
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsTaskInfo.java

@@ -24,38 +24,42 @@ import javax.persistence.Table;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="WMS_TASK")
+@Table(name = "WMS_TASK")
 @Api("作业任务表")
 public class WmsTaskInfo extends BaseBean {
 
-    @Column(name="MOVE_NO")
+    @Column(name = "ORDER_NO")
+    @ApiParam("单号")
+    public String orderNo;
+
+    @Column(name = "MOVE_NO")
     @ApiParam("移动单号")
     public String moveNo;
 
-    @Column(name="USER_NO")
+    @Column(name = "USER_NO")
     @ApiParam("作业人员")
     public String userNo;
 
-    @Column(name="OP_TYPE_CODE")
+    @Column(name = "OP_TYPE_CODE")
     @ApiParam("作业类型")
     public String opTypeCode;
 
-    @Column(name="REMARK")
+    @Column(name = "REMARK")
     @ApiParam("备注")
     public String reMark;
 
     /**
      * 状态:1=创建,10=待处理,20=已处理
      */
-    @Column(name="TASK_STATUS")
+    @Column(name = "TASK_STATUS")
     @ApiParam(value = "任务状态", example = "1")
     public Integer taskStatus;
 
-    @Column(name="TRANS_TYPE_CODE")
+    @Column(name = "TRANS_TYPE_CODE")
     @ApiParam("交易类型")
     private String transTypeCode;
 
-    @Column(name="PRE_USE_TIME")
+    @Column(name = "PRE_USE_TIME")
     @ApiParam(value = "预计作业时间(分钟)", example = "1")
     public Integer preUseTime;
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/WmsTaskSrc.java

@@ -24,19 +24,31 @@ import javax.persistence.Table;
 @DynamicInsert
 @DynamicUpdate
 @EqualsAndHashCode(callSuper = true)
-@Table(name="WMS_TASK_SRC")
+@Table(name = "WMS_TASK_SRC")
 @Api("作业任务表")
 public class WmsTaskSrc extends BaseBean {
 
-    @Column(name="OP_TYPE_CODE")
+    @Column(name = "OP_TYPE_CODE")
     @ApiParam("作业类型编号")
     public String opTypeCode;
 
-    @Column(name="ORDER_TYPE")
-    @ApiParam("业务类型")
-    public String orderType;
-
-    @Column(name="DATA_SRC")
+    @Column(name = "DATA_SRC")
     @ApiParam("数据来源")
     public String dataSrc;
+
+    @Column(name = "BUSI_TYPE")
+    @ApiParam("业务类型")
+    public String busiType;
+
+    @Column(name = "PRIORITY")
+    @ApiParam("优先级")
+    public String priority;
+
+    @Column(name = "IS_SN")
+    @ApiParam("是否有条码")
+    public String isSn;
+
+    @Column(name = "TRANS_CODE")
+    @ApiParam("默认交易类型")
+    public String transCode;
 }

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsOpTypeRepository.java

@@ -5,7 +5,7 @@ import cn.estsh.i3plus.pojo.wms.bean.WmsOpType;
 import org.springframework.stereotype.Repository;
 
 /**
- * @Description : 作业类型
+ * @Description : 作业类型DAO层
  * @Reference :
  * @Author : amy
  * @CreateDate : 2018-11-07 14:46

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsTaskDetailsRepository.java

@@ -0,0 +1,17 @@
+package cn.estsh.i3plus.pojo.wms.repository;
+
+import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
+import cn.estsh.i3plus.pojo.wms.bean.WmsTaskDetails;
+import cn.estsh.i3plus.pojo.wms.bean.WmsTaskInfo;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @Description : 对象持久层公用方法控制(作业任务明细信息)
+ * @Reference :
+ * @Author : dragon.xu
+ * @CreateDate : 2019-03-06 17:16
+ * @Modify:
+ **/
+@Repository
+public interface WmsTaskDetailsRepository extends BaseRepository<WmsTaskDetails, Long> {
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsTaskSrcRepository.java

@@ -0,0 +1,17 @@
+package cn.estsh.i3plus.pojo.wms.repository;
+
+import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
+import cn.estsh.i3plus.pojo.wms.bean.WmsOpType;
+import cn.estsh.i3plus.pojo.wms.bean.WmsTaskSrc;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @Description : 作业任务数据来源DAO层
+ * @Reference :
+ * @Author : dragon.xu
+ * @CreateDate : 2019-03-06 14:41
+ * @Modify:
+ **/
+@Repository
+public interface WmsTaskSrcRepository extends BaseRepository<WmsTaskSrc, Long> {
+}

modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/sqlpack/WmsHqlPack.java

@@ -1,11 +1,17 @@
 package cn.estsh.i3plus.pojo.wms.sqlpack;
 
+import cn.estsh.i3plus.platform.common.tool.TimeTool;
 import cn.estsh.i3plus.pojo.base.bean.BaseBean;
 import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
+import cn.estsh.i3plus.pojo.base.enumutil.WmsEnumUtil;
 import cn.estsh.i3plus.pojo.base.tool.HqlPack;
 import cn.estsh.i3plus.pojo.base.tool.SqlPack;
 import cn.estsh.i3plus.pojo.wms.bean.*;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.time.DateUtils;
+
+import java.util.Date;
+import java.util.List;
 
 /**
  * @Description : 仓库管理对象封装
@@ -18,7 +24,8 @@ public class WmsHqlPack {
 
     /**
      * 封装公用查询参数
-     * @param bean 实体对象
+     *
+     * @param bean   实体对象
      * @param hqlStr 查询语句
      * @return 封装完成的查询语句
      */
@@ -59,7 +66,7 @@ public class WmsHqlPack {
     }
 
     /**
-     * 库存移动单详情查询封装
+     * 库存移库单明细查询封装
      *
      * @param wmsDocMovementDetails
      * @return
@@ -76,6 +83,28 @@ public class WmsHqlPack {
     }
 
     /**
+     * 查询任务合并的移库单明细 查询条件封装
+     *
+     * @param orderNos
+     * @return
+     */
+    public static String packHqlWmsDocMovementDetailsByOrderNos(List<String> orderNos) {
+        StringBuffer result = new StringBuffer();
+        StringBuffer orderNoStr = new StringBuffer();
+        for (int i = 0; i < orderNos.size(); i++) {
+            if (i == orderNos.size()) {
+                orderNoStr.append("'" + orderNos.get(i) + "'");
+            } else {
+                orderNoStr.append("'" + orderNos.get(i) + "',");
+            }
+        }
+        result.append(" and model.isDeleted=" + CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() +
+                "and model.isValid=" + CommonEnumUtil.IS_VAILD.VAILD.getValue() +
+                "and model.orderNo in (" + orderNos + ")" + " order by model.partNo,model.orderNo");
+        return result.toString();
+    }
+
+    /**
      * 库存移动单查询封装
      *
      * @param wmsDocMovementMaster
@@ -183,10 +212,10 @@ public class WmsHqlPack {
         HqlPack.getStringLikerPack(wmsIbCheckPlan.getPartNameRdd(), "partNameRdd", result);
         getStringBuilderPack(wmsIbCheckPlan, result);
 
-        if(wmsIbCheckPlan.getStartDateStart() != null || wmsIbCheckPlan.getStartDateEnd() != null) {
+        if (wmsIbCheckPlan.getStartDateStart() != null || wmsIbCheckPlan.getStartDateEnd() != null) {
             HqlPack.timeBuilder(wmsIbCheckPlan.getStartDateStart(), wmsIbCheckPlan.getStartDateEnd(), "startDate", result, false);
         }
-        if(wmsIbCheckPlan.getEndDateStart() != null || wmsIbCheckPlan.getEndDateEnd() != null) {
+        if (wmsIbCheckPlan.getEndDateStart() != null || wmsIbCheckPlan.getEndDateEnd() != null) {
             HqlPack.timeBuilder(wmsIbCheckPlan.getEndDateStart(), wmsIbCheckPlan.getEndDateEnd(), "endDate", result, false);
         }
 
@@ -373,8 +402,38 @@ public class WmsHqlPack {
 
         HqlPack.getStringEqualPack(wmsOpType.getOpTypeCode(), "opTypeCode", result);
         HqlPack.getStringLikerPack(wmsOpType.getOpTypeName(), "opTypeName", result);
+        getStringBuilderPack(wmsOpType, result);
+
+        return result.toString();
+    }
+
+    /**
+     * 查询满足处理周期的作业类型 查询条件封装
+     *
+     * @param wmsOpType
+     * @return
+     */
+    public static String packHqlWmsOpTypeTime(WmsOpType wmsOpType) {
+        StringBuffer result = new StringBuffer();
 
         getStringBuilderPack(wmsOpType, result);
+        result.append(" and isnull(model.lastTransTime) or timestampdiff(Minute,nvl(model.lastTransTime,'2000'),now()) >= model.cycleMins");
+        return result.toString();
+    }
+
+    /**
+     * 作业任务数据来源 查询条件封装
+     *
+     * @param wmsTaskSrc
+     * @return
+     */
+    public static String packHqlWmsTaskSrc(WmsTaskSrc wmsTaskSrc) {
+        StringBuffer result = new StringBuffer();
+
+        //作业类型代码
+        HqlPack.getStringLikerPack(wmsTaskSrc.getOpTypeCode(), "opTypeCode", result);
+
+        getStringBuilderPack(wmsTaskSrc, result);
 
         return result.toString();
     }
@@ -395,7 +454,7 @@ public class WmsHqlPack {
         //存储区代码
         HqlPack.getStringLikerPack(wmsZones.getZoneNo(), "zoneNo", result);
         //存储区名称
-        HqlPack.getStringLikerPack(wmsZones.getZoneName(),"zoneName", result);
+        HqlPack.getStringLikerPack(wmsZones.getZoneName(), "zoneName", result);
 
         getStringBuilderPack(wmsZones, result);
 
@@ -461,7 +520,7 @@ public class WmsHqlPack {
         HqlPack.getStringLikerPack(wmsASNMaster.getSrc(), "src", result);
         HqlPack.getStringEqualPack(wmsASNMaster.getPoNo(), "poNo", result);
 
-        getStringBuilderPack(wmsASNMaster,result);
+        getStringBuilderPack(wmsASNMaster, result);
 
         return result.toString();
     }
@@ -540,7 +599,7 @@ public class WmsHqlPack {
         HqlPack.getStringEqualPack(wmsASNMasterDetails.getErpWhNo(), "erpWhNo", result);
         HqlPack.getStringEqualPack(wmsASNMasterDetails.getVendorLotNo(), "vendorLotNo", result);
 
-        getStringBuilderPack(wmsASNMasterDetails,result);
+        getStringBuilderPack(wmsASNMasterDetails, result);
 
         return result.toString();
     }
@@ -598,6 +657,7 @@ public class WmsHqlPack {
 
     /**
      * 根据条件查询打印机队列信息封装类
+     *
      * @param wmsSnPrint 打印机队列信息
      * @return 打印机队列信息
      */
@@ -620,10 +680,11 @@ public class WmsHqlPack {
 
     /**
      * 盘点库位 条件封装
+     *
      * @param wmsCSLocate
      * @return
      */
-    public static String packHqlWmsCSLocate(WmsCSLocate wmsCSLocate){
+    public static String packHqlWmsCSLocate(WmsCSLocate wmsCSLocate) {
         StringBuffer result = new StringBuffer();
 
         HqlPack.getStringEqualPack(wmsCSLocate.getOrderNo(), "orderNo", result);
@@ -636,15 +697,16 @@ public class WmsHqlPack {
 
     /**
      * 盘点物料 条件封装
+     *
      * @param wmsCSPart
      * @return
      */
-    public static String packHqlWmsCSPart(WmsCSPart wmsCSPart){
+    public static String packHqlWmsCSPart(WmsCSPart wmsCSPart) {
         StringBuffer result = new StringBuffer();
 
-        HqlPack.getStringEqualPack(wmsCSPart.getOrderNo(),"orderNo", result);
-        HqlPack.getStringEqualPack(wmsCSPart.getPartNo(),"partNo", result);
-        HqlPack.getStringLikerPack(wmsCSPart.getPartNameRdd(),"partNameRdd", result);
+        HqlPack.getStringEqualPack(wmsCSPart.getOrderNo(), "orderNo", result);
+        HqlPack.getStringEqualPack(wmsCSPart.getPartNo(), "partNo", result);
+        HqlPack.getStringLikerPack(wmsCSPart.getPartNameRdd(), "partNameRdd", result);
 
         getStringBuilderPack(wmsCSPart, result);
 
@@ -653,10 +715,11 @@ public class WmsHqlPack {
 
     /**
      * 盘点存储区 条件封装
+     *
      * @param wmsCSZone
      * @return
      */
-    public static String packHqlWmsCSZone(WmsCSZone wmsCSZone){
+    public static String packHqlWmsCSZone(WmsCSZone wmsCSZone) {
         StringBuffer result = new StringBuffer();
 
         HqlPack.getStringEqualPack(wmsCSZone.getOrderNo(), "orderNo", result);
@@ -669,6 +732,7 @@ public class WmsHqlPack {
 
     /**
      * 根据条件查询责任区分配信息封装类
+     *
      * @param wmsAreaOwner 责任区分配信息
      * @return 责任区分配信息
      */
@@ -695,6 +759,7 @@ public class WmsHqlPack {
 
     /**
      * 根据条件查询责任区分配信息封装类
+     *
      * @param wmsTempOrderLock 责任区分配信息
      * @return 责任区分配信息
      */
@@ -805,16 +870,18 @@ public class WmsHqlPack {
 
         return result.toString();
     }
+
     /**
-     *内部单据：库存移动单主表唯一性查询
+     * 内部单据：库存移动单主表唯一性查询
+     *
      * @param wmsMoveMaster
      * @return
      */
-    public static String packWmsMoveMasterUnique(WmsMoveMaster wmsMoveMaster){
+    public static String packWmsMoveMasterUnique(WmsMoveMaster wmsMoveMaster) {
         StringBuffer result = new StringBuffer();
 
         HqlPack.getStringEqualPack(wmsMoveMaster.getOrderNo(), "orderNo", result);
-        HqlPack.getNumNOEqualPack(wmsMoveMaster.getId(),"id",result);
+        HqlPack.getNumNOEqualPack(wmsMoveMaster.getId(), "id", result);
 
         getStringBuilderPack(wmsMoveMaster, result);
 
@@ -823,14 +890,15 @@ public class WmsHqlPack {
 
     /**
      * 内部单据：库存移动单主表分页查询
+     *
      * @param wmsMoveMaster
      * @return
      */
-    public static String packHqlWmsMoveMaster(WmsMoveMaster wmsMoveMaster){
+    public static String packHqlWmsMoveMaster(WmsMoveMaster wmsMoveMaster) {
         StringBuffer result = new StringBuffer();
 
         HqlPack.getStringEqualPack(wmsMoveMaster.getOrderNo(), "orderNo", result);
-        HqlPack.getNumEqualPack(wmsMoveMaster.getOrderStatus(),"orderStatus",result);
+        HqlPack.getNumEqualPack(wmsMoveMaster.getOrderStatus(), "orderStatus", result);
         HqlPack.getStringEqualPack(wmsMoveMaster.getTransTypeCode(), "transTypeCode", result);
         getStringBuilderPack(wmsMoveMaster, result);
 
@@ -839,10 +907,11 @@ public class WmsHqlPack {
 
     /**
      * 内部单据：库存移动单明细表分页查询
+     *
      * @param wmsMoveDetails
      * @return
      */
-    public static String packHqlWmsMoveDetails(WmsMoveDetails wmsMoveDetails){
+    public static String packHqlWmsMoveDetails(WmsMoveDetails wmsMoveDetails) {
         StringBuffer result = new StringBuffer();
 
         HqlPack.getStringEqualPack(wmsMoveDetails.getOrderNo(), "orderNo", result);
@@ -852,15 +921,15 @@ public class WmsHqlPack {
         HqlPack.getStringEqualPack(wmsMoveDetails.getVendorNo(), "vendorNo", result);
         HqlPack.getStringEqualPack(wmsMoveDetails.getCustNo(), "custNo", result);
         HqlPack.getStringEqualPack(wmsMoveDetails.getUnit(), "unit", result);
-        HqlPack.getStringEqualPack(wmsMoveDetails.getSrcWhNo(),"srcWhNo",result);
-        HqlPack.getStringEqualPack(wmsMoveDetails.getDestWhNo(),"destWhNo",result);
-        HqlPack.getStringEqualPack(wmsMoveDetails.getSrcZoneNo(),"srcZoneNo",result);
-        HqlPack.getStringEqualPack(wmsMoveDetails.getDestZoneNo(),"destZoneNo",result);
-        HqlPack.getStringEqualPack(wmsMoveDetails.getSrcLocateNo(),"srcLocateNo",result);
-        HqlPack.getStringEqualPack(wmsMoveDetails.getDestLocateNo(),"destLocateNo",result);
-        HqlPack.getNumEqualPack(wmsMoveDetails.getItemStatus(),"itemStatus",result);
-        HqlPack.getNumEqualPack(wmsMoveDetails.getRefType(),"refType",result);
-        HqlPack.getStringLikerPack(wmsMoveDetails.getRefSrc(),"refSrc",result);
+        HqlPack.getStringEqualPack(wmsMoveDetails.getSrcWhNo(), "srcWhNo", result);
+        HqlPack.getStringEqualPack(wmsMoveDetails.getDestWhNo(), "destWhNo", result);
+        HqlPack.getStringEqualPack(wmsMoveDetails.getSrcZoneNo(), "srcZoneNo", result);
+        HqlPack.getStringEqualPack(wmsMoveDetails.getDestZoneNo(), "destZoneNo", result);
+        HqlPack.getStringEqualPack(wmsMoveDetails.getSrcLocateNo(), "srcLocateNo", result);
+        HqlPack.getStringEqualPack(wmsMoveDetails.getDestLocateNo(), "destLocateNo", result);
+        HqlPack.getNumEqualPack(wmsMoveDetails.getItemStatus(), "itemStatus", result);
+        HqlPack.getNumEqualPack(wmsMoveDetails.getRefType(), "refType", result);
+        HqlPack.getStringLikerPack(wmsMoveDetails.getRefSrc(), "refSrc", result);
 
         getStringBuilderPack(wmsMoveDetails, result);
 
@@ -869,10 +938,11 @@ public class WmsHqlPack {
 
     /**
      * 内部单据：库存移动单条码信息分页查询
+     *
      * @param wmsMoveSn
      * @return
      */
-    public static String packHqlWmsMoveSn(WmsMoveSn wmsMoveSn){
+    public static String packHqlWmsMoveSn(WmsMoveSn wmsMoveSn) {
         StringBuffer result = new StringBuffer();
 
         HqlPack.getStringEqualPack(wmsMoveSn.getOrderNo(), "orderNo", result);
@@ -1092,9 +1162,10 @@ public class WmsHqlPack {
 
     /**
      * 作业流程分页查询
+     *
      * @return
      */
-    public static String packHqlWmsActionGroup(WmsActionGroup wmsActionGroup){
+    public static String packHqlWmsActionGroup(WmsActionGroup wmsActionGroup) {
         StringBuffer result = new StringBuffer();
 
         //查询参数封装 agDescC;agNameC
@@ -1107,9 +1178,10 @@ public class WmsHqlPack {
 
     /**
      * 作业流程明细分页查询
+     *
      * @return
      */
-    public static String packHqlWmsActionGroupDetails(WmsActionGroupDetails wmsActionGroupDetails){
+    public static String packHqlWmsActionGroupDetails(WmsActionGroupDetails wmsActionGroupDetails) {
         StringBuffer result = new StringBuffer();
 
         //查询参数封装
@@ -1156,6 +1228,7 @@ public class WmsHqlPack {
 
     /**
      * 作业记录 查询条件封装
+     *
      * @param wmsActionLog
      * @return
      */
@@ -1163,19 +1236,19 @@ public class WmsHqlPack {
         StringBuffer result = new StringBuffer();
 
         if (wmsActionLog.getStartTimeStart() != null || wmsActionLog.getStartTimeEnd() != null) {
-            HqlPack.timeBuilder(wmsActionLog.getStartTimeStart(),wmsActionLog.getStartTimeEnd(),
+            HqlPack.timeBuilder(wmsActionLog.getStartTimeStart(), wmsActionLog.getStartTimeEnd(),
                     "startTime", result, true);
         } else if (wmsActionLog.getEndTimeStart() != null || wmsActionLog.getEndTimeEnd() != null) {
-            HqlPack.timeBuilder(wmsActionLog.getEndTimeStart(),wmsActionLog.getEndTimeEnd(),
+            HqlPack.timeBuilder(wmsActionLog.getEndTimeStart(), wmsActionLog.getEndTimeEnd(),
                     "endTime", result, true);
         }
 
         // 作业流程编号
-        HqlPack.getNumEqualPack(wmsActionLog.getAgId(),"agId",result);
+        HqlPack.getNumEqualPack(wmsActionLog.getAgId(), "agId", result);
         // 作业流程名称
-        HqlPack.getStringLikerPack(wmsActionLog.getAgNameC(),"agNameC",result);
+        HqlPack.getStringLikerPack(wmsActionLog.getAgNameC(), "agNameC", result);
         // 单据编号
-        HqlPack.getStringLikerPack(wmsActionLog.getOrderNo(),"orderNo",result);
+        HqlPack.getStringLikerPack(wmsActionLog.getOrderNo(), "orderNo", result);
 
         getStringBuilderPack(wmsActionLog, result);
 
@@ -1184,15 +1257,16 @@ public class WmsHqlPack {
 
     /**
      * 作业记录明细 查询条件封装
+     *
      * @param wmsActionLogDetails
      * @return
      */
-    public static String packHqlWmsActionLogDetails(WmsActionLogDetails wmsActionLogDetails){
+    public static String packHqlWmsActionLogDetails(WmsActionLogDetails wmsActionLogDetails) {
         StringBuffer result = new StringBuffer();
 
         //作业流程id（对应作业记录明细里自增的id）
-        HqlPack.getNumEqualPack(wmsActionLogDetails.getAlId(),"alId",result);
-        HqlPack.getNumEqualPack(wmsActionLogDetails.getSeq(),"seq",result);
+        HqlPack.getNumEqualPack(wmsActionLogDetails.getAlId(), "alId", result);
+        HqlPack.getNumEqualPack(wmsActionLogDetails.getSeq(), "seq", result);
         HqlPack.getNumEqualPack(wmsActionLogDetails.getOkSeq(), "okSeq", result);
         HqlPack.getNumEqualPack(wmsActionLogDetails.getNgSeq(), "ngSeq", result);
         HqlPack.getNumEqualPack(wmsActionLogDetails.getValueType(), "valueType", result);
@@ -1224,14 +1298,15 @@ public class WmsHqlPack {
     }
 
     /**
-     *  按moveNo 取最后一笔插入的数据
+     * 按moveNo 取最后一笔插入的数据
+     *
      * @param wmsMoveSn
      * @return
      */
     public static String packHqlLastWmsMoveSn(WmsMoveSn wmsMoveSn) {
         StringBuffer result = new StringBuffer();
 
-        HqlPack.getStringEqualPack(wmsMoveSn.getOrderNo(),"orderNo", result);
+        HqlPack.getStringEqualPack(wmsMoveSn.getOrderNo(), "orderNo", result);
         getStringBuilderPack(wmsMoveSn, result);
         HqlPack.getOrderByPack(new Object[]{2}, new String[]{"createDatetime"}, result);
 
@@ -1239,19 +1314,21 @@ public class WmsHqlPack {
     }
 
     /**
-     *  根据条件查询库存条码信息
+     * 根据条件查询库存条码信息
+     *
      * @param wmsStockSn
      * @return
      */
     public static String packHqlWmsStockSn(WmsStockSn wmsStockSn) {
         StringBuffer result = new StringBuffer();
 
-        HqlPack.getStringEqualPack(wmsStockSn.getSn(),"sn", result);
-        HqlPack.getStringEqualPack(wmsStockSn.getSn2d(),"sn2d", result);
-        HqlPack.getStringEqualPack(wmsStockSn.getLocateNo(),"locateNo", result);
-        HqlPack.getNumEqualPack(wmsStockSn.getSnStatus(),"snStatus", result);
-        HqlPack.getNumEqualPack(wmsStockSn.getQcStatus(),"qcStatus", result);
+        HqlPack.getStringEqualPack(wmsStockSn.getSn(), "sn", result);
+        HqlPack.getStringEqualPack(wmsStockSn.getSn2d(), "sn2d", result);
+        HqlPack.getStringEqualPack(wmsStockSn.getLocateNo(), "locateNo", result);
+        HqlPack.getNumEqualPack(wmsStockSn.getSnStatus(), "snStatus", result);
+        HqlPack.getNumEqualPack(wmsStockSn.getQcStatus(), "qcStatus", result);
         getStringBuilderPack(wmsStockSn, result);
+
         return result.toString();
     }
 }