|
|
@@ -118,7 +118,7 @@ sql
|
|
|
$this->batchService->insert($insert);
|
|
|
LogService::log(__METHOD__,"SUCCESS-同步插入波次成功",json_encode($insert));
|
|
|
}
|
|
|
- ValueStore::query()->where("name","wave_last_sync_date")->update(["value"=>$waves[count($waves)-1]->editime]);
|
|
|
+ ValueStore::query()->where("name","wave_last_sync_date")->update(["value"=>$waves[count($waves)-1]->edittime]);
|
|
|
}
|
|
|
|
|
|
public function disposeDetail($date = null)
|
|
|
@@ -131,7 +131,7 @@ sql
|
|
|
$count = DB::connection("oracle")->selectOne(DB::raw("SELECT count(*) count FROM DOC_WAVE_DETAILS WHERE EDITTIME >= TO_DATE(?,'yyyy-mm-dd hh24:mi:ss')"),[$date]);
|
|
|
if ($count->count > 1000){
|
|
|
$sql = <<<sql
|
|
|
- SELECT * FROM (SELECT ORDERNO,WAVENO,SEQNO,EDITTIME, ROWNUM AS rowno FROM (
|
|
|
+ SELECT * FROM (SELECT ORDERNO,WAVENO,SEQNO,EDITTIME, ROWNUM AS rowno FROM (
|
|
|
SELECT * FROM DOC_WAVE_DETAILS WHERE EDITTIME >= TO_DATE(?,'yyyy-mm-dd hh24:mi:ss')
|
|
|
ORDER BY EDITTIME) WHERE ROWNUM <= 1000)wave WHERE wave.rowno >= 0
|
|
|
sql;
|