Browse Source

编码补零;销售区域添加停用及别名;成本中心逻辑重构

contract
Yen 2 years ago
parent
commit
c0735957dc
  1. 10
      src/main/java/com/qs/serve/common/util/CodeGenUtil.java
  2. 15
      src/main/java/com/qs/serve/modules/bms/controller/BmsCenterExtendController.java
  3. 25
      src/main/java/com/qs/serve/modules/bms/controller/BmsRegionController.java
  4. 2
      src/main/java/com/qs/serve/modules/bms/controller/api/BmsRegionApi.java
  5. 6
      src/main/java/com/qs/serve/modules/bms/entity/BmsRegion.java
  6. 6
      src/main/java/com/qs/serve/modules/bms/entity/bo/BmsRegionBatchBo.java
  7. 2
      src/main/java/com/qs/serve/modules/bms/entity/vo/BmsRegionTreeVo.java
  8. 1
      src/main/java/com/qs/serve/modules/bms/service/BmsCenterExtendService.java
  9. 2
      src/main/java/com/qs/serve/modules/bms/service/BmsRegionService.java
  10. 226
      src/main/java/com/qs/serve/modules/bms/service/impl/BmsCenterExtendServiceImpl.java
  11. 7
      src/main/java/com/qs/serve/modules/bms/service/impl/BmsRegionServiceImpl.java
  12. 3
      src/main/java/com/qs/serve/modules/tzc/service/impl/TzcPolicyServiceImpl.java
  13. 6
      src/main/resources/application.yml

10
src/main/java/com/qs/serve/common/util/CodeGenUtil.java

@ -48,7 +48,15 @@ public class CodeGenUtil {
DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyyMMdd"); DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyyMMdd");
String localTime = df.format(localDateTime); String localTime = df.format(localDateTime);
String appendStr = digits32(value); String appendStr = digits32(value);
return localTime.substring(2) + appendStr; //防止溢出
if(appendStr.length()<4){
redisService.set(key,1);
}
StringBuilder appendZeros = new StringBuilder();
for (int i = appendStr.length(); i < 4; i++) {
appendZeros.append("0");
}
return localTime.substring(2) + appendZeros + appendStr;
} catch (BeansException e) { } catch (BeansException e) {
e.printStackTrace(); e.printStackTrace();
} }

15
src/main/java/com/qs/serve/modules/bms/controller/BmsCenterExtendController.java

