Merge branch 'dev' of http://git.estsh.com/i3-IMPP/i3plus-pojo into dev

modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/codemaker/SnowflakeIdMaker.java

@@ -1,5 +1,6 @@
 package cn.estsh.i3plus.pojo.base.codemaker;
 
+import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import sun.management.VMManagement;
@@ -10,6 +11,7 @@ import java.lang.reflect.Field;
 import java.lang.reflect.Method;
 import java.net.InetAddress;
 import java.net.NetworkInterface;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * @Description : 使用SnowFlake，生成分布式ID
@@ -20,32 +22,73 @@ import java.net.NetworkInterface;
  * @CreateDate : 2018-09-11 16:35
  * @Modify:
  **/
-public class  SnowflakeIdMaker {
+public class SnowflakeIdMaker {
 
     public static final Logger LOGGER = LoggerFactory.getLogger(SnowflakeIdMaker.class);
 
+    private static final ConcurrentHashMap<String,SnowflakeIdMaker> RAM_CACHE_MAP = new ConcurrentHashMap();
+
     private long workerId;
     private long datacenterId;
     private long sequence = 0L;
 
-    public SnowflakeIdMaker(){
+    /**
+     * 禁止私自构建,防止ID重复
+     */
+    @Deprecated
+    private SnowflakeIdMaker() {
         this.workerId = getWorkerMacId();
         this.datacenterId = getDatacenterPid();
         this.sequence = 0L;
     }
 
-    public SnowflakeIdMaker(long workerId, long datacenterId){
+    /**
+     * 禁止私自构建 防止 ID 生成重复
+     * @param workerId      工作区ID
+     * @param datacenterId  数据区ID
+     */
+    private SnowflakeIdMaker(long workerId, long datacenterId) {
         if (workerId > maxWorkerId || workerId < 0) {
-            throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0",maxWorkerId));
+            throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));
         }
         if (datacenterId > maxDatacenterId || datacenterId < 0) {
-            throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0",maxDatacenterId));
+            throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0", maxDatacenterId));
         }
 
         this.workerId = workerId;
         this.datacenterId = datacenterId;
     }
 
+    /**
+     * 获取雪花生成器
+     * @param workerId 工作区ID
+     * @param softType 产品类型
+     * @return
+     */
+    public static SnowflakeIdMaker getSnowflakeIdMaker(long workerId, CommonEnumUtil.SOFT_TYPE softType) {
+        if(softType == null){
+            throw new IllegalArgumentException(String.format("The data warehouse soft type in the data center cannot be empty"));
+        }
+
+        return getSnowflakeIdMaker(workerId, softType.getSnowflakeId());
+    }
+
+    /**
+     * 获取雪花生成器
+     * @param workerId      工作区ID
+     * @param datacenterId  数据仓ID
+     * @return
+     */
+    public static SnowflakeIdMaker getSnowflakeIdMaker(long workerId, long datacenterId) {
+        String cacheKey = workerId + "_" + datacenterId;
+        SnowflakeIdMaker maker = RAM_CACHE_MAP.get(cacheKey);
+        if (maker == null) {
+            maker = new SnowflakeIdMaker(workerId, datacenterId);
+            RAM_CACHE_MAP.put(cacheKey, maker);
+        }
+        return maker;
+    }
+
     private long twepoch = 1288834974657L;
 
     private long workerIdBits = 5L;

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

@@ -17,35 +17,54 @@ public class CommonEnumUtil {
      */
     @JsonFormat(shape = JsonFormat.Shape.OBJECT)
     public enum SOFT_TYPE {
-        IMPP(1, "impp-platform", "IMPP平台"),
-        CORE(2, "i3core", "i3业务平台"),
-        WMS(3, "i3wms", "仓库管理软件"),
-        MES(4, "i3mes", "生产管理软件"),
-        QMS(5, "i3qms", "质量管理软件"),
-        MES_PCN(6, "i3mes-pcn", "生产管理软件-节点中心"),
-        SWEB(7, "i3sweb", "供应商服务"),
-
-        FORM(20,"block-form","智能表单"),
-        REPORT(21,"block-report","智能报表"),
-        WORKFLOW(22,"block-workflow","智能工作流"),
-        JOBFLOW(23,"block-jobflow","智能作业流"),
-        SOFTSWITCH(24,"block-softswitch","软件适配器"),
-        HARDSWITCH(25,"block-hardswitch","硬件适配器"),
-        LAC(26,"lac","连接适配器"),
-        ANDON(27,"andon","安灯"),
-        APS(28,"APS","高级计划与排程"),
-        CENTER(99,"icloud-server","注册中心"),
-        SURFACE(98,"i3surface","对外服务"),
-        CLOUD(97,"i3cloud","微服务"),
-        GATEWAY(96,"impp-gateway","服务网关"),
-        CONSOLE(95,"impp-console","服务监控台");
+        IMPP(1, 0, 0, "impp-platform", "IMPP平台"),
+        CORE(2, 8100, 4, "i3core", "i3业务平台"),
+        WMS(3, 8200, 10, "i3wms", "仓库管理软件"),
+        MES(4, 8300, 11, "i3mes", "生产管理软件"),
+        QMS(5, 0, 0, "i3qms", "质量管理软件"),
+        MES_PCN(6, 8350, 12, "i3mes-pcn", "生产管理软件-节点中心"),
+        SWEB(7, 8800, 19, "i3sweb", "供应商服务"),
+
+        FORM(20, 8900, 16, "block-form", "智能表单"),
+        REPORT(21, 8910, 17, "block-report", "智能报表"),
+        WORKFLOW(22, 0, 0, "block-workflow", "智能工作流"),
+        JOBFLOW(23, 0, 0, "block-jobflow", "智能作业流"),
+        SOFTSWITCH(24, 8920, 18, "block-softswitch", "软件适配器"),
+        HARDSWITCH(25, 0, 0, "block-hardswitch", "硬件适配器"),
+        LAC(26, 8600, 13, "lac", "连接适配器"),
+        ANDON(27, 8500, 14, "andon", "安灯"),
+        APS(28, 8410, 15, "APS", "高级计划与排程"),
+        CENTER(99, 8000, 1, "icloud-server", "注册中心"),
+        SURFACE(98, 0, 0, "i3surface", "对外服务"),
+        CLOUD(97, 0, 0, "i3cloud", "微服务"),
+        GATEWAY(96, 9000, 3, "impp-gateway", "服务网关"),
+        CONSOLE(95, 8010, 2, "impp-console", "服务监控台");
 
+        /**
+         * 产品ID
+         */
         private int value;
+        /**
+         * 应用默认端口
+         */
+        private int prot;
+        /**
+         * 应用默认雪花DataBaseId(0-31)共32 个存储区
+         */
+        private int snowflakeId;
+        /**
+         * 产品代码
+         */
         private String code;
+        /**
+         * 产品描述
+         */
         private String description;
 
-        private SOFT_TYPE(int value, String code, String description) {
+        SOFT_TYPE(int value, int prot, int snowflakeId, String code, String description) {
             this.value = value;
+            this.prot = prot;
+            this.snowflakeId = snowflakeId;
             this.code = code;
             this.description = description;
         }
@@ -62,6 +81,14 @@ public class CommonEnumUtil {
             return description;
         }
 
+        public int getProt() {
+            return prot;
+        }
+
+        public int getSnowflakeId() {
+            return snowflakeId;
+        }
+
         public static String valueOfCode(int val) {
             String tmp = null;
             for (int i = 0; i < values().length; i++) {
@@ -82,6 +109,15 @@ public class CommonEnumUtil {
             return tmp;
         }
 
+        public static SOFT_TYPE codeOf(String code) {
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].code.equals(code)) {
+                    return values()[i];
+                }
+            }
+            return null;
+        }
+
         public static String valueOfDescription(int val) {
             String tmp = null;
             for (int i = 0; i < values().length; i++) {

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

@@ -12,6 +12,145 @@ import com.fasterxml.jackson.annotation.JsonFormat;
 
 public class MesEnumUtil {
 
+    /**
+     * 包装规格-是否混包 MES_PACK_SPEC
+     * 10.
+     */
+    @JsonFormat(shape = JsonFormat.Shape.OBJECT)
+    public enum MES_PACK_SPEC_IS_MIXED {
+
+        TRUE(1, "是"),
+        FALSE(2, "否");
+
+        private int value;
+        private String description;
+
+        MES_PACK_SPEC_IS_MIXED(int value, String description) {
+            this.value = value;
+            this.description = description;
+        }
+
+        public int getValue() {
+            return value;
+        }
+
+        public String getDescription() {
+            return description;
+        }
+
+        public static String valueOfDescription(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 Integer descriptionOfValue(String description) {
+            Integer tmp = null;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].description.equals(description)) {
+                    tmp = values()[i].value;
+                }
+            }
+            return tmp;
+        }
+    }
+
+    /**
+     * PCN同步MES主数据同步类型枚举
+     */
+    @JsonFormat(shape = JsonFormat.Shape.OBJECT)
+    public enum SYNC_TYPE {
+
+        GET_MES_DATA(1, "pcn获取mes数据"),
+        DATA_TO_MES(2, "pcn推送数据至mes");
+
+        private int value;
+        private String description;
+
+        SYNC_TYPE(int value, String description) {
+            this.value = value;
+            this.description = description;
+        }
+
+        public int getValue() {
+            return value;
+        }
+
+        public String getDescription() {
+            return description;
+        }
+
+        public static String valueOfDescription(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 Integer descriptionOfValue(String description) {
+            Integer tmp = null;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].description.equals(description)) {
+                    tmp = values()[i].value;
+                }
+            }
+            return tmp;
+        }
+    }
+
+    /**
+     * PCN同步MES主数据同步方式枚举
+     */
+    @JsonFormat(shape = JsonFormat.Shape.OBJECT)
+    public enum SYNC_PATTERN {
+
+        UPDATE(1, "修改或新增"),
+        INSERT(2, "新增");
+
+        private int value;
+        private String description;
+
+        SYNC_PATTERN(int value, String description) {
+            this.value = value;
+            this.description = description;
+        }
+
+        public int getValue() {
+            return value;
+        }
+
+        public String getDescription() {
+            return description;
+        }
+
+        public static String valueOfDescription(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 Integer descriptionOfValue(String description) {
+            Integer tmp = null;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].description.equals(description)) {
+                    tmp = values()[i].value;
+                }
+            }
+            return tmp;
+        }
+    }
+
 
     /**
      * MES_TYPE_CFG 类型信息
@@ -443,6 +582,16 @@ public class MesEnumUtil {
             }
             return tmp;
         }
+
+        public static Integer descriptionOfValue(String description) {
+            Integer tmp = null;
+            for (int i = 0; i < values().length; i++) {
+                if (values()[i].description.equals(description)) {
+                    tmp = values()[i].value;
+                }
+            }
+            return tmp;
+        }
     }
 
     /**
@@ -1132,7 +1281,11 @@ public class MesEnumUtil {
         MES_PLAN_ORDER(10, "生产计划"),
         MES_EQUIPMENT(20, "设备台账"),
         MES_EQU_TASK_STANDARD(30, "设备作业要求"),
-        MES_CUST_ORDER(40, "客户订单");
+        MES_CUST_ORDER(40, "客户订单"),
+        MES_PCN_SYNC_CFG(50, "PCN同步配置"),
+        MES_PART(60, "物料表"),
+        MES_PRODUCE_CATEGORY(70, "产品类型"),
+        MES_PACK_SPEC(80, "包装规格");
 
         private int value;
         private String description;

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

@@ -950,6 +950,7 @@ public class WmsEnumUtil {
         INSTOCKED(40, "入库"),
         PICKED(50, "配料"),
         OUT_STOCK(60, "出库"),
+        SCRAP(70, "报废"),
         COMMING(80, "在途");
 
         private int value;

modules/i3plus-pojo-mes-pcn/src/main/java/cn/estsh/i3plus/pojo/mes/pcn/sqlpack/MesHqlPack.java

@@ -6,7 +6,7 @@ import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
 import cn.estsh.i3plus.pojo.base.enumutil.MesPcnEnumUtil;
 import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack;
 import cn.estsh.i3plus.pojo.mes.pcn.bean.*;
-import org.apache.commons.lang3.StringUtils;
+import org.springframework.util.StringUtils;
 
 /**
  * @Description:
@@ -54,13 +54,13 @@ public class MesHqlPack {
      */
     public static DdlPackBean getMesConfig(MesConfig mesConfig, String organizeCode) {
         DdlPackBean packBean = getAllBaseData(organizeCode);
-        if (StringUtils.isNotEmpty(mesConfig.getCfgCode())) {
+        if (!StringUtils.isEmpty(mesConfig.getCfgCode())) {
             DdlPreparedPack.getStringLikerPack(mesConfig.getCfgCode(), "cfgCode", packBean);
         }
-        if (StringUtils.isNotEmpty(mesConfig.getCfgName())) {
+        if (!StringUtils.isEmpty(mesConfig.getCfgName())) {
             DdlPreparedPack.getStringLikerPack(mesConfig.getCfgName(), "cfgName", packBean);
         }
-        if (mesConfig.getIsValid() != null) {
+        if (!StringUtils.isEmpty(mesConfig.getIsValid())) {
             DdlPreparedPack.getNumEqualPack(mesConfig.getIsValid(), "isValid", packBean);
         }
         return packBean;
@@ -120,34 +120,34 @@ public class MesHqlPack {
      */
     public static DdlPackBean getWorkOrderCondition(MesWorkOrder mesWorkOrder, String organizeCode) {
         DdlPackBean packBean = getAllBaseData(organizeCode);
-        if (StringUtils.isNotEmpty(mesWorkOrder.getOrderNo())) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getOrderNo())) {
             DdlPreparedPack.getStringLikerPack(mesWorkOrder.getOrderNo(), "orderNo", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getPartNo())) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getPartNo())) {
             DdlPreparedPack.getStringLikerPack(mesWorkOrder.getPartNo(), "partNo", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getWorkOrderStatus() + "") && mesWorkOrder.getWorkOrderStatusVal() != 0) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getWorkOrderStatus() + "") && mesWorkOrder.getWorkOrderStatusVal() != 0) {
             DdlPreparedPack.getNumEqualPack(mesWorkOrder.getWorkOrderStatus(), "workOrderStatus", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getWorkCenterCode())) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getWorkCenterCode())) {
             DdlPreparedPack.getStringEqualPack(mesWorkOrder.getWorkCenterCode(), "workCenterCode", packBean);
         }
