CZT
2023-10-11 f169fcb00f7bf8c15bb1d461cd3710ebaf8106e8
优化液位计算
已修改3个文件
63 ■■■■ 文件已修改
igds-basic/src/main/java/com/ld/igds/grain/manager/GrainManager.java 13 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
igds-core/src/main/java/com/ld/igds/view/service/BuildingService.java 26 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
igds-web/pom.xml 24 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
igds-basic/src/main/java/com/ld/igds/grain/manager/GrainManager.java
@@ -22,18 +22,13 @@
import com.ld.igds.util.ContextUtil;
import com.ld.igds.util.DateUtil;
import com.ld.igds.util.DecimalUtil;
import com.ld.igds.util.FilesUtil;
import com.ld.igds.view.service.BuildingService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.text.Collator;
import java.util.*;
import java.util.concurrent.ExecutorService;
@@ -67,8 +62,6 @@
    private BuildingService buildingService;
    @Autowired
    private GrainExportBuilder grainExportBuilder;
    @Resource
    private FilesUtil filesUtil;
    /**
     * 根据参数获取粮情数据信息
@@ -850,7 +843,11 @@
            if (null != bulkWeight && StringUtils.isNotEmpty(grainData.getOilHeight())) {
                Double oilHeight = Double.valueOf(grainData.getOilHeight());
                //计算体积
                volume = 3.14 * Math.pow(diameter / 2, 2) * oilHeight  - deVolume;
                volume = 3.14159 * Math.pow(diameter / 2, 2) * oilHeight;
                if(volume > 0){
                    volume = volume - deVolume;
                }
                storage = volume * bulkWeight;
            }
igds-core/src/main/java/com/ld/igds/view/service/BuildingService.java
@@ -3,6 +3,8 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import org.apache.commons.lang3.StringUtils;
import org.hibernate.Session;
import org.springframework.beans.factory.annotation.Autowired;
@@ -61,7 +63,7 @@
            }
            data.setCompanyId(ContextUtil.getCompanyId());
            session.saveOrUpdate(data);
            refreshCache(data.getCompanyId(), data.getDeptId());
            refreshCache(data.getCompanyId());
        } finally {
            session.flush();
            session.close();
@@ -101,7 +103,7 @@
                }
            }
            
            refreshCache(items.get(0).getCompanyId(), items.get(0).getDeptId());
            refreshCache(items.get(0).getCompanyId());
        } finally {
            session.flush();
            session.close();
@@ -110,7 +112,7 @@
    }
    @SuppressWarnings("unchecked")
    public List<Building> getCacheBuilding(String companyId,String deptId) {
    public List<Building> getCacheBuilding(String companyId, String deptId) {
        if(StringUtils.isEmpty(companyId)){
            companyId = ContextUtil.getCompanyId();
        }
@@ -120,14 +122,15 @@
        List<Building> result = (List<Building>) redisUtil.get(key);
        if (null == result) {
            refreshCache(companyId, deptId);
            refreshCache(companyId);
            
            return null;
        }
        if(null == deptId) return result;
        return result;
        return result.stream().filter(item -> item.getDeptId().equals(deptId))
                .collect(Collectors.toList());
    }
    @SuppressWarnings("unchecked")
@@ -136,12 +139,10 @@
            companyId = ContextUtil.getCompanyId();
        }
        String key = RedisConst.buildKey(companyId, RedisConst.KEY_BUILDING_LIST);
        List<Building> result = (List<Building>) redisUtil.get(key);
        List<Building> result = getCacheBuilding(companyId, deptId);
        if (null == result) {
            refreshCache(companyId, deptId);
            refreshCache(companyId);
            return null;
        }
@@ -154,12 +155,11 @@
    }
    
    
    public void refreshCache(String companyId, String deptId) {
    public void refreshCache(String companyId) {
        Map<String, Object> parameter = new HashMap<String, Object>();
        parameter.put("companyId", companyId);
        parameter.put("deptId", deptId);
        List<Building> list = this.loadData(parameter);
        
        redisUtil.set(RedisConst.buildKey(companyId, deptId, RedisConst.KEY_BUILDING_LIST),list);
        redisUtil.set(RedisConst.buildKey(companyId, RedisConst.KEY_BUILDING_LIST),list);
    }
}
igds-web/pom.xml
@@ -144,15 +144,15 @@
        </dependency>
        <!-- 接口包,包括上海接口和、气象接口、三维接口-->
        <!-- 接口包,包括上海接口和、气象接口、三维接口
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-api-inte</artifactId>
            <version>${igds.version}</version>
        </dependency>
        </dependency>-->
        <!--  私有协议-风正致远
        <!--  私有协议-风正致远-->
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-protocol-fzzy3</artifactId>
@@ -167,7 +167,7 @@
                    <groupId>log4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>-->
        </dependency>
        <!-- MODBUS-TCP
        <dependency>
@@ -187,7 +187,7 @@
        </dependency>-->
        <!-- 私有协议-风正致远IOT、制氮机
        <!-- 私有协议-风正致远IOT、制氮机-->
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-protocol-iot</artifactId>
@@ -202,9 +202,9 @@
                    <groupId>log4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>-->
        </dependency>
        <!--  私有协议-贝博粮情-->
        <!--  私有协议-贝博粮情
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-protocol-beibo</artifactId>
@@ -219,9 +219,9 @@
                    <groupId>log4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        </dependency>-->
        <!--  私有协议-DLT645电表协议-->
        <!--  私有协议-DLT645电表协议
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-protocol-es</artifactId>
@@ -236,7 +236,7 @@
                    <groupId>log4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        </dependency>-->
        <!--  私有协议-邦海智能-->
        <dependency>
@@ -255,7 +255,7 @@
            </exclusions>
        </dependency>
        <!--  私有协议-正来电子
        <!--  私有协议-正来电子-->
        <dependency>
            <groupId>com.ld.igds</groupId>
            <artifactId>igds-protocol-zldz</artifactId>
@@ -270,7 +270,7 @@
                    <groupId>log4j</groupId>
                </exclusion>
            </exclusions>
        </dependency> -->
        </dependency>
        <!--  海康车牌识别-SDK-->
        <dependency>