Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

zhubaomin

6 天以前 00d54db361d697cf8fdf2f15940f4650b21b3185

Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/queue/Node.java

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


public class Node {
    public Node pre ;
    public Node next ;
    public NodeObj obj ;
    public Node pre ;//前置结点
    public Node next ;//后置结点
    public NodeObj obj ;//本结点数据对象
}


 pipIrr-platform/pipIrr-global/src/main/resources/init-config(121·þÎñÆ÷).xml

@@ -254,7 +254,7 @@
                <item3 typeName="设备保养"/>
            </taskType>
        </org4>
        <org4 tag="lz" name="凉州" enable="true">
        <org5 tag="lz" name="凉州" enable="true">
            <districts>
                <province name="甘肃省" num="62" level="0">
                    <city name="武威市" num="06" level="1">
@@ -316,8 +316,8 @@
                <item2 typeName="设备维修"/>
                <item3 typeName="设备保养"/>
            </taskType>
        </org4>
        <org5 tag="jc" name="金川" enable="true">
        </org5>
        <org6 tag="jc" name="金川" enable="true">
            <districts>
                <province name="甘肃省" num="62" level="0">
                    <city name="金昌市" num="03" level="1">
@@ -379,6 +379,6 @@
                <item2 typeName="设备维修"/>
                <item3 typeName="设备保养"/>
            </taskType>
        </org5>
        </org6>
    </orgs>
</config>

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/msCenter/TestMsResource.java

@@ -17,30 +17,15 @@
    @Scheduled(cron = "0/4 * * * * ?")
    public void test1() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "开阀");
        msObj.put("clientId", 2024090517284400002L);
        msObj.put("clientName", "田仁春");
        msObj.put("clientAddress", "元谋县元马镇清和村委会挨那望村");
        msObj.put("icCardNo", "123456789");
        msObj.put("rtuAddr", "123456789");
        msObj.put("intakeId", 2024090517395800007L);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        setAttr4OpenCloseValve("开阀", msObj) ;
        MsCenterUnit.getInstance().pushMs(msObj);
    }


    // è®¾ç½®å®šæ—¶N秒一次
    @Scheduled(cron = "0/6 * * * * ?")
    public void test2() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "关阀");
        msObj.put("clientId", 2024090517284400002L);
        msObj.put("clientName", "田仁春");
        msObj.put("clientAddress", "元谋县元马镇清和村委会挨那望村");
        msObj.put("icCardNo", "123456789");
        msObj.put("rtuAddr", "123456789");
        msObj.put("intakeId", 2024090517395800007L);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        setAttr4OpenCloseValve("关阀", msObj) ;
        MsCenterUnit.getInstance().pushMs(msObj);
    }

@@ -48,12 +33,9 @@
    @Scheduled(cron = "0/10 * * * * ?")
    public void test4() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "阀态");
        msObj.put("rtuAddr","123456789");
        msObj.put("intakeId", 2024090517395800007L);
        setAttr4StateAlarm("阀态", msObj) ;
        msObj.put("state", 0);
        msObj.put("stateName", "开");
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        MsCenterUnit.getInstance().pushMs(msObj);
    }

@@ -61,13 +43,33 @@
    @Scheduled(cron = "0/15 * * * * ?")
    public void test3() throws Exception {
        MsObj msObj = new MsObj() ;
        msObj.put("name", "报警");
        msObj.put("rtuAddr","123456789");
        msObj.put("intakeId", 2024090517395800007L);
        setAttr4StateAlarm("阀态", msObj) ;
        msObj.put("alarm", "流量计故障报警、漏损报警");
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
        MsCenterUnit.getInstance().pushMs(msObj);
    }

    private void setAttr4OpenCloseValve(String name, MsObj msObj){
        msObj.put("name", name);
        msObj.put("clientId", clientId);
        msObj.put("clientName", clientName);
        msObj.put("clientAddress", clientAddress);
        msObj.put("icCardNo", icCardNo);
        msObj.put("rtuAddr", rtuAddr);
        msObj.put("intakeId", intakeId);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
    }

    private void setAttr4StateAlarm(String name, MsObj msObj){
        msObj.put("name", name);
        msObj.put("rtuAddr", rtuAddr);
        msObj.put("intakeId", intakeId);
        msObj.put("dt", DateTime.yyyy_MM_dd_HH_mm_ss());
    }

    private static final String clientName = "田仁春";
    private static final String clientAddress = "元谋县元马镇清和村委会挨那望村";
    private static final Long clientId = 2024090517284400002L;
    private static final Long intakeId = 2024090517395800007L;
    private static final String rtuAddr = "123456789";
    private static final String icCardNo = "123456789";
}

 pipIrr-platform/pipIrr-web/pipIrr-mwTest-web/src/main/java/com/dy/pipIrrMwTestWeb/p206V202404test/ComSupportP206V202404.java

