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 javassist.expr.NewArray;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
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.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.OrderCodeUtil;
|
import cn.ksource.core.util.StringUtil;
|
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("StockApplyFacade")
|
public class StockApplyFacadeImpl implements StockApplyFacade {
|
|
@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 where STATE=1 ");
|
}
|
/**
|
* 入库申请列表信息
|
* @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_storage 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");
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userId = user.get("Id").toString();
|
paramMap.put("create_id",userId );
|
//工单编号
|
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_storage 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");
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
String userId = user.get("Id").toString();
|
paramMap.put("create_id",userId );
|
//工单编号
|
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 pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public void delStockStorage(String id) {
|
String sql=" delete from SPARE_PART_STORAGE where id=:id ";
|
String sqlString=" delete from SPARE_PART where LINK_STORAGE_ID=:id ";
|
baseDao.execute(sql, new SqlParameter().addValue("id", id));
|
baseDao.execute(sqlString, new SqlParameter().addValue("id", id));
|
|
}
|
/**
|
* 删除备件信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public void deleteSpare_part(String id) {
|
String sql=" delete from SPARE_PART where id=:id ";
|
String sqlString=" delete from PROP_DATA where BUS_ID=:id ";
|
baseDao.execute(sql, new SqlParameter().addValue("id", id));
|
baseDao.execute(sqlString, new SqlParameter().addValue("id", id));
|
|
}
|
|
@Override
|
public void deleteSpareOverage_part(String id) {
|
String sql=" delete from SPARE_PART where id=:id ";
|
String sqlString=" delete from PROP_DATA where BUS_ID=:id ";
|
String overageSql = "delete from overage_loss_detail where ENTITY_ID=:id ";
|
baseDao.execute(sql, new SqlParameter().addValue("id", id));
|
baseDao.execute(sqlString, new SqlParameter().addValue("id", id));
|
baseDao.execute(overageSql, new SqlParameter().addValue("id", id));
|
|
}
|
|
|
|
/**
|
* 按分类删除备件信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public void deleteSpare_part(String id,String storage_id) {
|
String sqlString="select id from SPARE_PART where CATE_ID=:id and LINK_STORAGE_ID=:storage_id";
|
List<Map> dataList = baseDao.queryForList(sqlString.toString(), new SqlParameter().addValue("id", id).addValue("storage_id", storage_id));
|
|
if(dataList!=null&&dataList.size()>0){
|
for(Map cateMap:dataList){
|
String spare_id=ConvertUtil.obj2StrBlank(cateMap.get("id"));
|
String sqlStr=" delete from PROP_DATA where BUS_ID=:id";
|
baseDao.execute(sqlStr, new SqlParameter().addValue("id", spare_id));
|
}
|
}
|
String sql=" delete from SPARE_PART where CATE_ID=:id and LINK_STORAGE_ID=:storage_id";
|
baseDao.execute(sql, new SqlParameter().addValue("id", id).addValue("storage_id", storage_id));
|
|
}
|
/**
|
* 校验资产编码是否重复
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public String initAsset_no(HttpServletRequest request) {
|
String asset_no = request.getParameter("asset_no");
|
String sqlString="select count(*) from SPARE_PART where ASSET_NO=:asset_no ";
|
|
Integer num= baseDao.queryForInteger(sqlString, new SqlParameter().addValue("asset_no", asset_no));
|
String asset_no_num="";
|
if(num>0){
|
asset_no_num="1";
|
}else{
|
asset_no_num="0";
|
}
|
return asset_no_num;
|
}
|
/**
|
* 查询该工单下的备件信息
|
* @param id
|
* @return
|
*/
|
public List<Map> getEditStockApply(String id) {
|
StringBuilder sql = new StringBuilder();
|
Map paramMap = new HashMap();
|
sql.append(" select * from SPARE_PART where LINK_STORAGE_ID=:id ");
|
paramMap.put("id", id);
|
List<Map> queryForList = baseDao.queryForList(sql.toString(), paramMap);
|
return queryForList;
|
}
|
/**
|
* 发起流程
|
* @param spare_part_storage
|
*/
|
public String addSpare_part_storage(SPARE_PART_STORAGE spare_part_storage,String type){
|
if(type.equals("1")){
|
SPARE_PART_STORAGE spare_part_storage_old=new SPARE_PART_STORAGE(spare_part_storage.getId()).getInstanceById();
|
Integer state=spare_part_storage_old.getState();
|
if(state==Constants.SPARE_PART_STORAGE_STATE_N){
|
spare_part_storage.setState(Constants.SPARE_PART_STORAGE_STATE_N);
|
}else{
|
spare_part_storage.setState(Constants.SPARE_PART_STORAGE_STATE_Z);
|
}
|
spare_part_storage.setGmt_create(spare_part_storage_old.getGmt_create());
|
spare_part_storage.setGmt_modified(DateUtil.getCurrentDate14());
|
spare_part_storage.update();
|
}else{
|
spare_part_storage.setGmt_create(DateUtil.getCurrentDate14());
|
spare_part_storage.setState(Constants.SPARE_PART_STORAGE_STATE_Z);
|
//工单编号
|
String order_code = workOrderCodeService.getStockOrderCode();
|
spare_part_storage.setOrder_code(order_code);
|
spare_part_storage.insert();
|
}
|
return "";
|
}
|
public String addSpare_part_storagePl(SPARE_PART_STORAGE spare_part_storage){
|
spare_part_storage.setState(Constants.SPARE_PART_STORAGE_STATE_T);
|
String order_code = workOrderCodeService.getStockOrderCode();
|
spare_part_storage.setOrder_code(order_code);
|
spare_part_storage.insert();
|
return spare_part_storage.getId();
|
}
|
@Override
|
public List getCfgcateList(Map<String, String> params){
|
StringBuilder sql = new StringBuilder();
|
sql.append(" select id,name from cmdb_ci_category where state=1 and cate_type=2");
|
if(StringUtil.isNotBlank(params.get("lv"))){
|
sql.append(" and lv = :lv ");
|
}
|
if(StringUtil.isNotBlank(params.get("pid"))){
|
sql.append(" and pid = :pid ");
|
}
|
return baseDao.queryForList(sql.toString(), params);
|
}
|
/**
|
* 保存配置项
|
* @param params
|
* @param request
|
*/
|
@Override
|
public void saveCfg(Map<String, String> params, HttpServletRequest request) {
|
StringBuilder sql = new StringBuilder();
|
if (StringUtil.isNotBlank(params.get("full_cate_id"))) {
|
String[] cateIdArr = params.get("full_cate_id").split("-");
|
String[] cateNameArr = params.get("full_cate_name").split("-");
|
params.put("lv1_id", cateIdArr[0]);
|
params.put("lv1_name", cateNameArr[0]);
|
params.put("lv2_id", cateIdArr[1]);
|
params.put("lv2_name", cateNameArr[1]);
|
params.put("lv3_id", cateIdArr[2]);
|
params.put("lv3_name", cateNameArr[2]);
|
}
|
|
|
String searchcode = OrderCodeUtil.getUUIDCode("SH");
|
params.put("searchcode", searchcode);
|
params.put("create_time", DateUtil.getCurrentDate14().toString());
|
params.put("busId", params.get("id"));
|
params.put("linkId", params.get("lv3_id"));
|
saveProp(params);
|
}
|
|
|
|
private void saveProp(Map<String, String> params) {
|
String linkId = ConvertUtil.obj2StrBlank(params.get("linkId"));
|
String busId = ConvertUtil.obj2StrBlank(params.get("busId"));
|
//删除所有的属性配置信息
|
String delSql = "delete from prop_data where bus_id = :busId ";
|
baseDao.execute(delSql, new SqlParameter("busId", busId));
|
List<Map> glist = getPropTemplate(linkId, null);
|
if (glist != null && glist.size() > 0) {
|
List<SqlParameter> pList = new ArrayList<SqlParameter>();
|
for (Map g : glist) {
|
if (g.get("props") != null) {
|
List<Map> plist = (List<Map>) g.get("props");
|
for (Map p : plist) {
|
String key = "p_" + ConvertUtil.obj2StrBlank(p.get("columncode").toString());
|
if (params.get(key) != null) {
|
SqlParameter sqlParameter = new SqlParameter();
|
sqlParameter.addValue("id", StringUtil.getUUID())
|
.addValue("column_id", p.get("pid"))
|
.addValue("column_code", p.get("columncode"))
|
.addValue("column_name", p.get("columnname"))
|
.addValue("busId", busId)
|
.addValue("column_text", ConvertUtil.obj2StrBlank(params.get(key + "_text")))
|
.addValue("column_value", ConvertUtil.obj2StrBlank(params.get(key)));
|
pList.add(sqlParameter);
|
}
|
}
|
}
|
}
|
String insertSql = "insert into prop_data(id,bus_id,column_id,column_code,column_name,column_value,column_text) VALUES (:id,:busId,:column_id,:column_code,:column_name,:column_value,:column_text)";
|
baseDao.executeBatch(insertSql, pList);
|
}
|
}
|
|
|
|
|
@Override
|
public List<Map> getPropTemplate(String linkId ,String busId) {
|
StringBuilder sql = new StringBuilder();
|
Map propSet = new HashMap();
|
if(StringUtil.isNotBlank(busId)){
|
sql.append(" select * from prop_data where bus_id=:busId ");
|
List<Map> propList = baseDao.queryForList(sql.toString(),new SqlParameter("busId",busId));
|
if(propList!=null&&propList.size()>0){
|
for(Map p:propList){
|
propSet.put(p.get("column_id"), p);
|
}
|
}
|
sql.setLength(0);
|
}
|
|
SqlParameter param = new SqlParameter();
|
param.addValue("linkId", linkId);
|
Map cate = baseDao.queryForMap("select * from CMDB_CI_CATEGORY where id = :linkId ",param);
|
String lv = ConvertUtil.obj2StrBlank(cate.get("lv"));
|
String pid = ConvertUtil.obj2StrBlank(cate.get("pid"));
|
param.addValue("pid", pid);
|
List<Map> list = new ArrayList<Map>();
|
|
sql.append(" select g.serial gserial,g.id gid,g.group_name,p.id pid,p.* from ( ");
|
sql.append(" select g.id,g.group_name,g.serial from prop_group g,cmdb_ci_category c where g.link_id=c.id and c.state=1 ");
|
if(lv.equals("3")){
|
sql.append(" and (c.id = :linkId or c.id = :pid) ");
|
}else{
|
sql.append(" and c.id = :linkId ");
|
}
|
/*sql.append(" union select -1 as id,'通用属性' as group_name,0 as serial from prop_group g ");*/
|
sql.append(" ) g ,prop_column p ");
|
sql.append(" where g.id = p.group_id and p.state=1 order by gid,p.serial desc ");
|
List<Map> glist = baseDao.queryForList(sql.toString(),param);
|
sql.setLength(0);
|
sql.append(" select * from prop_sel where column_id = :pid ");
|
if(glist!=null&&glist.size()>0){
|
Stack<Map> stack= new Stack<Map>();
|
for(int i=0;i<=glist.size();i++){
|
if(i!=glist.size()){
|
int datatype = ConvertUtil.obj2Int(glist.get(i).get("DATATYPE"));
|
if(datatype==Constants.PROP_TYPE_SEL
|
||datatype==Constants.YSY_TYPE_MULTI_SEL) {
|
List sList = baseDao.queryForList(sql.toString(),new SqlParameter("pid",glist.get(i).get("pid")));
|
glist.get(i).put("items", sList);
|
}
|
}
|
if(stack.isEmpty()){
|
stack.push(glist.get(i));
|
}else{
|
if(i==glist.size()||!stack.peek().get("gid").toString().equals(glist.get(i).get("gid").toString())){
|
Map temp = stack.peek();
|
List plist = new ArrayList();
|
while(!stack.isEmpty()){
|
Map p = stack.pop();
|
if(!propSet.isEmpty()){
|
if(propSet.containsKey(p.get("pid").toString())){
|
Map prop = (Map)propSet.get(p.get("pid").toString());
|
String def_val = ConvertUtil.obj2StrBlank(prop.get("column_value"));
|
String def_text = ConvertUtil.obj2StrBlank(prop.get("column_text"));
|
p.put("default_val", def_val);
|
p.put("default_ext", def_text);
|
}
|
}
|
plist.add(p);
|
}
|
temp.put("props", plist);
|
list.add(temp);
|
}
|
if(i!=glist.size()){
|
stack.push(glist.get(i));
|
}
|
}
|
}
|
}
|
Collections.sort(list, new Comparator<Map>(){
|
@Override
|
public int compare(Map o1, Map o2) {
|
return ConvertUtil.obj2Integer(o1.get("gserial")).compareTo(ConvertUtil.obj2Integer(o2.get("gserial")));
|
}
|
});
|
return list;
|
}
|
|
@Override
|
public List<Map> getMftList(String cusId, String type) {
|
String sql = "select * from SUPPLIER_INFO where state=1 and customer_id = :cusId and type = :type";
|
return baseDao.queryForList(sql, new SqlParameter().addValue("cusId", cusId).addValue("type", type));
|
}
|
@Override
|
public List<Map> getCusList() {
|
return baseDao.queryForList(" select * from SUPPLIER_INFO where STATE=1 ");
|
}
|
|
/**
|
* 备件信息
|
*/
|
@Override
|
public Map getCfgById(String id) {
|
return baseDao.queryForMap("select SPARE_PART.*,CMDB_CI_CATEGORY.CODE CODE,CMDB_CI_CATEGORY.LV1_ID,CMDB_CI_CATEGORY.LV2_ID,CMDB_CI_CATEGORY.LV3_ID, CMDB_CI_CATEGORY.LV1_NAME,CMDB_CI_CATEGORY.LV2_NAME,CMDB_CI_CATEGORY.LV3_NAME from SPARE_PART,CMDB_CI_CATEGORY where SPARE_PART.id=:id and SPARE_PART.CATE_ID= CMDB_CI_CATEGORY.LV3_ID", new SqlParameter("id", id));
|
}
|
/**
|
* 查询备件列表信息
|
*/
|
@Override
|
public PageInfo stockListData(PageInfo pageInfo, Map<String, String> params) {
|
Map paramMap = new HashMap();
|
String storage_id=params.get("storage_id");
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT PATH.*,CMDB.LV1_NAME,CMDB.LV2_NAME,CMDB.LV3_NAME FROM SPARE_PART PATH,CMDB_CI_CATEGORY CMDB where PATH.LINK_STORAGE_ID=:link_storage_id and CMDB.LV3_ID=PATH.CATE_ID");
|
SqlParameter param = new SqlParameter();
|
paramMap.put("link_storage_id", storage_id);
|
return baseDao.queryforSplitPageInfo(pageInfo,sql.toString(), paramMap);
|
}
|
|
|
@Override
|
public PageInfo stockOverageListData(PageInfo pageInfo, Map<String, String> params) {
|
Map paramMap = new HashMap();
|
String partId =params.get("partId");
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT D.ID,path.ID as PATHID,d.ORDER_ID,PATH.ENTITY_NO,PATH.NAME,PATH.ASSET_NO,PATH.MODEL_NO,PATH.LOCATION,CMDB.LV1_NAME,CMDB.LV2_NAME,CMDB.LV3_NAME,d.REASON FROM overage_loss_detail d "+
|
" left join SPARE_PART path on d.ENTITY_ID = PATH.ID left join overage_loss c on c.id = d.ORDER_ID left join CMDB_CI_CATEGORY CMDB on CMDB.LV3_ID= PATH.CATE_ID "+
|
" where d.ORDER_ID =:partId ");
|
|
SqlParameter param = new SqlParameter();
|
paramMap.put("partId", partId);
|
return baseDao.queryforSplitPageInfo(pageInfo,sql.toString(), paramMap);
|
}
|
|
|
|
|
|
|
/**
|
* 查询备件树列表信息
|
* @param pageInfo
|
* @param params
|
* @return
|
*/
|
@Override
|
public List<Map> stockListTreeData(Map<String, String> params) {
|
Map paramMap = new HashMap();
|
String storage_id=params.get("storage_id");
|
StringBuilder sql = new StringBuilder();
|
|
sql.append(" select b.id,b.lv1_name,b.lv2_name,b.lv3_id,b.lv3_name,count(*) cate_num from spare_part a,cmdb_ci_category b "
|
+ " where a.cate_id=b.id and a.link_storage_id =:storage_id group by a.cate_id ");
|
|
List<Map> cateList = baseDao.queryForList(sql.toString(),params);
|
Map cateSetMap = new HashMap();
|
if(cateList!=null&&cateList.size()>0){
|
for(Map cateMap:cateList){
|
cateSetMap.put(ConvertUtil.obj2StrBlank(cateMap.get("id")), cateMap);
|
|
}
|
}
|
sql.setLength(0);
|
sql.append(" select a.* from spare_part a where a.link_storage_id =:storage_id ");
|
List<Map> dataList = baseDao.queryForList(sql.toString(),params);
|
|
if(dataList!=null&&dataList.size()>0){
|
for(Map data:dataList){
|
String cateId = ConvertUtil.obj2StrBlank(data.get("cate_id"));
|
if(StringUtil.isNotBlank(cateId)){
|
if(cateSetMap.get(cateId)!=null){
|
Map cateMap = (Map)cateSetMap.get(cateId);
|
if(cateMap.get("children")==null){
|
cateMap.put("children", new ArrayList<Map>());
|
}
|
((List<Map>)cateMap.get("children")).add(data);
|
}
|
}
|
}
|
}
|
|
|
|
/*sql.append(" SELECT PATH.*,CMDB.LV1_NAME,CMDB.LV2_NAME,CMDB.LV3_NAME FROM SPARE_PART PATH,CMDB_CI_CATEGORY CMDB where PATH.LINK_STORAGE_ID=:link_storage_id and CMDB.LV3_ID=PATH.CATE_ID order by PATH.CATE_ID");
|
SqlParameter param = new SqlParameter();
|
paramMap.put("link_storage_id", storage_id);
|
List<Map> partlist = baseDao.queryForList(sql.toString(),paramMap);
|
List<Map> resultList = new LinkedList<Map>();
|
Map<String, Map> CacheMap = new HashMap<String, Map>();
|
Map cate = new HashMap();
|
for (Map map : partlist) {
|
String cate_id = map.get("CATE_ID").toString();
|
|
if(cate.get(cate_id)==null){
|
Map cateMap = new HashMap();
|
cateMap.put("cate_id", cate_id);
|
cateMap.put("cate_name", "");
|
cateMap.put("children", new ArrayList<Map>());
|
|
cate.put(cate_id,cateMap );
|
}
|
|
((List<Map>)((Map)cate.get(cate_id)).get("children")).add(map);
|
|
*/
|
|
/*if (cate.get(cate_id)!=null && !"".equals(cate.get(cate_id))) {
|
list.put(cate.get(cate_id), map);
|
resultList.add(map);
|
continue;
|
}else{
|
List<Map> list = new LinkedList<Map>();
|
map.put("ejTree", ejgnList);
|
cate.put(cate_id, cate_id);
|
List<Map> list = new LinkedList<Map>();
|
list.add(map);
|
}
|
if (cate.get(cate_id)!=null && !"".equals(cate.get(cate_id))) {
|
Map yjgnMap = CacheMap.get(map.get("SJBH").toString());
|
List<Map> list = (List<Map>)yjgnMap.get("ejTree");
|
CacheMap.put(cate_id, map);
|
}else{
|
List<Map> list = new LinkedList<Map>();
|
cate.put(cate_id, cate_id);
|
CacheMap.put(cate_id, map);
|
}*/
|
return cateList;
|
}
|
|
|
|
@Override
|
public int stockListCount(Map<String, String> params) {
|
Map paramMap = new HashMap();
|
String storage_id=params.get("storage_id");
|
StringBuilder sql = new StringBuilder();
|
sql.append(" select count(*) from SPARE_PART where LINK_STORAGE_ID=:link_storage_id ");
|
SqlParameter param = new SqlParameter();
|
paramMap.put("link_storage_id", storage_id);
|
return baseDao.queryForInteger(sql.toString(), paramMap);
|
}
|
|
@Override
|
public int stockOverageListCount(Map<String, String> params) {
|
Map paramMap = new HashMap();
|
StringBuilder sql = new StringBuilder();
|
String partId =params.get("partId");
|
sql.append(" select count(*) from overage_loss_detail t where t.ENTITY_ID=:partId ");
|
SqlParameter param = new SqlParameter();
|
param.put("partId", partId);
|
return baseDao.queryForInteger(sql.toString(),param);
|
}
|
|
/**
|
* 查询供应商信息
|
* @param request
|
* @return
|
*/
|
@Override
|
public List querySupplier(HttpServletRequest request) {
|
StringBuilder builder = new StringBuilder("SELECT A.* FROM SUPPLIER_INFO A WHERE A.STATE = 1 ");
|
String supplier_name = request.getParameter("supplier_name");
|
String contacts = request.getParameter("contacts");
|
Map paramMap = new HashMap();
|
if(StringUtil.isNotBlank(supplier_name)){
|
builder.append(" and SUPPLIER_NAME like:supplier_name ");
|
paramMap.put("supplier_name", "%"+supplier_name.trim()+"%");
|
|
}
|
if(StringUtil.isNotBlank(contacts)){
|
builder.append(" and contacts like:contacts ");
|
paramMap.put("contacts", "%"+contacts.trim()+"%");
|
|
}
|
List<Map> devices = baseDao.queryForList(builder.toString(),paramMap);
|
return devices;
|
}
|
|
/**
|
* 提交申请入库
|
* @param request
|
* @return
|
*/
|
@Override
|
public void doApproveAssign(HttpServletRequest request) {
|
String type = request.getParameter("type");
|
String storage_id = request.getParameter("storage_id");
|
String order_name = AjaxUtil.decode(request.getParameter("order_name"));
|
String storage_reason = AjaxUtil.decode(request.getParameter("storage_reason"));
|
String orderId = request.getParameter("orderId");
|
String executeUserId = request.getParameter("dealId");
|
String executeUserName = request.getParameter("dealName");
|
String flowId ="";
|
SPARE_PART_STORAGE spare_part_storage=new SPARE_PART_STORAGE();
|
Map user = WebUtil.getLoginUser(request).getLoginUser();
|
if(type!=null && !"".equals(type)){
|
if(type.equals("0")){
|
//工单编号
|
String order_code = workOrderCodeService.getStockOrderCode();
|
spare_part_storage.setOrder_code(order_code);
|
spare_part_storage.setId(storage_id);
|
spare_part_storage.setOrder_name(order_name);
|
spare_part_storage.setStorage_reason(storage_reason);
|
spare_part_storage.setCreate_id(user.get("ID").toString());
|
spare_part_storage.setCreate_name( user.get("ZSXM").toString());
|
spare_part_storage.setGmt_create(DateUtil.getCurrentDate14());
|
spare_part_storage.setState(Constants.SPARE_PART_STORAGE_STATE_Z);
|
spare_part_storage.insert();
|
}else if(storage_id!=null & !"".equals(storage_id)){
|
spare_part_storage=new SPARE_PART_STORAGE(storage_id).getInstanceById();
|
}
|
}
|
|
String bz= request.getParameter("bz");
|
orderId = storage_id;
|
|
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",user.get("ID").toString());
|
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();
|
WORKFLOW_BASE base=new WORKFLOW_BASE(FlowId).getInstanceById();
|
workflowCoreService.finishNode(base, node, finishEntity);
|
WORKFLOW_NODE node_no = new WORKFLOW_NODE(NodeId).getInstanceById();
|
node_no.setAnswer_time(DateUtil.getCurrentDate14());
|
node_no.update();
|
|
NodeDealEntity entity = new NodeDealEntity();
|
entity.setDealer_type(2);
|
List<Map> userList = new ArrayList<Map>();
|
Map dealer = new HashMap();
|
dealer.put("USER_ID",executeUserId);
|
dealer.put("USER_NAME",executeUserName);
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
entity.setDealerList(userList);
|
workflowCoreService.toNode(base, Constants.RKSP, entity);
|
}else{
|
List<Map> userList = new ArrayList<Map>();
|
Map dealer = new HashMap();
|
dealer.put("USER_ID",executeUserId);
|
dealer.put("USER_NAME",executeUserName);
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
WorkFlowSupportEntity support = new WorkFlowSupportEntity();
|
support.setNote(bz);
|
support.setNextUserList(userList);
|
support.setOrderId(orderId);
|
support.setNextNodeTemplateId(Constants.RKSP);
|
support.setUserName(spare_part_storage.getCreate_name());
|
support.setUserId(spare_part_storage.getCreate_id());
|
support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_STOCK);
|
SysInfoMsg msg = workFlowSupportService.doOrderFlow(support);
|
}
|
spare_part_storage=new SPARE_PART_STORAGE(storage_id).getInstanceById();
|
|
spare_part_storage.setState(Constants.SPARE_PART_STORAGE_STATE_D);
|
spare_part_storage.update();
|
}
|
/**
|
* 提交申请入库
|
* @param request
|
* @return
|
*/
|
@Override
|
public void doApproveAssignPl(SPARE_PART_STORAGE spare_part_storage) {
|
String flowId ="";
|
String orderId = spare_part_storage.getId();
|
List<Map> userList = new ArrayList<Map>();
|
Map dealer = new HashMap();
|
dealer.put("USER_ID",spare_part_storage.getId());
|
dealer.put("USER_NAME",spare_part_storage.getCreate_name());
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
WorkFlowSupportEntity support = new WorkFlowSupportEntity();
|
support.setNote("批量入库");
|
support.setNextUserList(userList);
|
support.setOrderId(orderId);
|
support.setNextNodeTemplateId("");
|
support.setUserName(spare_part_storage.getCreate_name());
|
support.setUserId(spare_part_storage.getCreate_id());
|
support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_STOCK);
|
workFlowSupportService.doOrderFlow(support);
|
}
|
|
|
/**
|
* 查询报损报溢信息
|
* @param linkId
|
* @param busId
|
* @return
|
*/
|
@Override
|
public List<Map> getOverage_loss_detail(String orderId ,String bjId) {
|
String sqlString="select * from OVERAGE_LOSS_DETAIL WHERE ORDER_ID=:order_id and ENTITY_ID=:entity_id";
|
return baseDao.queryForList(sqlString, new SqlParameter().addValue("order_id", orderId).addValue("entity_id", bjId));
|
}
|
}
|
