修改

Administrator

2021-05-29 03ab6e7e44f5eb4d904240b8ffca95436c20ceb6

修改

 src/com/dev/fbs9009/MyModBusPowerOffRecordThread.java

@@ -30,7 +30,7 @@
                    BattData_RT rt = battData.getItem(i);

                    boolean isExsist = false;

                    for(int k = 0;k<threads.size();i++) {

                        if(rt.BattGroupId == threads.get(i).battData.BattGroupId) {

                        if(rt.BattGroupId == threads.get(k).battData.BattGroupId) {

                            //当前电池组已存在记录线程

                            isExsist = true;

                            break;

@@ -44,6 +44,11 @@
                }                

                Thread.sleep(1000);

            } catch (Exception e) {

                try {

                    Thread.sleep(5000);

                } catch (InterruptedException e1) {

                    e1.printStackTrace();

                }

                e.printStackTrace();

            }            

        }

@@ -137,6 +142,11 @@
                    }

                    Thread.sleep(1000);

                } catch (Exception e) {

                    try {

                        Thread.sleep(5000);

                    } catch (InterruptedException e1) {

                        e1.printStackTrace();

                    }

                    e.printStackTrace();

                }

            }


 src/com/dev/fbs9009/MyModBusSocketThread.java

@@ -425,11 +425,11 @@
                bytebuffer_for_socket_RX.flip();

                //byte[] plain_tx_t = bytebuffer_for_socket_RX.array();

                //System.out.println("接收数据:"+data.CMD+"\t读取数据"+ComFn.bytesToHexString(bytebuffer_for_socket_RX.array(), bytebuffer_for_socket_RX.limit()));

                Date d2 = new Date();

                long comm_tms = (d2.getTime() - d1.getTime());

                if(comm_tms < 200) {

                    Thread.sleep(200 - comm_tms);

                }

//                Date d2 = new Date();

//                long comm_tms = (d2.getTime() - d1.getTime());

//                if(comm_tms < 200) {

//                    Thread.sleep(200 - comm_tms);

//                }

                

                /*devinfo.setCmd(data.RES_Index);

                if((bytebuffer_for_socket_RX.limit()>=8) && (true == baseData.putByteBuffer(bytebuffer_for_socket_RX))){