|
|
@@ -286,7 +286,7 @@ func (s *TmpzcgtSession) InsertCertSub() error {
|
|
|
s.DBE.Query("SET unique_checks=0;")
|
|
|
s.DBE.Query("SET autocommit=0;")
|
|
|
|
|
|
- for i:=0; i <= int(n); i++ {
|
|
|
+ for i:=0; i < int(n); i++ {
|
|
|
start := strconv.Itoa(i * 5000)
|
|
|
end := strconv.Itoa(5000)
|
|
|
sql := "INSERT INTO `OilSupplierCertSub` (" +
|
|
|
@@ -388,7 +388,7 @@ func (s *TmpzcgtSession) UpdateCertSubCaseWhen() error {
|
|
|
for _, cert := range certList {
|
|
|
when1 += " WHEN " + strconv.Itoa(cert.GfId) + " THEN " + strconv.Itoa(cert.SupplierId)
|
|
|
when2 += " WHEN " + strconv.Itoa(cert.GfId) + " THEN " + strconv.Itoa(cert.Id)
|
|
|
- when3 += " WHEN " + strconv.Itoa(cert.GfId) + " THEN " + cert.SupplierTypeCode
|
|
|
+ when3 += " WHEN " + strconv.Itoa(cert.GfId) + " THEN '" + cert.SupplierTypeCode + "'"
|
|
|
oldId = cert.GfId
|
|
|
}
|
|
|
sql1 := " UPDATE OilSupplierCertSub b SET b.SupplierId = CASE b.OldId " + when1 + " END, " +
|