package com.shlanbao.tzsc.pms.cos.spare.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
import com.shlanbao.tzsc.utils.tools.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.CosSparePartsCopDaoI;
|
import com.shlanbao.tzsc.base.dao.CosSparePartsDaoI;
|
import com.shlanbao.tzsc.base.dao.MdEqpTypeDaoI;
|
import com.shlanbao.tzsc.base.mapping.CosSpareParts;
|
import com.shlanbao.tzsc.base.mapping.MdEqpType;
|
import com.shlanbao.tzsc.base.mapping.MdUnit;
|
import com.shlanbao.tzsc.base.model.DataGrid;
|
import com.shlanbao.tzsc.base.model.PageParams;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.pms.cos.spare.beans.CosSparePartsBean;
|
import com.shlanbao.tzsc.pms.cos.spare.service.CosSparePartsServiceI;
|
import com.shlanbao.tzsc.utils.params.SysEqpTypeBase;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
@Service
|
public class CosSparePartsServiceImpl extends BaseService implements
|
CosSparePartsServiceI {
|
|
@Autowired
|
public CosSparePartsDaoI cosSparePartsDaoI;
|
|
@Autowired
|
public CosSparePartsCopDaoI cosSparePartsCop;
|
|
@Autowired
|
public MdEqpTypeDaoI mdEqpTypeDao;
|
|
@Autowired
|
private HttpServletRequest request;
|
|
// 添加或修改
|
@LogAnno(operateType = "备品备件添加或修改")
|
@Override
|
public boolean saveOrUpdateBean(CosSparePartsBean bean) throws Exception {
|
CosSpareParts spare = null;
|
if (StringUtil.notNull(bean.getId())) {
|
spare = getMappingBeanById(bean.getId());
|
FillUserInfoUtil.fillUpdateUserInfo(spare,request);
|
}else {
|
spare = new CosSpareParts();
|
FillUserInfoUtil.fillCreateUserInfo(spare, request);
|
}
|
spare.setSpareCode(bean.getSpareCode());
|
spare.setNumber(bean.getNumber());
|
spare.setName(bean.getName());
|
spare.setPrice(bean.getPrice());
|
spare.setEqpType(mdEqpTypeDao.findById(MdEqpType.class, bean.getEqpTypeId()));
|
spare.setRemark(bean.getRemark());
|
spare.setType(bean.getType());
|
spare.setDel("0");
|
if (StringUtil.notNull(bean.getUnitId())) {
|
MdUnit unit = new MdUnit();
|
unit.setId(bean.getUnitId());
|
spare.setUnit(unit);
|
}
|
if (StringUtil.notNull(bean.getEqpTypeId())) {
|
MdEqpType eqpType = new MdEqpType();
|
eqpType.setId(bean.getEqpTypeId());
|
spare.setEqpType(eqpType);
|
}
|
|
return cosSparePartsDaoI.saveOrUpdate(spare);
|
}
|
|
// 查询list
|
@Override
|
public List<CosSparePartsBean> queryListByBeans(CosSparePartsBean bean)
|
throws Exception {
|
return queryListByBeans(bean, null, 0l, false);
|
}
|
|
// WCT备品备件查询
|
@Override
|
public DataGrid queryGridByBean(CosSparePartsBean bean,
|
PageParams pageParams) throws Exception {
|
Long length = queryTotal();
|
// long length=15;
|
List<CosSparePartsBean> beans = queryListByBeans(bean, pageParams,
|
length, true);
|
return new DataGrid(beans, length);
|
}
|
@LogAnno(operateType = "备品备件删除")
|
@Override
|
public boolean deleteById(String id){
|
CosSpareParts b=cosSparePartsDaoI.findById(CosSpareParts.class, id);
|
b.setDel("1");
|
return true;
|
}
|
// 根据id查询
|
@Override
|
public CosSparePartsBean getBeanById(String id) throws Exception {
|
CosSpareParts spare = cosSparePartsDaoI.findById(CosSpareParts.class,
|
id);
|
CosSparePartsBean b = new CosSparePartsBean();
|
BeanConvertor.copyProperties(spare, b);
|
try {
|
} catch (Exception e) {
|
|
}
|
try {
|
b.setEqpTypeId(spare.getEqpType().getId());
|
b.setEqpTypeCode(spare.getEqpType().getCode());
|
b.setEqpTypeName(spare.getEqpType().getName());
|
} catch (Exception e) {
|
b.setEqpTypeId(null);
|
b.setEqpTypeId(null);
|
b.setEqpTypeCode(null);
|
}
|
try {
|
b.setUnitId(spare.getUnit().getId());
|
b.setUnitName(spare.getUnit().getName());
|
} catch (Exception e) {
|
b.setUnitId(null);
|
b.setUnitName(null);
|
}
|
return b;
|
}
|
|
// 根据id查询mapping类
|
public CosSpareParts getMappingBeanById(String id) throws Exception {
|
return cosSparePartsDaoI.findById(CosSpareParts.class, id);
|
}
|
|
/**
|
* WCT备品备件更换框查询
|
*
|
* @param bean
|
* @param pageParams
|
* @param length
|
* @param isNameFuzzy
|
* @return
|
* @throws Exception
|
*/
|
public List<CosSparePartsBean> queryListByBeans(CosSparePartsBean bean,
|
PageParams pageParams, Long length, boolean isNameFuzzy)
|
throws Exception {
|
|
String hql = "from CosSpareParts o where 1=1 and del= '0' ";
|
String param = "";
|
if (StringUtil.notNull(bean.getId()))
|
param += "and o.id='" + bean.getId() + "' ";
|
if (StringUtil.notNull(bean.getEqpTypeId()))
|
param += "and o.eqpType.id='" + bean.getEqpTypeId() + "' ";
|
if (isNameFuzzy && StringUtil.notNull(bean.getName()))
|
param += "and o.name like '%" + bean.getName().trim() + "%' ";
|
else if (StringUtil.notNull(bean.getName()))
|
param += "and o.name='" + bean.getName().trim() + "' ";
|
// star-数量
|
if (StringUtil.notNull(bean.getNumber()))
|
param += "and o.number='" + bean.getNumber() + "' ";
|
// end
|
if (StringUtil.notNull(bean.getSpareCode()))
|
param += "and o.spareCode='" + bean.getSpareCode() + "' ";
|
if (StringUtil.notNull(bean.getEqpTypeName()))
|
param += "and o.eqpType.name='" + bean.getEqpTypeName() + "' ";
|
if (StringUtil.notNull(bean.getUnitId()))
|
param += "and o.unit.id='" + bean.getUnitId() + "' ";
|
if (StringUtil.notNull(bean.getType())) {
|
param += "and o.type like'%" + bean.getType().trim() + "%'";
|
}
|
List<CosSpareParts> list = null;
|
list=cosSparePartsDaoI.query(hql.concat(param));
|
List<CosSparePartsBean> beans = new ArrayList<CosSparePartsBean>();
|
if (list.size() > 0) {
|
for (CosSpareParts spare : list) {
|
CosSparePartsBean b = new CosSparePartsBean();
|
BeanConvertor.copyProperties(spare, b);
|
if (spare.getEqpType() != null
|
&& !spare.getEqpType().equals("")) {
|
b.setEqpTypeId(spare.getEqpType().getId());
|
b.setEqpTypeCode(spare.getEqpType().getCode());
|
b.setEqpTypeName(spare.getEqpType().getName());
|
}
|
if (spare.getUnit() != null && !spare.getUnit().equals("")) {
|
b.setUnitId(spare.getUnit().getId());
|
b.setUnitName(spare.getUnit().getName());
|
}
|
b.setNumber(spare.getNumber());
|
b.setType(spare.getType());
|
b.setId(spare.getId());
|
beans.add(b);
|
}
|
}
|
return beans;
|
}
|
|
// PMS备品备件查询
|
@Override
|
public DataGrid queryGridByBeanPMS(CosSparePartsBean bean,
|
PageParams pageParams) throws Exception {
|
Long length;
|
// long length=15;
|
/*List<CosSparePartsBean> beans = queryListByBeansPMS(bean, pageParams,
|
length, true);*/
|
String hql = "from CosSpareParts o where 1=1 and del='0' ";
|
String param = "";
|
if (StringUtil.notNull(bean.getId()))
|
param += "and o.id='" + bean.getId() + "' ";
|
if (StringUtil.notNull(bean.getEqpTypeId()))
|
param += "and o.eqpType.id='" + bean.getEqpTypeId() + "' ";
|
if (true && StringUtil.notNull(bean.getName()))
|
param += "and o.name like '%" + bean.getName().trim() + "%' ";
|
else if (StringUtil.notNull(bean.getName()))
|
param += "and o.name='" + bean.getName().trim() + "' ";
|
// star-数量
|
if (StringUtil.notNull(bean.getNumber()))
|
param += "and o.number='" + bean.getNumber() + "' ";
|
// end
|
if (StringUtil.notNull(bean.getSpareCode()))
|
param += "and o.spareCode='" + bean.getSpareCode() + "' ";
|
if (StringUtil.notNull(bean.getEqpTypeName()))
|
param += "and o.eqpType.name='" + bean.getEqpTypeName() + "' ";
|
if (StringUtil.notNull(bean.getUnitId()))
|
param += "and o.unit.id='" + bean.getUnitId() + "' ";
|
if (StringUtil.notNull(bean.getType())) {
|
param += "and o.type like'%" + bean.getType().trim() + "%'";
|
}
|
List<CosSpareParts> list = null;
|
if (pageParams != null) {
|
list = cosSparePartsDaoI.queryByPage(hql.concat(param), pageParams);
|
} else {
|
list = cosSparePartsDaoI.query(hql);
|
}
|
length = cosSparePartsDaoI.queryTotal("select count(1) "+hql.concat(param));
|
List<CosSparePartsBean> beans = new ArrayList<CosSparePartsBean>();
|
if (list.size() > 0) {
|
for (CosSpareParts spare : list) {
|
CosSparePartsBean b = new CosSparePartsBean();
|
BeanConvertor.copyProperties(spare, b);
|
if (spare.getEqpType() != null
|
&& !spare.getEqpType().equals("")) {
|
b.setEqpTypeId(spare.getEqpType().getId());
|
b.setEqpTypeCode(spare.getEqpType().getCode());
|
b.setEqpTypeName(spare.getEqpType().getName());
|
}
|
if (spare.getUnit() != null && !spare.getUnit().equals("")) {
|
b.setUnitId(spare.getUnit().getId());
|
b.setUnitName(spare.getUnit().getName());
|
}
|
b.setNumber(spare.getNumber());
|
b.setType(spare.getType());
|
b.setId(spare.getId());
|
FillUserInfoUtil.fillCreateAndUpdateUserInfo(spare,b);
|
beans.add(b);
|
}
|
}
|
return new DataGrid(beans, length);
|
}
|
|
/**
|
* PMS系统备品备件查询 张璐
|
*/
|
public List<CosSparePartsBean> queryListByBeansPMS(CosSparePartsBean bean,
|
PageParams pageParams, long length, boolean isNameFuzzy)
|
throws Exception {
|
String hql = "from CosSpareParts o where 1=1 and del='0' ";
|
String param = "";
|
if (StringUtil.notNull(bean.getId()))
|
param += "and o.id='" + bean.getId() + "' ";
|
if (StringUtil.notNull(bean.getEqpTypeId()))
|
param += "and o.eqpType.id='" + bean.getEqpTypeId() + "' ";
|
if (isNameFuzzy && StringUtil.notNull(bean.getName()))
|
param += "and o.name like '%" + bean.getName().trim() + "%' ";
|
else if (StringUtil.notNull(bean.getName()))
|
param += "and o.name='" + bean.getName().trim() + "' ";
|
// star-数量
|
if (StringUtil.notNull(bean.getNumber()))
|
param += "and o.number='" + bean.getNumber() + "' ";
|
// end
|
if (StringUtil.notNull(bean.getSpareCode()))
|
param += "and o.spareCode='" + bean.getSpareCode() + "' ";
|
if (StringUtil.notNull(bean.getEqpTypeName()))
|
param += "and o.eqpType.name='" + bean.getEqpTypeName() + "' ";
|
if (StringUtil.notNull(bean.getUnitId()))
|
param += "and o.unit.id='" + bean.getUnitId() + "' ";
|
if (StringUtil.notNull(bean.getType())) {
|
param += "and o.type like'%" + bean.getType().trim() + "%'";
|
}
|
List<CosSpareParts> list = null;
|
|
if (pageParams != null) {
|
length = cosSparePartsDaoI.queryTotal(hql.concat(param));
|
list = cosSparePartsDaoI.queryByPage(hql.concat(param), pageParams);
|
} else {
|
length = cosSparePartsDaoI.queryTotal(hql.concat(param));
|
list = cosSparePartsDaoI.query(hql);
|
}
|
List<CosSparePartsBean> beans = new ArrayList<CosSparePartsBean>();
|
if (list.size() > 0) {
|
for (CosSpareParts spare : list) {
|
CosSparePartsBean b = new CosSparePartsBean();
|
BeanConvertor.copyProperties(spare, b);
|
if (spare.getEqpType() != null
|
&& !spare.getEqpType().equals("")) {
|
b.setEqpTypeId(spare.getEqpType().getId());
|
b.setEqpTypeCode(spare.getEqpType().getCode());
|
b.setEqpTypeName(spare.getEqpType().getName());
|
}
|
if (spare.getUnit() != null && !spare.getUnit().equals("")) {
|
b.setUnitId(spare.getUnit().getId());
|
b.setUnitName(spare.getUnit().getName());
|
}
|
b.setNumber(spare.getNumber());
|
b.setType(spare.getType());
|
b.setId(spare.getId());
|
FillUserInfoUtil.fillCreateAndUpdateUserInfo(spare,b);
|
beans.add(b);
|
}
|
}
|
return beans;
|
}
|
|
private long queryTotal() throws Exception {
|
String sql = "select count(0) from CosSpareParts where del='0'";
|
return cosSparePartsDaoI.queryTotal(sql);
|
}
|
|
@Override
|
public void deleteBean(String id) {
|
cosSparePartsDaoI.deleteById(id, CosSpareParts.class);
|
}
|
|
/**
|
* 【功能说明】：备品备件导入Excel，批量保存
|
* shisihai
|
*
|
* */
|
@LogAnno(operateType = "备品备件批量导入")
|
@Override
|
public boolean batchInputExeclAndReadWrite(List<CosSparePartsBean> lt,
|
CosSparePartsBean cspb) throws Exception {
|
StringBuffer sb = null;
|
CosSpareParts p=null;
|
StringBuffer sb2=null;
|
for (int i = 0; i < lt.size(); i++) {
|
CosSparePartsBean csp = lt.get(i);
|
sb2=new StringBuffer();
|
sb = new StringBuffer();
|
if (csp == null || csp.getName().trim().equals("")) {
|
continue;
|
}
|
// 判断是否已经存在
|
sb2.append(" from CosSpareParts o where 1=1 and del='0' ");
|
if(csp.getSpareCode()!=null){
|
sb2.append(" and o.spareCode='"+ csp.getSpareCode()+"'");
|
}
|
if(csp.getType()!=null){
|
sb2.append(" and o.type='"+csp.getType()+"'");
|
}
|
if(csp.getEqpTypeId()!=null){
|
sb2.append(" and o.eqpType='"+csp.getEqpTypeId()+"'");
|
}
|
if(csp.getName()!=null){
|
String name=csp.getName();
|
if(name.contains("'")){
|
name=name.replace("'", "");
|
};
|
sb2.append(" and o.name='"+name+"'");
|
}
|
List<CosSpareParts> list = cosSparePartsDaoI.query(sb2.toString());
|
sb2=null;
|
if (list != null && list.size() > 0) {
|
p=list.get(0);//数据库已存在
|
int num=0;//用于接收库存的整数
|
double num4=0.0;//用于接收库存的小数
|
|
int num2=0;//用于接收导入的整数
|
double num3=0.0;//用于接收导入的小数
|
|
|
//库存信息
|
if(p.getNumber()!=null){
|
try {
|
num=Integer.parseInt(p.getNumber());
|
} catch (Exception e) {
|
try{
|
num4=Double.parseDouble(p.getNumber());
|
num4=MathUtil.roundHalfUp(num4, 2);
|
}catch(Exception e2){
|
e2.printStackTrace();
|
}
|
}
|
}
|
|
//需要累加的信息
|
if(csp.getNumber()!=null){//现在需要导入的数量
|
String numS=csp.getNumber();
|
try {
|
num2=Integer.parseInt(numS);
|
} catch (Exception e) {
|
try{
|
num3=Double.parseDouble(numS);
|
num3=MathUtil.roundHalfUp(num3, 2);
|
}catch(Exception e2 ){
|
e2.printStackTrace();
|
}
|
|
}
|
}
|
//如果导入累加的数量为0，继续下一个
|
if(num2==0&&num3==0){
|
continue;
|
}
|
String sql=null;
|
if(num3==0){
|
if(num4==0){
|
sql="UPDATE COS_SPARE_PARTS SET ATTR2 = "+(num+num2)+" where id='"+p.getId()+"'";
|
}else{
|
sql="UPDATE COS_SPARE_PARTS SET ATTR2 = "+(num4+num2)+" where id='"+p.getId()+"'";
|
}
|
}else{
|
if(num4==0){
|
sql="UPDATE COS_SPARE_PARTS SET ATTR2 = "+(num+num3)+" where id='"+p.getId()+"'";
|
}else{
|
sql="UPDATE COS_SPARE_PARTS SET ATTR2 = "+(num4+num3)+" where id='"+p.getId()+"'";
|
}
|
}
|
cosSparePartsDaoI.updateBySql(sql.toString(), null);
|
} else {
|
sb.append(" INSERT into COS_SPARE_PARTS(ID,NAME,EQP_TYPE,REMARK,PRICE,UNIT,ATTR1,ATTR2,TYPE,SEARCH_W,position,sell_num,random_num,amount,DEL) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)");
|
List<Object> params = new ArrayList<Object>();
|
params.add(UUID.randomUUID().toString());
|
//去掉特殊的字符
|
String name=csp.getName();
|
if(name.contains("'")){
|
name=name.replace("'", "");
|
};
|
params.add(name);
|
params.add(csp.getEqpTypeId());
|
params.add(csp.getRemark());
|
params.add(csp.getPrice());
|
params.add(csp.getUnitId());
|
params.add(csp.getNumber());
|
params.add(csp.getSpareCode());
|
params.add(csp.getType());
|
params.add(csp.getSEARCH_W());
|
params.add(csp.getPosition());
|
params.add(csp.getSell_num());
|
params.add(csp.getRandom_num());
|
params.add(csp.getAmount());
|
params.add("0");
|
cosSparePartsDaoI.updateBySql(sb.toString(), params);
|
}
|
}
|
return false;
|
}
|
|
/**
|
* 单位名：单位id
|
*
|
* @return
|
*/
|
public Map<String, String> retUnit() {
|
return SysEqpTypeBase.getUnit();
|
}
|
|
@Override
|
public void batchSaveSparePart(List<CosSparePartsBean> lt) throws Exception {
|
for (CosSparePartsBean cosSparePart : lt) {
|
//查询是否存在，存在更新
|
String hql="select id from CosSpareParts o where o.spareCode=? and o.name=? and o.categoryCode=?";
|
List<CosSparePartsBean> datas=cosSparePartsCop.query(hql, cosSparePart.getSpareCode(),cosSparePart.getName(),cosSparePart.getCategoryCode());
|
if(datas!=null && datas.size()>1){
|
throw new Exception("保存MES下发的备品备件数据错误！备件code为："+cosSparePart.getSpareCode()+"存在多个！");
|
}
|
if(datas!=null && datas.size()==1){
|
cosSparePart.setId(datas.get(0).getId());
|
}
|
cosSparePart.setDel("0");
|
cosSparePartsCop.saveOrUpdate(cosSparePart);
|
}
|
}
|
@LogAnno(operateType = "批量删除备品备件")
|
@Override
|
public void batchDeleteBean(String ids) {
|
String[] split = ids.split(",");
|
try {
|
for (int i = 0; i < split.length; i++) {
|
CosSpareParts b=cosSparePartsDaoI.findById(CosSpareParts.class, split[i]);
|
b.setDel("1");
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
}
|
}
|
