1.修改数据同步调用方法

cjy-project/src/main/java/com/cjy/happytoenjoy/task/GetHappyToEnjoyTask.java

@@ -122,7 +122,7 @@ public class GetHappyToEnjoyTask {
 					if (saveList.size() < 1000) {
 						saveList.add(appointmentCenterData);
 					} else {
-						iAppointmentCenterDataService.synchronousData(saveList);
+						iAppointmentCenterDataService.synchronousDataLxj(saveList);
 						saveList.clear();
 						saveList.add(appointmentCenterData);
 					}
@@ -131,7 +131,7 @@ public class GetHappyToEnjoyTask {
 			}
 
 			if (!saveList.isEmpty()) {
-				iAppointmentCenterDataService.synchronousData(saveList);
+				iAppointmentCenterDataService.synchronousDataLxj(saveList);
 			}
 		});
 

cjy-project/src/main/java/com/cjy/reservationdata/mapper/AppointmentCenterDataMapper.java

@@ -67,6 +67,7 @@ public interface AppointmentCenterDataMapper
      * @return
      */
     int synchronousData(@Param("list") List<AppointmentCenterData> list);
+    int synchronousDataLxj(@Param("list") List<AppointmentCenterData> list);
 
     /**
      * 核销预约数据

cjy-project/src/main/java/com/cjy/reservationdata/service/IAppointmentCenterDataService.java

@@ -66,6 +66,7 @@ public interface IAppointmentCenterDataService
      * @return
      */
     int synchronousData(List<AppointmentCenterData> list);
+    int synchronousDataLxj(List<AppointmentCenterData> list);
 
     /**
      * 核销预约数据

cjy-project/src/main/java/com/cjy/reservationdata/service/impl/AppointmentCenterDataServiceImpl.java

@@ -161,6 +161,10 @@ public class AppointmentCenterDataServiceImpl implements IAppointmentCenterDataS
 	public int synchronousData(List<AppointmentCenterData> list) {
 		return appointmentCenterDataMapper.synchronousData(list);
 	}
+	@Override
+	public int synchronousDataLxj(List<AppointmentCenterData> list) {
+		return appointmentCenterDataMapper.synchronousDataLxj(list);
+	}
 
 	/**
 	 * 核销预约数据

cjy-project/src/main/resources/mapper/reservationdata/AppointmentCenterDataMapper.xml

@@ -114,6 +114,23 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
          </trim>
     </insert>
     <insert id="synchronousData">
+        INSERT INTO  appointment_center_data ( appointment_number, scenic_name,
+                                                                 appointment_date, appointment_slot,
+                                                                 appointment_people_name, appointment_people_phone,
+                                                                 certificate_type, documents_number,
+                                                                 verification_code, state, write_off_time,
+                                                                 data_sources,
+                                                                 organ_code,appointment_people_id,external_id,source_data_id,source_type)
+        VALUES
+        <foreach item="item" collection="list" separator=",">
+         (#{item.appointmentNumber}, #{item.scenicName}, #{item.appointmentDate}, #{item.appointmentSlot},
+            #{item.appointmentPeopleName}, #{item.appointmentPeoplePhone}, #{item.certificateType}, #{item.documentsNumber}, #{item.verificationCode}, #{item.state}, #{item.writeOffTime}, #{item.dataSources},
+            #{item.organCode},#{item.appointmentPeopleId},#{item.externalId},#{item.sourceDataId},'1')
+        </foreach>
+
+    </insert>
+
+    <insert id="synchronousDataLxj">
         INSERT INTO  appointment_center_data ( appointment_number, scenic_name,
                                                                  appointment_date, appointment_slot,
                                                                  appointment_people_name, appointment_people_phone,