From da30b02214ab3a35a3b2ac163afce87e70a39ff4 Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期四, 23 六月 2022 10:30:10 +0800
Subject: [PATCH] fix : MySQL=》DMSQL
---
src/cn/ksource/web/facade/customerconfig/slacustomer/SlaCustomerFacadeImpl.java | 86 ++++++++++++++++++++----------------------
1 files changed, 41 insertions(+), 45 deletions(-)
diff --git a/src/cn/ksource/web/facade/customerconfig/slacustomer/SlaCustomerFacadeImpl.java b/src/cn/ksource/web/facade/customerconfig/slacustomer/SlaCustomerFacadeImpl.java
index d521c39..aeafa3c 100644
--- a/src/cn/ksource/web/facade/customerconfig/slacustomer/SlaCustomerFacadeImpl.java
+++ b/src/cn/ksource/web/facade/customerconfig/slacustomer/SlaCustomerFacadeImpl.java
@@ -1,15 +1,5 @@
package cn.ksource.web.facade.customerconfig.slacustomer;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import javax.servlet.http.HttpServletRequest;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
import cn.ksource.beans.CI_DAILY_PATROL_ITEM;
import cn.ksource.beans.CMDB_CI_CATEGORY;
import cn.ksource.core.dao.BaseDao;
@@ -18,7 +8,13 @@
import cn.ksource.core.util.ConvertUtil;
import cn.ksource.core.util.JsonUtil;
import cn.ksource.core.util.StringUtil;
-import cn.ksource.core.web.WebUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
@Service("slaCustomerFacade")
public class SlaCustomerFacadeImpl implements SlaCustomerFacade{
@Autowired
@@ -52,8 +48,8 @@
param.put("itemName", "%"+itemName+"%");
param.put("itemType", itemType);
param.put("state", state);
-
-
+
+
return baseDao.queryforSplitPageInfo(pageInfo, selectSql.toString(), param);
}
/**
@@ -155,10 +151,10 @@
String thirdCateId = param.get("business_id");
String thirdCateName = param.get("business_name");
String p_id = param.get("p_id");
-
+
item.setId(id).setState(1).setItem_type(2).setBusiness_id(thirdCateId).setBusiness_name(thirdCateName)
.setP_id(p_id).setCustomer_id(customerId).insert();
-
+
String insertSql = "INSERT INTO CI_DAILY_PATROL_CUSTOMER_ITEM(ID,CUSTOMER_ID,ITEM_ID,USING_STATE) VALUES (:id,:customerId,:itemId,1)";
param.put("id", StringUtil.getUUID());
param.put("itemId", id);
@@ -181,7 +177,7 @@
baseDao.execute(updateSql, param);
return true;
}
-
+
/**
* 鏌ヨ椤圭洰鍙互澧炲姞鐨勬寚鏍囬」
*/
@@ -238,7 +234,7 @@
param.put("itemName", "%"+itemName+"%");
return baseDao.queryForInteger(selectSql.toString(),param);
}
-
+
/**
* 淇濆瓨閫夋嫨鐨勬寚鏍囬」
*/
@@ -278,30 +274,30 @@
builder.append(" AND A.SUB_CUSTOMER_ID = :subCustomerId ");
paramMap.put("subCustomerId", subCustomerId);
}
-
+
if(StringUtil.notEmpty(categoryId)) {
builder.append(" AND B.LV3_ID = :categoryId ");
paramMap.put("categoryId", categoryId);
}
-
+
if(StringUtil.notEmpty(ciName)) {
builder.append(" AND B.CINAME LIKE :ciName ");
paramMap.put("ciName", "%"+ciName+"%");
}
-
+
builder.append(" ORDER BY B.CREATE_TIME DESC ");
-
+
PageInfo info = baseDao.queryforSplitPageInfo(pageInfo, builder.toString(), paramMap);
return info;
}
-
+
/**
* 鏃ュ父宸℃璁惧鏁伴噺
*/
@Override
public int queryDailyDeviceCount(String customerId,String subCustomerId,String categoryId,String ciName) {
StringBuilder builder = new StringBuilder("SELECT COUNT(A.ID) FROM CI_DAILY_PATROL_CI A,CMDB_CI_BASE B WHERE A.CI_ID = B.ID AND B.STATE = 1 AND A.CUSTOMER_ID = :customerId");
-
+
Map paramMap = new HashMap();
paramMap.put("customerId", customerId);
if(StringUtil.notEmpty(subCustomerId)) {
@@ -312,16 +308,16 @@
builder.append(" AND B.LV3_ID = :categoryId ");
paramMap.put("categoryId", categoryId);
}
-
+
if(StringUtil.notEmpty(ciName)) {
builder.append(" AND B.CINAME LIKE :ciName ");
paramMap.put("ciName", "%"+ciName+"%");
}
-
+
int count = baseDao.queryForInteger(builder.toString(),paramMap);
return count;
}
-
+
@Override
public List queryAddDailyDevice(String customerId,String subCustomerId,String ciName,String cateId,String sub_customer_id) {
StringBuilder builder = new StringBuilder("SELECT A.ID,A.SEARCHCODE,A.CINAME,A.LV3_NAME,A.POSITION,A.CUS_ID,A.SUB_CUS_ID,A.SUB_CUS_NAME " +
@@ -344,12 +340,12 @@
builder.append(" AND A.LV3_ID = :cateId ");
paramMap.put("cateId", cateId);
}
-
+
builder.append(" AND NOT EXISTS (SELECT B.ID FROM CI_DAILY_PATROL_CI B WHERE A.ID = B.CI_ID AND B.CUSTOMER_ID = :customerId ) ORDER BY A.CREATE_TIME DESC ");
List devices = baseDao.queryForList(builder.toString(),paramMap);
return devices;
}
-
+
@Override
public Integer queryAddDailyDeviceCount(String customerId,
String subCustomerId, String ciName, String cateId,
@@ -374,11 +370,11 @@
builder.append(" AND A.LV3_ID = :cateId ");
paramMap.put("cateId", cateId);
}
-
+
builder.append(" AND NOT EXISTS (SELECT B.ID FROM CI_DAILY_PATROL_CI B WHERE A.ID = B.CI_ID AND B.CUSTOMER_ID = :customerId ) ORDER BY A.CREATE_TIME DESC ");
Integer i = baseDao.queryForInteger(builder.toString(),paramMap);
return i;
- }
+ }
/**
* 娣诲姞椤圭洰闇�宸℃璁惧
* @param request
@@ -415,8 +411,8 @@
baseDao.execute(deleteSql, new SqlParameter("id",id));
return true;
}
-
-
+
+
/**
* 鏌ヨ鍋ュ悍妫�鏌ユ寚鏍囬」閰嶇疆
* @param request
@@ -592,7 +588,7 @@
String steps=param.get("steps");
String expect_value=param.get("expect_value");
String order_num = param.get("order_num");
-
+
String[] cateIds = param.get("full_cate_id").split("-");
String[] cateNames = param.get("full_cate_name").split("-");
if (cateIds.length == 3) {
@@ -604,9 +600,9 @@
param.put("business_name", cateNames[1]);
param.put("p_id", cateIds[0]);
}
-
+
String id = StringUtil.getUUID();
-
+
String insertSql = "INSERT INTO CI_HEALTH_ITEM(ID,ITEM_NAME,PRIORITY_LEVEL_ID,PRIORITY_LEVEL_NAME,ITEM_NOTE,ORDER_NUM,STATE,BUSINESS_ID,BUSINESS_NAME,ITEM_TYPE,CUSTOMER_ID,STEPS,EXPECT_VALUE,P_ID,FULL_CATE_ID,FULL_CATE_NAME) VALUES " +
"(:id,:item_name,:priority_level_id,:priority_level_name,:item_note,:order_num,1,:business_id,:business_name,2,:customerId,:steps,:expect_value,:pId,:full_cate_id,:full_cate_name)";
param.put("id", id);
@@ -621,9 +617,9 @@
param.put("steps", steps);
param.put("expect_value", expect_value);
param.put("pId", param.get("p_id"));
-
+
baseDao.execute(insertSql, param);
-
+
String saveProjectItemSql = "INSERT INTO CI_HEALTH_CUSTOMER_ITEM(ID,CUSTOMER_ID,ITEM_ID,USING_STATE) VALUES (:id,:customerId,:item_id,1)";
Map params = new HashMap();
String projectItemId = StringUtil.getUUID();
@@ -659,7 +655,7 @@
baseDao.execute(updateSql, param);
return true;
}
-
+
/**
* 鏌ヨ閫氱敤宸℃椤瑰垎绫�
*/
@@ -765,7 +761,7 @@
baseDao.execute(updateSql, param);
return true;
}
-
+
/**
* 鍚敤鎴栬�呯鐢ㄩ�氱敤宸℃椤瑰垎绫�
*/
@@ -779,7 +775,7 @@
baseDao.execute(updateSql, param);
return true;
}
-
+
/**
* 鍚敤鎴栬�呯鐢ㄩ�氱敤宸℃椤�
*/
@@ -793,13 +789,13 @@
baseDao.execute(updateSql, param);
return true;
}
-
+
/**
* 鑾峰彇璁惧鍒嗙被鏍�
*/
@Override
public List<Map> getCiCategoryTree(String pid,String type) {
- String sql = " SELECT ID as id,PID as pid,NAME as name,LV as jb,STATE,SERIAL FROM CMDB_CI_CATEGORY WHERE STATE=1 ";
+ String sql = " SELECT ID as id,PID as pid,NAME as \"name\",LV as jb,STATE,SERIAL FROM CMDB_CI_CATEGORY WHERE STATE=1 ";
SqlParameter param = new SqlParameter();
if(StringUtil.notEmpty(type)){
sql+=" and cate_type=:type";
@@ -817,7 +813,7 @@
sql="";
sql="select DISTINCT LV1_ID AS id,\n" +
" '0' AS pid ,\n" +
- " LV1_name AS name,\n" +
+ " LV1_name AS \"name\",\n" +
" '1' AS lv,STATE,SERIAL from CMDB_CI_CATEGORY where STATE=1 and lv=3 and CATE_TYPE=2 ";
}else if(StringUtil.isNotBlank(pid) && type.equals("2")){
CMDB_CI_CATEGORY cmdb_ci_category=new CMDB_CI_CATEGORY(pid).getInstanceById();
@@ -826,11 +822,11 @@
sql="";
sql="select DISTINCT LV1_ID AS id,\n" +
" '0' AS pid ,\n" +
- " LV1_name AS name,\n" +
+ " LV1_name AS \"name\",\n" +
" '1' AS lv,STATE,SERIAL from CMDB_CI_CATEGORY where STATE=1 and lv=3 and CATE_TYPE=2 and LV1_ID=:pid ";
param.addValue("pid", pid);
}
-
+
}
sql += " ORDER BY STATE,SERIAL ";
List<Map> list = baseDao.queryForList(sql,param);
--
Gitblit v1.9.1