mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/collector/moxa/MoxaCollector.java
@@ -63,7 +63,7 @@ private void insertOrUpdate(MachiningData data) { int time = (int) TimestampUtils.getCurrentTimestamp(); data.setMdcTime(time); /* //老的实现，为了减少数据的插入？ if (this.lastMdcData.equals(machine)) { @@ -89,13 +89,14 @@ //有问题，不可能相等，时间不同 MachiningData lastData = machiningDataMapper.lastOneByMachineId(data.getMachineId()); if(lastData == null) {//该机床没有历史数据，直接新增 data.setMdcTime(time); machiningDataMapper.insert(data); return; } if(data.equalsMachineData(lastData)) {//如果数据无变化,只更新updatetime lastData.setUpdateTime(time); machiningDataMapper.updateById(lastData); data.setUpdateTime(time); machiningDataMapper.updateById(data); }else {//加工数据变化了，加入新的数据 data.setMdcTime(time); machiningDataMapper.insert(data); mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/domain/MachineFocas.java
@@ -6,9 +6,9 @@ import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; @TableName("mdc_machine_focas") @TableName("machine_focas") public class MachineFocas implements Serializable { @TableId(type=IdType.INPUT) @TableId(type=IdType.ASSIGN_ID) private Long id; private Long machineId; mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/domain/MachineProtocol.java
@@ -5,9 +5,8 @@ import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; //mdc_machine_type //@TableName("machine_protocol") @TableName("machine_protocol")//TODO 临时的 @TableName("machine_protocol") public class MachineProtocol implements Serializable { @TableId(type=IdType.INPUT) mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/domain/MachiningData.java
@@ -11,9 +11,9 @@ public static final String STATE_STOP = "STOP"; public static final String STATE_ALARM = "ALARM"; public static final String STATE_RUN = "RUN"; public static final String STATE_IDLE = "STATE_IDLE"; public static final String STATE_IDLE = "IDLE"; @TableId(type = IdType.INPUT) @TableId(type = IdType.ASSIGN_ID) private Long id; private Long machineId; mdc-parent/mdc-collect/src/main/java/com/qianwen/mdc/mybatis/MybatisPlusWFGIdGenerator.java
@@ -21,5 +21,4 @@ return wFGIdGenerator.next(); } } mdc-parent/mdc-collect/src/main/resources/application.yml
@@ -11,3 +11,26 @@ 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
