Commit c064f81f authored by fangxinjiang's avatar fangxinjiang

Merge branch 'MVP1.5.9' into MVP1.6.0

# Conflicts:
#	yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/mapper/MsgInfoMapper.java
#	yifu-msg/yifu-msg-biz/src/main/resources/mapper/MsgInfoMapper.xml
parents 97148c24 2d57bd9e
package com.yifu.cloud.plus.v1.msg.vo;
import lombok.Data;
/**
* @Author huyc
* @Date 2023/11/1
* @Description
* @Version 1.0
*/
@Data
public class EkpInsertMsgVo {
/**
* 订单url
**/
private String urlInfo;
/**
* 订单id
**/
private String orderId;
/**
* 项目名称
**/
private String domainName;
/**
* 订单号
**/
private String dingdanNo;
/**
* 登录人
**/
private String userName;
}
...@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yifu.cloud.plus.v1.msg.entity.MsgInfo; import com.yifu.cloud.plus.v1.msg.entity.MsgInfo;
import com.yifu.cloud.plus.v1.msg.service.MsgInfoService; import com.yifu.cloud.plus.v1.msg.service.MsgInfoService;
import com.yifu.cloud.plus.v1.msg.vo.EkpAlertVo; import com.yifu.cloud.plus.v1.msg.vo.EkpAlertVo;
import com.yifu.cloud.plus.v1.msg.vo.EkpInsertMsgVo;
import com.yifu.cloud.plus.v1.yifu.common.core.util.R; import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
import com.yifu.cloud.plus.v1.yifu.common.log.annotation.SysLog; import com.yifu.cloud.plus.v1.yifu.common.log.annotation.SysLog;
import com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner; import com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner;
...@@ -118,4 +119,17 @@ public class MsgInfoController { ...@@ -118,4 +119,17 @@ public class MsgInfoController {
public void cancelHandledMsg() { public void cancelHandledMsg() {
msgInfoService.cancelHandledMsg(); msgInfoService.cancelHandledMsg();
} }
/**
* @Author huyc
* @Description 转办人发消息
* @Date 10:58 2023/11/1
* @Param
* @return
**/
@Operation(summary = "转办人发消息", description = "转办人发消息")
@PostMapping("/sendZbMessage")
public R sendZbMessage(EkpInsertMsgVo vo) {
return msgInfoService.sendZbMessage(vo);
}
} }
...@@ -21,6 +21,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; ...@@ -21,6 +21,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yifu.cloud.plus.v1.msg.entity.MsgInfo; import com.yifu.cloud.plus.v1.msg.entity.MsgInfo;
import com.yifu.cloud.plus.v1.msg.vo.EkpInsertMsgVo;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
...@@ -53,4 +54,7 @@ public interface MsgInfoMapper extends BaseMapper<MsgInfo> { ...@@ -53,4 +54,7 @@ public interface MsgInfoMapper extends BaseMapper<MsgInfo> {
int deleteHandledMsg(@Param("nos")List<String> nos); int deleteHandledMsg(@Param("nos")List<String> nos);
List<String> getOrderNos(); List<String> getOrderNos();
int insertMsg(@Param("vo") EkpInsertMsgVo vo);
} }
...@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.yifu.cloud.plus.v1.msg.entity.MsgInfo; import com.yifu.cloud.plus.v1.msg.entity.MsgInfo;
import com.yifu.cloud.plus.v1.msg.vo.EkpAlertVo; import com.yifu.cloud.plus.v1.msg.vo.EkpAlertVo;
import com.yifu.cloud.plus.v1.msg.vo.EkpInsertMsgVo;
import com.yifu.cloud.plus.v1.yifu.common.core.util.R; import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
import java.util.List; import java.util.List;
...@@ -49,4 +50,6 @@ public interface MsgInfoService extends IService<MsgInfo> { ...@@ -49,4 +50,6 @@ public interface MsgInfoService extends IService<MsgInfo> {
void cancelHandledMsg(); void cancelHandledMsg();
R sendZbMessage(EkpInsertMsgVo vo);
} }
...@@ -26,6 +26,7 @@ import com.yifu.cloud.plus.v1.msg.entity.MsgInfo; ...@@ -26,6 +26,7 @@ import com.yifu.cloud.plus.v1.msg.entity.MsgInfo;
import com.yifu.cloud.plus.v1.msg.mapper.MsgInfoMapper; import com.yifu.cloud.plus.v1.msg.mapper.MsgInfoMapper;
import com.yifu.cloud.plus.v1.msg.service.MsgInfoService; import com.yifu.cloud.plus.v1.msg.service.MsgInfoService;
import com.yifu.cloud.plus.v1.msg.vo.EkpAlertVo; import com.yifu.cloud.plus.v1.msg.vo.EkpAlertVo;
import com.yifu.cloud.plus.v1.msg.vo.EkpInsertMsgVo;
import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants; import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
import com.yifu.cloud.plus.v1.yifu.common.core.util.Common; import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
import com.yifu.cloud.plus.v1.yifu.common.core.util.R; import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
...@@ -215,4 +216,15 @@ public class MsgInfoServiceImpl extends ServiceImpl<MsgInfoMapper, MsgInfo> impl ...@@ -215,4 +216,15 @@ public class MsgInfoServiceImpl extends ServiceImpl<MsgInfoMapper, MsgInfo> impl
} }
} }
@Override
public R sendZbMessage(EkpInsertMsgVo vo) {
int a = baseMapper.insertMsg(vo);
if (a != -1) {
return R.ok();
} else {
return R.failed("插入失败");
}
}
} }
...@@ -173,4 +173,9 @@ ...@@ -173,4 +173,9 @@
e.fd_fact_node_id = 'N5' e.fd_fact_node_id = 'N5'
AND b1.fd_id IS NOT NULL AND b1.fd_id IS NOT NULL
</select> </select>
<insert id="insertMsg">
insert into msg_info (ID,URL,ORDER_ID,ALERT_USER,DOMAIN_NAME,CREATE_TIME,ALERT_TYPE,ORDER_NO)
value (REPLACE(UUID(),"-",""),#{vo.urlInfo},#{vo.orderId},#{vo.userName},#{vo.domainName},now(),'0',#{vo.dingdanNo})
</insert>
</mapper> </mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment