package com.mandi.fendan.controller;
|
|
import java.io.BufferedReader;
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
import javax.servlet.ServletInputStream;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import com.fasterxml.jackson.databind.JavaType;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.mandi.fendan.persist.FdMxWlgs;
|
import com.mandi.springmvc.logs.OpLogs;
|
import com.mandi.system.persist.ModuleEnum;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.log4j.Logger;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import com.google.gson.JsonArray;
|
import com.google.gson.JsonElement;
|
import com.google.gson.JsonObject;
|
import com.google.gson.JsonParser;
|
import com.mandi.common.JSONobj;
|
import com.mandi.common.Jacksonmethod;
|
import com.mandi.common.RequestParam;
|
import com.mandi.common.SessionMethod;
|
import com.mandi.dao.common.ObjectResult;
|
import com.mandi.dao.common.PageRequest;
|
import com.mandi.dao.common.PageResult;
|
import com.mandi.dao.common.Sort;
|
import com.mandi.fendan.service.IErpService;
|
import com.mandi.fendan.service.Ifd_bsheetService;
|
import com.mandi.fendan.service.Ifd_vehicleService;
|
import com.mandi.system.persist.Login;
|
|
@Controller("fd_businesscon")
|
@RequestMapping(value="/business",method={RequestMethod.POST})
|
public class Fd_businessCon {
|
Logger log = Logger.getLogger(Fd_businessCon.class);
|
|
@Resource
|
private IErpService erpser;
|
@Resource
|
private Ifd_bsheetService bsser;
|
@Resource
|
private Ifd_vehicleService fdvser;
|
|
/**
|
* 获取已分配的销售提单
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/getList.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String getXSTDList(HttpServletRequest r,HttpServletResponse re){
|
//tdbh--提单编号,khmc--客户,shdd--收货地点,zdbm--制单部门,zdr--制单人
|
String type=RequestParam.getSqlString(r, "type");
|
String keyword=RequestParam.getSqlString(r, "keyword");
|
String companyNo=RequestParam.getSqlString(r, "companyNo");
|
String sort=RequestParam.getString(r, "sort");
|
int wcSign=RequestParam.getInt(r, "wcSign");
|
// [{name, value: asc/desc}] tdbh--提单编,khmc--客户名称,shdd--收货地点,wfds--未分单数,wfdl--未分单量,
|
// shsj--审核时间,zdbm--制单部门,zdr--制单人,ywrq--业务日期,tdlx--提单类型
|
int page=RequestParam.getInt(r, "page");
|
int pagesize=RequestParam.getInt(r, "pagesize");
|
int pages=RequestParam.getInt(r, "pages");
|
Date sdate=RequestParam.getDate(r, "sdate");
|
Date edate=RequestParam.getDate(r, "edate");
|
String cqV=RequestParam.getSqlString(r, "cqV");//厂区
|
Login lg=SessionMethod.getlogin(r.getSession());
|
PageRequest pr=new PageRequest(page, pagesize, null);
|
if(pages>0)
|
pr.setNeedPages(true);
|
else
|
pr.setNeedPages(false);
|
List<String> sortc=new ArrayList<String>();
|
String sortStr="";
|
if(!StringUtils.isEmpty(sort)){
|
Sort st=new Sort();
|
JsonParser jp=new JsonParser();
|
JsonElement je=jp.parse(sort);
|
if(je!=null&&je.isJsonArray()){
|
JsonArray ja=je.getAsJsonArray();
|
// Map<String, String> sortmp=SortMap.getXSTDsortMap();
|
for (JsonElement je1 : ja) {
|
JsonObject jo=je1.getAsJsonObject();
|
if(jo!=null){
|
String name=JSONobj.getstring(jo, "name");
|
String value=JSONobj.getstring(jo, "value");
|
if(StringUtils.isEmpty(sortStr)){
|
sortStr+=(" "+name+" "+value);
|
}else{
|
sortStr+=(","+name+" "+value);
|
}
|
}
|
}
|
}
|
if(!StringUtils.isEmpty(st.toString())){
|
pr.setSort(st);
|
}
|
}
|
if(!StringUtils.isEmpty(sortStr)){
|
sortStr+=" ";
|
}
|
String str="";
|
if(wcSign==2){//已关闭销售提单
|
PageResult<Map<String, Object>> prrc=erpser.getCloseXSTDlist(lg,type,keyword, companyNo, sdate, edate,wcSign, pr,sortc);
|
str=Jacksonmethod.tojson(prrc, false);
|
}else{
|
PageResult<Map<String, Object>> prr=erpser.getXSTDList(lg,type,keyword, companyNo, sdate, edate,wcSign,null, pr,sortStr,cqV);
|
str=Jacksonmethod.tojson(prr, false);
|
}
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
/***
|
* 改变明细的物流公司
|
* @return
|
*/
|
@OpLogs(module = ModuleEnum.业务模块, name = "更改提单的物流公司")
|
@RequestMapping(value="/changeWlgs.htm",method= RequestMethod.POST,consumes = "application/json")
|
@ResponseBody
|
public String changeCompany(HttpServletRequest request, HttpServletResponse response){ // json 解析
|
PageResult<Map<String, Object>> prr = new PageResult<Map<String, Object>>();
|
// 开始解析JSON，接收的类型为List<FdMxWlgs>;主要为了解决这个框架使用@RequestBody时415问题
|
StringBuilder sb = new StringBuilder();
|
try(BufferedReader br = new BufferedReader(new InputStreamReader(request.getInputStream(),"utf-8"))) {
|
String line = null;
|
while ((line = br.readLine()) != null) {
|
sb.append(line);
|
}
|
} catch (IOException e) { e.printStackTrace(); }
|
ObjectMapper objectMapper =new ObjectMapper();
|
List<FdMxWlgs> fdMxWlgsList = null;
|
try {
|
JavaType javaType = objectMapper.getTypeFactory().constructParametricType(ArrayList.class, FdMxWlgs.class);
|
fdMxWlgsList = objectMapper.readValue(sb.toString(), javaType);
|
} catch (IOException e) {
|
prr.setCode(1);
|
prr.setErrmsg(e.getMessage());
|
SessionMethod.writeresp(response, Jacksonmethod.tojson(prr, false));
|
return null;
|
}
|
// 解析JSON结束
|
log.info("更改提单的物流公司：" + sb.toString());
|
try {
|
erpser.changeMxWlgs(fdMxWlgsList);
|
prr.setCode(0);
|
} catch (Exception e) {
|
log.error(e.getMessage(),e);
|
prr.setCode(1);
|
prr.setErrmsg(e.getMessage());
|
}
|
SessionMethod.writeresp(response, Jacksonmethod.tojson(prr, false));
|
return null;
|
}
|
/***
|
* 提单列表
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/billofLadingList.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String billofLadingList(HttpServletRequest r,HttpServletResponse re){
|
//tdbh--提单编号,khmc--客户,shdd--收货地点,zdbm--制单部门,zdr--制单人
|
String type=RequestParam.getSqlString(r, "type");
|
String keyword=RequestParam.getSqlString(r, "keyword");
|
// String companyNo=RequestParam.getSqlString(r, "companyNo");
|
String companyNo = ""; // 不要限定公司
|
String sort=RequestParam.getString(r, "sort");
|
int wcSign=RequestParam.getInt(r, "wcSign");
|
// [{name, value: asc/desc}] tdbh--提单编,khmc--客户名称,shdd--收货地点,wfds--未分单数,wfdl--未分单量,
|
// shsj--审核时间,zdbm--制单部门,zdr--制单人,ywrq--业务日期,tdlx--提单类型
|
int page=RequestParam.getInt(r, "page");
|
int pagesize=RequestParam.getInt(r, "pagesize");
|
int pages=RequestParam.getInt(r, "pages");
|
Date sdate=RequestParam.getDate(r, "sdate");
|
Date edate=RequestParam.getDate(r, "edate");
|
String cqV=RequestParam.getSqlString(r, "cqV");//厂区
|
Login lg=SessionMethod.getlogin(r.getSession());
|
PageRequest pr=new PageRequest(page, pagesize, null);
|
if(pages>0)
|
pr.setNeedPages(true);
|
else
|
pr.setNeedPages(false);
|
List<String> sortc=new ArrayList<String>();
|
String sortStr="";
|
if(!StringUtils.isEmpty(sort)){
|
Sort st=new Sort();
|
JsonParser jp=new JsonParser();
|
JsonElement je=jp.parse(sort);
|
if(je!=null&&je.isJsonArray()){
|
JsonArray ja=je.getAsJsonArray();
|
// Map<String, String> sortmp=SortMap.getXSTDsortMap();
|
for (JsonElement je1 : ja) {
|
JsonObject jo=je1.getAsJsonObject();
|
if(jo!=null){
|
String name=JSONobj.getstring(jo, "name");
|
String value=JSONobj.getstring(jo, "value");
|
if(StringUtils.isEmpty(sortStr)){
|
sortStr+=(" "+name+" "+value);
|
}else{
|
sortStr+=(","+name+" "+value);
|
}
|
}
|
}
|
}
|
if(!StringUtils.isEmpty(st.toString())){
|
pr.setSort(st);
|
}
|
}
|
if(!StringUtils.isEmpty(sortStr)){
|
sortStr+=" ";
|
}
|
String str="";
|
PageResult<Map<String, Object>> prr=erpser.getXSTDList(lg,type,keyword, companyNo, sdate, edate,wcSign,"fdAdmin" ,pr,sortStr,cqV);
|
str=Jacksonmethod.tojson(prr, false);
|
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
|
/**
|
*获取全部公司可用车
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/getVehicleList.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String getVehicleList(HttpServletRequest r,HttpServletResponse re){
|
String companyNo=RequestParam.getSqlString(r, "companyNo");
|
String vehicleId=RequestParam.getSqlString(r, "vehicleId");
|
Login lg=SessionMethod.getlogin(r.getSession());
|
PageResult<Map<String, Object>> prr=fdvser.getalllist(lg,companyNo,vehicleId);
|
String str=Jacksonmethod.tojson(prr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
/**
|
*验证临时车车牌号
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/validVehicle.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String validVehicle(HttpServletRequest r,HttpServletResponse re){
|
String vehicleId=RequestParam.getSqlString(r, "vehicleId");
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Boolean> orr=fdvser.validVehicle(lg, vehicleId);
|
String str=Jacksonmethod.tojson(orr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
/**
|
*获取单个销售提单信息
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/getItem.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String getItem(HttpServletRequest r,HttpServletResponse re){
|
String XSTD=RequestParam.getSqlString(r, "keyword");
|
Login lg=SessionMethod.getlogin(r.getSession());
|
Map<String, Object> mp=erpser.getXSTD(lg, XSTD);
|
String str=Jacksonmethod.tojson(mp, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
/**
|
*获取提单列表进入的单个销售提单信息
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/getBillofLadingItem.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String getBillofLadingItem(HttpServletRequest r,HttpServletResponse re) {
|
String XSTD=RequestParam.getSqlString(r, "keyword");
|
Login lg=SessionMethod.getlogin(r.getSession());
|
Map<String, Object> mp = erpser.getBillofLadingXSTD(lg, XSTD);
|
String str=Jacksonmethod.tojson(mp, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
/**
|
* 按单配车：拼单
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/doBindByList.htm",method={RequestMethod.POST})
|
@ResponseBody
|
@OpLogs(name="整单配车",module = ModuleEnum.业务模块)
|
public String doBindByList(HttpServletRequest r,HttpServletResponse re){
|
String list=RequestParam.getString(r, "list");
|
String vehicle=RequestParam.getString(r, "vehicle");
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
try {
|
orr = erpser.doBindByList(lg, list, vehicle);
|
} catch (Exception e) {
|
e.printStackTrace();
|
orr.setCode(1);
|
orr.setErrmsg(StringUtils.isEmpty(e.getMessage())?"配车程序出错！":e.getMessage());
|
}
|
String str=Jacksonmethod.tojson(orr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
/**
|
* 按车配单取消
|
* @param r
|
* @param re
|
* @return
|
*/
|
@OpLogs(name="整单取消配车",module = ModuleEnum.业务模块)
|
@RequestMapping(value="/doUnbindByList.htm",method={RequestMethod.POST})
|
@ResponseBody
|
public String doUnbindByList(HttpServletRequest r,HttpServletResponse re){
|
String tdbhlist=RequestParam.getString(r, "list");//[TD-0040130, TD-0040132,...]
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
try {
|
orr = erpser.dounBindByList(lg, tdbhlist);
|
} catch (Exception e) {
|
e.printStackTrace();
|
orr.setCode(1);
|
orr.setErrmsg(StringUtils.isEmpty(e.getMessage())?"配车取消程序出错！":e.getMessage());
|
}
|
String str=Jacksonmethod.tojson(orr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
/**
|
* 取消分单
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/doUnbind.htm",method={RequestMethod.POST})
|
@ResponseBody
|
@OpLogs(name="明细取消配车", module = ModuleEnum.业务模块)
|
public String doUnbind(HttpServletRequest r,HttpServletResponse re){
|
String list=RequestParam.getString(r, "list");//[{"tdls":,"tdfl":}]
|
String tdbh=RequestParam.getSqlString(r, "tdbh");//提单编号
|
// String cph=RequestParam.getSqlString(r, "vehicle");//车牌号
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
try {
|
orr = erpser.doUnbind(lg, list,tdbh);
|
} catch (Exception e) {
|
e.printStackTrace();
|
orr.setCode(1);
|
orr.setErrmsg(StringUtils.isEmpty(e.getMessage())?"取消分单操作失败！":e.getMessage());
|
}
|
String str=Jacksonmethod.tojson(orr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
/**
|
* 分单
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/doBind.htm",method={RequestMethod.POST})
|
@ResponseBody
|
@OpLogs(name="分单配车",module = ModuleEnum.业务模块)
|
public String doBind(HttpServletRequest r,HttpServletResponse re){
|
String list=RequestParam.getString(r, "list");//[{"tdls":,"tdfl":}]
|
String vehicle=RequestParam.getString(r, "vehicle");//[{"tdls":,"tdfl":}]
|
String xstdNo=RequestParam.getSqlString(r, "tdbh");//[{"tdls":,"tdfl":}]
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Map<String, Object>> orr=new ObjectResult<Map<String, Object>>();
|
try {
|
orr=bsser.saveFd_Bsheet(vehicle, xstdNo, list, lg);
|
} catch (Exception e) {
|
e.printStackTrace();
|
orr.setCode(1);
|
orr.setErrmsg(StringUtils.isEmpty(e.getMessage())?"业务单保存出错！":e.getMessage());
|
}
|
String str="";
|
if(orr.getCode()!=0){
|
str=Jacksonmethod.tojson(orr, false);
|
}else{
|
str=Jacksonmethod.tojson(orr, false);
|
}
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
|
/**
|
* 关闭分单
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/closexstd.htm",method={RequestMethod.POST})
|
@ResponseBody
|
@OpLogs(name="关闭分单",module = ModuleEnum.业务模块)
|
public String closeXstd(HttpServletRequest r,HttpServletResponse re){
|
String vehicleId=RequestParam.getSqlString(r, "vehicleId")==null?"":RequestParam.getSqlString(r, "vehicleId").trim();
|
String driver=RequestParam.getSqlString(r, "driver")==null?"":RequestParam.getSqlString(r, "driver").trim();
|
String phone=RequestParam.getSqlString(r, "phone")==null?"":RequestParam.getSqlString(r, "phone").trim();
|
String xstdNo=RequestParam.getSqlString(r, "tdNo")==null?"":RequestParam.getSqlString(r, "tdNo").trim();//提单编号
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
try {
|
orr = erpser.closeXstd(vehicleId,driver,phone,xstdNo, lg);
|
} catch (Exception e) {
|
e.printStackTrace();
|
orr.setCode(1);
|
orr.setErrmsg(StringUtils.isEmpty(e.getMessage())?"关闭分单程序出错！":e.getMessage());
|
}
|
String str=Jacksonmethod.tojson(orr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
/**
|
* 打开分单
|
* @param r
|
* @param re
|
* @return
|
*/
|
@RequestMapping(value="/openxstd.htm",method={RequestMethod.POST})
|
@ResponseBody
|
@OpLogs(name="打开分单",module = ModuleEnum.业务模块)
|
public String openXSTD(HttpServletRequest r,HttpServletResponse re){
|
String xstdNo=RequestParam.getSqlString(r, "tdNo");//提单编号
|
Login lg=SessionMethod.getlogin(r.getSession());
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
try {
|
orr = erpser.openXstd(xstdNo, lg);
|
} catch (Exception e) {
|
e.printStackTrace();
|
orr.setCode(1);
|
orr.setErrmsg(StringUtils.isEmpty(e.getMessage())?"恢复分单程序出错！":e.getMessage());
|
}
|
String str=Jacksonmethod.tojson(orr, false);
|
SessionMethod.writeresp(re, str);
|
return null;
|
}
|
}
|