@ -14,6 +14,7 @@ import com.qs.serve.modules.bms.entity.bo.BmsCenterExtendBo;
import com.qs.serve.modules.bms.service.BmsCenterExtendUserService; import com.qs.serve.modules.bms.service.BmsCenterExtendUserService;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.omg.CORBA.DynAnyPackage.Invalid;
import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
@ -68,12 +69,6 @@ public class BmsCenterExtendController {
LambdaQueryWrapper<BmsCenterExtend> childLqw = new LambdaQueryWrapper<>(); LambdaQueryWrapper<BmsCenterExtend> childLqw = new LambdaQueryWrapper<>();
childLqw.eq(BmsCenterExtend::getSourceId,centerExtend.getId()); childLqw.eq(BmsCenterExtend::getSourceId,centerExtend.getId());
List<BmsCenterExtend> childList = bmsCenterExtendService.list(childLqw); List<BmsCenterExtend> childList = bmsCenterExtendService.list(childLqw);
/*for (BmsCenterExtend childExt : childList) {
LambdaQueryWrapper<BmsCenterExtendUser> userLqw = new LambdaQueryWrapper<>();
userLqw.eq(BmsCenterExtendUser::getChildExtId,childExt.getId());
List<BmsCenterExtendUser> userList = bmsCenterExtendUserService.list(userLqw);
childExt.setUserList(userList);
}*/
centerExtend.setChildList(childList); centerExtend.setChildList(childList);
} }
return R.byPageHelperList(list); return R.byPageHelperList(list);
@ -110,6 +105,9 @@ public class BmsCenterExtendController {
@PostMapping("/allocation4Save") @PostMapping("/allocation4Save")
@SysLog(module = SystemModule.BASE, title = "后继成本中心", biz = BizType.INSERT) @SysLog(module = SystemModule.BASE, title = "后继成本中心", biz = BizType.INSERT)
public R<?> allocation(@RequestBody BmsCenterExtendBo param){ public R<?> allocation(@RequestBody BmsCenterExtendBo param){
if(param.getId()!=null){
return R.error("Invalid");
}
BmsCenterExtend detail = bmsCenterExtendService.allocation(param); BmsCenterExtend detail = bmsCenterExtendService.allocation(param);
return R.ok(detail); return R.ok(detail);
} }
@ -122,7 +120,10 @@ public class BmsCenterExtendController {
@PostMapping("/allocation4Update") @PostMapping("/allocation4Update")
@SysLog(module = SystemModule.BASE, title = "后继成本中心", biz = BizType.UPDATE) @SysLog(module = SystemModule.BASE, title = "后继成本中心", biz = BizType.UPDATE)
public R<?> allocation4Update(@RequestBody BmsCenterExtendBo param){ public R<?> allocation4Update(@RequestBody BmsCenterExtendBo param){
bmsCenterExtendService.allocation4Update(param); if(param.getId()==null){
return R.error("Invalid");
}
bmsCenterExtendService.allocation(param);
return R.ok(); return R.ok();
} }

25
src/main/java/com/qs/serve/modules/bms/controller/BmsRegionController.java

@ -81,19 +81,24 @@ public class BmsRegionController {
* 树查询 * 树查询
* @param listUserFlag 加载我负责的用户所属的区域 * @param listUserFlag 加载我负责的用户所属的区域
* @param loadByCurrent =1过滤当前用户负责数据(优先级最高) * @param loadByCurrent =1过滤当前用户负责数据(优先级最高)
* @param supplierId
* @param stopFlag 01是否停用2->加载所有
* @return * @return
*/ */
@GetMapping("/tree") @GetMapping("/tree")
@PreAuthorize("hasRole('bms:region:query')") @PreAuthorize("hasRole('bms:region:query')")
public R<List<BmsRegionTreeVo>> getTree(Integer listUserFlag,Integer loadByCurrent,String supplierId){ public R<List<BmsRegionTreeVo>> getTree(Integer listUserFlag,Integer loadByCurrent,String supplierId,Integer stopFlag){
if(stopFlag==null){
stopFlag = 0;
}
if(loadByCurrent!=null&&loadByCurrent.equals(1)){ if(loadByCurrent!=null&&loadByCurrent.equals(1)){
return R.ok(treeByCurrentUser(supplierId)); return R.ok(treeByCurrentUser(supplierId,stopFlag));
} }
return R.ok(bmsRegionService.getTree(listUserFlag!=null&&listUserFlag.equals(1))); return R.ok(bmsRegionService.getTree(listUserFlag!=null&&listUserFlag.equals(1), stopFlag));
} }
public List<BmsRegionTreeVo> treeByCurrentUser(String supplierId){ public List<BmsRegionTreeVo> treeByCurrentUser(String supplierId,Integer stopFlag){
String userId = AuthContextUtils.getSysUserId(); String userId = AuthContextUtils.getSysUserId();
LambdaQueryWrapper<BmsRegionUser> lqw = new LambdaQueryWrapper<>(); LambdaQueryWrapper<BmsRegionUser> lqw = new LambdaQueryWrapper<>();
lqw.eq(BmsRegionUser::getType,0); lqw.eq(BmsRegionUser::getType,0);
@ -123,7 +128,7 @@ public class BmsRegionController {
List<BmsRegion> regionList = bmsRegionService.listByIds(regionIds); List<BmsRegion> regionList = bmsRegionService.listByIds(regionIds);
if(regionList.size()==0){ if(regionList.size()==0){
return toTreeNodeList2(allSelectList); return toTreeNodeList2(allSelectList,stopFlag);
} }
List<String> pathIds = regionList.stream().map(a->a.getPathIds()).collect(Collectors.toList()); List<String> pathIds = regionList.stream().map(a->a.getPathIds()).collect(Collectors.toList());
@ -131,7 +136,7 @@ public class BmsRegionController {
.flatMap(pathId -> Arrays.stream(pathId.split("_"))) .flatMap(pathId -> Arrays.stream(pathId.split("_")))
.collect(Collectors.toList()); .collect(Collectors.toList());
regionList = bmsRegionService.listByIds(idList); regionList = bmsRegionService.listByIds(idList);
return toTreeNodeList2(regionList); return toTreeNodeList2(regionList,stopFlag);
// //
// Map<Integer,List<BmsRegion>> listMap = regionList.stream().collect(Collectors.groupingBy(BmsRegion::getLevel)); // Map<Integer,List<BmsRegion>> listMap = regionList.stream().collect(Collectors.groupingBy(BmsRegion::getLevel));
// List<BmsRegion> list1 = listMap.get(1)==null?new ArrayList<>():listMap.get(1); // List<BmsRegion> list1 = listMap.get(1)==null?new ArrayList<>():listMap.get(1);
@ -218,9 +223,13 @@ public class BmsRegionController {
} }
private List<BmsRegionTreeVo> toTreeNodeList2(List<BmsRegion> list){ private List<BmsRegionTreeVo> toTreeNodeList2(List<BmsRegion> list,Integer stopFlag){
List<BmsRegionTreeVo> treeVoList = new ArrayList<>(); List<BmsRegionTreeVo> treeVoList = new ArrayList<>();
for (BmsRegion region2 : list) { for (BmsRegion region2 : list) {
//跳过停用的或未停用的
if(stopFlag!=2&&!region2.getStopFlag().equals(stopFlag)){
continue;
}
BmsRegionTreeVo treeNode = CopierUtil.copy(region2,new BmsRegionTreeVo()); BmsRegionTreeVo treeNode = CopierUtil.copy(region2,new BmsRegionTreeVo());
treeNode.setId(region2.getId()); treeNode.setId(region2.getId());
treeNode.setParentId(region2.getPid()); treeNode.setParentId(region2.getPid());
@ -278,6 +287,8 @@ public class BmsRegionController {
param.setId(regionBo.getId()); param.setId(regionBo.getId());
param.setName(regionBo.getName()); param.setName(regionBo.getName());
param.setPid(regionBo.getPid()); param.setPid(regionBo.getPid());
param.setAliasRegion(regionBo.getAliasRegion());
param.setStopFlag(regionBo.getStopFlag());
boolean result = bmsRegionService.updateBmsRegionById(param); boolean result = bmsRegionService.updateBmsRegionById(param);
hisUserSupplierService.cleanTable(); hisUserSupplierService.cleanTable();
return R.isTrue(result); return R.isTrue(result);

2
src/main/java/com/qs/serve/modules/bms/controller/api/BmsRegionApi.java

@ -29,7 +29,7 @@ public class BmsRegionApi {
*/ */
@GetMapping("/tree") @GetMapping("/tree")
public R<List<BmsRegionTreeVo>> getTree(){ public R<List<BmsRegionTreeVo>> getTree(){
return R.ok(bmsRegionService.getTree(false)); return R.ok(bmsRegionService.getTree(false,0));
} }
/** /**

6
src/main/java/com/qs/serve/modules/bms/entity/BmsRegion.java

@ -36,6 +36,9 @@ public class BmsRegion implements Serializable {
@Length(max = 20,message = "名称长度不能超过20字") @Length(max = 20,message = "名称长度不能超过20字")
private String name; private String name;
/** 别名 */
private String aliasRegion;
/** 编码 */ /** 编码 */
@Length(max = 20,message = "编码长度不能超过20字") @Length(max = 20,message = "编码长度不能超过20字")
private String code; private String code;
@ -53,6 +56,9 @@ public class BmsRegion implements Serializable {
/** 祖级id */ /** 祖级id */
private String pathNames; private String pathNames;
/** 是否停用 */
private Integer stopFlag;
/** 工厂产地ID */ /** 工厂产地ID */
@TableField(typeHandler = SplitStringTypeHandler.class,jdbcType= JdbcType.VARCHAR) @TableField(typeHandler = SplitStringTypeHandler.class,jdbcType= JdbcType.VARCHAR)
private String[] factoryIds; private String[] factoryIds;

6
src/main/java/com/qs/serve/modules/bms/entity/bo/BmsRegionBatchBo.java

@ -31,6 +31,12 @@ public class BmsRegionBatchBo {
/** 父级ID */ /** 父级ID */
@Length(max = 32,message = "父级ID长度不能超过32字") @Length(max = 32,message = "父级ID长度不能超过32字")
private String pid; private String pid;
/** 别名 */
private String aliasRegion;
private Integer stopFlag;
} }
} }

2
src/main/java/com/qs/serve/modules/bms/entity/vo/BmsRegionTreeVo.java

@ -29,6 +29,8 @@ public class BmsRegionTreeVo extends TreeNode {
@Length(max = 32,message = "父级ID长度不能超过32字") @Length(max = 32,message = "父级ID长度不能超过32字")
private String pid; private String pid;
private String aliasRegion;
/** 层级 */ /** 层级 */
private Integer level; private Integer level;

1
src/main/java/com/qs/serve/modules/bms/service/BmsCenterExtendService.java

@ -15,7 +15,6 @@ public interface BmsCenterExtendService extends IService<BmsCenterExtend> {
BmsCenterExtend allocation(BmsCenterExtendBo param); BmsCenterExtend allocation(BmsCenterExtendBo param);
void allocation4Update(BmsCenterExtendBo param);
/** /**
* 删除所有均摊节点 * 删除所有均摊节点

2
src/main/java/com/qs/serve/modules/bms/service/BmsRegionService.java

@ -14,7 +14,7 @@ import java.util.List;
*/ */
public interface BmsRegionService extends IService<BmsRegion> { public interface BmsRegionService extends IService<BmsRegion> {
List<BmsRegionTreeVo> getTree(boolean listUserFlag); List<BmsRegionTreeVo> getTree(boolean listUserFlag,Integer stopFlag);
List<BmsRegion> listChild(String pid); List<BmsRegion> listChild(String pid);

226
src/main/java/com/qs/serve/modules/bms/service/impl/BmsCenterExtendServiceImpl.java

@ -72,44 +72,40 @@ public class BmsCenterExtendServiceImpl extends ServiceImpl<BmsCenterExtendMappe
if(targetCenter.getTargetCenterId().equals(param.getSourceCenterId())){ if(targetCenter.getTargetCenterId().equals(param.getSourceCenterId())){
Assert.throwEx("后继成本中心与当前成本中心相同"); Assert.throwEx("后继成本中心与当前成本中心相同");
} }
boolean b = this.checkIsStop(type,targetCenter.getTargetCenterId());
if(b){
Assert.throwEx("部分后继成本中心已分配");
}
} }
TbsCenterDto centerDto = centerDtoService.getCenterDto(type,centerId); TbsCenterDto centerDto = centerDtoService.getCenterDto(type,centerId);
//停止时间 //停止时间
//LocalDateTime nowTime = LocalDateTime.now();
LocalDateTime nowTime = param.getExtendDate().atStartOfDay(); LocalDateTime nowTime = param.getExtendDate().atStartOfDay();
//当前节点
BmsCenterExtend currentCenter = new BmsCenterExtend();
currentCenter.setSourceId(0L); BmsCenterExtend currentCenter;
currentCenter.setCenterType(type); if(param.getId()!=null){
currentCenter.setPathIds("0"); //代办更新,删除历史数据
currentCenter.setCenterId(centerId); LambdaQueryWrapper<BmsCenterExtend> rmLqw1 = new LambdaQueryWrapper<>();
currentCenter.setCenterCode(centerDto.getCenterCode()); rmLqw1.eq(BmsCenterExtend::getSourceId,param.getId());
currentCenter.setCenterName(centerDto.getCenterName()); this.remove(rmLqw1);
currentCenter.setStartTime(centerDto.getCreateTime());
currentCenter.setStopTime(nowTime); currentCenter = this.getById(param.getId());
currentCenter.setStopFlag(1); currentCenter.setStopTime(nowTime);
currentCenter.setWeightRate(n100); this.updateById(currentCenter);
this.save(currentCenter); }else {
//历史分摊节点 //代办新增
LambdaQueryWrapper<BmsCenterExtend> lqw = new LambdaQueryWrapper<>(); currentCenter = new BmsCenterExtend();
lqw.eq(BmsCenterExtend::getCenterType,param.getType()); currentCenter.setSourceId(0L);
lqw.eq(BmsCenterExtend::getCenterId,param.getSourceCenterId()); currentCenter.setCenterType(type);
lqw.eq(BmsCenterExtend::getStopFlag,0); currentCenter.setPathIds("0");
List<BmsCenterExtend> sourcesCenterList = this.list(lqw); currentCenter.setCenterId(centerId);
List<BmsCenterExtend> updList = this.list(lqw); currentCenter.setCenterCode(centerDto.getCenterCode());
for (BmsCenterExtend sourceCenter : sourcesCenterList) { currentCenter.setCenterName(centerDto.getCenterName());
if(sourceCenter.getStopFlag()==0){ currentCenter.setStartTime(centerDto.getCreateTime());
BmsCenterExtend centerExtend = new BmsCenterExtend(); currentCenter.setStopTime(nowTime);
centerExtend.setId(sourceCenter.getId()); currentCenter.setStopFlag(1);
centerExtend.setStopFlag(1); currentCenter.setWeightRate(n100);
centerExtend.setStopTime(nowTime); this.save(currentCenter);
updList.add(centerExtend);
}
} }
//新的继承节点 //新的继承节点
for (BmsCenterExtendBo.Item targetCenter : targetCenters) { for (BmsCenterExtendBo.Item targetCenter : targetCenters) {
TbsCenterDto centerDto2 = centerDtoService.getCenterDto(currentCenter.getCenterType(),targetCenter.getTargetCenterId()); TbsCenterDto centerDto2 = centerDtoService.getCenterDto(currentCenter.getCenterType(),targetCenter.getTargetCenterId());
@ -127,68 +123,10 @@ public class BmsCenterExtendServiceImpl extends ServiceImpl<BmsCenterExtendMappe
currentChildCenter.setStopFlag(0); currentChildCenter.setStopFlag(0);
currentChildCenter.setWeightRate(weightRate); currentChildCenter.setWeightRate(weightRate);
this.save(currentChildCenter); this.save(currentChildCenter);
//保持后继人员
this.toSaveExtendUser( currentCenter, targetCenter.getUserList(), centerDto2, currentChildCenter.getId()); this.toSaveExtendUser( currentCenter, targetCenter.getUserList(), centerDto2, currentChildCenter.getId());
} }
this.updateBatchById(updList);
return currentCenter; return currentCenter;
/*//校验
String type = param.getType();
String centerId = param.getSourceCenterId();
BigDecimal n100 = new BigDecimal("100");
List<BmsCenterExtendBo.Item> targetCenters = param.getTargetCenters();
BigDecimal totalRate = BigDecimal.ZERO;
for (BmsCenterExtendBo.Item center : targetCenters) {
totalRate=totalRate.add(center.getWeightRate());
}
if(totalRate.compareTo(n100)!=0){
Assert.throwEx("权重合计必须百分百");
}
if (this.checkIsStop(type,centerId)){
Assert.throwEx("当前成本中心已分配");
}
TbsCenterDto centerDto = centerDtoService.getCenterDto(type,centerId);
//停止时间
LocalDateTime nowTime = LocalDateTime.now();
//当前节点
BmsCenterExtend currentCenter = new BmsCenterExtend();
currentCenter.setSourceId(0L);
currentCenter.setCenterType(type);
currentCenter.setPathIds("0");
currentCenter.setCenterId(centerId);
currentCenter.setCenterCode(centerDto.getCenterCode());
currentCenter.setCenterName(centerDto.getCenterName());
currentCenter.setStartTime(centerDto.getCreateTime());
currentCenter.setStopTime(nowTime);
currentCenter.setStopFlag(1);
currentCenter.setWeightRate(n100);
this.save(currentCenter);
//历史分摊节点
LambdaQueryWrapper<BmsCenterExtend> lqw = new LambdaQueryWrapper<>();
lqw.eq(BmsCenterExtend::getCenterType,param.getType());
lqw.eq(BmsCenterExtend::getCenterId,param.getSourceCenterId());
lqw.eq(BmsCenterExtend::getStopFlag,0);
List<BmsCenterExtend> sourcesCenterList = this.list(lqw);
sourcesCenterList.add(currentCenter);
List<BmsCenterExtend> newList = new ArrayList<>();
List<BmsCenterExtend> updList = new ArrayList<>();
for (BmsCenterExtend sourceCenter : sourcesCenterList) {
newList.addAll(buildCenterExtend(sourceCenter,targetCenters,nowTime));
if(sourceCenter.getStopFlag()==0){
BmsCenterExtend centerExtend = new BmsCenterExtend();
centerExtend.setId(sourceCenter.getId());
centerExtend.setStopFlag(1);
centerExtend.setStopTime(nowTime);
updList.add(centerExtend);
}
}
if(CollectionUtil.isNotEmpty(updList)){
this.updateBatchById(updList);
}
this.saveBatch(newList);*/
} }
private void toSaveExtendUser(BmsCenterExtend currentCenter, List<BmsCenterExtendBo.AllocationUser> userList, TbsCenterDto centerDto2, Long childExtendId) { private void toSaveExtendUser(BmsCenterExtend currentCenter, List<BmsCenterExtendBo.AllocationUser> userList, TbsCenterDto centerDto2, Long childExtendId) {
@ -218,110 +156,6 @@ public class BmsCenterExtendServiceImpl extends ServiceImpl<BmsCenterExtendMappe
centerExtendUserService.saveBatch(extendUserList); centerExtendUserService.saveBatch(extendUserList);
} }
private List<BmsCenterExtend> buildCenterExtend(BmsCenterExtend sourceCenter,List<BmsCenterExtendBo.Item> targetCenters,LocalDateTime nowTime) {
BigDecimal n100 = new BigDecimal("100");
List<BmsCenterExtend> newList = new ArrayList<>();
for (BmsCenterExtendBo.Item targetCenter : targetCenters) {
TbsCenterDto centerDto = centerDtoService.getCenterDto(sourceCenter.getCenterType(),targetCenter.getTargetCenterId());
BigDecimal weightRate = sourceCenter.getWeightRate()
.multiply(sourceCenter.getWeightRate())
.divide(n100);
BmsCenterExtend currentCenter = new BmsCenterExtend();
currentCenter.setSourceId(sourceCenter.getId());
currentCenter.setCenterType(sourceCenter.getCenterType());
currentCenter.setPathIds(sourceCenter.getPathIds()+"_"+sourceCenter.getId());
currentCenter.setCenterId(centerDto.getId());
currentCenter.setCenterCode(centerDto.getCenterCode());
currentCenter.setCenterName(centerDto.getCenterName());
currentCenter.setStartTime(nowTime);
currentCenter.setStopFlag(0);
currentCenter.setWeightRate(weightRate);
newList.add(currentCenter);
}
return newList;
}
@Override
@Transactional(rollbackFor = Exception.class)
public void allocation4Update(BmsCenterExtendBo param) {
String type = param.getType();
String centerId = param.getSourceCenterId();
BigDecimal n100 = new BigDecimal("100");
List<BmsCenterExtendBo.Item> targetCenters = param.getTargetCenters();
BigDecimal totalRate = BigDecimal.ZERO;
for (BmsCenterExtendBo.Item center : targetCenters) {
totalRate=totalRate.add(center.getWeightRate());
}
if(totalRate.compareTo(n100)!=0){
Assert.throwEx("权重合计必须百分百");
}
for (BmsCenterExtendBo.Item targetCenter : targetCenters) {
if(targetCenter.getTargetCenterId().equals(param.getSourceCenterId())){
Assert.throwEx("后继成本中心与当前成本中心相同");
}
boolean b = this.checkIsStop(type,targetCenter.getTargetCenterId());
if(b){
Assert.throwEx("部分后继成本中心已分配");
}
}
List<BmsCenterExtendBo.Item> saveExtendBo = targetCenters.stream().filter(a->a.getId()==null).collect(Collectors.toList());
List<BmsCenterExtendBo.Item> updExtendBo = targetCenters.stream().filter(a->a.getId()!=null).collect(Collectors.toList());
List<Long> updateIds = targetCenters.stream().filter(a->a.getId()!=null).map(BmsCenterExtendBo.Item::getId).collect(Collectors.toList());
LocalDateTime nowTime = param.getExtendDate().atStartOfDay();
//更新被继承成本
BmsCenterExtend currentCenter = this.getById(param.getId());
currentCenter.setStopTime(nowTime);
this.updateById(currentCenter);
//移除
LambdaQueryWrapper<BmsCenterExtend> dellqw = new LambdaQueryWrapper<>();
dellqw.eq(BmsCenterExtend::getCenterType,param.getType());
dellqw.eq(BmsCenterExtend::getSourceId,param.getId());
dellqw.notIn(BmsCenterExtend::getId,updateIds);
this.remove(dellqw);
//新增
for (BmsCenterExtendBo.Item item : saveExtendBo) {
//校验是否可添加
if (this.checkIsStop(currentCenter.getCenterType(),item.getTargetCenterId())){
Assert.throwEx("新增的后继成本中心已被停用,请重新选择");
}
TbsCenterDto centerDto2 = centerDtoService.getCenterDto(type,centerId);
BmsCenterExtend currentChildCenter = new BmsCenterExtend();
currentChildCenter.setSourceId(currentCenter.getId());
currentChildCenter.setCenterType(currentCenter.getCenterType());
currentChildCenter.setPathIds(currentCenter.getPathIds()+"_"+currentCenter.getId());
currentChildCenter.setCenterId(centerDto2.getId());
currentChildCenter.setCenterCode(centerDto2.getCenterCode());
currentChildCenter.setCenterName(centerDto2.getCenterName());
currentChildCenter.setStartTime(currentCenter.getStopTime());
currentChildCenter.setStopFlag(0);
currentChildCenter.setWeightRate(item.getWeightRate());
this.save(currentChildCenter);
this.toSaveExtendUser( currentCenter, item.getUserList(), centerDto2, currentChildCenter.getId());
}
//更新
LambdaQueryWrapper<BmsCenterExtend> lqw = new LambdaQueryWrapper<>();
lqw.eq(BmsCenterExtend::getCenterType,param.getType());
lqw.in(BmsCenterExtend::getId,updateIds);
List<BmsCenterExtend> sourcesCenterList = this.list(lqw);
for (BmsCenterExtend centerExtend : sourcesCenterList) {
for (BmsCenterExtendBo.Item item : updExtendBo) {
if(centerExtend.getId().equals(item.getId())){
//匹配更新
centerExtend.setWeightRate(item.getWeightRate());
centerExtend.setStartTime(nowTime);
this.updateById(centerExtend);
LambdaQueryWrapper<BmsCenterExtendUser> delUsrLqw = new LambdaQueryWrapper<>();
delUsrLqw.eq(BmsCenterExtendUser::getChildExtId,centerExtend.getId());
centerExtendUserService.remove(delUsrLqw);
//重新保存
TbsCenterDto centerDto2 = centerDtoService.getCenterDto(type,item.getTargetCenterId());
this.toSaveExtendUser( currentCenter, item.getUserList(), centerDto2, centerExtend.getId());
}
}
}
}
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)

7
src/main/java/com/qs/serve/modules/bms/service/impl/BmsRegionServiceImpl.java

@ -111,8 +111,11 @@ public class BmsRegionServiceImpl extends ServiceImpl<BmsRegionMapper,BmsRegion>
} }
@Override @Override
public List<BmsRegionTreeVo> getTree(boolean listUserFlag) { public List<BmsRegionTreeVo> getTree(boolean listUserFlag,Integer stopFlag) {
LambdaQueryWrapper<BmsRegion> regionWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<BmsRegion> regionWrapper = new LambdaQueryWrapper<>();
if(stopFlag!=2){
regionWrapper.eq(BmsRegion::getStopFlag,stopFlag);
}
List<BmsRegion> list = this.list(regionWrapper); List<BmsRegion> list = this.list(regionWrapper);
if(listUserFlag){ if(listUserFlag){
LambdaQueryWrapper<BmsRegionUser> lqw = new LambdaQueryWrapper<>(); LambdaQueryWrapper<BmsRegionUser> lqw = new LambdaQueryWrapper<>();
@ -219,7 +222,7 @@ public class BmsRegionServiceImpl extends ServiceImpl<BmsRegionMapper,BmsRegion>
@Override @Override
public void flushAllLevel(boolean batchUpdate) { public void flushAllLevel(boolean batchUpdate) {
this.baseMapper.updateSetPathNull(); this.baseMapper.updateSetPathNull();
List<BmsRegionTreeVo> treeVoList = this.getTree(false); List<BmsRegionTreeVo> treeVoList = this.getTree(false,2);
for (BmsRegionTreeVo firstTree : treeVoList) { for (BmsRegionTreeVo firstTree : treeVoList) {
if(firstTree.getLevel()==null||firstTree.getLevel()!=1||batchUpdate){ if(firstTree.getLevel()==null||firstTree.getLevel()!=1||batchUpdate){
String pathIds = firstTree.getId(); String pathIds = firstTree.getId();

3
src/main/java/com/qs/serve/modules/tzc/service/impl/TzcPolicyServiceImpl.java

@ -53,8 +53,7 @@ public class TzcPolicyServiceImpl extends ServiceImpl<TzcPolicyMapper,TzcPolicy>
} }
}else { }else {
tzcPolicy = new TzcPolicy(); tzcPolicy = new TzcPolicy();
//tzcPolicy.setId(IdUtil.getSnowFlakeId()); tzcPolicy.setPolicyCode("P"+CodeGenUtil.generate(CodeGenUtil.SourceKey.Policy));
tzcPolicy.setPolicyCode(CodeGenUtil.generate(CodeGenUtil.SourceKey.Policy));
SysUser sysUser = sysUserService.getById(AuthContextUtils.getSysUserId()); SysUser sysUser = sysUserService.getById(AuthContextUtils.getSysUserId());
tzcPolicy.setUserId(sysUser.getId()); tzcPolicy.setUserId(sysUser.getId());
tzcPolicy.setUserCode(sysUser.getCode()); tzcPolicy.setUserCode(sysUser.getCode());

6
src/main/resources/application.yml

@ -22,11 +22,15 @@ project:
- /error - /error
- /portal/syKeyLogin - /portal/syKeyLogin
- /bir/roiRate/test - /bir/roiRate/test
- /static/*
- /web/*
permits: #忽略登录 permits: #忽略登录
- /thirty/** #第三方接口 - /thirty/** #第三方接口
- /common/upload #支持API上传调整 - /common/upload #支持API上传调整
- /common/validToken #验证token - /common/validToken #验证token
- /api/** - /api/**
- /static/**
- /web/**
- /portal/** - /portal/**
- /favicon.ico - /favicon.ico
- /error - /error
@ -52,6 +56,8 @@ logging:
level: level:
ROOT: info ROOT: info
com.qs.serve: debug com.qs.serve: debug
#com.qs.serve.modules.his: info
com.qs.serve.modules.sys: info
org.xnio.nio: info org.xnio.nio: info
org.springframework: info org.springframework: info
com.baomidou: info com.baomidou: info

Loading…
Cancel
Save