From 80e709a6aea9a7913edcb96f3ebdb98305555195 Mon Sep 17 00:00:00 2001 From: liangcheng <1546584672@qq.com> Date: Wed, 16 Jul 2025 15:37:19 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A5=A5=E6=85=A7=E6=81=92=E6=98=95=E7=BB=A9?= =?UTF-8?q?=E6=95=88=E6=A8=A1=E5=9D=97=E5=BC=80=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/EbTableMonitorController.java | 41 ++++++ .../cron/EbTableInsertEscheduler.java | 58 ++++++++ .../entity/bo/EbTableMonitorBO.java | 123 +++++++++++++++++ .../entity/po/EbTableMonitorPO.java | 61 +++++++++ .../entity/po/EbTableScoreCoefficientPO.java | 50 +++++++ .../performance/entity/po/EmployeePO.java | 25 ++++ .../performance/entity/po/HrKpiFlowPO.java | 85 ++++++++++++ .../mapper/EbTableMonitorMapper.java | 17 +++ .../mapper/EbTableScoreCoefficientMapper.java | 16 +++ .../performance/mapper/HrKpiFlowMapper.java | 18 +++ .../service/EbTableMonitorService.java | 45 +++++++ .../impl/EbTableMonitorServiceImpl.java | 125 ++++++++++++++++++ .../resources/mapper/EbTableMonitorMapper.xml | 107 +++++++++++++++ .../mapper/EbTableScoreCoefficientMapper.xml | 30 +++++ .../main/resources/mapper/HrKpiFlowMapper.xml | 99 ++++++++++++++ 15 files changed, 900 insertions(+) create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/controller/EbTableMonitorController.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/cron/EbTableInsertEscheduler.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/bo/EbTableMonitorBO.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableMonitorPO.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableScoreCoefficientPO.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EmployeePO.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/HrKpiFlowPO.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableMonitorMapper.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableScoreCoefficientMapper.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/HrKpiFlowMapper.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/EbTableMonitorService.java create mode 100644 secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/impl/EbTableMonitorServiceImpl.java create mode 100644 secondev-xianghui-performance/src/main/resources/mapper/EbTableMonitorMapper.xml create mode 100644 secondev-xianghui-performance/src/main/resources/mapper/EbTableScoreCoefficientMapper.xml create mode 100644 secondev-xianghui-performance/src/main/resources/mapper/HrKpiFlowMapper.xml diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/controller/EbTableMonitorController.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/controller/EbTableMonitorController.java new file mode 100644 index 0000000..882ca9d --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/controller/EbTableMonitorController.java @@ -0,0 +1,41 @@ +package com.weaver.seconddev.xianghui.performance.controller; + +import com.weaver.common.authority.annotation.WeaPermission; +import com.weaver.common.base.entity.result.WeaResult; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableMonitorPO; +import com.weaver.seconddev.xianghui.performance.entity.po.HrKpiFlowPO; +import com.weaver.seconddev.xianghui.performance.service.EbTableMonitorService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.ws.rs.QueryParam; +import java.util.List; + + + +@RestController +@RequestMapping("/api/secondev/xh/performance") +@WeaPermission(publicPermission = true) +public class EbTableMonitorController { + + @Autowired + private EbTableMonitorService ebTableMonitorService; + + @GetMapping("/getData") + public WeaResult> getData() { + return WeaResult.success(ebTableMonitorService.getData()); + } + + @GetMapping("/buildEbData") + public WeaResult> buildEbData() { + return WeaResult.success(ebTableMonitorService.buildEbData()); + } + + @GetMapping("/deleteEbData") + public WeaResult deleteEbData(@QueryParam("pfid") String pfid) { + return WeaResult.success(ebTableMonitorService.deleteEbData(pfid)); + } + +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/cron/EbTableInsertEscheduler.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/cron/EbTableInsertEscheduler.java new file mode 100644 index 0000000..030740c --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/cron/EbTableInsertEscheduler.java @@ -0,0 +1,58 @@ +package com.weaver.seconddev.xianghui.performance.cron; + +import com.weaver.common.distribution.genid.IdGenerator; +import com.weaver.common.escheduler.handler.annotation.ESchedulerHandler; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableMonitorPO; +import com.weaver.seconddev.xianghui.performance.mapper.EbTableMonitorMapper; +import com.weaver.seconddev.xianghui.performance.service.EbTableMonitorService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + + +@Service +public class EbTableInsertEscheduler { + + @Autowired + private EbTableMonitorService ebTableMonitorService; + + @Autowired + private EbTableMonitorMapper ebTableMonitorMapper; + + private static final Logger log = LoggerFactory.getLogger(EbTableInsertEscheduler.class); + + + + /** + * value: 业务方法的执行名称 + * cron: cron表达式自定义执行时间 + * @throws Exception + */ + @ESchedulerHandler(value = "EbTableInsertHander", cron = "0/10 * * * * ?") + public void ebTableInsertHander() throws Exception { + try { + + List ebTableMonitorPOS = ebTableMonitorService.buildEbData(); + ebTableMonitorPOS.forEach(item -> { + boolean isExsit = ebTableMonitorMapper.existsByPfid(item.getPfid(),item.getTenantKey()); + if (isExsit) { + //更新 + ebTableMonitorMapper.updateByPfid(item); + }else { + // 使用新的ID生成器 + Long idNext = IdGenerator.generate(); + item.setId(idNext); + item.setFormDataId(idNext); + ebTableMonitorMapper.insert(item); + } + }); + + } catch (Exception e) { + e.printStackTrace(); + log.error("demoJobHandler runnint error"); + } + } +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/bo/EbTableMonitorBO.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/bo/EbTableMonitorBO.java new file mode 100644 index 0000000..a55dc42 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/bo/EbTableMonitorBO.java @@ -0,0 +1,123 @@ +package com.weaver.seconddev.xianghui.performance.entity.bo; + +import com.weaver.common.distribution.genid.IdGenerator; +import com.weaver.common.hrm.cache.HrmDepartmentComInfo; +import com.weaver.common.hrm.util.StringUtils; +import com.weaver.common.hrm.util.Util; +import com.weaver.common.i18n.tool.util.I18nContextUtil; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableMonitorPO; +import com.weaver.seconddev.xianghui.performance.entity.po.EmployeePO; +import com.weaver.seconddev.xianghui.performance.entity.po.HrKpiFlowPO; +import com.weaver.seconddev.xianghui.performance.mapper.HrKpiFlowMapper; +import com.weaver.seconddev.xianghui.performance.service.EbTableMonitorService; +import com.weaver.verupgrade.conn.CONN_TYPE; +import com.weaver.verupgrade.conn.RecordSet; +import com.weaver.workflow.common.cfg.org.service.DepartMentService; +import com.weaver.workflow.common.constant.org.WeaDeptPathLevel; +import com.weaver.workflow.common.entity.org.WeaDepartMent; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.List; +import java.util.TimeZone; +import java.util.stream.Collectors; + +/** + * @Author liang.cheng + * @Date 2025/6/11 11:21 + * @Description: TODO + * @Version 1.0 + */ +@Component +public class EbTableMonitorBO { + + @Autowired + private HrKpiFlowMapper hrKpiFlowMapper; + + @Autowired + private DepartMentService departMentService; + + @Autowired + private EbTableMonitorService ebTableMonitorService; + + + public List convertToEbTableMonitor(List hrKpiFlows) { + + EmployeePO employeePO = selectEmployee(); + return hrKpiFlows.stream() + .map(hrKpiFlow -> { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM"); + sdf.setTimeZone(TimeZone.getTimeZone("GMT+8")); + String formattedDate = hrKpiFlow.getRealPeriod() != null + ? sdf.format(hrKpiFlow.getRealPeriod()) + : null; + WeaDepartMent weaDepartMent = departMentService.getDepartMentById(hrKpiFlow.getDepartmentId()); + String deptPath = departMentService.getDeptPath(hrKpiFlow.getDepartmentId(), WeaDeptPathLevel.DEPT_ALL_LEVEL, ">", employeePO.getTenantKey()); + if (StringUtils.isNotBlank(deptPath)) { + deptPath = deptPath + ">" + weaDepartMent.getDepartMentName(); + } else { + deptPath = weaDepartMent.getDepartMentName(); + } + + return EbTableMonitorPO.builder() + // 基础字段 + .dataIndex(0) + .isFlow(0) + .dataStatus(1) + .createTime(new Date()) + .updateTime(new Date()) + .tenantKey(employeePO.getTenantKey()) + .creator(employeePO.getId()) + .updater(employeePO.getId()) + .deleteType(0) + .ftStatus(0) + + // 自定义字段 + .pfid(String.valueOf(hrKpiFlow.getId())) + .khmc(hrKpiFlow.getName()) + .khzq(hrKpiFlow.getDateType()) + .khdx(hrKpiFlow.getKpiUser()) + .pfzq(hrKpiFlow.getRealPeriod()) + .dqjd(hrKpiFlow.getFlowStatus()) + .dclr(getPengdingPerson(hrKpiFlow,employeePO.getTenantKey())) + .fbsj(hrKpiFlow.getCreateTime()) + .bm(hrKpiFlow.getDepartmentId()) + .qljbm(deptPath) + .zq(formattedDate) + .df(hrKpiFlow.getScore()) + .xs(ebTableMonitorService.buildScoreCoefficient(hrKpiFlow,employeePO.getTenantKey())) + .build(); + }) + .collect(Collectors.toList()); + } + + + public String getPengdingPerson(HrKpiFlowPO hrKpiFlowPO,String tenantKey){ + if ("frozen".equals(hrKpiFlowPO.getFlowStatus())){ + return ""; + } + List operatorsByStepId = hrKpiFlowMapper.findOperatorsByStepId(hrKpiFlowPO.getKpiCurrentStep(), tenantKey); + + return operatorsByStepId.stream() + .distinct() + .map(String::valueOf) + .collect(Collectors.joining(",")); + } + + public EmployeePO selectEmployee(){ + //todo 如果sysadmin名称会变 后续用配置文件id + RecordSet rs = I18nContextUtil.getBean(RecordSet.class); + String poolname = CONN_TYPE.hrm.getType(); + EmployeePO employeePO = new EmployeePO(); + String sql = "select id,tenant_key from eteams.employee where username = 'sysadmin'"; + rs.executeSql(sql,poolname); + if (rs.next()){ + employeePO.setId(Util.getLongValue(rs.getString("id"))); + employeePO.setTenantKey(Util.null2String(rs.getString("tenant_key"))); + } + return employeePO; + + } +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableMonitorPO.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableMonitorPO.java new file mode 100644 index 0000000..a0ebcbd --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableMonitorPO.java @@ -0,0 +1,61 @@ +package com.weaver.seconddev.xianghui.performance.entity.po; + +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * @Author liang.cheng + * @Date 2025/6/10 16:35 + * @Description: TODO + * @Version 1.0 + */ + +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +@TableName("uf_jxcx") +public class EbTableMonitorPO { + + /** + * eb表单基础字段 + */ + private Long id; + private Long formDataId; + private Integer dataIndex; + private Integer isFlow; + private Integer dataStatus; + private Date createTime; + private Date updateTime; + private String tenantKey; + private Long creator; + private Long updater; + private Integer deleteType; + private Integer ftStatus; + + /** + * 自定义字段 + */ + private String pfid; + private String khmc; + private String khzq; + private Date pfzq; + private Long khdx; + private Long bm; + private String dqjd; + private String dclr; + private Date fbsj; + private String qljbm; + /** + * 评分周期截取字段 2025-06 + */ + private String zq; + private BigDecimal df; + private BigDecimal xs; +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableScoreCoefficientPO.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableScoreCoefficientPO.java new file mode 100644 index 0000000..deed228 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EbTableScoreCoefficientPO.java @@ -0,0 +1,50 @@ +package com.weaver.seconddev.xianghui.performance.entity.po; + +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * @Author liang.cheng + * @Date 2025/6/10 16:35 + * @Version 1.0 + */ + +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +@TableName("uf_jxdfxs") +public class EbTableScoreCoefficientPO { + + /** + * eb表单基础字段 + */ + private Long id; + private Long formDataId; + private Integer dataIndex; + private Integer isFlow; + private Integer dataStatus; + private Date createTime; + private Date updateTime; + private String tenantKey; + private Long creator; + private Long updater; + private Integer deleteType; + private Integer ftStatus; + + /** + * 自定义字段 + */ + private Long bm; + private Date nf; + private BigDecimal zxfs; + private BigDecimal zdfs; + private String pfxs; + +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EmployeePO.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EmployeePO.java new file mode 100644 index 0000000..4e812b4 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/EmployeePO.java @@ -0,0 +1,25 @@ +package com.weaver.seconddev.xianghui.performance.entity.po; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @Author liang.cheng + * @Date 2025/6/11 14:52 + * @Description: TODO + * @Version 1.0 + */ +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class EmployeePO { + + private Long id; + + private String tenantKey; + + private String username; +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/HrKpiFlowPO.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/HrKpiFlowPO.java new file mode 100644 index 0000000..d1d1497 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/entity/po/HrKpiFlowPO.java @@ -0,0 +1,85 @@ +package com.weaver.seconddev.xianghui.performance.entity.po; + +import com.fasterxml.jackson.annotation.JsonFormat; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * @Author liang.cheng + * @Date 2025/6/10 16:46 + * @Description: 评分 + * @Version 1.0 + */ +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class HrKpiFlowPO { + + /** + * 主键id + */ + private Long id; + + /** + * 考核对象 + */ + private Long kpiUser; + + /** + * 评分名称 + */ + private String name; + + /** + * 当前步骤id + */ + private Long kpiCurrentStep; + + + /** + * 考核周期 + */ + private String dateType; + + /** + * 当前阶段 + */ + private String flowStatus; + + /** + * 评分周期 + */ + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private Date realPeriod; + + /** + * 待处理人 + */ + private String pendingPerson; + + + /** + * 发布时间 + */ + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private Date createTime; + + + /** + * 部门 + */ + private Long departmentId; + + /** + * 分数 + */ + private BigDecimal score; + + +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableMonitorMapper.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableMonitorMapper.java new file mode 100644 index 0000000..398b4a9 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableMonitorMapper.java @@ -0,0 +1,17 @@ +package com.weaver.seconddev.xianghui.performance.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableMonitorPO; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +@Mapper +public interface EbTableMonitorMapper extends BaseMapper { + + boolean existsByPfid(@Param("pfid") String pfid, @Param("tenantKey") String tenantKey); + void deleteByPfid(@Param("pfid") String pfid, @Param("tenantKey") String tenantKey); + + int updateByPfid(@Param("record") EbTableMonitorPO record); + + int insert(@Param("record") EbTableMonitorPO record); +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableScoreCoefficientMapper.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableScoreCoefficientMapper.java new file mode 100644 index 0000000..3668162 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/EbTableScoreCoefficientMapper.java @@ -0,0 +1,16 @@ +package com.weaver.seconddev.xianghui.performance.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableScoreCoefficientPO; +import com.weaver.seconddev.xianghui.performance.entity.po.HrKpiFlowPO; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +@Mapper +public interface EbTableScoreCoefficientMapper extends BaseMapper { + + List selectScoreCoefficient(@Param("hrKpiFlowPO") HrKpiFlowPO hrKpiFlowPO,@Param("year") String year,@Param("tenantKey") String tenantKey); + +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/HrKpiFlowMapper.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/HrKpiFlowMapper.java new file mode 100644 index 0000000..eafc563 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/mapper/HrKpiFlowMapper.java @@ -0,0 +1,18 @@ +package com.weaver.seconddev.xianghui.performance.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.weaver.seconddev.xianghui.performance.entity.po.HrKpiFlowPO; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.Date; +import java.util.List; + +@Mapper +public interface HrKpiFlowMapper extends BaseMapper { + + List selectHrKpiFlowList(@Param("tenantKey")String tenantKey,@Param("startDate") Date startDate, + @Param("endDate") Date endDate); + + List findOperatorsByStepId(@Param("stepId") Long stepId, @Param("tenantKey") String tenantKey); +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/EbTableMonitorService.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/EbTableMonitorService.java new file mode 100644 index 0000000..caa44f0 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/EbTableMonitorService.java @@ -0,0 +1,45 @@ +package com.weaver.seconddev.xianghui.performance.service; + +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableMonitorPO; +import com.weaver.seconddev.xianghui.performance.entity.po.HrKpiFlowPO; + +import com.weaver.framework.rpc.context.impl.TenantRpcContext; + + +import java.math.BigDecimal; +import java.util.List; + +/** + * @Author liang.cheng + * @Date 2025/6/10 11:40 + * @Description: TODO + * @Version 1.0 + */ +public interface EbTableMonitorService { + + List getData(); + + List buildEbData(); + + int deleteEbData(String pfid); + + BigDecimal buildScoreCoefficient(HrKpiFlowPO hrKpiFlowPO,String tenantKey); + + /** + * 获取租户 + */ + default String getTenantKey() { + return TenantRpcContext.getCurrentTenantKey(); + } + + default String getCurrentUserId() { + return TenantRpcContext.getCurrentEmployeeId(); + } + + default Long getCurrentUserIdLong() { + return TenantRpcContext.getEmployeeIdLong(); + } + + + +} diff --git a/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/impl/EbTableMonitorServiceImpl.java b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/impl/EbTableMonitorServiceImpl.java new file mode 100644 index 0000000..72e39b4 --- /dev/null +++ b/secondev-xianghui-performance/src/main/java/com/weaver/seconddev/xianghui/performance/service/impl/EbTableMonitorServiceImpl.java @@ -0,0 +1,125 @@ +package com.weaver.seconddev.xianghui.performance.service.impl; + +import com.weaver.seconddev.xianghui.performance.entity.bo.EbTableMonitorBO; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableMonitorPO; +import com.weaver.seconddev.xianghui.performance.entity.po.EbTableScoreCoefficientPO; +import com.weaver.seconddev.xianghui.performance.entity.po.EmployeePO; +import com.weaver.seconddev.xianghui.performance.entity.po.HrKpiFlowPO; +import com.weaver.seconddev.xianghui.performance.mapper.EbTableMonitorMapper; +import com.weaver.seconddev.xianghui.performance.mapper.EbTableScoreCoefficientMapper; +import com.weaver.seconddev.xianghui.performance.mapper.HrKpiFlowMapper; +import com.weaver.seconddev.xianghui.performance.service.EbTableMonitorService; +import com.weaver.teams.security.context.UserContext; +import com.weaver.teams.security.user.User; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.math.BigDecimal; +import java.math.RoundingMode; +import java.text.SimpleDateFormat; +import java.util.Calendar; +import java.util.Comparator; +import java.util.Date; +import java.util.List; +import java.util.Optional; + +import static com.weaver.teams.security.DateUtils.clearTime; +import static com.weaver.teams.security.DateUtils.setTimeToEndOfDay; + +/** + * @Author liang.cheng + * @Date 2025/6/10 11:40 + * @Description: TODO + * @Version 1.0 + */ +@Service +public class EbTableMonitorServiceImpl implements EbTableMonitorService { + + @Autowired + private HrKpiFlowMapper hrKpiFlowMapper; + + @Autowired + private EbTableMonitorMapper ebTableMonitorMapper; + + @Autowired + private EbTableScoreCoefficientMapper ebTableScoreCoefficientMapper; + + @Autowired + private EbTableMonitorBO ebTableMonitorBO; + + private static final Logger log = LoggerFactory.getLogger(EbTableMonitorServiceImpl.class); + + + @Override + public List getData() { + +// User currentUser = UserContext.getCurrentUser(); +// String tenantKey1 = currentUser.getTenantKey(); + EmployeePO employeePO = ebTableMonitorBO.selectEmployee(); + String tenantKey = employeePO.getTenantKey(); + return hrKpiFlowMapper.selectHrKpiFlowList(tenantKey,getFirstDayOfCurrentYear(),getLastDayOfCurrentYear()); + } + + @Override + public List buildEbData() { + List data = getData(); + return ebTableMonitorBO.convertToEbTableMonitor(data); + } + + @Override + public int deleteEbData(String pfid) { + User currentUser = UserContext.getCurrentUser(); + String tenantKey = currentUser.getTenantKey(); + ebTableMonitorMapper.deleteByPfid(pfid,tenantKey); + return 1; + } + + @Override + public BigDecimal buildScoreCoefficient(HrKpiFlowPO hrKpiFlowPO,String tenantKey) { + String year = ""; + if (hrKpiFlowPO.getRealPeriod() != null) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy"); + year = sdf.format(hrKpiFlowPO.getRealPeriod()); + } + List coefficientPOList = ebTableScoreCoefficientMapper.selectScoreCoefficient(hrKpiFlowPO, year, tenantKey); + EbTableScoreCoefficientPO coefficientPO = coefficientPOList.stream() + .max(Comparator.comparingLong(EbTableScoreCoefficientPO::getId)) + .orElse(null); + + if (coefficientPO == null) { + return null; + } + + String pfxs = coefficientPO.getPfxs(); + if (pfxs == null) {return null;} + + if (pfxs.trim().contains("实际绩效得分/100") ) { + return Optional.ofNullable(hrKpiFlowPO.getScore()) + .map(score -> score.divide(new BigDecimal(100), 2, RoundingMode.HALF_UP)) + .orElse(null); + }else { + try { + return new BigDecimal(pfxs); + } catch (NumberFormatException e) { + log.error("无效的pfxs数值格式: {}", pfxs+"--->"+hrKpiFlowPO.getScore()); + return null; + } + } + } + + + private Date getFirstDayOfCurrentYear() { + Calendar cal = Calendar.getInstance(); + cal.set(Calendar.DAY_OF_YEAR, 1); // 设为当年第一天 + return clearTime(cal.getTime()); // 时间清零：00:00:00 + } + + private Date getLastDayOfCurrentYear() { + Calendar cal = Calendar.getInstance(); + cal.set(Calendar.MONTH, 11); // 12月（注意Calendar.MONTH从0开始） + cal.set(Calendar.DAY_OF_MONTH, 31); // 31号 + return setTimeToEndOfDay(cal.getTime()); // 时间设为：23:59:59 + } +} \ No newline at end of file diff --git a/secondev-xianghui-performance/src/main/resources/mapper/EbTableMonitorMapper.xml b/secondev-xianghui-performance/src/main/resources/mapper/EbTableMonitorMapper.xml new file mode 100644 index 0000000..397d5f7 --- /dev/null +++ b/secondev-xianghui-performance/src/main/resources/mapper/EbTableMonitorMapper.xml @@ -0,0 +1,107 @@ + + + + + + + + UPDATE uf_jxcx + SET + + update_time = #{record.updateTime}, + + + khmc = #{record.khmc}, + khzq = #{record.khzq}, + pfzq = #{record.pfzq}, + khdx = #{record.khdx}, + bm = #{record.bm}, + dqjd = #{record.dqjd}, + dclr = #{record.dclr}, + fbsj = #{record.fbsj}, + qljbm = #{record.qljbm}, + zq = #{record.zq}, + df=#{record.df}, + xs=#{record.xs} + WHERE + pfid = #{record.pfid} + AND tenant_key = #{record.tenantKey} + AND delete_type = 0 + + + + INSERT INTO uf_jxcx ( + + id, + form_data_id, + data_index, + is_flow, + data_status, + create_time, + update_time, + tenant_key, + creator, + updater, + delete_type, + ft_status, + + + pfid, + khmc, + khzq, + pfzq, + khdx, + bm, + dqjd, + dclr, + fbsj, + qljbm, + zq, + df, + xs + ) VALUES ( + #{record.id}, + #{record.formDataId}, + #{record.dataIndex}, + #{record.isFlow}, + #{record.dataStatus}, + #{record.createTime}, + #{record.updateTime}, + #{record.tenantKey}, + #{record.creator}, + #{record.updater}, + #{record.deleteType}, + #{record.ftStatus}, + + #{record.pfid}, + #{record.khmc}, + #{record.khzq}, + #{record.pfzq}, + #{record.khdx}, + #{record.bm}, + #{record.dqjd}, + #{record.dclr}, + #{record.fbsj}, + #{record.qljbm}, + #{record.zq}, + #{record.df}, + #{record.xs} + ) + + + + UPDATE uf_jxcx SET delete_type = 3 + WHERE pfid = #{pfid} + AND tenant_key = #{tenantKey} + AND delete_type = 0 + + + + diff --git a/secondev-xianghui-performance/src/main/resources/mapper/EbTableScoreCoefficientMapper.xml b/secondev-xianghui-performance/src/main/resources/mapper/EbTableScoreCoefficientMapper.xml new file mode 100644 index 0000000..9a6b989 --- /dev/null +++ b/secondev-xianghui-performance/src/main/resources/mapper/EbTableScoreCoefficientMapper.xml @@ -0,0 +1,30 @@ + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/secondev-xianghui-performance/src/main/resources/mapper/HrKpiFlowMapper.xml b/secondev-xianghui-performance/src/main/resources/mapper/HrKpiFlowMapper.xml new file mode 100644 index 0000000..5cb795f --- /dev/null +++ b/secondev-xianghui-performance/src/main/resources/mapper/HrKpiFlowMapper.xml @@ -0,0 +1,99 @@ + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file