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.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_WORKFLOW_RELEASE;
|
import cn.ksource.beans.SPARE_PART;
|
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("DeliveryQueryFacade")
|
public class DeliveryQueryFacadeImpl implements DeliveryQueryFacade {
|
|
@Resource
|
private BaseDao baseDao;
|
/**
|
* 出库申请列表信息
|
* @return
|
*/
|
@Override
|
public List<Map> getSpareList() {
|
return baseDao.queryForList(" select * from SPARE_PART_APPLY where STATE=1 ");
|
}
|
/**
|
* 出库申请列表信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public PageInfo getSpareListData(Map<String, String> params,PageInfo pageInfo){
|
StringBuilder sql = new StringBuilder();
|
Map paramMap = new HashMap();
|
sql.append("SELECT\n" +
|
" D.*, A.ORDER_CODE ORDER_CODE_A\n" +
|
"FROM\n" +
|
" SPARE_PART_DELIVERY D\n" +
|
"LEFT JOIN SPARE_PART_APPLY A ON D.APPLY_ORDER_ID = A.ID WHERE D.STATE='3'");
|
String order_code=params.get("order_code");
|
String order_name=params.get("order_name");
|
String state=params.get("state");
|
String start_time=params.get("start_time");
|
String end_time=params.get("end_time");
|
String customer_id=params.get("customer_id");
|
String order_code_A=params.get("order_code_A");
|
//关联工单
|
if (StringUtil.isNotBlank(order_code_A)) {
|
sql.append(" and D.APPLY_ORDER_ID in(select id from SPARE_PART_APPLY where order_code like :order_code_A) ");
|
paramMap.put("order_code_A", "%"+order_code_A.trim()+"%");
|
}
|
|
//出库类型KEY
|
String delivery_type_keys=params.get("delivery_type_keys");
|
if (StringUtil.notEmpty(delivery_type_keys)) {
|
String[] keys = delivery_type_keys.split(",");
|
if (keys.length == 1) {
|
sql.append(" AND D.DELIVERY_TYPE_KEY = :delivery_type_key");
|
paramMap.put("delivery_type_key", keys[0]);
|
} else {
|
sql.append(" AND D.DELIVERY_TYPE_KEY IN (");
|
for (int i = 0; i < keys.length; i++) {
|
sql.append(" :pri" + i);
|
sql.append(",");
|
paramMap.put("pri" + i, keys[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
//工单编号
|
if (StringUtil.isNotBlank(order_code)) {
|
sql.append(" and D.order_code like :order_code ");
|
paramMap.put("order_code", "%"+order_code.trim()+"%");
|
}
|
//工单名称
|
if (StringUtil.isNotBlank(order_name)) {
|
sql.append(" and D.order_name like :order_name ");
|
paramMap.put("order_name", "%"+order_name.trim()+"%");
|
}
|
/* //工单状态
|
if (StringUtil.isNotBlank(state)) {
|
sql.append(" and D.state=:state ");
|
paramMap.put("state", state);
|
}*/
|
//开始时间
|
if(StringUtil.isNotBlank(start_time)){
|
sql.append(" AND D.gmt_create>=:start_time");
|
paramMap.put("start_time", start_time+"000000");
|
}
|
//结束时间
|
if(StringUtil.isNotBlank(end_time)){
|
sql.append(" and D.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 getSpareListCount(Map<String, String> params) {
|
StringBuilder sql = new StringBuilder();
|
Map paramMap = new HashMap();
|
sql.append("SELECT\n" +
|
" COUNT(D.ID)\n" +
|
"FROM\n" +
|
" SPARE_PART_DELIVERY D\n" +
|
"LEFT JOIN SPARE_PART_APPLY A ON D.APPLY_ORDER_ID = A.ID WHERE D.STATE='3'");
|
String order_code=params.get("order_code");
|
String order_name=params.get("order_name");
|
String state=params.get("state");
|
String start_time=params.get("start_time");
|
String end_time=params.get("end_time");
|
String customer_id=params.get("customer_id");
|
String order_code_A=params.get("order_code_A");
|
//关联工单
|
if (StringUtil.isNotBlank(order_code_A)) {
|
sql.append(" and D.APPLY_ORDER_ID in(select id from SPARE_PART_APPLY where order_code like :order_code_A) ");
|
paramMap.put("order_code_A", "%"+order_code_A.trim()+"%");
|
}
|
|
//出库类型KEY
|
String delivery_type_keys=params.get("delivery_type_keys");
|
if (StringUtil.notEmpty(delivery_type_keys)) {
|
String[] keys = delivery_type_keys.split(",");
|
if (keys.length == 1) {
|
sql.append(" AND D.DELIVERY_TYPE_KEY = :delivery_type_key");
|
paramMap.put("delivery_type_key", keys[0]);
|
} else {
|
sql.append(" AND D.DELIVERY_TYPE_KEY IN (");
|
for (int i = 0; i < keys.length; i++) {
|
sql.append(" :pri" + i);
|
sql.append(",");
|
paramMap.put("pri" + i, keys[i]);
|
}
|
sql.deleteCharAt(sql.lastIndexOf(","));
|
sql.append(")");
|
}
|
}
|
|
//工单编号
|
if (StringUtil.isNotBlank(order_code)) {
|
sql.append(" and D.order_code like :order_code ");
|
paramMap.put("order_code", "%"+order_code.trim()+"%");
|
}
|
//工单名称
|
if (StringUtil.isNotBlank(order_name)) {
|
sql.append(" and D.order_name like :order_name ");
|
paramMap.put("order_name", "%"+order_name.trim()+"%");
|
}
|
//开始时间
|
if(StringUtil.isNotBlank(start_time)){
|
sql.append(" AND D.gmt_create>=:start_time");
|
paramMap.put("start_time", start_time+"000000");
|
}
|
//结束时间
|
if(StringUtil.isNotBlank(end_time)){
|
sql.append(" and D.gmt_create<=:end_time");
|
paramMap.put("end_time", end_time+"235959");
|
}
|
sql.append(" order by D.gmt_create desc ");
|
int count = baseDao.queryForInteger(sql.toString(), paramMap);
|
return count;
|
|
}
|
|
|
}
|
