shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/backlogTack/ToDoResendTack.java

@@ -1,243 +0,0 @@
-package shkd.sse.midservice.ct.backlogTack;
-
-import com.bes.admin.jeemx.util.ObjectUtil;
-import com.google.common.base.Objects;
-import kd.bos.algo.DataSet;
-import kd.bos.algo.Row;
-import kd.bos.context.RequestContext;
-import kd.bos.dataentity.entity.DynamicObject;
-import kd.bos.db.DB;
-import kd.bos.db.DBRoute;
-import kd.bos.exception.KDException;
-import kd.bos.logging.Log;
-import kd.bos.logging.LogFactory;
-import kd.bos.login.utils.DateUtils;
-import kd.bos.orm.query.QFilter;
-import kd.bos.schedule.executor.AbstractTask;
-import kd.bos.servicehelper.QueryServiceHelper;
-import kd.bos.util.StringUtils;
-import shkd.sse.midservice.ct.handler.CreateToDoHandler;
-import shkd.sse.midservice.ct.handler.DealToDoHandler;
-import shkd.sse.midservice.ct.handler.deleteToDoHandler;
-import shkd.sse.midservice.ct.model.BacklogMessage;
-import shkd.sse.midservice.ct.utils.GetUrlUtils;
-
-import java.util.*;
-
-public class ToDoResendTack extends AbstractTask {
-    private static final Log logger = LogFactory.getLog(ToDoResendTack.class);
-
-    /***
-     * 重发
-     * @param requestContext 未使用
-     * @param map 调度作业中的参数
-     * @throws KDException 异常
-     */
-    @Override
-    public void execute(RequestContext requestContext, Map<String, Object> map) throws KDException {
-        logger.info("待办重发开始");
-        String startTime = (String) map.get("starttime");
-        String endTime = (String) map.get("endtime");
-        Date startTimeDate = null;
-        Date endTimeDate = null;
-        if (StringUtils.isEmpty(startTime) || startTime.length() != 19) {
-            Date date = new Date();
-            logger.error("调度作业参数提供的开始时间格式不对或者未传入开始时间，自动转成：" + date);
-            //获得前三天对应的时间
-            endTimeDate = date;
-            long time = endTimeDate.getTime() - 86400000 * 3;
-            startTimeDate = new Date(time);
-        } else {
-            startTimeDate = DateUtils.parseDateTime(startTime, "yyyy-MM-dd HH:mm:ss");
-            endTimeDate = DateUtils.parseDateTime(endTime, "yyyy-MM-dd HH:mm:ss");
-            logger.info("待办重发-starttime:" + startTimeDate);
-            logger.info("待办重发-endtime:" + endTimeDate);
-        }
-        logger.info("组装待办、已办重发的数据");
-        Date beginTimeDate = startTimeDate;
-        // 待办
-        boolean hasNext = true;
-        logger.info("开始抽取待办,参数 beginTimeDate：" + beginTimeDate + "endTimeDate:" + endTimeDate);
-        extractToDoList(beginTimeDate, endTimeDate, "1");
-        extractToDoList(beginTimeDate, endTimeDate, "2");
-        extractToDoList(beginTimeDate, endTimeDate, "5");
-    }
-
-    /***
-     *  抽取待办
-     * @param startTime 开始时间
-     * @param endTime 结束时间
-     * @param t_status 待办状态
-     * @return
-     */
-    private void extractToDoList(Date startTime, Date endTime, String t_status) {
-        String accountId = System.getProperty("efms.midservice.accountid");
-        logger.info("拼接sql,此次拼接的待办类型为:" + t_status + "(1:待办、2已办、5撤销),使用参数startTime：" + startTime + "endTime:"
-                + endTime);
-        StringBuffer cwbSql1 = new StringBuffer();
-        cwbSql1.append("SELECT ");
-        cwbSql1.append("b.FID,");
-        cwbSql1.append("b.FPROCDEFID,");
-        cwbSql1.append("b.FTASKDEFKEY,");
-        cwbSql1.append("b.FPROCINSTID,");
-        cwbSql1.append("b.FEXECUTIONID,");
-        cwbSql1.append("b.FPARENTTASKID,");
-        cwbSql1.append("b.FOWNER,");
-        cwbSql1.append("b.FASSIGNEE,");
-        cwbSql1.append("b.FCLAIMTIME,");
-        cwbSql1.append("b.FENDTIME,");
-        cwbSql1.append("b.FDURATION,");
-        cwbSql1.append("b.FPRIORITY,");
-        cwbSql1.append("b.FDUEDATE,");
-        cwbSql1.append("b.FFORMKEY,");
-        cwbSql1.append("b.FCATEGORY,");
-        cwbSql1.append("b.FISDISPLAY,");
-        cwbSql1.append("b.FSTARTERID,");
-        cwbSql1.append("b.FENTITYNUMBER,");
-        cwbSql1.append("b.FCREATEDATE,");
-        cwbSql1.append("b.FMODIFYDATE,");
-        cwbSql1.append("b.FASSIGNEEID,");
-        cwbSql1.append("b.FOWNERID,");
-        cwbSql1.append("b.FEXECUTIONTYPE,");
-        cwbSql1.append("b.FBUSINESSKEY,");
-        cwbSql1.append("b.FYZJGROUPID,");
-        cwbSql1.append("b.FPROCESSINGPAGE,");
-        cwbSql1.append("b.FHANDLESTATE,");
-        cwbSql1.append("b.FMOBILEFORMKEY,");
-        cwbSql1.append("b.FDELEGATION,");
-        cwbSql1.append("b.FBILLNO,");
-        cwbSql1.append("b.FPROCESSINGMOBILEPAGE,");
-        cwbSql1.append("b.FENDTYPE,");
-        cwbSql1.append("b.FSOURCE,");
-        cwbSql1.append("b.FVALIDATEOPERATION,");
-        cwbSql1.append("b.FNAME,");
-        cwbSql1.append("b.FSUBACTIVITYNAME,");
-        cwbSql1.append("b.FDESCRIPTION,");
-        cwbSql1.append("b.FSUBJECT,");
-        cwbSql1.append("b.FENTITYNAME,");
-        cwbSql1.append("b.FSENDERNAME,");
-        cwbSql1.append("b.FSTARTNAME,");
-        cwbSql1.append("b.FPARTICIPANTNAME,");
-        cwbSql1.append("b.FGROUPNUMBER,");
-        cwbSql1.append("b.FREALDURATION,");
-        cwbSql1.append("b.FBATCHOP,");
-        cwbSql1.append("b.FBILLTYPE,");
-        cwbSql1.append("b.FBIZTRACENO,");
-        cwbSql1.append("b.FSENDERNAMEFORMAT,");
-        cwbSql1.append("b.FSTARTNAMEFORMAT,");
-        cwbSql1.append("b.FPRESENTASSIGNEE,");
-        cwbSql1.append("b.FORGUNITID,");
-        cwbSql1.append("b.FORGVIEWID,");
-        cwbSql1.append("b.FPROCESSTYPE,");
-        cwbSql1.append("b.FSENDERID,");
-        cwbSql1.append("b.FCONTROL,");
-        cwbSql1.append("b.FEXTENDDATE,");
-        cwbSql1.append("b.FEXTENDNUMBER,");
-        cwbSql1.append("b.FEXTENDSTR1,");
-        cwbSql1.append("b.FEXTENDSTR2,");
-        cwbSql1.append("b.FDELETEREASON,");
-        cwbSql1.append("b.FEXTENDFORMAT,");
-        cwbSql1.append("b.FEXTENDMULSTR1,");
-        cwbSql1.append("b.FEXTENDMULSTR2,");
-        cwbSql1.append("a.FCREATEDATE fstarttime,");
-        cwbSql1.append("c.FID as factivityId,");
-        cwbSql1.append("d.FUSERID freceiveuserid,");
-        cwbSql1.append("d.FUSERNAME freceiveusername,");
-        cwbSql1.append("d.FCREATEDATE freceivetime,");
-        cwbSql1.append("d.FENDTIME fcompletetime,");
-        cwbSql1.append("d.FMODIFYDATE flastmodifytime ");
-        cwbSql1.append("from t_wf_hitaskinst b ");
-        cwbSql1.append("INNER JOIN t_wf_hiparticipant d on d.FTASKID=b.FID ");
-        cwbSql1.append("INNER JOIN t_wf_hiactinst c on c.FTASKID=b.FID ");
-        cwbSql1.append("INNER JOIN t_wf_hiprocinst a on a.FID=b.FPROCINSTID ");
-        cwbSql1.append("where b.FMODIFYDATE >= ? and b.FMODIFYDATE <=?");
-        if (Objects.equal("1", t_status)) {
-            cwbSql1.append("and (b.FDELETEREASON is null or b.FDELETEREASON =' ' or b.fdeletereason='') ");
-            cwbSql1.append(" and b.FENDTIME is null and d.FENDTIME is null ");
-        } else if (Objects.equal("2", t_status)) {
-            //   cwbSql1.append(" and (b.FDELETEREASON ='task complete' ) ");
-            cwbSql1.append(" and (b.FDELETEREASON ='task complete' or b.FDELETEREASON ='first_usertask_skip') ");
-            cwbSql1.append("  and b.FENDTIME is not null and d.FENDTIME is not null ");
-        } else if (Objects.equal("5", t_status)) {
-            cwbSql1.append(" and not ((b.FDELETEREASON is null or b.FDELETEREASON =' ' or b.fdeletereason='') ");
-            cwbSql1.append("  and b.FENDTIME is null and d.FENDTIME is null) ");
-            cwbSql1.append(" and not ((b.FDELETEREASON ='task complete' or b.FDELETEREASON ='first_usertask_skip') and b.FENDTIME is not null and d.FENDTIME is not null)");
-        }
-        cwbSql1.append(" ORDER BY b.FMODIFYDATE,b.FID");
-        DataSet cwbAmount1 = DB.queryDataSet(this.getClass().getName(), DBRoute.of("sys"), cwbSql1.toString(), new Object[]{startTime, endTime});
-        Iterator<Row> iterator = cwbAmount1.iterator();
-        logger.info("开始拼接待办数据");
-        try {
-            while (iterator.hasNext()) {
-                Row next = iterator.next();
-                //接收人手机号
-                DynamicObject dynamicObject = QueryServiceHelper.queryOne("bos_user", "name,shkd_pid," +
-                        "phone", new QFilter[]{new QFilter("id", "=", next.getString("freceiveuserid"))});
-                String phone = dynamicObject.getString("phone");
-                switch (t_status) {
-                    case "1":
-                        BacklogMessage backlogMessage = new BacklogMessage();
-                        //业务类型名称
-                        backlogMessage.setbName("业务类型名称");
-                        // 紧急程度
-                        backlogMessage.setUrGency("0");
-                        //当前节点名称
-                        backlogMessage.setCurrentStepName(next.getString("FNAME"));
-                        //上步骤名称
-                        backlogMessage.setPreStepName("");
-                        // startname发起人名称
-                        backlogMessage.setSendUserName(dynamicObject.getString("startname"));
-                        //接收人手机号
-                        backlogMessage.setReceiveUserId(phone);
-                        //标题
-                        String title = "请处理" + next.getString("fstartname") + "提交的" + next.getString("fentityname");
-                        backlogMessage.setTitle(title);
-                        //PC地址
-                        String pcUrl = GetUrlUtils.getInstance().getPcUrl(next.getString("fprocessingpage"),
-                            next.getString("fprocessingmobilepage"),
-                            next.getString("fsource"),
-                            accountId,
-                            next.getString("factivityId"),
-                            next.getString("fbusinesskey"),
-                            next.getString("fid"));
-                        backlogMessage.setHandleUrl(pcUrl);
-                        //PC地址查看
-                        backlogMessage.setViewUrl(pcUrl + "&ado=view");
-                        //app地址
-                        backlogMessage.setAppHandleUrl(pcUrl);
-                        //App应用名称
-                        backlogMessage.setAppName("");
-                        //app地址查看
-                        backlogMessage.setAppViewUrl(pcUrl + "&ado=view");
-                        //业务id
-                        backlogMessage.setPendingId(String.valueOf(next.getLong("fid")));
-                        // 业务编码
-                        backlogMessage.setBussinessCode(next.getString("fbillno"));
-                        //属性
-                        backlogMessage.setPendingAttr("0");
-                        //notifyMsg 通知消息
-                        backlogMessage.setNotifyMsg("");
-                        //notifyMethod 通知方式
-                        backlogMessage.setNotifyMethod("");
-                        //业务自定义数据
-                        backlogMessage.setJsonData("");
-                        CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(backlogMessage);
-                        break;
-                    case "2":
-                        DealToDoHandler.get_DealToDoHandler().sendDealToDo(next.getLong("id"),phone);
-                        break;
-                    case "5":
-                        deleteToDoHandler.get_deleteToDoHandler().sendDeleteToDo(next.getLong("id"),phone);
-                        break;
-                    default:
-                        break;
-                }
-            }
-        } catch (Exception e) {
-            logger.error("###待办数据拼接、发送失败,状态为"+t_status+",（1:待办,2:已办,5:撤销）,具体原因：", e.getMessage(), e);
-        }
-
-        logger.info("待办数据拼接和发送完成");
-    }
-}
-

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/constant/ToDoCenterConstant.java

