Merge remote-tracking branch 'origin/develop'

yifu-msg/yifu-msg-api/src/main/java/com/yifu/cloud/plus/v1/msg/vo/EkpInsertMsgVo.java

+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;
+}

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/controller/MsgInfoController.java

@@ -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.service.MsgInfoService;
 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.log.annotation.SysLog;
 import com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner;
@@ -118,4 +119,17 @@ public class MsgInfoController {
 	public void 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);
+	}
 }

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/mapper/MsgInfoMapper.java

@@ -21,6 +21,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 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.Param;
 
@@ -51,4 +52,6 @@ public interface MsgInfoMapper extends BaseMapper<MsgInfo> {
 	List<MsgInfo> getMsgInfo(@Param("msgInfo") MsgInfo msgInfo);
 
 	int deleteHandledMsg();
+
+	int insertMsg(@Param("vo") EkpInsertMsgVo vo);
 }

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/service/MsgInfoService.java

@@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 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.EkpInsertMsgVo;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
 
 import java.util.List;
@@ -49,4 +50,6 @@ public interface MsgInfoService extends IService<MsgInfo> {
 
 	void cancelHandledMsg();
 
+	R sendZbMessage(EkpInsertMsgVo vo);
+
 }

yifu-msg/yifu-msg-biz/src/main/java/com/yifu/cloud/plus/v1/msg/service/impl/MsgInfoServiceImpl.java

@@ -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.service.MsgInfoService;
 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.util.Common;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
@@ -212,4 +213,15 @@ public class MsgInfoServiceImpl extends ServiceImpl<MsgInfoMapper, MsgInfo> impl
 		baseMapper.deleteHandledMsg();
 	}
 
+	@Override
+	public R sendZbMessage(EkpInsertMsgVo vo) {
+		int a = baseMapper.insertMsg(vo);
+		if (a != -1) {
+			return R.ok();
+		} else {
+			return R.failed("插入失败");
+		}
+	}
+
+
 }

yifu-msg/yifu-msg-biz/src/main/resources/mapper/MsgInfoMapper.xml

@@ -166,4 +166,9 @@
 			  AND b1.fd_id IS NOT NULL
 		)
 	</delete>
+
+	<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>