记得上下班打卡 | git大法好,push需谨慎

Commit 4536cf36 authored by zhengfuxin's avatar zhengfuxin

修改bug

parent 9924a7fe
......@@ -37,7 +37,7 @@ public class ConsumerSmileUserRedisStreamConfig {
* @param t
* @return
*/
private Subscription receiveSqlAnswer(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
private Subscription receiveSqlUser(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
return listenerContainer.receiveAutoAck(
Consumer.from(MQConst.SmileQueue.SMILE_USER.getGroup(), MQConst.SmileQueue.SMILE_USER.name() + t),
StreamOffset.create(MQConst.SmileQueue.SMILE_USER.getKey(), ReadOffset.lastConsumed()), consumerSmileUserReceiver
......@@ -49,25 +49,25 @@ public class ConsumerSmileUserRedisStreamConfig {
/* -------------------------------------------------------- | 缺票登记 */
@Bean
public Subscription subscriptionSqlAnswer(RedisConnectionFactory factory) {
public Subscription subscriptionSqlUser(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlAnswer(listenerContainer, 1);
var subscription = receiveSqlUser(listenerContainer, 1);
listenerContainer.start();
return subscription;
}
@Bean
public Subscription subscriptionSqlAnswer2(RedisConnectionFactory factory) {
public Subscription subscriptionSqlUser2(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlAnswer(listenerContainer, 2);
var subscription = receiveSqlUser(listenerContainer, 2);
listenerContainer.start();
return subscription;
}
@Bean
public Subscription subscriptionSqlAnswer3(RedisConnectionFactory factory) {
public Subscription subscriptionSqlUser3(RedisConnectionFactory factory) {
var listenerContainer = this.buildStreamMessageListenerContainer(factory);
var subscription = receiveSqlAnswer(listenerContainer, 3);
var subscription = receiveSqlUser(listenerContainer, 3);
listenerContainer.start();
return subscription;
}
......
#---- 服务支持信息
goblin_service_support.insert_byreplace=REPLACE INTO goblin_service_support (ssid,name,`desc`,url,del_flg,created_by,created_at)VALUES(?,?,?,?,'0','-',sysdate())
smile_service.insert_user= insert into smile_user(img,`name`,`uid`,birthday,sex,phone,province_key,province,city_key,city,area_key,area,address,wechat,`type`,org_id,id_card,school_name,school_major,`identity`,tag,agent,auth_tag,error_reason,introduce,specialty_1,specialty_2,specialty_3,`state`,del_tag,created_date,updated_date) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
smile_service.update_user= update smile_user set img =?,`name`=?,`uid`=?,birthday=?,sex =?,phone=?,province_key=?,province=?,city_key =?,city=?,area_key=?,area =?,address =?,wechat =?,`type`=?,org_id =?,id_card=?,school_name =?,school_major =?,`identity`=?,tag =?,agent =?,auth_tag =?,error_reason =?,introduce =?,specialty_1 =?,specialty_2 =?,specialty_3 =?,`state`=?,updated_date=?
\ No newline at end of file
smile_service.insert_user= insert into smile_user(img,`name`,`uid`,birthday,sex,phone,province_key,province,city_key,city,area_key,area,address,wechat,`type`,org_id,id_card,school_name,school_major,`identity`,tag,agent,auth_tag,error_reason,introduce,specialty1,specialty2,specialty3,`state`,del_tag,created_date,updated_date) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
smile_service.update_user= update smile_user set img =?,`name`=?,`uid`=?,birthday=?,sex =?,phone=?,province_key=?,province=?,city_key =?,city=?,area_key=?,area =?,address =?,wechat =?,`type`=?,org_id =?,id_card=?,school_name =?,school_major =?,`identity`=?,tag =?,agent =?,auth_tag =?,error_reason =?,introduce =?,specialty1 =?,specialty2 =?,specialty3 =?,`state`=?,updated_date=?
\ No newline at end of file
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