|
|
@@ -2,6 +2,7 @@
|
|
|
|
|
|
namespace App\Jobs;
|
|
|
|
|
|
+use App\OracleDOCASNDetail;
|
|
|
use Illuminate\Bus\Queueable;
|
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
|
@@ -25,14 +26,15 @@ class RejectedPushJob implements ShouldQueue
|
|
|
* ['sku' => '75603675975072','taskNum' => 'JI20220316211', 'asnNo' => 'asn002', 'type' => '推单'],
|
|
|
* ]
|
|
|
*/
|
|
|
- private $pushData;
|
|
|
+ private $asnHerders;
|
|
|
|
|
|
/**
|
|
|
- * @param array $pushData
|
|
|
+ * RejectedPushJob constructor.
|
|
|
+ * @param $asnHerders
|
|
|
*/
|
|
|
- public function __construct(array $pushData)
|
|
|
+ public function __construct($asnHerders)
|
|
|
{
|
|
|
- $this->pushData = $pushData;
|
|
|
+ $this->asnHerders = $asnHerders;
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -43,8 +45,31 @@ class RejectedPushJob implements ShouldQueue
|
|
|
*/
|
|
|
public function handle()
|
|
|
{
|
|
|
+ $result = array();
|
|
|
+ $array = array();
|
|
|
+ if (count($this->asnHerders) > 0) {
|
|
|
+ foreach ($this->asnHerders as $asnHerder) {
|
|
|
+ if ($asnHerder->asntype == 'THRK' && $asnHerder->notes) {
|
|
|
+ preg_match('/^[A-Z]{2}[0-9]{8}\d{0,8}/', $asnHerder->notes, $result);
|
|
|
+ if (count($result) < 1) continue;
|
|
|
+ $details = OracleDOCASNDetail::query()->select('sku', 'linestatus')->where('asnno', $asnHerder->asnno)->get();
|
|
|
+ if (count($details) < 1) continue;
|
|
|
+ foreach ($details as $detail) {
|
|
|
+ $array[][] = [
|
|
|
+ 'sku' => $detail->sku,
|
|
|
+ 'taskNum' => $result[0],
|
|
|
+ 'asnNo' => $asnHerder->asnno,
|
|
|
+ 'type' => $detail->linestatus == '99' ? '上架' : '推单'
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
$url = config('api.java.wms.rejectedPushTask.receivePush');
|
|
|
- $response = Http::post($url, $this->pushData);
|
|
|
- Log::info("推送信息!", ['res' => $response->body(), 'req' => $this->pushData]);
|
|
|
+ if (count($array) > 0) {
|
|
|
+ $response = Http::post($url, $array);
|
|
|
+ Log::info("推送信息!", ['res' => $response->body(), 'req' => $array]);
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
}
|