package cn.ksource.web.facade.bpbj;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
|
import cn.ksource.beans.WORKFLOW_BASE;
|
import cn.ksource.beans.WORKFLOW_NODE;
|
import cn.ksource.core.util.ConvertUtil;
|
import cn.ksource.core.util.DateUtil;
|
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.workFlowSupport.WorkFlowSupportService;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import cn.ksource.core.dao.BaseDao;
|
import cn.ksource.core.dao.SqlParameter;
|
import cn.ksource.core.page.PageInfo;
|
import cn.ksource.core.util.StringUtil;
|
|
/**
|
* 库存盘点 实现层
|
*
|
* @author zf
|
* @version 1.0
|
* @date 2017-5-31下午2:17:09
|
*/
|
@Service
|
public class StockTakingFacadeImpl implements StockTakingFacade {
|
|
@Resource
|
private BaseDao baseDao;
|
|
@Resource
|
private WorkFlowSupportService workFlowSupportService;
|
|
@Resource
|
private WorkOrderCodeService workOrderCodeService;
|
@Autowired
|
private WorkflowBusinessService workflowBusinessService;
|
@Resource
|
private WorkflowCoreService workflowCoreService;
|
|
|
@Override
|
public PageInfo getStockTakingListData(PageInfo pageInfo,
|
Map<String, String> params) {
|
String sql = getStockTakingList(params);
|
return baseDao.queryforSplitPageInfo(pageInfo, sql.toString(), params);
|
}
|
|
@Override
|
public Integer getStockTakingListCount(Map<String, String> params) {
|
String sql = "select count(*) from ( " + getStockTakingList(params) + " ) t ";
|
return baseDao.queryForInteger(sql, params);
|
}
|
|
|
private String getStockTakingList(Map<String, String> params) {
|
|
StringBuilder sql = new StringBuilder(" SELECT a.ID,a.ORDER_NAME,a.STATE,sum(b.INVENTORY_NUM) INVENTORY_NUM," +
|
"sum(b.BOOK_NUM) BOOK_NUM,sum(b.LOSS_NUM) LOSS_NUM,sum(b.OVERAGE_NUM) OVERAGE_NUM," +
|
" a.CREATE_NAME,a.GMT_CREATE,a.ORDER_CODE" +
|
" from STOCK_INVENTORY a LEFT JOIN SPARE_PART_DETAIL b" +
|
" ON a.ID = b.INVENTORY_ORDER_ID where 1=1 and a.STATE!=0 ");
|
|
//盘点单号
|
if (StringUtil.isNotBlank(params.get("pddh"))) {
|
sql.append(" and a.ORDER_CODE like :pddh ");
|
params.put("pddh", "%" + params.get("pddh") + "%");
|
}
|
|
//工单名称
|
if (StringUtil.isNotBlank(params.get("gdmc"))) {
|
sql.append(" and a.ORDER_NAME like :gdmc ");
|
params.put("gdmc", "%" + params.get("gdmc") + "%");
|
}
|
|
//开始时间
|
if (StringUtil.isNotBlank(params.get("startDate"))) {
|
sql.append(" and a.GMT_CREATE >= :startDate ");
|
params.put("startDate", params.get("startDate") + "000000");
|
}
|
|
//结束时间
|
if (StringUtil.isNotBlank(params.get("endDate"))) {
|
sql.append(" and a.GMT_CREATE <= :endDate ");
|
params.put("endDate", params.get("endDate") + "235959");
|
}
|
|
//状态
|
if (StringUtil.isNotBlank(params.get("state"))) {
|
sql.append(" and a.STATE = :state ");
|
params.put("state", params.get("state"));
|
}
|
|
sql.append(" group by a.id,a.ORDER_NAME,a.STATE,a.CREATE_NAME,a.GMT_CREATE,a.ORDER_CODE order by a.GMT_CREATE desc");
|
return sql.toString();
|
}
|
|
@Override
|
public Map getStockTakingInfo(String id) {
|
SqlParameter param = new SqlParameter("id", id);
|
StringBuilder sql = new StringBuilder(" select * from STOCK_INVENTORY where id=:id ");
|
Map info = baseDao.queryForMap(sql.toString(), param);
|
|
sql.setLength(0);
|
sql.append(" SELECT a.ID,a.ORDER_NAME,a.STATE,b.INVENTORY_NUM,b.BOOK_NUM,b.LOSS_NUM," +
|
" b.OVERAGE_NUM,a.CREATE_NAME,a.GMT_MODIFIED,b.NOTE,b.CATE_NUM,b.CATE_ID,b.INVENTORY_ORDER_ID," +
|
" c.CODE,c.LV1_NAME,c.LV2_NAME,c.LV3_NAME " +
|
" from STOCK_INVENTORY a LEFT JOIN SPARE_PART_DETAIL b ON a.ID = b.INVENTORY_ORDER_ID " +
|
" left join cmdb_ci_category c on c.id = b.CATE_ID " +
|
" where b.INVENTORY_ORDER_ID=:inventory_order_id ");
|
|
param.put("inventory_order_id", id);
|
List<Map> list = baseDao.queryForList(sql.toString(), param);
|
info.put("list", list);
|
|
return info;
|
}
|
|
@Override
|
public void sendToApprove(Map<String, String> param) {
|
String orderId=param.get("orderId");
|
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",param.get("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(param.get("note"));
|
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.setDeal_note(param.get("bz"));
|
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",param.get("dealId"));
|
dealer.put("USER_NAME",param.get("dealName"));
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
entity.setDealerList(userList);
|
workflowCoreService.toNode(base, Constants.PDSH, entity);
|
|
|
}else{
|
List<Map> userList = new ArrayList<Map>();
|
Map user_map = new HashMap();
|
user_map.put("USER_ID", param.get("dealId"));
|
user_map.put("USER_NAME", param.get("dealName"));
|
user_map.put("IS_ADMIN", 1);
|
userList.add(user_map);
|
|
WorkFlowSupportEntity support = new WorkFlowSupportEntity();
|
support.setOrderId(param.get("orderId"));
|
support.setUserName(param.get("userName"));
|
support.setUserId(param.get("userId"));
|
support.setNote(param.get("bz"));
|
support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_KCPD);
|
support.setNextNodeTemplateId(Constants.PDSH);
|
support.setNextUserList(userList);
|
workFlowSupportService.doOrderFlow(support);
|
}
|
String sql = " update stock_inventory set state =2 where id=:orderId ";
|
baseDao.execute(sql, param);
|
}
|
|
@Override
|
public PageInfo inventoryApproveListData(PageInfo pageInfo, Map<String, String> params) {
|
String sql = inventoryListSuppot(params);
|
return baseDao.queryforSplitPageInfo(pageInfo, sql, params);
|
}
|
|
@Override
|
public Integer inventoryApproveListCount(Map<String, String> params) {
|
String sql = "select count(*) from ( " + inventoryListSuppot(params) + " ) t ";
|
return baseDao.queryForInteger(sql, params);
|
}
|
|
private String inventoryListSuppot(Map<String, String> params) {
|
|
StringBuilder sql = new StringBuilder(" select a.*,b.* from stock_inventory a,( " +
|
" select inventory_order_id,sum(inventory_num) inventory_num,sum(book_num) book_num,sum(loss_num) loss_num,sum(overage_num) overage_num " +
|
" from spare_part_detail b group by inventory_order_id ) b," +
|
" workflow_base c where a.id = b.inventory_order_id and a.flow_id=c.id ");
|
|
//审核
|
if (StringUtil.isNotBlank(params.get("approveFlag"))) {
|
sql.append(" and a.state in (2,3,4) ");
|
}
|
|
//工单状态
|
if (StringUtil.isNotBlank(params.get("state"))) {
|
sql.append(" and a.state = :state ");
|
}
|
|
//用户id
|
if (StringUtil.isNotBlank(params.get("userId"))) {
|
sql.append(" and c.current_dealer_id = :userId ");
|
}
|
|
//盘点单号
|
if (StringUtil.isNotBlank(params.get("order_code"))) {
|
sql.append(" and a.order_code like :order_code ");
|
params.put("order_code", "%" + params.get("order_code") + "%");
|
}
|
|
//工单名称
|
if (StringUtil.isNotBlank(params.get("order_name"))) {
|
sql.append(" and a.order_name like :order_name ");
|
params.put("order_name", "%" + params.get("order_name") + "%");
|
}
|
|
//开始时间
|
if (StringUtil.isNotBlank(params.get("start_date"))) {
|
sql.append(" and a.gmt_create >= :start_date ");
|
params.put("start_date", params.get("start_date") + "000000");
|
}
|
|
//结束时间
|
if (StringUtil.isNotBlank(params.get("end_date"))) {
|
sql.append(" and a.gmt_create <= :end_date ");
|
params.put("end_date", params.get("end_date") + "235959");
|
}
|
|
sql.append(" order by a.state asc,a.gmt_create desc ");
|
return sql.toString();
|
}
|
|
@Override
|
public void doApprove(Map<String, String> param) {
|
String flowId = param.get("flowId");
|
StringBuilder sql = new StringBuilder(" select current_node_id from workflow_base where id = :flowId ");
|
String nodeId = baseDao.queryForString(sql.toString(), param);
|
String note_key= param.get("note_key");
|
String state= param.get("state");
|
String note_val= param.get("note_val");
|
WorkFlowSupportEntity support = new WorkFlowSupportEntity();
|
support.setFlowId(flowId);
|
support.setNodeId(nodeId);
|
support.setUserName(param.get("userName"));
|
support.setUserId(param.get("userId"));
|
support.setNote(param.get("note"));
|
support.setWorkFlowType(Constants.WORKFLOW_BASE_BUSINESS_TYPE_KCPD);
|
support.setFlowEndflag(true);
|
workFlowSupportService.doOrderFlow(support);
|
if(StringUtil.isNotBlank(state)){
|
WORKFLOW_BASE base = new WORKFLOW_BASE(flowId).getInstanceById();
|
WORKFLOW_NODE node = new WORKFLOW_NODE(nodeId).getInstanceById();
|
if(state.equals("4")){
|
node.setNote_key(note_key);
|
node.setDeal_result(2);
|
node.setNote_val(note_val);
|
node.setAnswer_time(DateUtil.getCurrentDate14());
|
node.update();
|
NodeDealEntity entity = new NodeDealEntity();
|
List<Map> userList = new ArrayList<Map>();
|
Map dealer = new HashMap();
|
dealer.put("USER_ID",param.get("userId"));
|
dealer.put("USER_NAME",param.get("userName"));
|
dealer.put("IS_ADMIN","1");
|
userList.add(dealer);
|
entity.setDealerList(userList);
|
entity.setDealer_type(2);
|
workflowCoreService.toNode(base,Constants.PDXZ, entity);
|
}else{
|
node.setNote_key(note_key);
|
node.setDeal_result(1);
|
node.setNote_val(note_val);
|
node.setAnswer_time(DateUtil.getCurrentDate14());
|
node.update();
|
|
}
|
}
|
|
//更新盘点工单状态
|
sql.setLength(0);
|
sql.append(" update stock_inventory set state =:state where id=:orderId ");
|
baseDao.execute(sql.toString(), param);
|
}
|
|
@Override
|
public Map getDetail(String orderId) {
|
Map<String, String> param = new HashMap<String, String>();
|
param.put("orderId", orderId);
|
StringBuilder sql = new StringBuilder(" select * from stock_inventory where id = :orderId ");
|
Map detail = baseDao.queryForMap(sql.toString(), param);
|
|
//查询盘点明细
|
sql.setLength(0);
|
sql.append(" select a.*,b.lv1_name,b.lv2_name,b.name from spare_part_detail a,cmdb_ci_category b where a.cate_id = b.id and a.inventory_order_id=:orderId ");
|
List<Map> list = baseDao.queryForList(sql.toString(), param);
|
detail.put("list", list);
|
|
sql.setLength(0);
|
sql.append(" select inventory_order_id,sum(inventory_num) inventory_num,sum(book_num) book_num,sum(loss_num) loss_num,sum(overage_num) overage_num " +
|
" from spare_part_detail where inventory_order_id=:orderId group by inventory_order_id ");
|
Map sumInfo = baseDao.queryForMap(sql.toString(), param);
|
detail.put("inventory_num", ConvertUtil.obj2StrBlank(sumInfo.get("inventory_num")));
|
detail.put("book_num", ConvertUtil.obj2StrBlank(sumInfo.get("book_num")));
|
detail.put("loss_num", ConvertUtil.obj2StrBlank(sumInfo.get("loss_num")));
|
detail.put("overage_num", ConvertUtil.obj2StrBlank(sumInfo.get("overage_num")));
|
return detail;
|
}
|
|
@Override
|
public void editStockTaking(Map<String, String> params) {
|
|
String id = params.get("id");
|
params.put("gmt_create", DateUtil.getCurrentDate14().toString());
|
params.put("gmt_modified", DateUtil.getCurrentDate14().toString());
|
params.put("order_code", workOrderCodeService.getStockTakingCode());
|
|
if (params.get("gmt_start").isEmpty()) {
|
params.put("gmt_start", null);
|
}
|
|
if (params.get("gmt_end").isEmpty()) {
|
params.put("gmt_end", null);
|
}
|
if (params.get("cycle").isEmpty()) {
|
params.put("cycle", "0");
|
}
|
StringBuilder sql = new StringBuilder();
|
if (StringUtil.isBlank(id)) {//新增
|
params.put("state", "1");
|
id = StringUtil.getUUID();
|
params.put("id", id);
|
sql.append(" INSERT INTO stock_inventory (id,order_name,gmt_start,gmt_end,cycle,note,flow_id,create_id,create_name,gmt_create,gmt_modified,state,order_code ) ");
|
sql.append(" values (:id,:order_name,:gmt_start,:gmt_end,:cycle,:note,:flow_id,:create_id,:create_name,:gmt_create,:gmt_modified,:state,:order_code) ");
|
} else {
|
|
sql.append(" update stock_inventory set order_name=:order_name,gmt_start=:gmt_start,gmt_end=:gmt_end,cycle=:cycle," +
|
" note=:note,gmt_modified=:gmt_modified " +
|
" where id=:id ");
|
}
|
|
|
//保存新增盘点工单
|
baseDao.execute(sql.toString(), params);
|
params.put("id", id);
|
params.put("inventory_order_id", id);
|
baseDao.execute("delete from spare_part_detail where inventory_order_id=:id ", params);
|
|
//添加供货信息
|
String cateIds = params.get("cate_id");
|
String inventory_num = params.get("inventory_num"); //盘点总数
|
String book_num = params.get("book_num");
|
String note2 = params.get("note2");
|
|
String loss_num = params.get("loss_num");
|
String overage_num = params.get("overage_num");
|
String cate_num = params.get("cate_num");
|
|
if (StringUtil.isNotBlank(cateIds)) {
|
sql.setLength(0);
|
sql.append(" insert into spare_part_detail (id,inventory_order_id,cate_id,inventory_num,book_num,loss_num,overage_num,cate_num,note ) ");
|
sql.append(" values (:id,:inventory_order_id,:cate_id,:inventory_num,:book_num,:loss_num,:overage_num,:cate_num,:note2)");
|
List<SqlParameter> paramList = new ArrayList<SqlParameter>();
|
|
String[] cateIdAry = cateIds.split(",");
|
String[] slNumAry = inventory_num.split(",");
|
String[] bookNumAry = book_num.split(",");
|
String[] note2Ary = note2.split(",");
|
String[] lossNumAry = loss_num.split(",");
|
String[] overageNumAry = overage_num.split(",");
|
String[] cateNumAry = cate_num.split(",");
|
for (int i = 0; i < cateIdAry.length; i++) {
|
SqlParameter p = new SqlParameter();
|
p.addValue("id", StringUtil.getUUID())
|
.addValue("cate_id", cateIdAry[i])
|
.addValue("inventory_order_id", id)
|
.addValue("book_num", bookNumAry[i])
|
.addValue("note2", note2Ary.length == 0 ? null : note2Ary[i])
|
.addValue("loss_num", lossNumAry[i])
|
.addValue("overage_num", overageNumAry[i])
|
.addValue("cate_num", cateNumAry[i])
|
.addValue("inventory_num", slNumAry[i]);
|
|
paramList.add(p);
|
}
|
baseDao.executeBatch(sql.toString(), paramList);
|
} else {
|
|
sql.setLength(0);
|
sql.append(" update spare_part_detail set inventory_order_id=:inventory_order_id,cate_id=:cate_id,inventory_num=:inventory_num," +
|
"book_num=:book_num,loss_num=:loss_num,overage_num=:overage_num,cate_num=:cate_num,note=:note2 " +
|
" where inventory_order_id= :id");
|
List<SqlParameter> paramList = new ArrayList<SqlParameter>();
|
String[] cateIdAry = cateIds.split(",");
|
String[] slNumAry = inventory_num.split(",");
|
String[] bookNumAry = book_num.split(",");
|
String[] note2Ary = note2.split(",");
|
String[] lossNumAry = loss_num.split(",");
|
String[] overageNumAry = overage_num.split(",");
|
String[] cateNumAry = cate_num.split(",");
|
for (int i = 0; i < cateIdAry.length; i++) {
|
SqlParameter p = new SqlParameter();
|
p.addValue("id", id)
|
.addValue("cate_id", cateIdAry[i])
|
.addValue("inventory_order_id", id)
|
.addValue("book_num", bookNumAry[i])
|
.addValue("note2", note2Ary[i])
|
.addValue("loss_num", lossNumAry[i])
|
.addValue("overage_num", overageNumAry[i])
|
.addValue("cate_num", cateNumAry[i])
|
.addValue("inventory_num", slNumAry[i]);
|
|
paramList.add(p);
|
}
|
baseDao.executeBatch(sql.toString(), paramList);
|
|
|
}
|
|
//如果处理人不为空，则发送到审核环节
|
if(StringUtil.isNotBlank(params.get("dealId"))){
|
params.put("orderId", id);
|
params.remove("id");
|
params.put("userId", params.get("create_id"));
|
this.sendToApprove(params);
|
}
|
|
}
|
|
@Override
|
public void editStockStatus(String id) {
|
String sql= "update stock_inventory set STATE = 0 where id = '"+id+"'";
|
baseDao.execute(sql, null);
|
}
|
}
|
