From 75ebb56ab456cea188806a8ce685f46d687a9c82 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期六, 02 十一月 2024 13:54:15 +0800
Subject: [PATCH] 合并代码

---
 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TAccountingStrategyController.java |   40 +++++++++++++++++++++++++++++-----------
 1 files changed, 29 insertions(+), 11 deletions(-)

diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TAccountingStrategyController.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TAccountingStrategyController.java
index a4a794b..2855545 100644
--- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TAccountingStrategyController.java
+++ b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/controller/TAccountingStrategyController.java
@@ -1,6 +1,8 @@
 package com.ruoyi.chargingPile.controller;
 
 
+import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.ruoyi.account.api.model.TAppUser;
 import com.ruoyi.chargingPile.api.dto.TAccountingStrategyDTO;
@@ -119,16 +121,16 @@
         Long userId = SecurityUtils.getLoginUser().getUserid();
         dto.setUserId(userId);
         accountingStrategyService.save(dto);
+        // 添加明细
+        dto.getAccountingStrategyDetails().forEach(detail -> detail.setAccountingStrategyId(dto.getId()));
+        accountingStrategyDetailService.saveBatch(dto.getAccountingStrategyDetails());
         if(null != dto.getSiteId()){
             //下发硬件数据
             List<TChargingPile> list = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, dto.getSiteId()).eq(TChargingPile::getDelFlag, 0).list();
             for (TChargingPile tChargingPile : list) {
-                integrationClient.setupBillingModel1(tChargingPile.getCode());
+                integrationClient.setupBillingModel1(tChargingPile.getCode(), JSON.toJSONString(dto.getAccountingStrategyDetails()));
             }
         }
-        // 添加明细
-        dto.getAccountingStrategyDetails().forEach(detail -> detail.setAccountingStrategyId(dto.getId()));
-        accountingStrategyDetailService.saveBatch(dto.getAccountingStrategyDetails());
         return AjaxResult.ok(dto.getId());
     }
 
@@ -164,7 +166,10 @@
                 dto.setAuditStatus(1);
                 accountingStrategyService.updateById(dto);
                 // 添加明细
-                dto.getAccountingStrategyDetails().forEach(detail -> detail.setAccountingStrategyId(dto.getId()));
+                dto.getAccountingStrategyDetails().forEach(detail -> {
+                    detail.setAccountingStrategyId(dto.getId());
+                    detail.setId(null);
+                });
                 accountingStrategyDetailService.saveBatch(dto.getAccountingStrategyDetails());
             }else {
                 Long userId = SecurityUtils.getLoginUser().getUserid();
@@ -188,7 +193,10 @@
             dto.setAuditStatus(1);
             accountingStrategyService.updateById(dto);
             // 添加明细
-            dto.getAccountingStrategyDetails().forEach(detail -> detail.setAccountingStrategyId(dto.getId()));
+            dto.getAccountingStrategyDetails().forEach(detail -> {
+                detail.setAccountingStrategyId(dto.getId());
+                detail.setId(null);
+            });
             accountingStrategyDetailService.saveBatch(dto.getAccountingStrategyDetails());
         }
         
@@ -196,7 +204,7 @@
             //下发硬件数据
             List<TChargingPile> list = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, dto.getSiteId()).eq(TChargingPile::getDelFlag, 0).list();
             for (TChargingPile tChargingPile : list) {
-                integrationClient.setupBillingModel1(tChargingPile.getCode());
+                integrationClient.setupBillingModel1(tChargingPile.getCode(), JSON.toJSONString(dto.getAccountingStrategyDetails()));
             }
         }
         return AjaxResult.success();
@@ -360,14 +368,24 @@
                     TAccountingStrategy one = accountingStrategyService.lambdaQuery().eq(TAccountingStrategy::getId, byId.getParentId()).one();
                     byId.setSiteId(one.getSiteId());
                     //将site表对应的模板id修改为新的这个
-                    Site byId1 = siteService.getById(one.getSiteId());
-                    byId1.setAccountingStrategyId(byId.getId());
-                    siteService.updateById(byId1);
+                    List<Site> list = siteService.lambdaQuery().eq(Site::getAccountingStrategyId, one.getId()).list();
+                    for (Site site : list) {
+                        site.setAccountingStrategyId(byId.getId());
+                    }
+                    siteService.updateBatchById(list);
+                    //
+                    
+
+
+                    //
+                    accountingStrategyService.removeById(one.getId());
                 }
                 //硬件
+    
+                List<TAccountingStrategyDetail> accountingStrategyDetails = accountingStrategyDetailService.list(new LambdaQueryWrapper<TAccountingStrategyDetail>().eq(TAccountingStrategyDetail::getAccountingStrategyId, byId.getId()));
                 List<TChargingPile> list = chargingPileService.lambdaQuery().eq(TChargingPile::getSiteId, byId.getSiteId()).list();
                 for (TChargingPile tChargingPile : list) {
-                    integrationClient.setupBillingModel1(tChargingPile.getCode());
+                    integrationClient.setupBillingModel1(tChargingPile.getCode(), JSON.toJSONString(accountingStrategyDetails));
                 }
             }
         }else {

--
Gitblit v1.7.1