Compare commits

...

4 Commits

Author SHA1 Message Date
YY
9ba13f6f06 Merge branch 'dev' of http://59.110.10.99:53000/liuc/biz_supplier_manage into dev 2025-07-16 09:49:54 +08:00
YY
e827c1f8b9 添加sql supplierId 2025-07-16 09:49:24 +08:00
YY
a9677f9169 错误修改 2025-07-15 17:04:31 +08:00
YY
8c087005f3 修改错误 2025-07-15 15:24:26 +08:00
17 changed files with 66 additions and 22 deletions

View File

@ -60,6 +60,7 @@ public class CoscoAnnualreviewTaskSupplierUserServiceImpl implements ICoscoAnnua
//返回封装
AnnualreviewTaskSupplierUserInfoVo vo = new AnnualreviewTaskSupplierUserInfoVo();
vo.setId(id);
vo.setSupplierId(coscoAnnualreviewTaskSupplierUser.getSupplierId());
vo.setName(baseCategoryNameVo.getName());
BaseCacheUser currentUser = TokenUtil.getCurrentUser();
//TODO 待完善,部门名称

View File

@ -47,6 +47,8 @@ public class AnnualreviewTaskSupplierUserInfoVo implements Serializable {
@JsonFormat(pattern = "yyyy-MM-dd")
private Date endTime;
private String supplierId;
/**
* 打分项集合

View File

@ -16,6 +16,9 @@ public class ScheduledTasksController {
public void checkTask() {
scheduledTasksService.checkTask();
}
@RequestMapping("/closeTask")
public void close() {
scheduledTasksService.closeTask();
}
}

View File

@ -1,6 +1,7 @@
package com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.dao;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.entity.CoscoEvaluateTaskDeptWeight;
import org.apache.ibatis.annotations.Param;
import java.util.List;
@ -72,5 +73,5 @@ public interface CoscoEvaluateTaskDeptWeightMapper {
* @param taskIds
* @return
*/
List<CoscoEvaluateTaskDeptWeight> selectByTaskId(List<String> taskIds);
List<CoscoEvaluateTaskDeptWeight> selectByTaskId(@Param("taskIds")List<String> taskIds);
}

View File

