package cn.ksource.web.facade.emergencyPlan;
|
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.web.service.WorkOrderCodeService;
|
/**
|
* 应急预案管理接口实现
|
* @author gaofazhan
|
*2018-03-14
|
*/
|
@Service
|
public class EmergencyPlanFacadeImpl implements EmergencyPlanFacade{
|
@Autowired
|
private BaseDao baseDao;
|
@Autowired
|
private WorkOrderCodeService workOrderCodeService;
|
@SuppressWarnings({ "rawtypes", "unchecked" })
|
@Override
|
public PageInfo getEmergencyPlanData(Map param, PageInfo pageInfo) {
|
String sql="select * from emergency_plan where state=1 ";
|
String plan_name=ConvertUtil.obj2StrBlank(param.get("plan_name"));
|
if(StringUtil.notEmpty(plan_name)){
|
param.put("plan_name", "%"+plan_name+"%");
|
sql+=" AND PLAN_NAME like :plan_name ";
|
}
|
String cusId=ConvertUtil.obj2StrBlank(param.get("cusId"));
|
if(StringUtil.notEmpty(cusId)){
|
sql+=" AND CUSTOMER_ID =:cusId ";
|
}
|
String subCusId=ConvertUtil.obj2StrBlank(param.get("subCusId"));
|
if(StringUtil.notEmpty(subCusId)){
|
sql+=" AND SUB_CUSTOMER_ID =:subCusId ";
|
}
|
String startDate=ConvertUtil.obj2StrBlank(param.get("startDate"));
|
if(StringUtil.notEmpty(startDate)){
|
sql+=" AND CREATE_TIME>=:startDate ";
|
}
|
String endDate=ConvertUtil.obj2StrBlank(param.get("endDate"));
|
if(StringUtil.notEmpty(endDate)){
|
sql+=" AND CREATE_TIME<=:endDate ";
|
}
|
PageInfo info=baseDao.queryforSplitPageInfo(pageInfo, sql, param);
|
List<Map> list=info.getDatas();
|
if(list.size()>0){
|
for(Map map:list){
|
List<Map> dateList=new LinkedList<Map>();
|
param.put("plan_id", ConvertUtil.obj2StrBlank(map.get("ID")));
|
String sqlb="select * from emergency_date where plan_id=:plan_id";
|
String is_zx="1";
|
List<Map> dates=baseDao.queryForList(sqlb, param);
|
if(dates.size()>0){
|
for(Map mapa:dates){
|
dateList.add(mapa);
|
String zx=ConvertUtil.obj2StrBlank(mapa.get("IS_ORDER"));
|
if(zx.equals("0")){
|
is_zx="0";
|
}
|
}
|
}
|
map.put("dateList", dateList);
|
map.put("is_zx", is_zx);
|
}
|
}
|
return info;
|
}
|
|
@SuppressWarnings({ "rawtypes", "unchecked" })
|
@Override
|
public int getEmergencyPlanCount(Map param) {
|
String sql="select COUNT(ID) from emergency_plan where state=1 ";
|
String plan_name=ConvertUtil.obj2StrBlank(param.get("plan_name"));
|
if(StringUtil.notEmpty(plan_name)){
|
param.put("plan_name", "%"+plan_name+"%");
|
sql+=" AND PLAN_NAME like :plan_name ";
|
}
|
String cusId=ConvertUtil.obj2StrBlank(param.get("cusId"));
|
if(StringUtil.notEmpty(cusId)){
|
sql+=" AND CUSTOMER_ID =:cusId ";
|
}
|
String subCusId=ConvertUtil.obj2StrBlank(param.get("subCusId"));
|
if(StringUtil.notEmpty(subCusId)){
|
sql+=" AND SUB_CUSTOMER_ID =:subCusId ";
|
}
|
String startDate=ConvertUtil.obj2StrBlank(param.get("startDate"));
|
if(StringUtil.notEmpty(startDate)){
|
sql+=" AND CREATE_TIME>=:startDate ";
|
}
|
String endDate=ConvertUtil.obj2StrBlank(param.get("endDate"));
|
if(StringUtil.notEmpty(endDate)){
|
sql+=" AND CREATE_TIME<=:endDate ";
|
}
|
return baseDao.queryForInteger(sql, param);
|
}
|
|
@SuppressWarnings("rawtypes")
|
@Override
|
public Map getEmergencyPlan(Map param) {
|
String sql="select * from emergency_plan where id=:id";
|
return baseDao.queryForMap(sql, param);
|
}
|
|
@SuppressWarnings("rawtypes")
|
@Override
|
public List<Map> getDateList(Map param) {
|
String sql="select * from emergency_date where PLAN_ID=:id";
|
return baseDao.queryForList(sql, param);
|
}
|
|
@SuppressWarnings({ "unchecked", "rawtypes" })
|
@Override
|
public void saveEmergencyPlan(Map param) {
|
String id=StringUtil.getUUID();
|
param.put("id", id);
|
param.put("create_time", DateUtil.getCurrentDate14());
|
String sql="insert into emergency_plan(ID,PLAN_NAME,CUSTOMER_ID,CUSTOMER_NAME,SUB_CUSTOMER_ID," +
|
"SUB_CUSTOMER_NAME,INTENT,PLAN_RANGE,STANDARD,LEVEL,DUTY,PLAN_DESCRIBE,SOLVE,PREVENTION,COMMAND," +
|
"CREATE_TIME,PARTAKE,STATE,USER_ID,USER_NAME) values(:id,:plan_name,:customer_id,:customer_name," +
|
":sub_customer_id,:sub_customer_name,:intent,:plan_range,:standard,:level,:duty,:plan_describe,:solve," +
|
":prevention,:command,:create_time,:partake,1,:userId,:userName)";
|
baseDao.execute(sql, param);
|
String ylDate=ConvertUtil.obj2StrBlank(param.get("ylDate"));
|
if(StringUtil.notEmpty(ylDate)){
|
String[] times=ylDate.split(",");
|
for(int i=0;i<times.length;i++){
|
String time=times[i].replace("-", "");
|
param.put("time", time);
|
String did= StringUtil.getUUID();
|
param.put("did",did );
|
String sqla="insert into emergency_date(ID,PLAN_ID,PLAN_DATE,IS_ORDER) values(:did,:id,:time,:is_order)";
|
|
Long now=DateUtil.getCurrentDate8();
|
Long sevenTime=DateUtil.getDateAdd(now, 7, 8);
|
if(sevenTime>=ConvertUtil.obj2Long(time)){
|
//生成工单
|
param.put("is_order", 0);
|
baseDao.execute(sqla, param);
|
param.put("yid", StringUtil.getUUID());
|
String order_code = workOrderCodeService.getYatOrderCode();
|
param.put("order_code", order_code);
|
String sqlb="insert into emergency_drill(ID,PLAN_ID,DATE_ID,ORDER_CODE,IS_ZX) " +
|
"values(:yid,:id,:did,:order_code,2)";
|
baseDao.execute(sqlb, param);
|
}else{
|
param.put("is_order", 1);
|
baseDao.execute(sqla, param);
|
}
|
|
}
|
}
|
}
|
|
@SuppressWarnings({ "unchecked", "rawtypes" })
|
@Override
|
public void updateEmergencyPlan(Map param) {
|
String sql="update emergency_plan set PLAN_NAME=:plan_name,CUSTOMER_ID=:customer_id," +
|
"CUSTOMER_NAME=:customer_name,SUB_CUSTOMER_ID=:sub_customer_id," +
|
"SUB_CUSTOMER_NAME=:sub_customer_name,INTENT=:intent,PLAN_RANGE=:plan_range,STANDARD=:standard," +
|
"LEVEL=:level,DUTY=:duty,PLAN_DESCRIBE=:plan_describe,SOLVE=:solve,PREVENTION=:prevention," +
|
"COMMAND=:command,PARTAKE=:partake where id=:id";
|
baseDao.execute(sql, param);
|
String sqlc="delete from emergency_date where plan_id=:id";
|
baseDao.execute(sqlc, param);
|
String ylDate=ConvertUtil.obj2StrBlank(param.get("ylDate"));
|
if(StringUtil.notEmpty(ylDate)){
|
String[] times=ylDate.split(",");
|
for(int i=0;i<times.length;i++){
|
String time=times[i].replace("-", "");
|
param.put("time", time);
|
String did= StringUtil.getUUID();
|
param.put("did",did );
|
String sqla="insert into emergency_date(ID,PLAN_ID,PLAN_DATE,IS_ORDER) values(:did,:id,:time,:is_order)";
|
|
Long now=DateUtil.getCurrentDate8();
|
|
Long sevenTime=DateUtil.getDateAdd(now, 7, 8);
|
if(sevenTime>=ConvertUtil.obj2Long(time)){
|
//生成工单
|
param.put("is_order", 0);
|
baseDao.execute(sqla, param);
|
param.put("yid", StringUtil.getUUID());
|
String order_code = workOrderCodeService.getYatOrderCode();
|
param.put("order_code", order_code);
|
String sqlb="insert into emergency_drill(ID,PLAN_ID,DATE_ID,ORDER_CODE,IS_ZX) " +
|
"values(:yid,:id,:did,:order_code,2)";
|
baseDao.execute(sqlb, param);
|
}else{
|
param.put("is_order", 1);
|
baseDao.execute(sqla, param);
|
}
|
|
}
|
}
|
}
|
|
@SuppressWarnings("rawtypes")
|
@Override
|
public void delEmergencyPlan(Map param) {
|
String sql="update emergency_plan set STATE=2 where id=:id ";
|
baseDao.execute(sql, param);
|
}
|
|
@SuppressWarnings({ "unchecked", "rawtypes" })
|
@Override
|
public PageInfo getEmergencyDrillData(Map param, PageInfo pageInfo) {
|
String sql="select a.*,b.plan_date,c.order_code,c.is_zx,c.id cid,b.id bid from emergency_plan a,emergency_date b,emergency_drill c" +
|
" where a.state=1 and a.id=b.plan_id and a.id=c.plan_id and c.date_id=b.id ";
|
String plan_name=ConvertUtil.obj2StrBlank(param.get("plan_name"));
|
if(StringUtil.notEmpty(plan_name)){
|
param.put("plan_name", "%"+plan_name+"%");
|
sql+=" AND a.PLAN_NAME like :plan_name ";
|
}
|
String plan_id=ConvertUtil.obj2StrBlank(param.get("plan_id"));
|
if(StringUtil.notEmpty(plan_id)){
|
sql+=" AND a.ID = :plan_id ";
|
}
|
String cusId=ConvertUtil.obj2StrBlank(param.get("cusId"));
|
if(StringUtil.notEmpty(cusId)){
|
sql+=" AND a.CUSTOMER_ID =:cusId ";
|
}
|
String subCusId=ConvertUtil.obj2StrBlank(param.get("subCusId"));
|
if(StringUtil.notEmpty(subCusId)){
|
sql+=" AND a.SUB_CUSTOMER_ID =:subCusId ";
|
}
|
String startDate=ConvertUtil.obj2StrBlank(param.get("startDate"));
|
if(StringUtil.notEmpty(startDate)){
|
sql+=" AND a.CREATE_TIME>=:startDate ";
|
}
|
String endDate=ConvertUtil.obj2StrBlank(param.get("endDate"));
|
if(StringUtil.notEmpty(endDate)){
|
sql+=" AND a.CREATE_TIME<=:endDate ";
|
}
|
String plan_startDate=ConvertUtil.obj2StrBlank(param.get("plan_startDate"));
|
if(StringUtil.notEmpty(plan_startDate)){
|
sql+=" AND b.plan_date>=:plan_startDate ";
|
}
|
String plan_endDate=ConvertUtil.obj2StrBlank(param.get("plan_endDate"));
|
if(StringUtil.notEmpty(plan_endDate)){
|
sql+=" AND b.plan_date<=:plan_endDate ";
|
}
|
String order_code=ConvertUtil.obj2StrBlank(param.get("order_code"));
|
if(StringUtil.notEmpty(order_code)){
|
param.put("order_code", "%"+order_code+"%");
|
sql+=" AND c.ORDER_CODE like :order_code ";
|
}
|
String state=ConvertUtil.obj2StrBlank(param.get("state"));
|
if(StringUtil.notEmpty(state)){
|
sql+=" AND c.IS_ZX =:state ";
|
}
|
return baseDao.queryforSplitPageInfo(pageInfo, sql, param);
|
}
|
|
@SuppressWarnings({ "rawtypes", "unchecked" })
|
@Override
|
public int getEmergencyDrillCount(Map param) {
|
String sql="select count(c.id) from emergency_plan a,emergency_date b,emergency_drill c" +
|
" where a.state=1 and a.id=b.plan_id and a.id=c.plan_id and c.date_id=b.id ";
|
String plan_name=ConvertUtil.obj2StrBlank(param.get("plan_name"));
|
if(StringUtil.notEmpty(plan_name)){
|
param.put("plan_name", "%"+plan_name+"%");
|
sql+=" AND a.PLAN_NAME like :plan_name ";
|
}
|
String plan_id=ConvertUtil.obj2StrBlank(param.get("plan_id"));
|
if(StringUtil.notEmpty(plan_id)){
|
sql+=" AND a.ID = :plan_id ";
|
}
|
String cusId=ConvertUtil.obj2StrBlank(param.get("cusId"));
|
if(StringUtil.notEmpty(cusId)){
|
sql+=" AND a.CUSTOMER_ID =:cusId ";
|
}
|
String subCusId=ConvertUtil.obj2StrBlank(param.get("subCusId"));
|
if(StringUtil.notEmpty(subCusId)){
|
sql+=" AND a.SUB_CUSTOMER_ID =:subCusId ";
|
}
|
String startDate=ConvertUtil.obj2StrBlank(param.get("startDate"));
|
if(StringUtil.notEmpty(startDate)){
|
sql+=" AND a.CREATE_TIME>=:startDate ";
|
}
|
String endDate=ConvertUtil.obj2StrBlank(param.get("endDate"));
|
if(StringUtil.notEmpty(endDate)){
|
sql+=" AND a.CREATE_TIME<=:endDate ";
|
}
|
String order_code=ConvertUtil.obj2StrBlank(param.get("order_code"));
|
if(StringUtil.notEmpty(order_code)){
|
param.put("order_code", "%"+order_code+"%");
|
sql+=" AND c.ORDER_CODE like :order_code ";
|
}
|
String state=ConvertUtil.obj2StrBlank(param.get("state"));
|
if(StringUtil.notEmpty(state)){
|
sql+=" AND c.IS_ZX =:state ";
|
}
|
return baseDao.queryForInteger(sql, param);
|
}
|
|
@SuppressWarnings("rawtypes")
|
@Override
|
public Map getDrill(Map param) {
|
String sql="select a.*,a.COMMAND COMMAND_TWO,a.PARTAKE PARTAKE_TWO,c.*,b.plan_date,c.order_code,c.is_zx,c.id cid,c.command commandTwo,c.PARTAKE partakenTwo,b.id bid from emergency_plan a," +
|
"emergency_date b,emergency_drill c" +
|
" where a.state=1 and a.id=b.plan_id and a.id=c.plan_id and c.date_id=b.id and a.id=:planId and b.id=:dateId and c.id=:drillId ";
|
return baseDao.queryForMap(sql, param);
|
}
|
|
@SuppressWarnings("rawtypes")
|
@Override
|
public void saveDrill(Map param) {
|
String sql="update emergency_drill set IS_ZX=1,DEPART=:depart,COMMAND=:command,PARTAKE=:partake," +
|
"SITUATION=:situation,PROCESS=:process,STEP=:step,SUMMARY=:summary,DRILL_TYPE=:drill_type," +
|
"PLAN_TYPE=:plan_type,SUITABLE_TYPE=:suitable_type,FULL_TYPE=:full_type,PERSON_ONE_TYPE=:person_one_type," +
|
"PERSON_TWO_TYPE=:person_two_type,MATERIAL_TYPE=:material_type,PROTECT_TYPE=:protect_type," +
|
"ZTZZ_TYPE=:ztzz_type,YJFG_TYPE=:yjfg_type,PJ_TYPE=:pj_type,BG_TYPE=:bg_type,ZY_TYPE=:zy_type " +
|
"where id=:id ";
|
baseDao.execute(sql, param);
|
}
|
}
|
