|
@@ -11,8 +11,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
|
|
import io.swagger.annotations.*;
|
|
import io.swagger.annotations.*;
|
|
|
-import lombok.AllArgsConstructor;
|
|
|
|
|
-import org.springblade.common.cache.DictBizCache;
|
|
|
|
|
|
|
+import lombok.RequiredArgsConstructor;
|
|
|
import org.springblade.constant.BusinessConstant;
|
|
import org.springblade.constant.BusinessConstant;
|
|
|
import org.springblade.constant.DictBusinessConstant;
|
|
import org.springblade.constant.DictBusinessConstant;
|
|
|
import org.springblade.core.boot.ctrl.BladeController;
|
|
import org.springblade.core.boot.ctrl.BladeController;
|
|
@@ -21,16 +20,18 @@ import org.springblade.core.mp.support.Query;
|
|
|
import org.springblade.core.secure.BladeUser;
|
|
import org.springblade.core.secure.BladeUser;
|
|
|
import org.springblade.core.secure.utils.AuthUtil;
|
|
import org.springblade.core.secure.utils.AuthUtil;
|
|
|
import org.springblade.core.tool.api.R;
|
|
import org.springblade.core.tool.api.R;
|
|
|
-import org.springblade.core.tool.utils.ConcurrentDateFormat;
|
|
|
|
|
import org.springblade.core.tool.utils.Func;
|
|
import org.springblade.core.tool.utils.Func;
|
|
|
import org.springblade.enums.*;
|
|
import org.springblade.enums.*;
|
|
|
import org.springblade.modules.baseinfo.dict.entity.DictInfoEntity;
|
|
import org.springblade.modules.baseinfo.dict.entity.DictInfoEntity;
|
|
|
import org.springblade.modules.baseinfo.dict.service.IBaseInfoDictService;
|
|
import org.springblade.modules.baseinfo.dict.service.IBaseInfoDictService;
|
|
|
|
|
+import org.springblade.modules.baseinfo.org.entity.DeptRegionEntity;
|
|
|
|
|
+import org.springblade.modules.baseinfo.org.service.IDeptRegionService;
|
|
|
import org.springblade.modules.baseinfo.rtu.entity.RtuInfoEntity;
|
|
import org.springblade.modules.baseinfo.rtu.entity.RtuInfoEntity;
|
|
|
import org.springblade.modules.baseinfo.rtu.service.IRtuBaseInfoService;
|
|
import org.springblade.modules.baseinfo.rtu.service.IRtuBaseInfoService;
|
|
|
-import org.springblade.modules.baseinfo.stbase.service.IMvAttStBaseService;
|
|
|
|
|
import org.springblade.modules.business.check.order.dto.CheckOrderInfoDTO;
|
|
import org.springblade.modules.business.check.order.dto.CheckOrderInfoDTO;
|
|
|
import org.springblade.modules.business.check.order.entity.CheckOrderInfoEntity;
|
|
import org.springblade.modules.business.check.order.entity.CheckOrderInfoEntity;
|
|
|
|
|
+import org.springblade.modules.business.check.order.entity.CheckOrderSettingEntity;
|
|
|
|
|
+import org.springblade.modules.business.check.order.service.ICheckOrderSettingService;
|
|
|
import org.springblade.modules.business.check.order.service.IRtuCheckOrderService;
|
|
import org.springblade.modules.business.check.order.service.IRtuCheckOrderService;
|
|
|
import org.springblade.modules.business.check.order.vo.CheckOrderCountVO;
|
|
import org.springblade.modules.business.check.order.vo.CheckOrderCountVO;
|
|
|
import org.springblade.modules.business.check.order.vo.CheckOrderInfoVO;
|
|
import org.springblade.modules.business.check.order.vo.CheckOrderInfoVO;
|
|
@@ -41,7 +42,6 @@ import org.springblade.modules.business.check.process.service.IRtuOrderProcessSe
|
|
|
import org.springblade.modules.business.data.entity.RtuDataRainEntity;
|
|
import org.springblade.modules.business.data.entity.RtuDataRainEntity;
|
|
|
import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
|
|
import org.springblade.modules.business.data.entity.RtuDataRiverEntity;
|
|
|
import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
|
|
import org.springblade.modules.business.data.entity.RtuDataRsvrEntity;
|
|
|
-import org.springblade.modules.business.data.service.IRtuDataGroundService;
|
|
|
|
|
import org.springblade.modules.business.data.service.IRtuDataRainService;
|
|
import org.springblade.modules.business.data.service.IRtuDataRainService;
|
|
|
import org.springblade.modules.business.data.service.IRtuDataRiverService;
|
|
import org.springblade.modules.business.data.service.IRtuDataRiverService;
|
|
|
import org.springblade.modules.business.data.service.IRtuDataRsvrService;
|
|
import org.springblade.modules.business.data.service.IRtuDataRsvrService;
|
|
@@ -58,10 +58,7 @@ import org.springblade.modules.system.service.IUserService;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
import springfox.documentation.annotations.ApiIgnore;
|
|
import springfox.documentation.annotations.ApiIgnore;
|
|
|
|
|
|
|
|
-import java.util.Date;
|
|
|
|
|
-import java.util.LinkedList;
|
|
|
|
|
-import java.util.List;
|
|
|
|
|
-import java.util.Map;
|
|
|
|
|
|
|
+import java.util.*;
|
|
|
|
|
|
|
|
/***
|
|
/***
|
|
|
* Date:2022/8/22
|
|
* Date:2022/8/22
|
|
@@ -73,44 +70,24 @@ import java.util.Map;
|
|
|
*/
|
|
*/
|
|
|
@RestController
|
|
@RestController
|
|
|
@RequestMapping("galaxy-business/rtu/check/order")
|
|
@RequestMapping("galaxy-business/rtu/check/order")
|
|
|
-@AllArgsConstructor
|
|
|
|
|
|
|
+@RequiredArgsConstructor
|
|
|
@Api(value = "测站设备故障工单管理模块", tags = "测站设备故障工单管理模块")
|
|
@Api(value = "测站设备故障工单管理模块", tags = "测站设备故障工单管理模块")
|
|
|
public class RtuCheckOrderController extends BladeController {
|
|
public class RtuCheckOrderController extends BladeController {
|
|
|
|
|
|
|
|
- private final IRtuCheckOrderService checkOrderService;
|
|
|
|
|
- private final IRtuOrderProcessService processService;
|
|
|
|
|
- private final IRtuWarningService warningService;
|
|
|
|
|
|
|
+ private final IRtuCheckOrderService rtuCheckOrderService;
|
|
|
|
|
+ private final IRtuOrderProcessService rtuOrderProcessService;
|
|
|
|
|
+ private final IRtuWarningService rtuWarningService;
|
|
|
private final IDictBizService dictBizService;
|
|
private final IDictBizService dictBizService;
|
|
|
- private final IRtuManageService manageService;
|
|
|
|
|
|
|
+ private final IRtuManageService rtuManageService;
|
|
|
private final IUserService userService;
|
|
private final IUserService userService;
|
|
|
private final IDeptService deptService;
|
|
private final IDeptService deptService;
|
|
|
private final IRtuBaseInfoService rtuBaseInfoService;
|
|
private final IRtuBaseInfoService rtuBaseInfoService;
|
|
|
- private final IMvAttStBaseService iMvAttStBaseService;
|
|
|
|
|
- private final IRtuDataRainService iRtuDataRainService;
|
|
|
|
|
- private final IRtuDataRiverService iRtuDataRiverService;
|
|
|
|
|
- private final IRtuDataRsvrService iRtuDataRsvrService;
|
|
|
|
|
- private final IRtuDataGroundService iRtuDataGroundService;
|
|
|
|
|
- private final IRtuManageService iRtuManageService;
|
|
|
|
|
- private final IBaseInfoDictService dictService;
|
|
|
|
|
- ;
|
|
|
|
|
-
|
|
|
|
|
- @GetMapping("/list")
|
|
|
|
|
- @ApiOperationSupport(order = 3)
|
|
|
|
|
- @ApiOperation(value = "列表", notes = "传入CheckOrderInfoDTO")
|
|
|
|
|
- public R<List<CheckOrderInfoVO>> page(CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
- LambdaQueryWrapper<CheckOrderInfoEntity> wrapper = Wrappers.<CheckOrderInfoEntity>query().lambda();
|
|
|
|
|
- if (checkOrderInfoDTO.getRtuCode() != null) {
|
|
|
|
|
- wrapper.eq(CheckOrderInfoEntity::getRtuCode, checkOrderInfoDTO.getRtuCode());
|
|
|
|
|
- }
|
|
|
|
|
- wrapper.orderByAsc(CheckOrderInfoEntity::getOrderStatusKey);
|
|
|
|
|
- wrapper.orderByDesc(CheckOrderInfoEntity::getUpdateTime);
|
|
|
|
|
- //wrapper.last("limit 1");
|
|
|
|
|
- List<CheckOrderInfoEntity> pages = checkOrderService.list(wrapper);
|
|
|
|
|
-
|
|
|
|
|
- return R.data(RtuCheckOrderWrapper.build().listVO(pages));
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ private final IRtuDataRainService rtuDataRainService;
|
|
|
|
|
+ private final IRtuDataRiverService rtuDataRiverService;
|
|
|
|
|
+ private final IRtuDataRsvrService rtuDataRsvrService;
|
|
|
|
|
+ private final IBaseInfoDictService baseInfoDictService;
|
|
|
|
|
+ private final IDeptRegionService deptRegionService;
|
|
|
|
|
+ private final ICheckOrderSettingService checkOrderSettingService;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 工单查询,分页
|
|
* 工单查询,分页
|
|
@@ -120,34 +97,57 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
|
|
|
@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string"),
|
|
|
@ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
|
|
|
- @ApiImplicitParam(name = "orgId", value = "机构ID", paramType = "query", dataType = "long"),
|
|
|
|
|
@ApiImplicitParam(name = "orderConfirm", value = "是否确认", paramType = "query", dataType = "int"),
|
|
@ApiImplicitParam(name = "orderConfirm", value = "是否确认", paramType = "query", dataType = "int"),
|
|
|
@ApiImplicitParam(name = "orderClose", value = "是否关闭", paramType = "query", dataType = "int"),
|
|
@ApiImplicitParam(name = "orderClose", value = "是否关闭", paramType = "query", dataType = "int"),
|
|
|
|
|
+ @ApiImplicitParam(name = "servicePersonId", value = "运维人员", paramType = "query", dataType = "long"),
|
|
|
|
|
+ @ApiImplicitParam(name = "deptId", value = "部门ID", paramType = "query", dataType = "long"),
|
|
|
|
|
+ @ApiImplicitParam(name = "warnKind", value = "异常类型", paramType = "query", dataType = "int")
|
|
|
})
|
|
})
|
|
|
@ApiOperationSupport(order = 3)
|
|
@ApiOperationSupport(order = 3)
|
|
|
- @ApiOperation(value = "分页", notes = "传入checkOrderInfoDTO")
|
|
|
|
|
|
|
+ @ApiOperation(value = "分页", notes = "传入实体类CheckOrderInfoDTO")
|
|
|
public R<IPage<CheckOrderInfoVO>> page(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO, Query query) {
|
|
public R<IPage<CheckOrderInfoVO>> page(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO, Query query) {
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_ORG_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(Func.toLong(user.getDeptId()));
|
|
|
|
|
- }
|
|
|
|
|
- if (null != checkOrderInfoDTO.getRtuCode() && checkOrderInfoDTO.getRtuCode().length() > 0) {
|
|
|
|
|
- if (Func.isNumeric(checkOrderInfoDTO.getRtuCode())) {
|
|
|
|
|
- checkOrderInfoDTO.setRtuName(null);
|
|
|
|
|
- } else {
|
|
|
|
|
- checkOrderInfoDTO.setRtuCode(null);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ if (checkOrderInfoDTO.getDeptId() != null) {
|
|
|
|
|
+ LambdaQueryWrapper<DeptRegionEntity> deptLambdaQueryWrapper = Wrappers.<DeptRegionEntity>query().lambda();
|
|
|
|
|
+ deptLambdaQueryWrapper.eq(DeptRegionEntity::getIsDeleted, 0);
|
|
|
|
|
+ deptLambdaQueryWrapper.eq(DeptRegionEntity::getDeptId, checkOrderInfoDTO.getDeptId());
|
|
|
|
|
+ DeptRegionEntity deptRegionEntity = deptRegionService.getOne(deptLambdaQueryWrapper);
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(deptRegionEntity.getAdcd());
|
|
|
} else {
|
|
} else {
|
|
|
- checkOrderInfoDTO.setRtuCode(null);
|
|
|
|
|
- checkOrderInfoDTO.setRtuName(null);
|
|
|
|
|
|
|
+ if (BusinessConstant.ROLE_SYS_ADMIN.equals(user.getRoleName())) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(BusinessConstant.REGION_NM_ADCODE);
|
|
|
|
|
+ }
|
|
|
|
|
+ } else if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ LambdaQueryWrapper<DeptRegionEntity> deptRegionEntityLambdaQueryWrapper = Wrappers.<DeptRegionEntity>query().lambda();
|
|
|
|
|
+ deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getIsDeleted, 0);
|
|
|
|
|
+ deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getDeptId, Func.toLong(user.getDeptId()));
|
|
|
|
|
+ DeptRegionEntity deptRegionEntity = deptRegionService.getOne(deptRegionEntityLambdaQueryWrapper);
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(deptRegionEntity.getAdcd());
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ if (BusinessConstant.ROLE_COMPANY_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
+ if(checkOrderInfoDTO.getOrderConfirm()!=null&&checkOrderInfoDTO.getOrderConfirm()==1 ){
|
|
|
|
|
+ checkOrderInfoDTO.setContactUser(user.getUserId());
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- IPage<CheckOrderInfoVO> pages = checkOrderService.selectPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
|
|
- List<CheckOrderInfoVO> list = pages.getRecords();
|
|
|
|
|
- for (CheckOrderInfoVO v : list) {
|
|
|
|
|
- RtuCheckOrderWrapper.build().addInfoVO(v);
|
|
|
|
|
|
|
+ if (checkOrderInfoDTO.getWarnKind()!=null){
|
|
|
|
|
+ IPage<CheckOrderInfoVO> pages = rtuCheckOrderService.selectWarnPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
|
|
+ List<CheckOrderInfoVO> list = pages.getRecords();
|
|
|
|
|
+ for (CheckOrderInfoVO v : list) {
|
|
|
|
|
+ RtuCheckOrderWrapper.build().entityVO(v);
|
|
|
|
|
+ }
|
|
|
|
|
+ return R.data(pages);
|
|
|
|
|
+ }else{
|
|
|
|
|
+ IPage<CheckOrderInfoVO> pages = rtuCheckOrderService.selectPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
|
|
+ List<CheckOrderInfoVO> list = pages.getRecords();
|
|
|
|
|
+ for (CheckOrderInfoVO v : list) {
|
|
|
|
|
+ RtuCheckOrderWrapper.build().entityVO(v);
|
|
|
|
|
+ }
|
|
|
|
|
+ return R.data(pages);
|
|
|
}
|
|
}
|
|
|
- return R.data(pages);
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -159,81 +159,91 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string")
|
|
@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string")
|
|
|
})
|
|
})
|
|
|
@ApiOperationSupport(order = 3)
|
|
@ApiOperationSupport(order = 3)
|
|
|
- @ApiOperation(value = "分页", notes = "传入checkOrderInfoDTO")
|
|
|
|
|
|
|
+ @ApiOperation(value = "分页", notes = "传入实体类CheckOrderInfoDTO")
|
|
|
public R<IPage<CheckOrderInfoVO>> mypage(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO, Query query) {
|
|
public R<IPage<CheckOrderInfoVO>> mypage(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO, Query query) {
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
checkOrderInfoDTO.setContactUser(user.getUserId());
|
|
checkOrderInfoDTO.setContactUser(user.getUserId());
|
|
|
checkOrderInfoDTO.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
checkOrderInfoDTO.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
|
checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
|
- IPage<CheckOrderInfoVO> pages = checkOrderService.selectPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
|
|
|
|
+ IPage<CheckOrderInfoVO> pages = rtuCheckOrderService.selectMyPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
List<CheckOrderInfoVO> list = pages.getRecords();
|
|
List<CheckOrderInfoVO> list = pages.getRecords();
|
|
|
for (CheckOrderInfoVO v : list) {
|
|
for (CheckOrderInfoVO v : list) {
|
|
|
- RtuCheckOrderWrapper.build().addInfoVO(v);
|
|
|
|
|
|
|
+ RtuCheckOrderWrapper.build().entityVO(v);
|
|
|
}
|
|
}
|
|
|
return R.data(pages);
|
|
return R.data(pages);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-
|
|
|
|
|
/**
|
|
/**
|
|
|
- * 未确认工单列表,不分页
|
|
|
|
|
|
|
+ * 未确认工单列表,不分页,最多返回10条数据
|
|
|
*/
|
|
*/
|
|
|
- @GetMapping("/unconfirm/list")
|
|
|
|
|
|
|
+ @GetMapping("/unconfirm/last/list")
|
|
|
@ApiImplicitParams({
|
|
@ApiImplicitParams({
|
|
|
@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
|
|
|
@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string"),
|
|
|
@ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
|
|
|
})
|
|
})
|
|
|
@ApiOperationSupport(order = 3)
|
|
@ApiOperationSupport(order = 3)
|
|
|
- @ApiOperation(value = "不分页", notes = "")
|
|
|
|
|
|
|
+ @ApiOperation(value = "不分页", notes = "传入实体类CheckOrderInfoDTO")
|
|
|
public R<List<CheckOrderInfoVO>> unconfirmOrderList(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
public R<List<CheckOrderInfoVO>> unconfirmOrderList(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- checkOrderInfoDTO.setOrderConfirm(OrderConfirmEnum.ACTIVE_CREATE.getCode());
|
|
|
|
|
- if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_ORG_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(Func.toLong(user.getDeptId()));
|
|
|
|
|
- } else {
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(null);
|
|
|
|
|
- }
|
|
|
|
|
- if (null != checkOrderInfoDTO.getRtuCode() && checkOrderInfoDTO.getRtuCode().length() > 0) {
|
|
|
|
|
- if (Func.isNumeric(checkOrderInfoDTO.getRtuCode())) {
|
|
|
|
|
- checkOrderInfoDTO.setRtuName(null);
|
|
|
|
|
- } else {
|
|
|
|
|
- checkOrderInfoDTO.setRtuCode(null);
|
|
|
|
|
|
|
+ if (BusinessConstant.ROLE_SYS_ADMIN.equals(user.getRoleName())) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(BusinessConstant.REGION_NM_ADCODE);
|
|
|
|
|
+ }
|
|
|
|
|
+ } else if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ LambdaQueryWrapper<DeptRegionEntity> deptRegionEntityLambdaQueryWrapper = Wrappers.<DeptRegionEntity>query().lambda();
|
|
|
|
|
+ deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getIsDeleted, 0);
|
|
|
|
|
+ deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getDeptId, Func.toLong(user.getDeptId()));
|
|
|
|
|
+ DeptRegionEntity deptRegionEntity = deptRegionService.getOne(deptRegionEntityLambdaQueryWrapper);
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(deptRegionEntity.getAdcd());
|
|
|
}
|
|
}
|
|
|
- } else {
|
|
|
|
|
- checkOrderInfoDTO.setRtuCode(null);
|
|
|
|
|
- checkOrderInfoDTO.setRtuName(null);
|
|
|
|
|
}
|
|
}
|
|
|
- List<CheckOrderInfoVO> list = checkOrderService.unconfirmOrderList(checkOrderInfoDTO);
|
|
|
|
|
|
|
+ List<CheckOrderInfoVO> list = rtuCheckOrderService.unconfirmOrderList(checkOrderInfoDTO);
|
|
|
for (CheckOrderInfoVO v : list) {
|
|
for (CheckOrderInfoVO v : list) {
|
|
|
- RtuCheckOrderWrapper.build().addInfoVO(v);
|
|
|
|
|
|
|
+ RtuCheckOrderWrapper.build().entityVO(v);
|
|
|
}
|
|
}
|
|
|
return R.data(list);
|
|
return R.data(list);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- /**
|
|
|
|
|
- * 今日工单动态
|
|
|
|
|
- */
|
|
|
|
|
- @GetMapping("/today/page")
|
|
|
|
|
|
|
+ @GetMapping("/confirm/delay/page")
|
|
|
@ApiImplicitParams({
|
|
@ApiImplicitParams({
|
|
|
@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
|
|
@ApiImplicitParam(name = "rtuCode", value = "测站编码", paramType = "query", dataType = "string"),
|
|
|
- @ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string")
|
|
|
|
|
|
|
+ @ApiImplicitParam(name = "rtuName", value = "测站名称", paramType = "query", dataType = "string"),
|
|
|
|
|
+ @ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
|
|
|
})
|
|
})
|
|
|
@ApiOperationSupport(order = 3)
|
|
@ApiOperationSupport(order = 3)
|
|
|
- @ApiOperation(value = "分页", notes = "传入checkOrderInfoDTO")
|
|
|
|
|
- public R<IPage<CheckOrderInfoVO>> todayPage(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO, Query query) {
|
|
|
|
|
|
|
+ @ApiOperation(value = "分页", notes = "传入实体类CheckOrderInfoDTO")
|
|
|
|
|
+ public R<IPage<CheckOrderInfoVO>> unconfirmDelayPage(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO, Query query) {
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_ORG_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(Func.toLong(user.getDeptId()));
|
|
|
|
|
|
|
+ if (BusinessConstant.ROLE_SYS_ADMIN.equals(user.getRoleName())) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(BusinessConstant.REGION_NM_ADCODE);
|
|
|
|
|
+ }
|
|
|
|
|
+ } else if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_COMPANY_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ LambdaQueryWrapper<DeptRegionEntity> deptRegionEntityLambdaQueryWrapper = Wrappers.<DeptRegionEntity>query().lambda();
|
|
|
|
|
+ deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getIsDeleted, 0);
|
|
|
|
|
+ deptRegionEntityLambdaQueryWrapper.eq(DeptRegionEntity::getDeptId, Func.toLong(user.getDeptId()));
|
|
|
|
|
+ DeptRegionEntity deptRegionEntity = deptRegionService.getOne(deptRegionEntityLambdaQueryWrapper);
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(deptRegionEntity.getAdcd());
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ CheckOrderSettingEntity vo = new CheckOrderSettingEntity();
|
|
|
|
|
+ LambdaQueryWrapper<CheckOrderSettingEntity> wrapper = Wrappers.<CheckOrderSettingEntity>query().lambda();
|
|
|
|
|
+ wrapper.eq(CheckOrderSettingEntity::getIsDeleted, 0);
|
|
|
|
|
+ List<CheckOrderSettingEntity> settingEntityList = checkOrderSettingService.list(wrapper);
|
|
|
|
|
+ if (null != settingEntityList && settingEntityList.size() > 0) {
|
|
|
|
|
+ CheckOrderSettingEntity settingEntity = settingEntityList.get(0);
|
|
|
|
|
+ checkOrderInfoDTO.setOrderComfireDelayTime(settingEntity.getOrderComfireDelayTime());
|
|
|
} else {
|
|
} else {
|
|
|
- checkOrderInfoDTO.setOrgId(null);
|
|
|
|
|
|
|
+ checkOrderInfoDTO.setOrderComfireDelayTime(120);
|
|
|
}
|
|
}
|
|
|
- Date date = new Date();
|
|
|
|
|
- String dt = Func.formatDateTime(date);
|
|
|
|
|
- checkOrderInfoDTO.setCreateTime(Func.parse(dt, ConcurrentDateFormat.of("yyyy-MM-dd")));
|
|
|
|
|
- IPage<CheckOrderInfoVO> pages = checkOrderService.selectPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
|
|
|
|
+
|
|
|
|
|
+ IPage<CheckOrderInfoVO> pages = rtuCheckOrderService.selectConfirmDelayPage(Condition.getPage(query), checkOrderInfoDTO);
|
|
|
List<CheckOrderInfoVO> list = pages.getRecords();
|
|
List<CheckOrderInfoVO> list = pages.getRecords();
|
|
|
for (CheckOrderInfoVO v : list) {
|
|
for (CheckOrderInfoVO v : list) {
|
|
|
- RtuCheckOrderWrapper.build().addInfoVO(v);
|
|
|
|
|
|
|
+ RtuCheckOrderWrapper.build().entityVO(v);
|
|
|
}
|
|
}
|
|
|
return R.data(pages);
|
|
return R.data(pages);
|
|
|
}
|
|
}
|
|
@@ -243,68 +253,83 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
*/
|
|
*/
|
|
|
@GetMapping("/detail")
|
|
@GetMapping("/detail")
|
|
|
@ApiOperationSupport(order = 1)
|
|
@ApiOperationSupport(order = 1)
|
|
|
- @ApiOperation(value = "详情", notes = "传入CheckOrderInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "详情", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
public R<CheckOrderInfoVO> detail(CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
public R<CheckOrderInfoVO> detail(CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
|
- BladeUser user = AuthUtil.getUser();
|
|
|
|
|
-
|
|
|
|
|
- CheckOrderInfoEntity detail = checkOrderService.getOne(Condition.getQueryWrapper(checkOrderInfoEntity));
|
|
|
|
|
-
|
|
|
|
|
|
|
+ if (checkOrderInfoEntity.getId() == null) {
|
|
|
|
|
+ return R.fail("参数错误");
|
|
|
|
|
+ }
|
|
|
|
|
+ CheckOrderInfoEntity detail = rtuCheckOrderService.getById(checkOrderInfoEntity.getId());
|
|
|
LambdaQueryWrapper<RtuInfoEntity> wrapper = Wrappers.<RtuInfoEntity>query().lambda();
|
|
LambdaQueryWrapper<RtuInfoEntity> wrapper = Wrappers.<RtuInfoEntity>query().lambda();
|
|
|
wrapper.eq(RtuInfoEntity::getRtuCode, detail.getRtuCode());
|
|
wrapper.eq(RtuInfoEntity::getRtuCode, detail.getRtuCode());
|
|
|
wrapper.eq(RtuInfoEntity::getIsDeleted, 0L);
|
|
wrapper.eq(RtuInfoEntity::getIsDeleted, 0L);
|
|
|
RtuInfoEntity rtuInfoEntity = rtuBaseInfoService.getOne(wrapper);
|
|
RtuInfoEntity rtuInfoEntity = rtuBaseInfoService.getOne(wrapper);
|
|
|
-
|
|
|
|
|
CheckOrderInfoVO vo = RtuCheckOrderWrapper.build().entityVO(detail);
|
|
CheckOrderInfoVO vo = RtuCheckOrderWrapper.build().entityVO(detail);
|
|
|
- RtuCheckOrderWrapper.build().addInfoVO(vo);
|
|
|
|
|
-
|
|
|
|
|
vo.setRtuName(rtuInfoEntity.getRtuName());
|
|
vo.setRtuName(rtuInfoEntity.getRtuName());
|
|
|
vo.setAdCity(rtuInfoEntity.getAdCity());
|
|
vo.setAdCity(rtuInfoEntity.getAdCity());
|
|
|
vo.setAdDist(rtuInfoEntity.getAdDist());
|
|
vo.setAdDist(rtuInfoEntity.getAdDist());
|
|
|
- vo.setAreaName(rtuInfoEntity.getAdCity() + "/" + rtuInfoEntity.getAdDist());
|
|
|
|
|
vo.setLocationDesc(rtuInfoEntity.getLocationDesc());
|
|
vo.setLocationDesc(rtuInfoEntity.getLocationDesc());
|
|
|
vo.setLng(rtuInfoEntity.getLng());
|
|
vo.setLng(rtuInfoEntity.getLng());
|
|
|
vo.setLat(rtuInfoEntity.getLat());
|
|
vo.setLat(rtuInfoEntity.getLat());
|
|
|
-
|
|
|
|
|
|
|
+ vo.setNetworkPayer(rtuInfoEntity.getNetworkPayer());
|
|
|
|
|
+ vo.setNetworkSimId(rtuInfoEntity.getNetworkSimId());
|
|
|
|
|
+ vo.setIsRain(rtuInfoEntity.getIsRain());
|
|
|
|
|
+ vo.setIsRiver(rtuInfoEntity.getIsRiver());
|
|
|
|
|
+ vo.setIsRes(rtuInfoEntity.getIsRes());
|
|
|
|
|
+ vo.setIsGround(rtuInfoEntity.getIsGround());
|
|
|
|
|
+ vo.setIsVideo(rtuInfoEntity.getIsVideo());
|
|
|
LambdaQueryWrapper<RtuStatusEntity> statusWwrapper = Wrappers.<RtuStatusEntity>query().lambda();
|
|
LambdaQueryWrapper<RtuStatusEntity> statusWwrapper = Wrappers.<RtuStatusEntity>query().lambda();
|
|
|
statusWwrapper.eq(RtuStatusEntity::getRtuCode, detail.getRtuCode());
|
|
statusWwrapper.eq(RtuStatusEntity::getRtuCode, detail.getRtuCode());
|
|
|
statusWwrapper.eq(RtuStatusEntity::getIsDeleted, 0L);
|
|
statusWwrapper.eq(RtuStatusEntity::getIsDeleted, 0L);
|
|
|
- RtuStatusEntity statusEntity = iRtuManageService.getOne(statusWwrapper);
|
|
|
|
|
|
|
+ RtuStatusEntity statusEntity = rtuManageService.getOne(statusWwrapper);
|
|
|
if (null != statusEntity) {
|
|
if (null != statusEntity) {
|
|
|
vo.setLastUpTime(statusEntity.getLastUpTime());
|
|
vo.setLastUpTime(statusEntity.getLastUpTime());
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- vo.setIsRain(rtuInfoEntity.getIsRain());
|
|
|
|
|
- vo.setIsRiver(rtuInfoEntity.getIsRiver());
|
|
|
|
|
- vo.setIsRes(rtuInfoEntity.getIsRes());
|
|
|
|
|
- vo.setIsGround(rtuInfoEntity.getIsGround());
|
|
|
|
|
-
|
|
|
|
|
- if (rtuInfoEntity.getIsRain() == 1) {
|
|
|
|
|
|
|
+ if (rtuInfoEntity.getIsRain() != null && rtuInfoEntity.getIsRain() == 1) {
|
|
|
LambdaQueryWrapper<RtuDataRainEntity> rainwrapper = Wrappers.<RtuDataRainEntity>query().lambda();
|
|
LambdaQueryWrapper<RtuDataRainEntity> rainwrapper = Wrappers.<RtuDataRainEntity>query().lambda();
|
|
|
rainwrapper.eq(RtuDataRainEntity::getRtuCode, detail.getRtuCode());
|
|
rainwrapper.eq(RtuDataRainEntity::getRtuCode, detail.getRtuCode());
|
|
|
rainwrapper.eq(RtuDataRainEntity::getIsDeleted, 0L);
|
|
rainwrapper.eq(RtuDataRainEntity::getIsDeleted, 0L);
|
|
|
- RtuDataRainEntity rainEntity = iRtuDataRainService.getOne(rainwrapper);
|
|
|
|
|
- vo.setDrp(rainEntity.getDrp());
|
|
|
|
|
- } else if (rtuInfoEntity.getIsRiver() == 1) {
|
|
|
|
|
|
|
+ RtuDataRainEntity rainEntity = rtuDataRainService.getOne(rainwrapper);
|
|
|
|
|
+ if (null != rainEntity) {
|
|
|
|
|
+ vo.setDrp(rainEntity.getDrp());
|
|
|
|
|
+ }
|
|
|
|
|
+ } else if (rtuInfoEntity.getIsRiver() != null && rtuInfoEntity.getIsRiver() == 1) {
|
|
|
LambdaQueryWrapper<RtuDataRiverEntity> riverwrapper = Wrappers.<RtuDataRiverEntity>query().lambda();
|
|
LambdaQueryWrapper<RtuDataRiverEntity> riverwrapper = Wrappers.<RtuDataRiverEntity>query().lambda();
|
|
|
riverwrapper.eq(RtuDataRiverEntity::getRtuCode, detail.getRtuCode());
|
|
riverwrapper.eq(RtuDataRiverEntity::getRtuCode, detail.getRtuCode());
|
|
|
riverwrapper.eq(RtuDataRiverEntity::getIsDeleted, 0L);
|
|
riverwrapper.eq(RtuDataRiverEntity::getIsDeleted, 0L);
|
|
|
- RtuDataRiverEntity riverEntity = iRtuDataRiverService.getOne(riverwrapper);
|
|
|
|
|
- vo.setZ(riverEntity.getZ());
|
|
|
|
|
- } else if (rtuInfoEntity.getIsRes() == 1) {
|
|
|
|
|
|
|
+ RtuDataRiverEntity riverEntity = rtuDataRiverService.getOne(riverwrapper);
|
|
|
|
|
+ if (riverEntity != null) {
|
|
|
|
|
+ vo.setZ(riverEntity.getZ());
|
|
|
|
|
+ }
|
|
|
|
|
+ } else if (rtuInfoEntity.getIsRes() != null && rtuInfoEntity.getIsRes() == 1) {
|
|
|
LambdaQueryWrapper<RtuDataRsvrEntity> rsvrWrapper = Wrappers.<RtuDataRsvrEntity>query().lambda();
|
|
LambdaQueryWrapper<RtuDataRsvrEntity> rsvrWrapper = Wrappers.<RtuDataRsvrEntity>query().lambda();
|
|
|
rsvrWrapper.eq(RtuDataRsvrEntity::getRtuCode, detail.getRtuCode());
|
|
rsvrWrapper.eq(RtuDataRsvrEntity::getRtuCode, detail.getRtuCode());
|
|
|
rsvrWrapper.eq(RtuDataRsvrEntity::getIsDeleted, 0L);
|
|
rsvrWrapper.eq(RtuDataRsvrEntity::getIsDeleted, 0L);
|
|
|
- RtuDataRsvrEntity rsvrEntity = iRtuDataRsvrService.getOne(rsvrWrapper);
|
|
|
|
|
- vo.setRz(rsvrEntity.getRz());
|
|
|
|
|
- } else if (rtuInfoEntity.getIsGround() == 1) {
|
|
|
|
|
-// LambdaQueryWrapper<RtuDataRainEntity> rainwrapper = Wrappers.<RtuDataRainEntity>query().lambda();
|
|
|
|
|
-// rainwrapper.eq(RtuDataRainEntity::getRtuCode,detail.getRtuCode());
|
|
|
|
|
-// rainwrapper.eq(RtuDataRainEntity::getIsDeleted,0L);
|
|
|
|
|
-// RtuDataRainEntity rainEntity=iRtuDataRainService.getOne(rainwrapper);
|
|
|
|
|
-// vo.setDrp(rainEntity.getDrp());
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ RtuDataRsvrEntity rsvrEntity = rtuDataRsvrService.getOne(rsvrWrapper);
|
|
|
|
|
+ if (rsvrEntity != null) {
|
|
|
|
|
+ vo.setRz(rsvrEntity.getRz());
|
|
|
|
|
+ }
|
|
|
|
|
+ } else if (rtuInfoEntity.getIsGround() != null && rtuInfoEntity.getIsGround() == 1) {
|
|
|
|
|
|
|
|
|
|
+ }
|
|
|
|
|
+ return R.data(vo);
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 详情
|
|
|
|
|
+ */
|
|
|
|
|
+ @GetMapping("/setting/detail")
|
|
|
|
|
+ @ApiOperationSupport(order = 1)
|
|
|
|
|
+ @ApiOperation(value = "设置详情")
|
|
|
|
|
+ public R<CheckOrderSettingEntity> settingDetail() {
|
|
|
|
|
+ CheckOrderSettingEntity vo = new CheckOrderSettingEntity();
|
|
|
|
|
+ LambdaQueryWrapper<CheckOrderSettingEntity> wrapper = Wrappers.<CheckOrderSettingEntity>query().lambda();
|
|
|
|
|
+ wrapper.eq(CheckOrderSettingEntity::getIsDeleted, 0);
|
|
|
|
|
+ List<CheckOrderSettingEntity> list = checkOrderSettingService.list(wrapper);
|
|
|
|
|
+ if (null != list && list.size() > 0) {
|
|
|
|
|
+ vo = list.get(0);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ vo.setOrderComfireDelayTime(120);
|
|
|
|
|
+ }
|
|
|
return R.data(vo);
|
|
return R.data(vo);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -313,16 +338,16 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
*/
|
|
*/
|
|
|
@PostMapping("/save")
|
|
@PostMapping("/save")
|
|
|
@ApiOperationSupport(order = 4)
|
|
@ApiOperationSupport(order = 4)
|
|
|
- @ApiOperation(value = "新增", notes = "传入checkOrderInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "新增", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
public R save(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
public R save(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
|
- DictInfoEntity dictInfoEntity = dictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CREATE.getCode());
|
|
|
|
|
|
|
+ DictInfoEntity dictInfoEntity = baseInfoDictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CREATE.getCode());
|
|
|
checkOrderInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
checkOrderInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
|
- checkOrderService.save(checkOrderInfoEntity);
|
|
|
|
|
|
|
+ rtuCheckOrderService.save(checkOrderInfoEntity);
|
|
|
OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
|
processInfoEntity.setOrderId(checkOrderInfoEntity.getId());
|
|
processInfoEntity.setOrderId(checkOrderInfoEntity.getId());
|
|
|
processInfoEntity.setOrderStatusKey(checkOrderInfoEntity.getOrderStatusKey());
|
|
processInfoEntity.setOrderStatusKey(checkOrderInfoEntity.getOrderStatusKey());
|
|
|
processInfoEntity.setProcessDesc(checkOrderInfoEntity.getOrderDesc());
|
|
processInfoEntity.setProcessDesc(checkOrderInfoEntity.getOrderDesc());
|
|
|
- return R.status(processService.save(processInfoEntity));
|
|
|
|
|
|
|
+ return R.status(rtuOrderProcessService.save(processInfoEntity));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -330,9 +355,9 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
*/
|
|
*/
|
|
|
@PostMapping("/update")
|
|
@PostMapping("/update")
|
|
|
@ApiOperationSupport(order = 5)
|
|
@ApiOperationSupport(order = 5)
|
|
|
- @ApiOperation(value = "修改", notes = "传入checkOrderInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "修改", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
public R update(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
public R update(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
|
- return R.status(checkOrderService.updateById(checkOrderInfoEntity));
|
|
|
|
|
|
|
+ return R.status(rtuCheckOrderService.updateById(checkOrderInfoEntity));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -340,9 +365,22 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
*/
|
|
*/
|
|
|
@PostMapping("/submit")
|
|
@PostMapping("/submit")
|
|
|
@ApiOperationSupport(order = 6)
|
|
@ApiOperationSupport(order = 6)
|
|
|
- @ApiOperation(value = "新增或修改", notes = "传入checkOrderInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "新增或修改", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
public R submit(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
public R submit(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
|
- return R.status(checkOrderService.saveOrUpdate(checkOrderInfoEntity));
|
|
|
|
|
|
|
+ return R.status(rtuCheckOrderService.saveOrUpdate(checkOrderInfoEntity));
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 新增或修改
|
|
|
|
|
+ */
|
|
|
|
|
+ @PostMapping("/setting/submit")
|
|
|
|
|
+ @ApiOperationSupport(order = 6)
|
|
|
|
|
+ @ApiOperation(value = "新增或修改", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
|
|
+ public R settingSubmit(@RequestBody CheckOrderSettingEntity checkOrderSettingEntity) {
|
|
|
|
|
+ if (checkOrderSettingEntity.getId() <= 0L) {
|
|
|
|
|
+ checkOrderSettingEntity.setId(null);
|
|
|
|
|
+ }
|
|
|
|
|
+ return R.status(checkOrderSettingService.saveOrUpdate(checkOrderSettingEntity));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -350,9 +388,9 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
*/
|
|
*/
|
|
|
@PostMapping("/remove")
|
|
@PostMapping("/remove")
|
|
|
@ApiOperationSupport(order = 7)
|
|
@ApiOperationSupport(order = 7)
|
|
|
- @ApiOperation(value = "逻辑删除", notes = "传入projectInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "逻辑删除", notes = "传入ID数组")
|
|
|
public R remove(@ApiParam(value = "主键集合") @RequestParam String ids) {
|
|
public R remove(@ApiParam(value = "主键集合") @RequestParam String ids) {
|
|
|
- boolean temp = checkOrderService.deleteLogic(Func.toLongList(ids));
|
|
|
|
|
|
|
+ boolean temp = rtuCheckOrderService.deleteLogic(Func.toLongList(ids));
|
|
|
return R.status(temp);
|
|
return R.status(temp);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -368,12 +406,12 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
@ApiImplicitParam(name = "orderDesc", value = "处理意见", paramType = "query", dataType = "string")
|
|
@ApiImplicitParam(name = "orderDesc", value = "处理意见", paramType = "query", dataType = "string")
|
|
|
})
|
|
})
|
|
|
@ApiOperationSupport(order = 4)
|
|
@ApiOperationSupport(order = 4)
|
|
|
- @ApiOperation(value = "工单关闭", notes = "传入checkOrderInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "工单关闭", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
public R orderClose(@ApiIgnore CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
public R orderClose(@ApiIgnore CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- DictInfoEntity dictInfoEntity = dictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CLOSE.getCode());
|
|
|
|
|
|
|
+ DictInfoEntity dictInfoEntity = baseInfoDictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CLOSE.getCode());
|
|
|
checkOrderInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
checkOrderInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
|
- CheckOrderInfoEntity detail = this.checkOrderService.getById(checkOrderInfoEntity.getId());
|
|
|
|
|
|
|
+ CheckOrderInfoEntity detail = this.rtuCheckOrderService.getById(checkOrderInfoEntity.getId());
|
|
|
if (null == detail || detail.getOrderClose() == OrderCloseEnum.ACTIVE_CLOSE.getCode()) {
|
|
if (null == detail || detail.getOrderClose() == OrderCloseEnum.ACTIVE_CLOSE.getCode()) {
|
|
|
return R.status(false);
|
|
return R.status(false);
|
|
|
}
|
|
}
|
|
@@ -382,25 +420,29 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
detail.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
detail.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
|
detail.setUpdateTime(new Date());
|
|
detail.setUpdateTime(new Date());
|
|
|
detail.setUpdateUser(user.getUserId());
|
|
detail.setUpdateUser(user.getUserId());
|
|
|
- checkOrderService.updateById(detail);
|
|
|
|
|
|
|
+ rtuCheckOrderService.updateById(detail);
|
|
|
OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
|
processInfoEntity.setOrderId(detail.getId());
|
|
processInfoEntity.setOrderId(detail.getId());
|
|
|
processInfoEntity.setOrderStatusKey(detail.getOrderStatusKey());
|
|
processInfoEntity.setOrderStatusKey(detail.getOrderStatusKey());
|
|
|
- processInfoEntity.setProcessDesc("由[" + user.getNickName() + "]人工关闭维修任务:" + checkOrderInfoEntity.getOrderDesc());
|
|
|
|
|
|
|
+ if (checkOrderInfoEntity.getOrderDesc() != null) {
|
|
|
|
|
+ processInfoEntity.setProcessDesc("由用户[" + user.getNickName() + "]人工关闭维修任务,处理意见:" + checkOrderInfoEntity.getOrderDesc());
|
|
|
|
|
+ } else {
|
|
|
|
|
+ processInfoEntity.setProcessDesc("由用户[" + user.getNickName() + "]人工关闭维修任务");
|
|
|
|
|
+ }
|
|
|
processInfoEntity.setCreateUser(user.getUserId());
|
|
processInfoEntity.setCreateUser(user.getUserId());
|
|
|
processInfoEntity.setUpdateUser(user.getUserId());
|
|
processInfoEntity.setUpdateUser(user.getUserId());
|
|
|
- processService.save(processInfoEntity);
|
|
|
|
|
|
|
+ rtuOrderProcessService.save(processInfoEntity);
|
|
|
if (null != detail.getWarnId()) {
|
|
if (null != detail.getWarnId()) {
|
|
|
List<DictBiz> orderFromDict = dictBizService.getList("rtu_check_order_from");
|
|
List<DictBiz> orderFromDict = dictBizService.getList("rtu_check_order_from");
|
|
|
for (DictBiz biz : orderFromDict) {
|
|
for (DictBiz biz : orderFromDict) {
|
|
|
if (biz.getDictKey().equals(OrderFromEnum.FROM_WARNING.getCode())) {
|
|
if (biz.getDictKey().equals(OrderFromEnum.FROM_WARNING.getCode())) {
|
|
|
- RtuWarningInfoEntity warningInfoEntity = this.warningService.getById(detail.getWarnId());
|
|
|
|
|
|
|
+ RtuWarningInfoEntity warningInfoEntity = this.rtuWarningService.getById(detail.getWarnId());
|
|
|
if (null != warningInfoEntity) {
|
|
if (null != warningInfoEntity) {
|
|
|
warningInfoEntity.setWarningRecoveryTime(new Date());
|
|
warningInfoEntity.setWarningRecoveryTime(new Date());
|
|
|
warningInfoEntity.setWarningStatus(WarningStatusEnum.STATUS_CLOSE.getCode());
|
|
warningInfoEntity.setWarningStatus(WarningStatusEnum.STATUS_CLOSE.getCode());
|
|
|
warningInfoEntity.setUpdateTime(new Date());
|
|
warningInfoEntity.setUpdateTime(new Date());
|
|
|
warningInfoEntity.setUpdateUser(user.getUserId());
|
|
warningInfoEntity.setUpdateUser(user.getUserId());
|
|
|
- this.warningService.updateById(warningInfoEntity);
|
|
|
|
|
|
|
+ this.rtuWarningService.updateById(warningInfoEntity);
|
|
|
}
|
|
}
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
@@ -408,11 +450,10 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
}
|
|
}
|
|
|
RtuStatusEntity rtuStatusEntity = new RtuStatusEntity();
|
|
RtuStatusEntity rtuStatusEntity = new RtuStatusEntity();
|
|
|
rtuStatusEntity.setRunStatusId(EquipmentStatusEnum.STATUS_RUN.getCode());
|
|
rtuStatusEntity.setRunStatusId(EquipmentStatusEnum.STATUS_RUN.getCode());
|
|
|
- this.manageService.updateRtuStatus(rtuStatusEntity);
|
|
|
|
|
|
|
+ this.rtuManageService.updateRtuStatus(rtuStatusEntity);
|
|
|
return R.success("工单关闭已操作成功!");
|
|
return R.success("工单关闭已操作成功!");
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-
|
|
|
|
|
/**
|
|
/**
|
|
|
* 查询最新的数据
|
|
* 查询最新的数据
|
|
|
*/
|
|
*/
|
|
@@ -423,11 +464,10 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
LambdaQueryWrapper<CheckOrderInfoEntity> wrapper = Wrappers.<CheckOrderInfoEntity>query().lambda();
|
|
LambdaQueryWrapper<CheckOrderInfoEntity> wrapper = Wrappers.<CheckOrderInfoEntity>query().lambda();
|
|
|
wrapper.orderByDesc(CheckOrderInfoEntity::getUpdateTime);
|
|
wrapper.orderByDesc(CheckOrderInfoEntity::getUpdateTime);
|
|
|
wrapper.last("limit 1");
|
|
wrapper.last("limit 1");
|
|
|
- List<CheckOrderInfoEntity> pages = checkOrderService.list(wrapper);
|
|
|
|
|
|
|
+ List<CheckOrderInfoEntity> pages = rtuCheckOrderService.list(wrapper);
|
|
|
return R.data(RtuCheckOrderWrapper.build().listVO(pages));
|
|
return R.data(RtuCheckOrderWrapper.build().listVO(pages));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-
|
|
|
|
|
/**
|
|
/**
|
|
|
* 工单确认
|
|
* 工单确认
|
|
|
*
|
|
*
|
|
@@ -436,13 +476,13 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
*/
|
|
*/
|
|
|
@PostMapping("/confirm")
|
|
@PostMapping("/confirm")
|
|
|
@ApiOperationSupport(order = 4)
|
|
@ApiOperationSupport(order = 4)
|
|
|
- @ApiOperation(value = "工单确认", notes = "传入checkOrderInfoEntity")
|
|
|
|
|
|
|
+ @ApiOperation(value = "工单确认", notes = "传入实体类CheckOrderInfoEntity")
|
|
|
public R orderConfirm(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
public R orderConfirm(@RequestBody CheckOrderInfoEntity checkOrderInfoEntity) {
|
|
|
- DictInfoEntity dictInfoEntity = dictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CONFIRM.getCode());
|
|
|
|
|
|
|
+ DictInfoEntity dictInfoEntity = baseInfoDictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CONFIRM.getCode());
|
|
|
checkOrderInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
checkOrderInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
User userInfo = userService.getById(user.getUserId());
|
|
User userInfo = userService.getById(user.getUserId());
|
|
|
- CheckOrderInfoEntity detail = this.checkOrderService.getById(checkOrderInfoEntity.getId());
|
|
|
|
|
|
|
+ CheckOrderInfoEntity detail = this.rtuCheckOrderService.getById(checkOrderInfoEntity.getId());
|
|
|
if (null == detail || null != detail.getOrderConfirmUser()) {
|
|
if (null == detail || null != detail.getOrderConfirmUser()) {
|
|
|
return R.status(false);
|
|
return R.status(false);
|
|
|
}
|
|
}
|
|
@@ -453,25 +493,68 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
detail.setUpdateTime(new Date());
|
|
detail.setUpdateTime(new Date());
|
|
|
detail.setContactUser(userInfo.getId());
|
|
detail.setContactUser(userInfo.getId());
|
|
|
detail.setContactPhone(userInfo.getPhone());
|
|
detail.setContactPhone(userInfo.getPhone());
|
|
|
- checkOrderService.updateById(detail);
|
|
|
|
|
|
|
+ rtuCheckOrderService.updateById(detail);
|
|
|
OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
|
processInfoEntity.setOrderId(checkOrderInfoEntity.getId());
|
|
processInfoEntity.setOrderId(checkOrderInfoEntity.getId());
|
|
|
processInfoEntity.setOrderStatusKey(checkOrderInfoEntity.getOrderStatusKey());
|
|
processInfoEntity.setOrderStatusKey(checkOrderInfoEntity.getOrderStatusKey());
|
|
|
processInfoEntity.setProcessDesc("维修任务由[" + userInfo.getRealName() + "]确认");
|
|
processInfoEntity.setProcessDesc("维修任务由[" + userInfo.getRealName() + "]确认");
|
|
|
- return R.status(processService.save(processInfoEntity));
|
|
|
|
|
|
|
+ return R.status(rtuOrderProcessService.save(processInfoEntity));
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ @PostMapping("/manually")
|
|
|
|
|
+ @ApiOperationSupport(order = 4)
|
|
|
|
|
+ @ApiOperation(value = "人工生成工单", notes = "传入实体类CheckOrderInfoDTO")
|
|
|
|
|
+ public R manuallyOrder(@RequestBody CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
|
|
|
+ if (null == checkOrderInfoDTO.getRtuCode()) {
|
|
|
|
|
+ return R.status(false);
|
|
|
|
|
+ }
|
|
|
|
|
+ BladeUser user = AuthUtil.getUser();
|
|
|
|
|
+ LambdaQueryWrapper<CheckOrderInfoEntity> wrapper = Wrappers.<CheckOrderInfoEntity>query().lambda();
|
|
|
|
|
+ wrapper.eq(CheckOrderInfoEntity::getIsDeleted, 0);
|
|
|
|
|
+ wrapper.eq(CheckOrderInfoEntity::getOrderClose, 0);
|
|
|
|
|
+ wrapper.eq(CheckOrderInfoEntity::getRtuCode, checkOrderInfoDTO.getRtuCode());
|
|
|
|
|
+ long orders = rtuCheckOrderService.count(wrapper);
|
|
|
|
|
+ if (orders > 0) {
|
|
|
|
|
+ return R.fail("当前测站已经有维修任务");
|
|
|
|
|
+ }
|
|
|
|
|
+ DictInfoEntity statusdict = baseInfoDictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CREATE.getCode());
|
|
|
|
|
+ DictInfoEntity fromdict = baseInfoDictService.getDict(DictBusinessConstant.ORDER_FROM_CODE, OrderFromEnum.FROM_MANUALLY.getCode());
|
|
|
|
|
+ checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
|
|
|
+ checkOrderInfoDTO.setOrderConfirm(OrderConfirmEnum.ACTIVE_CREATE.getCode());
|
|
|
|
|
+ checkOrderInfoDTO.setOrderFromKey(fromdict.getId());
|
|
|
|
|
+ checkOrderInfoDTO.setOrderStatusKey(statusdict.getId());
|
|
|
|
|
+ checkOrderInfoDTO.setStatus(1);
|
|
|
|
|
+ checkOrderInfoDTO.setCreateTime(new Date());
|
|
|
|
|
+ checkOrderInfoDTO.setCreateUser(user.getUserId());
|
|
|
|
|
+ checkOrderInfoDTO.setCreateDept(Func.toLong(user.getDeptId()));
|
|
|
|
|
+ rtuCheckOrderService.save(checkOrderInfoDTO);
|
|
|
|
|
+ //增加工单处理创建记录
|
|
|
|
|
+ OrderProcessInfoEntity processInfoEntity = new OrderProcessInfoEntity();
|
|
|
|
|
+ processInfoEntity.setOrderId(checkOrderInfoDTO.getId());
|
|
|
|
|
+ processInfoEntity.setOrderStatusKey(statusdict.getId());
|
|
|
|
|
+ processInfoEntity.setProcessDesc(checkOrderInfoDTO.getOrderDesc());
|
|
|
|
|
+
|
|
|
|
|
+ rtuOrderProcessService.save(processInfoEntity);
|
|
|
|
|
+ //更新测站状态
|
|
|
|
|
+ RtuStatusEntity statusEntity = new RtuStatusEntity();
|
|
|
|
|
+ statusEntity.setRtuCode(checkOrderInfoDTO.getRtuCode());
|
|
|
|
|
+ statusEntity.setRunStatusId(EquipmentStatusEnum.STATUS_FAILURE.getCode());
|
|
|
|
|
+ rtuManageService.updateRtuStatus(statusEntity);
|
|
|
|
|
+
|
|
|
|
|
+ return R.status(true);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
@PostMapping("/change")
|
|
@PostMapping("/change")
|
|
|
@ApiOperationSupport(order = 4)
|
|
@ApiOperationSupport(order = 4)
|
|
|
- @ApiOperation(value = "任务指派", notes = "CheckOrderInfoDTO")
|
|
|
|
|
|
|
+ @ApiOperation(value = "任务指派", notes = "传入实体类CheckOrderInfoDTO")
|
|
|
public R orderChange(@RequestBody CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
public R orderChange(@RequestBody CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
|
- CheckOrderInfoEntity detail = this.checkOrderService.getById(checkOrderInfoDTO.getId());
|
|
|
|
|
|
|
+ CheckOrderInfoEntity detail = this.rtuCheckOrderService.getById(checkOrderInfoDTO.getId());
|
|
|
if (null == detail) {
|
|
if (null == detail) {
|
|
|
return R.status(false);
|
|
return R.status(false);
|
|
|
}
|
|
}
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- DictInfoEntity dictInfoEntity = dictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CONFIRM.getCode());
|
|
|
|
|
|
|
+ DictInfoEntity dictInfoEntity = baseInfoDictService.getDict(DictBusinessConstant.ORDER_STATUS_CODE, OrderStatusEnum.STATUS_CONFIRM.getCode());
|
|
|
if (detail.getOrderConfirm() != OrderConfirmEnum.ACTIVE_CONFIRM.getCode()) {
|
|
if (detail.getOrderConfirm() != OrderConfirmEnum.ACTIVE_CONFIRM.getCode()) {
|
|
|
detail.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
detail.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
|
detail.setOrderStatusKey(dictInfoEntity.getId());
|
|
detail.setOrderStatusKey(dictInfoEntity.getId());
|
|
@@ -483,12 +566,12 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
processInfoEntity.setOrderId(detail.getId());
|
|
processInfoEntity.setOrderId(detail.getId());
|
|
|
processInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
processInfoEntity.setOrderStatusKey(dictInfoEntity.getId());
|
|
|
processInfoEntity.setProcessDesc("维修任务指派给[" + userInfo.getRealName() + "]");
|
|
processInfoEntity.setProcessDesc("维修任务指派给[" + userInfo.getRealName() + "]");
|
|
|
- processService.save(processInfoEntity);
|
|
|
|
|
|
|
+ rtuOrderProcessService.save(processInfoEntity);
|
|
|
detail.setUpdateTime(new Date());
|
|
detail.setUpdateTime(new Date());
|
|
|
detail.setContactUser(userInfo.getId());
|
|
detail.setContactUser(userInfo.getId());
|
|
|
detail.setContactPhone(userInfo.getPhone());
|
|
detail.setContactPhone(userInfo.getPhone());
|
|
|
- checkOrderService.updateById(detail);
|
|
|
|
|
- return R.status(checkOrderService.updateById(detail));
|
|
|
|
|
|
|
+ rtuCheckOrderService.updateById(detail);
|
|
|
|
|
+ return R.status(rtuCheckOrderService.updateById(detail));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@@ -501,15 +584,32 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
@ApiOperationSupport(order = 3)
|
|
@ApiOperationSupport(order = 3)
|
|
|
@ApiOperation(value = "统计表格")
|
|
@ApiOperation(value = "统计表格")
|
|
|
public R<List<CheckOrderCountVO>> orderStatistics() {
|
|
public R<List<CheckOrderCountVO>> orderStatistics() {
|
|
|
- CheckOrderInfoDTO checkOrderInfoDTO = new CheckOrderInfoDTO();
|
|
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- if (BusinessConstant.ROLE_ORG_ADMIN.equals(user.getRoleName()) || BusinessConstant.ROLE_ORG_SERVICE_PERSON.equals(user.getRoleName())) {
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(Func.toLong(user.getDeptId()));
|
|
|
|
|
- } else {
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(null);
|
|
|
|
|
|
|
+ List<CheckOrderCountVO> countList = new LinkedList<>();
|
|
|
|
|
+ LambdaQueryWrapper<User> userQueryWrapper = Wrappers.<User>query().lambda();
|
|
|
|
|
+ userQueryWrapper.eq(User::getIsDeleted, 0);
|
|
|
|
|
+ userQueryWrapper.eq(User::getDeptId, Func.toLong(user.getDeptId()));
|
|
|
|
|
+ List<User> list = userService.list(userQueryWrapper);
|
|
|
|
|
+ for (User u : list) {
|
|
|
|
|
+ CheckOrderCountVO vo = new CheckOrderCountVO();
|
|
|
|
|
+ vo.setUserId(u.getId());
|
|
|
|
|
+ vo.setServicePersonName(u.getRealName());
|
|
|
|
|
+ LambdaQueryWrapper<CheckOrderInfoEntity> queryWrapper = Wrappers.<CheckOrderInfoEntity>query().lambda();
|
|
|
|
|
+ queryWrapper.eq(CheckOrderInfoEntity::getIsDeleted, 0);
|
|
|
|
|
+ queryWrapper.eq(CheckOrderInfoEntity::getOrderConfirm, OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
|
|
|
+ queryWrapper.eq(CheckOrderInfoEntity::getOrderConfirmUser, u.getId());
|
|
|
|
|
+ long count = rtuCheckOrderService.count(queryWrapper);
|
|
|
|
|
+ vo.setOrderCount(count);
|
|
|
|
|
+ LambdaQueryWrapper<OrderProcessInfoEntity> reportQueryWrapper = Wrappers.<OrderProcessInfoEntity>query().lambda();
|
|
|
|
|
+ reportQueryWrapper.eq(OrderProcessInfoEntity::getIsDeleted, 0);
|
|
|
|
|
+ reportQueryWrapper.eq(OrderProcessInfoEntity::getCreateUser, u.getId());
|
|
|
|
|
+ count = rtuOrderProcessService.count(reportQueryWrapper);
|
|
|
|
|
+ vo.setProcessingOrderCount(count);
|
|
|
|
|
+ countList.add(vo);
|
|
|
}
|
|
}
|
|
|
- List<CheckOrderCountVO> pages = checkOrderService.orderReportCount(checkOrderInfoDTO);
|
|
|
|
|
- return R.data(pages);
|
|
|
|
|
|
|
+ return R.data(countList);
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -518,37 +618,63 @@ public class RtuCheckOrderController extends BladeController {
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
@GetMapping("/org/statistics")
|
|
@GetMapping("/org/statistics")
|
|
|
|
|
+ @ApiImplicitParams({
|
|
|
|
|
+ @ApiImplicitParam(name = "adCode", value = "行政区划编码", paramType = "query", dataType = "string"),
|
|
|
|
|
+ })
|
|
|
@ApiOperationSupport(order = 3)
|
|
@ApiOperationSupport(order = 3)
|
|
|
@ApiOperation(value = "统计表格")
|
|
@ApiOperation(value = "统计表格")
|
|
|
public R<List<OrgCheckOrderCountVO>> orgOrderStatistics() {
|
|
public R<List<OrgCheckOrderCountVO>> orgOrderStatistics() {
|
|
|
- List<OrgCheckOrderCountVO> list = new LinkedList<>();
|
|
|
|
|
BladeUser user = AuthUtil.getUser();
|
|
BladeUser user = AuthUtil.getUser();
|
|
|
- List<Dept> root = this.deptService.getDeptChild(Func.toLong(user.getDeptId()));
|
|
|
|
|
-
|
|
|
|
|
|
|
+ List<OrgCheckOrderCountVO> list = new LinkedList<>();
|
|
|
|
|
+ LambdaQueryWrapper<Dept> wrapper = Wrappers.<Dept>query().lambda();
|
|
|
|
|
+ wrapper.eq(Dept::getIsDeleted, 0);
|
|
|
|
|
+ wrapper.eq(Dept::getParentId, Func.toLong(user.getDeptId()));
|
|
|
|
|
+ List<Dept> root = this.deptService.list(wrapper);
|
|
|
for (Dept dept : root) {
|
|
for (Dept dept : root) {
|
|
|
OrgCheckOrderCountVO orgCheckOrderCountVO = new OrgCheckOrderCountVO();
|
|
OrgCheckOrderCountVO orgCheckOrderCountVO = new OrgCheckOrderCountVO();
|
|
|
- orgCheckOrderCountVO.setId(dept.getId());
|
|
|
|
|
|
|
+ orgCheckOrderCountVO.setDeptId(dept.getId());
|
|
|
orgCheckOrderCountVO.setOrgName(dept.getDeptName());
|
|
orgCheckOrderCountVO.setOrgName(dept.getDeptName());
|
|
|
-
|
|
|
|
|
CheckOrderInfoDTO checkOrderInfoDTO = new CheckOrderInfoDTO();
|
|
CheckOrderInfoDTO checkOrderInfoDTO = new CheckOrderInfoDTO();
|
|
|
-
|
|
|
|
|
- checkOrderInfoDTO.setOrgId(Func.toLong(dept.getId()));
|
|
|
|
|
-
|
|
|
|
|
- Long orderCount = checkOrderService.orderCount(checkOrderInfoDTO);
|
|
|
|
|
-
|
|
|
|
|
|
|
+ LambdaQueryWrapper<DeptRegionEntity> deptLambdaQueryWrapper = Wrappers.<DeptRegionEntity>query().lambda();
|
|
|
|
|
+ deptLambdaQueryWrapper.eq(DeptRegionEntity::getIsDeleted, 0);
|
|
|
|
|
+ deptLambdaQueryWrapper.eq(DeptRegionEntity::getDeptId, dept.getId());
|
|
|
|
|
+ DeptRegionEntity deptRegionEntity = deptRegionService.getOne(deptLambdaQueryWrapper);
|
|
|
|
|
+ checkOrderInfoDTO.setAdCode(deptRegionEntity.getAdcd());
|
|
|
checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
|
- Long unCloseOrderCount = checkOrderService.unCloseOrderCount(checkOrderInfoDTO);
|
|
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
|
|
+ Long orderCount = rtuCheckOrderService.orderCount(checkOrderInfoDTO);
|
|
|
orgCheckOrderCountVO.setOrderCount(orderCount);
|
|
orgCheckOrderCountVO.setOrderCount(orderCount);
|
|
|
|
|
+ checkOrderInfoDTO.setOrderConfirm(OrderConfirmEnum.ACTIVE_CONFIRM.getCode());
|
|
|
|
|
+ checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
|
|
|
+ Long unCloseOrderCount = rtuCheckOrderService.unCloseOrderCount(checkOrderInfoDTO);
|
|
|
orgCheckOrderCountVO.setProcessingOrderCount(unCloseOrderCount);
|
|
orgCheckOrderCountVO.setProcessingOrderCount(unCloseOrderCount);
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
|
|
+ checkOrderInfoDTO.setOrderConfirm(OrderConfirmEnum.ACTIVE_CREATE.getCode());
|
|
|
|
|
+ checkOrderInfoDTO.setOrderClose(OrderCloseEnum.ACTIVE_OPEN.getCode());
|
|
|
|
|
+ long count = rtuCheckOrderService.unconfirmOrderCount(checkOrderInfoDTO);
|
|
|
|
|
+ orgCheckOrderCountVO.setUnconfirmOrderCount(count);
|
|
|
list.add(orgCheckOrderCountVO);
|
|
list.add(orgCheckOrderCountVO);
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
-
|
|
|
|
|
return R.data(list);
|
|
return R.data(list);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ @GetMapping("/count")
|
|
|
|
|
+ @ApiOperationSupport(order = 3)
|
|
|
|
|
+ @ApiOperation(value = "统计表格")
|
|
|
|
|
+ public R<Map<String, Object>> orderCount(@ApiIgnore CheckOrderInfoDTO checkOrderInfoDTO) {
|
|
|
|
|
+ if (checkOrderInfoDTO.getAdCode() == null) {
|
|
|
|
|
+ return R.status(false);
|
|
|
|
|
+ }
|
|
|
|
|
+ checkOrderInfoDTO.setOrderClose(0);
|
|
|
|
|
+ Long orderCount = rtuCheckOrderService.orderCount(checkOrderInfoDTO);
|
|
|
|
|
+ Long unConfirmOrderCount = rtuCheckOrderService.unconfirmOrderCount(checkOrderInfoDTO);
|
|
|
|
|
+ Long unCloseOrderCount = rtuCheckOrderService.unCloseOrderCount(checkOrderInfoDTO);
|
|
|
|
|
+ Map<String, Object> data = new HashMap<>();
|
|
|
|
|
+ data.put("orderCount", orderCount);
|
|
|
|
|
+ data.put("orderUnconfirm", unConfirmOrderCount);
|
|
|
|
|
+ data.put("orderProcessing", unCloseOrderCount);
|
|
|
|
|
+ checkOrderInfoDTO.setOrderConfirm(1);
|
|
|
|
|
+ checkOrderInfoDTO.setOrderClose(1);
|
|
|
|
|
+ Long reportOrderCount = rtuCheckOrderService.orderCount(checkOrderInfoDTO);
|
|
|
|
|
+ data.put("reportOrderCount", reportOrderCount);
|
|
|
|
|
+ return R.data(data);
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|