From 494bc82a715bd910353401c24ecde75b7c68ec31 Mon Sep 17 00:00:00 2001 From: "15989082884@163.com" <15989082884@163.com> Date: Mon, 22 Jan 2024 09:22:37 +0800 Subject: [PATCH] =?UTF-8?q?=E7=AC=AC=E4=B8=89=E6=96=B9=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3=EF=BC=8C=E6=B7=BB=E5=8A=A0=E5=92=8C=E6=9B=B4?= =?UTF-8?q?=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../third/PortalSupplierController.java | 1271 +---------------- 1 file changed, 56 insertions(+), 1215 deletions(-) diff --git a/src/main/java/com/qs/serve/modules/third/PortalSupplierController.java b/src/main/java/com/qs/serve/modules/third/PortalSupplierController.java index 11f9a423..da40de29 100644 --- a/src/main/java/com/qs/serve/modules/third/PortalSupplierController.java +++ b/src/main/java/com/qs/serve/modules/third/PortalSupplierController.java @@ -1,4 +1,4 @@ -package com.qs.serve.modules.third.util; +package com.qs.serve.modules.third; import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -26,6 +26,7 @@ import com.qs.serve.modules.bms.mapper.BmsSupplierMapper; import com.qs.serve.modules.bms.service.*; import com.qs.serve.modules.his.entity.HisUserSupplier; import com.qs.serve.modules.his.service.HisUserSupplierService; +import com.qs.serve.modules.sys.entity.SysSyncLog; import com.qs.serve.modules.sys.entity.SysUser; import com.qs.serve.modules.sys.entity.bo.SysRelateSuppliersParam; import com.qs.serve.modules.sys.entity.bo.SysRelateSuppliersParam2; @@ -33,15 +34,18 @@ import com.qs.serve.modules.sys.entity.dto.SysUserSimpleVo; import com.qs.serve.modules.sys.entity.dto.SysUserVo; import com.qs.serve.modules.sys.service.SysAttachService; import com.qs.serve.modules.sys.service.SysPostUserService; +import com.qs.serve.modules.sys.service.SysSyncLogService; import com.qs.serve.modules.sys.service.SysUserService; import com.qs.serve.modules.tbs.common.TbsCenterType; import com.qs.serve.modules.tbs.entity.TbsBudget; import com.qs.serve.modules.tbs.service.TbsBudgetService; +import com.qs.serve.modules.third.entity.ProcessCreateCostApplyBo; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.web.bind.annotation.*; +import javax.servlet.http.HttpServletRequest; import javax.validation.Valid; import java.time.LocalDateTime; import java.util.*; @@ -55,605 +59,52 @@ import java.util.stream.Collectors; @Slf4j @AllArgsConstructor @RestController -@RequestMapping("bms/supplier") +@RequestMapping("thirty/supplier") public class PortalSupplierController { private BmsSupplierService bmsSupplierService; - private BmsSupplierComRegionMapper supplierComRegionMapper; - private BmsSupplierAddressService bmsSupplierAddressService; - private BmsSupplierVisitAddressService bmsSupplierVisitAddressService; - private BmsSupplierContactsService bmsSupplierContactsService; - private BmsSupplierChannelService bmsSupplierChannelService; - private BmsRegionService bmsRegionService; - private BmsRegion2Service bmsRegion2Service; - private SysUserService sysUserService; - private SysPostUserService sysPostUserService; - private BmsSupplierMapper bmsSupplierMapper; - private HisUserSupplierService hisUserSupplierService; - private RedisService redisService; - private TbsBudgetService tbsBudgetService; - private BmsSupplierMyController supplierMyController; - private SysAttachService attachService; - /** - * 翻页查询 - * @param param - * @return - */ - @PostMapping("/list") - @PreAuthorize("hasRole('bms:supplier:query')") - public R> getList(@RequestBody BmsSupplier param){ - - param = this.initQueryParam(param); - - String userId = param.getUserId(); - if(param.getLoadByCurrent()!=null&¶m.getLoadByCurrent().equals(1)){ - List userIds = sysPostUserService.listByChildIds(userId); - userIds.add(userId); - param.setSelectUserIds(userIds); - }else { - param.setCurrUserId(userId); - } - - List list = bmsSupplierService.selectSupplierList(param); - initSupplierList(list); - initParentList(list); - for (BmsSupplier supplier : list) { - supplier.setMasterFlag(0); - if(supplier.getUserId()!=null&&supplier.getUserId().equals(userId)){ - supplier.setMasterFlag(1); - break; - } - } - return R.ok(list); - } - - - /** - * 翻页查询，值=1，过滤当前用户负责数据 - * @param param - * @return - */ - @PostMapping("/page") - @PreAuthorize("hasRole('bms:supplier:query')") - public R> getPage(@RequestBody BmsSupplier param){ - param = this.initQueryParam(param); - - if(param.getLoadByCurrent()!=null&¶m.getLoadByCurrent().equals(1)){ - PageUtil.setPageSize(param.getPageSize()+""); - PageUtil.setPageNum(param.getPageNum()+""); - return supplierMyController.getUnderlingAndMinePage(param); - } - - PageHelper.startPage(param.getPageNum(),param.getPageSize()); - List list = bmsSupplierService.selectSupplierList(param); - initSupplierList(list); - initParentList(list); - return R.byPageHelperList(list); - } - - @PostMapping("/exportExcel") - @PreAuthorize("hasRole('bms:supplier:query')") - public R> exportExcel(@RequestBody BmsSupplier param){ - - param = this.initQueryParam(param); - - List list = bmsSupplierService.selectSupplierList(param); - initSupplierList(list); - initParentList(list); - - List boList = list.stream().map(a->BmsSupplierExcelBo.toExcelBo(a)).collect(Collectors.toList()); - - return R.ok(boList); - } - - private BmsSupplier initQueryParam(BmsSupplier param){ - //兼容 前端接错参数 - if(param.getSupplierName()!=null){ - param.setName(param.getSupplierName()); - } - if(param.getSupplierCode()!=null){ - param.setCode(param.getSupplierCode()); - } - - if(StringUtils.hasText(param.getRegion2Label())){ - LambdaQueryWrapper region2LambdaQueryWrapper = new LambdaQueryWrapper<>(); - region2LambdaQueryWrapper.like(BmsRegion2::getPathNames,param.getRegion2Label()); - List region2List = bmsRegion2Service.list(region2LambdaQueryWrapper); - if(region2List.size()>0) { - param.setRegion2Ids(region2List.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setRegion2Ids(Arrays.asList("#")); - } - } - if(StringUtils.hasText(param.getSearchRegion2FirstName())){ - LambdaQueryWrapper region2LambdaQueryWrapper = new LambdaQueryWrapper<>(); - region2LambdaQueryWrapper.like(BmsRegion2::getName,param.getSearchRegion2FirstName()); - List region2List = bmsRegion2Service.list(region2LambdaQueryWrapper); - if(region2List.size()>0) { - param.setSearchRegion2First(region2List.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setSearchRegion2First(Arrays.asList("#")); - } - } - if(StringUtils.hasText(param.getSearchRegion2SecondName())){ - LambdaQueryWrapper region2LambdaQueryWrapper = new LambdaQueryWrapper<>(); - region2LambdaQueryWrapper.like(BmsRegion2::getName,param.getSearchRegion2SecondName()); - List region2List = bmsRegion2Service.list(region2LambdaQueryWrapper); - if(region2List.size()>0) { - param.setSearchRegion2Second(region2List.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setSearchRegion2Second(Arrays.asList("#")); - } - } - if(StringUtils.hasText(param.getSearchRegion2ThirdName())){ - LambdaQueryWrapper region2LambdaQueryWrapper = new LambdaQueryWrapper<>(); - region2LambdaQueryWrapper.like(BmsRegion2::getName,param.getSearchRegion2ThirdName()); - List region2List = bmsRegion2Service.list(region2LambdaQueryWrapper); - if(region2List.size()>0) { - param.setSearchRegion2Third(region2List.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setSearchRegion2Third(Arrays.asList("#")); - } - } - - if(StringUtils.hasText(param.getRegionLabel())){ - LambdaQueryWrapper regionLambdaQueryWrapper = new LambdaQueryWrapper<>(); - regionLambdaQueryWrapper.like(BmsRegion::getPathNames,param.getRegionLabel()); - List regionList = bmsRegionService.list(regionLambdaQueryWrapper); - if(regionList.size()>0) { - param.setRegionIds(regionList.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setRegion2Ids(Arrays.asList("#")); - } - } - if(StringUtils.hasText(param.getSearchRegionFirstName())){ - LambdaQueryWrapper regionLambdaQueryWrapper = new LambdaQueryWrapper<>(); - regionLambdaQueryWrapper.like(BmsRegion::getName,param.getSearchRegionFirstName()); - List regionList = bmsRegionService.list(regionLambdaQueryWrapper); - if(regionList.size()>0) { - param.setSearchRegionFirst(regionList.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setSearchRegionFirst(Arrays.asList("#")); - } - } - if(StringUtils.hasText(param.getSearchRegionSecondName())){ - LambdaQueryWrapper regionLambdaQueryWrapper = new LambdaQueryWrapper<>(); - regionLambdaQueryWrapper.like(BmsRegion::getName,param.getSearchRegionSecondName()); - List regionList = bmsRegionService.list(regionLambdaQueryWrapper); - if(regionList.size()>0) { - param.setSearchRegionSecond(regionList.stream().map(a -> a.getId()).collect(Collectors.toList())); - }else{ - param.setSearchRegionSecond(Arrays.asList("#")); - } - } - return param; - } - - /** - * 树查询 - * @param param - * @return - */ - @GetMapping("/tree") - @PreAuthorize("hasRole('bms:supplier:query')") - public R getTree(BmsSupplier param){ - String json = redisService.getString(RedisCacheKeys.SUPPLIER_RELATE_TREE); - if(json==null){ - List list = bmsSupplierService.selectSupplierList(param); - initSupplierList(list); - List list2 = list.stream().map(supplier->{ - BmsSupplierTreeVo treeNode = CopierUtil.copy(supplier,new BmsSupplierTreeVo()); - treeNode.setId(supplier.getId()); - treeNode.setParentId(supplier.getPid()); - treeNode.setSort(0); - return treeNode; - }).collect(Collectors.toList()); - list2 = TreeUtil.buildByRecursive(list2,TreeUtil.DEFAULT_PID_STRING); - String jsonString = JsonUtil.objectToJson(list2); - redisService.set(RedisCacheKeys.SUPPLIER_RELATE_TREE,jsonString); - return R.ok(list2); - } - return R.ok(JSONArray.parseArray(json)); - } - - - - /** - * 更改客户授权(用户页面) - * @return - */ - @PostMapping("/relateSuppliers") - @PreAuthorize("hasRole('bms:supplier:update')") - public R relateSuppliers(@RequestBody @Valid SysRelateSuppliersParam param){ - List supplierIds = param.getSupplierIds(); - String userId = param.getUserId(); - List list = bmsSupplierService.listByIds(supplierIds); - for (BmsSupplier supplier : list) { - if(userId.equals(supplier.getUserId())){ - continue; - } - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - boolean exist = false; - for (String otherUserId : supplier.getOtherUserIds()) { - if(userId.equals(otherUserId)){ - exist = true; - break; - } - } - if(exist){ - continue; - } - } - List otherUserIds = new ArrayList<>(); - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - otherUserIds.addAll(Arrays.asList(supplier.getOtherUserIds())); - } - otherUserIds.add(userId); - //更新次要负责人 - BmsSupplier supplierParam = new BmsSupplier(); - supplierParam.setId(supplier.getId()); - supplierParam.setOtherUserIds(otherUserIds.toArray(new String[otherUserIds.size()])); - bmsSupplierService.updateById(supplierParam); - } - initSupplierOtherInfo(supplierIds); - //清空临时表 - hisUserSupplierService.cleanTable(); - return R.ok(); - } - - /** - * 更改客户授权(客户页面) - * @return - */ - @PostMapping("/relateSuppliers2") - @PreAuthorize("hasRole('bms:supplier:update')") - public R relateSuppliers2(@RequestBody SysRelateSuppliersParam2 param){ - BmsSupplier supplier = bmsSupplierService.getById(param.getSupplierId()); - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - for (String userId : supplier.getOtherUserIds()) { - param.getUserIds().add(userId); - } - } - List uids = param.getUserIds().stream() - .filter(uid->supplier.getUserId()==null || !supplier.getUserId().equals(uid)) - .collect(Collectors.toList()); - BmsSupplier bmsSupplier = new BmsSupplier(); - bmsSupplier.setId(param.getSupplierId().toString()); - bmsSupplier.setOtherUserIds(param.getUserIds()==null?new String[]{}:uids.toArray(new String[uids.size()])); - bmsSupplierService.updateById(bmsSupplier); - initSupplierOtherInfo(Arrays.asList(supplier.getId())); - //清空临时表 - hisUserSupplierService.cleanTable(); - this.saveTOHis(param.getUserIds(), supplier); - return R.ok(); - } - - - /** - * 删除客户分配 - * @return - */ - @PostMapping("/relateRemove") - @PreAuthorize("hasRole('bms:supplier:update')") - public R relateRemove(@RequestBody SysRelateSuppliersParam param){ - List supplierIds = param.getSupplierIds(); - String userId = param.getUserId(); - List list = bmsSupplierService.listByIds(supplierIds); - for (BmsSupplier supplier : list) { - if(userId.equals(supplier.getUserId())){ - bmsSupplierMapper.removeRelateUserInfo(Long.parseLong(supplier.getId())); - } - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - List otherUserIds = new ArrayList<>(); - for (String otherUserId : supplier.getOtherUserIds()) { - if(userId.equals(otherUserId)){ - continue; - } - otherUserIds.add(otherUserId); - } - //更新次要负责人 - BmsSupplier supplierParam = new BmsSupplier(); - supplierParam.setId(supplier.getId()); - supplierParam.setOtherUserIds(otherUserIds.toArray(new String[otherUserIds.size()])); - bmsSupplierService.updateById(supplierParam); - } - } - initSupplierOtherInfo(supplierIds); - //清空临时表 - hisUserSupplierService.cleanTable(); - redisService.remove(RedisCacheKeys.SUPPLIER_RELATE_TREE); - return R.ok(); - } - - /** - * 删除客户分配 - * @return - */ - @PostMapping("/relateRemove2") - @PreAuthorize("hasRole('bms:supplier:update')") - public R relateRemove2(@RequestBody SysRelateSuppliersParam2 param){ - List userIds = param.getUserIds(); - BmsSupplier supplier = bmsSupplierService.getById(param.getSupplierId()); - for (String userId : userIds) { - if(supplier.getUserId()!=null && userId.equals(supplier.getUserId())){ - bmsSupplierMapper.removeRelateUserInfo(Long.parseLong(supplier.getId())); - } - } - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - List otherUserIds = new ArrayList<>(); - for (String otherUserId : supplier.getOtherUserIds()) { - if(!userIds.contains(otherUserId)){ - otherUserIds.add(otherUserId); - } - } - BmsSupplier supplier1 = new BmsSupplier(); - supplier1.setId(supplier.getId()); - supplier1.setOtherUserIds(otherUserIds.toArray(new String[otherUserIds.size()])); - if(otherUserIds.size()<1){ - supplier1.setOtherUserNames(""); - supplier1.setOtherUserCodes(""); - }else { - List sysUsers = sysUserService.listByIds(otherUserIds); - String names = sysUsers.stream().map(SysUser::getName).collect(Collectors.joining(",")); - String codes = sysUsers.stream().map(SysUser::getCode).collect(Collectors.joining(",")); - supplier1.setOtherUserNames(names); - supplier1.setOtherUserCodes(codes); - } - bmsSupplierService.updateById(supplier1); - } - initSupplierOtherInfo(Arrays.asList(supplier.getId())); - //清空临时表 - hisUserSupplierService.cleanTable(); - redisService.remove(RedisCacheKeys.SUPPLIER_RELATE_TREE); - //移除客户直属负责人 - LambdaQueryWrapper rmLqw = new LambdaQueryWrapper<>(); - rmLqw.in(HisUserSupplier::getUserId,userIds); - rmLqw.eq(HisUserSupplier::getSupplierId,supplier.getId()); - rmLqw.eq(HisUserSupplier::getType,2); - hisUserSupplierService.remove(rmLqw); - return R.ok(); - } + private SysSyncLogService sysSyncLogService; - /** - * 设置主要负责人 - * @param supplierId - * @param userId - * @return - */ - @GetMapping("/setMainUser") - @PreAuthorize("hasRole('bms:supplier:update')") - public R setMainUser(String supplierId,String userId){ - BmsSupplier supplier = bmsSupplierService.getById(supplierId); - if(supplier.getUserId()!=null&&supplier.getUserId().equals(userId)){ - return R.ok(); - } - SysUser sysUser = sysUserService.getById(userId); - BmsSupplier supplierParam = new BmsSupplier(); - supplierParam.setId(supplierId); - supplierParam.setUserId(sysUser.getId()); - supplierParam.setUserName(sysUser.getName()); - supplierParam.setUserCode(sysUser.getCode()); - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - List otherUserIds = new ArrayList<>(Arrays.asList(supplier.getOtherUserIds())); - if(supplier.getUserId() != null){ - otherUserIds.add(supplier.getUserId()); - } - otherUserIds = otherUserIds.stream().filter(uid->!uid.equals(userId)).collect(Collectors.toList()); - Set otherUserIdSet = new HashSet<>(otherUserIds); - String[] otherArr = otherUserIdSet.toArray(new String[otherUserIdSet.size()]); - supplierParam.setOtherUserIds(otherArr); - } - bmsSupplierService.updateById(supplierParam); - initSupplierOtherInfo(Arrays.asList(supplier.getId())); - return R.ok(); - } - - - - /** - * 移除主要负责人 - * @param supplierId - * @return - */ - @GetMapping("/setOtherUser") - @PreAuthorize("hasRole('bms:supplier:update')") - public R setOtherUser(Long supplierId){ - BmsSupplier supplier = bmsSupplierService.getById(supplierId); - List userIds = new ArrayList<>(); - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - userIds = Arrays.asList(supplier.getOtherUserIds()); - } - if(supplier.getUserId()==null){ - return R.ok(); - } - Set otherUserIdSet = new HashSet<>(userIds); - otherUserIdSet.add(supplier.getUserId()); - String[] otherArr = otherUserIdSet.toArray(new String[otherUserIdSet.size()]); - bmsSupplierMapper.removeRelateUserInfo(supplierId); - BmsSupplier bmsSupplier = new BmsSupplier(); - bmsSupplier.setId(supplier.getId()); - bmsSupplier.setOtherUserIds(otherArr); - bmsSupplierService.updateById(bmsSupplier); - //清空临时表 - hisUserSupplierService.cleanTable(); - initSupplierOtherInfo(Arrays.asList(supplierId.toString())); - return R.ok(); - } - - /** - * 获取负责人接口(用于后续成本中心) - * @param supplierId - * @return - */ - @GetMapping("/getMgrUser") - public R> getMgrUser(Long supplierId){ - BmsSupplier supplier = bmsSupplierService.getById(supplierId); - List userIds = new ArrayList<>(); - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - userIds = Arrays.asList(supplier.getOtherUserIds()); - } - Set otherUserIdSet = new HashSet<>(userIds); - if(supplier.getUserId()==null){ - otherUserIdSet.add(supplier.getUserId()); - } - if(otherUserIdSet.size()<1){ - return R.ok(); - } - List userList = sysUserService.listByIds(otherUserIdSet); - List sysUsers = userList.stream().map(SysUser::toSysUserVo).collect(Collectors.toList()); - return R.ok(sysUsers); - } - - /** - * 根据ID查询 - * @param id - * @return - */ - @GetMapping("/getById/{id}") - @SysLog(module = SystemModule.BASE, title = "供应商", biz = BizType.QUERY) - @PreAuthorize("hasRole('bms:supplier:query')") - public R getById(@PathVariable("id") String id,Integer loadRegionInfo){ - BmsSupplier bmsSupplier = bmsSupplierService.getById(id); - if(StringUtils.hasText(bmsSupplier.getPid())&&!bmsSupplier.getPid().equals("0")){ - BmsSupplier parentInfo = bmsSupplierService.getById(bmsSupplier.getPid()); - bmsSupplier.setParentRegionInfo(parentInfo); - }else { - bmsSupplier.setPid(null); - } - BmsRegion region = bmsRegionService.getById(bmsSupplier.getRegionLast()); - if(region!=null){ - bmsSupplier.setRegionLabel(region.getName()); - } - BmsRegion2 region2 = bmsRegion2Service.getById(bmsSupplier.getRegion2Last()); - if(region2!=null){ - bmsSupplier.setRegion2Label(region2.getName()); - } - List userVos = new ArrayList<>(); - if(bmsSupplier.getUserId()!=null){ - SysUser sysUser = sysUserService.getById(bmsSupplier.getUserId()); - SysUserSimpleVo simpleVo = sysUser.toSimpleVo(true); - simpleVo.setSupplierMainFlag(1); - userVos.add(simpleVo); - } - if(CollectionUtil.isNotEmpty(bmsSupplier.getOtherUserIds())){ - List userList = sysUserService.listByIds(Arrays.asList(bmsSupplier.getOtherUserIds())); - List userVos2 = userList.stream().map(ur->{ - SysUserSimpleVo simpleVo = ur.toSimpleVo(true); - simpleVo.setSupplierMainFlag(0); - return simpleVo; - }).collect(Collectors.toList()); - userVos.addAll(userVos2); - } - if(loadRegionInfo!=null&&loadRegionInfo.equals(1)){ - BmsRegion obj1 = bmsRegionService.getById(bmsSupplier.getRegionFirst()); - BmsRegion obj2 = bmsRegionService.getById(bmsSupplier.getRegionSecond()); - BmsRegion obj3 = bmsRegionService.getById(bmsSupplier.getRegionThird()); - BmsRegion obj4 = bmsRegionService.getById(bmsSupplier.getRegionFourthly()); - bmsSupplier.setRegionFirstInfo(obj1); - bmsSupplier.setRegionSecondInfo(obj2); - bmsSupplier.setRegionThirdInfo(obj3); - bmsSupplier.setRegionFourthlyInfo(obj4); - BmsRegion2 obj11 = bmsRegion2Service.getById(bmsSupplier.getRegion2First()); - BmsRegion2 obj22 = bmsRegion2Service.getById(bmsSupplier.getRegion2Second()); - BmsRegion2 obj33 = bmsRegion2Service.getById(bmsSupplier.getRegion2Third()); - BmsRegion2 obj44 = bmsRegion2Service.getById(bmsSupplier.getRegion2Fourthly()); - bmsSupplier.setRegion2FirstInfo(obj11); - bmsSupplier.setRegion2SecondInfo(obj22); - bmsSupplier.setRegion2ThirdInfo(obj33); - bmsSupplier.setRegion2FourthlyInfo(obj44); - } - if(bmsSupplier.getSupplierAttachIds()!=null&&bmsSupplier.getSupplierAttachIds().length>0){ - bmsSupplier.setSupplierAttachInfoList(attachService.listByIds(Arrays.asList(bmsSupplier.getSupplierAttachIds()))); - } - bmsSupplier.setUserVos(userVos); - return R.ok(bmsSupplier); - } - /** * 根据ID更新 * @param param * @return */ @PostMapping("/updateById") - @SysLog(module = SystemModule.BASE, title = "供应商", biz = BizType.UPDATE) @PreAuthorize("hasRole('bms:supplier:update')") - public R updateById(@RequestBody BmsSupplierBo param){ - if(param.getId()==null){ - return R.error("id不能为空"); - } - bmsSupplierService.edit(param); - redisService.remove(RedisCacheKeys.SUPPLIER_RELATE_TREE); - hisUserSupplierService.cleanTable(); - return R.ok(); - } - - /** - * 根据ID更新供应商标识 - * @apiNote (SupplierFlag,id)不能为空 - * @param param - * @return - */ - @PostMapping("/updateSupplierFlagById") - @SysLog(module = SystemModule.BASE, title = "供应商标识", biz = BizType.UPDATE) - public R updateSupplierFlagById(@RequestBody BmsSupplierBo param){ - if(param.getId()==null){ - return R.error("id不能为空"); + public R updateById(@RequestBody BmsSupplierBo param, HttpServletRequest request){ + SysSyncLog syncLog = new SysSyncLog(); + syncLog.setFromPlat("更新客户"); + syncLog.setUrl(request.getRequestURI()); + syncLog.setRequestJson(JsonUtil.objectToJson(param)); + syncLog.setEntityClass(BmsSupplierBo.class.getName()); + try { + ThirdTokenUtil.checkToken(request); + + if(param.getId()==null){ + Assert.throwEx("id不能为空"); + } + BmsSupplier supplier = new BmsSupplier(); + CopierUtil.copy(param,supplier); + bmsSupplierService.updateById(supplier); + syncLog.setSuccessStatus(1); + } catch (Exception e) { + log.error("更新客户===>{}", JsonUtil.objectToJson(param)); + syncLog.setFailReason(e.getMessage()); + sysSyncLogService.save(syncLog); + return R.error(e.getMessage()); + } + sysSyncLogService.save(syncLog); + if(syncLog.getSuccessStatus()!=null&&syncLog.getSuccessStatus().equals(1)){ + return R.ok(); } - BmsSupplier entity = new BmsSupplier(); - entity.setId(param.getId()); - entity.setSupplierFlag(param.getSupplierFlag()); - bmsSupplierService.updateById(entity); - return R.ok(); + return R.error("更新客户异常"); } - /** - * 更新父级ID - * @param param - * @return - */ - @PostMapping("/updateParent") - @SysLog(module = SystemModule.BASE, title = "供应商", biz = BizType.UPDATE) - @PreAuthorize("hasRole('bms:supplier:update')") - public R updateParent(@RequestBody BmsSupplierParentBo param){ - BmsSupplier supplier = new BmsSupplier(); - BmsSupplier supplierdb = null; - if(param.getId()!=null){ - supplier.setId(param.getId()); - supplierdb = bmsSupplierService.getById(param.getId()); - } - if(supplierdb!=null && !supplierdb.getPid().equals(param.getPid())){ - List childList = bmsSupplierService.listChildByPathIds(supplierdb.getPathIds()); - if(param.getPid()==null||param.getPid().equals("0")){ - supplier.setPid("0"); - supplier.setParentCode("0"); - supplier.setPathIds("0_"+supplier.getId()); - }else { - BmsSupplier parentNode = bmsSupplierService.getById(param.getPid()); - supplier.setPid(param.getPid()); - String[] pids = parentNode.getPathIds().split("_"); - for (String pid : pids) { - if(pid.equals(supplier.getId())){ - return R.error("数据出现循环递归，保存失败"); - } - } - supplier.setPathIds(parentNode.getPathIds()+"_"+supplier.getId()); - supplier.setParentCode(parentNode.getCode()); - } - for (BmsSupplier bmsSupplier : childList) { - BmsSupplier bmsSupplier2 = new BmsSupplier(); - bmsSupplier2.setPathIds(bmsSupplier.getPathIds().replace(supplierdb.getPathIds(),supplier.getPathIds())); - bmsSupplier2.setId(bmsSupplier.getId()); - bmsSupplierService.updateById(bmsSupplier2); - } - } - bmsSupplierService.updateById(supplier); - redisService.remove(RedisCacheKeys.SUPPLIER_RELATE_TREE); - return R.ok(); - } /** * 新增 @@ -661,643 +112,33 @@ public class PortalSupplierController { * @return */ @PostMapping("/save") - @SysLog(module = SystemModule.BASE, title = "供应商", biz = BizType.INSERT) @PreAuthorize("hasRole('bms:supplier:insert')") - public R save(@RequestBody @Valid BmsSupplierBo param){ - bmsSupplierService.edit(param); - //清空临时表 - hisUserSupplierService.cleanTable(); - redisService.remove(RedisCacheKeys.SUPPLIER_RELATE_TREE); - return R.ok(); - } - - /** - * 删除 - * @param id - * @return - */ - @DeleteMapping("/deleteById/{id}") - @SysLog(module = SystemModule.BASE, title = "供应商", biz = BizType.DELETE) - @PreAuthorize("hasRole('bms:supplier:delete')") - public R deleteById(@PathVariable("id") String id){ - if(bmsSupplierService.listChild(id).size()>0){ - return R.error("含有子客户无法删除"); - } - LambdaQueryWrapper budgetLambdaQueryWrapper = new LambdaQueryWrapper<>(); - budgetLambdaQueryWrapper.eq(TbsBudget::getCenterType, TbsCenterType.customer); - budgetLambdaQueryWrapper.eq(TbsBudget::getCenterId,id); - if(0 list) { - //设置销售区域 - List regionIds = list.stream() - .filter(sup -> sup.getRegionLast() != null && !sup.getRegionLast().equals("0")) - .map(BmsSupplier::getRegionLast).collect(Collectors.toList()); - regionIds.addAll(list.stream() - .filter(sup -> sup.getRegionFirst() != null && !sup.getRegionFirst().equals("0")) - .map(BmsSupplier::getRegionFirst).collect(Collectors.toList())); - regionIds.addAll(list.stream() - .filter(sup -> sup.getRegionSecond() != null && !sup.getRegionSecond().equals("0")) - .map(BmsSupplier::getRegionSecond).collect(Collectors.toList())); - regionIds.addAll(list.stream() - .filter(sup -> sup.getRegionThird() != null && !sup.getRegionThird().equals("0")) - .map(BmsSupplier::getRegionThird).collect(Collectors.toList())); - regionIds.addAll(list.stream() - .filter(sup -> sup.getRegionFourthly() != null && !sup.getRegionFourthly().equals("0")) - .map(BmsSupplier::getRegionFourthly).collect(Collectors.toList())); - - List regionList = null; - if (CollectionUtil.isNotEmpty(regionIds)) { - regionList = bmsRegionService.listByIds(regionIds); - } - if (CollectionUtil.isNotEmpty(regionList)){ - for (BmsSupplier supplier : list) { - String regionId = supplier.getRegionLast(); - String regionFirst = supplier.getRegionFirst(); - String regionSecond = supplier.getRegionSecond(); - String regionThird = supplier.getRegionThird(); - String regionFourthly = supplier.getRegionFourthly(); - - for (BmsRegion region : regionList) { - if (region.getId().equals(regionId)) { - supplier.setRegionLabel(region.getName()); - } - if (region.getId().equals(regionFirst)) { - supplier.setRegionFirstInfo(region); - } - if (region.getId().equals(regionSecond)) { - supplier.setRegionSecondInfo(region); - } - if (region.getId().equals(regionThird)) { - supplier.setRegionThirdInfo(region); - } - if (region.getId().equals(regionFourthly)) { - supplier.setRegionFourthlyInfo(region); - } - } - } - } - //设置行政区域 - List region2Ids = list.stream() - .filter(sup->sup.getRegion2Last()!=null&&!sup.getRegion2Last().equals("0")) - .map(BmsSupplier::getRegion2Last).collect(Collectors.toList()); - region2Ids.addAll(list.stream() - .filter(sup -> sup.getRegion2First() != null && !sup.getRegion2First().equals("0")) - .map(BmsSupplier::getRegion2First).collect(Collectors.toList())); - region2Ids.addAll(list.stream() - .filter(sup -> sup.getRegion2Second() != null && !sup.getRegion2Second().equals("0")) - .map(BmsSupplier::getRegion2Second).collect(Collectors.toList())); - region2Ids.addAll(list.stream() - .filter(sup -> sup.getRegion2Third() != null && !sup.getRegion2Third().equals("0")) - .map(BmsSupplier::getRegion2Third).collect(Collectors.toList())); - region2Ids.addAll(list.stream() - .filter(sup -> sup.getRegion2Fourthly() != null && !sup.getRegion2Fourthly().equals("0")) - .map(BmsSupplier::getRegion2Fourthly).collect(Collectors.toList())); - - List region2List = null; - if(CollectionUtil.isNotEmpty(region2Ids)){ - region2List = bmsRegion2Service.listByIds(region2Ids); - } - if(CollectionUtil.isNotEmpty(region2List)){ - for (BmsSupplier supplier : list) { - String region2Id = supplier.getRegion2Last(); - String regionFirst = supplier.getRegion2First(); - String regionSecond = supplier.getRegion2Second(); - String regionThird = supplier.getRegion2Third(); - String regionFourthly = supplier.getRegion2Fourthly(); - - for (BmsRegion2 region : region2List) { - String regionId = region.getId(); - - if (regionId.equals(region2Id)) { - supplier.setRegion2Label(region.getName()); - } - if (region.getId().equals(regionFirst)) { - supplier.setRegion2FirstInfo(region); - } - if (region.getId().equals(regionSecond)) { - supplier.setRegion2SecondInfo(region); - } - if (region.getId().equals(regionThird)) { - supplier.setRegion2ThirdInfo(region); - } - if (region.getId().equals(regionFourthly)) { - supplier.setRegion2FourthlyInfo(region); - } - } - } - } - } - - - private void initParentList(List list){ - for (BmsSupplier supplier : list) { - if(StringUtils.hasText(supplier.getPid())&&!supplier.getPid().equals("0")){ - BmsSupplier parentInfo = bmsSupplierService.getById(supplier.getPid()); - supplier.setParentRegionInfo(parentInfo); - }else { - supplier.setPid(null); - } - } - } - - /** - * 初始化其它信息 - * @param supplierIds - */ - private void initSupplierOtherInfo(List supplierIds){ - List suppliers = bmsSupplierService.listByIds(supplierIds); - List updParams = new ArrayList<>(); - for (BmsSupplier supplier : suppliers) { - if(CollectionUtil.isNotEmpty(supplier.getOtherUserIds())){ - List otherUserIds = Arrays.asList(supplier.getOtherUserIds()); - BmsSupplier param = new BmsSupplier(); - param.setId(supplier.getId()); - if(otherUserIds.size()>0){ - List userList = sysUserService.listByIds(otherUserIds); - String codes = userList.stream().map(SysUser::getCode).collect(Collectors.joining(",")); - String names = userList.stream().map(SysUser::getName).collect(Collectors.joining(",")); - param.setOtherUserCodes(codes); - param.setOtherUserNames(names); - }else { - param.setOtherUserCodes(""); - param.setOtherUserNames(""); - } - updParams.add(param); - } - } - if(CollectionUtil.isNotEmpty(updParams)){ - bmsSupplierService.updateBatchById(updParams); - } - } - - /** - * 获取大区下来列表 - * @return - */ - @GetMapping("/getComRegion") - public R> getComRegion(){ - List supplierComRegions = supplierComRegionMapper.selectList(new QueryWrapper<>()); - return R.ok(supplierComRegions); - } - - /** - * 新增 - * @param param - * @return - */ - @PostMapping("/importExcel") -// @SysLog(module = SystemModule.BASE, title = "供应商", biz = BizType.INSERT) - @PreAuthorize("hasRole('bms:supplier:insert')") - public R importExcel(@RequestBody List param){ - param.forEach(a->{ - a.setErrorInfo(""); - if(a.getType().equals("4")){ - return; - } - if(!StringUtils.hasText(a.getCustomerCode())){ - a.setErrorInfo(a.getErrorInfo()+"客户编号不能为空;"); - } - if(a.getType().equals("3")){ - return; - } - if(!StringUtils.hasText(a.getCustomerName())){ - a.setErrorInfo(a.getErrorInfo()+"客户名称不能为空;"); - } - if(!StringUtils.hasText(a.getSalesRegionName())){ - a.setErrorInfo(a.getErrorInfo()+"销售区域不能为空;"); - } - if(!StringUtils.hasText(a.getFirstLevelAdministrativeRegionName())){ - a.setErrorInfo(a.getErrorInfo()+"省不能为空;"); - } - if(!StringUtils.hasText(a.getSecondaryLevelAdministrativeRegionName())){ - a.setErrorInfo(a.getErrorInfo()+"市不能为空;"); - } - if(!StringUtils.hasText(a.getAdministrativeRegionName())){ - a.setErrorInfo(a.getErrorInfo()+"行政区域不能为空;"); - } - if(a.getIsSupplier()==null){ - a.setErrorInfo(a.getErrorInfo()+"是否供应商字段不能为空;"); - } -// if(!StringUtils.hasText(a.getMinorHeadCodes()) && !StringUtils.hasText(a.getMainHeadCode())){ -// a.setErrorInfo(a.getErrorInfo()+"负责人不能为空;"); -// } - if(a.getIsExpendableExpense()==null){ - a.setErrorInfo(a.getErrorInfo()+"是否投放费用字段不能为空;"); - } -// if(a.getCloseAccountStatus()==null){ -// a.setErrorInfo(a.getErrorInfo()+"闭户状态不能为空;"); -// } - }); - List saveList = param.stream().filter(a->a.getType().equals("1")).collect(Collectors.toList()); - List updateList = param.stream().filter(a->a.getType().equals("2")).collect(Collectors.toList()); - List deleteList = param.stream().filter(a->a.getType().equals("3")).collect(Collectors.toList()); - - /** --------------------------------------------------------------------------- **/ - List bmsRegionNames = new ArrayList<>(); - bmsRegionNames.addAll( - saveList.stream().filter(a->a.getSalesRegionName()!=null) - .map(a->a.getSalesRegionName()).collect(Collectors.toList()) - ); - bmsRegionNames.addAll( - updateList.stream().filter(a->a.getSalesRegionName()!=null) - .map(a->a.getSalesRegionName()).collect(Collectors.toList()) - ); - bmsRegionNames = bmsRegionNames.stream().distinct().collect(Collectors.toList()); - List regionList = new ArrayList<>(); - if(bmsRegionNames.size()>0){ - LambdaQueryWrapper bmsRegionLambdaQueryWrapper = new LambdaQueryWrapper<>(); - bmsRegionLambdaQueryWrapper.in(BmsRegion::getName,bmsRegionNames); - regionList = bmsRegionService.list(bmsRegionLambdaQueryWrapper); - List existBmsRegionName = regionList.stream().map(a->a.getName()).collect(Collectors.toList()); - if(regionList.size(){ - if(a.getType().equals("4")){ - return; - } - if(!existBmsRegionName.contains(a.getSalesRegionName())){ - a.setErrorInfo(a.getErrorInfo()+"不存在销售区域"+a.getSalesRegionName()+";"); - } - }); - - } - } - - List bmsBizRegionNames = new ArrayList<>(); - List bizRegionList = new ArrayList<>(); - - bmsBizRegionNames.addAll( - saveList.stream().filter(a->a.getSecondaryLevelAdministrativeRegionName()!=null - && a.getFirstLevelAdministrativeRegionName()!=null && a.getAdministrativeRegionName()!=null) - .map(a->a.getFirstLevelAdministrativeRegionName()+"_"+a.getSecondaryLevelAdministrativeRegionName()+"_"+a.getAdministrativeRegionName()).collect(Collectors.toList()) - ); - bmsBizRegionNames.addAll( - updateList.stream().filter(a->a.getSecondaryLevelAdministrativeRegionName()!=null - && a.getFirstLevelAdministrativeRegionName()!=null && a.getAdministrativeRegionName()!=null) - .map(a->a.getFirstLevelAdministrativeRegionName()+"_"+a.getSecondaryLevelAdministrativeRegionName()+"_"+a.getAdministrativeRegionName()).collect(Collectors.toList()) - ); - bmsBizRegionNames = bmsBizRegionNames.stream().distinct().collect(Collectors.toList()); - if(bmsBizRegionNames.size()>0){ - LambdaQueryWrapper bmsRegion2LambdaQueryWrapper = new LambdaQueryWrapper<>(); - bmsRegion2LambdaQueryWrapper.in(BmsRegion2::getPathNames,bmsBizRegionNames); - bizRegionList = bmsRegion2Service.list(bmsRegion2LambdaQueryWrapper); - List exsitBizRegeionName = bizRegionList.stream().map(BmsRegion2::getPathNames).collect(Collectors.toList()); - if(bizRegionList.size(){ - if(a.getType().equals("4")){ - return; - } - if(!exsitBizRegeionName.contains( - a.getFirstLevelAdministrativeRegionName()+"_"+a.getSecondaryLevelAdministrativeRegionName()+"_"+a.getAdministrativeRegionName()) - ){ - a.setErrorInfo(a.getErrorInfo()+"不存在行政区域"+a.getFirstLevelAdministrativeRegionName()+"_"+a.getSecondaryLevelAdministrativeRegionName()+"_"+a.getAdministrativeRegionName()+";"); - } - }); - } - } - /** ------------------------------- 校验负责人 ------------------------------------------------ */ - List userCodes = new ArrayList<>(); - userCodes.addAll( - saveList.stream().filter(a->StringUtils.hasText(a.getMainHeadCode())) - .map(a->Arrays.asList(a.getMainHeadCode().split(";"))) - .flatMap(List::stream).collect(Collectors.toList()) - ); - userCodes.addAll( - saveList.stream().filter(a->StringUtils.hasText(a.getMinorHeadCodes())) - .map(a->Arrays.asList(a.getMinorHeadCodes().split(";"))) - .flatMap(List::stream).collect(Collectors.toList()) - ); - userCodes.addAll( - updateList.stream().filter(a->StringUtils.hasText(a.getMainHeadCode())) - .map(a->Arrays.asList(a.getMainHeadCode().split(";"))) - .flatMap(List::stream).collect(Collectors.toList()) - ); - userCodes.addAll( - updateList.stream().filter(a->StringUtils.hasText(a.getMinorHeadCodes())) - .map(a->Arrays.asList(a.getMinorHeadCodes().split(";"))) - .flatMap(List::stream).collect(Collectors.toList()) - ); - userCodes = userCodes.stream().distinct().collect(Collectors.toList()); - List userList = new ArrayList<>(); - if(userCodes.size()>0){ - LambdaQueryWrapper sysUserLambdaQueryWrapper = new LambdaQueryWrapper<>(); - sysUserLambdaQueryWrapper.in(SysUser::getCode,userCodes); - userList = sysUserService.list(sysUserLambdaQueryWrapper); - List exsitUserCodes = userList.stream().map(a->a.getCode()).collect(Collectors.toList()); - if(userList.size(){ - if(a.getType().equals("4")){ - return; - } - if(a.getType().equals("3")){ - return; - } - List userCodeTemp = new ArrayList<>(); - if(StringUtils.hasText(a.getMainHeadCode())){ - userCodeTemp.addAll(Arrays.asList(a.getMainHeadCode().split(";"))); - } - if(StringUtils.hasText(a.getMinorHeadCodes())){ - userCodeTemp.addAll(Arrays.asList(a.getMinorHeadCodes().split(";"))); - } - List noExistUserCode = userCodeTemp.stream().filter(b->!exsitUserCodes.contains(b)).collect(Collectors.toList()); - if(noExistUserCode.size()>0){ - a.setErrorInfo(a.getErrorInfo()+"不存在人员"+noExistUserCode.stream().collect(Collectors.joining(","))); - } - }); - } - } - /** --------------------------------------------------------------------------- **/ - - /** --------------------------------------------------------------------------- **/ - /** ------------------------------- 校验新增 ------------------------------------------------ */ - if(saveList.size()>0){ - List saveCodes = saveList.stream().filter(a->StringUtils.hasText(a.getCustomerCode())).map(a->a.getCustomerCode()).distinct().collect(Collectors.toList()); - if(saveCodes.size()>0){ - LambdaQueryWrapper checkSave = new LambdaQueryWrapper<>(); - checkSave.in(BmsSupplier::getCode,saveCodes); - List checkSaveSupplier = bmsSupplierService.list(checkSave); - if(checkSaveSupplier.size()>0){ - List existSaveCodes = checkSaveSupplier.stream().map(a->a.getCode()).collect(Collectors.toList()); - param.forEach(a->{ - if(a.getType().equals("1")){ - if(existSaveCodes.contains(a.getCustomerCode())){ - a.setErrorInfo(a.getErrorInfo()+"已存在客户编码"); - } - } - }); - } - } - } - - - /** --------------------------------------------------------------------------- **/ - - /** ------------------------------- 校验更新 ------------------------------------------------ */ - if(updateList.size()>0){ - List updateCheckCodes = updateList.stream().filter(a->StringUtils.hasText(a.getCustomerCode())).map(a->a.getCustomerCode()).distinct().collect(Collectors.toList()); - if(updateCheckCodes.size()==0){ - param.forEach(a->{ - if(a.getType().equals("2")){ - a.setErrorInfo(a.getErrorInfo()+"更新不存在客户编码;"); - } - }); - - }else{ - LambdaQueryWrapper checkUpdateCustomerCode = new LambdaQueryWrapper<>(); - checkUpdateCustomerCode.in(BmsSupplier::getCode,updateCheckCodes); - List checkUpdateSupplierList = bmsSupplierService.list(checkUpdateCustomerCode); - List existUpdateCodes = checkUpdateSupplierList.stream().map(a->a.getCode()).collect(Collectors.toList()); - param.forEach(a->{ - if(a.getType().equals("2")){ - if(!existUpdateCodes.contains(a.getCustomerCode())){ - a.setErrorInfo(a.getErrorInfo()+"更新不存在客户编码;"); - } - } - }); - } - } - /** ----------------------------------------------------------------------------------- */ - - /** ------------------------------- 删除更新 ------------------------------------------------ */ - if(deleteList.size()>0){ - List deleteCheckCodes = deleteList.stream().map(a->a.getCustomerCode()).collect(Collectors.toList()); - if(deleteCheckCodes.size()==0){ - param.forEach(a->{ - if(a.getType().equals("3")){ - a.setErrorInfo(a.getErrorInfo()+"删除不存在客户编码"); - } - }); - }else{ - LambdaQueryWrapper checkDeleteCustomerCode = new LambdaQueryWrapper<>(); - checkDeleteCustomerCode.in(BmsSupplier::getCode,deleteCheckCodes); - List checkDeleteSupplierList = bmsSupplierService.list(checkDeleteCustomerCode); - List existDeleteCodes = checkDeleteSupplierList.stream().map(a->a.getCode()).collect(Collectors.toList()); - param.forEach(a->{ - if(a.getType().equals("3")){ - if(!existDeleteCodes.contains(a.getCustomerCode())){ - a.setErrorInfo(a.getErrorInfo()+"删除不存在客户编码;"); - } - } - }); - } - } - /** ----------------------------------------------------------------------------------- */ - - /** ------------------------------- 返回错误 ------------------------------------------- */ - if(param.stream().filter(a->a.getErrorInfo().length()>0).count()>0) { - return R.ok(param, "导入失败，请打开EXCEL查询错误详情！"); - } - /** ----------------------------------------------------------------------------------- */ - - Map bizRegionMap = bizRegionList.stream().collect(Collectors.toMap(BmsRegion2::getPathNames, a->a)); - Map saleRegionMap = regionList.stream().collect(Collectors.toMap(BmsRegion::getName, a->a)); - Map sysUserMap = userList.stream().collect(Collectors.toMap(SysUser::getCode, a->a)); - - /** ------------------------------- 保存新增 ------------------------------------------------ */ - if(saveList.size()>0) { - List saveBmsSuppliers = saveList.stream().map(a->{ - BmsSupplier supplier = new BmsSupplier(); - supplier.setName(a.getCustomerName()); - supplier.setCode(a.getCustomerCode()); - supplier.setBelong(a.getAffiliatedCompany()); - supplier.setCostFlag(a.getIsExpendableExpense()); - supplier.setStopFlag(a.getCloseAccountStatus()); - supplier.setStopFlagDate(a.getCloseAccountDate()); - supplier.setCooperatePauseFlag(a.getSuspendCooperationStatus()); - supplier.setCooperatePauseFlagDate(a.getSuspendCooperationDate()); - if(StringUtils.hasText(a.getMainHeadCode())){ - SysUser sysUser = sysUserMap.get(a.getMainHeadCode()); - supplier.setUserId(sysUser.getId()); - supplier.setUserCode(sysUser.getCode()); - supplier.setUserName(sysUser.getName()); - } - - if(StringUtils.hasText(a.getMinorHeadCodes())){ - List otherUserCodes = Arrays.asList(a.getMinorHeadCodes().split(";")); - List otherUserNames = new ArrayList<>(); - List otherUserIds = new ArrayList<>(); - otherUserCodes.forEach(b->{ - SysUser sysUser = sysUserMap.get(b); - otherUserNames.add(sysUser.getName()); - otherUserIds.add(sysUser.getId()); - }); - supplier.setOtherUserCodes(otherUserCodes.stream().collect(Collectors.joining(","))); - supplier.setOtherUserNames(otherUserNames.stream().collect(Collectors.joining(","))); - supplier.setOtherUserIds(otherUserIds.toArray(new String[otherUserIds.size()])); - } - - if(StringUtils.hasText(a.getSalesRegionName())){ - BmsRegion saleRegion = saleRegionMap.get(a.getSalesRegionName()); - supplier.setRegionLast(saleRegion.getId()); - supplier.setRegionSecond(saleRegion.getId()); - supplier.setRegionFirst(saleRegion.getPid()); - } - - if(StringUtils.hasText(a.getSecondaryLevelAdministrativeRegionName()) - && StringUtils.hasText(a.getFirstLevelAdministrativeRegionName()) - && StringUtils.hasText(a.getAdministrativeRegionName())){ - BmsRegion2 bizRegion = bizRegionMap.get(a.getFirstLevelAdministrativeRegionName()+"_"+a.getSecondaryLevelAdministrativeRegionName()+"_"+a.getAdministrativeRegionName()); - supplier.setRegion2Third(bizRegion.getId()); - supplier.setRegion2Second(bizRegion.getPid()); - String firstRegion2Id = bizRegion.getPathIds().split("_")[0]; - supplier.setRegion2First(firstRegion2Id); - supplier.setRegion2Last(bizRegion.getId()); - } - - return supplier; - }).collect(Collectors.toList()); - bmsSupplierService.saveBatch(saveBmsSuppliers); - } - /** ----------------------------------------------------------------------------------- */ - /** ------------------------------- 保存更新 ------------------------------------------------ */ - if(updateList.size()>0) { - LambdaQueryWrapper oriBmsLqw = new LambdaQueryWrapper<>(); - oriBmsLqw.in(BmsSupplier::getCode,updateList.stream().map(b->b.getCustomerCode()).collect(Collectors.toList())); - List oriBmsSuppliers = bmsSupplierService.list(oriBmsLqw); - Map codeToSupplierId = oriBmsSuppliers.stream().collect(Collectors.toMap(BmsSupplier::getCode, BmsSupplier::getId)); - - List updateBmsSuppliers = updateList.stream().map(a->{ - BmsSupplier supplier = new BmsSupplier(); - - supplier.setId(codeToSupplierId.get(a.getCustomerCode())); - supplier.setName(a.getCustomerName()); - supplier.setCode(a.getCustomerCode()); - supplier.setCostFlag(a.getIsExpendableExpense()); - supplier.setBelong(a.getAffiliatedCompany()); - supplier.setStopFlag(a.getCloseAccountStatus()); - supplier.setStopFlagDate(a.getCloseAccountDate()); - supplier.setCooperatePauseFlag(a.getSuspendCooperationStatus()); - supplier.setCooperatePauseFlagDate(a.getSuspendCooperationDate()); - if(StringUtils.hasText(a.getMainHeadCode())){ - SysUser sysUser = sysUserMap.get(a.getMainHeadCode()); - supplier.setUserId(sysUser.getId()); - supplier.setUserCode(sysUser.getCode()); - supplier.setUserName(sysUser.getName()); - } - - if(StringUtils.hasText(a.getMinorHeadCodes())){ - List otherUserCodes = Arrays.asList(a.getMinorHeadCodes().split(";")); - List otherUserNames = new ArrayList<>(); - List otherUserIds = new ArrayList<>(); - otherUserCodes.forEach(b->{ - SysUser sysUser = sysUserMap.get(b); - otherUserNames.add(sysUser.getName()); - otherUserIds.add(sysUser.getId()); - }); - supplier.setOtherUserCodes(otherUserCodes.stream().collect(Collectors.joining(","))); - supplier.setOtherUserNames(otherUserNames.stream().collect(Collectors.joining(","))); - supplier.setOtherUserIds(otherUserIds.toArray(new String[otherUserIds.size()])); - } - - if(StringUtils.hasText(a.getSalesRegionName())){ - BmsRegion saleRegion = saleRegionMap.get(a.getSalesRegionName()); - supplier.setRegionLast(saleRegion.getId()); - supplier.setRegionSecond(saleRegion.getId()); - supplier.setRegionFirst(saleRegion.getPid()); - } - - if(StringUtils.hasText(a.getSecondaryLevelAdministrativeRegionName()) - && StringUtils.hasText(a.getFirstLevelAdministrativeRegionName()) - && StringUtils.hasText(a.getAdministrativeRegionName())){ - BmsRegion2 bizRegion = bizRegionMap.get(a.getFirstLevelAdministrativeRegionName()+"_"+a.getSecondaryLevelAdministrativeRegionName()+"_"+a.getAdministrativeRegionName()); - supplier.setRegion2Third(bizRegion.getId()); - supplier.setRegion2Second(bizRegion.getPid()); - String firstRegion2Id = bizRegion.getPathIds().split("_")[0]; - supplier.setRegion2First(firstRegion2Id); - supplier.setRegion2Last(bizRegion.getId()); - } - - return supplier; - }).collect(Collectors.toList()); - bmsSupplierService.updateBatchById(updateBmsSuppliers); - - List updateBmsSuppliersUserNullById = updateList.stream() - .filter(a->!StringUtils.hasText(a.getMainHeadCode())) - .map(a-> codeToSupplierId.get(a.getCustomerCode())).collect(Collectors.toList()); - - if(updateBmsSuppliersUserNullById.size()>0){ - bmsSupplierService.updateBmsSuppliersUserNullById(updateBmsSuppliersUserNullById); - } - - List updateBmsSuppliersOtherUserNullById = updateList.stream() - .filter(a->!StringUtils.hasText(a.getMinorHeadCodes())) - .map(a-> codeToSupplierId.get(a.getCustomerCode())).collect(Collectors.toList()); - - if(updateBmsSuppliersOtherUserNullById.size()>0){ - bmsSupplierService.updateBmsSuppliersOtherUserNullById(updateBmsSuppliersOtherUserNullById); - } - } - /** ----------------------------------------------------------------------------------- */ - /** ------------------------------- 删除数据 ------------------------------------------------ */ - if(deleteList.size()>0) { - LambdaQueryWrapper oriBmsLqw = new LambdaQueryWrapper<>(); - oriBmsLqw.in(BmsSupplier::getCode,deleteList.stream().map(b->b.getCustomerCode()).collect(Collectors.toList())); - List oriBmsSuppliers = bmsSupplierService.list(oriBmsLqw); -// Map codeToSupplierId = oriBmsSuppliers.stream().collect(Collectors.toMap(BmsSupplier::getCode, BmsSupplier::getId)); - List deleteIds = oriBmsSuppliers.stream().map(a->a.getId()).collect(Collectors.toList()); - bmsSupplierService.removeBatchByIds(deleteIds); - } - /** ----------------------------------------------------------------------------------- */ - - return R.ok(); - } - - - /** - * 直属负责人，直接添加到his表 - * @param userIds - * @param supplier - */ - private void saveTOHis(List userIds, BmsSupplier supplier) { - //直属负责人，直接添加到his表 - for (String userId : userIds) { - HisUserSupplier hisUserSupplier = new HisUserSupplier(); - hisUserSupplier.setUserId(userId); - hisUserSupplier.setSupplierId(Long.parseLong(supplier.getId())); - hisUserSupplier.setSupplierName(supplier.getName()); - hisUserSupplier.setSupplierCode(supplier.getCode()); - hisUserSupplier.setType(2); - hisUserSupplier.setSaleRegionFirst(supplier.getRegionFirst()); - hisUserSupplier.setSaleRegionSecond(supplier.getRegionSecond()); - hisUserSupplier.setSaleRegionThird(supplier.getRegionThird()); - hisUserSupplier.setSaleRegionFourthly(supplier.getRegionFourthly()); - hisUserSupplier.setMasterFlag(1); - hisUserSupplier.setCreateTime(LocalDateTime.now()); - hisUserSupplier.setBizRegionFirst(supplier.getRegion2First()); - hisUserSupplier.setBizRegionSecond(supplier.getRegion2Second()); - hisUserSupplier.setBizRegionThird(supplier.getRegion2Third()); - hisUserSupplier.setBizRegionFourthly(supplier.getRegion2Fourthly()); - hisUserSupplier.setCostFlag(supplier.getCostFlag()); - hisUserSupplier.setSupplierFlag(supplier.getSupplierFlag()); - hisUserSupplier.setStopFlag(supplier.getStopFlag()); - hisUserSupplier.setStopFlagDate(supplier.getStopFlagDate()); - hisUserSupplier.setCooperatePauseFlag(supplier.getCooperatePauseFlag()); - hisUserSupplier.setCooperatePauseFlagDate(supplier.getCooperatePauseFlagDate()); - hisUserSupplierService.save(hisUserSupplier); + public R save(@RequestBody @Valid BmsSupplierBo param, HttpServletRequest request){ + SysSyncLog syncLog = new SysSyncLog(); + syncLog.setFromPlat("新建客户"); + syncLog.setUrl(request.getRequestURI()); + syncLog.setRequestJson(JsonUtil.objectToJson(param)); + syncLog.setEntityClass(BmsSupplierBo.class.getName()); + try { + ThirdTokenUtil.checkToken(request); + + BmsSupplier supplier = new BmsSupplier(); + CopierUtil.copy(param,supplier); + bmsSupplierService.save(supplier); + syncLog.setSuccessStatus(1); + } catch (Exception e) { + log.error("新建客户===>{}", JsonUtil.objectToJson(param)); + syncLog.setFailReason(e.getMessage()); + sysSyncLogService.save(syncLog); + return R.error(e.getMessage()); + } + sysSyncLogService.save(syncLog); + if(syncLog.getSuccessStatus()!=null&&syncLog.getSuccessStatus().equals(1)){ + return R.ok(); } + return R.error("新建客户异常"); } - - }