百度外呼任务回调接口

pom.xml

@@ -24,7 +24,7 @@
 		<alicloud.version>2.1.1.RELEASE</alicloud.version>
 		<poi.version>3.9</poi.version>
 		<log4j2.version>2.17.2</log4j2.version>
-		<project.name>exam-admin</project.name>
+		<project.name>aiobcallback</project.name>
 		<wechatpay-apiv3.version>0.4.4</wechatpay-apiv3.version>
 	</properties>
 

src/main/java/org/example/controller/AIOBCallbackController.java

@@ -8,6 +8,8 @@ import javax.servlet.http.HttpServletRequest;
 import org.example.core.api.ApiRest;
 import org.example.core.api.controller.BaseController;
 import org.example.dto.TaskCallbackDto;
+import org.example.dto.TaskCallbackUpdateDto;
+import org.example.entity.AIOBCallbackEntity;
 import org.example.service.IAIOBCallbackService;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -40,4 +42,16 @@ public class AIOBCallbackController extends BaseController {
 		System.out.println("1111111111111111111111");
 		return super.success();
 	}
+
+	@ApiOperation("查询列表")
+	@PostMapping("/getList")
+	public ApiRest getList(@RequestBody AIOBCallbackEntity aiobCallbackEntity) {
+		return super.success(aiobCallbackService.getList(aiobCallbackEntity));
+	}
+
+	@ApiOperation("修改已读状态")
+	@PostMapping("/updateReadState")
+	public ApiRest updateReadState(@RequestBody TaskCallbackUpdateDto taskCallbackUpdateDto) {
+		return super.success(aiobCallbackService.updateReadState(taskCallbackUpdateDto));
+	}
 }

src/main/java/org/example/dto/TaskCallbackUpdateDto.java

@@ -0,0 +1,22 @@
+package org.example.dto;
+
+import lombok.Data;
+
+/**
+ * @description: 修改已读状态传输对象
+ * @author: haown
+ * @create: 2026-01-12 16:25
+ **/
+@Data
+public class TaskCallbackUpdateDto {
+
+	/**
+	 * 主键
+	 */
+	private Integer id;
+	/**
+	 * 已读状态，0：未读，1：已读
+	 */
+	private Integer readState;
+
+}

src/main/java/org/example/mapper/AIOBCallbackMapper.java

@@ -1,8 +1,13 @@
 package org.example.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import java.util.List;
+import org.example.dto.TaskCallbackUpdateDto;
 import org.example.entity.AIOBCallbackEntity;
 
 public interface AIOBCallbackMapper extends BaseMapper<AIOBCallbackEntity> {
 
+	List<AIOBCallbackEntity> getList(AIOBCallbackEntity aiobCallbackEntity);
+
+	Integer updateReadState(TaskCallbackUpdateDto taskCallbackUpdateDto);
 }

src/main/java/org/example/service/IAIOBCallbackService.java

@@ -2,7 +2,9 @@ package org.example.service;
 
 import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.extension.service.IService;
+import java.util.List;
 import org.example.dto.TaskCallbackDataDto;
+import org.example.dto.TaskCallbackUpdateDto;
 import org.example.entity.AIOBCallbackEntity;
 
 /**
@@ -13,4 +15,8 @@ import org.example.entity.AIOBCallbackEntity;
 public interface IAIOBCallbackService extends IService<AIOBCallbackEntity> {
 
 	JSONObject taskCallBack(Integer callbackType, TaskCallbackDataDto data);
+
+	List<AIOBCallbackEntity> getList(AIOBCallbackEntity aiobCallbackEntity);
+
+	Integer updateReadState(TaskCallbackUpdateDto taskCallbackUpdateDto);
 }

src/main/java/org/example/service/impl/AIOBCallbackServiceImpl.java

@@ -4,8 +4,10 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import java.util.Date;
+import java.util.List;
 import javax.annotation.Resource;
 import org.example.dto.TaskCallbackDataDto;
+import org.example.dto.TaskCallbackUpdateDto;
 import org.example.entity.AIOBCallbackEntity;
 import org.example.mapper.AIOBCallbackMapper;
 import org.example.service.IAIOBCallbackService;
@@ -36,4 +38,19 @@ public class AIOBCallbackServiceImpl extends ServiceImpl<AIOBCallbackMapper, AIO
 		}
 		return retObj;
 	}
+
+	/**
+	 * @description 查询未转换的回调数据列表
+	 * @return null
+	 * @Author haown
+	 * @Date 2026-1-12 15:52
+	*/
+	@Override
+	public List<AIOBCallbackEntity> getList(AIOBCallbackEntity aiobCallbackEntity) {
+		return aiobCallbackMapper.getList(aiobCallbackEntity);
+	}
+
+	@Override public Integer updateReadState(TaskCallbackUpdateDto taskCallbackUpdateDto) {
+		return aiobCallbackMapper.updateReadState(taskCallbackUpdateDto);
+	}
 }

src/main/resources/application.yml

@@ -22,7 +22,7 @@ spring:
       # 支持类型转换
       allow-coercion-of-scalars: true
 server:
-  port: 8101
+  port: 8105
   servlet:
       # 应用的访问路径
       context-path: /

src/main/resources/mapper/AIOBCallbackMapper.xml

@@ -17,4 +17,17 @@
 		id, callback_type, callback_data, read_state, create_date, update_date
     </sql>
 
+	<select id="getList" resultType="org.example.entity.AIOBCallbackEntity">
+		select * from aiob_callback_data
+		<where>
+			<if test="readState != null">
+				and read_state = #{readState}
+			</if>
+		</where>
+	</select>
+
+	<update id="updateReadState">
+		update aiob_callback_data set read_state = #{readState}, update_date = sysdate()
+		where id = #{id}
+	</update>
 </mapper>

target/classes/application-dev.yml

@@ -4,9 +4,9 @@ spring:
   datasource:
     type: com.alibaba.druid.pool.DruidDataSource
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://8.131.93.145:54081/aiob_callback?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
+    url: jdbc:mysql://127.0.0.1:3306/aiob_callback?useSSL=false&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowPublicKeyRetrieval=true
     username: root
-    password: 1qaz!@#$
+    password: Xyl_1024!@#$
     # druid相关配置
     druid:
       max-active: 5000

target/classes/application-local.yml

@@ -1,7 +1,7 @@
 # 独立配置文件，可以拿到jar外面跑
 spring:
   application:
-    name: yf-exam-lite
+    name: aiobcallback
   profiles:
     active: dev
   main:

target/classes/application.yml

@@ -1,6 +1,6 @@
 spring:
   application:
-    name: aiob-callback
+    name: aiobcallback
   profiles:
       active: dev
   main:
@@ -22,7 +22,7 @@ spring:
       # 支持类型转换
       allow-coercion-of-scalars: true
 server:
-  port: 8101
+  port: 8105
   servlet:
       # 应用的访问路径
       context-path: /