提交地磅管理开发

sckw-modules/sckw-system/src/main/java/com/sckw/system/dao/KwsPrinterDao.java

@@ -0,0 +1,9 @@
+package com.sckw.system.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.system.model.KwsPrinter;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface KwsPrinterDao extends BaseMapper<KwsPrinter> {
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/dao/KwsWeighbridgeDao.java

@@ -0,0 +1,9 @@
+package com.sckw.system.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.system.model.KwsWeighbridge;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface KwsWeighbridgeDao extends BaseMapper<KwsWeighbridge> {
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/dao/KwsWeighbridgeDiffConfigDao.java

@@ -0,0 +1,12 @@
+package com.sckw.system.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.system.model.KwsWeighbridgeDiffConfig;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 地磅差异化配置 Mapper。
+ */
+@Mapper
+public interface KwsWeighbridgeDiffConfigDao extends BaseMapper<KwsWeighbridgeDiffConfig> {
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/dao/KwsWeighbridgeRecordDao.java

@@ -0,0 +1,9 @@
+package com.sckw.system.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.sckw.system.model.KwsWeighbridgeRecord;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface KwsWeighbridgeRecordDao extends BaseMapper<KwsWeighbridgeRecord> {
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/repository/KwsPrinterRepository.java

@@ -0,0 +1,49 @@
+package com.sckw.system.repository;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.system.dao.KwsPrinterDao;
+import com.sckw.system.model.KwsPrinter;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Repository;
+
+import java.util.Collection;
+import java.util.List;
+
+@Repository
+public class KwsPrinterRepository extends ServiceImpl<KwsPrinterDao, KwsPrinter> {
+
+    public IPage<KwsPrinter> pageQuery(int pageNum, int pageSize, String printerName, Collection<Long> entIds) {
+        return page(new Page<>(pageNum, pageSize), Wrappers.<KwsPrinter>lambdaQuery()
+                .eq(KwsPrinter::getDelFlag, 0)
+                .like(StringUtils.isNotBlank(printerName), KwsPrinter::getPrinterName, printerName)
+                .in(entIds != null && !entIds.isEmpty(), KwsPrinter::getEntId, entIds)
+                .orderByDesc(KwsPrinter::getCreateTime)
+                .orderByDesc(KwsPrinter::getId));
+    }
+
+    public KwsPrinter findAvailableById(Long id) {
+        return getOne(Wrappers.<KwsPrinter>lambdaQuery()
+                .eq(KwsPrinter::getId, id)
+                .eq(KwsPrinter::getDelFlag, 0)
+                .last("limit 1"));
+    }
+
+    public KwsPrinter findByEntIdAndName(Long entId, String printerName) {
+        return getOne(Wrappers.<KwsPrinter>lambdaQuery()
+                .eq(KwsPrinter::getDelFlag, 0)
+                .eq(KwsPrinter::getEntId, entId)
+                .eq(KwsPrinter::getPrinterName, printerName)
+                .last("limit 1"));
+    }
+
+    public List<KwsPrinter> listByEntId(Long entId) {
+        return list(Wrappers.<KwsPrinter>lambdaQuery()
+                .eq(KwsPrinter::getDelFlag, 0)
+                .eq(KwsPrinter::getStatus, 0)
+                .eq(KwsPrinter::getEntId, entId)
+                .orderByDesc(KwsPrinter::getCreateTime));
+    }
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/repository/KwsWeighbridgeDiffConfigRepository.java

@@ -0,0 +1,21 @@
+package com.sckw.system.repository;
+
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.system.dao.KwsWeighbridgeDiffConfigDao;
+import com.sckw.system.model.KwsWeighbridgeDiffConfig;
+import org.springframework.stereotype.Repository;
+
+/**
+ * 地磅差异化配置仓储。
+ */
+@Repository
+public class KwsWeighbridgeDiffConfigRepository extends ServiceImpl<KwsWeighbridgeDiffConfigDao, KwsWeighbridgeDiffConfig> {
+
+    public KwsWeighbridgeDiffConfig findByEntId(Long entId) {
+        return getOne(Wrappers.<KwsWeighbridgeDiffConfig>lambdaQuery()
+                .eq(KwsWeighbridgeDiffConfig::getEntId, entId)
+                .eq(KwsWeighbridgeDiffConfig::getDelFlag, 0)
+                .last("limit 1"));
+    }
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/repository/KwsWeighbridgeRecordRepository.java

@@ -0,0 +1,55 @@
+package com.sckw.system.repository;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.system.dao.KwsWeighbridgeRecordDao;
+import com.sckw.system.model.KwsWeighbridgeRecord;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Repository;
+
+import java.math.BigDecimal;
+import java.util.Collection;
+import java.util.Date;
+import java.util.List;
+
+@Repository
+public class KwsWeighbridgeRecordRepository extends ServiceImpl<KwsWeighbridgeRecordDao, KwsWeighbridgeRecord> {
+
+    public IPage<KwsWeighbridgeRecord> pageQuery(int pageNum, int pageSize, Collection<Long> weighbridgeIds,
+                                                 String truckNo, BigDecimal minWeight, BigDecimal maxWeight,
+                                                 Date createStartTime, Date createEndTime,
+                                                 Date receiveStartTime, Date receiveEndTime) {
+        return page(new Page<>(pageNum, pageSize), Wrappers.<KwsWeighbridgeRecord>lambdaQuery()
+                .eq(KwsWeighbridgeRecord::getDelFlag, 0)
+                .in(weighbridgeIds != null && !weighbridgeIds.isEmpty(), KwsWeighbridgeRecord::getWeighbridgeId, weighbridgeIds)
+                .like(StringUtils.isNotBlank(truckNo), KwsWeighbridgeRecord::getTruckNo, truckNo)
+                .ge(minWeight != null, KwsWeighbridgeRecord::getWeight, minWeight)
+                .le(maxWeight != null, KwsWeighbridgeRecord::getWeight, maxWeight)
+                .ge(createStartTime != null, KwsWeighbridgeRecord::getCreateTime, createStartTime)
+                .le(createEndTime != null, KwsWeighbridgeRecord::getCreateTime, createEndTime)
+                .ge(receiveStartTime != null, KwsWeighbridgeRecord::getReceiveTime, receiveStartTime)
+                .le(receiveEndTime != null, KwsWeighbridgeRecord::getReceiveTime, receiveEndTime)
+                .orderByDesc(KwsWeighbridgeRecord::getCreateTime)
+                .orderByDesc(KwsWeighbridgeRecord::getId));
+    }
+
+    public List<KwsWeighbridgeRecord> listQuery(Collection<Long> weighbridgeIds,
+                                                String truckNo, BigDecimal minWeight, BigDecimal maxWeight,
+                                                Date createStartTime, Date createEndTime,
+                                                Date receiveStartTime, Date receiveEndTime) {
+        return list(Wrappers.<KwsWeighbridgeRecord>lambdaQuery()
+                .eq(KwsWeighbridgeRecord::getDelFlag, 0)
+                .in(weighbridgeIds != null && !weighbridgeIds.isEmpty(), KwsWeighbridgeRecord::getWeighbridgeId, weighbridgeIds)
+                .like(StringUtils.isNotBlank(truckNo), KwsWeighbridgeRecord::getTruckNo, truckNo)
+                .ge(minWeight != null, KwsWeighbridgeRecord::getWeight, minWeight)
+                .le(maxWeight != null, KwsWeighbridgeRecord::getWeight, maxWeight)
+                .ge(createStartTime != null, KwsWeighbridgeRecord::getCreateTime, createStartTime)
+                .le(createEndTime != null, KwsWeighbridgeRecord::getCreateTime, createEndTime)
+                .ge(receiveStartTime != null, KwsWeighbridgeRecord::getReceiveTime, receiveStartTime)
+                .le(receiveEndTime != null, KwsWeighbridgeRecord::getReceiveTime, receiveEndTime)
+                .orderByDesc(KwsWeighbridgeRecord::getCreateTime)
+                .orderByDesc(KwsWeighbridgeRecord::getId));
+    }
+}

sckw-modules/sckw-system/src/main/java/com/sckw/system/repository/KwsWeighbridgeRepository.java

@@ -0,0 +1,58 @@
+package com.sckw.system.repository;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.sckw.system.dao.KwsWeighbridgeDao;
+import com.sckw.system.model.KwsWeighbridge;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Repository;
+
+import java.util.Collection;
+import java.util.List;
+
+@Repository
+public class KwsWeighbridgeRepository extends ServiceImpl<KwsWeighbridgeDao, KwsWeighbridge> {
+
+    public IPage<KwsWeighbridge> pageQuery(int pageNum, int pageSize, String weighbridgeName, Collection<Long> entIds) {
+        return page(new Page<>(pageNum, pageSize), Wrappers.<KwsWeighbridge>lambdaQuery()
+                .eq(KwsWeighbridge::getDelFlag, 0)
+                .like(StringUtils.isNotBlank(weighbridgeName), KwsWeighbridge::getWeighbridgeName, weighbridgeName)
+                .in(entIds != null && !entIds.isEmpty(), KwsWeighbridge::getEntId, entIds)
+                .orderByDesc(KwsWeighbridge::getCreateTime)
+                .orderByDesc(KwsWeighbridge::getId));
+    }
+
+    public KwsWeighbridge findAvailableById(Long id) {
+        return getOne(Wrappers.<KwsWeighbridge>lambdaQuery()
+                .eq(KwsWeighbridge::getId, id)
+                .eq(KwsWeighbridge::getDelFlag, 0)
+                .last("limit 1"));
+    }
+
+    public KwsWeighbridge findByUniqueCode(String uniqueCode) {
+        return getOne(Wrappers.<KwsWeighbridge>lambdaQuery()
+                .eq(KwsWeighbridge::getUniqueCode, uniqueCode)
+                .eq(KwsWeighbridge::getDelFlag, 0)
+                .last("limit 1"));
+    }
+
+    public List<KwsWeighbridge> listByNameAndCode(String weighbridgeName, String uniqueCode, Collection<Long> entIds) {
+        return list(Wrappers.<KwsWeighbridge>lambdaQuery()
+                .eq(KwsWeighbridge::getDelFlag, 0)
+                .like(StringUtils.isNotBlank(weighbridgeName), KwsWeighbridge::getWeighbridgeName, weighbridgeName)
+                .like(StringUtils.isNotBlank(uniqueCode), KwsWeighbridge::getUniqueCode, uniqueCode)
+                .in(entIds != null && !entIds.isEmpty(), KwsWeighbridge::getEntId, entIds)
+                .orderByDesc(KwsWeighbridge::getCreateTime));
+    }
+
+    public boolean updateDiffConfigByEntId(Long entId, String diffConfig, Long updateBy) {
+        return update(Wrappers.<KwsWeighbridge>lambdaUpdate()
+                .eq(KwsWeighbridge::getEntId, entId)
+                .eq(KwsWeighbridge::getDelFlag, 0)
+                .set(KwsWeighbridge::getDiffConfig, diffConfig)
+                .set(KwsWeighbridge::getUpdateBy, updateBy)
+                .set(KwsWeighbridge::getUpdateTime, new java.util.Date()));
+    }
+}