刷数据

server/src/main/java/com/pica/cloud/wechat/yunqueyilian/server/controller/refresh/RefreshServiceImpl.java

@@ -204,6 +204,7 @@ public class RefreshServiceImpl implements RefreshService {
 
                     logger.info("开始处理数据：第" + index + "条, patientId=" + realPatient.getPatientId() + "，id=" + realPatient.getId());
                 }
+                id = realPatient.getId();
             }
         }
     }

server/src/main/resources/mybatis/RefreshMapper.xml

@@ -255,7 +255,7 @@
      values (#{doctorId,jdbcType=INTEGER}, #{patientId,jdbcType=INTEGER},
       #{type,jdbcType=TINYINT}, #{validateCode,jdbcType=VARCHAR}, #{deleteFlag,jdbcType=TINYINT},
       #{createdId,jdbcType=INTEGER}, #{createdTime,jdbcType=TIMESTAMP}, #{modifiedId,jdbcType=INTEGER},
-      #{modifiedTime,jdbcType=TIMESTAMP})
+      #{modifiedTime,jdbcType=TIMESTAMP}
       )
   </insert>
 
@@ -268,9 +268,9 @@
              case when tor.user_type = 1 then tmp.validate_code else '' end as validateCode,
              tmp.delete_flag AS deleteFlag,
              tor.prescriber_id as createdId,
-             tmp.created_time as createdTime,
+             toa.created_time as createdTime,
              tor.prescriber_id as modifiedId,
-             tmp.created_time as modifiedTime
+             toa.created_time as modifiedTime
         from
             pica_trade.trade_mobile_phone_real tmp,
             pica_trade.trade_order_address toa,
@@ -291,9 +291,9 @@
              '' as validateCode,
              tmp.delete_flag AS deleteFlag,
              fpor.doctor_id as createdId,
-             tmp.created_time as createdTime,
+             fpor.created_time as createdTime,
              fpor.doctor_id as modifiedId,
-             tmp.created_time as modifiedTime
+             fpor.created_time as modifiedTime
         from
             pica_trade.trade_mobile_phone_real tmp,
             pica_follow_up.fu_plan_order_scales fpor
@@ -321,7 +321,7 @@
      values (#{doctorId,jdbcType=INTEGER}, #{patientId,jdbcType=INTEGER},
       #{type,jdbcType=TINYINT}, #{validateCode,jdbcType=VARCHAR}, #{deleteFlag,jdbcType=TINYINT},
       #{createdId,jdbcType=INTEGER}, #{createdTime,jdbcType=TIMESTAMP}, #{modifiedId,jdbcType=INTEGER},
-      #{modifiedTime,jdbcType=TIMESTAMP})
+      #{modifiedTime,jdbcType=TIMESTAMP}
       )
   </insert>