From cbaa51b8be6b912c01ab247baf302c99fa525544 Mon Sep 17 00:00:00 2001 From: yuanye <418471657@qq.com> Date: Mon, 14 Jul 2025 10:17:07 +0800 Subject: [PATCH] 1 --- .../item/EnOilManagementController.java | 142 ++++++++++++ .../item/EnTransportCompanyCarController.java | 211 ++++++++++++++++++ .../java/com/hfkj/entity/EnOilManagement.java | 2 +- .../service/item/EnOilManagementService.java | 68 ++++++ .../item/EnTransportCompanyCarService.java | 69 ++++++ .../item/impl/EnOilManagementServiceImpl.java | 126 +++++++++++ .../EnTransportCompanyCarServiceImpl.java | 169 ++++++++++++++ 7 files changed, 786 insertions(+), 1 deletion(-) create mode 100644 bweb/src/main/java/com/bweb/controller/item/EnOilManagementController.java create mode 100644 bweb/src/main/java/com/bweb/controller/item/EnTransportCompanyCarController.java create mode 100644 service/src/main/java/com/hfkj/service/item/EnOilManagementService.java create mode 100644 service/src/main/java/com/hfkj/service/item/EnTransportCompanyCarService.java create mode 100644 service/src/main/java/com/hfkj/service/item/impl/EnOilManagementServiceImpl.java create mode 100644 service/src/main/java/com/hfkj/service/item/impl/EnTransportCompanyCarServiceImpl.java diff --git a/bweb/src/main/java/com/bweb/controller/item/EnOilManagementController.java b/bweb/src/main/java/com/bweb/controller/item/EnOilManagementController.java new file mode 100644 index 0000000..3001734 --- /dev/null +++ b/bweb/src/main/java/com/bweb/controller/item/EnOilManagementController.java @@ -0,0 +1,142 @@ +package com.bweb.controller.item; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.hfkj.common.exception.ErrorCode; +import com.hfkj.common.exception.ErrorHelp; +import com.hfkj.common.exception.SysCode; +import com.hfkj.common.security.UserCenter; +import com.hfkj.common.utils.ResponseMsgUtil; +import com.hfkj.config.MathConfig; +import com.hfkj.entity.EnOilDepots; +import com.hfkj.entity.EnOilManagement; +import com.hfkj.entity.EnTransportCompanyCar; +import com.hfkj.model.ResponseData; +import com.hfkj.model.SecUserSessionObject; +import com.hfkj.service.item.EnOilManagementService; +import com.hfkj.service.item.EnTransportCompanyCarService; +import com.hfkj.sysenum.SecUserObjectTypeEnum; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import io.swagger.models.auth.In; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import java.math.BigDecimal; +import java.util.Date; +import java.util.HashMap; +import java.util.Map; + +@Controller +@RequestMapping(value="/enOilManagement") +@Api(value="油库进销存管理管理") +public class EnOilManagementController { + + Logger log = LoggerFactory.getLogger(EnOilDepotsController.class); + @Resource + private UserCenter userCenter; + @Resource + private EnOilManagementService enOilManagementService; + @Resource + private EnTransportCompanyCarService enTransportCompanyCarService; + + @RequestMapping(value="/oilInOutRecord",method = RequestMethod.POST) + @ResponseBody + @ApiOperation(value = "进出库记录") + public ResponseData oilInOutRecord(@RequestBody EnOilManagement body) { + try { + if (body == null + || body.getType() == null + || body.getOilType() == null + || StringUtils.isBlank(body.getRemark()) + ) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); + } + SecUserSessionObject sessionModel = userCenter.getSessionModel(SecUserSessionObject.class); + + if (sessionModel == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_LOGIN_NOT, ""); + } + if (!sessionModel.getAccount().getObjectType().equals(SecUserObjectTypeEnum.type3.getCode())) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ROLE_NOT_PERMISSIONS, ""); + } + + // 当类型为出库 + if (body.getType() == 1) { + if (body.getOutQuantity() == null + || body.getOutQuantity().compareTo(BigDecimal.ZERO) <= 0 + || body.getTransportCarId() == null + ){ + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); + } + + EnTransportCompanyCar enTransportCompanyCar = enTransportCompanyCarService.queryDetail(body.getTransportCarId()); + body.setTransportCarNo(enTransportCompanyCar.getCarNo()); + } + + // 当类型为入库 + if (body.getType() == 2) { + if (body.getInQuantity() == null + || body.getInQuantity().compareTo(BigDecimal.ZERO) <= 0 + || body.getTransportCarNo() == null + || StringUtils.isBlank(body.getSupplier()) + ){ + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); + } + } + + body.setUpdateTime(new Date()); + body.setCreateTime(new Date()); + body.setCreateUser(sessionModel.getAccount().getId()); + body.setStatus(1); + body.setCreateUserName(sessionModel.getAccount().getUserName()); + + enOilManagementService.create(body); + + return ResponseMsgUtil.success("操作成功"); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + + @RequestMapping(value="/queryList",method = RequestMethod.GET) + @ResponseBody + @ApiOperation(value = "查询项目列表") + public ResponseData queryList(@RequestParam(value = "type" , required = false) Integer type, + @RequestParam(value = "transportCarId" , required = false) Long transportCarId, + @RequestParam(value = "oilType" , required = false) Integer oilType, + @RequestParam(value = "transportCarNo" , required = false) String transportCarNo, + @RequestParam(value = "status" , required = false) Integer status, + @RequestParam(value = "supplier" , required = false) String supplier, + @RequestParam(value = "pageNum" , required = true) Integer pageNum, + @RequestParam(value = "pageSize" , required = true) Integer pageSize) { + try { + SecUserSessionObject sessionModel = userCenter.getSessionModel(SecUserSessionObject.class); + if (sessionModel == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_LOGIN_NOT, ""); + } + + Map param = new HashMap<>(); + param.put("type", type); + param.put("transportCarId", transportCarId); + param.put("oilType", oilType); + param.put("transportCarNo", transportCarNo); + param.put("supplier", supplier); + param.put("status", status); + + PageHelper.startPage(pageNum, pageSize); + return ResponseMsgUtil.success(new PageInfo<>(enTransportCompanyCarService.getList(param))); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + +} diff --git a/bweb/src/main/java/com/bweb/controller/item/EnTransportCompanyCarController.java b/bweb/src/main/java/com/bweb/controller/item/EnTransportCompanyCarController.java new file mode 100644 index 0000000..6320806 --- /dev/null +++ b/bweb/src/main/java/com/bweb/controller/item/EnTransportCompanyCarController.java @@ -0,0 +1,211 @@ +package com.bweb.controller.item; + +import com.github.pagehelper.PageHelper; +import com.github.pagehelper.PageInfo; +import com.hfkj.common.exception.ErrorCode; +import com.hfkj.common.exception.ErrorHelp; +import com.hfkj.common.exception.SysCode; +import com.hfkj.common.security.UserCenter; +import com.hfkj.common.utils.ResponseMsgUtil; +import com.hfkj.entity.EnTransportCompany; +import com.hfkj.entity.EnTransportCompanyCar; +import com.hfkj.model.ResponseData; +import com.hfkj.model.SecUserSessionObject; +import com.hfkj.service.item.EnTransportCompanyCarService; +import com.hfkj.service.item.EnTransportCompanyService; +import com.hfkj.sysenum.SecUserObjectTypeEnum; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import java.util.Date; +import java.util.HashMap; +import java.util.Map; + +@Controller +@RequestMapping(value="/enTransportCompanyCar") +@Api(value="运输公司车辆管理") +public class EnTransportCompanyCarController { + Logger log = LoggerFactory.getLogger(EnTransportCompanyCarController.class); + @Resource + private UserCenter userCenter; + @Resource + private EnTransportCompanyCarService enTransportCompanyCarService; + + @RequestMapping(value="/create",method = RequestMethod.POST) + @ResponseBody + @ApiOperation(value = "创建运输公司车辆") + public ResponseData create(@RequestBody EnTransportCompanyCar body) { + try { + if (body == null + || body.getCarType() == null + || body.getOilTankCapacity() == null + || StringUtils.isBlank(body.getContactInfo()) + || StringUtils.isBlank(body.getCarNo()) + || StringUtils.isBlank(body.getCredentialsImg()) + || StringUtils.isBlank(body.getPerson()) + ) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); + } + SecUserSessionObject sessionModel = userCenter.getSessionModel(SecUserSessionObject.class); + if (sessionModel == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_LOGIN_NOT, ""); + } + if (!sessionModel.getAccount().getObjectType().equals(SecUserObjectTypeEnum.type5.getCode())) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ROLE_NOT_PERMISSIONS, ""); + } + + body.setUpdateTime(new Date()); + body.setCreateTime(new Date()); + body.setCreateUser(sessionModel.getAccount().getId()); + body.setStatus(1); + body.setCreateUserName(sessionModel.getAccount().getUserName()); + enTransportCompanyCarService.create(body); + + return ResponseMsgUtil.success("操作成功"); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + + @RequestMapping(value="/update",method = RequestMethod.POST) + @ResponseBody + @ApiOperation(value = "修改运输公司") + public ResponseData update(@RequestBody EnTransportCompanyCar body) { + try { + if (body == null + || body.getId() == null + || body.getCarType() == null + || body.getOilTankCapacity() == null + || StringUtils.isBlank(body.getCarNo()) + || StringUtils.isBlank(body.getCredentialsImg()) + || StringUtils.isBlank(body.getPerson()) + ) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); + } + SecUserSessionObject sessionModel = userCenter.getSessionModel(SecUserSessionObject.class); + if (sessionModel == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_LOGIN_NOT, ""); + } + if (!sessionModel.getAccount().getObjectType().equals(SecUserObjectTypeEnum.type5.getCode())) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ROLE_NOT_PERMISSIONS, ""); + } + + Map map = new HashMap<>(); + + map.put("id",body.getId()); + map.put("createUser" , sessionModel.getAccount().getId()); + + EnTransportCompanyCar enTransportCompanyCar = enTransportCompanyCarService.queryDetailByMap(map); + if (enTransportCompanyCar == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, "服务公司车辆不存在"); + } + + enTransportCompanyCar.setPerson(body.getPerson()); + enTransportCompanyCar.setCarNo(body.getCarNo()); + enTransportCompanyCar.setCarType(body.getCarType()); + enTransportCompanyCar.setOilTankCapacity(body.getOilTankCapacity()); + enTransportCompanyCar.setUpdateTime(new Date()); + enTransportCompanyCar.setUpdateUser(sessionModel.getAccount().getId()); + enTransportCompanyCar.setUpdateUserName(sessionModel.getAccount().getUserName()); + enTransportCompanyCarService.update(enTransportCompanyCar); + + return ResponseMsgUtil.success("操作成功"); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + + @RequestMapping(value="/delete",method = RequestMethod.GET) + @ResponseBody + @ApiOperation(value = "删除") + public ResponseData delete(@RequestParam(value = "id" , required = false) Long id) { + try { + + SecUserSessionObject sessionModel = userCenter.getSessionModel(SecUserSessionObject.class); + if (sessionModel == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_LOGIN_NOT, ""); + } + + Map map = new HashMap<>(); + + map.put("id",id); + map.put("createUser" , sessionModel.getAccount().getId()); + + EnTransportCompanyCar enTransportCompanyCar = enTransportCompanyCarService.queryDetailByMap(map); + if (enTransportCompanyCar == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, "服务公司车辆不存在"); + } + + enTransportCompanyCarService.delete(id , false); + + return ResponseMsgUtil.success("删除成功"); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + + + + @RequestMapping(value="/queryDetail",method = RequestMethod.GET) + @ResponseBody + @ApiOperation(value = "查询详情") + public ResponseData queryDetail(@RequestParam(value = "id" , required = false) Long id) { + try { + + return ResponseMsgUtil.success(enTransportCompanyCarService.queryDetail(id)); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + + @RequestMapping(value="/queryList",method = RequestMethod.GET) + @ResponseBody + @ApiOperation(value = "查询项目列表") + public ResponseData queryList(@RequestParam(value = "carNo" , required = false) String carNo, + @RequestParam(value = "carType" , required = false) Integer carType, + @RequestParam(value = "status" , required = false) Integer status, + @RequestParam(value = "transportId" , required = false) Long transportId, + @RequestParam(value = "person" , required = false) String person, + @RequestParam(value = "contactInfo" , required = false) String contactInfo, + @RequestParam(value = "pageNum" , required = true) Integer pageNum, + @RequestParam(value = "pageSize" , required = true) Integer pageSize) { + try { + SecUserSessionObject sessionModel = userCenter.getSessionModel(SecUserSessionObject.class); + if (sessionModel == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.ACCOUNT_LOGIN_NOT, ""); + } + + Map param = new HashMap<>(); + param.put("carNo", carNo); + param.put("contactInfo", contactInfo); + param.put("transportId", transportId); + param.put("carType", carType); + param.put("person", person); + param.put("status", status); + param.put("createUser", sessionModel.getAccount().getId()); + + PageHelper.startPage(pageNum, pageSize); + return ResponseMsgUtil.success(new PageInfo<>(enTransportCompanyCarService.getList(param))); + + } catch (Exception e) { + log.error("error!",e); + return ResponseMsgUtil.exception(e); + } + } + + +} diff --git a/service/src/main/java/com/hfkj/entity/EnOilManagement.java b/service/src/main/java/com/hfkj/entity/EnOilManagement.java index 91267d9..495c284 100644 --- a/service/src/main/java/com/hfkj/entity/EnOilManagement.java +++ b/service/src/main/java/com/hfkj/entity/EnOilManagement.java @@ -35,7 +35,7 @@ public class EnOilManagement implements Serializable { private String transportCarNo; /** - * 油品类型:1柴油 2:汽油 + * 油品类型:1 柴油 2:汽油 */ private Integer oilType; diff --git a/service/src/main/java/com/hfkj/service/item/EnOilManagementService.java b/service/src/main/java/com/hfkj/service/item/EnOilManagementService.java new file mode 100644 index 0000000..bf2e5a4 --- /dev/null +++ b/service/src/main/java/com/hfkj/service/item/EnOilManagementService.java @@ -0,0 +1,68 @@ +package com.hfkj.service.item; + +import com.hfkj.entity.EnOilManagement; + +import java.util.List; +import java.util.Map; + +public interface EnOilManagementService { + + /** + * @MethodName 创建 + * @Description: + * @param enOilManagement + * @Author: Sum1Dream + * @Date: 2025/7/11 下午4:34 + */ + void create(EnOilManagement enOilManagement); + + /** + * @MethodName update + * @Description:修改 + * @param enOilManagement + * @Author: Sum1Dream + * @Date: 2025/7/11 下午4:34 + */ + void update(EnOilManagement enOilManagement); + + /** + * @MethodName delete + * @Description:删除 + * @param id + * @param fullDelete + * @Author: Sum1Dream + * @Date: 2025/7/11 下午4:34 + */ + void delete(Long id , Boolean fullDelete); + + /** + * @MethodName queryDetail + * @Description:查询详情 + * @param id + * @return: com.hfkj.entity.EnOilManagement + * @Author: Sum1Dream + * @Date: 2025/7/11 下午4:34 + */ + EnOilManagement queryDetail(Long id); + + /** + * @MethodName queryDetailByMap + * @Description:根据多条件查询详情 + * @param map + * @return: com.hfkj.entity.EnOilManagement + * @Author: Sum1Dream + * @Date: 2025/7/11 下午4:34 + */ + EnOilManagement queryDetailByMap(Map map); + + /** + * @MethodName getList + * @Description:查询列表 + * @param map + * @return: java.util.List + * @Author: Sum1Dream + * @Date: 2025/7/11 下午4:35 + */ + List getList(Map map); + +} diff --git a/service/src/main/java/com/hfkj/service/item/EnTransportCompanyCarService.java b/service/src/main/java/com/hfkj/service/item/EnTransportCompanyCarService.java new file mode 100644 index 0000000..193f798 --- /dev/null +++ b/service/src/main/java/com/hfkj/service/item/EnTransportCompanyCarService.java @@ -0,0 +1,69 @@ +package com.hfkj.service.item; + +import com.hfkj.entity.EnTransportCompanyCar; + +import java.util.List; +import java.util.Map; + +public interface EnTransportCompanyCarService { + + /** + * @MethodName create + * @Description:新增 + * @param enTransportCompanyCar + * @Author: Sum1Dream + * @Date: 2025/7/10 下午5:17 + */ + void create(EnTransportCompanyCar enTransportCompanyCar) throws Exception; + + /** + * @MethodName update + * @Description:修改 + * @param enTransportCompanyCar + * @Author: Sum1Dream + * @Date: 2025/7/9 下午5:41 + */ + void update(EnTransportCompanyCar enTransportCompanyCar); + + /** + * @MethodName delete + * @Description:删除 + * @param id + * @param fullDelete + * @Author: Sum1Dream + * @Date: 2025/7/9 下午5:41 + */ + void delete(Long id , Boolean fullDelete); + + /** + * @MethodName queryDetail + * @Description:查询详情 + * @param id + * @return: com.hfkj.entity.EnTransportCompanyCar + * @Author: Sum1Dream + * @Date: 2025/7/9 下午5:41 + */ + EnTransportCompanyCar queryDetail(Long id); + + /** + * @MethodName queryDetailByMap + * @Description:根据多条件查询详情 + * @param map + * @return: com.hfkj.entity.EnTransportCompanyCar + * @Author: Sum1Dream + * @Date: 2025/7/9 下午5:41 + */ + EnTransportCompanyCar queryDetailByMap(Map map); + + + /** + * @MethodName getList + * @Description:查询列表 + * @param map + * @return: java.util.List + * @Author: Sum1Dream + * @Date: 2025/7/9 下午5:41 + */ + List getList(Map map); + +} diff --git a/service/src/main/java/com/hfkj/service/item/impl/EnOilManagementServiceImpl.java b/service/src/main/java/com/hfkj/service/item/impl/EnOilManagementServiceImpl.java new file mode 100644 index 0000000..55e3e8f --- /dev/null +++ b/service/src/main/java/com/hfkj/service/item/impl/EnOilManagementServiceImpl.java @@ -0,0 +1,126 @@ +package com.hfkj.service.item.impl; + +import com.hfkj.dao.EnOilManagementMapper; +import com.hfkj.entity.EnOilManagement; +import com.hfkj.entity.EnOilManagementExample; +import com.hfkj.entity.EnServiceCompanyDevice; +import com.hfkj.service.item.EnOilManagementService; +import org.apache.commons.collections4.MapUtils; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.Collections; +import java.util.Date; +import java.util.List; +import java.util.Map; + +@Service("enOilManagementService") +public class EnOilManagementServiceImpl implements EnOilManagementService { + + @Resource + private EnOilManagementMapper enOilManagementMapper; + + @Override + public void create(EnOilManagement enOilManagement) { + enOilManagementMapper.insert(enOilManagement); + } + + @Override + public void update(EnOilManagement enOilManagement) { + enOilManagementMapper.updateByPrimaryKey(enOilManagement); + } + + @Override + public void delete(Long id, Boolean fullDelete) { + if (fullDelete) { + enOilManagementMapper.deleteByPrimaryKey(id); + } else { + EnOilManagement enOilManagement = queryDetail(id); + enOilManagement.setStatus(0); + enOilManagement.setUpdateTime(new Date()); + update(enOilManagement); + } + } + + @Override + public EnOilManagement queryDetail(Long id) { + return enOilManagementMapper.selectByPrimaryKey(id); + } + + @Override + public EnOilManagement queryDetailByMap(Map map) { + EnOilManagementExample example = new EnOilManagementExample(); + EnOilManagementExample.Criteria criteria = example.createCriteria(); + + if (StringUtils.isNotBlank(MapUtils.getString(map, "transportCarNo"))) { + criteria.andTransportCarNoNotLike("%"+MapUtils.getString(map, "transportCarNo")+"%"); + } + if (StringUtils.isNotBlank(MapUtils.getString(map, "supplier"))) { + criteria.andSupplierLike("%"+MapUtils.getString(map, "supplier")+"%"); + } + + if (MapUtils.getInteger(map , "type") != null) { + criteria.andTypeEqualTo(MapUtils.getInteger(map , "type")); + } + if (MapUtils.getInteger(map , "oilType") != null) { + criteria.andOilTypeEqualTo(MapUtils.getInteger(map , "oilType")); + } + + if (MapUtils.getLong(map , "transportCarId") != null) { + criteria.andTransportCarIdEqualTo(MapUtils.getLong(map , "transportCarId")); + } + if (MapUtils.getLong(map, "createUser") != null) { + criteria.andCreateUserEqualTo(MapUtils.getLong(map, "createUser")); + } + if (MapUtils.getInteger(map, "status") != null) { + criteria.andStatusEqualTo(MapUtils.getInteger(map, "status")); + }else { + criteria.andStatusNotEqualTo(0); + } + if (MapUtils.getLong(map , "id") != null) { + criteria.andIdEqualTo(MapUtils.getLong(map , "id")); + } + + List list = enOilManagementMapper.selectByExample(example); + + return list.isEmpty() ? null : list.get(0); + } + + @Override + public List getList(Map map) { + EnOilManagementExample example = new EnOilManagementExample(); + EnOilManagementExample.Criteria criteria = example.createCriteria(); + + if (StringUtils.isNotBlank(MapUtils.getString(map, "transportCarNo"))) { + criteria.andTransportCarNoNotLike("%"+MapUtils.getString(map, "transportCarNo")+"%"); + } + if (StringUtils.isNotBlank(MapUtils.getString(map, "supplier"))) { + criteria.andSupplierLike("%"+MapUtils.getString(map, "supplier")+"%"); + } + + if (MapUtils.getInteger(map , "type") != null) { + criteria.andTypeEqualTo(MapUtils.getInteger(map , "type")); + } + if (MapUtils.getInteger(map , "oilType") != null) { + criteria.andOilTypeEqualTo(MapUtils.getInteger(map , "oilType")); + } + + if (MapUtils.getLong(map , "transportCarId") != null) { + criteria.andTransportCarIdEqualTo(MapUtils.getLong(map , "transportCarId")); + } + if (MapUtils.getLong(map, "createUser") != null) { + criteria.andCreateUserEqualTo(MapUtils.getLong(map, "createUser")); + } + if (MapUtils.getInteger(map, "status") != null) { + criteria.andStatusEqualTo(MapUtils.getInteger(map, "status")); + }else { + criteria.andStatusNotEqualTo(0); + } + if (MapUtils.getLong(map , "id") != null) { + criteria.andIdEqualTo(MapUtils.getLong(map , "id")); + } + + return enOilManagementMapper.selectByExample(example); + } +} diff --git a/service/src/main/java/com/hfkj/service/item/impl/EnTransportCompanyCarServiceImpl.java b/service/src/main/java/com/hfkj/service/item/impl/EnTransportCompanyCarServiceImpl.java new file mode 100644 index 0000000..0d2ac07 --- /dev/null +++ b/service/src/main/java/com/hfkj/service/item/impl/EnTransportCompanyCarServiceImpl.java @@ -0,0 +1,169 @@ +package com.hfkj.service.item.impl; + +import com.hfkj.common.exception.ErrorCode; +import com.hfkj.common.exception.ErrorHelp; +import com.hfkj.common.exception.SysCode; +import com.hfkj.common.utils.MD5Util; +import com.hfkj.dao.EnTransportCompanyCarMapper; +import com.hfkj.entity.*; +import com.hfkj.service.SecUserService; +import com.hfkj.service.item.EnTransportCompanyCarService; +import com.hfkj.sysenum.SecUserObjectTypeEnum; +import com.hfkj.sysenum.SecUserStatusEnum; +import org.apache.commons.collections4.MapUtils; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; +import java.util.Collections; +import java.util.Date; +import java.util.List; +import java.util.Map; + + +@Service("enTransportCompanyCarService") +public class EnTransportCompanyCarServiceImpl implements EnTransportCompanyCarService { + + @Resource + private EnTransportCompanyCarMapper enTransportCompanyCarMapper; + @Resource + private SecUserService secUserService; + + @Override + public void create(EnTransportCompanyCar enTransportCompanyCar) throws Exception { + enTransportCompanyCarMapper.insert(enTransportCompanyCar); + + if (secUserService.getDetailByLoginName(enTransportCompanyCar.getContactInfo()) != null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "登录账户已存在,请更换"); + } + + SecUser secUser = new SecUser(); + secUser.setUserName(enTransportCompanyCar.getPerson()); + secUser.setLoginName(enTransportCompanyCar.getContactInfo()); + secUser.setPassword(MD5Util.encode("123456".getBytes())); + secUser.setTelephone(enTransportCompanyCar.getContactInfo()); + secUser.setRoleId(1029L); + secUser.setObjectType(SecUserObjectTypeEnum.type6.getCode()); + secUser.setObjectId(enTransportCompanyCar.getId()); + secUser.setStatus(SecUserStatusEnum.status1.getCode()); + secUserService.editUser(secUser); + } + + @Override + public void update(EnTransportCompanyCar enTransportCompanyCar) { + enTransportCompanyCarMapper.updateByPrimaryKey(enTransportCompanyCar); + // 查询账户 + SecUser secUser = secUserService.getDetail(SecUserObjectTypeEnum.type6, enTransportCompanyCar.getId()); + if (secUser == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "账户数据异常"); + } + secUser.setUserName(enTransportCompanyCar.getPerson()); + secUserService.editUser(secUser); + } + + @Override + public void delete(Long id, Boolean fullDelete) { + EnTransportCompanyCar enTransportCompanyCar = queryDetail(id); + if (fullDelete) { + enTransportCompanyCarMapper.deleteByPrimaryKey(id); + } else { + + enTransportCompanyCar.setStatus(0); + enTransportCompanyCar.setUpdateTime(new Date()); + update(enTransportCompanyCar); + } + + // 查询账户 + SecUser secUser = secUserService.getDetail(SecUserObjectTypeEnum.type6, enTransportCompanyCar.getId()); + if (secUser == null) { + throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "账户数据异常"); + } + secUser.setStatus(SecUserStatusEnum.status0.getCode()); + secUserService.editUser(secUser); + } + + @Override + public EnTransportCompanyCar queryDetail(Long id) { + return enTransportCompanyCarMapper.selectByPrimaryKey(id); + } + + @Override + public EnTransportCompanyCar queryDetailByMap(Map map) { + EnTransportCompanyCarExample example = new EnTransportCompanyCarExample(); + EnTransportCompanyCarExample.Criteria criteria = example.createCriteria(); + + if (StringUtils.isNotBlank(MapUtils.getString(map, "person"))) { + criteria.andPersonLike("%"+MapUtils.getString(map, "person")+"%"); + } + if (StringUtils.isNotBlank(MapUtils.getString(map, "carNo"))) { + criteria.andPersonLike("%"+MapUtils.getString(map, "carNo")+"%"); + } + if (MapUtils.getLong(map, "createUser") != null) { + criteria.andCreateUserEqualTo(MapUtils.getLong(map, "createUser")); + } + if (MapUtils.getInteger(map, "carType") != null) { + criteria.andCarTypeEqualTo(MapUtils.getInteger(map, "carType")); + } + + if (MapUtils.getLong(map, "transportId") != null) { + criteria.andCreateUserEqualTo(MapUtils.getLong(map, "transportId")); + } + + if (StringUtils.isNotBlank(MapUtils.getString(map, "person"))) { + criteria.andPersonLike("%"+MapUtils.getString(map, "person")+"%"); + } + if (StringUtils.isNotBlank(MapUtils.getString(map, "contactInfo"))) { + criteria.andContactInfoLike("%"+MapUtils.getString(map, "contactInfo")+"%"); + } + if (MapUtils.getInteger(map, "status") != null) { + criteria.andStatusEqualTo(MapUtils.getInteger(map, "status")); + }else { + criteria.andStatusNotEqualTo(0); + } + if (MapUtils.getLong(map , "id") != null) { + criteria.andIdEqualTo(MapUtils.getLong(map , "id")); + } + List list = enTransportCompanyCarMapper.selectByExample(example); + + return list.isEmpty() ? null : list.get(0); + } + + @Override + public List getList(Map map) { + EnTransportCompanyCarExample example = new EnTransportCompanyCarExample(); + EnTransportCompanyCarExample.Criteria criteria = example.createCriteria(); + + if (StringUtils.isNotBlank(MapUtils.getString(map, "person"))) { + criteria.andPersonLike("%"+MapUtils.getString(map, "person")+"%"); + } + if (StringUtils.isNotBlank(MapUtils.getString(map, "carNo"))) { + criteria.andPersonLike("%"+MapUtils.getString(map, "carNo")+"%"); + } + if (MapUtils.getLong(map, "createUser") != null) { + criteria.andCreateUserEqualTo(MapUtils.getLong(map, "createUser")); + } + if (MapUtils.getInteger(map, "carType") != null) { + criteria.andCarTypeEqualTo(MapUtils.getInteger(map, "carType")); + } + + if (MapUtils.getLong(map, "transportId") != null) { + criteria.andCreateUserEqualTo(MapUtils.getLong(map, "transportId")); + } + + if (StringUtils.isNotBlank(MapUtils.getString(map, "person"))) { + criteria.andPersonLike("%"+MapUtils.getString(map, "person")+"%"); + } + if (StringUtils.isNotBlank(MapUtils.getString(map, "contactInfo"))) { + criteria.andContactInfoLike("%"+MapUtils.getString(map, "contactInfo")+"%"); + } + if (MapUtils.getInteger(map, "status") != null) { + criteria.andStatusEqualTo(MapUtils.getInteger(map, "status")); + }else { + criteria.andStatusNotEqualTo(0); + } + if (MapUtils.getLong(map , "id") != null) { + criteria.andIdEqualTo(MapUtils.getLong(map , "id")); + } + return enTransportCompanyCarMapper.selectByExample(example) ; + } +}