package com.shlanbao.tzsc.pms.md.fixCode.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.shlanbao.tzsc.base.model.SessionInfo;
|
import com.shlanbao.tzsc.plugin.service.LoadComboboxServiceI;
|
import com.shlanbao.tzsc.pms.md.fixCode.beans.AccessParam;
|
import com.shlanbao.tzsc.pms.md.fixCode.beans.SelfCheckParam;
|
import com.shlanbao.tzsc.utils.params.ComboboxType;
|
import com.shlanbao.tzsc.utils.tools.BeanConvertor;
|
import com.shlanbao.tzsc.utils.tools.LogAnno;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.MdFixCodeDaoI;
|
import com.shlanbao.tzsc.base.mapping.MdFixCode;
|
import com.shlanbao.tzsc.base.model.Json;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.pms.md.fixCode.beans.FixCodeBean;
|
import com.shlanbao.tzsc.pms.md.fixCode.service.FixCodeServiceI;
|
import com.shlanbao.tzsc.utils.tools.StringUtil;
|
|
import javax.servlet.http.HttpServletRequest;
|
@Service
|
public class FixCodeServiceImpl extends BaseService implements FixCodeServiceI {
|
|
@Autowired
|
private MdFixCodeDaoI mdFixCodeDao;
|
@Autowired
|
private HttpServletRequest request;
|
@Autowired
|
private LoadComboboxServiceI loadComboboxService;
|
/**
|
* 【功能说明】：查询综合基础数据
|
*
|
* @author wanchanghuang
|
* @createTime 2016年6月2日15:56:12
|
* @return
|
*
|
*/
|
@Override
|
public List<FixCodeBean> queryFixCode(FixCodeBean fixBean) {
|
try {
|
StringBuffer sql = new StringBuffer(1000);
|
sql.append("select id,name,mes_code,type,del,code,upcode,des,create_time,create_name,update_time,update_name,bak from md_fix_code where del=0 ");
|
if (fixBean != null) {
|
if(StringUtil.notEmpty(fixBean.getId())){
|
sql.append(" and id='" + fixBean.getId() + "'");
|
}
|
if (StringUtil.notEmpty(fixBean.getName())) {
|
sql.append(" and name='" + fixBean.getName() + "'");
|
}
|
if (StringUtil.notEmpty(fixBean.getMesCode())) {
|
sql.append(" and mes_code='" + fixBean.getMesCode() + "'");
|
}
|
if (StringUtil.notEmpty(fixBean.getType())) {
|
sql.append(" and type='" + fixBean.getType() + "'");
|
}
|
if (StringUtil.notEmpty(fixBean.getCode())) {
|
sql.append(" and code='" + fixBean.getCode() + "'");
|
}
|
if (StringUtil.notEmpty(fixBean.getUpcode())) {
|
sql.append(" and upcode='" + fixBean.getUpcode() + "'");
|
}
|
if (StringUtil.notEmpty(fixBean.getBak())) {
|
sql.append(" and bak='" + fixBean.getBak() + "'");
|
}
|
|
}
|
sql.append(" order by upcode");
|
List<?> list = mdFixCodeDao.queryBySql(sql.toString());
|
List<FixCodeBean> fixc = new ArrayList<FixCodeBean>();
|
FixCodeBean fixbean = null;
|
for (int i = 0; i < list.size(); i++) {
|
Object[] arr = (Object[]) list.get(i);
|
fixbean = new FixCodeBean();
|
if (arr[0] != null) {
|
fixbean.setId(arr[0].toString());
|
}
|
if (arr[1] != null) {
|
fixbean.setName(arr[1].toString());
|
}
|
if (arr[2] != null) {
|
fixbean.setMesCode(arr[2].toString());
|
}
|
if (arr[3] != null) {
|
fixbean.setType(arr[3].toString());
|
}
|
if (arr[4] != null) {
|
fixbean.setDel(arr[4].toString());
|
}
|
if (arr[5] != null) {
|
fixbean.setCode(arr[5].toString());
|
}
|
if (arr[6] != null) {
|
fixbean.setUpcode(arr[6].toString());
|
}
|
|
if (arr[7] != null) {
|
fixbean.setDes(arr[7].toString());
|
}
|
if (arr[8] != null) {
|
fixbean.setCreateTime(arr[8].toString());
|
}
|
if (arr[9] != null) {
|
fixbean.setCreateName(arr[9].toString());
|
}
|
if (arr[10] != null) {
|
fixbean.setUpdateTime(arr[10].toString());
|
}
|
if (arr[11] != null) {
|
fixbean.setUpdateName(arr[11].toString());
|
}
|
if (arr[12] != null) {
|
fixbean.setBak(arr[12].toString());
|
}
|
//fixbean.setCreateTime(DateUtil.formatDateToString(new Date(), "yyyy-MM-dd HH:mm:sss"));
|
//fixbean.setUpdateTime(DateUtil.formatDateToString(new Date(), "yyyy-MM-dd HH:mm:sss"));
|
fixc.add(fixbean);
|
}
|
return fixc;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
@LogAnno(operateType = "综合基础数据添加或编辑")
|
@Override
|
public Json saveFixCode(MdFixCode fixBean2,FixCodeBean params) {
|
//查询是否存在！存在更新 不存在添加
|
Json json=new Json();
|
try {
|
MdFixCode fixBean = new MdFixCode();
|
//如果fixBean2中有id值那么就是修改，需要从数据库查该条数据的创建信息
|
if(StringUtil.notNull(fixBean2.getId())){
|
fixBean = mdFixCodeDao.findById(MdFixCode.class, fixBean2.getId());
|
}
|
//将fixBean2转换到fixBean，如果是新增则没有改变
|
BeanConvertor.copyProperties(fixBean2,fixBean);
|
List<FixCodeBean> ls=null;
|
if(params!=null){
|
if(StringUtil.notEmpty(params.getId())){
|
FixCodeBean bean2=new FixCodeBean();
|
bean2.setId(fixBean.getId());
|
bean2.setDel("0");
|
ls=queryFixCode(bean2);
|
}else{
|
ls=queryFixCode(params);
|
}
|
}
|
//获得当前登录者的信息
|
SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
//如果创建信息为空则初始化创建信息与修改信息
|
if(!StringUtil.notNull(fixBean.getCreateName())){
|
fixBean.setCreateName(sessionInfo.getUser().getName());
|
fixBean.setCreateTime(new Date());
|
fixBean.setUpdateName(sessionInfo.getUser().getName());
|
fixBean.setUpdateTime(new Date());
|
}
|
json.setMsg("新增数据成功！");
|
json.setSuccess(true);
|
if((ls!=null && ls.size() <=1) || ls==null ){
|
if(ls!=null && ls.size()==1){
|
fixBean.setId(ls.get(0).getId());
|
//如果是修改则填充修改信息
|
fixBean.setUpdateName(sessionInfo.getUser().getName());
|
fixBean.setUpdateTime(new Date());
|
json.setMsg("更新数据成功！");
|
}
|
//避免id=“”的数据
|
if(!StringUtil.notEmpty(fixBean.getId())){
|
fixBean.setId(null);
|
}
|
mdFixCodeDao.saveOrUpdate(fixBean);
|
}else{
|
json.setSuccess(false);
|
json.setMsg("查询出的数据不唯一！保存或更新MdFixCode失败！");
|
log.error("查询出的数据不唯一！保存更新MdFixCode失败！");
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
json.setSuccess(false);
|
json.setMsg("保存或更新MdFixCode异常！");
|
}
|
return json;
|
}
|
|
@Override
|
public void refrushData() {
|
/*BaseParams.getListMdFixCode().clear();
|
BaseParams.setListMdFixCode(queryFixCode(null));*/
|
loadComboboxService.initCombobox(ComboboxType.ALL); //初始化基础数据
|
}
|
|
@LogAnno(operateType = "综合基础数据删除")
|
@Override
|
public Json deleteFixCode(String id) {
|
Json json=new Json();
|
try {
|
MdFixCode mdFixCode= mdFixCodeDao.findById(MdFixCode.class, id);
|
mdFixCode.setDel("1");
|
json.setMsg("成功");
|
json.setSuccess(true);
|
} catch (Exception e) {
|
json.setMsg("失败");
|
json.setSuccess(false);
|
e.printStackTrace();
|
}
|
return json;
|
}
|
|
@Override
|
public void saveWorkCenterByCenter(String workCenterCode,MdFixCode fixCode){
|
FixCodeBean params=new FixCodeBean();
|
params.setMesCode(workCenterCode);
|
params.setUpcode("WORKCENTEREQP0001");
|
params.setDel("0");
|
List<FixCodeBean> ls=queryFixCode(params);
|
if(null==ls || ls.size()==0){
|
mdFixCodeDao.save(fixCode);
|
}
|
}
|
|
/**
|
* 更新发送状态
|
*
|
* */
|
@Override
|
public void updateQmOLinkCheck(String olid,String param) {
|
//更新修改人与修改时间
|
// SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
// String updateUserName = sessionInfo.getUser().getName();
|
try {
|
olid=olid.substring(0,olid.lastIndexOf(","));
|
if(!"".equals(olid)){
|
olid=olid.replaceAll(",", "','");
|
if(param!=null && !"".equals(param) ){
|
mdFixCodeDao.updateBySql("update QM_ONLINECHECK set sts='"+param+"',UPDATE_USER_TIME=sysdate where id in ('"+olid+"')", null);
|
}else{
|
mdFixCodeDao.updateBySql("update QM_ONLINECHECK set sts=1,UPDATE_USER_TIME=sysdate,check_sts=1 where id in ('"+olid+"')", null);
|
}
|
}
|
} catch (Exception e) {
|
log.error("查询出的数据不唯一！保存更新MdFixCode失败！");
|
}
|
}
|
|
/**
|
* [功能说明]修改外观数据自动反馈 共用方法
|
* 反馈成功，修改工单状态
|
* @author wanchanghuang
|
* @param olid
|
* flag true :20支质量反馈 false：正常MES反馈
|
* */
|
@Override
|
public void updateQmOutWard(String olid,String sts,boolean flag) {
|
try {
|
//更新修改人与修改时间
|
//SessionInfo sessionInfo = (SessionInfo) request.getSession().getAttribute("sessionInfo");
|
// String updateUserName = sessionInfo.getUser().getName();
|
if(flag){
|
mdFixCodeDao.updateBySql("update QM_OUTWARD set sts2='"+sts+"',UPDATE_USER_TIME=sysdate where id in ("+olid+")", null);
|
}else{
|
mdFixCodeDao.updateBySql("update QM_OUTWARD set sts='"+sts+"',UPDATE_USER_TIME=sysdate where id in ("+olid+")", null);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("修改反馈状态");
|
}
|
}
|
|
@Override
|
public void batchDeleteMdFixCode(String ids) {
|
String[] split = ids.split(",");
|
for (int i = 0; i <split.length; i++) {
|
mdFixCodeDao.findById(MdFixCode.class, split[i]).setDel("1");
|
}
|
|
|
}
|
|
|
@Override
|
public AccessParam queryWagesAccess() {
|
AccessParam accessParam = new AccessParam();
|
String sql = "from MdFixCode where upcode = 'JBGZKHCX'";
|
List<MdFixCode> list = mdFixCodeDao.query(sql);
|
if (list!=null && list.size()>0) {
|
list.forEach(item->{
|
if ("51qty".equals(item.getType())) {
|
accessParam.setA51qty(item.getCode());
|
} else if ("other1qty".equals(item.getType())) {
|
accessParam.setOther1qty(item.getCode());
|
} else if ("52qty".equals(item.getType())) {
|
accessParam.setA52qty(item.getCode());
|
} else if ("other2qty".equals(item.getType())) {
|
accessParam.setOther2qty(item.getCode());
|
} else if ("exceedEvery".equals(item.getType())) {
|
accessParam.setExceedEvery(item.getCode());
|
} else if ("exceedTotalAnther".equals(item.getType())) {
|
accessParam.setExceedTotalAnther(item.getCode());
|
} else if ("exceedAnther".equals(item.getType())) {
|
accessParam.setExceedAnther(item.getCode());
|
} else if ("totalQtyStd".equals(item.getType())) {
|
accessParam.setTotalQtystd(item.getCode());
|
} else if ("howMuch".equals(item.getType())) {
|
accessParam.setHowMuch(item.getCode());
|
} else if ("xiZhi".equals(item.getType())) {
|
accessParam.setXiZhi(item.getCode());
|
} else if ("changGui".equals(item.getType())) {
|
accessParam.setChangGui(item.getCode());
|
} else if ("underFirst".equals(item.getType())) {
|
accessParam.setUnderFirst(item.getCode());
|
} else if ("underFirstMiddle".equals(item.getType())) {
|
accessParam.setUnderFirstMiddle(item.getCode());
|
} else if ("underEvery".equals(item.getType())) {
|
accessParam.setUnderEvery(item.getCode());
|
} else if ("underSecond".equals(item.getType())) {
|
accessParam.setUnderSecond(item.getCode());
|
} else if ("underTotal".equals(item.getType())) {
|
accessParam.setUnderTotal(item.getCode());
|
} else if ("exceedOfPlan".equals(item.getType())){
|
accessParam.setExceedOfPlan(item.getCode());
|
} else if ("exceedOfPlanMiddle".equals(item.getType())){
|
accessParam.setExceedOfPlanMiddle(item.getCode());
|
} else if ("exceedOfPlanEvery".equals(item.getType())){
|
accessParam.setExceedOfPlanEvery(item.getCode());
|
}
|
});
|
}
|
return accessParam;
|
}
|
|
@Override
|
public void saveWagesAccess(AccessParam accessParam) {
|
String sql = "update md_fix_code set code = ? where upcode = 'JBGZKHCX' and type = ?";
|
List<Object> list = new ArrayList<>();
|
list.add(accessParam.getA51qty());
|
list.add("51qty");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getOther1qty());
|
list.add("other1qty");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getA52qty());
|
list.add("52qty");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getOther2qty());
|
list.add("other2qty");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getExceedAnther());
|
list.add("exceedAnther");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getExceedEvery());
|
list.add("exceedEvery");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getHowMuch());
|
list.add("howMuch");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getExceedTotalAnther());
|
list.add("exceedTotalAnther");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getTotalQtystd());
|
list.add("totalQtyStd");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getXiZhi());
|
list.add("xiZhi");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getChangGui());
|
list.add("changGui");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getUnderFirst());
|
list.add("underFirst");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getUnderFirstMiddle());
|
list.add("underFirstMiddle");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getUnderEvery());
|
list.add("underEvery");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getUnderSecond());
|
list.add("underSecond");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getUnderTotal());
|
list.add("underTotal");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getExceedOfPlan());
|
list.add("exceedOfPlan");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getExceedOfPlanMiddle());
|
list.add("exceedOfPlanMiddle");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(accessParam.getExceedOfPlanEvery());
|
list.add("exceedOfPlanEvery");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
}
|
|
|
@Override
|
public SelfCheckParam queryWlkh(String upcode) {
|
SelfCheckParam param = new SelfCheckParam();
|
String hql = "from MdFixCode where upcode = '"+upcode+"'";
|
|
List<MdFixCode> fixCodes = mdFixCodeDao.query(hql);
|
if (fixCodes!=null && fixCodes.size()>0) {
|
fixCodes.forEach(item->{
|
if ("shoujianshijian".equals(item.getType())) {
|
param.setShoujianshijian(item.getCode());
|
} else if ("zijianpinlv".equals(item.getType())) {
|
param.setZijianpinlv(item.getCode());
|
} else if ("zijianyuncha".equals(item.getType())) {
|
param.setZijianyuncha(item.getCode());
|
} else if ("loujianfakuan".equals(item.getType())) {
|
param.setLoujianfakuan(item.getCode());
|
}
|
});
|
}
|
|
|
return param;
|
}
|
|
|
@Override
|
public void saveWlkh(SelfCheckParam param, String upcode) {
|
String sql = "update md_fix_code set code = ? where upcode = '"+upcode+"' and type = ?";
|
List<Object> list = new ArrayList<>();
|
list.add(param.getShoujianshijian());
|
list.add("shoujianshijian");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(param.getZijianpinlv());
|
list.add("zijianpinlv");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(param.getZijianyuncha());
|
list.add("zijianyuncha");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
list.add(param.getLoujianfakuan());
|
list.add("loujianfakuan");
|
mdFixCodeDao.updateBySql(sql,list);
|
list.clear();
|
}
|
}
|