@@ -1,16 +0,0 @@
-package shkd.sse.midservice.ct.constant;
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 16:37
- * @Version: 1.0
- * @Ability
- */
-public class ToDoCenterConstant {
-    public static String URI_send_addNew = "/bpm/task/api/addNew.dhtml";
-
-    public static String URI_SEND_finish = "/bpm/task/api/finishByRecordIdAndUserId.dhtml";
-
-    public static String URI_send_deleteP = "/oa/task/api/deletePendingByRecordIdAndUserId.dhtml";
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/CreateToDoHandler.java

@@ -1,59 +0,0 @@
-package shkd.sse.midservice.ct.handler;
-
-import com.alibaba.fastjson.JSONObject;
-import kd.bos.logging.Log;
-import kd.bos.logging.LogFactory;
-import shkd.sse.midservice.ct.constant.ToDoCenterConstant;
-import shkd.sse.midservice.ct.model.BacklogMessage;
-import shkd.sse.midservice.ct.utils.RequestClient;
-
-
-import java.util.Objects;
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 14:16
- * @Version: 1.0
- * @Ability 待办
- */
-public class CreateToDoHandler {
-
-    private static Log logger = LogFactory.getLog(CreateToDoHandler.class);
-    private static CreateToDoHandler _CreateToDoHandler;
-
-    public static synchronized CreateToDoHandler get_CreateToDoHandler(){
-        if(_CreateToDoHandler == null){
-            _CreateToDoHandler =  new CreateToDoHandler();
-        }
-        return _CreateToDoHandler;
-    }
-    public boolean sendCreateToDo(BacklogMessage messageInfo) {
-        try {
-            //body
-            JSONObject jsonObject2 = new JSONObject();
-            jsonObject2.put("params",messageInfo);
-            String jsonMessage = jsonObject2.toJSONString();
-            //调用接口结果
-            String result = RequestClient.getInstance().callService(ToDoCenterConstant.URI_send_addNew,jsonMessage);
-            //接口调用结果
-            JSONObject jsonObject = JSONObject.parseObject(result);
-            if(Objects.equals("success",jsonObject.getString("status"))){
-                //发送成功
-                //调用保存操作
-                RequestClient.getInstance().saveCreateToDo(messageInfo.getTitle(),ToDoCenterConstant.URI_send_addNew,true,result,jsonMessage);
-                return true;
-            }else{
-                //调用保存操作
-                RequestClient.getInstance().saveCreateToDo(messageInfo.getTitle(),ToDoCenterConstant.URI_send_addNew,false,result,jsonMessage);
-                //发送失败
-                logger.error("##接口调通失败");
-               return false;
-            }
-        } catch (Exception e) {
-            logger.error("###调用接口失败："+e.getMessage(),e);
-            return false;
-        }
-    }
-
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/DealToDoHandler.java

@@ -1,58 +0,0 @@
-package shkd.sse.midservice.ct.handler;
-
-import com.alibaba.fastjson.JSONObject;
-import kd.bos.logging.Log;
-import kd.bos.logging.LogFactory;
-import shkd.sse.midservice.ct.constant.ToDoCenterConstant;
-import shkd.sse.midservice.ct.utils.RequestClient;
-
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 14:18
- * @Version: 1.0
- * @Ability 处理（已办）
- */
-public class DealToDoHandler {
-    private static Log logger = LogFactory.getLog(DealToDoHandler.class);
-
-    private static DealToDoHandler _DealToDoHandler;
-
-    public static synchronized DealToDoHandler get_DealToDoHandler(){
-        if(_DealToDoHandler == null){
-            _DealToDoHandler =  new DealToDoHandler();
-        }
-        return _DealToDoHandler;
-    }
-
-    public boolean sendDealToDo(Long appRecordId,String userId) {
-        try {
-            //body
-            JSONObject jsonObject2 = new JSONObject();
-            JSONObject jsonObject_1 = new JSONObject();
-            jsonObject_1.put("appRecordId", appRecordId);
-            jsonObject_1.put("userId",userId);
-            jsonObject2.put("params",jsonObject_1);
-            String jsonMessage = jsonObject2.toJSONString();
-            //调用接口结果
-            String result = RequestClient.getInstance().callService(ToDoCenterConstant.URI_SEND_finish,jsonMessage);
-            //保存发送消息日志
-            //  writeMessageLog(MessageCenterConstant.URI_SEND_MESSAGE,messageInfo,result);
-            //接口调用结果
-            JSONObject jsonObject = JSONObject.parseObject(result);
-            if(jsonObject.getBoolean("success")){
-                //发送成功
-                RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_SEND_finish,true,result,jsonMessage,"2");
-                return true;
-            }else{
-                //发送失败
-                RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_SEND_finish,false,result,jsonMessage,"2");
-                return false;
-            }
-        } catch (Exception e) {
-            logger.error("调用接口失败："+e.getMessage(),e);
-            return false;
-        }
-    }
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/handler/deleteToDoHandler.java

@@ -1,57 +0,0 @@
-package shkd.sse.midservice.ct.handler;
-
-import com.alibaba.fastjson.JSONObject;
-import kd.bos.logging.Log;
-import kd.bos.logging.LogFactory;
-import shkd.sse.midservice.ct.constant.ToDoCenterConstant;
-import shkd.sse.midservice.ct.utils.RequestClient;
-
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 14:18
- * @Version: 1.0
- * @Ability 撤销
- */
-public class deleteToDoHandler {
-    private static Log logger = LogFactory.getLog(deleteToDoHandler.class);
-
-    private static deleteToDoHandler _deleteToDoHandler;
-
-    public static synchronized deleteToDoHandler get_deleteToDoHandler(){
-        if(_deleteToDoHandler == null){
-            _deleteToDoHandler =  new deleteToDoHandler();
-        }
-        return _deleteToDoHandler;
-    }
-
-    public boolean sendDeleteToDo(Long appRecordId,String userId) {
-        try {
-            //body
-            JSONObject jsonObject2 = new JSONObject();
-            JSONObject jsonObject_1 = new JSONObject();
-            jsonObject_1.put("appRecordId", appRecordId);
-            jsonObject_1.put("userId",userId);
-            jsonObject2.put("params",jsonObject_1);
-            String jsonMessage = jsonObject2.toJSONString();
-            //调用接口结果
-            String result = RequestClient.getInstance().callService(ToDoCenterConstant.URI_send_deleteP,jsonMessage);
-            //保存发送消息日志
-          //  writeMessageLog(MessageCenterConstant.URI_SEND_MESSAGE,messageInfo,result);
-            //接口调用结果
-            JSONObject jsonObject = JSONObject.parseObject(result);
-            if(jsonObject.getBoolean("success")){
-                //发送成功
-                RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_send_deleteP,true,result,jsonMessage,"5");
-                return true;
-            }else{
-                RequestClient.getInstance().saveDeLToDo(appRecordId,userId,ToDoCenterConstant.URI_send_deleteP,false,result,jsonMessage,"5");
-                return false;
-            }
-        } catch (Exception e) {
-            logger.error("###调用中台服务消息中心发送消息服务异常："+e.getMessage(),e);
-            return false;
-        }
-    }
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/model/BacklogMessage.java

@@ -1,176 +0,0 @@
-package shkd.sse.midservice.ct.model;
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 13:38
- * @Version: 1.0
- * @Ability
- */
-public class BacklogMessage {
-
-    private String bName;//业务类型名称 String false
-    private String urGency;//紧急程度 int true 0:普通;1:紧急;2:加急;3:特急 true
-    private String currentStepName;// 当前步骤名称 String false
-    private String preStepName;// 上步步骤名称 String false
-    private String sendUserName;// 发起人名称 String true
-    private String receiveUserId; //接收人 id String true 支持如下三种类型1.身份证号 2.手机号 3.登录账号
-    private String title;// 待办名称 String true
-    private String handleUrl;// pc 办理 url 地址 String true
-    private String appHandleUrl;// app 办理地址 String false
-    private String appViewUrl;// app 查看地址 String false
-    private String appName;// 应用名称 String false
-    private String viewUrl;// pc 查看 url 地址 String true
-    private String pendingId;// 业务 id String true
-    private String bussinessCode;// 业务编码 String true
-    private String pendingAttr;// 属性 Int true 0:待办;1:待阅；3:承办
-    private String notifyMsg;// 通知消息 String false
-    private String notifyMethod;// 通知方式 String false 0- 系统消息 1- 短信 2- 邮件3-app 消息推送。多个方式英文逗号隔开
-    private String jsonData;// 业务自定义数据 String false 业务模块的数据，再调用查询待办的接口将会返回，建议传一个 json 字符串;
-
-    public String getbName() {
-        return bName;
-    }
-
-    public void setbName(String bName) {
-        this.bName = bName;
-    }
-
-    public String getUrGency() {
-        return urGency;
-    }
-
-    public void setUrGency(String urGency) {
-        this.urGency = urGency;
-    }
-
-    public String getCurrentStepName() {
-        return currentStepName;
-    }
-
-    public void setCurrentStepName(String currentStepName) {
-        this.currentStepName = currentStepName;
-    }
-
-    public String getPreStepName() {
-        return preStepName;
-    }
-
-    public void setPreStepName(String preStepName) {
-        this.preStepName = preStepName;
-    }
-
-    public String getSendUserName() {
-        return sendUserName;
-    }
-
-    public void setSendUserName(String sendUserName) {
-        this.sendUserName = sendUserName;
-    }
-
-    public String getReceiveUserId() {
-        return receiveUserId;
-    }
-
-    public void setReceiveUserId(String receiveUserId) {
-        this.receiveUserId = receiveUserId;
-    }
-
-    public String getTitle() {
-        return title;
-    }
-
-    public void setTitle(String title) {
-        this.title = title;
-    }
-
-    public String getHandleUrl() {
-        return handleUrl;
-    }
-
-    public void setHandleUrl(String handleUrl) {
-        this.handleUrl = handleUrl;
-    }
-
-    public String getAppHandleUrl() {
-        return appHandleUrl;
-    }
-
-    public void setAppHandleUrl(String appHandleUrl) {
-        this.appHandleUrl = appHandleUrl;
-    }
-
-    public String getAppViewUrl() {
-        return appViewUrl;
-    }
-
-    public void setAppViewUrl(String appViewUrl) {
-        this.appViewUrl = appViewUrl;
-    }
-
-    public String getAppName() {
-        return appName;
-    }
-
-    public void setAppName(String appName) {
-        this.appName = appName;
-    }
-
-    public String getViewUrl() {
-        return viewUrl;
-    }
-
-    public void setViewUrl(String viewUrl) {
-        this.viewUrl = viewUrl;
-    }
-
-    public String getPendingId() {
-        return pendingId;
-    }
-
-    public void setPendingId(String pendingId) {
-        this.pendingId = pendingId;
-    }
-
-    public String getBussinessCode() {
-        return bussinessCode;
-    }
-
-    public void setBussinessCode(String bussinessCode) {
-        this.bussinessCode = bussinessCode;
-    }
-
-    public String getPendingAttr() {
-        return pendingAttr;
-    }
-
-    public void setPendingAttr(String pendingAttr) {
-        this.pendingAttr = pendingAttr;
-    }
-
-    public String getNotifyMsg() {
-        return notifyMsg;
-    }
-
-    public void setNotifyMsg(String notifyMsg) {
-        this.notifyMsg = notifyMsg;
-    }
-
-    public String getNotifyMethod() {
-        return notifyMethod;
-    }
-
-    public void setNotifyMethod(String notifyMethod) {
-        this.notifyMethod = notifyMethod;
-    }
-
-    public String getJsonData() {
-        return jsonData;
-    }
-
-    public void setJsonData(String jsonData) {
-        this.jsonData = jsonData;
-    }
-
-
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/servicehandler/BacklogServiceHandle.java

@@ -1,112 +0,0 @@
-package shkd.sse.midservice.ct.servicehandler;
-
-import kd.bos.dataentity.entity.DynamicObject;
-import kd.bos.dataentity.entity.DynamicObjectCollection;
-import kd.bos.logging.Log;
-import kd.bos.logging.LogFactory;
-import kd.bos.orm.query.QFilter;
-import kd.bos.servicehelper.QueryServiceHelper;
-import kd.bos.workflow.engine.msg.ctx.MessageContext;
-import kd.bos.workflow.engine.msg.handler.AbstractServiceHandler;
-import kd.bos.workflow.engine.msg.info.ToDoInfo;
-import shkd.sse.midservice.ct.handler.CreateToDoHandler;
-import shkd.sse.midservice.ct.handler.DealToDoHandler;
-import shkd.sse.midservice.ct.handler.deleteToDoHandler;
-import shkd.sse.midservice.ct.model.BacklogMessage;
-
-import java.util.List;
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 14:07
- * @Version: 1.0
- * @Ability
- */
-public class BacklogServiceHandle extends AbstractServiceHandler {
-
-    public static final String TYPE = "todo";
-
-    private static final Log logger = LogFactory.getLog(BacklogServiceHandle.class);
-
-    public void createToDo(MessageContext ctx, ToDoInfo todoInfo) {
-
-        logger.info("###创建待办_createToDo");
-        //几个待办
-        List<Long> userIds = todoInfo.getUserIds();
-        DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone", new QFilter[]{new QFilter("id", "in", userIds)});
-        DynamicObject dynamicObject = QueryServiceHelper.queryOne("wf_hitaskinst", "billno,startname,id,name",
-                new QFilter[]{new QFilter("id", "=", todoInfo.getTaskId())});
-        for (DynamicObject query_one : query) {
-
-            BacklogMessage backlogMessage = new BacklogMessage();
-            //业务类型名称
-            backlogMessage.setbName("业务类型名称");
-            // 紧急程度
-            backlogMessage.setUrGency("0");
-            //当前节点名称
-            backlogMessage.setCurrentStepName(dynamicObject.getString("name"));
-            //上步骤名称
-            backlogMessage.setPreStepName("");
-            // startname发起人名称
-            backlogMessage.setSendUserName(dynamicObject.getString("startname"));
-            //接收人手机号
-            backlogMessage.setReceiveUserId(query_one.getString("phone"));
-            //标题
-            backlogMessage.setTitle(todoInfo.getTitle());
-            //PC地址
-            backlogMessage.setHandleUrl(todoInfo.getUrl());
-            //PC地址查看
-            backlogMessage.setViewUrl(todoInfo.getUrl()+"&ado=view");
-            //app地址
-            backlogMessage.setAppHandleUrl(todoInfo.getUrl());
-            //App应用名称
-            backlogMessage.setAppName("");
-            //app地址查看
-            backlogMessage.setAppViewUrl(todoInfo.getUrl()+"&ado=view");
-            //业务id
-            backlogMessage.setPendingId(String.valueOf(todoInfo.getTaskId()));
-            // 业务编码
-            backlogMessage.setBussinessCode(dynamicObject.getString("billno"));
-            //属性
-            backlogMessage.setPendingAttr("0");
-            //notifyMsg 通知消息
-            backlogMessage.setNotifyMsg("");
-            //notifyMethod 通知方式
-            backlogMessage.setNotifyMethod("");
-            //业务自定义数据
-            backlogMessage.setJsonData("");
-            CreateToDoHandler.get_CreateToDoHandler().sendCreateToDo(backlogMessage);
-        }
-        logger.info("###结束待办_createToDo");
-
-    }
-
-    //已办
-    public void dealToDo(MessageContext ctx, ToDoInfo info){
-        logger.info("###创建已办_dealToDo");
-        //几个已办
-        List<Long> userIds = info.getUserIds();
-        DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone", new QFilter[]{new QFilter("id", "in", userIds)});
-       //业务id
-        Long taskId = ctx.getTaskId();
-        for (DynamicObject queryOne : query) {
-            DealToDoHandler.get_DealToDoHandler().sendDealToDo(taskId,queryOne.getString("phone"));
-        }
-        logger.info("###结束已办_dealToDo");
-
-    }
-    //撤销
-    public void deleteToDo(MessageContext ctx, ToDoInfo info){
-        logger.info("###创建撤销_deleteToDo");
-        List<Long> userIds = info.getUserIds();
-        DynamicObjectCollection query = QueryServiceHelper.query("bos_user", "id,name,phone", new QFilter[]{new QFilter("id", "in", userIds)});
-        //业务id
-        Long taskId = ctx.getTaskId();
-        for (DynamicObject queryOne : query) {
-            deleteToDoHandler.get_deleteToDoHandler().sendDeleteToDo(taskId,queryOne.getString("phone"));
-        }
-        logger.info("###结束撤销_deleteToDo");
-    }
-
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/GetUrlUtils.java

@@ -1,52 +0,0 @@
-package shkd.sse.midservice.ct.utils;
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/7 14:38
- * @Version: 1.0
- * @Ability 获得url地址
- */
-public class GetUrlUtils {
-
-    private static GetUrlUtils _instance;
-    /**
-     * 获取实例
-     */
-    public static synchronized GetUrlUtils getInstance() {
-        if (_instance == null) {
-            _instance = new GetUrlUtils();
-        }
-        return _instance;
-    }
-
-    /**
-     * 构建待办链接
-     * @param formId PC表单id
-     * @param mobFormId 移动表单id
-     * @param source 来源应用编码
-     * @param accountId 数据中心
-     * @param activityId 活动id
-     * @param pkId 单据id
-     * @param taskId 任务id
-     * @return
-     */
-    public String getPcUrl(String formId, String mobFormId, String source, String accountId,
-    Object activityId, Object pkId, Object taskId) {
-        StringBuffer urlBuffer = new StringBuffer();
-        urlBuffer.append(System.getProperty("efms.midservice.backlog.url"));
-        // urlBuffer.append("http:10.17.85:8022/ierp");
-        urlBuffer.append("/integration/yzjShareOpen.do");
-        urlBuffer.append("?formId=").append(formId);
-        urlBuffer.append("&mb_formId=").append(mobFormId);
-        urlBuffer.append("&pkId=").append(pkId);
-        urlBuffer.append("&src=").append(source.toLowerCase());
-        urlBuffer.append("&accountId=").append(accountId);
-        urlBuffer.append("&activityId=").append(activityId);
-        urlBuffer.append("&tId=").append(taskId);
-        urlBuffer.append("&apptype=backlogMQ");
-        return urlBuffer.toString();
-    }
-
-
-}

shkd-cosmic-debug/src/main/java/shkd/sse/midservice/ct/utils/RequestClient.java

@@ -1,130 +0,0 @@
-package shkd.sse.midservice.ct.utils;
-
-import com.alibaba.fastjson.JSON;
-import kd.bos.dataentity.entity.DynamicObject;
-import kd.bos.servicehelper.BusinessDataServiceHelper;
-import kd.bos.servicehelper.operation.SaveServiceHelper;
-import kd.bos.util.HttpClientUtils;
-import kd.bos.util.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @Description:
- * @Author: FangShiXiao
- * @Date: 2024/11/5 14:46
- * @Version: 1.0
- * @Ability
- */
-public class RequestClient {
-    private static RequestClient _instance;
-    private static Logger logger = LoggerFactory.getLogger(RequestClient.class);
- // application/x-www-form-urlencoded
-    private String protocal;//http
-    private String ip;// 域名
-    private String port;// 端口
-
-    private RequestClient() {
-        this.protocal = System.getProperty("efms.midservice.protocal");
-        this.ip = System.getProperty("efms.midservice.ip");
-        this.port = System.getProperty("efms.midservice.port");
-    }
-    /**
-     * 获取中台服务客户端实例
-     *
-     * @return
-     */
-    public static synchronized RequestClient getInstance() {
-        if (_instance == null) {
-            _instance = new RequestClient();
-        }
-        return _instance;
-    }
-    /**
-     * 封装中台请求头，执行POST请求
-     *
-     * @param url  接口地址（不含http://ip:port的后半部分）
-     * @param body JSON格式字符串
-     * @return 响应结果报文
-     */
-    public String callService(String url, String body) {
-        Map<String, String> header = new HashMap<>();
-        header.put("Content-Type", "application/x-www-form-urlencoded");
-        StringBuffer urlStr = new StringBuffer();
-        urlStr.append(this.protocal).append("://").append(this.ip);
-        if (!StringUtils.isEmpty(this.port)) {
-            urlStr.append(":").append(this.port);
-        }
-        urlStr.append(url);
-        String responseText = null;
-        try {
-            //直接POST请求
-            responseText = HttpClientUtils.postjson(urlStr.toString(), header, body);
-            logger.info(String.format("###调用接口成功，请求URL：%s，请求Header：%s，请求Body：%s，响应报文：%s", url, JSON.toJSONString(header), body, responseText));
-        } catch (IOException e) {
-            logger.error(String.format("###调用接口异常：%s，请求URL：%s，请求Header：%s，请求Body：%s", e.getMessage(), url, JSON.toJSONString(header), body), e);
-        }
-        return responseText;
-    }
-
-    /***
-     *  保存待办日志
-     * @param title 标题
-     * @param url 路径
-     * @param isTrue 接口调用是否成功
-     * @param result 响应报文
-     * @param jsonMessage 请求报文
-     */
-    public void saveCreateToDo(String title,String url, boolean isTrue,String result,String jsonMessage){
-        logger.info("###开始调用待办保存日志方法");
-        StringBuffer urlStr = new StringBuffer();
-        urlStr.append(this.protocal).append("://").append(this.ip);
-        if (!StringUtils.isEmpty(this.port)) {
-            urlStr.append(":").append(this.port);
-        }
-        urlStr.append(url);;
-        DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog");
-        dynamicObject.set("shkd_url",urlStr);
-        dynamicObject.set("shkd_request",title);
-        dynamicObject.set("shkd_request_tag",jsonMessage);
-        dynamicObject.set("shkd_response",isTrue);
-        dynamicObject.set("shkd_response",result);
-        dynamicObject.set("shkd_status","0");
-        SaveServiceHelper.save(new DynamicObject[]{dynamicObject});
-        logger.info("###结束调用待办保存日志方法");
-    }
-    /***
-     *  保存待办日志
-     * @param appRecordId 业务id
-     * @param userId 接收人id
-     * @param url 路径
-     * @param isTrue 接口调用是否成功
-     * @param result 响应报文
-     * @param jsonMessage 请求报文
-     * @param status 类型 2：已办 5：撤销
-     */
-    public void saveDeLToDo(Long appRecordId,String userId,String url,boolean isTrue,String result,String jsonMessage,String status){
-        logger.info("###开始调用已办、撤销保存日志方法");
-        StringBuffer urlStr = new StringBuffer();
-        urlStr.append(this.protocal).append("://").append(this.ip);
-        if (!StringUtils.isEmpty(this.port)) {
-            urlStr.append(":").append(this.port);
-        }
-        urlStr.append(url);
-        DynamicObject dynamicObject = BusinessDataServiceHelper.newDynamicObject("shkd_backlog");
-        dynamicObject.set("shkd_url",urlStr);
-        dynamicObject.set("shkd_request","业务id:"+appRecordId+",接收人手机号："+userId);
-        dynamicObject.set("shkd_request_tag",jsonMessage);
-        dynamicObject.set("shkd_response",isTrue);
-        dynamicObject.set("shkd_response",result);
-        dynamicObject.set("shkd_status",status);
-        logger.info("###开始调用已办、撤销保存日志方法");
-
-    }
-
-
-}