package com.mandi.fendan.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
import javax.annotation.Resource;
|
import javax.transaction.Transactional;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Service;
|
|
import com.mandi.common.ParamFileter.RegexCheck;
|
import com.mandi.dao.common.Daomethod;
|
import com.mandi.dao.common.ObjectResult;
|
import com.mandi.dao.common.PageRequest;
|
import com.mandi.dao.common.PageResult;
|
import com.mandi.fendan.mapper.Fd_BsheetMapper;
|
import com.mandi.fendan.mapper.Fd_CompanyMapper;
|
import com.mandi.fendan.mapper.Fd_VehicleMapper;
|
import com.mandi.fendan.mapper.VehicleXSTDMapper;
|
import com.mandi.fendan.persist.Fd_Bsheet;
|
import com.mandi.fendan.persist.Fd_Company;
|
import com.mandi.fendan.persist.Fd_Vehicle;
|
import com.mandi.fendan.persist.VehicleStatus;
|
import com.mandi.fendan.persist.VehicleType;
|
import com.mandi.fendan.persist.Vehicle_XSTD;
|
import com.mandi.fendan.service.Ifd_vehicleService;
|
import com.mandi.fendan.util.persist.Serviceenum;
|
import com.mandi.system.persist.Login;
|
import com.mandi.system.persist.UserType;
|
@Service
|
public class Fd_VehicleService implements Ifd_vehicleService {
|
@Resource
|
private Fd_VehicleMapper Fd_Vcper;
|
@Resource
|
private Fd_CompanyMapper fdcper;
|
@Resource
|
private Fd_BsheetMapper fdbper;
|
@Resource
|
private VehicleXSTDMapper vxper;
|
|
|
@Override
|
public ObjectResult<Fd_Vehicle> getFd_VehicleById(String id) {
|
ObjectResult<Fd_Vehicle> prr = new ObjectResult<Fd_Vehicle>();
|
if(!StringUtils.isBlank(id)){
|
Fd_Vehicle fve = Fd_Vcper.get(id);
|
prr.setCode(0);
|
prr.setItem(fve);
|
}else{
|
prr.setCode(1);
|
prr.setErrmsg("查询值为空，不能查询！");;
|
}
|
|
return prr;
|
|
}
|
public ObjectResult<Fd_Vehicle> getFd_VehicleByFd_VehicleId(String vehicleId) {
|
ObjectResult<Fd_Vehicle> prr = new ObjectResult<Fd_Vehicle>();
|
if(!StringUtils.isBlank(vehicleId)){
|
Fd_Vehicle fcy = Fd_Vcper.getByVehicleId(vehicleId);
|
prr.setCode(0);
|
prr.setItem(fcy);
|
}else{
|
prr.setCode(1);
|
prr.setErrmsg("车牌号不能为空");;
|
}
|
|
return prr;
|
}
|
@Override
|
public PageResult<Map<String, Object>> getList(Map<String,Object> map,PageRequest pr) {
|
PageResult<Map<String, Object>> prr=new PageResult<Map<String, Object>>();
|
|
map.put("pagesize", pr.getPageSize());
|
map.put("page", pr.getStart());
|
map.put("type", VehicleType.公司车.toString());
|
List<Map<String, Object>> list;
|
if(pr.isNeedPages())
|
{
|
int pages=Fd_Vcper.getPages(map);
|
pages=Daomethod.countpages(pages, pr.getPageSize());
|
prr.setPages(pages);
|
list=Fd_Vcper.getList2(map);
|
}else{
|
list=Fd_Vcper.getList1(map);
|
prr.setPages(0);
|
}
|
|
prr.setCode(0);
|
prr.setList(list);
|
return prr;
|
}
|
|
@Override
|
public PageResult<Map<String, Object>> getalllist(Login lg,String companyNo,String vId) {
|
PageResult<Map<String, Object>> prr=new PageResult<Map<String, Object>>();
|
List<Map<String, Object>> ll=new ArrayList<Map<String,Object>>();
|
if(lg==null){
|
prr.setCode(1);
|
prr.setErrmsg("请登录账号！");
|
return prr;
|
}
|
String cmc=companyNo;
|
Map<String, Object> map=new HashMap<String, Object>();
|
if(StringUtils.isEmpty(companyNo)){
|
if(UserType.admin.toString().equals(lg.getWorkerno())){
|
map.put("companyNo","");
|
cmc="";
|
}else{
|
prr.setList(ll);
|
prr.setCode(0);
|
return prr;
|
}
|
}else{
|
map.put("companyNo",companyNo);
|
}
|
map.put("vehicleId",vId);
|
List<Map<String, Object>> clist=Fd_Vcper.getCompanyVehicle(map);
|
if(clist==null){
|
clist=new ArrayList<Map<String,Object>>();
|
}
|
List<Map<String, Object>> rlist=new ArrayList<Map<String,Object>>();
|
if(clist!=null){
|
List<Vehicle_XSTD> vxlist=vxper.getlistbycomNo(cmc);
|
for (Map<String, Object> map2 : clist) {
|
String vehicleId=map2.get("vehicleId")==null?"":map2.get("vehicleId").toString();
|
// List<Vehicle_XSTD> vxlist=vxper.getlistbyVehicleId(vehicleId);
|
if(vxlist!=null){
|
for (Vehicle_XSTD vehicle_XSTD2 : vxlist) {
|
try{
|
if(vehicle_XSTD2.getVehicleId().equals(vehicleId)){
|
map2.put("fdCnum", Integer.parseInt(map2.get("fdCnum")==null?"0":map2.get("fdCnum").toString())+vehicle_XSTD2.getFd_num());
|
map2.put("fdCweight", Double.parseDouble(map2.get("fdCweight")==null?"0":map2.get("fdCweight").toString())+vehicle_XSTD2.getFd_weight());
|
if(vehicle_XSTD2.getCompanyNo()!=null&&vehicle_XSTD2.getCompanyNo().equals(lg.getDepartno())){
|
map2.put("fdnum", Double.parseDouble(map2.get("fdnum")==null?"0":map2.get("fdnum").toString())+vehicle_XSTD2.getFd_weight());
|
map2.put("fdweight", Double.parseDouble(map2.get("fdweight")==null?"0":map2.get("fdweight").toString())+vehicle_XSTD2.getFd_weight());
|
}
|
}
|
} catch (Exception e) {
|
prr.setCode(1);
|
prr.setErrmsg("数据转换错误，请刷新页面重新获取数据！");
|
return prr;
|
}
|
}
|
}
|
rlist.add(map2);
|
}
|
}
|
prr.setCode(0);
|
prr.setList(rlist);
|
return prr;
|
}
|
|
@Override
|
public ObjectResult<Boolean> validVehicle(Login lg, String vehicleId) {
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
if(!StringUtils.isEmpty(vehicleId)){
|
boolean boo=RegexCheck.isVehicleID(vehicleId);
|
if(!boo){
|
orr.setCode(1);
|
orr.setErrmsg("车牌号验证不正确，请输入正确的车牌号！");
|
return orr;
|
}
|
}else{
|
orr.setCode(1);
|
orr.setErrmsg("参数车牌号为空，请输入！");
|
return orr;
|
}
|
orr.setCode(0);
|
return orr;
|
}
|
|
@Override
|
@Transactional(rollbackOn=Exception.class)
|
public ObjectResult<Fd_Vehicle> saveFd_Vehicle(Fd_Vehicle cq,Login lg) throws Exception {
|
ObjectResult<Fd_Vehicle> or = new ObjectResult<Fd_Vehicle>();
|
if(lg==null){
|
or.setCode(1);
|
or.setErrmsg("请登录账号！");
|
return or;
|
}
|
if(cq==null){
|
or.setCode(1);
|
or.setErrmsg("车辆对象为空，不能保存！");
|
}else{
|
if(StringUtils.isEmpty(cq.getVehicleId())||StringUtils.isEmpty(cq.getIDNum())||StringUtils.isEmpty(cq.getPhone())||StringUtils.isEmpty(cq.getDriver())){
|
or.setCode(1);
|
or.setErrmsg("必填项不能为空！");
|
return or;
|
}
|
String companyNo=cq.getCompanyNo();
|
Fd_Company fdc=fdcper.getByCompanyNo(companyNo);
|
if(fdc==null){
|
or.setCode(1);
|
or.setErrmsg("运输公司未找到，车辆信息不能保存，请选择正确的运输公司！");
|
return or;
|
}
|
if(StringUtils.isEmpty(cq.getVehicleId())){
|
or.setCode(1);
|
or.setErrmsg("车牌号不能为空，请修改后保存！");
|
return or;
|
}
|
boolean boo=RegexCheck.isVehicleID(cq.getVehicleId());
|
if(!boo){
|
or.setCode(1);
|
or.setErrmsg("车牌号不正确，请修改！");
|
return or;
|
}
|
Fd_Vehicle cc=Fd_Vcper.getByVehicleId(cq.getVehicleId());
|
if(cc!=null){
|
if(!cc.getId().equals(cq.getId())){
|
or.setCode(1);
|
or.setErrmsg("该车牌号已经存在，不能重复保存！");
|
return or;
|
}
|
}
|
|
// if(cq.getId()!=null){
|
Fd_Vehicle fd_Vehicle = Fd_Vcper.getByVehicleId(cq.getVehicleId());
|
if(fd_Vehicle==null){
|
cq.setId(UUID.randomUUID()+"");
|
cq.setState(true);
|
cq.setStatus(VehicleStatus.未配车);
|
cq.setType(VehicleType.公司车);
|
int insert = Fd_Vcper.insert(cq);
|
if(insert>0){
|
or.setCode(0);
|
or.setItem(cq);
|
}else{
|
or.setCode(1);
|
or.setErrmsg("保存失败");
|
}
|
}else{
|
cq.setStatus(cc.getStatus());
|
cq.setType(cc.getType());
|
int update = Fd_Vcper.update(cq);
|
or.setCode(0);
|
or.setItem(cq);
|
}
|
// }else{
|
// or.setCode(1);
|
// or.setErrmsg("对象主键不能为空");
|
// }
|
|
// Fd_Company_Vehicle fdvc=fdcvper.getbyIDs(cq.getVehicleId(), lg.getDepartno());
|
// if(fdvc==null){
|
// fdvc=new Fd_Company_Vehicle();
|
// fdvc.setCompanyNo(lg.getDepartno());
|
// fdvc.setVehicleId(cq.getVehicleId());
|
// fdcvper.insert(fdvc);
|
// }
|
|
|
}
|
return or;
|
}
|
|
|
|
|
@Override
|
@Transactional(rollbackOn=Exception.class)
|
public ObjectResult<Boolean> changeState(String vehicleId, Login lg, boolean state)
|
throws Exception {
|
ObjectResult<Boolean> orr=new ObjectResult<Boolean>();
|
if(lg==null){
|
orr.setCode(1);
|
orr.setErrmsg("账号未登录，请重新登录！");
|
return orr;
|
}
|
Fd_Vehicle fv= Fd_Vcper.getByVehicleId(vehicleId);
|
if(fv==null){
|
orr.setCode(1);
|
orr.setErrmsg("该车辆不存在！");
|
return orr;
|
}
|
if(!UserType.admin.toString().equals(lg.getWorkerno())){
|
if(!StringUtils.isEmpty(lg.getDepartno())){
|
if(!lg.getDepartno().equals(fv.getCompanyNo())){
|
orr.setCode(1);
|
orr.setErrmsg("你没有权限修改分本公司车辆！");
|
return orr;
|
}
|
}
|
}
|
fv.setState(state);
|
Fd_Vcper.update(fv);
|
orr.setCode(0);
|
orr.setItem(state);
|
return orr;
|
}
|
@Override
|
@Transactional(rollbackOn=Exception.class)
|
public ObjectResult<Boolean> delFd_Vehicle(String vehicleId) throws Exception {
|
|
ObjectResult<Boolean> prr = new ObjectResult<Boolean>();
|
if(!StringUtils.isBlank(vehicleId)){
|
Fd_Vehicle fdv=Fd_Vcper.getByVehicleId(vehicleId);
|
if(fdv!=null){
|
List<Fd_Bsheet> fdb=fdbper.getListbyVehicleId(vehicleId,Serviceenum.在办);
|
if(fdb!=null&&!fdb.isEmpty()){
|
prr.setCode(1);
|
prr.setErrmsg("车辆有在办的提单，不能删除，等业务办完之后再删除！");
|
return prr;
|
}
|
// if(fdv.getStatus()!=VehicleStatus.未配车){
|
// prr.setCode(1);
|
// prr.setErrmsg("车辆状态不是未配车状态，不能删除！");
|
// return prr;
|
// }
|
}
|
int i = Fd_Vcper.delByVehicleId(vehicleId);
|
// fdcvper.delbyID(vehicleId);
|
prr.setCode(0);
|
prr.setItem(true);
|
}else{
|
prr.setCode(1);
|
prr.setItem(false);
|
prr.setErrmsg("车牌号不能为空");;
|
}
|
|
return prr;
|
}
|
|
}
|
