diff --git a/src/main/java/com/glxp/api/controller/auth/DeptController.java b/src/main/java/com/glxp/api/controller/auth/DeptController.java index 8a3fcd40..644c69e2 100644 --- a/src/main/java/com/glxp/api/controller/auth/DeptController.java +++ b/src/main/java/com/glxp/api/controller/auth/DeptController.java @@ -9,12 +9,16 @@ import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; import com.glxp.api.entity.auth.AuthAdmin; import com.glxp.api.entity.auth.DeptEntity; +import com.glxp.api.entity.auth.DeptUserEntity; +import com.glxp.api.entity.auth.InvWarehouseEntity; import com.glxp.api.entity.system.SystemParamConfigEntity; +import com.glxp.api.req.auth.FilterDeptUserReqeust; import com.glxp.api.req.auth.FilterInvWarehouseRequest; import com.glxp.api.req.system.DeleteRequest; import com.glxp.api.res.PageSimpleResponse; import com.glxp.api.service.auth.CustomerService; import com.glxp.api.service.auth.DeptService; +import com.glxp.api.service.auth.DeptUserService; import com.glxp.api.service.auth.InvWarehouseService; import com.glxp.api.service.system.SystemParamConfigService; import org.springframework.validation.BindingResult; @@ -226,6 +230,11 @@ public class DeptController { return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); } + //判断状态 + String msg = isCheckStatus(deptEntity.getStatus(), deptEntity); + if (msg != "") { + return ResultVOUtils.error(999, msg); + } List deptEntityList = deptService.selectByNameList(deptEntity.getName()); if (deptEntityList != null && deptEntityList.size() > 0) { for (DeptEntity obj : deptEntityList) { @@ -244,6 +253,8 @@ public class DeptController { return ResultVOUtils.success(); } + @Resource + DeptUserService deptUserService; @AuthRuleAnnotation("") @PostMapping("/spms/inv/warehouse/delete") public BaseResponse delete(@RequestBody DeleteRequest deleteRequest) { @@ -252,18 +263,27 @@ public class DeptController { return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); } - //todo 代码未迁移完,后续记得修改 + DeptEntity deptEntity = deptService.selectById(deleteRequest.getId()); + if (deptEntity.getLevel() != null && deptEntity.getLevel() == 1) { + return ResultVOUtils.error(500, "删除失败,一级部门不允许删除!"); + } + + List invSubWarehouseEntities = invWarehouseService.findByParentId(deptEntity.getCode()); + if (CollUtil.isNotEmpty(invSubWarehouseEntities)) { + return ResultVOUtils.error(500, "删除失败,请先移除该部门关联仓库信息!"); + } + FilterDeptUserReqeust filterDeptUserReqeust = new FilterDeptUserReqeust(); + filterDeptUserReqeust.setDeptId(deptEntity.getId().longValue()); + List deptUserEntities = deptUserService.selectDeptUser(filterDeptUserReqeust); + if (CollUtil.isNotEmpty(deptUserEntities)) { + return ResultVOUtils.error(500, "删除失败,请先移除该部门关联用户信息!"); + } + List deptEntities = deptService.selectByPcode(deptEntity.getCode()); + if (deptEntities.size() > 0) { + return ResultVOUtils.error(500, "删除失败,请先移除该部门下的子部门!"); + } + -// DeptEntity deptEntity = deptService.selectById(deleteRequest.getId()); -// InvProductDetailEntity invProductDetailEntity = invProductDetailService.isExit(deptEntity.getCode()); -// if (invProductDetailEntity != null) { -// return ResultVOUtils.error(500, "该仓库已有库存,不能删除!"); -// } -// -// List invSubWarehouseEntities = invSubWarehouseService.findByParentId(deptEntity.getCode()); -// if (CollUtil.isNotEmpty(invSubWarehouseEntities)) { -// return ResultVOUtils.error(500, "删除失败,请先移除该部门关联仓库信息!"); -// } boolean b = deptService.deleteById(deleteRequest.getId()); if (!b) { return ResultVOUtils.error(ResultEnum.NOT_NETWORK); @@ -298,4 +318,43 @@ public class DeptController { return ResultVOUtils.success(byCode); } + @AuthRuleAnnotation("") + @PostMapping("/spms/inv/warehouse/selectInvById") + public BaseResponse selectInvById(@RequestBody List InvList) { + + if (InvList.size() == 0) { + return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); + } + //先得到部门编码 + List String = deptService.selectByIdCode(InvList); + + + List list = invWarehouseService.selectInvById(String); + + return ResultVOUtils.success(list); + } + + public String isCheckStatus(Integer status, DeptEntity deptEntity) { + //启用的时候需要判断上级是不是被禁用 + if (status == 1) { + //查询所有的上级 + List deptEntityList = deptService.selectupDeptAll(deptEntity.getPcode()); + for (DeptEntity obj : deptEntityList) { + if (obj.getStatus() == 0) { + return "上级存在禁用的部门修改失败!"; + } + } + } else { + List deptEntityList = deptService.selectLowDeptAll(deptEntity.getCode()); + for (DeptEntity obj : deptEntityList) { + if (obj.getStatus() == 1) { + return "下级存在启用的部门修改失败!"; + } + } + } + return ""; + } + + + } diff --git a/src/main/java/com/glxp/api/controller/auth/DeptUserController.java b/src/main/java/com/glxp/api/controller/auth/DeptUserController.java index a4b8fe81..2a49d387 100644 --- a/src/main/java/com/glxp/api/controller/auth/DeptUserController.java +++ b/src/main/java/com/glxp/api/controller/auth/DeptUserController.java @@ -4,6 +4,7 @@ import com.github.pagehelper.PageInfo; import com.glxp.api.annotation.AuthRuleAnnotation; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; +import com.glxp.api.entity.auth.DeptEntity; import com.glxp.api.entity.auth.DeptUserEntity; import com.glxp.api.req.auth.FilterDeptUserReqeust; import com.glxp.api.res.PageSimpleResponse; @@ -26,12 +27,19 @@ public class DeptUserController { DeptUserService deptUserService; @Resource DeptService deptService; - + @AuthRuleAnnotation("") @GetMapping("udi/auth/dept/user/filter") public BaseResponse filterList(FilterDeptUserReqeust filterDeptUserReqeust) { - filterDeptUserReqeust.setDeptId(filterDeptUserReqeust.getDeptId()); + //获取部门id + Long idByCode = deptService.getIdByCode(filterDeptUserReqeust.getDeptId()); + DeptEntity deptEntity = deptService.selectById(idByCode + ""); + if (deptEntity.getLevel() == 1) { + filterDeptUserReqeust.setDeptId(null); + } else { + filterDeptUserReqeust.setDeptId(idByCode); + } List deptEntityList = deptUserService.selectJoinDeptUser(filterDeptUserReqeust); PageInfo pageInfo = new PageInfo<>(deptEntityList); PageSimpleResponse deptEntityPageSimpleResponse = new PageSimpleResponse<>(); diff --git a/src/main/java/com/glxp/api/controller/auth/InvWarehouseController.java b/src/main/java/com/glxp/api/controller/auth/InvWarehouseController.java index 9808c352..0eacca17 100644 --- a/src/main/java/com/glxp/api/controller/auth/InvWarehouseController.java +++ b/src/main/java/com/glxp/api/controller/auth/InvWarehouseController.java @@ -219,6 +219,7 @@ public class InvWarehouseController extends BaseController { public BaseResponse save(@RequestBody @Valid InvWarehouseEntity invWarehouseEntity, BindingResult bindingResult) { + if (bindingResult.hasErrors()) { return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL, bindingResult.getFieldError().getDefaultMessage()); } @@ -245,6 +246,7 @@ public class InvWarehouseController extends BaseController { updateEntity.setUpdateTime(new Date()); deptService.updateInvWarehouse(updateEntity); invWarehouseEntity.setId(IdUtil.getSnowflake(6, 1).nextId() + ""); + invWarehouseEntity.setUpdateTime(new Date()); boolean b = invWarehouseService.insertInvSubWarehouse(invWarehouseEntity); if (!b) { return ResultVOUtils.error(ResultEnum.NOT_NETWORK); @@ -264,9 +266,27 @@ public class InvWarehouseController extends BaseController { return ResultVOUtils.error(ResultEnum.PARAM_VERIFY_FALL); } + Integer userCount = warehouseUserService.countUserBySubInvCode(invWarehouseEntity.getCode()); + if (userCount > 0) { + return ResultVOUtils.error(500, "修改失败,请先移除该仓库关联用户!"); + } + //更新仓库信息 + invWarehouseEntity.setUpdateTime(new Date()); boolean b = invWarehouseService.updateInvSubWarehouse(invWarehouseEntity); + //如果要是一级仓库就吧全部子集都刷成一样的寄售仓库 + if(StrUtil.isBlank(invWarehouseEntity.getParentCode())){ + List invWarehouseEntityList=invWarehouseService.selectLowWarehouseAll(invWarehouseEntity.getCode()); + for (InvWarehouseEntity obj : invWarehouseEntityList) { + obj.setAdvanceType(invWarehouseEntity.getAdvanceType()); + obj.setUpdateTime(new Date()); + invWarehouseService.updateInvSubWarehouse(obj); + } + } + + + //更新部门信息 DeptEntity pEntity = deptService.selectByCode(invWarehouseEntity.getParentId()); pEntity.setUpdateTime(new Date()); @@ -323,6 +343,14 @@ public class InvWarehouseController extends BaseController { // return ResultVOUtils.error(500, "此分库存在库存,不能删除!"); // } // + + // 判断此分库中是否还有库存 + InvWarehouseEntity byWareId = invWarehouseService.getByWareId(deleteRequest.getId()); + List byWarePcode = invWarehouseService.getByWarePcode(byWareId.getCode()); + if( byWarePcode.size()>0){ + return ResultVOUtils.error(500, "此仓库下存在仓库无法删除!"); + } + //判断此分库下是否有货位 List spaceList = invSpaceService.findBySubWarehouseCode(invWarehouseEntity.getCode()); if (CollUtil.isNotEmpty(spaceList)) { @@ -444,8 +472,8 @@ public class InvWarehouseController extends BaseController { //1.获取所有单据类型 FilterBussinessTypeRequest filterBussinessTypeRequest = new FilterBussinessTypeRequest(); filterBussinessTypeRequest.setEnable(true); - if (invWarehouseEntity.getAdvanceType()) { - filterBussinessTypeRequest.setAdvanceType(true); + if (invWarehouseEntity.getAdvanceType() == 2) { + filterBussinessTypeRequest.setAdvanceType(2); } List basicBussinessTypeEntities = basicBussinessTypeService.findList(filterBussinessTypeRequest); @@ -610,4 +638,10 @@ public class InvWarehouseController extends BaseController { return ResultVOUtils.success(); } + @PostMapping("/warehouse/inout/getDeptById") + public BaseResponse getDeptById(@RequestBody List deptIds) { + List list = deptService.getDeptById(deptIds); + return ResultVOUtils.success(list); + } + } diff --git a/src/main/java/com/glxp/api/controller/auth/SysUserController.java b/src/main/java/com/glxp/api/controller/auth/SysUserController.java index a4a0b1e2..43e69beb 100644 --- a/src/main/java/com/glxp/api/controller/auth/SysUserController.java +++ b/src/main/java/com/glxp/api/controller/auth/SysUserController.java @@ -64,15 +64,26 @@ public class SysUserController extends BaseController { AuthAdminResponse authAdminResponse = new AuthAdminResponse(); BeanUtils.copyProperties(item, authAdminResponse); List roles = sysRoleService.selectRoleListByUserId(authAdminResponse.getId()); - List deptUserResponses = deptUserService.selectByUserId(authAdminResponse.getId()); + List deptUserResponses=null; + if("key".equals(filterAuthUserRequest.getKey())){ + deptUserResponses = deptUserService.selectByUserIdKey(authAdminResponse.getId()); + }else{ + deptUserResponses = deptUserService.selectByUserId(authAdminResponse.getId()); + } if (CollUtil.isNotEmpty(deptUserResponses)) { List depts = new ArrayList<>(); String deptName = ""; for (DeptUserResponse deptUserResponse : deptUserResponses) { - depts.add(deptUserResponse.getDeptId()); - deptName = deptName + "," + deptUserResponse.getDeptName(); + if(deptUserResponse.getDeptId()!=1){ + depts.add(deptUserResponse.getDeptId()); + deptName = deptName + "," + deptUserResponse.getDeptName(); + } + } + if(deptName.length()!=0){ + authAdminResponse.setDeptName(deptName.substring(1)); + }else{ + authAdminResponse.setDeptName(deptName); } - authAdminResponse.setDeptName(deptName.substring(1)); authAdminResponse.setDepts(depts); } authAdminResponse.setRoles(roles); diff --git a/src/main/java/com/glxp/api/controller/basic/BasicBussinessTypeController.java b/src/main/java/com/glxp/api/controller/basic/BasicBussinessTypeController.java index bc7dd1bc..5c97cc0d 100644 --- a/src/main/java/com/glxp/api/controller/basic/BasicBussinessTypeController.java +++ b/src/main/java/com/glxp/api/controller/basic/BasicBussinessTypeController.java @@ -389,4 +389,15 @@ public class BasicBussinessTypeController extends BaseController { return ResultVOUtils.success(pageSimpleResponse); } + @GetMapping("/udiwms/busType/selectList") + public BaseResponse selectList() { + + FilterBussinessTypeRequest bussinessTypeFilterRequest=new FilterBussinessTypeRequest(); + bussinessTypeFilterRequest.setAction("2"); + bussinessTypeFilterRequest.setMainAction("WareHouseOut"); + bussinessTypeFilterRequest.setCorpType(2); + List bussinessTypeEntities = basicBussinessTypeService.findList(bussinessTypeFilterRequest); + return ResultVOUtils.success(bussinessTypeEntities); + } + } diff --git a/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java b/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java index c2d8b4e0..3235f1b2 100644 --- a/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java +++ b/src/main/java/com/glxp/api/controller/inout/IoCodeTempController.java @@ -428,7 +428,7 @@ public class IoCodeTempController extends BaseController { //过期提醒: // SystemParamConfigEntity expireParamConfigEntity = systemParamConfigService.selectByParamKey("expire_date_tip"); - if (bussinessTypeEntity.isCheckExpire() && !addOrderRequest.isIgnoreExpire()) { + if (bussinessTypeEntity.getCheckVailDate()==1 && !addOrderRequest.isIgnoreExpire()) { if (StrUtil.isNotEmpty(udiEntity.getExpireDate())) { String expireDate = "20" + udiEntity.getExpireDate(); long expireTime = DateUtil.parseDateExpire(expireDate); @@ -441,7 +441,7 @@ public class IoCodeTempController extends BaseController { //失效期提醒 SystemParamConfigEntity recentParamConfigEntity = systemParamConfigService.selectByParamKey("recent_date_tip"); long recent = Long.parseLong(recentParamConfigEntity.getParamValue()); - if (bussinessTypeEntity.isCheckVailDate() && recent > 0 && !addOrderRequest.isIgnoreRecentExpire()) { + if (bussinessTypeEntity.getCheckVailDate()==1 && recent > 0 && !addOrderRequest.isIgnoreRecentExpire()) { if (StrUtil.isNotEmpty(udiEntity.getExpireDate())) { String expireDate = "20" + udiEntity.getExpireDate(); long expireTime = DateUtil.parseDateExpire(expireDate); diff --git a/src/main/java/com/glxp/api/controller/purchase/IoPurChangeService.java b/src/main/java/com/glxp/api/controller/purchase/IoPurChangeService.java index 0c5a048d..7317cd49 100644 --- a/src/main/java/com/glxp/api/controller/purchase/IoPurChangeService.java +++ b/src/main/java/com/glxp/api/controller/purchase/IoPurChangeService.java @@ -275,7 +275,7 @@ public class IoPurChangeService { billNo += ioOrderEntity.getBillNo() + ","; //插入业务单表 for (PurReceiveDetailEntity obj : m.getValue()) { - BasicProductsEntity basicProductsEntity = purPlanDetailService.selectIoOrderDetailBiz(obj.getId()); + BasicProductsEntity basicProductsEntity = receivedetailService.selectIoOrderDetailBiz(obj.getId()); IoOrderDetailBizEntity ioOrderDetailBizEntity = new IoOrderDetailBizEntity(); ioOrderDetailBizEntity.setOrderIdFk(ioOrderEntity.getBillNo()); ioOrderDetailBizEntity.setBindRlFk(obj.getRelIdFk()); @@ -436,10 +436,10 @@ public class IoPurChangeService { ioOrderEntity.setAction(basicBusTypeChangeEntity.getTargetAction()); ioOrderEntity.setFromCorp(m.getKey()); ioOrderEntity.setFromType(ConstantStatus.FROM_Order); - if(basicBusTypeChangeEntity.getAuditStatus()==1){ + if (basicBusTypeChangeEntity.getAuditStatus() == 1) { ioOrderEntity.setStatus(ConstantStatus.ORDER_STATUS_TEMP_SAVE); ioOrderEntity.setDealStatus(ConstantStatus.ORDER_STATUS_TEMP_SAVE); - }else if(basicBusTypeChangeEntity.getAuditStatus()==2){ + } else if (basicBusTypeChangeEntity.getAuditStatus() == 2) { ioOrderEntity.setStatus(ConstantStatus.ORDER_STATUS_CHECK); ioOrderEntity.setDealStatus(ConstantStatus.ORDER_STATUS_PROCESS); } diff --git a/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java b/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java index 4b0bdfdb..a15eccff 100644 --- a/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java +++ b/src/main/java/com/glxp/api/controller/sync/SpsSyncExportStatusController.java @@ -1,6 +1,7 @@ package com.glxp.api.controller.sync; import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.util.StrUtil; import com.github.pagehelper.PageInfo; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.common.util.ResultVOUtils; @@ -60,7 +61,9 @@ public class SpsSyncExportStatusController { @PostMapping("/spssync/basic/udiinfo/deleteByStatus") public BaseResponse deleteByStatus(@RequestBody DeleteRequest deleteRequest) { - + if (StrUtil.isBlank(deleteRequest.getId())) { + return ResultVOUtils.error(500, "缺少唯一标识"); + } boolean b = basicExportService.deleteById(deleteRequest.getId()); redisUtil.del(deleteRequest.getId()); if (b) diff --git a/src/main/java/com/glxp/api/dao/auth/DeptDao.java b/src/main/java/com/glxp/api/dao/auth/DeptDao.java index 1750556e..0f72e36c 100644 --- a/src/main/java/com/glxp/api/dao/auth/DeptDao.java +++ b/src/main/java/com/glxp/api/dao/auth/DeptDao.java @@ -17,6 +17,8 @@ public interface DeptDao { List filterGroupInvWarehouse(FilterInvWarehouseRequest filterInvWarehouseRequest); + List selectByIdCode(@Param("List") List list); + boolean insertInvWarehouse(DeptEntity DeptEntity); boolean updateInvWarehouse(DeptEntity DeptEntity); @@ -49,6 +51,10 @@ public interface DeptDao { boolean updateTime(@Param("code") String code, @Param("updateTime") Date updateTime); + List getDeptById(@Param("ids") List ids); + + List selectByPcode(@Param("pcode") String pcode); + DeptEntity selectByThirdSys(@Param("thirdIdSys") String thirdIdSys, @Param("thirdId") String thirdId); /** @@ -63,4 +69,8 @@ public interface DeptDao { * @return */ String selectNameByCode(@Param("code") String code); + + List selectupDeptAll(@Param("pcode") String pCode); + + List selectLowDeptAll(@Param("pcode") String pCode); } diff --git a/src/main/java/com/glxp/api/dao/auth/DeptUserDao.java b/src/main/java/com/glxp/api/dao/auth/DeptUserDao.java index dc10b7ef..b43f8987 100644 --- a/src/main/java/com/glxp/api/dao/auth/DeptUserDao.java +++ b/src/main/java/com/glxp/api/dao/auth/DeptUserDao.java @@ -16,6 +16,8 @@ public interface DeptUserDao { List selectJoinDeptUser(FilterDeptUserReqeust filterDeptUserReqeust); + List selectJoinDeptUserKey(FilterDeptUserReqeust filterDeptUserReqeust); + boolean delete(@Param("deptId") Long deptId, @Param("userId") Long userId); int deleteById(Integer id); diff --git a/src/main/java/com/glxp/api/dao/auth/InvWarehouseDao.java b/src/main/java/com/glxp/api/dao/auth/InvWarehouseDao.java index 4b5a65a6..d411dd6e 100644 --- a/src/main/java/com/glxp/api/dao/auth/InvWarehouseDao.java +++ b/src/main/java/com/glxp/api/dao/auth/InvWarehouseDao.java @@ -21,6 +21,11 @@ public interface InvWarehouseDao extends BaseMapperPlus getByWarePcode(@Param("parentCode") String parentCode); + boolean insertInvSubWarehouse(InvWarehouseEntity invWarehouseEntity); boolean updateInvSubWarehouse(InvWarehouseEntity invWarehouseEntity); @@ -96,6 +101,8 @@ public interface InvWarehouseDao extends BaseMapperPlus selectInvById(@Param("InvList") List InvList); + List selectLowWarehouseAll(@Param("pcode") String pCode); } diff --git a/src/main/java/com/glxp/api/dao/basic/BasicBusTypeChangeDao.java b/src/main/java/com/glxp/api/dao/basic/BasicBusTypeChangeDao.java index 652a0b2b..088aefdf 100644 --- a/src/main/java/com/glxp/api/dao/basic/BasicBusTypeChangeDao.java +++ b/src/main/java/com/glxp/api/dao/basic/BasicBusTypeChangeDao.java @@ -21,4 +21,5 @@ public interface BasicBusTypeChangeDao extends BaseMapper filterList(FilterBusTypeChangeRequest filterBusTypeChangeRequest); -} \ No newline at end of file + +} diff --git a/src/main/java/com/glxp/api/dao/inout/ReceiveDetailDao.java b/src/main/java/com/glxp/api/dao/inout/ReceiveDetailDao.java index c0258375..ffaf2e57 100644 --- a/src/main/java/com/glxp/api/dao/inout/ReceiveDetailDao.java +++ b/src/main/java/com/glxp/api/dao/inout/ReceiveDetailDao.java @@ -1,12 +1,14 @@ package com.glxp.api.dao.inout; import com.glxp.api.dao.BaseMapperPlus; +import com.glxp.api.entity.basic.BasicProductsEntity; import com.glxp.api.entity.inout.PurReceiveDetailEntity; import com.glxp.api.req.inout.FilterReceiveDetailRequest; import com.glxp.api.req.inout.UpdateReceiveDetailRequest; import com.glxp.api.res.inout.ReceiveDetailResponse; import com.glxp.api.res.inout.ReceiveResponse; import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; import java.util.List; @@ -17,5 +19,5 @@ public interface ReceiveDetailDao extends BaseMapperPlus selectByIdCode(List list); DeptEntity findDefault(Boolean advaceType, Boolean isDefault); DeptEntity selectMaxCode(FilterInvWarehouseRequest filterInvWarehouseRequest); @@ -35,6 +35,8 @@ public interface DeptService { boolean deleteById(String id); + List selectByPcode(String pcode); + List selectByNameList(String name); /** @@ -73,4 +75,10 @@ public interface DeptService { boolean updateTime(String code, Date updateTime); + List getDeptById( List ids); + + List selectupDeptAll(String pCode); + + List selectLowDeptAll(String pCode); + } diff --git a/src/main/java/com/glxp/api/service/auth/DeptUserService.java b/src/main/java/com/glxp/api/service/auth/DeptUserService.java index df853215..977f4b2a 100644 --- a/src/main/java/com/glxp/api/service/auth/DeptUserService.java +++ b/src/main/java/com/glxp/api/service/auth/DeptUserService.java @@ -13,6 +13,8 @@ public interface DeptUserService { List selectByUserId(Long userId); + List selectByUserIdKey(Long userId); + List selectJoinDeptUser(FilterDeptUserReqeust filterDeptUserReqeust); boolean delete(Long deptId, Long userId); diff --git a/src/main/java/com/glxp/api/service/auth/InvWarehouseService.java b/src/main/java/com/glxp/api/service/auth/InvWarehouseService.java index 35dd2420..7dfe6e0e 100644 --- a/src/main/java/com/glxp/api/service/auth/InvWarehouseService.java +++ b/src/main/java/com/glxp/api/service/auth/InvWarehouseService.java @@ -12,6 +12,10 @@ import java.util.List; public interface InvWarehouseService { + InvWarehouseEntity getByWareId( String id); + + List getByWarePcode(@Param("parentCode") String parentCode); + InvWarehouseEntity findById(String id); InvWarehouseEntity selectByThrCode(String code, String thirdSys); @@ -86,5 +90,9 @@ public interface InvWarehouseService { String selectParentIdByCode(String invCode); + List selectInvById(List InvList); + List findByLastTime(Date lastUpdateTime); + + List selectLowWarehouseAll(String pCode); } diff --git a/src/main/java/com/glxp/api/service/auth/impl/DeptServiceImpl.java b/src/main/java/com/glxp/api/service/auth/impl/DeptServiceImpl.java index f81197ef..b4a35958 100644 --- a/src/main/java/com/glxp/api/service/auth/impl/DeptServiceImpl.java +++ b/src/main/java/com/glxp/api/service/auth/impl/DeptServiceImpl.java @@ -22,6 +22,11 @@ public class DeptServiceImpl implements DeptService { @Resource DeptDao deptDao; + @Override + public List selectByIdCode(List list) { + return deptDao.selectByIdCode(list); + } + @Override public DeptEntity findDefault(Boolean advaceType, Boolean isDefault) { FilterInvWarehouseRequest filterInvWarehouseRequest = new FilterInvWarehouseRequest(); @@ -138,6 +143,11 @@ public class DeptServiceImpl implements DeptService { return deptDao.deleteById(id); } + @Override + public List selectByPcode(String pcode) { + return deptDao.selectByPcode(pcode); + } + @Override public void importInvWarehouse(List invWarehouseEntities) { if (CollUtil.isNotEmpty(invWarehouseEntities)) { @@ -173,4 +183,20 @@ public class DeptServiceImpl implements DeptService { public boolean updateTime(String code, Date updateTime) { return deptDao.updateTime(code, updateTime); } + + @Override + public List getDeptById(List ids) { + return deptDao.getDeptById(ids); + } + + @Override + public List selectupDeptAll(String pCode) { + return deptDao.selectupDeptAll(pCode); + } + + @Override + public List selectLowDeptAll(String pCode) { + return deptDao.selectLowDeptAll(pCode); + } + } diff --git a/src/main/java/com/glxp/api/service/auth/impl/DeptUserServiceImpl.java b/src/main/java/com/glxp/api/service/auth/impl/DeptUserServiceImpl.java index 5e7fda2e..4d2b3f7a 100644 --- a/src/main/java/com/glxp/api/service/auth/impl/DeptUserServiceImpl.java +++ b/src/main/java/com/glxp/api/service/auth/impl/DeptUserServiceImpl.java @@ -37,6 +37,13 @@ public class DeptUserServiceImpl implements DeptUserService { return deptUserDao.selectJoinDeptUser(filterDeptUserReqeust); } + @Override + public List selectByUserIdKey(Long userId) { + FilterDeptUserReqeust filterDeptUserReqeust = new FilterDeptUserReqeust(); + filterDeptUserReqeust.setUserId(userId); + return deptUserDao.selectJoinDeptUserKey(filterDeptUserReqeust); + } + @Override public List selectJoinDeptUser(FilterDeptUserReqeust filterDeptUserReqeust) { if (filterDeptUserReqeust.getPage() != null) { diff --git a/src/main/java/com/glxp/api/service/auth/impl/InvWarehouseServiceImpl.java b/src/main/java/com/glxp/api/service/auth/impl/InvWarehouseServiceImpl.java index b3144530..f9a0b38d 100644 --- a/src/main/java/com/glxp/api/service/auth/impl/InvWarehouseServiceImpl.java +++ b/src/main/java/com/glxp/api/service/auth/impl/InvWarehouseServiceImpl.java @@ -35,6 +35,16 @@ public class InvWarehouseServiceImpl implements InvWarehouseService { @Resource private ThrSystemDao thrSystemDao; + @Override + public InvWarehouseEntity getByWareId(String id) { + return invWarehouseDao.getByWareId(id); + } + + @Override + public List getByWarePcode(String parentCode) { + return invWarehouseDao.getByWarePcode(parentCode); + } + @Override public InvWarehouseEntity findById(String id) { FilterInvSubWarehouseRequest filterInvSubWarehouseRequest = new FilterInvSubWarehouseRequest(); @@ -235,8 +245,18 @@ public class InvWarehouseServiceImpl implements InvWarehouseService { return invWarehouseDao.selectParentIdByCode(invCode); } + @Override + public List selectInvById(List InvList) { + return invWarehouseDao.selectInvById(InvList); + } + @Override public List findByLastTime(Date lastUpdateTime) { return invWarehouseDao.selectList(new QueryWrapper().gt("updateTime", lastUpdateTime)); } + + @Override + public List selectLowWarehouseAll(String pCode) { + return invWarehouseDao.selectLowWarehouseAll(pCode); + } } diff --git a/src/main/java/com/glxp/api/service/basic/IBasicBusTypeChangeService.java b/src/main/java/com/glxp/api/service/basic/IBasicBusTypeChangeService.java index 39bfac03..b8cbac5e 100644 --- a/src/main/java/com/glxp/api/service/basic/IBasicBusTypeChangeService.java +++ b/src/main/java/com/glxp/api/service/basic/IBasicBusTypeChangeService.java @@ -1,7 +1,6 @@ package com.glxp.api.service.basic; import com.glxp.api.entity.basic.BasicBusTypeChangeEntity; -import com.glxp.api.entity.basic.BasicBussinessTypeEntity; import com.glxp.api.req.basic.FilterBusTypeChangeRequest; import com.glxp.api.res.basic.BasicBusTypeChangeResponse; diff --git a/src/main/java/com/glxp/api/service/basic/IBasicBusTypePreService.java b/src/main/java/com/glxp/api/service/basic/IBasicBusTypePreService.java index 8c3aa4c0..3822a371 100644 --- a/src/main/java/com/glxp/api/service/basic/IBasicBusTypePreService.java +++ b/src/main/java/com/glxp/api/service/basic/IBasicBusTypePreService.java @@ -5,6 +5,7 @@ import com.glxp.api.req.basic.FilterBusTypeChangeRequest; import com.glxp.api.req.basic.FilterBusTypePreRequest; import com.glxp.api.res.basic.BasicBusTypePreResponse; +import java.util.Date; import java.util.List; /** @@ -79,4 +80,6 @@ public interface IBasicBusTypePreService { * @return */ boolean verifyExists(BasicBusTypePreEntity basicBusTypePreEntity); + + List findByLastTime(Date lastUpdateTime); } diff --git a/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypeChangeServiceImpl.java b/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypeChangeServiceImpl.java index a37faad5..7812a8b3 100644 --- a/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypeChangeServiceImpl.java +++ b/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypeChangeServiceImpl.java @@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageHelper; import com.glxp.api.dao.basic.BasicBusTypeChangeDao; import com.glxp.api.entity.basic.BasicBusTypeChangeEntity; -import com.glxp.api.entity.basic.BasicBussinessTypeEntity; import com.glxp.api.req.basic.FilterBusTypeChangeRequest; import com.glxp.api.res.basic.BasicBusTypeChangeResponse; import com.glxp.api.service.auth.CustomerService; diff --git a/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypePreServiceImpl.java b/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypePreServiceImpl.java index 2b898f0d..856aad5a 100644 --- a/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypePreServiceImpl.java +++ b/src/main/java/com/glxp/api/service/basic/impl/BasicBusTypePreServiceImpl.java @@ -105,6 +105,10 @@ public class BasicBusTypePreServiceImpl implements IBasicBusTypePreService { return false; } + @Override + public List findByLastTime(Date lastUpdateTime) { + return basicBusTypePreDao.selectList(new QueryWrapper().gt("updateTime", lastUpdateTime)); + } /** * 设置创建/更新信息 * diff --git a/src/main/java/com/glxp/api/service/inout/IoAddInoutService.java b/src/main/java/com/glxp/api/service/inout/IoAddInoutService.java index aaebf94b..aa276a9c 100644 --- a/src/main/java/com/glxp/api/service/inout/IoAddInoutService.java +++ b/src/main/java/com/glxp/api/service/inout/IoAddInoutService.java @@ -326,7 +326,7 @@ public class IoAddInoutService { IoOrderEntity order = orderService.findByBillNo(orderId); BasicBussinessTypeEntity bussinessTypeEntity = basicBussinessTypeService.findByAction(order.getAction()); if (StrUtil.isBlank(bussinessTypeEntity.getSupplementOrderType())) { - return ResultVOUtils.error(ResultEnum.valueOf("此类型单据不可补单")); + return ResultVOUtils.error(500,"此单据类型不可补单"); } IoOrderEntity supplementOrder = new IoOrderEntity(); BeanUtil.copyProperties(order, supplementOrder); diff --git a/src/main/java/com/glxp/api/service/inout/ReceiveService.java b/src/main/java/com/glxp/api/service/inout/ReceiveService.java index f0592f6d..bd7aed7c 100644 --- a/src/main/java/com/glxp/api/service/inout/ReceiveService.java +++ b/src/main/java/com/glxp/api/service/inout/ReceiveService.java @@ -1,5 +1,6 @@ package com.glxp.api.service.inout; +import com.glxp.api.entity.basic.BasicProductsEntity; import com.glxp.api.entity.inout.PurReceiveEntity; import com.glxp.api.req.inout.FilterReceiveRequest; import com.glxp.api.res.inout.ReceiveResponse; @@ -21,4 +22,7 @@ public interface ReceiveService { boolean delReceive(String orderIdFk); + + + } diff --git a/src/main/java/com/glxp/api/service/inout/ReceivedetailService.java b/src/main/java/com/glxp/api/service/inout/ReceivedetailService.java index 15e4c842..b097e0b3 100644 --- a/src/main/java/com/glxp/api/service/inout/ReceivedetailService.java +++ b/src/main/java/com/glxp/api/service/inout/ReceivedetailService.java @@ -1,5 +1,6 @@ package com.glxp.api.service.inout; +import com.glxp.api.entity.basic.BasicProductsEntity; import com.glxp.api.entity.inout.PurReceiveDetailEntity; import com.glxp.api.req.inout.FilterReceiveDetailRequest; import com.glxp.api.req.inout.FilterReceiveRequest; @@ -22,5 +23,5 @@ public interface ReceivedetailService { boolean delDetail(String id); - + BasicProductsEntity selectIoOrderDetailBiz(long id); } diff --git a/src/main/java/com/glxp/api/service/inout/impl/ReceiveDetailServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/ReceiveDetailServiceImpl.java index 2562bd1b..8e046072 100644 --- a/src/main/java/com/glxp/api/service/inout/impl/ReceiveDetailServiceImpl.java +++ b/src/main/java/com/glxp/api/service/inout/impl/ReceiveDetailServiceImpl.java @@ -3,6 +3,7 @@ package com.glxp.api.service.inout.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageHelper; import com.glxp.api.dao.inout.ReceiveDetailDao; +import com.glxp.api.entity.basic.BasicProductsEntity; import com.glxp.api.entity.inout.PurReceiveDetailEntity; import com.glxp.api.req.inout.FilterReceiveDetailRequest; import com.glxp.api.req.inout.UpdateReceiveDetailRequest; @@ -55,5 +56,8 @@ public class ReceiveDetailServiceImpl implements ReceivedetailService { return true; } - + @Override + public BasicProductsEntity selectIoOrderDetailBiz(long id) { + return receiveDetailDao.selectIoOrderDetailBiz(id); + } } diff --git a/src/main/java/com/glxp/api/service/inout/impl/ReceiveServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/ReceiveServiceImpl.java index f9e07174..866506ba 100644 --- a/src/main/java/com/glxp/api/service/inout/impl/ReceiveServiceImpl.java +++ b/src/main/java/com/glxp/api/service/inout/impl/ReceiveServiceImpl.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageHelper; import com.glxp.api.dao.inout.ReceiveDao; import com.glxp.api.dao.inout.ReceiveDetailDao; +import com.glxp.api.entity.basic.BasicProductsEntity; import com.glxp.api.entity.inout.PurReceiveDetailEntity; import com.glxp.api.entity.inout.PurReceiveEntity; import com.glxp.api.req.inout.FilterReceiveRequest; @@ -38,9 +39,9 @@ public class ReceiveServiceImpl implements ReceiveService { @Override public int updateOrder(PurReceiveEntity purReceiveEntity) { - QueryWrapper ew=new QueryWrapper<>(); - ew.eq("billNo",purReceiveEntity.getBillNo()); - return receiveDao.update(purReceiveEntity,ew); + QueryWrapper ew = new QueryWrapper<>(); + ew.eq("billNo", purReceiveEntity.getBillNo()); + return receiveDao.update(purReceiveEntity, ew); } @Override @@ -67,4 +68,6 @@ public class ReceiveServiceImpl implements ReceiveService { } + + } diff --git a/src/main/java/com/glxp/api/service/thrsys/impl/ThrSystemDetailServiceImpl.java b/src/main/java/com/glxp/api/service/thrsys/impl/ThrSystemDetailServiceImpl.java index 752c1505..f96c99d1 100644 --- a/src/main/java/com/glxp/api/service/thrsys/impl/ThrSystemDetailServiceImpl.java +++ b/src/main/java/com/glxp/api/service/thrsys/impl/ThrSystemDetailServiceImpl.java @@ -50,10 +50,11 @@ public class ThrSystemDetailServiceImpl implements ThrSystemDetailService { return data; } - @Transactional(rollbackFor = Exception.class) @Override public void updateInterfaceStatus(List list) { for (ThrSystemDetailEntity thrSystemDetailEntity : list) { + //请求默认0分钟 + thrSystemDetailEntity.setTime(0); thrSystemDetailDao.updateBasicThirdSysDetail(thrSystemDetailEntity); } } diff --git a/src/main/java/com/glxp/api/task/AsyncFetchUdiTask.java b/src/main/java/com/glxp/api/task/AsyncFetchUdiTask.java index ccf16ef4..ec0dfd45 100644 --- a/src/main/java/com/glxp/api/task/AsyncFetchUdiTask.java +++ b/src/main/java/com/glxp/api/task/AsyncFetchUdiTask.java @@ -15,7 +15,7 @@ import com.glxp.api.entity.system.ScheduledEntity; import com.glxp.api.idc.service.IdcService; import com.glxp.api.req.system.ScheduledRequest; - +// //@Component //@EnableScheduling public class AsyncFetchUdiTask implements SchedulingConfigurer { diff --git a/src/main/java/com/glxp/api/task/AsyncUdiTask.java b/src/main/java/com/glxp/api/task/AsyncUdiTask.java index 8db9661d..c00ae317 100644 --- a/src/main/java/com/glxp/api/task/AsyncUdiTask.java +++ b/src/main/java/com/glxp/api/task/AsyncUdiTask.java @@ -15,7 +15,7 @@ import com.glxp.api.entity.system.ScheduledEntity; import com.glxp.api.idc.service.IdcService; import com.glxp.api.req.system.ScheduledRequest; - +// //@Component //@EnableScheduling public class AsyncUdiTask implements SchedulingConfigurer { diff --git a/src/main/resources/mybatis/mapper/auth/DeptDao.xml b/src/main/resources/mybatis/mapper/auth/DeptDao.xml index eacf395c..40e9d0f2 100644 --- a/src/main/resources/mybatis/mapper/auth/DeptDao.xml +++ b/src/main/resources/mybatis/mapper/auth/DeptDao.xml @@ -94,6 +94,21 @@ + + + select * + from auth_dept + where id in + + #{item} + + + + + select name from auth_dept where code = #{code} + + + diff --git a/src/main/resources/mybatis/mapper/auth/DeptUserDao.xml b/src/main/resources/mybatis/mapper/auth/DeptUserDao.xml index 6cfb932f..123fa62a 100644 --- a/src/main/resources/mybatis/mapper/auth/DeptUserDao.xml +++ b/src/main/resources/mybatis/mapper/auth/DeptUserDao.xml @@ -17,6 +17,30 @@ + + + + + @@ -373,4 +386,26 @@ from auth_warehouse where code = #{invCode} + + + + diff --git a/src/main/resources/mybatis/mapper/basic/BasicBusTypeChangeDao.xml b/src/main/resources/mybatis/mapper/basic/BasicBusTypeChangeDao.xml index 4f5748d8..9560b4ea 100644 --- a/src/main/resources/mybatis/mapper/basic/BasicBusTypeChangeDao.xml +++ b/src/main/resources/mybatis/mapper/basic/BasicBusTypeChangeDao.xml @@ -2,10 +2,11 @@ @@ -70,7 +70,7 @@ vailGroupBuy, busType, inStock, actionType, thrCheckEnable, thrCheckWebNew, thrCheckPdaUn, thrCheckPdaEd, thrCheckUdims, thrCheckPc, thrCheckSp, thrCheckChange, thrCheckBalance, thrCheckCopy, fillCodeRel, checkVailDate, - checkExpire, checkCertExpire, preInBackAction, backPreinType, checkPreInOrders) + checkExpire, checkCertExpire, preInBackAction, backPreinType, checkPreInOrders,sortNum) values (#{mainAction}, #{action}, #{name}, #{enable}, #{remark}, #{thirdSysFk}, #{genUnit}, #{innerOrder}, #{secCheckEnable}, #{checkEnable}, #{checkUdims}, #{checkPdaEd}, #{checkPdaUn}, #{checkPc}, #{checkWebNew}, #{checkSp}, #{checkChange}, #{secCheckUdims}, #{secCheckPdaEd}, #{secCheckPdaUn}, @@ -82,7 +82,7 @@ #{vailGroupBuy}, #{busType}, #{inStock}, #{actionType}, #{thrCheckEnable}, #{thrCheckWebNew}, #{thrCheckPdaUn}, #{thrCheckPdaEd}, #{thrCheckUdims}, #{thrCheckPc}, #{thrCheckSp}, #{thrCheckChange}, #{thrCheckBalance}, #{thrCheckCopy}, #{fillCodeRel}, #{checkVailDate}, - #{checkExpire}, #{checkCertExpire}, #{preInBackAction}, #{backPreinType}, #{checkPreInOrders}) + #{checkExpire}, #{checkCertExpire}, #{preInBackAction}, #{backPreinType}, #{checkPreInOrders}, #{sortNum}) UPDATE pur_receive_detail - orderIdFk=#{orderIdFk}, - relIdFk=#{relIdFk}, - nameCode=#{nameCode}, - count=#{count}, - supId=#{supId}, - productDate=#{productDate}, - batchNo=#{batchNo}, - expireDate=#{expireDate}, + + orderIdFk=#{orderIdFk}, + + + relIdFk=#{relIdFk}, + + + nameCode=#{nameCode}, + + + count=#{count}, + + + supId=#{supId}, + + + productDate=#{productDate}, + + + batchNo=#{batchNo}, + + + expireDate=#{expireDate}, + WHERE id = #{id} + + diff --git a/src/main/resources/mybatis/mapper/thrsys/ThrSystemDetailDao.xml b/src/main/resources/mybatis/mapper/thrsys/ThrSystemDetailDao.xml index fbc6227f..dc79e907 100644 --- a/src/main/resources/mybatis/mapper/thrsys/ThrSystemDetailDao.xml +++ b/src/main/resources/mybatis/mapper/thrsys/ThrSystemDetailDao.xml @@ -14,6 +14,7 @@ name=#{name}, fromType=#{fromType}, thirdSysFk=#{thirdSysFk}, + time=#{time}, WHERE id=#{id} diff --git a/src/main/resources/schemas/schema_v2.1.sql b/src/main/resources/schemas/schema_v2.1.sql index 82ca826f..116bb89e 100644 --- a/src/main/resources/schemas/schema_v2.1.sql +++ b/src/main/resources/schemas/schema_v2.1.sql @@ -66,8 +66,8 @@ CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'checkExpire', 'tinyint', 1); CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'checkCertExpire', 'tinyint', 1); CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'preInBackAction', 'varchar(255) ', 1); CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'backPreinType', 'tinyint', 1); -CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'checkPreInOrders', 'varchar(255)', 1); -CALL Pro_Temp_ColumnWork('basic_bustype_pre', 'createType', 'tinyint', 1); + + CALL Pro_Temp_ColumnWork('pur_delivery_detail', 'batchNo', 'varchar(255) ', 1); CALL Pro_Temp_ColumnWork('pur_delivery_detail', 'productDate', 'varchar(255) ', 1); @@ -186,6 +186,14 @@ CALL Pro_Temp_ColumnWork('sys_pdf_template_relevance_biz', 'updateTime', 'dateti CALL Pro_Temp_ColumnWork('sys_pdf_template_relevance_label', 'updateTime', 'datetime', 1); CALL Pro_Temp_ColumnWork('sys_pdf_template_relevance_statemen', 'updateTime', 'datetime', 1); +CALL Pro_Temp_ColumnWork('thr_system_detail', 'time', 'int(5)', 1); + + +CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'advancePreIn', 'tinyint', 1); +CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'sortNum', 'int', 1); +CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'preInBackAction', 'varchar(255) ', 1); +CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'backPreinType', 'tinyint', 1); +CALL Pro_Temp_ColumnWork('basic_bussiness_type', 'checkPreInOrders', 'varchar(255)', 1); # CALL Pro_Temp_ColumnWork('sup_cert_set', 'foreign', 'tinyint', 3); # CALL Pro_Temp_ColumnWork('sup_cert_set', 'needForeign', 'tinyint', 1);