@ -1,20 +1,24 @@
package com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.service.impl;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.chinaunicom.zyhy.ebtp.supplier.base.service.IUserService;
import com.chinaunicom.zyhy.ebtp.supplier.base.vo.SelectUserVo;
import com.chinaunicom.zyhy.ebtp.supplier.base.vo.UserVo;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.dao.*;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.entity.*;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.vo.*;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.service.ICoscoEvaluateTaskSupplierService;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.vo.SupplierDimensionVo;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.vo.TaskIndicatorBaseVo;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.vo.TaskIndicatorVo;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.vo.TaskSubIndicatorVo;
import com.chinaunicom.zyhy.ebtp.supplier.coscosupplier.dao.mapper.CoscoSupplierBaseMapper;
import com.chinaunicom.zyhy.ebtp.supplier.coscosupplier.vo.BaseCategoryNameVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.service.ICoscoEvaluateTaskSupplierService;
import java.util.*;
import java.util.stream.Collectors;
/**
* 【供应商评价_评价任务关联供应商表】Service业务层处理
@ -36,6 +40,8 @@ public class CoscoEvaluateTaskSupplierServiceImpl implements ICoscoEvaluateTaskS
private CoscoEvaluateScoringResultMapper coscoEvaluateScoringResultMapper;
@Autowired
private CoscoEvaluateTemplateIndicatorNdMapper coscoEvaluateTemplateIndicatorNdMapper;
@Autowired
private IUserService userService;
/**
* 查询【供应商评价_评价任务关联供应商表】
@ -116,9 +122,19 @@ public class CoscoEvaluateTaskSupplierServiceImpl implements ICoscoEvaluateTaskS
IPage<SupplierDimensionVo> p = new Page<>(vo.getBasePageRequest().getPageNo(),
vo.getBasePageRequest().getPageSize());
IPage<SupplierDimensionVo> supplierDimensionVoIPage = coscoEvaluateTaskSupplierMapper.selectSupplierDimensionPage(p, vo);
List<UserVo> user = userService.getUser(new SelectUserVo());
Map<String ,UserVo> map = new HashMap<>();
user.forEach(userVo -> {
map.put(userVo.getUserId(), userVo);
});
List<String> deptIds = new ArrayList<>();
supplierDimensionVoIPage.getRecords().forEach(item -> {
deptIds.add(item.getDeptId());
UserVo userVo = map.get(item.getUserId());
if(userVo!=null){
item.setUserName(userVo.getUserName());
item.setDeptName(userVo.getUserDept());
}
});
//根据部门id查询评价单位
return supplierDimensionVoIPage;

View File

@ -19,12 +19,10 @@ import com.chinaunicom.zyhy.ebtp.supplier.coscosupplier.entity.CoscoMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;
@Service
@ -69,6 +67,7 @@ public class ScheduledTasksServiceImpl implements ScheduledTasksService {
*/
@Scheduled(cron = "0 0 2 * * ?")
@Override
@Transactional(rollbackFor = Exception.class)
public void closeTask() {
//查询小于当前时间 未关闭任务
//获取当前时间指标信息
@ -100,7 +99,10 @@ public class ScheduledTasksServiceImpl implements ScheduledTasksService {
//获取人员信息
List<UserVo> user = userService.getUser(new SelectUserVo());
//给人员添加部门信息
Map<String, String> userMap = user.stream().collect(Collectors.toMap(UserVo::getUserId, UserVo::getUserDeptId));
Map<String, String> userMap=new HashMap<>();
user.forEach(userVo -> {
System.out.println(userVo.getUserId());
userMap.put(userVo.getUserId(), userVo.getUserDeptId());});
calculateAndObtainScoresVos.forEach(vos -> {
vos.setDeptId(userMap.get(vos.getUserId()));
});

View File

@ -65,6 +65,10 @@ public class SupplierDimensionVo implements Serializable {
* 人员id
*/
private String userId;
/**
* 人员名称
*/
private String userName;
/**
* 任务id
@ -78,10 +82,11 @@ public class SupplierDimensionVo implements Serializable {
/**
* 分数
*/
private String suscore;
private Integer suScore;
private String categoryName;
@ApiModelProperty(value = "分页对象信息")
private BasePageRequest basePageRequest;
}

View File

@ -46,6 +46,8 @@ public class SupplierAnnualReviewStatisticsVo {
*/
@ExcelProperty("评价年度")
private String annualreviewYear;
private String supplierId;
/**
* 评价结果
*/

View File

@ -43,6 +43,8 @@ public class SupplierExitStatisticsVo {
@ExcelProperty("退出时间")
private String applyTime;
private String supplierId;
@ApiModelProperty(value = "分页对象信息")
private BasePageRequest basePageRequest;
}

View File

@ -58,6 +58,8 @@ public class SupplierQualificationExpireVo {
@ExcelProperty("分类名称")
private String categoryName;
private String supplierId;
@ApiModelProperty(value = "分页对象信息")
private BasePageRequest basePageRequest;
}

View File

@ -237,6 +237,7 @@
select
csb.name supplierName,
csb.id as supplierId,
case when csb.supplier_type = 'ovs' then '境外'
when csb.supplier_type = 'ovs' then '境内'
else '境内' end as area ,

View File

@ -43,6 +43,7 @@
SELECT
catsu.id,
csb.NAME,
csb.id as supplierId,
cat.dept_id as deptId,
cat.annualreview_theme,
'单位' AS deptName,

View File

@ -192,7 +192,7 @@
<select id="selectByTaskIds" parameterType="list"
resultType="com.chinaunicom.zyhy.ebtp.supplier.coscoEvaluate.vo.CalculateAndObtainScoresVo">
select cetsu.user_id as userId, ces.score, ces.indicator_nd_id as indicatorNdId, '1' as dept_id as deptId,
select cetsu.user_id as userId, ces.score, ces.indicator_nd_id as indicatorNdId, '1' as deptId,
cets.supplier_id as supplierId,cetsu.evaluate_task_id as evaluateTaskId
from cosco_evaluate_scoring ces
join cosco_evaluate_task_supplier_user cetsu

View File

@ -389,6 +389,7 @@
</if>
</where>
group by cet.id
order by cet.create_time desc
</select>
<select id="selectMyPage"

View File

@ -281,9 +281,11 @@
SELECT
cetsu.id,
csb.`name`,
csb.id as supplierId,
cet.evaluate_theme evaluateTheme,
cet.start_time startTime,
cet.end_time endTime,
cetsu.user_id as userId,
case when cc.category_name is null then '未指定'
else cc.category_name end as categoryName,
cet.STATUS ,
@ -295,11 +297,12 @@
when cet.status =2 then '已结束' end as statusName,
case when cetsu.review_status =0 then '未提交'
when cetsu.review_status=1 then '已提交' end as reviewStatusName,
(select sum(score)
from cosco_evaluate_scoring where del_flag='normal'
and evaluate_task_supplier_user_id=cetsu.id)
as suscore
IFNULL((
SELECT SUM(score)
FROM cosco_evaluate_scoring
WHERE del_flag='normal'
AND evaluate_task_supplier_user_id=cetsu.id
), 0) AS suScore
FROM
cosco_evaluate_task_supplier_user cetsu
LEFT JOIN cosco_evaluate_task cet ON cetsu.evaluate_task_id = cet.id

View File

@ -265,6 +265,7 @@
csq.authority,
csq.term_of_validity,
csb.NAME supplierName,
csb.id as supplierId,
CASE
WHEN csb.supplier_type = 'ovs' THEN

View File

@ -232,6 +232,7 @@
<select id="getSupplierExitStatistics" resultType="com.chinaunicom.zyhy.ebtp.supplier.dataStatistics.vo.SupplierExitStatisticsVo" parameterType="map">
select
csb.name supplierName,
csb.id as supplierId,
case when csb.supplier_type = 'ovs' then '境外'
when csb.supplier_type = 'ovs' then '境内'
else '境内' end as area ,