-        if (mesWorkOrder.getApprovalStatus() != null) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getApprovalStatus())) {
             DdlPreparedPack.getNumEqualPack(mesWorkOrder.getApprovalStatus(), "approvalStatus", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getWorkOrderType() + "") && mesWorkOrder.getWorkOrderTypeVal() != 0) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getWorkOrderType() + "") && mesWorkOrder.getWorkOrderTypeVal() != 0) {
             DdlPreparedPack.getNumEqualPack(mesWorkOrder.getWorkOrderType(), "workOrderType", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getCustOrderNo())) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getCustOrderNo())) {
             DdlPreparedPack.getStringLikerPack(mesWorkOrder.getCustOrderNo(), "custOrderNo", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getPlanOrderNo())) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getPlanOrderNo())) {
             DdlPreparedPack.getStringLikerPack(mesWorkOrder.getPlanOrderNo(), "planOrderNo", packBean);
         }
-        if (StringUtils.isNotEmpty(mesWorkOrder.getCreateUser())) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getCreateUser())) {
             DdlPreparedPack.getStringLikerPack(mesWorkOrder.getCreateUser(), "createUser", packBean);
         }
-        if (mesWorkOrder.getIsValid() != null) {
+        if (!StringUtils.isEmpty(mesWorkOrder.getIsValid())) {
             DdlPreparedPack.getNumEqualPack(mesWorkOrder.getIsValid(), "isValid", packBean);
         }
 
@@ -181,19 +181,19 @@ public class MesHqlPack {
         DdlPreparedPack.getNumEqualPack(CommonEnumUtil.IS_VAILD.VAILD.getValue(), "isValid", packBean);
         DdlPreparedPack.getNumEqualPack(CommonEnumUtil.IS_DEAL.NO.getValue(), "isDeleted", packBean);
 
-        if (StringUtils.isNotEmpty(mesPart.getPartNo())) {
+        if (!StringUtils.isEmpty(mesPart.getPartNo())) {
             DdlPreparedPack.getStringLikerPack(mesPart.getPartNo(), "partNo", packBean);
         }
-        if (StringUtils.isNotEmpty(mesPart.getPartName())) {
+        if (!StringUtils.isEmpty(mesPart.getPartName())) {
             DdlPreparedPack.getStringLikerPack(mesPart.getPartName(), "partName", packBean);
         }
-        if (StringUtils.isNotEmpty(mesPart.getCategoryCode1())) {
+        if (!StringUtils.isEmpty(mesPart.getCategoryCode1())) {
             DdlPreparedPack.getStringEqualPack(mesPart.getCategoryCode1(), "categoryCode1", packBean);
         }
-        if (StringUtils.isNotEmpty(mesPart.getCategoryCode2())) {
+        if (!StringUtils.isEmpty(mesPart.getCategoryCode2())) {
             DdlPreparedPack.getStringEqualPack(mesPart.getCategoryCode2(), "categoryCode2", packBean);
         }
-        if (StringUtils.isNotEmpty(mesPart.getCategoryCode3())) {
+        if (!StringUtils.isEmpty(mesPart.getCategoryCode3())) {
             DdlPreparedPack.getStringEqualPack(mesPart.getCategoryCode3(), "categoryCode3", packBean);
         }
 
@@ -210,10 +210,10 @@ public class MesHqlPack {
      */
     public static DdlPackBean getMesCustomer(MesCustomer customer, String organizeCode) {
         DdlPackBean packBean = getAllBaseDataByNormalPro(customer, organizeCode);
-        if (StringUtils.isNotEmpty(customer.getCustomerCode())) {
+        if (!StringUtils.isEmpty(customer.getCustomerCode())) {
             DdlPreparedPack.getStringLikerPack(customer.getCustomerCode(), "customerCode", packBean);
         }
-        if (StringUtils.isNotEmpty(customer.getCustomerName())) {
+        if (!StringUtils.isEmpty(customer.getCustomerName())) {
             DdlPreparedPack.getStringLikerPack(customer.getCustomerName(), "customerName", packBean);
         }
 
@@ -228,13 +228,13 @@ public class MesHqlPack {
      */
     public static DdlPackBean getMesRepair(MesRepair mesRepair, String organizeCode) {
         DdlPackBean packBean = getAllBaseData(organizeCode);
-        if (StringUtils.isNotEmpty(mesRepair.getRepairCode())) {
+        if (!StringUtils.isEmpty(mesRepair.getRepairCode())) {
             DdlPreparedPack.getStringLikerPack(mesRepair.getRepairCode(), "repairCode", packBean);
         }
-        if (StringUtils.isNotEmpty(mesRepair.getRepairName())) {
+        if (!StringUtils.isEmpty(mesRepair.getRepairName())) {
             DdlPreparedPack.getStringLikerPack(mesRepair.getRepairName(), "repairName", packBean);
         }
-        if (mesRepair.getRepairType() != null) {
+        if (!StringUtils.isEmpty(mesRepair.getRepairType())) {
             DdlPreparedPack.getNumEqualPack(mesRepair.getRepairType(), "repairType", packBean);
         }
         return packBean;
@@ -248,13 +248,13 @@ public class MesHqlPack {
      */
     public static DdlPackBean getMesScrap(MesScrap mesScrap, String organizeCode) {
         DdlPackBean packBean = getAllBaseData(organizeCode);
-        if (StringUtils.isNotEmpty(mesScrap.getScrapCode())) {
+        if (!StringUtils.isEmpty(mesScrap.getScrapCode())) {
             DdlPreparedPack.getStringLikerPack(mesScrap.getScrapCode(), "scrapCode", packBean);
         }
-        if (StringUtils.isNotEmpty(mesScrap.getScrapName())) {
+        if (!StringUtils.isEmpty(mesScrap.getScrapName())) {
             DdlPreparedPack.getStringLikerPack(mesScrap.getScrapName(), "scrapName", packBean);
         }
-        if (StringUtils.isNotEmpty(mesScrap.getScrapType())) {
+        if (!StringUtils.isEmpty(mesScrap.getScrapType())) {
             DdlPreparedPack.getStringLikerPack(mesScrap.getScrapType(), "scrapType", packBean);
         }
         return packBean;
@@ -268,13 +268,13 @@ public class MesHqlPack {
      */
     public static DdlPackBean getMesDefectCause(MesDefectCause mesDefectCause, String organizeCode) {
         DdlPackBean packBean = getAllBaseData(organizeCode);
-        if (StringUtils.isNotEmpty(mesDefectCause.getDcCode())) {
+        if (!StringUtils.isEmpty(mesDefectCause.getDcCode())) {
             DdlPreparedPack.getStringLikerPack(mesDefectCause.getDcCode(), "dcCode", packBean);
         }
-        if (StringUtils.isNotEmpty(mesDefectCause.getDcName())) {
+        if (!StringUtils.isEmpty(mesDefectCause.getDcName())) {
             DdlPreparedPack.getStringLikerPack(mesDefectCause.getDcName(), "dcName", packBean);
         }
-        if (mesDefectCause.getDcType() != null) {
+        if (!StringUtils.isEmpty(mesDefectCause.getDcType())) {
             DdlPreparedPack.getNumEqualPack(mesDefectCause.getDcType(), "dcType", packBean);
         }
         return packBean;
@@ -324,19 +324,19 @@ public class MesHqlPack {
     public static DdlPackBean getPackageSnPrint(MesPackage mesPackage) {
 
         DdlPackBean packBean = getAllBaseData(mesPackage.getOrganizeCode());
-        if (!org.springframework.util.StringUtils.isEmpty(mesPackage.getPartNo())) {
+        if (!StringUtils.isEmpty(mesPackage.getPartNo())) {
             DdlPreparedPack.getStringLikerPack(mesPackage.getPartNo(), "partNo", packBean);
         }
 
-        if (!org.springframework.util.StringUtils.isEmpty(mesPackage.getPackLevel())) {
+        if (!StringUtils.isEmpty(mesPackage.getPackLevel())) {
             DdlPreparedPack.getNumEqualPack(mesPackage.getPackLevel(), "packLevel", packBean);
         }
 
-        if (!org.springframework.util.StringUtils.isEmpty(mesPackage.getPackageNo())) {
+        if (!StringUtils.isEmpty(mesPackage.getPackageNo())) {
             DdlPreparedPack.getStringLikerPack(mesPackage.getPackageNo(), "packageNo", packBean);
         }
 
-        if (!org.springframework.util.StringUtils.isEmpty(mesPackage.getWorkCenterCode())) {
+        if (!StringUtils.isEmpty(mesPackage.getWorkCenterCode())) {
             DdlPreparedPack.getStringLikerPack(mesPackage.getWorkCenterCode(), "workCenterCode", packBean);
         }
 

modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/model/DataSyncExtractConditionModel.java

@@ -0,0 +1,35 @@
+package cn.estsh.i3plus.pojo.mes.model;
+
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiParam;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * @Author: wangjie
+ * @CreateDate: 2019/8/21 9:19 AM
+ * @Description:
+ **/
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+@Api("MesPcnSyncCfg数据同步抽取条件model")
+public class DataSyncExtractConditionModel implements Serializable {
+
+    @ApiParam("字段")
+    private String field;
+
+    @ApiParam("条件")
+    private String condition;
+
+    @ApiParam("值")
+    private Object value;
+
+    @ApiParam("数据类型")
+    private Integer innerType;
+
+}

modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/model/ExcelImportErrorModel.java

@@ -18,7 +18,7 @@ import java.io.Serializable;
 @NoArgsConstructor
 @AllArgsConstructor
 @Api("mes导入异常结果model")
-public class MesExcelErrorModel implements Serializable {
+public class ExcelImportErrorModel implements Serializable {
 
     @ApiParam("错误的行号")
     private int rowNum;

modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/model/ExcelImportResultModel.java

@@ -19,7 +19,7 @@ import java.util.List;
 @NoArgsConstructor
 @AllArgsConstructor
 @Api("mes导入结果model")
-public class MesExcelResultModel<T> implements Serializable {
+public class ExcelImportResultModel<T> implements Serializable {
 
     @ApiParam("结果")
     private boolean result;
@@ -31,7 +31,7 @@ public class MesExcelResultModel<T> implements Serializable {
     private int failRowNum;
 
     @ApiParam("错误信息集合")
-    private List<MesExcelErrorModel> mesExcelErrorModel;
+    private List<ExcelImportErrorModel> excelImportErrorModels;
 
     @ApiParam("错误的行号")
     private String errorRows;

modules/i3plus-pojo-model/src/main/java/cn/estsh/i3plus/pojo/model/wms/WmsTaskInfoModel.java

@@ -56,12 +56,15 @@ public class WmsTaskInfoModel implements Serializable {
     @ApiParam(value = "创建日期")
     public String createDatetime;
 
+    @ApiParam(value = "创建人")
+    public String createUser;
+
     public WmsTaskInfoModel() {
     }
 
     public WmsTaskInfoModel(String orderNo, Integer taskStatus, String opTypeName, String transTypeCode, String refSrc,
                             String busiTypeDesc, String zdate, String ztime, String custNo, String vendorNo,
-                            String createDatetime, String srcZoneNo) {
+                            String createDatetime, String srcZoneNo, String createUser) {
         this.orderNo = orderNo;
         this.taskStatus = taskStatus;
         this.opTypeName = opTypeName;
@@ -74,5 +77,6 @@ public class WmsTaskInfoModel implements Serializable {
         this.vendorNo = vendorNo;
         this.createDatetime = createDatetime;
         this.srcZoneNo = srcZoneNo;
+        this.createUser = createUser;
     }
 }

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

@@ -330,11 +330,12 @@ public class WmsStockSn extends BaseBean {
         this.qty = qty;
     }
 
-    public WmsStockSn(String sn, String partNo, String partNameRdd, String unit, Integer snStatus,
+    public WmsStockSn(Long id,String sn, String partNo, String partNameRdd, String unit, Integer snStatus,
                       Integer qcStatus, Double qty, String locateNo, String zoneNo, String whNo, String lotNo,
                       String dateCode, String leftCode, String fixLotNo, String vendorNo, String vendorNameRdd,
                       String qualityDate, String custNo, String lotCheckRule, String sn2d,
                       String packageNo, String createDatetime, String createUser, String modifyDatetime, String modifyUser) {
+        this.id = id;
         this.sn = sn;
         this.partNo = partNo;
         this.partNameRdd = partNameRdd;

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

@@ -9,10 +9,7 @@ import org.hibernate.annotations.ColumnDefault;
 import org.hibernate.annotations.DynamicInsert;
 import org.hibernate.annotations.DynamicUpdate;
 
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.Index;
-import javax.persistence.Table;
+import javax.persistence.*;
 import java.math.BigDecimal;
 
 /**
@@ -31,7 +28,7 @@ import java.math.BigDecimal;
         @Index(columnList = "ORDER_NO"),
         @Index(columnList = "PART_NO"),
         @Index(columnList = "ITEM_STATUS")
-})
+}, uniqueConstraints = {@UniqueConstraint(columnNames = {"REF_SRC", "ITEM", "TRANS_TYPE_CODE_RDD"})})
 @Api("作业任务明细信息")
 public class WmsTaskDetails extends BaseBean {
 
@@ -143,6 +140,10 @@ public class WmsTaskDetails extends BaseBean {
     @ApiParam("业务类型描述")
     public String busiTypeDesc;
 
+    @Column(name = "TRANS_TYPE_CODE_RDD")
+    @ApiParam("交易类型")
+    public String transTypeCodeRdd;
+
     public Double getQty() {
         return this.qty == null ? 0 : this.qty;
     }