|
|
|
@ -26,6 +26,7 @@ import java.time.LocalDateTime; |
|
|
|
import java.time.Month; |
|
|
|
import java.time.format.DateTimeFormatter; |
|
|
|
import java.util.*; |
|
|
|
import java.util.Date; |
|
|
|
|
|
|
|
|
|
|
|
@Service |
|
|
|
@ -64,7 +65,7 @@ public class MysqlServiceImpl implements MysqlService { |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Transactional(transactionManager = "mysqlTransactionManager") // 👈 保证插入和用户更新在一个事务 |
|
|
|
@Transactional(transactionManager = "mysqlTransactionManager",rollbackFor = Exception.class) // 👈 保证插入和用户更新在一个事务 |
|
|
|
public void getSqlserverData() throws Exception { |
|
|
|
logger.info("开始从 SQL Server 同步数据到 MySQL"); |
|
|
|
|
|
|
|
@ -357,7 +358,7 @@ public class MysqlServiceImpl implements MysqlService { |
|
|
|
|
|
|
|
if (validZeroTypes.contains(data.gtype)) { |
|
|
|
stmt.setInt(13, 0); |
|
|
|
stmt.setNull(20, 0); |
|
|
|
stmt.setInt(20, 0); |
|
|
|
stmt.setString(1, "ERPCZ_" + data.orderNumber); |
|
|
|
} else if (validOneTypes.contains(data.gtype)) { |
|
|
|
stmt.setInt(13, 1); |
|
|
|
@ -415,8 +416,8 @@ public class MysqlServiceImpl implements MysqlService { |
|
|
|
} else { |
|
|
|
stmt.setInt(17, 1); |
|
|
|
} |
|
|
|
|
|
|
|
stmt.setTimestamp(18, data.cz_time); |
|
|
|
Timestamp now = new Timestamp(System.currentTimeMillis()); |
|
|
|
stmt.setTimestamp(18, now); |
|
|
|
stmt.setTimestamp(19, data.cz_time); |
|
|
|
stmt.setString(21, data.uid); |
|
|
|
} |
|
|
|
|