318 lines
9.7 KiB
Plaintext
318 lines
9.7 KiB
Plaintext
package com.bonus.ma.controller;
|
|
|
|
import java.io.BufferedInputStream;
|
|
import java.io.File;
|
|
import java.io.FileInputStream;
|
|
import java.io.IOException;
|
|
import java.io.OutputStream;
|
|
import java.math.BigDecimal;
|
|
import java.net.URLEncoder;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletResponse;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Controller;
|
|
import org.springframework.ui.Model;
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import org.springframework.web.bind.annotation.RequestMethod;
|
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
|
|
import com.bonus.bm.beans.LogBean;
|
|
import com.bonus.bm.dao.LogDao;
|
|
import com.bonus.core.DateTimeHelper;
|
|
import com.bonus.ma.beans.LibNumsInventoryBean;
|
|
import com.bonus.ma.beans.MachineTypeBean;
|
|
import com.bonus.ma.service.LibNumsInventoryService;
|
|
import com.bonus.ma.service.MachineTypeService;
|
|
import com.bonus.sys.AjaxRes;
|
|
import com.bonus.sys.BaseController;
|
|
import com.bonus.sys.GlobalConst;
|
|
import com.bonus.sys.Page;
|
|
import com.bonus.sys.UserShiroHelper;
|
|
import com.bonus.sys.beans.UserBean;
|
|
|
|
import sun.misc.BASE64Encoder;
|
|
|
|
@Controller
|
|
@RequestMapping("/backstage/inventory/")
|
|
public class LibNumsInventoryController extends BaseController<LibNumsInventoryBean> {
|
|
|
|
@Autowired
|
|
private LibNumsInventoryService service;
|
|
|
|
@Autowired
|
|
private MachineTypeService mtservice;
|
|
|
|
@Autowired
|
|
LogDao logDao;
|
|
@RequestMapping("list")
|
|
public String index(Model model) {
|
|
return "/ma/libNumsInventorylist";
|
|
}
|
|
|
|
@RequestMapping(value = "findByPage", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes findByPage(Page<LibNumsInventoryBean> page, LibNumsInventoryBean o) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
UserBean user = UserShiroHelper.getRealCurrentUser();
|
|
String companyId = user.getCompanyId();
|
|
o.setOrgId(companyId);
|
|
Page<LibNumsInventoryBean> result = service.findByPage(o, page);
|
|
Map<String, Object> p = new HashMap<String, Object>();
|
|
p.put("list", result);
|
|
ar.setSucceed(p);
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.DATA_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
@RequestMapping(value = "find", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes find(LibNumsInventoryBean o) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
List<LibNumsInventoryBean> list = service.find(o);
|
|
LibNumsInventoryBean station = list.get(0);
|
|
ar.setSucceed(station);
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.DATA_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
@RequestMapping(value = "update", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes update(LibNumsInventoryBean o) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
service.update(o);
|
|
ar.setSucceedMsg(GlobalConst.UPDATE_SUCCEED);
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.UPDATE_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
@RequestMapping(value = "addLibs", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes addLibs(LibNumsInventoryBean o, HttpServletRequest request) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
String num = "";
|
|
String isCount = "";
|
|
String inNums = o.getInNums();
|
|
String maModelId = o.getMaModelId();
|
|
MachineTypeBean mt = new MachineTypeBean();
|
|
mt.setId(maModelId);
|
|
List<MachineTypeBean> list = mtservice.find(mt);
|
|
if (list.size() > 0) {
|
|
String num1 = list.get(0).getNums();
|
|
if(num1 == null){
|
|
num = "0";
|
|
}else{
|
|
num = num1;
|
|
}
|
|
isCount = list.get(0).getIsCount();
|
|
}
|
|
if ("0".equals(isCount)) {
|
|
ar.setFailMsg("该设备不可计数盘点入库！");
|
|
} else {
|
|
//添加日志
|
|
LogBean logBean= new LogBean();
|
|
logBean.setModel("盘点库存-盘赢");
|
|
logBean.setFun("addLibs");
|
|
logBean.setTask(o.getId());
|
|
logBean.setTypeId(maModelId);
|
|
LogBean inBean=logDao.findInNum(logBean);
|
|
String description="在库数:"+inBean.getInNum()+";盘赢数:"+inNums;
|
|
logBean.setDescription(description);
|
|
String time = DateTimeHelper.currentDateTime();
|
|
logBean.setTime(time);
|
|
String userId = UserShiroHelper.getRealCurrentUser().getId()+"";
|
|
logBean.setCreator(userId);
|
|
logDao.insertLog(logBean);
|
|
|
|
LogBean total = logDao.findTotalNum(logBean);
|
|
float num1 = Float.parseFloat(total.getTotal());
|
|
float num2 = Float.parseFloat(inNums);
|
|
float num3 = num1+num2;
|
|
String description2 =total.getTotal()+"=>"+num3;
|
|
total.setTask(o.getId());
|
|
total.setTaskCode("盘点库存-盘赢");
|
|
total.setCreator(userId);
|
|
total.setTime(time);
|
|
total.setDescription(description2);
|
|
logDao.insertTotalLog(total);
|
|
|
|
|
|
addLibsNums(inNums, num, maModelId, request);
|
|
String createTime = DateTimeHelper.getNowTime();
|
|
o.setCreateTime(createTime);
|
|
service.update(o);
|
|
ar.setSucceedMsg(GlobalConst.UPDATE_SUCCEED);
|
|
}
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.UPDATE_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
private synchronized void addLibsNums(String inNums, String num, String maModelId,
|
|
HttpServletRequest request) {
|
|
BigDecimal bd1 = new BigDecimal(num);
|
|
BigDecimal bd2 = new BigDecimal(inNums);
|
|
Float lib = bd1.add(bd2).setScale(3,BigDecimal.ROUND_HALF_UP).floatValue();
|
|
MachineTypeBean bean = new MachineTypeBean();
|
|
bean.setId(maModelId);
|
|
bean.setNums(lib + "");
|
|
mtservice.update(bean);
|
|
}
|
|
|
|
@RequestMapping(value = "minusLibs", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes minusLibs(LibNumsInventoryBean o) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
String num = "";
|
|
String isCount = "";
|
|
String inNums = o.getInNums();
|
|
String maModelId = o.getMaModelId();
|
|
MachineTypeBean mt = new MachineTypeBean();
|
|
mt.setId(maModelId);
|
|
List<MachineTypeBean> list = mtservice.find(mt);
|
|
if (list.size() > 0) {
|
|
num = list.get(0).getNums();
|
|
isCount = list.get(0).getIsCount();
|
|
}
|
|
if ("0".equals(isCount)) {
|
|
ar.setFailMsg("该设备不可计数盘点入库！");
|
|
} else {
|
|
//添加日志
|
|
LogBean logBean= new LogBean();
|
|
logBean.setModel("盘点库存-盘亏");
|
|
logBean.setFun("minusLibs");
|
|
logBean.setTask(o.getId());
|
|
logBean.setTypeId(maModelId);
|
|
LogBean inBean=logDao.findInNum(logBean);
|
|
String description="在库数:"+inBean.getInNum()+";盘亏数:"+inNums;
|
|
logBean.setDescription(description);
|
|
String time = DateTimeHelper.currentDateTime();
|
|
logBean.setTime(time);
|
|
String userId = UserShiroHelper.getRealCurrentUser().getId()+"";
|
|
logBean.setCreator(userId);
|
|
logDao.insertLog(logBean);
|
|
|
|
LogBean total = logDao.findTotalNum(logBean);
|
|
float num1 = Float.parseFloat(total.getTotal());
|
|
float num2 = Float.parseFloat(inNums);
|
|
float num3 = num1-num2;
|
|
String description2 =total.getTotal()+"=>"+num3;
|
|
total.setTask(o.getId());
|
|
total.setTaskCode("盘点库存-盘亏");
|
|
total.setCreator(userId);
|
|
total.setTime(time);
|
|
total.setDescription(description2);
|
|
logDao.insertTotalLog(total);
|
|
|
|
addMinusNums(inNums, num, maModelId);
|
|
String createTime = DateTimeHelper.getNowTime();
|
|
o.setCreateTime(createTime);
|
|
service.update(o);
|
|
ar.setSucceedMsg(GlobalConst.UPDATE_SUCCEED);
|
|
}
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.UPDATE_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
private synchronized void addMinusNums(String inNums, String num, String maModelId) {
|
|
Float lib = Float.parseFloat(num) - Float.parseFloat(inNums);
|
|
MachineTypeBean bean = new MachineTypeBean();
|
|
bean.setId(maModelId);
|
|
bean.setNums(lib + "");
|
|
mtservice.update(bean);
|
|
}
|
|
|
|
@RequestMapping(value = "add", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes add(LibNumsInventoryBean o) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
String maModelId = o.getMaModelName();
|
|
o.setMaModelId(maModelId);
|
|
UserBean user = UserShiroHelper.getRealCurrentUser();
|
|
String companyId = user.getCompanyId();
|
|
o.setOrgId(companyId);
|
|
String isExist = service.findByModelId(o);
|
|
if (isExist == null) {
|
|
service.insert(o);
|
|
ar.setSucceedMsg(GlobalConst.SAVE_SUCCEED);
|
|
} else {
|
|
ar.setSucceedMsg("该类型机具已存在，请勿重复添加！");
|
|
}
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.SAVE_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
@RequestMapping(value = "del", method = RequestMethod.POST)
|
|
@ResponseBody
|
|
public AjaxRes del(LibNumsInventoryBean o) {
|
|
AjaxRes ar = getAjaxRes();
|
|
try {
|
|
service.delete(o);
|
|
ar.setSucceedMsg(GlobalConst.DEL_SUCCEED);
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
ar.setFailMsg(GlobalConst.DEL_FAIL);
|
|
}
|
|
return ar;
|
|
}
|
|
|
|
@RequestMapping(value = "/readDoc")
|
|
@ResponseBody
|
|
public String previewResources1(HttpServletRequest request, HttpServletResponse response,String path) {
|
|
String dataString=null;
|
|
try {
|
|
|
|
File file = new File(request.getSession().getServletContext().getRealPath("/")+path);
|
|
|
|
FileInputStream fis = new FileInputStream(file);
|
|
BufferedInputStream br = new BufferedInputStream(fis);
|
|
response.setHeader("Content-Disposition",
|
|
"inline; filename=" + URLEncoder.encode("aaa", "UTF-8"));
|
|
OutputStream out = response.getOutputStream();
|
|
byte[] buf = new byte[1024];
|
|
int len = 0;
|
|
while ((len = br.read(buf)) != -1)
|
|
out.write(buf, 0, len);
|
|
|
|
dataString= getImageString(buf);
|
|
br.close();
|
|
out.close();
|
|
} catch (Exception e) {
|
|
logger.error(e.toString(), e);
|
|
}
|
|
return dataString;
|
|
}
|
|
|
|
public static String getImageString(byte[] data) throws IOException {
|
|
BASE64Encoder encoder = new BASE64Encoder();
|
|
return data != null ? encoder.encode(data) : "";
|
|
}
|
|
}
|