同步accoutId

fuliqi

2023-12-16 3794effa1e9e78e82e81253d6a6d54ad6db89b7e

 ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/IDispatchHandleServiceImpl.java

@@ -1,22 +1,31 @@
package com.ycl.service.caseHandler.impl;

import com.alibaba.druid.support.json.JSONUtils;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ycl.controller.video.common.constant.BaseCaseStatus;
import com.ycl.controller.video.common.constant.StepName;
import com.google.gson.JsonObject;
import com.ycl.common.constant.BaseCaseStatus;
import com.ycl.common.constant.StepName;
import com.ycl.common.dingding.DingCommon;
import com.ycl.controller.user.UmsAdminController;
import com.ycl.dto.caseHandler.DispatchInfoParam;
import com.ycl.entity.caseHandler.BaseCase;
import com.ycl.entity.caseHandler.DispatchInfo;
import com.ycl.entity.caseHandler.DisposeRecord;
import com.ycl.entity.caseHandler.WorkflowConfigStep;
import com.ycl.entity.user.UmsAdmin;
import com.ycl.exception.ApiException;
import com.ycl.mapper.caseHandler.BaseCaseMapper;
import com.ycl.mapper.caseHandler.DispatchInfoMapper;
import com.ycl.mapper.caseHandler.DisposeRecordMapper;
import com.ycl.mapper.caseHandler.WorkflowConfigStepMapper;
import com.ycl.service.caseHandler.IDispatchHandleService;
import com.ycl.service.user.UmsAdminService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@@ -34,6 +43,7 @@
 */
@Service
@Transactional
@Slf4j
public class IDispatchHandleServiceImpl extends ServiceImpl<DispatchInfoMapper, DispatchInfo> implements IDispatchHandleService {

    @Resource
@@ -42,8 +52,12 @@
    DisposeRecordMapper disposeRecordMapper;
    @Resource
    WorkflowConfigStepMapper workflowConfigStepMapper;

    @Autowired
    DingCommon dingCommon;
    @Autowired
    UmsAdminService umsAdminService;
    @Override
    @Transactional
    public DispatchInfo dispatch(DispatchInfoParam dispatchInfoParam) {
        //新增调度信息
        DispatchInfo dispatchInfo = new DispatchInfo();
@@ -88,6 +102,7 @@
        stepNextRecord.setStepName(stepNext.getName());
        stepNextRecord.setLimitTime(dispatchInfoParam.getDisposeDate());
        stepNextRecord.setHandlerId(dispatchInfoParam.getLawEnforcer());
        stepNextRecord.setHandlerRoleId(stepNext.getRoleId());
        //上传处置未结束
        stepNextRecord.setState(0);
        stepNextRecord.setStartTime(LocalDateTime.now());
@@ -95,6 +110,18 @@
        stepNextRecord.setCreateTime(LocalDateTime.now());

        disposeRecordMapper.insert(stepNextRecord);
        //发送钉钉工作通知消息
        log.info("发送一条工作通知");
        BaseCase baseCaseForCode = baseCaseMapper.selectById(dispatchInfoParam.getBaseCaseId());
        String baseCaseCode = baseCaseForCode.getCode();
        String text ="您有一条工作通知  \n  " +
                " 遂昌云执法：有待处理的任务  \n  " +
                "·您有1条待处理事件。事件编号:  \n  " +
                baseCaseCode;
        Long lawEnforcer = dispatchInfoParam.getLawEnforcer();
        UmsAdmin user = umsAdminService.getById(lawEnforcer);
        dingCommon.sendDingMsgStr(user.getAccountId()+"",text);

        return dispatchInfo;
    }