package cn.ksource.web.facade.wbx.rcxj;
|
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.beans.CI_DAILY_PATROL_ITEM;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.core.util.StringUtil;
|
@Service("rcxjItemFacade")
|
@SuppressWarnings("unchecked")
|
public class RcxjItemFacadeImpl implements RcxjItemFacade {
|
|
@Autowired
|
private BaseDao baseDao;
|
|
@Override
|
public List<Map> queryPzflTree(HttpServletRequest request) {
|
Map paramMap = new HashMap();
|
String selectSubSql = "SELECT * FROM CMDB_CI_CATEGORY WHERE TYPE = 1 AND STATE = 1 AND CATE_TYPE=1 ORDER BY LV,SERIAL ";
|
List<Map> cates = baseDao.queryForList(selectSubSql,paramMap);
|
Map result = new HashMap();
|
|
List<Map> resultList = new LinkedList<Map>();
|
|
Map<String, Map> yjgnCache = new HashMap<String, Map>();
|
Map<String, Map> ejgnCache = new HashMap<String, Map>();
|
Map<String, Map> sjgnCache = new HashMap<String, Map>();
|
|
for (Map map : cates) {
|
String level = map.get("LV").toString();
|
String id = map.get("ID").toString();
|
|
//一级树
|
if (level.equalsIgnoreCase("1")) {
|
yjgnCache.put(id, map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (level.equalsIgnoreCase("2")) {
|
String pId = map.get("PID").toString();
|
if(yjgnCache.containsKey(pId)) {
|
Map yjgnMap = yjgnCache.get(pId);
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
map.put("sjTree", new LinkedList<Map>());
|
list.add(map);
|
|
ejgnCache.put(id, map);
|
}
|
continue;
|
}
|
//三级树
|
if (level.equalsIgnoreCase("3")) {
|
if(null!=map.get("PID")){
|
String pId = map.get("PID").toString();
|
if(ejgnCache.containsKey(pId)) {
|
Map ejgnMap = ejgnCache.get(map.get("PID").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("sjTree");
|
list.add(map);
|
}
|
}
|
}
|
}
|
System.out.println(JsonUtil.list2Json(resultList));
|
return resultList;
|
}
|
|
@Override
|
public int rcxjxListCount(Map<String,String> params) {
|
String categoryId = params.get("pId");
|
SqlParameter param = new SqlParameter();
|
|
StringBuilder builder = new StringBuilder("SELECT COUNT(ID) FROM CI_DAILY_PATROL_ITEM WHERE ITEM_TYPE = 1");
|
|
if(StringUtils.isNotBlank(categoryId)){
|
builder.append(" AND BUSINESS_ID = :categoryId ");
|
param.addValue("categoryId", categoryId);
|
}
|
|
return baseDao.queryForInteger(builder.toString(),param);
|
}
|
|
@Override
|
public PageInfo rcxjxListData(PageInfo pageInfo,Map<String,String> params) {
|
String categoryId = params.get("pId");
|
SqlParameter param = new SqlParameter();
|
|
StringBuilder builder = new StringBuilder("SELECT * FROM CI_DAILY_PATROL_ITEM WHERE ITEM_TYPE = 1");
|
|
|
if(StringUtils.isNotBlank(categoryId)){
|
builder.append(" AND BUSINESS_ID = :categoryId ");
|
param.addValue("categoryId", categoryId);
|
}
|
builder.append(" ORDER BY STATE,ORDER_NUM ");
|
|
PageInfo info = baseDao.queryforSplitPageInfo(pageInfo,builder.toString(),param);
|
return info;
|
|
}
|
|
@Override
|
public CI_DAILY_PATROL_ITEM getCiDailyItem(String id) {
|
return new CI_DAILY_PATROL_ITEM(id).getInstanceById();
|
}
|
|
@Override
|
public void saveItem(CI_DAILY_PATROL_ITEM item) {
|
String id = item.getId();
|
item.insertOrUpdate();
|
if(StringUtil.isEmpty(id)){
|
SqlParameter param = new SqlParameter();
|
param.addValue("item_id", item.getId())
|
.addValue("id", StringUtil.getUUID())
|
.addValue("customer_id","-1");
|
String sql = " insert into ci_daily_patrol_customer_item (id,customer_id,item_id,using_state) "
|
+ " values (:id,:customer_id,:item_id,1) ";
|
baseDao.execute(sql, param);
|
}
|
}
|
|
@Override
|
public void updateItem(String id, String state) {
|
CI_DAILY_PATROL_ITEM item = new CI_DAILY_PATROL_ITEM();
|
item.setId(id);
|
item.setState(Integer.parseInt(state));
|
item.update();
|
String sql = "UPDATE CI_DAILY_PATROL_CUSTOMER_ITEM SET USING_STATE = :state WHERE ITEM_ID = :item_id AND CUSTOMER_ID = :customer_id ";
|
SqlParameter param = new SqlParameter();
|
param.addValue("item_id", id)
|
.addValue("state",state)
|
.addValue("customer_id","-1");
|
baseDao.execute(sql, param);
|
|
}
|
|
}
|
