使用漂移雪花算法生成id

yangys

2024-01-19 334d000fbd4fef1051a40bef6f55ee270c0cfd94

使用漂移雪花算法生成id

 mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/collector/moxa/MoxaCollector.java

@@ -31,7 +31,7 @@
        Integer port = machine.getPort();
        MachiningData mdcData = new MachiningData();
        mdcData.setMachineId(machine.getId());
        //MachiningData lastMdcData = new MachiningData();// ??new?
		
        MoxaClient moxaClient = new MoxaClient();

        try {
@@ -63,6 +63,7 @@

    private void insertOrUpdate(MachiningData data) {
        int time = (int) TimestampUtils.getCurrentTimestamp();
        data.setMdcTime(time);
        /*
        //老的实现，为了减少数据的插入？
        if (this.lastMdcData.equals(machine)) {
@@ -87,16 +88,15 @@
        //先简单做，直接插入
        //有问题，不可能相等，时间不同
        MachiningData lastData = machiningDataMapper.lastOneByMachineId(data.getMachineId());
        //2当前数据与库内最新数据设置相同的时间，就能equals了
        lastData.setUpdateTime(time);
        data.setUpdateTime(time);
		
        data.setId(lastData.getId());
		
        if(data.equals(lastData)) {//如果数据无变化
        if(lastData == null) {//该机床没有历史数据，直接新增
            machiningDataMapper.insert(data);
            return;
        }

        if(data.equalsMachineData(lastData)) {//如果数据无变化,只更新updatetime
            lastData.setUpdateTime(time);
            machiningDataMapper.updateById(lastData);
        }else {
            data.setId(null);
        }else {//加工数据变化了，加入新的数据
            data.setMdcTime(time);
            machiningDataMapper.insert(data);
        }

 mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/domain/MachiningData.java

@@ -310,6 +310,65 @@
        this.isPartComplete = isPartComplete;

    }



    /**

     * æ¯”较2个对象加工数据是否相同，如状态，进给倍率，主轴转速刀具号等（不比较id,mdcTime,updateDate这些和加工无关的属性）

     * @param that

     * @return

     */

    public boolean equalsMachineData(Object that) {

        if (this == that)

            return true;

        if (that == null)

            return false;

        if (getClass() != that.getClass())

            return false;

        com.qianwen.mdc.domain.MachiningData other = (com.qianwen.mdc.domain.MachiningData) that;

        if (((getMachineId() == null) ? (other.getMachineId() == null)

                        : getMachineId().equals(other.getMachineId()))

				
                && ((getState() == null) ? (other.getState() == null) : getState().equals(other.getState())))

            if (((getMode() == null) ? (other.getMode() == null) : getMode().equals(other.getMode()))

                    && ((getOpMode() == null) ? (other.getOpMode() == null) : getOpMode().equals(other.getOpMode()))

                    && ((getSpindleSpeed() == null) ? (other.getSpindleSpeed() == null)

                            : getSpindleSpeed().equals(other.getSpindleSpeed()))

                    && ((getSpindleOverride() == null) ? (other.getSpindleOverride() == null)

                            : getSpindleOverride().equals(other.getSpindleOverride()))

                    && ((getSpindleLoad() == null) ? (other.getSpindleLoad() == null)

                            : getSpindleLoad().equals(other.getSpindleLoad()))

                    && ((getFeedrateOverride() == null) ? (other.getFeedrateOverride() == null)

                            : getFeedrateOverride().equals(other.getFeedrateOverride()))

                    && ((getFeedRate() == null) ? (other.getFeedRate() == null)

                            : getFeedRate().equals(other.getFeedRate()))

                    && ((getRapidFeedOverride() == null) ? (other.getRapidFeedOverride() == null)

                            : getRapidFeedOverride().equals(other.getRapidFeedOverride()))

                    && ((getRapidFeed() == null) ? (other.getRapidFeed() == null)

                            : getRapidFeed().equals(other.getRapidFeed()))

                    && ((getProgName() == null) ? (other.getProgName() == null)

                            : getProgName().equals(other.getProgName()))

                    && ((getProgBlock() == null) ? (other.getProgBlock() == null)

                            : getProgBlock().equals(other.getProgBlock()))

                    && ((getAlarmNo() == null) ? (other.getAlarmNo() == null) : getAlarmNo().equals(other.getAlarmNo()))

                    && ((getAlarmMsg() == null) ? (other.getAlarmMsg() == null)

                            : getAlarmMsg().equals(other.getAlarmMsg()))

                    && ((getToolNo() == null) ? (other.getToolNo() == null) : getToolNo().equals(other.getToolNo()))

                    && ((getToolName() == null) ? (other.getToolName() == null)

                            : getToolName().equals(other.getToolName()))

                    && ((getOperId() == null) ? (other.getOperId() == null) : getOperId().equals(other.getOperId()))

                    && ((getAxisNames() == null) ? (other.getAxisNames() == null)

                            : getAxisNames().equals(other.getAxisNames()))

                    && ((getAxisAbsolute() == null) ? (other.getAxisAbsolute() == null)

                            : getAxisAbsolute().equals(other.getAxisAbsolute()))

                    && ((getAxisRelative() == null) ? (other.getAxisRelative() == null)

                            : getAxisRelative().equals(other.getAxisRelative()))

                    && ((getAxisServoloads() == null) ? (other.getAxisServoloads() == null)

                            : getAxisServoloads().equals(other.getAxisServoloads()))

                    && ((getIsMaintain() == null) ? (other.getIsMaintain() == null)

                            : getIsMaintain().equals(other.getIsMaintain()))

                    && ((getIsPartComplete() == null) ? (other.getIsPartComplete() == null)

                            : getIsPartComplete().equals(other.getIsPartComplete())))

                ;

        return false;

    }

    public String toString() {

        StringBuilder sb = new StringBuilder();

        sb.append(getClass().getSimpleName());


 mdc-parent/mdc-collect/src/main/resources/application-dev.yml

@@ -46,4 +46,4 @@
    cache: false



collect:

  interval: 10000
  interval: 30000

 mdc-parent/mdc-show/pom.xml

@@ -125,9 +125,13 @@
        </dependency>





        <!--mybatis-->





        <!--雪花漂移ID生成器-->

        <dependency>

            <groupId>io.github.lmlx66</groupId>

            <artifactId>yitter-idgenerator-spring-boot-starter</artifactId>

            <version>1.1.3-RELEASE</version>

        </dependency>

		
        <!--pagehelper-->

        <!-- 

        <dependency>

@@ -223,6 +227,7 @@
                        </goals>

                        <configuration>

                            <outputDirectory>${project.build.directory}/lib</outputDirectory>

                            <includeScope>runtime</includeScope>

                        </configuration>

                    </execution>

                </executions>


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/config/WFGIdGeneratorConfig.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,34 @@
package com.qianwen.mdc.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.hy.properties.IdGeneratorOptions;

/**
 * æ¼‚移雪花算法的option生成配置
 */
@Configuration
public class WFGIdGeneratorConfig {

    @Autowired
    private WfgProperties wftProperties;
	
    @Bean(name="idGeneratorOptions") //bean的name必须为该值!!!
    public IdGeneratorOptions buildOptions() {
        IdGeneratorOptions options = new IdGeneratorOptions();
        options.setBaseTime(wftProperties.getBaseTime());
		
        options.setWorkerId(wftProperties.getWorkerId());
        options.setDataCenterId((short)wftProperties.getDataCenterId());
        options.setDataCenterIdBitLength(wftProperties.getDataCenterIdBitLength());
        options.setMaxSeqNumber(wftProperties.getMaxSeqNumber());
        options.setMethod(wftProperties.getMethod());
        options.setMinSeqNumber(wftProperties.getMinSeqNumber());
        options.setSeqBitLength(wftProperties.getSeqBitLength());
        options.setTopOverCostCount(wftProperties.getTopOverCostCount());
        options.setWorkerIdBitLength(wftProperties.getWorkerIdBitLength());
        return options;
    }
}

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/config/WfgProperties.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,89 @@
package com.qianwen.mdc.config;

import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "wfg")
public class WfgProperties {
    private short method;
    private short workerId;

    private long baseTime;
    // # æ•°æ®ä¸­å¿ƒid
    private short dataCenterId;
    // # æ•°æ®ä¸­å¿ƒid位长，默认为0表示不开启数据中心id功能
    private byte dataCenterIdBitLength;
    // # æœºå™¨ç ï¼ˆå½“前系统的机器码）
    // # æœºå™¨ç ä½é•¿ï¼ˆèƒ½è¡¨ç¤ºæœºå™¨ç çš„最大值）
    private byte workerIdBitLength;
    // # åºåˆ—数位长（能表示机器码的最大序列数）
    private byte seqBitLength;
    // # æœ€å¤§åºåˆ—数（含）
    private short minSeqNumber;
    // # æœ€å°åºåˆ—数（含）
    private short maxSeqNumber;
    // # æœ€å¤§æ¼‚移次数，与计算能力有关
    private short topOverCostCount;
    public short getMethod() {
        return method;
    }
    public void setMethod(short method) {
        this.method = method;
    }
    public short getWorkerId() {
        return workerId;
    }
    public void setWorkerId(short workerId) {
        this.workerId = workerId;
    }
    public long getBaseTime() {
        return baseTime;
    }
    public void setBaseTime(long baseTime) {
        this.baseTime = baseTime;
    }
    public short getDataCenterId() {
        return dataCenterId;
    }
    public void setDataCenterId(short dataCenterId) {
        this.dataCenterId = dataCenterId;
    }
    public byte getDataCenterIdBitLength() {
        return dataCenterIdBitLength;
    }
    public void setDataCenterIdBitLength(byte dataCenterIdBitLength) {
        this.dataCenterIdBitLength = dataCenterIdBitLength;
    }
    public byte getWorkerIdBitLength() {
        return workerIdBitLength;
    }
    public void setWorkerIdBitLength(byte workerIdBitLength) {
        this.workerIdBitLength = workerIdBitLength;
    }
    public byte getSeqBitLength() {
        return seqBitLength;
    }
    public void setSeqBitLength(byte seqBitLength) {
        this.seqBitLength = seqBitLength;
    }
    public short getMinSeqNumber() {
        return minSeqNumber;
    }
    public void setMinSeqNumber(short minSeqNumber) {
        this.minSeqNumber = minSeqNumber;
    }
    public short getMaxSeqNumber() {
        return maxSeqNumber;
    }
    public void setMaxSeqNumber(short maxSeqNumber) {
        this.maxSeqNumber = maxSeqNumber;
    }
    public short getTopOverCostCount() {
        return topOverCostCount;
    }
    public void setTopOverCostCount(short topOverCostCount) {
        this.topOverCostCount = topOverCostCount;
    }
	
}

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/AccountToken.java

@@ -13,18 +13,14 @@
 */

@TableName("account_token")

public class AccountToken implements Serializable {

    /**

     * primary key

     */

    //@Id

    //@GeneratedValue(strategy = GenerationType.IDENTITY)

    @TableId(type=IdType.AUTO)

    private Integer id;



    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * 

     */

    private Integer userId;

    private Long userId;



    /**

     * 

@@ -43,7 +39,7 @@
     *

     * @return id - primary key

     */

    public Integer getId() {

    public Long getId() {

        return id;

    }



@@ -52,7 +48,7 @@
     *

     * @param id primary key

     */

    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



@@ -61,24 +57,14 @@
     *

     * @return user - user id

     */

    public Integer getUserId() {

    public Long getUserId() {

        return userId;

    }



    /**

     * è®¾ç½®user id

     *

     * @param user user id

     */

    public void setUserId(Integer userId) {

    public void setUserId(Long userId) {

        this.userId = userId;

    }



    /**

     * èŽ·å–token

     *

     * @return token - token

     */

    public String getToken() {

        return token;

    }


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/DeviceType.java

@@ -14,8 +14,8 @@
     */

    public static final int DELETE_FLAG_REMOVED = 1;

    public static final int DELETE_FLAG_NOTREMOVED = 0;

    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * ç±»åž‹åç§°

@@ -28,11 +28,11 @@
    private int deleteFlag;



   

    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/DncProcessing.java

@@ -9,19 +9,15 @@


@TableName("dnc_processing")

public class DncProcessing implements Serializable {

    /**

     * primary key

     */

    //@Id

    //@GeneratedValue(strategy = GenerationType.IDENTITY)

    @TableId(type=IdType.AUTO)



    @TableId(type=IdType.ASSIGN_ID)

    private Integer id;



    /**

     * machine id

     */

    //@Column(name = "machine_id")

    private Integer machineId;

    private Long machineId;



    /**

     * nc program file name

@@ -64,11 +60,11 @@
        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/Machine.java

@@ -23,15 +23,13 @@
    /**

     * id,实际上引用台账中的machine_id

     */

    //@Id

    //@GeneratedValue(strategy = GenerationType.IDENTITY)

    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * æ‰€å±žåŽ‚房的id

     */

    private Integer plantId;

    private Long plantId;

    



    /**

@@ -52,16 +50,9 @@
    @TableField("protocol_id")

    //private Integer typeId;

    private Integer protocolId;

    /**

     * workshop id

     */

    //@Column(name = "workshop_id")



    private Integer workshopId;



    /**

     * section id

     */

    //@Column(name = "section_id")

    private Integer sectionId;



    /**

@@ -196,16 +187,12 @@
        this.status = status;

    }



    /**

     * èŽ·å–primary key

     *

     * @return id - primary key

     */

    public Integer getId() {

	
    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



@@ -276,11 +263,11 @@
    }





    public Integer getPlantId() {

    public Long getPlantId() {

        return plantId;

    }



    public void setPlantId(Integer plantId) {

    public void setPlantId(Long plantId) {

        this.plantId = plantId;

    }

    


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachineAccount.java

@@ -15,19 +15,15 @@
@TableName("machine_account")

public class MachineAccount implements Serializable {



    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)//使用雪花漂移算法

    private Long id;



    /**

     * æœºåºŠid

     */

    @TableField("machine_id")

    private Integer machineId;

    private Long machineId;



    /**

     * machine name

     */

    //@Column(name = "machine_name")

    private String machineName;



    /**

@@ -150,19 +146,19 @@


    private static final long serialVersionUID = 1L;



    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachineProtocol.java

@@ -9,7 +9,7 @@
@TableName("machine_protocol")

public class MachineProtocol implements Serializable {



    @TableId(type=IdType.AUTO)

    @TableId(type=IdType.ASSIGN_ID)

    private Integer id;



    /**


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachineSeq.java

ÎļþÒÑɾ³ý

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachineStatus.java

@@ -10,11 +10,11 @@
@TableName("machine_status")

public class MachineStatus implements Serializable {



    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    

    private Integer machineId;

    private Long machineId;



    /**

     * mdc time

@@ -307,21 +307,21 @@
    private static final long serialVersionUID = 1L;



   

    public Integer getId() {

    public Long getId() {

        return id;

    }



   

    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    

    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachineStatusHistory.java

@@ -9,13 +9,13 @@
@TableName("machine_status_history")

public class MachineStatusHistory implements Serializable {

    

    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * machine id

     */

    private Integer machineId;

    private Long machineId;



    /**

     * mdc time

@@ -180,20 +180,20 @@
    private static final long serialVersionUID = 1L;



   

    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    

    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachineUtilization.java

@@ -13,7 +13,7 @@
    /**

     * primary key

     */

    @TableId(type=IdType.AUTO)

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachiningData.java

@@ -10,25 +10,15 @@
@TableName("machining_data")

public class MachiningData implements Serializable {

   

    @TableId(type=IdType.AUTO)

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * machine id

     */

    //@Column(name = "machine_id")

    private Integer machineId;



    /**

     * mdc time

     */

    //@Column(name = "mdc_time")

    private Long machineId;



    private Integer mdcTime;



    /**

     * update time

     */

    //@Column(name = "update_time")

  
    private Integer updateTime;



    /**

@@ -158,11 +148,11 @@
        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MachiningDataNc.java

@@ -11,17 +11,11 @@
 */

@TableName("machining_data_nc")

public class MachiningDataNc implements Serializable {

    /**

     * primary key

     */

    @TableId(type=IdType.AUTO)

  
    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * machine id，对应machine.id

     */

    //@Column(name = "machine_id")

    private Integer machineId;

    private Long machineId;



    /**

     * start time

@@ -52,11 +46,11 @@
        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/MdcWorkDays.java

@@ -12,7 +12,7 @@
 */

@TableName("mdc_work_days")

public class MdcWorkDays implements Serializable {

    @TableId(type=IdType.AUTO)

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/Section.java

@@ -13,7 +13,7 @@
    /**

     * primary key

     */

    @TableId(type=IdType.AUTO)

    @TableId(type=IdType.ASSIGN_ID)

    private Integer id;



    /**


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/SysAccount.java

@@ -18,8 +18,8 @@
     * è§’色：普通用户

     */

    public static final String ROLE_USER = "USER";

    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * ç”¨æˆ·å

@@ -58,11 +58,11 @@


    private static final long serialVersionUID = 1L;



    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/maintain/MachineMaintain.java

@@ -11,20 +11,20 @@
@TableName("machine_maintain")

public class MachineMaintain implements Serializable {

    

    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * machine id

     */

    //@Column(name = "machine_id")

    private Integer machineId;

    private Long machineId;



    /**

     * ä¿å…»è€… user id

     */

    //@Column(name = "user_id")

    private Integer userId;

    private Long userId;



    /**

     * machine account id

@@ -91,27 +91,27 @@
    private static final long serialVersionUID = 1L;



    

    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }



    public Integer getUserId() {

    public Long getUserId() {

        return userId;

    }



    public void setUserId(Integer userId) {

    public void setUserId(Long userId) {

        this.userId = userId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/plant/Plant.java

@@ -18,8 +18,8 @@
    /**

     * primary key

     */

    @TableId(type=IdType.AUTO)

    private Integer id;

    @TableId(type=IdType.ASSIGN_ID)

    private Long id;



    /**

     * åŽ‚房名称

@@ -33,11 +33,11 @@
    private String gridSetting;





    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/domain/workshop/Workshop.java

@@ -12,7 +12,7 @@
    /**

     * primary key

     */

    @TableId(type=IdType.AUTO)

    @TableId(type=IdType.ASSIGN_ID)

    private Integer id;



    /**


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/DncProcessingDTO.java

@@ -6,12 +6,12 @@


public class DncProcessingDTO implements Serializable {



    private Integer id;

    private Long id;



    /**

     * æœºåºŠid

     */

    private Integer machineId;

    private Long machineId;





    private String fileName;

@@ -43,19 +43,19 @@


    private static final long serialVersionUID = 1L;



    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/IdsDTO.java

@@ -6,13 +6,13 @@
 * åªæœ‰ids(id List)参数，主要用户批量删除这类场景的参数传递
 */
public class IdsDTO {
    private List<Integer> ids;
    private List<Long> ids;

    public List<Integer> getIds() {
    public List<Long> getIds() {
        return ids;
    }

    public void setIds(List<Integer> ids) {
    public void setIds(List<Long> ids) {
        this.ids = ids;
    }
    

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/MachineMaintainDTO.java

@@ -8,7 +8,7 @@
 * è®¾å¤‡ä¿å…»dto

 */

public class MachineMaintainDTO {

    private Integer id;

    private Long id;

    

    

    /*

@@ -18,7 +18,7 @@
    /**

     * è®¾å¤‡id

     */

    private Integer machineId;

    private Long machineId;

    /**

     * è®¾å¤‡åž‹å·ï¼Œæ–‡æœ¬

     */

@@ -59,17 +59,17 @@
    /**

     * ä¿å…»è€…id

     */

    private Integer userId;

    private Long userId;

    

    /**

     * ä½¿ç”¨å•ä½ï¼š1工艺/2编制/3生产

     */

    private Integer department;

    

    public Integer getId() {

    public Long getId() {

        return id;

    }

    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }

    

@@ -79,10 +79,10 @@
    public void setStyle(Integer style) {

        this.style = style;

    }

    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }

    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }

    public String getType() {

@@ -127,10 +127,10 @@
    public void setCompleteDateTo(Date completeDateTo) {

        this.completeDateTo = completeDateTo;

    }

    public Integer getUserId() {

    public Long getUserId() {

        return userId;

    }

    public void setUserId(Integer userId) {

    public void setUserId(Long userId) {

        this.userId = userId;

    }

    public Integer getDepartment() {


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/MachineMaintainFullDTO.java

@@ -8,7 +8,7 @@
 * è®¾å¤‡ä¿å…»dto

 */

public class MachineMaintainFullDTO {

    private Integer id;

    private Long id;

    

    /**

     * ç»Ÿä¸€ç¼–号，来自台账

@@ -22,7 +22,7 @@
    /**

     * è®¾å¤‡id

     */

    private Integer machineId;

    private Long machineId;

    private String machineName;

    /**

     * è®¾å¤‡åž‹å·ï¼Œå°è´¦é‡Œçš„信息

@@ -55,7 +55,7 @@
    /**

     * ä¿å…»è€…id

     */

    private Integer userId;

    private Long userId;

    /**

     * ç”¨æˆ·å§“名

     */

@@ -75,10 +75,10 @@
    private String specification;

   

    

    public Integer getId() {

    public Long getId() {

        return id;

    }

    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }

    

@@ -94,10 +94,10 @@
    public void setStyle(Integer style) {

        this.style = style;

    }

    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }

    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }

    public String getType() {

@@ -142,10 +142,10 @@
    public void setCompleteDateTo(Date completeDateTo) {

        this.completeDateTo = completeDateTo;

    }

    public Integer getUserId() {

    public Long getUserId() {

        return userId;

    }

    public void setUserId(Integer userId) {

    public void setUserId(Long userId) {

        this.userId = userId;

    }

    


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/MachineMaintainQueryDTO.java

@@ -21,7 +21,7 @@
    /**

     * è®¾å¤‡id

     */

    private Integer machineId;

    private Long machineId;

    /**

     * è®¾å¤‡åž‹å·ï¼Œæ–‡æœ¬

     */

@@ -64,10 +64,10 @@
    public void setStyle(Integer style) {

        this.style = style;

    }

    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }

    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }

    public String getType() {


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/PlantDTO.java

@@ -17,19 +17,19 @@
     */

    private static final long serialVersionUID = -2006517821720524176L;

    @NotNull(message = "id不能为空", groups = {UpdateGroup.class})

    private Integer id;

    private Long id;

    @NotBlank(message = "名称不能为空", groups = {AddGroup.class, UpdateGroup.class})

    private String name;



    @NotBlank(message = "厂房设置不能为空", groups = {AddGroup.class, UpdateGroup.class})

    private String gridSetting;



    public Integer getId() {

    public Long getId() {

        return id;

    }





    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/SysAccountDTO.java

@@ -5,7 +5,7 @@
public class SysAccountDTO{



    

    private Integer id;

    private Long id;



    /**

     * ç”¨æˆ·å

@@ -40,12 +40,12 @@


    private static final long serialVersionUID = 1L;



    public Integer getId() {

    public Long getId() {

        return id;

    }



   

    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/account/MachineAccountDTO.java

@@ -11,12 +11,12 @@


public class MachineAccountDTO implements Serializable {



    private Integer id;

    private Long id;



    /**

     * 

     */

    private Integer machineId;

    private Long machineId;



    /**

     * machine name

@@ -136,19 +136,19 @@
    private String status;

    private static final long serialVersionUID = 1L;



    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/account/MachineAccountEditDTO.java

@@ -11,12 +11,12 @@


public class MachineAccountEditDTO implements Serializable {



    private Integer id;

    private Long id;



    /**

     * 

     */

    private Integer machineId;

    private Long machineId;



    /**

     * machine name

@@ -131,19 +131,19 @@


    private static final long serialVersionUID = 1L;



    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }



    public Integer getMachineId() {

    public Long getMachineId() {

        return machineId;

    }



    public void setMachineId(Integer machineId) {

    public void setMachineId(Long machineId) {

        this.machineId = machineId;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/devicetype/DeviceTypeDTO.java

@@ -8,7 +8,7 @@


public class DeviceTypeDTO extends BasePageDTO{



    private int id;

    private Long id;



    /*

     * ç±»åž‹åç§°

@@ -20,11 +20,11 @@
     */

    private int deleteFlag;



    public int getId() {

    public Long getId() {

        return id;

    }



    public void setId(int id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/dto/machine/MachineDTO.java

@@ -8,7 +8,7 @@
 */

public class MachineDTO {

    @NotNull(message = "id不能为空")

    private Integer id;

    private Long id;

    //@NotBlank(message = "名称不能为空")

    //private String name;

    @NotBlank(message = "IP地址不能为空")

@@ -65,11 +65,11 @@
     */

    private  Integer concern;

    

    public Integer getId() {

    public Long getId() {

        return id;

    }



    public void setId(Integer id) {

    public void setId(Long id) {

        this.id = id;

    }




 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/AccountTokenMapper.java

@@ -10,5 +10,5 @@
     * @param userId

     * @return

     */

    AccountToken getByUserId(Integer userId);

    AccountToken getByUserId(Long userId);

}

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/MachineAccountMapper.java

@@ -28,7 +28,7 @@
     * @param machineId

     * @return

     */

    List<MachineAccount> lastByMachineId(Integer machineId);

    List<MachineAccount> lastByMachineId(Long machineId);



    /**

     * æŸ¥è¯¢æœªåŠ å…¥machine表的数据，供车间地图添加机器时候，作为筛选列表


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/MachineMapper.java

@@ -75,5 +75,5 @@
     * æ¸…空指定厂房id的机床plantId字段，yangys

     * @param plantId åŽ‚房id

     */

    void clearPlantIdInPlant(@Param("plantId")Integer plantId);

    void clearPlantIdInPlant(@Param("plantId")Long plantId);

}


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/MachineSeqMapper.java

ÎļþÒÑɾ³ý

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/MachineStatusMapper.java

@@ -16,5 +16,5 @@
     * @param time

     * @return

     */

    List<MachineStatus> machineLastListByTime(@Param("machineId")Integer machineId,@Param("time") int time);

    List<MachineStatus> machineLastListByTime(@Param("machineId")Long machineId,@Param("time") int time);

}

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/MachiningDataMapper.java

@@ -9,7 +9,7 @@


public interface MachiningDataMapper extends BaseMapper<MachiningData> {

    

    List<MachiningData> machineLastDataBeforeTime(@Param("machineId")Integer machineId,@Param("mdcTime")long mdcTime);

    List<MachiningData> machineLastDataBeforeTime(@Param("machineId")Long machineId,@Param("mdcTime")long mdcTime);



    /**

     * æŸè®¾å¤‡æœ€åŽ

@@ -17,5 +17,5 @@
     * @param updateTime æ›´æ–°æ—¶é—´

     * @return

     */

    List<MachiningData> machineLastDatasAfterUpdateTime(@Param("machineId")Integer machineId,@Param("updateTime") int updateTime);

    List<MachiningData> machineLastDatasAfterUpdateTime(@Param("machineId")Long machineId,@Param("updateTime") int updateTime);

}

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mapper/MachiningDataNcMapper.java

@@ -20,7 +20,7 @@
     * @param machineId æœºåºŠè®¾å¤‡id

     * @return

     */

    List<MachiningDataNc> machineLastList(Integer machineId);

    List<MachiningDataNc> machineLastList(Long machineId);

    

    /**

     * æœºåºŠåˆ†å¸ƒå›¾æŸ¥è¯¢


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/mybatis/MybatisPlusWFGIdGenerator.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
package com.qianwen.mdc.mybatis;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.baomidou.mybatisplus.core.incrementer.IdentifierGenerator;
import com.hy.corecode.idgen.WFGIdGenerator;

/**
 * mp拦截器用于注入id请求
 */
@Component
public class MybatisPlusWFGIdGenerator implements IdentifierGenerator {

    @Autowired
    private WFGIdGenerator wFGIdGenerator;

    @Override
    public Long nextId(Object entity) {
    	
       return wFGIdGenerator.next();
    }
    
    
}

 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/service/account/MachineAccountAddService.java

@@ -17,11 +17,9 @@
import com.qianwen.mdc.domain.DomainException;

import com.qianwen.mdc.domain.Machine;

import com.qianwen.mdc.domain.MachineAccount;

import com.qianwen.mdc.domain.MachineSeq;

import com.qianwen.mdc.dto.account.MachineAccountEditDTO;

import com.qianwen.mdc.mapper.MachineAccountMapper;

import com.qianwen.mdc.mapper.MachineMapper;

import com.qianwen.mdc.mapper.MachineSeqMapper;



/**

 * @author y_ys79

@@ -31,8 +29,7 @@
public class MachineAccountAddService {

    @Autowired

    private MachineAccountMapper accountMapper;

    @Autowired

    private MachineSeqMapper seqMapper;



    @Autowired

    private MachineMapper machineMapper;

    /**


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/service/account/MachineAccountEditService.java

@@ -56,11 +56,11 @@
    }



    @Transactional

    public void remove(List<Integer> ids) {

    public void remove(List<Long> ids) {

        

        for(Integer id : ids ) {

        for(Long id : ids ) {

            MachineAccount account = accountMapper.selectById(id);

            int machineId = account.getMachineId();

            Long machineId = account.getMachineId();

            accountMapper.deleteById(id);

            

            //删除对应的采集信息


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/service/devicetype/DeviceTypeService.java

@@ -78,9 +78,9 @@
    }



    @Transactional

    public void delete(List<Integer> ids) {

    public void delete(List<Long> ids) {

        DeviceType dtype;

        for(Integer id : ids) {

        for(Long id : ids) {

            dtype = deviceTypeMapper.selectById(id);

            if(dtype == null) {

                continue;


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/service/machine/MachineEditService.java

@@ -89,7 +89,7 @@
     * @param concern

     */

    @Transactional

    public void switchConcern(Integer id, int concern) {

    public void switchConcern(Long id, int concern) {

        Machine machine = machineMapper.selectById(id);

        machine.setConcern(concern);

        machineMapper.updateById(machine);


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/service/maintain/MachineMaintainEditService.java

@@ -40,7 +40,7 @@
    }

    

    @Transactional

    public void delete(List<Integer> idList) {

    public void delete(List<Long> idList) {

        

        maintainMapper.deleteBatchIds(idList);

    }


 mdc-parent/mdc-show/src/main/java/com/qianwen/mdc/service/plant/PlantService.java

@@ -47,7 +47,7 @@
        

        plantMapper.insert(p);

        

        Integer plantId = p.getId();

        Long plantId = p.getId();

        

        List<Integer> machineIds = this.parseMachineIdInGrid(plantDTO.getGridSetting());

        

@@ -108,7 +108,7 @@
        //新配置的机床，更新plantId

        List<Integer> machineIds = this.parseMachineIdInGrid(plantDTO.getGridSetting());

        

        Integer plantId = plantDTO.getId();

        Long plantId = plantDTO.getId();

        for(Integer mid:machineIds ) {

            Machine m = machineMapper.selectById(mid);

            if(m != null) {

@@ -148,9 +148,9 @@
     * @param ids åŽ‚房id列表

     */

    @Transactional

    public void delete(List<Integer> ids) {

    public void delete(List<Long> ids) {

        //TODO æ£€æŸ¥åŽ‚房的设备数量

        for(Integer plantId :ids) {

        for(Long plantId :ids) {

            plantMapper.deleteById(plantId);

            machineMapper.clearPlantIdInPlant(plantId);

        }


 mdc-parent/mdc-show/src/main/resources/application.yml

@@ -18,7 +18,30 @@
    map-underscore-to-camel-case: true

  mapper-locations: classpath:mapper/*.xml

  type-aliases-package: com.qianwen.mdc.domain

  


wfg:

# è¯·ä¸€å®šæ³¨æ„ï¼ WorkerIdBitLength + SeqBitLength + DataCenterIdBitLength <= 22

  # 1表示雪花漂移算法，2表示传统雪花算法

  method: 1

  # åŸºç¡€æ—¶é—´ï¼Œä¸º2023-07-01 00:00:00 id>0

  baseTime: 1688140800000

  # æ•°æ®ä¸­å¿ƒid

  dataCenterId: 0

  # æ•°æ®ä¸­å¿ƒid位长，默认为0表示不开启数据中心id功能

  dataCenterIdBitLength: 0

  # æœºå™¨ç ï¼ˆå½“前系统的机器码）

  workerId: 0

  # æœºå™¨ç ä½é•¿ï¼ˆèƒ½è¡¨ç¤ºæœºå™¨ç çš„最大值）

  workerIdBitLength: 1

  # åºåˆ—数位长（能表示机器码的最大序列数）

  seqBitLength: 6

  # æœ€å¤§åºåˆ—数（含）

  maxSeqNumber: 0

  # æœ€å°åºåˆ—数（含）

  minSeqNumber: 5

  # æœ€å¤§æ¼‚移次数，与计算能力有关

  topOverCostCount: 2000

    
staticdata:

  useDepartments:

    - id: 1


 mdc-parent/mdc-show/src/test/java/com/qianwen/mdc/service/plant/TimeTest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.qianwen.mdc.service.plant;

import java.time.LocalDateTime;
import java.time.ZoneOffset;

import org.junit.jupiter.api.Test;

public class TimeTest {
	
    @Test
    public void t() {
        LocalDateTime lt = LocalDateTime.of(2023, 7, 1,0,0);
        Long m = lt.toInstant(ZoneOffset.of("+8")).toEpochMilli();
        System.out.println(m);
    }

}

 mdc-parent/mdc-showdb-mysql/src/main/resources/mapper/MachineSeqMapper.xml

ÎļþÒÑɾ³ý