From 346b480ab7848c742065e9bf989abaf43b515613 Mon Sep 17 00:00:00 2001
From: zhubaomin <zhubaomin>
Date: 星期一, 21 四月 2025 15:05:26 +0800
Subject: [PATCH] 获取轮灌组详情

---
 pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java |   94 ++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 92 insertions(+), 2 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java b/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java
index eaf3213..c535adf 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-base/src/main/java/com/dy/pipIrrBase/util/InitListener.java
@@ -6,14 +6,18 @@
 import com.dy.common.util.ConfigXml4Springboot;
 import com.dy.common.util.MD5;
 import com.dy.pipIrrGlobal.daoBa.*;
+import com.dy.pipIrrGlobal.daoOp.OpeTaskTypeMapper;
 import com.dy.pipIrrGlobal.daoPr.PrWaterPriceMapper;
 import com.dy.pipIrrGlobal.daoRm.RmIrrigateProfileMapper;
 import com.dy.pipIrrGlobal.daoSe.SePaymentMethodMapper;
+import com.dy.pipIrrGlobal.daoSe.SeRechargeProfileMapper;
 import com.dy.pipIrrGlobal.daoSe.SeWaterTypeMapper;
 import com.dy.pipIrrGlobal.pojoBa.*;
+import com.dy.pipIrrGlobal.pojoOp.OpeTaskType;
 import com.dy.pipIrrGlobal.pojoPr.PrWaterPrice;
 import com.dy.pipIrrGlobal.pojoRm.RmIrrigateProfile;
 import com.dy.pipIrrGlobal.pojoSe.SePaymentMethod;
+import com.dy.pipIrrGlobal.pojoSe.SeRechargeProfile;
 import com.dy.pipIrrGlobal.pojoSe.SeWaterType;
 import com.dy.pipIrrGlobal.util.DistrictLevel;
 import org.jdom2.Document;
@@ -44,6 +48,8 @@
     private PrWaterPriceMapper prWaterPriceDao;
     private BaDictMapper baDictDao;
     private BaDictItemMapper baDictItemDao;
+    private SeRechargeProfileMapper seRechargeProfileDao;
+    private OpeTaskTypeMapper taskTypeDao;
 
     @Autowired
     public void setResourceLoader(ResourceLoader resourceLoader){
@@ -93,6 +99,16 @@
     @Autowired
     public void setBaDictItemDao(BaDictItemMapper baDictItemDao) {
         this.baDictItemDao = baDictItemDao;
+    }
+
+    @Autowired
+    public void setSeRechargeProfileDao(SeRechargeProfileMapper seRechargeProfileDao) {
+        this.seRechargeProfileDao = seRechargeProfileDao;
+    }
+
+    @Autowired
+    public void setOpeTaskTypeDao(OpeTaskTypeMapper taskTypeDao) {
+        this.taskTypeDao = taskTypeDao;
     }
 
     /**
@@ -205,6 +221,21 @@
                                 }
                             }
                         }
+
+                        if(!this.existRechargeProfile()){
+                            if(configXml.existElement(doc, "config.orgs.org" + num + ".rechargeProfile")){
+                                for(int i = 1 ; i < 10000; i++){
+                                    if(configXml.existElement(doc, "config.orgs.org" + num + ".rechargeProfile.item" + i)){
+                                        String rechargeAmount = configXml.getSetAttrTxt(doc, "config.orgs.org" + num + ".rechargeProfile.item" + i,"rechargeAmount", null, false, null) ;
+                                        String sort = configXml.getSetAttrTxt(doc, "config.orgs.org" + num + ".rechargeProfile.item" + i,"sort", null, false, null) ;
+                                        this.saveRechargeProfile(orgTag, rechargeAmount, sort);
+                                    }else{
+                                        break ;
+                                    }
+                                }
+                            }
+                        }
+
                         if(!this.existWaterTypes()){
                             if(configXml.existElement(doc, "config.orgs.org" + num + ".waterTypes")){
                                 for(int i = 1 ; i < 10000; i++){
@@ -245,6 +276,20 @@
                                 }
                             }
                         }
+
+                        if(!this.existTaskType()){
+                            if(configXml.existElement(doc, "config.orgs.org" + num + ".taskType")){
+                                for(int i = 1 ; i < 10000; i++){
+                                    if(configXml.existElement(doc, "config.orgs.org" + num + ".taskType.item" + i)){
+                                        String taskType = configXml.getSetAttrTxt(doc, "config.orgs.org" + num + ".taskType.item" + i,"typeName", null, false, null) ;
+                                        this.saveTaskType(orgTag, taskType);
+                                    }else{
+                                        break ;
+                                    }
+                                }
+                            }
+                        }
+
                     }
                 }else{
                     break ;
@@ -308,6 +353,15 @@
     }
 
     /**
+     * 鏁版嵁搴撲腑鏄惁瀛樺湪铏氭嫙甯哥敤鍏呭�奸噾棰濋厤缃�
+     * @return
+     */
+    private boolean existRechargeProfile() {
+        Long total = this.seRechargeProfileDao.selectCount(null);
+        return (total != null && total > 0);
+    }
+
+    /**
      * 鏁版嵁搴撲腑鏄惁瀛樺湪姘翠环
      * @return
      */
@@ -323,6 +377,15 @@
     private boolean existDict() {
         Long total = this.baDictDao.selectCount(null);
         return (total != null && total > 0) ;
+    }
+
+    /**
+     * 鏁版嵁搴撲腑鏄惁瀛樺湪宸ュ崟浠诲姟绫诲瀷
+     * @return
+     */
+    private boolean existTaskType() {
+        Long total = this.taskTypeDao.selectCount(null);
+        return (total != null && total > 0);
     }
 
     /**
@@ -446,6 +509,22 @@
     }
 
     /**
+     * 淇濆瓨铏氭嫙鍗″父鐢ㄥ厖鍊奸噾棰濋厤缃�
+     * @param orgTag
+     * @param recharge_amount
+     * @param sort
+     */
+    private void saveRechargeProfile(String orgTag, String recharge_amount, String sort) {
+        if((recharge_amount != null && !recharge_amount.trim().equals("")) && (sort != null && !sort.trim().equals(""))) {
+            SeRechargeProfile po = new SeRechargeProfile();
+            po.setRechargeAmount(Integer.parseInt(recharge_amount));
+            po.setSort(Integer.parseInt(sort));
+            this.seRechargeProfileDao.insert(po);
+
+        }
+    }
+
+    /**
      * 淇濆瓨姘翠环
      * @param price
      */
@@ -504,9 +583,20 @@
             po.setDeleted(0L);
             this.baDictItemDao.insert(po);
         }
-
     }
 
-
+    /**
+     * 淇濆瓨宸ュ崟浠诲姟绫诲瀷
+     * @param orgTag
+     * @param task_type
+     */
+    private void saveTaskType(String orgTag, String task_type) {
+        if(task_type != null && !task_type.trim().equals("")) {
+            OpeTaskType po = new OpeTaskType();
+            po.setTaskType(task_type);
+            po.setDeleted(0L);
+            this.taskTypeDao.insert(po);
+        }
+    }
 
 }

--
Gitblit v1.8.0