|
|
@@ -12,33 +12,24 @@ import java.util.ArrayList;
|
|
|
public class AutoCreateU8prodprice extends ServiceController {
|
|
|
@Override
|
|
|
public void serviceRun() throws Exception {
|
|
|
- DBConnect u8dbConnect = new DBConnect("U8");
|
|
|
- ArrayList<String> sa_u8prodpriceids =new ArrayList<>();
|
|
|
+ ArrayList<String> sa_u8prodpriceids = new ArrayList<>();
|
|
|
SQLFactory u8cprksqlFactory = new SQLFactory(this, "u8产品入库");
|
|
|
Rows cprkrows = dbConnect.runSqlQuery(u8cprksqlFactory.getSQL());
|
|
|
ArrayList<String> sqlList = new ArrayList<>();
|
|
|
- if(cprkrows.isEmpty()){
|
|
|
- for(Row row :cprkrows){
|
|
|
- System.err.println(row.getString("sqlstr"));
|
|
|
- sqlList.add(row.getString("sqlstr"));
|
|
|
- }
|
|
|
+ for (Row row : cprkrows) {
|
|
|
+ sqlList.add(row.getString("sqlstr"));
|
|
|
}
|
|
|
SQLFactory u8wwrksqlFactory = new SQLFactory(this, "u8委外入库");
|
|
|
Rows wwrkrows = dbConnect.runSqlQuery(u8wwrksqlFactory.getSQL());
|
|
|
- if(wwrkrows.isEmpty()){
|
|
|
- for(Row row :wwrkrows){
|
|
|
- sqlList.add(row.getString("sqlstr"));
|
|
|
- }
|
|
|
+ for (Row row : wwrkrows) {
|
|
|
+ sqlList.add(row.getString("sqlstr"));
|
|
|
}
|
|
|
-
|
|
|
- u8dbConnect.runSqlUpdate(sqlList);
|
|
|
-
|
|
|
+ new DBConnect("U8").runSqlUpdate(sqlList);
|
|
|
sa_u8prodpriceids.addAll(cprkrows.toArrayList("sa_u8prodpriceid"));
|
|
|
sa_u8prodpriceids.addAll(wwrkrows.toArrayList("sa_u8prodpriceid"));
|
|
|
UpdateSQL updateSQL = SQLFactory.createUpdateSQL(dbConnect, "sa_u8prodprice");
|
|
|
updateSQL.setDateValue("uploaddate");
|
|
|
updateSQL.setWhere("sa_u8prodpriceid", sa_u8prodpriceids);
|
|
|
dbConnect.runSqlUpdate(updateSQL.getSQL());
|
|
|
-
|
|
|
}
|
|
|
}
|