|
@@ -20,6 +20,7 @@ import com.ruoyi.system.service.projectV2.IZsyzShyjService;
|
|
|
import com.ruoyi.system.service.projectV2.common.IZsyzCommonService;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
@@ -64,7 +65,7 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
//先获取角色
|
|
|
List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();
|
|
|
String roleName = "";
|
|
|
- if (roles != null && roles.size() > 0){
|
|
|
+ if (roles != null && roles.size() > 0) {
|
|
|
for (SysRole role : roles) {
|
|
|
roleName = role.getRoleKey();
|
|
|
}
|
|
@@ -77,23 +78,23 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
ZsyzSbbzb zsyzSbbzb = new ZsyzSbbzb();
|
|
|
zsyzSbbzb.setId(zsyzShyj.getXmId());
|
|
|
//如果是要素部门处理,需要修改中间表的回复字段
|
|
|
- if (SZBM.equals(roleName)){
|
|
|
+ if (SZBM.equals(roleName)) {
|
|
|
ZsyzProjectDept zsyzProjectDept = new ZsyzProjectDept();
|
|
|
zsyzProjectDept.setXmId(zsyzShyj.getXmId());
|
|
|
zsyzProjectDept.setDeptId(SecurityUtils.getDeptId());
|
|
|
//查询是否回复过最新的一条
|
|
|
ZsyzProjectDept zsyzProjectDeptOld = projectDeptService.selectZsyzProjectDeptByXmId(zsyzProjectDept);
|
|
|
- if (zsyzProjectDeptOld != null && "Y".equals(zsyzProjectDeptOld.getIsHf())){
|
|
|
+ if (zsyzProjectDeptOld != null && "Y".equals(zsyzProjectDeptOld.getIsHf())) {
|
|
|
return AjaxResult.error("当前已审核");
|
|
|
}
|
|
|
projectDeptService.updateZsyzProjectDeptByXmId(zsyzProjectDept);
|
|
|
- }else {
|
|
|
+ } else {
|
|
|
if (ONE.equals(shjg)) {
|
|
|
//通过
|
|
|
//审核通过需要进入下一阶段/要素部门审核通过,不进行进度前进
|
|
|
//判断项目进度
|
|
|
String progressResult = changeProgress(progress, roleName);
|
|
|
- if (ERROR.equals(progressResult)){
|
|
|
+ if (ERROR.equals(progressResult)) {
|
|
|
return AjaxResult.error("当前状态下您没有审核权限");
|
|
|
}
|
|
|
zsyzSbbzb.setProgress(progressResult);
|
|
@@ -101,7 +102,7 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
zsyzSbbzbMapper.updateZsyzSbbzbProgress(zsyzSbbzb);
|
|
|
} else if (TWO.equals(shjg)) {
|
|
|
String progressResult = changeProgressBack(progress, roleName);
|
|
|
- if (ERROR.equals(progressResult)){
|
|
|
+ if (ERROR.equals(progressResult)) {
|
|
|
return AjaxResult.error("当前状态下您没有审核权限");
|
|
|
}
|
|
|
//驳回
|
|
@@ -136,105 +137,101 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public AjaxResult census() {
|
|
|
+ public AjaxResult census(ZsyzSbbzb zsyzSbbzb) {
|
|
|
Long deptId = SecurityUtils.getDeptId();
|
|
|
//先去redis 中查询
|
|
|
- Map<String, Object> map = redisCache.getCacheObject(INDEX+deptId);
|
|
|
- if (map == null) {
|
|
|
- map = new HashMap<>();
|
|
|
- //定义返回值
|
|
|
- int sk = 0;
|
|
|
- SysUser currentUser = SecurityUtils.getLoginUser().getUser();
|
|
|
- ZsyzSbbzb zsyzSbbzb = new ZsyzSbbzb();
|
|
|
- List<ZsyzSbbzb> zsyzSbbzbs = new ArrayList<>();
|
|
|
- String roleKey = "";
|
|
|
- // 如果是超级管理员/管理员,则不过滤数据
|
|
|
- List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();
|
|
|
- if (roles != null && roles.size() > 0) {
|
|
|
- for (SysRole role : roles) {
|
|
|
- //获取角色的权限字符串
|
|
|
- roleKey = roleKey + "," + role.getRoleKey();
|
|
|
- if (MANAGE.equals(roleKey)) {
|
|
|
- roleKey = MANAGE;
|
|
|
- break;
|
|
|
- }
|
|
|
+ Map<String, Object> map = new HashMap<>();
|
|
|
+ map = new HashMap<>();
|
|
|
+ //定义返回值
|
|
|
+ int sk = 0;
|
|
|
+ SysUser currentUser = SecurityUtils.getLoginUser().getUser();
|
|
|
+ List<ZsyzSbbzb> zsyzSbbzbs = new ArrayList<>();
|
|
|
+ String roleKey = "";
|
|
|
+ // 如果是超级管理员/管理员,则不过滤数据
|
|
|
+ List<SysRole> roles = SecurityUtils.getLoginUser().getUser().getRoles();
|
|
|
+ if (roles != null && roles.size() > 0) {
|
|
|
+ for (SysRole role : roles) {
|
|
|
+ //获取角色的权限字符串
|
|
|
+ roleKey = roleKey + "," + role.getRoleKey();
|
|
|
+ if (MANAGE.equals(roleKey)) {
|
|
|
+ roleKey = MANAGE;
|
|
|
+ break;
|
|
|
}
|
|
|
}
|
|
|
- boolean flag = true;
|
|
|
- if (StringUtils.isNotNull(currentUser) && (!currentUser.isAdmin() || MANAGE.equals(roleKey))) {
|
|
|
- //如果不是admin/或者平台管理员 判断是什么角色
|
|
|
- if (StringUtils.isNotEmpty(roleKey)) {
|
|
|
- String[] split = roleKey.split(",");
|
|
|
- for (int i = 0; i < split.length; i++) {
|
|
|
- if (SZBM.equals(split[i])) {
|
|
|
- //如果是市直部门则包含承接地数据
|
|
|
- flag = false;
|
|
|
- break;
|
|
|
- }
|
|
|
+ }
|
|
|
+ boolean flag = true;
|
|
|
+ if (StringUtils.isNotNull(currentUser) && (!currentUser.isAdmin() || MANAGE.equals(roleKey))) {
|
|
|
+ //如果不是admin/或者平台管理员 判断是什么角色
|
|
|
+ if (StringUtils.isNotEmpty(roleKey)) {
|
|
|
+ String[] split = roleKey.split(",");
|
|
|
+ for (int i = 0; i < split.length; i++) {
|
|
|
+ if (SZBM.equals(split[i])) {
|
|
|
+ //如果是市直部门则包含承接地数据
|
|
|
+ flag = false;
|
|
|
+ break;
|
|
|
}
|
|
|
}
|
|
|
- //如果是FALSE 则包含承接地
|
|
|
- if (flag) {
|
|
|
- //只查询承接地数据
|
|
|
- zsyzSbbzb.setCjdId(deptId);
|
|
|
- zsyzSbbzbs = zsyzSbbzbMapper.selectZsyzSbbzbCjdList(zsyzSbbzb);
|
|
|
- } else {
|
|
|
- zsyzSbbzb.setDeptId(deptId);
|
|
|
- //查询指派给市值
|
|
|
- zsyzSbbzbs = zsyzSbbzbMapper.selectZsyzSbbzbListByZp(zsyzSbbzb);
|
|
|
- }
|
|
|
+ }
|
|
|
+ //如果是FALSE 则包含承接地
|
|
|
+ if (flag) {
|
|
|
+ //只查询承接地数据
|
|
|
+ zsyzSbbzb.setCjdId(deptId);
|
|
|
+ zsyzSbbzbs = zsyzSbbzbMapper.selectZsyzSbbzbCjdList(zsyzSbbzb);
|
|
|
} else {
|
|
|
- //如果是admin/或者平台管理员 获取到所有数据
|
|
|
- zsyzSbbzbs = zsyzSbbzbMapper.selectZsyzSbbzbList(zsyzSbbzb);
|
|
|
- //查询省库数据
|
|
|
- ZsyzSkxm zsyzSkxm = new ZsyzSkxm();
|
|
|
- zsyzSkxm.setDeptId(deptId);
|
|
|
- List<ZsyzSkxm> zsyzSkxms = zsyzSkxmMapper.selectZsyzSkxmList(zsyzSkxm);
|
|
|
- if (zsyzSkxms != null && zsyzSkxms.size() > 0) {
|
|
|
- sk = zsyzSkxms.size();
|
|
|
- }
|
|
|
+ zsyzSbbzb.setDeptId(deptId);
|
|
|
+ //查询指派给市值
|
|
|
+ zsyzSbbzbs = zsyzSbbzbMapper.selectZsyzSbbzbListByZp(zsyzSbbzb);
|
|
|
}
|
|
|
- //对数据进行分组统计
|
|
|
- int xs = 0;
|
|
|
- int qy = 0;
|
|
|
- int kg = 0;
|
|
|
- int tc = 0;
|
|
|
- int all = 0;
|
|
|
- if (zsyzSbbzbs != null && zsyzSbbzbs.size() > 0) {
|
|
|
- for (ZsyzSbbzb sbbzb : zsyzSbbzbs) {
|
|
|
- String progress = sbbzb.getProgress();
|
|
|
- if (ONE.equals(progress) || TWO.equals(progress) || THR.equals(progress) || FOR.equals(progress) || FIV.equals(progress)) {
|
|
|
- xs = xs + 1;
|
|
|
- } else if (SIX.equals(progress) || SEV.equals(progress)) {
|
|
|
- qy = qy + 1;
|
|
|
- } else if (EIG.equals(progress) || NIN.equals(progress)) {
|
|
|
- kg = kg + 1;
|
|
|
- } else if (TEN.equals(progress) || ELE.equals(progress)) {
|
|
|
- tc = tc + 1;
|
|
|
- }
|
|
|
- }
|
|
|
- all = zsyzSbbzbs.size();
|
|
|
+ } else {
|
|
|
+ //如果是admin/或者平台管理员 获取到所有数据
|
|
|
+ zsyzSbbzbs = zsyzSbbzbMapper.selectZsyzSbbzbList(zsyzSbbzb);
|
|
|
+ //查询省库数据
|
|
|
+ ZsyzSkxm zsyzSkxm = new ZsyzSkxm();
|
|
|
+ zsyzSkxm.setDeptId(deptId);
|
|
|
+ List<ZsyzSkxm> zsyzSkxms = zsyzSkxmMapper.selectZsyzSkxmList(zsyzSkxm);
|
|
|
+ if (zsyzSkxms != null && zsyzSkxms.size() > 0) {
|
|
|
+ sk = zsyzSkxms.size();
|
|
|
}
|
|
|
- map.put("xs", xs);
|
|
|
- map.put("qy", qy);
|
|
|
- map.put("kg", kg);
|
|
|
- map.put("tc", tc);
|
|
|
- map.put("sk", sk);
|
|
|
- //todo 问题项目 只有要素部门意见不通过和承接地不承接的是问题项目
|
|
|
- List<ZsyzShyj> zsyzShyjs = zsyzShyjService.selectZsyzShyjListByWt(new ZsyzShyj());
|
|
|
- int wt = 0;
|
|
|
- if (zsyzShyjs != null) {
|
|
|
- wt = zsyzShyjs.size();
|
|
|
+ }
|
|
|
+ //对数据进行分组统计
|
|
|
+ int xs = 0;
|
|
|
+ int qy = 0;
|
|
|
+ int kg = 0;
|
|
|
+ int tc = 0;
|
|
|
+ int all = 0;
|
|
|
+ if (zsyzSbbzbs != null && zsyzSbbzbs.size() > 0) {
|
|
|
+ for (ZsyzSbbzb sbbzb : zsyzSbbzbs) {
|
|
|
+ String progress = sbbzb.getProgress();
|
|
|
+ if (ONE.equals(progress) || TWO.equals(progress) || THR.equals(progress) || FOR.equals(progress) || FIV.equals(progress)) {
|
|
|
+ xs = xs + 1;
|
|
|
+ } else if (SIX.equals(progress) || SEV.equals(progress)) {
|
|
|
+ qy = qy + 1;
|
|
|
+ } else if (EIG.equals(progress) || NIN.equals(progress)) {
|
|
|
+ kg = kg + 1;
|
|
|
+ } else if (TEN.equals(progress) || ELE.equals(progress)) {
|
|
|
+ tc = tc + 1;
|
|
|
+ }
|
|
|
}
|
|
|
- map.put("wt", wt);
|
|
|
- //统计批示项目数量
|
|
|
- ZsyzSbbzb zsyzSbb = new ZsyzSbbzb();
|
|
|
- zsyzSbbzb.setDeptId(deptId);
|
|
|
- long ps = zsyzSbbzbMapper.ldpsListCount(zsyzSbb);
|
|
|
- map.put("ps", ps);
|
|
|
- map.put("all", all);
|
|
|
- redisCache.setCacheObject(INDEX+deptId, map, 1, TimeUnit.HOURS);
|
|
|
+ all = zsyzSbbzbs.size();
|
|
|
+ }
|
|
|
+ map.put("xs", xs);
|
|
|
+ map.put("qy", qy);
|
|
|
+ map.put("kg", kg);
|
|
|
+ map.put("tc", tc);
|
|
|
+ map.put("sk", sk);
|
|
|
+ //todo 问题项目 只有要素部门意见不通过和承接地不承接的是问题项目
|
|
|
+ List<ZsyzShyj> zsyzShyjs = zsyzShyjService.selectZsyzShyjListByWt(new ZsyzShyj());
|
|
|
+ int wt = 0;
|
|
|
+ if (zsyzShyjs != null) {
|
|
|
+ wt = zsyzShyjs.size();
|
|
|
}
|
|
|
+ map.put("wt", wt);
|
|
|
+ //统计批示项目数量
|
|
|
+ ZsyzSbbzb zsyzSbb = new ZsyzSbbzb();
|
|
|
+ zsyzSbbzb.setDeptId(deptId);
|
|
|
+ long ps = zsyzSbbzbMapper.ldpsListCount(zsyzSbb);
|
|
|
+ map.put("ps", ps);
|
|
|
+ map.put("all", all);
|
|
|
return AjaxResult.success(map);
|
|
|
}
|
|
|
|
|
@@ -258,10 +255,10 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
List<Map<String, Object>> dateList = new ArrayList<>();
|
|
|
String year = DateUtils.getTime();
|
|
|
//获取当前年
|
|
|
- Map<String,Object> timeMapOne = new HashMap<>(2);
|
|
|
- Map<String,Object> timeMapTwo = new HashMap<>(2);
|
|
|
- Map<String,Object> timeMapThr= new HashMap<>(2);
|
|
|
- Map<String,Object> timeMapFor = new HashMap<>(2);
|
|
|
+ Map<String, Object> timeMapOne = new HashMap<>(2);
|
|
|
+ Map<String, Object> timeMapTwo = new HashMap<>(2);
|
|
|
+ Map<String, Object> timeMapThr = new HashMap<>(2);
|
|
|
+ Map<String, Object> timeMapFor = new HashMap<>(2);
|
|
|
timeMapOne.put("beginTime", year + "0101");
|
|
|
timeMapOne.put("endTime", year + "0331");
|
|
|
timeMapTwo.put("beginTime", year + "0401");
|
|
@@ -286,14 +283,14 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
for (ZsyzSbbzb sbbzb : zsyzSbbzbs) {
|
|
|
String progress = sbbzb.getProgress();
|
|
|
String xmjd = xmjd(progress);
|
|
|
- if (XMJD_XS.equals(xmjd)){
|
|
|
+ if (XMJD_XS.equals(xmjd)) {
|
|
|
xsNub = xsNub + 1;
|
|
|
- }else if (XMJD_QY.equals(xmjd)){
|
|
|
- qyNub = qyNub +1;
|
|
|
- }else if (XMJD_KG.equals(xmjd)){
|
|
|
- kgNub = kgNub +1;
|
|
|
- }else if (XMJD_TC.equals(xmjd)){
|
|
|
- tcNub = tcNub +1;
|
|
|
+ } else if (XMJD_QY.equals(xmjd)) {
|
|
|
+ qyNub = qyNub + 1;
|
|
|
+ } else if (XMJD_KG.equals(xmjd)) {
|
|
|
+ kgNub = kgNub + 1;
|
|
|
+ } else if (XMJD_TC.equals(xmjd)) {
|
|
|
+ tcNub = tcNub + 1;
|
|
|
}
|
|
|
}
|
|
|
xs.add(xsNub);
|
|
@@ -306,21 +303,21 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
yMpa.put("qy", qy);
|
|
|
yMpa.put("kg", kg);
|
|
|
yMpa.put("tc", tc);
|
|
|
- map.put("y",yMpa);
|
|
|
+ map.put("y", yMpa);
|
|
|
return AjaxResult.success(map);
|
|
|
}
|
|
|
|
|
|
//更改项目进度前进
|
|
|
- public String changeProgress(String progress,String roleName) {
|
|
|
- if (ONE.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ public String changeProgress(String progress, String roleName) {
|
|
|
+ if (ONE.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = TWO;
|
|
|
- } else if (FOR.equals(progress) && (CJD.equals(roleName)|| ADMIN.equals(roleName))) {
|
|
|
+ } else if (FOR.equals(progress) && (CJD.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = FIV;
|
|
|
- } else if (SIX.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ } else if (SIX.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = SEV;
|
|
|
- } else if (EIG.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ } else if (EIG.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = NIN;
|
|
|
- } else if (TEN.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ } else if (TEN.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = ELE;
|
|
|
}//项目入归暂时保留
|
|
|
else {
|
|
@@ -330,16 +327,16 @@ public class ZsyzCommonServiceImpL implements IZsyzCommonService {
|
|
|
}
|
|
|
|
|
|
//更改项目进度后退
|
|
|
- public String changeProgressBack(String progress,String roleName) {
|
|
|
- if (TWO.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ public String changeProgressBack(String progress, String roleName) {
|
|
|
+ if (TWO.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = ONE;
|
|
|
- } else if (FOR.equals(progress) && (CJD.equals(roleName)|| ADMIN.equals(roleName))) {
|
|
|
+ } else if (FOR.equals(progress) && (CJD.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = TWO;
|
|
|
- } else if (SIX.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ } else if (SIX.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = FIV;
|
|
|
- } else if (EIG.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ } else if (EIG.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = SEV;
|
|
|
- } else if (TEN.equals(progress) && (MANAGE.equals(roleName)||ADMIN.equals(roleName))) {
|
|
|
+ } else if (TEN.equals(progress) && (MANAGE.equals(roleName) || ADMIN.equals(roleName))) {
|
|
|
progress = NIN;
|
|
|
}//项目入归暂时保留
|
|
|
else {
|