@@ -31,7 +31,7 @@
    protected static String rtuAddr = "37142501020100229" ;
    protected static String rtuResultSendWebUrl = "http://127.0.0.1:65535/test/comRes/receive" ;

    protected static String controllerType = "57" ;//控制器类型
    protected static String controllerType = "02" ;//控制器类型 57水泵，02阀门
    protected static Integer projectNo = 10 ;//项目编码

    protected static String icCardAddr = "04BEA5BB" ;//IC卡地址

 pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/user/UserCtrl.java

@@ -508,7 +508,7 @@
            if(res == null) {
                return BaseResponseUtils.buildException(SystemResultCode.THE_USER_NOT_EXIST.getMessage());
            }
            System.out.println("   :" + res);
            //System.out.println("   :" + res);
            return BaseResponseUtils.buildSuccess(res);
        } catch (Exception e) {
            log.error("查询用户信息异常", e);

 pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java

@@ -20,6 +20,7 @@
import com.dy.pipIrrGlobal.pojoSe.SeRechargeProfile;
import com.dy.pipIrrGlobal.pojoSe.SeWaterType;
import com.dy.pipIrrGlobal.util.DistrictLevel;
import lombok.extern.slf4j.Slf4j;
import org.jdom2.Document;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.event.ApplicationReadyEvent;
@@ -34,6 +35,7 @@
 * Spring容器并没有创建完，而本类中用了Spring容器中的Bean，即distriDao, userDao。
 * æ‰€ä»¥é‡‡ç”¨äº†Spring事件监听器来实现
 */
@Slf4j
@Component
public class InitListener implements ApplicationListener<ApplicationReadyEvent> {

@@ -137,17 +139,22 @@
            Document doc = configXml.createDom(this.resourceLoader, "init-config.xml") ;
            this.doInit(configXml, doc);
        } catch (Exception e) {
            System.out.println("系统启动时，初始化配置出错 !");
            System.out.println(e.getMessage());
            log.error("系统启动时，初始化配置出错 !");
            log.error(e.getMessage());
            e.printStackTrace();
        }
    }
    private void doInit(ConfigXml4Springboot configXml, Document doc) throws Exception{
        //Check if configXml and doc are not null
        if(configXml != null && doc != null){
            //Loop through 10000 orgs
            for(int num = 1; num <= 10000; num++){
                //Check if the org exists
                if(configXml.existElement(doc, "config.orgs.org" + num)){
                    //Get the tag and enable value of the org
                    String orgTag = configXml.getSetAttrTxt(doc, "config.orgs.org" + num,"tag", null, false, null) ;
                    Boolean enable = configXml.getSetAttrBoolean(doc, "config.orgs.org" + num, "enable", null, null);
                    //If the org is enabled
                    if(enable != null && enable.booleanValue()){
                        //设置数据源
                        DataSourceContext.set(orgTag);

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/common/CommandSv.java

@@ -213,7 +213,7 @@
                    jsonArray.add(jsonObject);
                });
            }
            System.out.println(jsonArray);
        //    System.out.println(jsonArray);
        //} else {
        //    VoUnclosedParam voUnclosedParam = new VoUnclosedParam();
        //    return voUnclosedParam;

 pipIrr-platform/pipIrr-web/pipIrr-web-remote/src/main/java/com/dy/pipIrrRemote/monitor/MonitorSv.java

@@ -61,7 +61,7 @@
    }

    /**
     * æŸ¥è¯¢RTU在通信中间件中的在线状态
     * æŸ¥è¯¢RTU在通信中间件中的状态
     * @param rtuAddr
     * @return
     */