package com.slcf.service.impl;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.interceptor.TransactionAspectSupport;
|
|
import com.slcf.bean.LocDetailCondition;
|
import com.slcf.dao.LocDetailDao;
|
import com.slcf.dao.LocationDao;
|
import com.slcf.dao.MatCodeDao;
|
import com.slcf.dao.StationDao;
|
import com.slcf.dao.WaitPakInDao;
|
import com.slcf.dao.WaitPakOutDao;
|
import com.slcf.dao.WorkFileDao;
|
import com.slcf.dao.WorkNoDao;
|
import com.slcf.pojo.WorkMastBean;
|
import com.slcf.service.OperateService;
|
import com.slcf.service.WaitPakOutService;
|
import com.slcf.util.CommonMethod;
|
import com.slcf.util.DateTimeUtil;
|
import com.slcf.pojo.LocDetailBean;
|
import com.slcf.pojo.LocationBean;
|
import com.slcf.pojo.MatCodeBean;
|
import com.slcf.pojo.StationBean;
|
import com.slcf.pojo.UserBean;
|
import com.slcf.pojo.WaitPakInBean;
|
import com.slcf.pojo.WaitPakOutBean;
|
import com.slcf.pojo.WorkDetailBean;
|
|
/**
|
* 入出库作业接口实现
|
* @author admin
|
* @date 2018年12月4日
|
*/
|
@Service
|
public class OperateServiceImpl implements OperateService {
|
|
@Autowired
|
WorkFileDao workFileDao;
|
@Autowired
|
MatCodeDao matCodeDao;
|
@Autowired
|
WaitPakInDao waitPakInDao;
|
@Autowired
|
LocationDao locationDao;
|
@Autowired
|
StationDao stationDao;
|
@Autowired
|
WorkNoDao workNoDao;
|
@Autowired
|
LocDetailDao locDetailDao;
|
@Autowired
|
WaitPakOutDao waitPakOutDao;
|
@Autowired
|
WaitPakOutService waitPakOutService;
|
|
/**
|
* 入库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertPakStoreIn(WorkMastBean workMast,String[] detls,
|
StationBean station,UserBean user) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
//插入workDetail
|
if(detls!=null) {
|
for(String str : detls) {
|
String[] arr = str.split(";");
|
if(arr!=null && arr.length>2) {
|
String sheet_no = arr[0];
|
String mat_no = arr[1];
|
int store_qty = Integer.parseInt(arr[2]);
|
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(workMast.getWrk_no());
|
workDetl.setMat_no(mat_no);
|
workDetl.setIo_time(workMast.getIo_time());
|
workDetl.setModi_user(user.getUser_account());
|
int result=0;
|
WorkDetailBean detl = workFileDao.getWorkDetlByIdNo(workMast.getWrk_no(),mat_no);
|
if(detl==null) {//插入
|
workDetl.setQty(store_qty);
|
result = workFileDao.insertWorkDetail(workDetl);
|
}else {//修改，数量相加
|
workDetl.setQty(store_qty + detl.getQty());
|
result = workFileDao.upWorkDetail(workDetl);
|
}
|
|
if(result>0) {
|
WaitPakInBean bean = new WaitPakInBean();
|
bean.setSheet_no(sheet_no);
|
bean.setMat_no(mat_no);
|
WaitPakInBean waitPakIn = waitPakInDao.getWaitPakInById(bean);
|
if(waitPakIn!=null) {
|
int in_qty = waitPakIn.getIn_qty() + store_qty;
|
waitPakIn.setIn_qty(in_qty);
|
if(in_qty>=waitPakIn.getQty()) {
|
waitPakIn.setIo_status("Y");
|
}
|
result = waitPakInDao.upWaitPakIn(waitPakIn);
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "查询通知档待入库资料失败:单号--" + sheet_no + "\n物料编号--" + mat_no);
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
}
|
}
|
else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
station.setWrk_no(workMast.getWrk_no());
|
station.setIn_enable(station.getIn_enable());
|
station.setOut_enable(station.getOut_enable());
|
station.setBarcode(station.getBarcode());
|
station.setDec_desc(station.getDec_desc());
|
station.setModi_user(user.getUser_account());
|
result = stationDao.upStation(station);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "更新设备档失败:" + station.getDev_no());
|
return map;
|
}
|
|
LocationBean location = locationDao.getLocationById(workMast.getLoc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("O")) {
|
location.setLoc_sts("S");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + workMast.getLoc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + workMast.getLoc_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "库位号：" + workMast.getLoc_no());
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动入库失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 空托盘入库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertEmptyStoreIn(WorkMastBean workMast,
|
StationBean station,UserBean user) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
station.setWrk_no(workMast.getWrk_no());
|
station.setIn_enable(station.getIn_enable());
|
station.setOut_enable(station.getOut_enable());
|
station.setBarcode(station.getBarcode());
|
station.setDec_desc(station.getDec_desc());
|
station.setModi_user(user.getUser_account());
|
result = stationDao.upStation(station);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "更新设备档失败:" + station.getDev_no());
|
return map;
|
}
|
|
LocationBean location = locationDao.getLocationById(workMast.getLoc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("O")) {
|
location.setLoc_sts("S");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + workMast.getLoc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + workMast.getLoc_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "库位号：" + workMast.getLoc_no());
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动入库失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 空托盘出库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertemptyRetrieve(WorkMastBean workMast,String[] locs,
|
int stn_no,UserBean user, CommonMethod commonMethod) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
int result = 0;
|
//插入workDetail
|
if(locs!=null) {
|
for(String loc_no : locs) {
|
int wrk_no = commonMethod.getNewWorkNo(workNoDao.getWorkNoById(0));
|
if(wrk_no<=0) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号失败，请联系管理员");
|
return map;
|
}else {
|
WorkMastBean workFile = workFileDao.getWorkMastById(wrk_no);
|
if(workFile!=null) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
|
return map;
|
}
|
}
|
|
int crn_no = Integer.parseInt(loc_no.substring(0,2));
|
crn_no = (crn_no + 1) / 2;
|
int s_staNo = commonMethod.getIoStaNo(110,crn_no,stn_no);
|
if(s_staNo<=0) {
|
map.put("code", 1);
|
map.put("msg", "获取堆垛机站点失败");
|
return map;
|
}
|
String io_time = DateTimeUtil.getStringDateTime(19);
|
workMast.setWrk_no(wrk_no);
|
workMast.setIo_time(io_time);
|
workMast.setCrn_no(crn_no);
|
workMast.setSource_sta_no(s_staNo);
|
workMast.setSta_no(stn_no);
|
workMast.setSource_loc_no(loc_no);
|
|
//插入workMast
|
result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean location = locationDao.getLocationById(workMast.getSource_loc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("D")) {
|
location.setLoc_sts("R");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
}
|
}
|
|
map.put("code", 0);
|
map.put("msg", "库位号：" + workMast.getSource_loc_no());
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动入库失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 库位移转
|
*/
|
@Transactional
|
public Map<String,Object> insertLocMove(WorkMastBean workMast,String old_loc_no,
|
String new_loc_no,UserBean user) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
LocDetailCondition locationCon = new LocDetailCondition();
|
locationCon.setLoc_no(old_loc_no);
|
List<LocDetailBean> list = locDetailDao.getLocDetailAll(locationCon);
|
//插入workDetail
|
if(list!=null && list.size()>0) {
|
for(LocDetailBean locDetail : list) {
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(workMast.getWrk_no());
|
workDetl.setMat_no(locDetail.getMat_no());
|
workDetl.setIo_time(workMast.getIo_time());
|
workDetl.setQty(locDetail.getQty());
|
// workDetl.setCtns(locDetail.getCtns());
|
// workDetl.setWt(locDetail.getWt());
|
workDetl.setModi_user(user.getUser_account());
|
int result = workFileDao.insertWorkDetail(workDetl);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
}
|
}
|
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean slocation = locationDao.getLocationById(workMast.getSource_loc_no());
|
if(slocation!=null) {
|
if(slocation.getLoc_sts().equals("F") || slocation.getLoc_sts().equals("D")) {
|
slocation.setLoc_sts("R");
|
slocation.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(slocation);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约原库位状态失败:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约原库位状态失败,库位号不存在:" + workMast.getLoc_no());
|
return map;
|
}
|
}
|
|
LocationBean location = locationDao.getLocationById(workMast.getLoc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("O")) {
|
location.setLoc_sts("S");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约新库位状态失败:" + workMast.getLoc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约新库位状态失败,库位号不存在:" + workMast.getLoc_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "库位号：" + workMast.getSource_loc_no() + "-->" + workMast.getLoc_no());
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动库位移转失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 指定库位盘点作业
|
*/
|
@Transactional
|
public Map<String,Object> insertLocCheck(String value,
|
int stn_no,UserBean user, CommonMethod commonMethod) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
String loc_no = value;
|
String io_time = DateTimeUtil.getStringDateTime(19);
|
//插入workDetail
|
int wrk_no = commonMethod.getNewWorkNo(workNoDao.getWorkNoById(0));
|
if(wrk_no<=0) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号失败，请联系管理员");
|
return map;
|
}else {
|
WorkMastBean workFile = workFileDao.getWorkMastById(wrk_no);
|
if(workFile!=null) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
|
return map;
|
}
|
}
|
|
LocDetailCondition locationCon = new LocDetailCondition();
|
locationCon.setLoc_no(loc_no);
|
List<LocDetailBean> list = locDetailDao.getLocDetailAll(locationCon);
|
//插入workDetail
|
if(list!=null && list.size()>0) {
|
for(LocDetailBean locDetail : list) {
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(wrk_no);
|
workDetl.setMat_no(locDetail.getMat_no());
|
workDetl.setIo_time(io_time);
|
workDetl.setQty(locDetail.getQty());
|
workDetl.setModi_user(user.getUser_account());
|
int result = workFileDao.insertWorkDetail(workDetl);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
}
|
}
|
|
WorkMastBean workMast = new WorkMastBean();
|
int crn_no = Integer.parseInt(loc_no.substring(0,2));
|
crn_no = (crn_no + 1) / 2;
|
int s_staNo = commonMethod.getIoStaNo(107,crn_no,stn_no);
|
if(s_staNo<=0) {
|
map.put("code", 1);
|
map.put("msg", "获取堆垛机站点失败");
|
return map;
|
}
|
workMast.setWrk_no(wrk_no);
|
workMast.setIo_time(io_time);
|
workMast.setWrk_sts(11);
|
workMast.setIo_type(107);
|
workMast.setIo_pri(13);
|
workMast.setCrn_no(crn_no);
|
workMast.setSource_sta_no(s_staNo);
|
workMast.setSta_no(stn_no);
|
workMast.setSource_loc_no(loc_no);
|
workMast.setFull_plt("N");
|
workMast.setPicking("N");
|
workMast.setExit_mk("N");
|
workMast.setEmpty_mk("N");
|
workMast.setLink_mis("N");
|
workMast.setModi_user(user.getUser_account());
|
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean location = locationDao.getLocationById(workMast.getSource_loc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("F")) {
|
location.setLoc_sts("P");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "库位号不存在:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
|
map.put("code", 0);
|
// map.put("msg", "库位号：" + workMast.getSource_loc_no());
|
map.put("msg", "");
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动盘点失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 并板作业
|
*/
|
@Transactional
|
public Map<String,Object> insertPakCombine(WorkMastBean workMast,String[] detls,
|
UserBean user) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
//插入workDetail
|
if(detls!=null) {
|
for(String str : detls) {
|
String[] arr = str.split(";");
|
if(arr!=null && arr.length>2) {
|
String sheet_no = arr[0];
|
String mat_no = arr[1];
|
int store_qty = Integer.parseInt(arr[2]);
|
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(workMast.getWrk_no());
|
workDetl.setMat_no(mat_no);
|
workDetl.setIo_time(workMast.getIo_time());
|
workDetl.setModi_user(user.getUser_account());
|
int result=0;
|
WorkDetailBean detl = workFileDao.getWorkDetlByIdNo(workMast.getWrk_no(),mat_no);
|
if(detl==null) {//插入
|
workDetl.setQty(store_qty);
|
result = workFileDao.insertWorkDetail(workDetl);
|
}else {//修改，数量相加
|
workDetl.setQty(store_qty + detl.getQty());
|
result = workFileDao.upWorkDetail(workDetl);
|
}
|
|
if(result>0) {
|
WaitPakInBean bean = new WaitPakInBean();
|
bean.setSheet_no(sheet_no);
|
bean.setMat_no(mat_no);
|
WaitPakInBean waitPakIn = waitPakInDao.getWaitPakInById(bean);
|
if(waitPakIn!=null) {
|
int in_qty = waitPakIn.getIn_qty() + store_qty;
|
waitPakIn.setIn_qty(in_qty);
|
if(in_qty>=waitPakIn.getQty()) {
|
waitPakIn.setIo_status("Y");
|
}
|
result = waitPakInDao.upWaitPakIn(waitPakIn);
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "查询通知档待入库资料失败:单号--" + sheet_no + "\n物料编号--" + mat_no);
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
}
|
}
|
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean location = locationDao.getLocationById(workMast.getSource_loc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("F")) {
|
location.setLoc_sts("P");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + workMast.getSource_loc_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "库位号：" + workMast.getSource_loc_no());
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动并板失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 出库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertPakRetrieve(String loc_no, String[] detls,
|
int stn_no,UserBean user, CommonMethod commonMethod) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
String io_time = DateTimeUtil.getStringDateTime(19);
|
//插入workDetail
|
int wrk_no = commonMethod.getNewWorkNo(workNoDao.getWorkNoById(1));
|
if(wrk_no<=0) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号失败，请联系管理员");
|
return map;
|
}else {
|
WorkMastBean workFile = workFileDao.getWorkMastById(wrk_no);
|
if(workFile!=null) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
|
return map;
|
}
|
}
|
// int qty=0;
|
//插入workDetail
|
if(detls!=null) {
|
for(String str : detls) {
|
String[] arr = str.split(";");
|
if(arr!=null && arr.length>4) {
|
if(!loc_no.equals(arr[0])) {
|
continue;
|
}
|
String matnr = arr[1];
|
String lgnum = arr[2];
|
String tbnum = arr[3];
|
String tbpos = arr[4];
|
|
LocDetailBean locDetl = locDetailDao.getLocDetailById(loc_no,matnr);
|
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(wrk_no);
|
workDetl.setMatnr(matnr);
|
workDetl.setLgnum(lgnum);
|
workDetl.setTbnum(Integer.parseInt(tbnum));
|
workDetl.setTbpos(Integer.parseInt(tbpos));
|
workDetl.setZmatid(locDetl.getZmatid());
|
workDetl.setMaktx(locDetl.getMaktx());
|
workDetl.setWerks(locDetl.getWerks());
|
workDetl.setAnfme(locDetl.getAnfme());
|
workDetl.setAltme(locDetl.getAltme());
|
workDetl.setBname(locDetl.getBname());
|
workDetl.setZpallet(locDetl.getZpallet());
|
workDetl.setIo_time(io_time);
|
// workDetl.setQty(retrieve_qty);
|
workDetl.setModi_user(user.getUser_account());
|
int result=workFileDao.insertWorkDetail(workDetl);
|
|
if(result>0) {
|
// WaitPakOutBean waitPakOut = new WaitPakOutBean();
|
// int random = (int)(Math.random()*900 + 100);
|
// waitPakOut.setSheet_no(DateTimeUtil.getStringDateTime(14)+Integer.toString(random));
|
// waitPakOut.setMat_no(mat_no);
|
// waitPakOut.setQty(retrieve_qty);
|
// waitPakOut.setOut_qty(retrieve_qty);
|
// waitPakOut.setStatus("Y");
|
// waitPakOut.setIo_status("Y");
|
// waitPakOut.setType("ASRS");
|
// waitPakOut.setModi_user(user.getUser_account());
|
// result = waitPakOutDao.insertWaitPakOut(waitPakOut);
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
// qty = qty + retrieve_qty;
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
|
WorkMastBean workMast = new WorkMastBean();
|
int crn_no = Integer.parseInt(loc_no.substring(0,2));
|
crn_no = (crn_no + 1) / 2;
|
String loc_sts="";
|
// int stk_qty = locDetailDao.getStockQtyByLoc(loc_no);
|
|
int s_staNo = commonMethod.getIoStaNo(101,crn_no,stn_no);
|
if(s_staNo<=0) {
|
map.put("code", 1);
|
map.put("msg", "获取堆垛机站点失败");
|
return map;
|
}
|
workMast.setSource_sta_no(s_staNo);
|
workMast.setSta_no(stn_no);
|
workMast.setIo_type(101);
|
workMast.setPicking("N");
|
loc_sts = "R";
|
|
workMast.setWrk_no(wrk_no);
|
workMast.setIo_time(io_time);
|
workMast.setWrk_sts(11);
|
workMast.setIo_pri(13);
|
workMast.setCrn_no(crn_no);
|
workMast.setSource_loc_no(loc_no);
|
workMast.setFull_plt("Y");
|
workMast.setExit_mk("N");
|
workMast.setEmpty_mk("N");
|
workMast.setLink_mis("N");
|
workMast.setModi_user(user.getUser_account());
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean location = locationDao.getLocationById(loc_no);
|
if(location!=null) {
|
if(location.getLoc_sts().equals("F")) {
|
location.setLoc_sts(loc_sts);
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + loc_no);
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + loc_no);
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "");
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 预约出库->出库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertPakRetrieve1(String loc_no, String[] detls,
|
int stn_no,UserBean user, CommonMethod commonMethod) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
String io_time = DateTimeUtil.getStringDateTime(19);
|
String mat_no = "";
|
//插入workDetail
|
int wrk_no = commonMethod.getNewWorkNo(workNoDao.getWorkNoById(1));
|
if(wrk_no<=0) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号失败，请联系管理员");
|
return map;
|
}else {
|
WorkMastBean workFile = workFileDao.getWorkMastById(wrk_no);
|
if(workFile!=null) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
|
return map;
|
}
|
}
|
// int qty=0;
|
//插入workDetail
|
if(detls!=null) {
|
for(String str : detls) {
|
String[] arr = str.split(";");
|
if(arr!=null && arr.length>1) {
|
if(!loc_no.equals(arr[0])) {
|
continue;
|
}
|
mat_no = arr[1];
|
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(wrk_no);
|
workDetl.setMat_no(mat_no);
|
workDetl.setIo_time(io_time);
|
// workDetl.setQty(retrieve_qty);
|
workDetl.setModi_user(user.getUser_account());
|
int result=workFileDao.insertWorkDetail(workDetl);
|
|
if(result>0) {
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
// qty = qty + retrieve_qty;
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无入库明细数据");
|
return map;
|
}
|
|
WorkMastBean workMast = new WorkMastBean();
|
int crn_no = Integer.parseInt(loc_no.substring(0,2));
|
crn_no = (crn_no + 1) / 2;
|
String loc_sts="";
|
// int stk_qty = locDetailDao.getStockQtyByLoc(loc_no);
|
|
int s_staNo = commonMethod.getIoStaNo(101,crn_no,stn_no);
|
if(s_staNo<=0) {
|
map.put("code", 1);
|
map.put("msg", "获取堆垛机站点失败");
|
return map;
|
}
|
workMast.setSource_sta_no(s_staNo);
|
workMast.setSta_no(stn_no);
|
workMast.setIo_type(101);
|
workMast.setPicking("N");
|
loc_sts = "R";
|
|
workMast.setWrk_no(wrk_no);
|
workMast.setIo_time(io_time);
|
workMast.setWrk_sts(11);
|
|
WaitPakOutBean waitPakOutBean = waitPakOutService.queryWaitPakOutByMatNo(mat_no);
|
if(waitPakOutBean!=null) {
|
workMast.setIo_pri(waitPakOutBean.getCtns());
|
}
|
// workMast.setIo_pri(13);
|
workMast.setCrn_no(crn_no);
|
workMast.setSource_loc_no(loc_no);
|
workMast.setFull_plt("Y");
|
workMast.setExit_mk("N");
|
workMast.setEmpty_mk("N");
|
workMast.setLink_mis("N");
|
workMast.setModi_user(user.getUser_account());
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean location = locationDao.getLocationById(loc_no);
|
if(location!=null) {
|
if(location.getLoc_sts().equals("L")) {
|
location.setLoc_sts(loc_sts);
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result>0) {
|
//更新待出库档
|
// WaitPakOutBean waitPakOutBean = waitPakOutDao.getWaitPakOutByMatNo(mat_no);
|
if(waitPakOutBean!=null) {
|
waitPakOutBean.setIo_status("2");
|
waitPakOutBean.setModi_time(io_time);
|
result=waitPakOutDao.upWaitPakOutByLocNo(waitPakOutBean);
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + loc_no);
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + loc_no);
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "");
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 手持端入库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertApiStoreIn(WorkMastBean workMast,String barcode,
|
StationBean station,UserBean user) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
//插入workDetail
|
MatCodeBean matCode = matCodeDao.getMatCodeByBarcode(barcode);
|
if(matCode!=null) {
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(workMast.getWrk_no());
|
workDetl.setMat_no(matCode.getMat_no());
|
workDetl.setIo_time(workMast.getIo_time());
|
workDetl.setModi_user(user.getUser_account());
|
int result=0;
|
result = workFileDao.insertWorkDetail(workDetl);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "条码数据为空");
|
return map;
|
}
|
|
// List<WaitPakInBean> list = waitPakInDao.getApiWaitPakInList(barcode);
|
// if(list!=null && list.size()>0) {
|
// for(WaitPakInBean pak : list) {
|
// WorkDetailBean workDetl = new WorkDetailBean();
|
// workDetl.setWrk_no(workMast.getWrk_no());
|
// workDetl.setMat_no(pak.getMat_no());
|
// workDetl.setIo_time(workMast.getIo_time());
|
// workDetl.setModi_user(user.getUser_account());
|
// workDetl.setQty(pak.getQty());
|
// int result=0;
|
// result = workFileDao.insertWorkDetail(workDetl);
|
//
|
// if(result>0) {
|
// pak.setIn_qty(pak.getQty());
|
// result = waitPakInDao.upWaitPakIn(pak);
|
// }else {
|
// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
// map.put("code", 1);
|
// map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
// return map;
|
// }
|
// }
|
// }else {
|
// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
// map.put("code", 1);
|
// map.put("msg", "条码数据为空");
|
// return map;
|
// }
|
|
//插入workMast
|
workMast.setBarcode(barcode);
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
station.setWrk_no(workMast.getWrk_no());
|
station.setIn_enable(station.getIn_enable());
|
station.setOut_enable(station.getOut_enable());
|
station.setBarcode(station.getBarcode());
|
station.setDec_desc(station.getDec_desc());
|
station.setModi_user(user.getUser_account());
|
result = stationDao.upStation(station);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "更新设备档失败:" + station.getDev_no());
|
return map;
|
}
|
|
LocationBean location = locationDao.getLocationById(workMast.getLoc_no());
|
if(location!=null) {
|
if(location.getLoc_sts().equals("O")) {
|
location.setLoc_sts("S");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + workMast.getLoc_no());
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + workMast.getLoc_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "库位号：" + workMast.getLoc_no());
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动入库失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
/**
|
* 手持端出库作业
|
*/
|
@Transactional
|
public Map<String,Object> insertApiPakRetrieve(String loc_no,
|
int stn_no,UserBean user, CommonMethod commonMethod, String barcode) throws Exception{
|
Map<String,Object> map=new HashMap<String, Object>();
|
try {
|
String io_time = DateTimeUtil.getStringDateTime(19);
|
//插入workDetail
|
int wrk_no = commonMethod.getNewWorkNo(workNoDao.getWorkNoById(1));
|
if(wrk_no<=0) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号失败，请联系管理员");
|
return map;
|
}else {
|
WorkMastBean workFile = workFileDao.getWorkMastById(wrk_no);
|
if(workFile!=null) {
|
map.put("code", 1);
|
map.put("msg", "生成工作号" + wrk_no + "在工作档中已存在");
|
return map;
|
}
|
}
|
|
//插入workDetail
|
List<LocDetailBean> list = locDetailDao.getLocDetlByLoc(loc_no);
|
if(list!=null && list.size()>0) {
|
for(LocDetailBean detl : list) {
|
WorkDetailBean workDetl = new WorkDetailBean();
|
workDetl.setWrk_no(wrk_no);
|
workDetl.setMat_no(detl.getMat_no());
|
workDetl.setIo_time(io_time);
|
workDetl.setQty(detl.getQty());
|
workDetl.setModi_user(user.getUser_account());
|
int result=workFileDao.insertWorkDetail(workDetl);
|
|
if(result>0) {
|
// WaitPakOutBean waitPakOut = new WaitPakOutBean();
|
// int random = (int)(Math.random()*900 + 100);
|
// waitPakOut.setSheet_no(DateTimeUtil.getStringDateTime(14)+Integer.toString(random));
|
// waitPakOut.setMat_no(detl.getMat_no());
|
// waitPakOut.setQty(detl.getQty());
|
// waitPakOut.setOut_qty(detl.getQty());
|
// waitPakOut.setStatus("Y");
|
// waitPakOut.setIo_status("Y");
|
// waitPakOut.setType("ASRS");
|
// waitPakOut.setModi_user(user.getUser_account());
|
// result = waitPakOutDao.insertWaitPakOut(waitPakOut);
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作明细档失败:" + workDetl.getMat_no());
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "无库存明细数据");
|
return map;
|
}
|
|
WorkMastBean workMast = new WorkMastBean();
|
int crn_no = Integer.parseInt(loc_no.substring(0,2));
|
crn_no = (crn_no+1) / 2 ;
|
int s_staNo = commonMethod.getIoStaNo(101,crn_no,stn_no);
|
if(s_staNo<=0) {
|
map.put("code", 1);
|
map.put("msg", "获取堆垛机站点失败");
|
return map;
|
}
|
workMast.setSource_sta_no(s_staNo);
|
workMast.setSta_no(stn_no);
|
workMast.setIo_type(101);
|
workMast.setPicking("N");
|
workMast.setWrk_no(wrk_no);
|
workMast.setIo_time(io_time);
|
workMast.setWrk_sts(11);
|
workMast.setIo_pri(13);
|
workMast.setCrn_no(crn_no);
|
workMast.setSource_loc_no(loc_no);
|
workMast.setFull_plt("Y");
|
workMast.setExit_mk("N");
|
workMast.setEmpty_mk("N");
|
workMast.setLink_mis("N");
|
workMast.setModi_user(user.getUser_account());
|
if(barcode!=null && !barcode.equals("")) {
|
workMast.setBarcode(barcode);
|
}
|
//插入workMast
|
int result = workFileDao.insertWorkMast(workMast);
|
if(result>0) {
|
LocationBean location = locationDao.getLocationById(loc_no);
|
if(location!=null) {
|
if(location.getLoc_sts().equals("F")) {
|
location.setLoc_sts("R");
|
location.setModi_user(user.getUser_account());
|
result = locationDao.upLocation(location);
|
if(result<=0) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败:" + loc_no);
|
return map;
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "预约库位状态失败,库位号不存在:" + loc_no);
|
return map;
|
}
|
}
|
}else {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
map.put("code", 1);
|
map.put("msg", "插入工作主档失败");
|
return map;
|
}
|
map.put("code", 0);
|
map.put("msg", "");
|
return map;
|
}catch(Exception e) {
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
System.out.println(e.getMessage());
|
map.put("code", 1);
|
map.put("msg", "启动失败--" + e.getMessage());
|
}
|
return map;
|
}
|
|
}
|
