package cn.ksource.web.facade.bpbj;
|
|
import java.util.ArrayList;
|
import java.util.Collections;
|
import java.util.Comparator;
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Stack;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.apache.commons.lang.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.ui.Model;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
|
import cn.ksource.beans.CMDB_CI_CATEGORY;
|
import cn.ksource.beans.GG_RECORD;
|
import cn.ksource.beans.SC_PARTNER_CUSTOMER_INFO;
|
import cn.ksource.beans.SC_PARTNER_CUSTOMER_SUB;
|
import cn.ksource.beans.SC_WORKFLOW_INCIDENT_LOCAL;
|
import cn.ksource.beans.SC_WORKFLOW_RELEASE;
|
import cn.ksource.beans.SPARE_PART;
|
import cn.ksource.beans.SPARE_PART_APPLY;
|
import cn.ksource.beans.SPARE_PART_APPLY_CATE;
|
import cn.ksource.beans.SPARE_PART_APPLY_ENTITY;
|
import cn.ksource.beans.SPARE_PART_STORAGE;
|
import cn.ksource.beans.WORKFLOW_BASE;
|
import cn.ksource.beans.WORKFLOW_NODE;
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.AjaxUtil;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
import cn.ksource.core.util.JsonUtil;
|
import cn.ksource.core.util.OrderCodeUtil;
|
import cn.ksource.core.util.StringUtil;
|
import cn.ksource.core.util.TwoDimensionCode;
|
import cn.ksource.core.web.SysInfoMsg;
|
import cn.ksource.core.web.WebUtil;
|
import cn.ksource.core.workflow.NodeDealEntity;
|
import cn.ksource.core.workflow.NodeFinishEntity;
|
import cn.ksource.core.workflow.WorkflowBusinessService;
|
import cn.ksource.core.workflow.WorkflowCoreService;
|
import cn.ksource.web.Constants;
|
import cn.ksource.web.entity.WorkFlowSupportEntity;
|
import cn.ksource.web.service.WorkOrderCodeService;
|
import cn.ksource.web.service.record.RecordService;
|
import cn.ksource.web.service.workFlowSupport.WorkFlowSupportService;
|
|
@Service("SparePartsFacade")
|
public class SparePartsFacadeImpl implements SparePartsFacade {
|
@Resource
|
private BaseDao baseDao;
|
@Autowired
|
private WorkflowBusinessService workflowBusinessService;
|
@Autowired
|
private WorkOrderCodeService workOrderCodeService;
|
@Autowired
|
private WorkFlowSupportService workFlowSupportService;
|
@Autowired
|
private RecordService recordService;
|
@Resource
|
private WorkflowCoreService workflowCoreService;
|
/**
|
*备件申请列表信息
|
* @return
|
*/
|
@Override
|
public List<Map> getStockList() {
|
return baseDao.queryForList(" select * from SPARE_PART_APPLY where STATE=1 ");
|
}
|
/**
|
* 项目查询
|
* @return
|
*/
|
@Override
|
public List<Map> getCustomerList() {
|
String sql = "SELECT * FROM SC_PARTNER_CUSTOMER_INFO WHERE CUSTOMER_STATE = 1 ";
|
return baseDao.queryForList(sql);
|
}
|
/**
|
* 备件供应商查询
|
* @return
|
*/
|
@Override
|
public List<Map> getSupplierList() {
|
String sql = "SELECT * FROM SUPPLIER_INFO WHERE STATE = 1 ";
|
return baseDao.queryForList(sql);
|
}
|
/**
|
* 查询备件申请头部状态数量信息
|
* @param request
|
* @param type
|
* @return
|
*/
|
@Override
|
public Map queryOrderCountByCate(HttpServletRequest request){
|
String userId = WebUtil.getLoginedUserId(request);
|
Map<String,String> groupMap = WebUtil.getLoginUser(request).getGroupMap();
|
Map paramMap = new HashMap();
|
|
StringBuilder builder = new StringBuilder();
|
paramMap.put("create_id", userId);
|
builder.append("SELECT COUNT(1) AS 'TOTAL',SUM(CASE WHEN STATE=2 THEN 1 ELSE 0 END) AS 'AUDITING' ,SUM(CASE WHEN STATE=3 THEN 1 ELSE 0 END) AS 'DELIVERY',SUM(CASE WHEN STATE=4 THEN 1 ELSE 0 END) AS 'CONFIRM' FROM SPARE_PART_APPLY WHERE CREATE_ID=:create_id");
|
|
|
List<Map> list = baseDao.queryForList(builder.toString(),paramMap);
|
Map resultMap = new HashMap();
|
for(Map m : list) {
|
resultMap.put("TOTAL", m.get("TOTAL"));
|
resultMap.put("AUDITING", m.get("AUDITING"));
|
resultMap.put("DELIVERY", m.get("DELIVERY"));
|
resultMap.put("CONFIRM", m.get("CONFIRM"));
|
}
|
return resultMap;
|
}
|
/**
|
* 备件申请列表信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public PageInfo getStockListData(HttpServletRequest request,PageInfo pageInfo){
|
StringBuilder sql = new StringBuilder();
|
Map paramMap = new HashMap();
|
sql.append(" select * from SPARE_PART_APPLY where CREATE_ID=:create_id");
|
String order_code=request.getParameter("order_code");
|
String order_name=request.getParameter("order_name");
|
String state=request.getParameter("state");
|
String start_time=request.getParameter("start_time");
|
String end_time=request.getParameter("end_time");
|
String customer_id=request.getParameter("customer_id");
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userId = user.get("Id").toString();
|
paramMap.put("create_id",userId );
|
//项目
|
if (StringUtil.isNotBlank(customer_id)) {
|
sql.append(" and PROJECT_ID=:project_id ");
|
paramMap.put("project_id", customer_id);
|
}
|
//工单编号
|
if (StringUtil.isNotBlank(order_code)) {
|
sql.append(" and order_code like :order_code ");
|
paramMap.put("order_code","%"+order_code.trim()+"%");
|
}
|
//工单名称
|
if (StringUtil.isNotBlank(order_name)) {
|
sql.append(" and order_name like:order_name ");
|
paramMap.put("order_name", "%"+order_name.trim()+"%");
|
}
|
//工单状态
|
if (StringUtil.isNotBlank(state)) {
|
sql.append(" and state=:state ");
|
paramMap.put("state", state);
|
}
|
//开始时间
|
if(StringUtil.isNotBlank(start_time)){
|
sql.append(" AND gmt_create>=:start_time");
|
paramMap.put("start_time", start_time+"000000");
|
}
|
//结束时间
|
if(StringUtil.isNotBlank(end_time)){
|
sql.append(" and gmt_create<=:end_time");
|
paramMap.put("end_time", end_time+"235959");
|
}
|
sql.append(" order by gmt_create desc ");
|
return baseDao.queryforSplitPageInfo(pageInfo,sql.toString(), paramMap);
|
}
|
/**
|
* 备件申请列表数量信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public int getStockListCount(HttpServletRequest request) {
|
StringBuilder sql = new StringBuilder();
|
Map paramMap = new HashMap();
|
sql.append(" select count(*) from SPARE_PART_APPLY where CREATE_ID=:create_id ");
|
String order_code=request.getParameter("order_code");
|
String order_name=request.getParameter("order_name");
|
String state=request.getParameter("state");
|
String start_time=request.getParameter("start_time");
|
String end_time=request.getParameter("end_time");
|
String customer_id=request.getParameter("customer_id");
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userId = user.get("Id").toString();
|
paramMap.put("create_id",userId );
|
//项目
|
if (StringUtil.isNotBlank(customer_id)) {
|
sql.append(" and PROJECT_ID=:project_id ");
|
paramMap.put("project_id", customer_id);
|
}
|
//工单编号
|
if (StringUtil.isNotBlank(order_code)) {
|
sql.append(" and order_code like :order_code ");
|
paramMap.put("order_code","%"+order_code.trim()+"%");
|
}
|
//工单名称
|
if (StringUtil.isNotBlank(order_name)) {
|
sql.append(" and order_name like:order_name ");
|
paramMap.put("order_name", "%"+order_name.trim()+"%");
|
}
|
//工单状态
|
if (StringUtil.isNotBlank(state)) {
|
sql.append(" and state=:state ");
|
paramMap.put("state", state);
|
}
|
//开始时间
|
if(StringUtil.isNotBlank(start_time)){
|
sql.append(" AND gmt_create>=:start_time");
|
paramMap.put("start_time", start_time+"000000");
|
}
|
//结束时间
|
if(StringUtil.isNotBlank(end_time)){
|
sql.append(" and gmt_create<=:end_time");
|
paramMap.put("end_time", end_time+"235959");
|
}
|
sql.append(" order by gmt_create desc ");
|
int count = baseDao.queryForInteger(sql.toString(), paramMap);
|
return count;
|
|
}
|
/**
|
* 备件信息
|
* @param customerid
|
* @param subCustomerId
|
* @return
|
*/
|
@Override
|
public String getCustomerName(String customerid) {
|
String subCustomerName = new String();
|
if (StringUtil.notEmpty(customerid)) {
|
SC_PARTNER_CUSTOMER_INFO info = new SC_PARTNER_CUSTOMER_INFO(customerid).getInstanceById();
|
subCustomerName = info.getCustomer_name();
|
}
|
|
return subCustomerName;
|
}
|
/**
|
* 查询关联配置
|
* @param request
|
* @return
|
*/
|
@Override
|
public List queryLinkDevice(HttpServletRequest request) {
|
String seachcode = request.getParameter("seachcode");
|
String categoryid = request.getParameter("categoryid");
|
String customerid = request.getParameter("customerid");
|
String ciids = request.getParameter("ciids");
|
String cmdbName = AjaxUtil.decode(request.getParameter("cmdbName"));
|
String subCustomerId =customerid;
|
String membercode = request.getParameter("membercode");
|
String spare_part_apply_entity_id = request.getParameter("spare_part_apply_entity_id");
|
String orderId = request.getParameter("orderId");
|
Map paramMap = new HashMap();
|
|
//查询关联设备
|
StringBuilder builder = new StringBuilder("SELECT A.* FROM CMDB_CI_BASE A LEFT JOIN CMDB_CI_FLOW B ON A.ID = B.CFG_ID AND B.STATE = 4 WHERE A.STATE = 1 ");
|
|
String ciid[] = ciids.split("-");
|
if (!StringUtil.isEmpty(ciids)) {
|
String para = "";
|
for (int i = 0; i < ciid.length; i++) {
|
if (i < ciid.length - 1) {
|
para += ciid[i] + "','";
|
} else if (i == ciid.length - 1) {
|
para += ciid[i];
|
}
|
}
|
builder.append(" and A.ID NOT IN ('");
|
builder.append(para);
|
builder.append("') ");
|
}
|
if(StringUtil.isNotBlank(orderId)){
|
String sqlString="select CI_ID from CMDB_CI_REF_ORDER where FLOW_ID=(select FLOW_ID from SPARE_PART_APPLY where id=:orderId)";
|
paramMap.put("orderId", orderId);
|
List<Map> ci_ids = baseDao.queryForList(sqlString, paramMap);
|
if(ci_ids!=null && ci_ids.size()>0){
|
String ci_id_s = "";
|
for (Map ci_id :ci_ids){
|
String cmdb_ci_base_id=ConvertUtil.obj2StrBlank(ci_id.get("CI_ID"));
|
ci_id_s += cmdb_ci_base_id + "','";
|
}
|
builder.append(" and A.ID IN ('");
|
builder.append(ci_id_s);
|
builder.append("') ");
|
}else{
|
builder.append(" and A.ID IN ('");
|
builder.append("");
|
builder.append("') ");
|
}
|
}
|
if(StringUtil.isNotBlank(spare_part_apply_entity_id)){
|
String sqlString="select CI_ID from CMDB_CI_REF_ORDER where FLOW_ID=(select FLOW_ID from SPARE_PART_APPLY where id=(select ORDER_ID from SPARE_PART_APPLY_ENTITY where id=:spare_part_apply_entity_id))";
|
paramMap.put("spare_part_apply_entity_id", spare_part_apply_entity_id);
|
List<Map> ci_ids = baseDao.queryForList(sqlString, paramMap);
|
if(ci_ids!=null && ci_ids.size()>0){
|
String ci_id_s = "";
|
for (Map ci_id :ci_ids){
|
String cmdb_ci_base_id=ConvertUtil.obj2StrBlank(ci_id.get("CI_ID"));
|
ci_id_s += cmdb_ci_base_id + "','";
|
}
|
builder.append(" and A.ID IN ('");
|
builder.append(ci_id_s);
|
builder.append("') ");
|
}else{
|
builder.append(" and A.ID IN ('");
|
builder.append("");
|
builder.append("') ");
|
}
|
}
|
if(StringUtil.isNotBlank(customerid)){
|
builder.append(" AND A.CUS_ID =:customerId ");
|
paramMap.put("customerId", customerid);
|
}
|
|
if (StringUtil.notEmpty(cmdbName)) {
|
builder.append(" AND A.CINAME LIKE :ciName ");
|
paramMap.put("ciName", "%" + cmdbName + "%");
|
}
|
|
if (StringUtil.notEmpty(seachcode)) {
|
builder.append(" AND A.SEARCHCODE LIKE :seachcode ");
|
paramMap.put("seachcode", "%" + seachcode + "%");
|
}
|
|
if (StringUtil.notEmpty(membercode)) {
|
builder.append(" AND A.CODE = :membercode ");
|
paramMap.put("membercode", membercode);
|
}
|
|
/* if (StringUtil.notEmpty(subCustomerId)) {
|
builder.append(" AND A.SUB_CUS_ID = :subCustomerId ");
|
paramMap.put("subCustomerId", subCustomerId);
|
}*/
|
|
builder.append(" ORDER BY A.CODE ");
|
|
List<Map> devices = baseDao.queryForList(builder.toString(), paramMap);
|
|
for (Map device : devices) {
|
device.put("LASTUPDATETIME", DateUtil.format("yyyy-MM-dd HH:mm:ss", device.get("LASTUPDATETIME")));
|
int i = device.get("STATE") == null ? 0 : ConvertUtil.obj2Int(device.get("STATE"));
|
device.put("STATE", Constants.getCMDB_CI_BASE_USINGSTATE_Label(i));
|
}
|
System.out.println(JsonUtil.list2Json(devices));
|
return devices;
|
}
|
|
/**
|
* 查询申请备件列表
|
* @param request
|
* @return
|
*/
|
@Override
|
public List querySpareDeviceList(String orderId) {
|
Map paramMap = new HashMap();
|
paramMap.put("orderId", orderId);
|
String sqlString="SELECT\n" +
|
" cate.cate_id id,\n" +
|
" (select code from CMDB_CI_CATEGORY where id=gory.LV1_id) code1,\n" +
|
" (select code from CMDB_CI_CATEGORY where id=gory.LV2_id) code2,\n" +
|
" gory.LV1_NAME,\n" +
|
" gory.LV2_NAME,\n" +
|
" gory.LV3_NAME,\n" +
|
" gory. CODE,\n" +
|
" cate.CATE_NUM\n" +
|
"FROM\n" +
|
" SPARE_PART_APPLY_CATE cate\n" +
|
"LEFT JOIN CMDB_CI_CATEGORY gory ON cate.CATE_ID = gory.id\n" +
|
"WHERE\n" +
|
" cate.APPLY_ORDER_ID =:orderId order by cate.cate_id";
|
List<Map> devices = baseDao.queryForList(sqlString, paramMap);
|
return devices;
|
}
|
|
/**
|
* 查询关联配置信息
|
* @param request
|
* @return
|
*/
|
@Override
|
public List queryLinkDeviceList(String flowId) {
|
Map paramMap = new HashMap();
|
paramMap.put("flowId", flowId);
|
String sqlString="SELECT\n" +
|
" cmdb.CI_ID id,\n" +
|
" base.ciname,\n" +
|
" base.POSITION,\n" +
|
" base.SEARCHCODE\n" +
|
"FROM\n" +
|
" CMDB_CI_REF_ORDER cmdb\n" +
|
"LEFT JOIN CMDB_CI_BASE base ON cmdb.CI_ID = base.ID\n" +
|
"WHERE\n" +
|
" cmdb.FLOW_ID =:flowId";
|
List<Map> devices = baseDao.queryForList(sqlString, paramMap);
|
return devices;
|
}
|
/**
|
* 查询备件树列表信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public List<Map> stockListTreeData(HttpServletRequest request) {
|
String sql="select * from cmdb_ci_category where state=1 and cate_type=2 ";
|
|
|
String spareIds = request.getParameter("spareIds");
|
if(StringUtil.isNotBlank(spareIds)){
|
String spareId[] = spareIds.split("-");
|
if (!StringUtil.isEmpty(spareIds)) {
|
String para = "";
|
for (int i = 0; i < spareId.length; i++) {
|
if (i < spareId.length - 1) {
|
para += spareId[i] + "','";
|
} else if (i == spareId.length - 1) {
|
para += spareId[i];
|
}
|
}
|
sql+=" and ID NOT IN ('";
|
sql+=para;
|
sql+="') ";
|
}
|
}
|
sql+=" order BY lv";
|
List<Map> categoryList = baseDao.queryForList(sql);
|
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 : categoryList) {
|
String level = map.get("lv").toString();
|
|
//一级树
|
if (level.equalsIgnoreCase("1")) {
|
yjgnCache.put(map.get("ID").toString(), map);
|
List<Map> ejgnList = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
resultList.add(map);
|
continue;
|
}
|
//二级树
|
if (level.equalsIgnoreCase("2")) {
|
Map yjgnMap = yjgnCache.get(map.get("pid").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
map.put("sjTree", new LinkedList<Map>());
|
list.add(map);
|
|
ejgnCache.put(map.get("ID").toString(), map);
|
continue;
|
}
|
//三级树
|
if (level.equalsIgnoreCase("3")) {
|
if(null!=map.get("pid")){
|
Map ejgnMap = ejgnCache.get(map.get("pid").toString());
|
List<Map> list = (List<Map>)ejgnMap.get("sjTree");
|
list.add(map);
|
}
|
}
|
}
|
return resultList;
|
|
}
|
/**
|
* 保存备件信息
|
* @param request
|
* @param release
|
* @return
|
*/
|
@Override
|
public String saveSpare(HttpServletRequest request, SPARE_PART_APPLY spare_part_apply) {
|
String orderId = request.getParameter("orderId");
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userName = user.get("ZSXM").toString();
|
String userId = user.get("Id").toString();
|
String type = request.getParameter("type");
|
String customer_id = request.getParameter("customer_id");
|
String customer_name = request.getParameter("customer_name");
|
String dealId = request.getParameter("dealId");
|
String dealName = request.getParameter("dealName");
|
String bz = request.getParameter("bz");
|
if(StringUtil.isBlank(orderId)){
|
//工单编号
|
String order_code = workOrderCodeService.getSpareOrderCode();
|
spare_part_apply.setOrder_code(order_code);
|
spare_part_apply.setCreate_id(userId);
|
spare_part_apply.setCreate_name(userName);
|
spare_part_apply.setGmt_create(DateUtil.getCurrentDate14());
|
spare_part_apply.setProject_id(customer_id);
|
spare_part_apply.setProject_name(customer_name);
|
spare_part_apply.setState(Constants.SPARE_PART_APPLY_STATE_X);
|
spare_part_apply.insertOrUpdate();
|
orderId=spare_part_apply.getId();
|
workflowBusinessService.startSpareWorkflow(spare_part_apply.getId(),bz);
|
}else{
|
SPARE_PART_APPLY spare_part=new SPARE_PART_APPLY(orderId).getInstanceById();
|
String flowId=spare_part.getFlow_id();
|
spare_part_apply.setId(orderId);
|
spare_part_apply.setFlow_id(flowId);
|
spare_part_apply.setOrder_code(spare_part.getOrder_code());
|
spare_part_apply.setState(spare_part.getState());
|
if(StringUtil.isNotBlank(customer_name)){
|
spare_part_apply.setProject_id(customer_id);
|
spare_part_apply.setProject_name(customer_name);
|
}else{
|
spare_part_apply.setProject_id(spare_part.getProject_id());
|
spare_part_apply.setProject_name(spare_part.getProject_name());
|
}
|
|
spare_part_apply.update();
|
Map paramMap = new HashMap();
|
//删除关联配置表
|
if(StringUtil.isNotBlank(flowId)){
|
paramMap.put("flowId", flowId);
|
String sqlString="delete from CMDB_CI_REF_ORDER WHERE FLOW_ID =:flowId";
|
baseDao.execute(sqlString, paramMap);
|
|
/* String node="select id from WORKFLOW_NODE where FLOWID=:flowId and FLOWSTATE='3'";
|
List<Map> node_id = baseDao.queryForList(node, paramMap);
|
if(node_id!=null && node_id.size()>0){
|
String workflow_node_id = node_id.get(0).get("id").toString();
|
String current_dealer_name = node_id.get(0).get("CURRENT_DEALER_NAME").toString();
|
|
WORKFLOW_NODE workflow_node=new WORKFLOW_NODE(workflow_node_id).getInstanceById();
|
workflow_node.setCurrent_dealer_name(current_dealer_name);
|
workflow_node.setCurrent_dealer_id(workflow_node_id);
|
workflow_node.setCreatetime(DateUtil.getCurrentDate14());
|
workflow_node.update();
|
}*/
|
|
|
//删除申请备件变
|
paramMap.put("orderId", orderId);
|
String spare_part_apply_cate="delete from SPARE_PART_APPLY_CATE WHERE apply_order_id =:orderId";
|
baseDao.execute(spare_part_apply_cate, paramMap);
|
}
|
}
|
orderId=spare_part_apply.getId();
|
String[] spareDeviceId = request.getParameterValues("spareDeviceId");
|
if(spareDeviceId!=null && spareDeviceId.length>0){
|
for (String str : spareDeviceId) {
|
SPARE_PART_APPLY_CATE apply_cate = new SPARE_PART_APPLY_CATE();
|
String cate_id=str;
|
String num=request.getParameter(cate_id+"_cateNum");
|
if(StringUtil.isNotBlank(num)){
|
apply_cate.setCate_num(Integer.valueOf(num));
|
}
|
apply_cate.setApply_order_id(spare_part_apply.getId());
|
apply_cate.setCate_id(cate_id);
|
apply_cate.insertOrUpdate();
|
}
|
|
}
|
//关联配置ids
|
String[] linkDeviceIds = request.getParameterValues("linkDeviceId");
|
if(linkDeviceIds!=null &&linkDeviceIds.length>0 ){
|
SPARE_PART_APPLY spare_part=new SPARE_PART_APPLY(orderId).getInstanceById();
|
String flowid =spare_part.getFlow_id();
|
if(StringUtil.isNotBlank(flowid)){
|
//关联配置
|
workFlowSupportService.saveLinkDevices(flowid,linkDeviceIds);
|
}
|
}
|
SPARE_PART_APPLY spare_part=new SPARE_PART_APPLY(orderId).getInstanceById();
|
if(StringUtil.isNotBlank(dealId)){
|
String flowid= spare_part.getFlow_id();
|
WORKFLOW_BASE base=new WORKFLOW_BASE(flowid).getInstanceById();
|
NodeDealEntity entity = new NodeDealEntity();
|
entity.setDealer_type(2);
|
List<Map> userList = new ArrayList<Map>();
|
Map dealer = new HashMap();
|
dealer.put("USER_ID",dealId);
|
dealer.put("USER_NAME",dealName);
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
entity.setDealerList(userList);
|
workflowCoreService.toNode(base, Constants.BJSLSP, entity);
|
spare_part.setState(Constants.SPARE_PART_APPLY_STATE_S);
|
}
|
spare_part.update();
|
return orderId;
|
|
}
|
|
/**
|
* 流程节点查询
|
* @return
|
*/
|
@Override
|
public List<Map> getFlowList(String orderId) {
|
String sql = "SELECT\n" +
|
" WORKFLOW_NODE.id nextNoid,\n" +
|
" WORKFLOW_BASE.id flowid\n" +
|
"FROM\n" +
|
" WORKFLOW_BASE,\n" +
|
" WORKFLOW_NODE\n" +
|
"WHERE\n" +
|
" WORKFLOW_BASE.id = WORKFLOW_NODE.FLOWID\n" +
|
"AND WORKFLOW_BASE.BUSINESS_ID =:orderId\n" +
|
"AND WORKFLOW_NODE.FLOWSTATE = '1'";
|
Map paramMap = new HashMap();
|
paramMap.put("orderId", orderId);
|
return baseDao.queryForList(sql,paramMap);
|
}
|
|
/**
|
* 提交
|
* @param request
|
* @return
|
*/
|
@Override
|
public void doApproveAssign(HttpServletRequest request) {
|
String type = request.getParameter("type");
|
String orderId = request.getParameter("orderId");
|
String bz= request.getParameter("bz");
|
String flowid = request.getParameter("flowid");
|
String nexNodeId = request.getParameter("nexNodeId");
|
String dealId = request.getParameter("dealId");
|
String dealName = request.getParameter("dealName");
|
SPARE_PART_APPLY spare_part_apply=new SPARE_PART_APPLY(orderId).getInstanceById();
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userid=user.get("ID").toString();
|
String usernameString=user.get("ZSXM").toString();
|
flowid= spare_part_apply.getFlow_id();
|
WORKFLOW_BASE base=new WORKFLOW_BASE(flowid).getInstanceById();
|
String sqlString="SELECT\n" +
|
" WORKFLOW_BASE.id flowid,\n" +
|
" WORKFLOW_NODE.CURRENT_DEALER_ID userid,\n" +
|
" WORKFLOW_NODE.CURRENT_DEALER_NAME username,\n" +
|
" WORKFLOW_NODE.ID nodeid\n" +
|
"FROM\n" +
|
" WORKFLOW_BASE,\n" +
|
" WORKFLOW_NODE\n" +
|
"WHERE\n" +
|
" WORKFLOW_BASE.BUSINESS_ID =:business_id\n" +
|
"AND WORKFLOW_BASE.id = WORKFLOW_NODE.FLOWID\n" +
|
"AND WORKFLOW_NODE.FLOWSTATE = 1 and WORKFLOW_NODE.CURRENT_DEALER_ID=:userid";
|
Map paramMap = new HashMap();
|
paramMap.put("business_id",orderId);
|
paramMap.put("userid",userid);
|
List<Map> queryForList = baseDao.queryForList(sqlString, paramMap);
|
if(queryForList!=null && queryForList.size()>0){
|
String NodeId=queryForList.get(0).get("nodeid").toString();
|
String FlowId=queryForList.get(0).get("flowid").toString();
|
String UserName=queryForList.get(0).get("username").toString();
|
String Userid=queryForList.get(0).get("userid").toString();
|
NodeFinishEntity finishEntity = new NodeFinishEntity();
|
finishEntity.setDeal_result(0);
|
finishEntity.setDeal_note_title(UserName+"完成了节点");
|
finishEntity.setDeal_note(bz);
|
WORKFLOW_NODE node = new WORKFLOW_NODE(NodeId).getInstanceById();
|
node.setAnswer_time(DateUtil.getCurrentDate14());
|
node.setDealtime(DateUtil.getCurrentDate14());
|
node.setDeal_note(bz);
|
node.update();
|
WORKFLOW_NODE workflow_node = new WORKFLOW_NODE(NodeId).getInstanceById();
|
workflowCoreService.finishNode(base, workflow_node, finishEntity);
|
|
}
|
NodeDealEntity entity = new NodeDealEntity();
|
entity.setDealer_type(2);
|
List<Map> userList = new ArrayList<Map>();
|
Map dealer = new HashMap();
|
dealer.put("USER_ID",dealId);
|
dealer.put("USER_NAME",dealName);
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
entity.setDealerList(userList);
|
workflowCoreService.toNode(base, Constants.BJSLSP, entity);
|
|
String sqlString2="select * from WORKFLOW_NODE where NODE_TEMPLATE_ID=:node_template_id order by CREATETIME desc";
|
paramMap.put("node_template_id", Constants.BJSLSQ);
|
List<Map> list_note = baseDao.queryForList(sqlString2, paramMap);
|
if(list_note!=null & list_note.size()>0){
|
String Node_Id=ConvertUtil.obj2StrBlank(list_note.get(0).get("id"));
|
WORKFLOW_NODE workflow_node = new WORKFLOW_NODE(Node_Id).getInstanceById();
|
workflow_node.setDeal_note(bz);
|
workflow_node.update();
|
}
|
if(orderId!=null){
|
spare_part_apply.setId(orderId);
|
spare_part_apply.setState(Constants.SPARE_PART_STORAGE_STATE_D);
|
spare_part_apply.update();
|
}
|
}
|
|
|
/**
|
* 删除备件工单信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public void delSpareSpart(String id) {
|
SPARE_PART_APPLY spare_part_apply=new SPARE_PART_APPLY(id).getInstanceById();
|
String flowId=spare_part_apply.getFlow_id();
|
String spare_part=" delete from spare_part_apply where id=:id ";
|
String apply_cate=" delete from SPARE_PART_APPLY_CATE where APPLY_ORDER_ID=:id ";
|
String workflow_node=" delete from WORKFLOW_NODE where FLOWID=:flowId ";
|
String workflow_base=" delete from WORKFLOW_BASE where BUSINESS_ID=:id ";
|
String cmdb_ci_ref_order=" delete from CMDB_CI_REF_ORDER where FLOW_ID=:flowId";
|
|
Map paramMap = new HashMap();
|
paramMap.put("id",id);
|
paramMap.put("flowId",flowId);
|
baseDao.execute(spare_part, paramMap);
|
baseDao.execute(apply_cate, paramMap);
|
baseDao.execute(workflow_node, paramMap);
|
baseDao.execute(workflow_base, paramMap);
|
baseDao.execute(cmdb_ci_ref_order, paramMap);
|
}
|
|
/**
|
* 关联配置保存
|
* @param xyzzjg
|
* @param request
|
* @param response
|
* @return
|
*/
|
@Override
|
public String doEditCiId(HttpServletRequest request) {
|
String orderId = request.getParameter("orderId");
|
if(StringUtil.isNotBlank(orderId)){
|
String sqlString="select * from SPARE_PART_APPLY_ENTITY where ORDER_ID=:orderId";
|
Map paramMap = new HashMap();
|
paramMap.put("orderId",orderId);
|
List<Map> list= baseDao.queryForList(sqlString,paramMap);
|
if(list!=null && list.size()>0){
|
for(Map map:list){
|
String id=ConvertUtil.obj2StrBlank(map.get("id"));
|
String entity_id=ConvertUtil.obj2StrBlank(map.get("entity_id"));
|
if(StringUtil.isNotBlank(entity_id)){
|
String ci_id=request.getParameter(id+"_ciid");
|
if(StringUtil.isNotBlank(ci_id)){
|
String entity="update SPARE_PART_APPLY_ENTITY set CI_ID=:ci_id ,STATE='2',GMT_USAGE=:gmt_usage where id=:id";
|
paramMap.put("ci_id", ci_id);
|
paramMap.put("id", id);
|
paramMap.put("gmt_usage", DateUtil.getCurrentDate14());
|
baseDao.execute(entity, paramMap);
|
|
|
}
|
}
|
|
}
|
}
|
|
SPARE_PART_APPLY spare_part_apply=new SPARE_PART_APPLY(orderId).getInstanceById();
|
spare_part_apply.setState(Constants.SPARE_PART_APPLY_STATE_T);
|
spare_part_apply.update();
|
}
|
return "";
|
}
|
|
/**
|
* 校验提交前信息
|
* @param request
|
* @return
|
*/
|
@Override
|
public String initDelivery(HttpServletRequest request) {
|
String orderId = request.getParameter("orderId");
|
if(StringUtil.isNotBlank(orderId)){
|
String sqlString="select * from SPARE_PART_APPLY_ENTITY where ORDER_ID=:orderId and ci_id is null";
|
Map paramMap = new HashMap();
|
paramMap.put("orderId",orderId);
|
List<Map> list= baseDao.queryForList(sqlString,paramMap);
|
if(list!=null && list.size()>0){
|
for(Map map:list){
|
String id=ConvertUtil.obj2StrBlank(map.get("id"));
|
String ci_id=request.getParameter(id+"_ciid");
|
if(StringUtil.isBlank(ci_id)){
|
return "0";
|
}
|
|
}
|
}
|
}
|
|
return "1";
|
}
|
|
/**
|
* 校验列表提交前信息
|
* @param request
|
* @return
|
*/
|
@Override
|
public String initCateNum(HttpServletRequest request) {
|
String orderId = request.getParameter("orderId");
|
if(StringUtil.isNotBlank(orderId)){
|
String sqlString="select count(*) from SPARE_PART_APPLY_CATE where APPLY_ORDER_ID=:orderId and CATE_NUM is null";
|
Map paramMap = new HashMap();
|
paramMap.put("orderId",orderId);
|
Integer num= baseDao.queryForInteger(sqlString,paramMap);
|
if(num > 0){
|
return "0";
|
}
|
}
|
return "1";
|
}
|
}
|
