Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

2021.01.21
2. 実行 php備忘録
ECシステム, Laravel, PHP, スクリプト備忘録, ネクストエンジン, ネットショップ, 在庫連動, 自作システム, 自動処理, 自動化

1. Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

前回までの関連記事はこちら『access_token取得』『在庫変更の段取りを考える』

今回は在庫更新のScriptを書きながら少々の解説をしたいと思います。
ただし、実際のScriptは色々仕込んだ事もあり『600行を超え』になってしまったので省略しながら書いていきます。

作成していて分かったNextEngineAPIの注意点

在庫更新関連で利用したAPIのみですが、幾つか注意すべきことがありました。

refresh_tokenに値を入れているとaccess_tokenは自動的に変更してくれるが、タイミングが読めない
CSVデータではスペースを「レコードの切り替わり」と判断される
商品マスタアップロードの成功が【更新の成功】ではない

項目1について

有効なaccess_tokenを持っていれば「token取得」から動かす必要はないのでSQLにtokenの格納庫を作成しました。で、有効期間内であれば保存しているtoken情報を使ってAPI接続しようと考えていたのですが問題が発生しました。

有効期間内のtokenであるはずなのにAPI接続で拒否られる

理由はrefresh_tokenが気を利かせてくれたことでした。
まだ有効期間内だったのですが、どうやらaccess_tokenを再発行してくれたようで、2つのtokenの内容と有効期限か変わっていました。何かのトリガーがあるのだと思いますがそこまでは解明できていません。

なので、APIアクセスの度にtokenと有効期限を返してくれるので【有効期限が変わっていたらSQLを変更】するように仕掛けました。

項目2について

社内システムにあってネクストエンジンに未登録の商品があるので、在庫調整の際に一緒に追加してしまおうと模索。そうしたところ「9項目の1行目に対してレコードが5項目しかない」と怒られました。

商品登録の必須項目『商品名』にスペースが入っているものが【次レコード送り】と認識さているようです。

項目3について

ネクストエンジンでは、APIアップロードと同時に適用が入りません。あくまでキューに入れるだけです。
なので『アップロード』と『値の適用』とは別物と考える必要があります。
『値の適用』でエラーが起こるとしても、アップロードでそのエラーを捉えることはできません。
エラーの原因を知りたい場合は【アップロードキュー検索API】を利用して欲しいとの事でした。

在庫数更新のScript

■全体的な流れ

有効な access_tokenがあるか確認
ある場合 => 6 / ない場合 => 2
refresh_tokenの有効性を確認
期限切れの場合 => 4 / 期限内の場合 => 3
refresh_tokenでaccess_tokenを再発行
成功の場合 => 6 / 失敗の場合 => 4
ログインしてuidなどを取得
成功の場合 => 5 / 失敗の場合 => エラー吐いて終了
uidからaccess_tokenを取得
成功の場合 => 6 / 失敗の場合 => エラー吐いて終了
access_tokenを使ってAPI接続
※ $selecterCodeに沿った各処理へ投げる

上記 1～5については『access_token取得』で書いたので省略します。

class NEAPI {

    public static function ConnectNE($selecterCode)
    {
        #token取得部（1～5）省略
        //////////////////////////////////////////////////
        // 動作の分岐 ※引数で動作を分けることでtoken発行までを共通化
        //////////////////////////////////////////////////
        Switch($selecterCode){
            case 1:
                #NE在庫数更新 ※ついでに出品中商品の登録
                self::StockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);
                break;
            case 99:
                #NEアップロードキュー検索 ※期間指定自動で昨日～本日
                self::QueSearch_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);
                break;
            default:
                break;
        }
    }
    
    public static function StockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)
    {
        #タイムアウトしない & パース時間を設定しない
        ini_set("max_execution_time",0);
        ini_set("max_input_time",0); 

        #ネクストエンジンの商品マスタからテンポラリテーブルを作成
        self::getItemData_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);
        #ネクストエンジンの在庫マスタからテンポラリテーブルに在庫数を登録
        self::getStockData_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);
        #出品中のシステム内商品情報の抽出
        $saleingItems = self::pickUpSaleItem_SystemData();
        If(!empty($saleingItems)){
            #システム内商品情報とテンポラリテーブルを比較して加減算
            self::checkStockSystemData_Temp($saleingItems);
            #テンポラリテーブルのマーカーで抽出ネクストエンジンアップロード
            self::ItemStockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);
        }
        return;
    }
    /////////////// NextEngin商品マスタ取得 //////////////////
    public static function getItem_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)
    {
        $Endpoint = 'https://api.next-engine.org/api_v1_master_goods/count';
        $header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");
        $params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1';

        #エンドポイントへアクセスして情報取得
        $response = self::postSSLAPI_Curl($Endpoint,$header,$params);
        #JSONの取り出し
        $pattern = '/\{.+?\}/';
        preg_match_all($pattern, $response, $match);
        $list = (array)json_decode($match[0][0]);

        #sitelogincodesにend_Dateを登録
        //$access_token
        self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);
        //$refresh_toke
        self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);
        
        If(!empty($list['count'])){
            $count = (ceil($list['count']/10000));
            
            #NE商品マスタを取得
            $Endpoint = 'https://api.next-engine.org/api_v1_master_goods/search';
            $header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");
            $fields = 'goods_id,goods_representation_id,goods_name,goods_supplier_id,goods_jan_code,goods_maker_model_number,goods_cost_price,goods_display_price,goods_selling_price';
            for($i=0;$i < $count; $i++){
                #forループで取り出し
                $list = $ItemData = array();
                $params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&offset='.$i.'&fields='.$fields;
                
                $response = self::postSSLAPI_Curl($Endpoint,$header,$params);
                $list = (array)json_decode($response);

                #sitelogincodesにend_Dateを登録
                //$access_token
                self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);
                //$refresh_toke
                self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);
        
                If(!empty($list['data'])){
                    foreach($list['data'] as $id){
                        #取得したデータを商品テンポラリテーブルに格納
                        $item = new Producttemporary;
                        $item->product_id = $id->goods_id;
                        If(!empty($id->goods_maker_model_number)){$item->makercode = $id->goods_maker_model_number;}else{$item->makercode = NULL;}
                        If(!empty($id->goods_jan_code)){$item->jan = $id->goods_jan_code;}else{$item->jan = NULL;}
                        $item->jan = $id->goods_jan_code;
                        $item->productname = $id->goods_name;
                        $item->stock = NULL;
                        $item->originalprice = $id->goods_display_price;
                        $item->assunedcost = $id->goods_cost_price;
                        $item->salesprice = $id->goods_selling_price;
                        $item->shipper_id = $id->goods_supplier_id;
                        $item->mathstocks = NULL;//更新用差分計算結果
                        $item->onoff = 0;//更新適用フラグ
                        $item->save();
                    }
                }
            }
        }else{
            #個数調査失敗※ログに残す
        }
        return;
    }
    /////////////// NextEngin在庫マスタ取得 //////////////////
    public static function getStock_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)
    {
        $Endpoint = 'https://api.next-engine.org/api_v1_master_stock/count';
        $header = array("cache-control: no-cache;charset=UTF-8");
        $params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1';

        #エンドポイントへアクセスして情報取得
        $response = self::postSSLAPI_Curl($Endpoint,$header,$params);

        #JSONの取り出し
        $pattern = '/\{.+?\}/';
        preg_match_all($pattern, $response, $match);
        $list = (array)json_decode($match[0][0]);

        #sitelogincodesにend_Dateを登録
        //$access_token
        self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);
        //$refresh_toke
        self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);
        
        If(!empty($list['count'])){
            $count = (ceil($list['count']/10000));
            
            #NE商品マスタを取得
            $Endpoint = 'https://api.next-engine.org/api_v1_master_stock/search';
            $header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");
            $fields = 'stock_goods_id,stock_quantity';
            for($i=0;$i < $count; $i++){
                #forループで取り出し
                $list = $ItemData = array();
                $params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&offset='.$i.'&fields='.$fields;
                $response = self::postSSLAPI_Curl($Endpoint,$header,$params);
                $list = (array)json_decode($response);

                #sitelogincodesにend_Dateを登録
                //$access_token
                self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);
                //$refresh_toke
                self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);
        
                If(!Empty($list['data'])){
                    foreach($list['data'] as $id){
                        #テンポラリに在庫数を登録
                        $item = Producttemporary::where('product_id',$id->stock_goods_id)->first();
                        $item->stock = $id->stock_quantity;
                        $item->save();
                    }
                }
            }
        }else{
            #個数調査失敗※ログに残す
        }
        return;
    }
    /////////////// 自社システム出品中抽出 //////////////////
    public static function pickUpSaleItem_SystemData()
    {
        $array = MySQLから出品中商品を抽出;
        return $array;
    }
    /////////////// レコード比較・差分計算 //////////////////
    public static function checkStockSystemData_Temp($saleingItems)
    {
        #出品中商品から抽出した値を使ってループ
        foreach($saleingItems as $saleslist){
            ////////////////////////////////////////
            // Saleitemsに格納されている価格情報を取り出す
            ////////////////////////////////////////
            #Select出品か否かを確認
            If(!empty(optional($saleslist->saleitem)->selectsalesmark)){
                #0はEmptyなのでここには選択肢商品のみが入る ※組み合わせ販売を振りから落せればOK
                If($saleslist->product_id == $saleslist->selectitem_id){
                    #選択肢IDとproduct_idが同じ => パターン販売
                    //価格情報確定
                    $salesprice = optional($saleslist->saleitem)->salesprice;
                    $assumedcost =optional($saleslist->saleitem)->assumedcost;
                    $originalprice = optional($saleslist->saleitem)->originalprice;
                    $shipper_id = optional($saleslist->saleitem->shipper)->pictfolder;
                }else{
                    #組み合わせ販売 か 設定ミス
                    //productconverterに複数のSaleitem_idが登録されていないかチェック
                    $subchecks = 選択肢販売のMySQL登録ルール
                            組合せ販売で発生するMySQL登録ルール
                            有効商品のルール->get();
                    If(!Empty($subchecks)){
                        #レコードが存在する
                        $salesprice = $assumedcost = $originalprice = $flag = 0;
                        foreach($subchecks as $subcheck){
                            #レコードの中にセレクトマーク0の値がないかチェック
                            $saleitemCheck = 商品情報のfind抽出;
                            If(($saleitemCheck->選択肢販売マーカー)&&($flag == 0)){
                                
                                #価格情報を固定
                                $salesprice = $saleitemCheck->販売価格;
                                $assumedcost = $saleitemCheck->仕入原価;
                                $originalprice = $saleitemCheck->定価;
                                $shipper_id = optional($saleitemCheck->仕入企業テーブル)->区分名;
                                $flag = 1;//ループ終了マーカー
                            }
                        }
                    }else{
                        #レコードがない
                        $salesprice = $assumedcost = $originalprice = 0;
                        $shipper_id = '9999';
                    }
                    //組合せのみで出品している商品の諸々価格は0で登録される ※ただし上書き時には既存価格が入っているときスキップする
                }
            }else{
                #NULLと0の境を作れないので0とみなして動作する
                If(!empty(optional($saleslist->saleitem)->salesprice)){
                    #売価が入っていれば情報はnonObjectエラー回避できる
                    $salesprice = optional($saleslist->saleitem)->salesprice;
                    $assumedcost =optional($saleslist->saleitem)->assumedcost;
                    $originalprice = optional($saleslist->saleitem)->originalprice;
                    $shipper_id = optional($saleslist->saleitem)->shipper_id;
                }else{
                    #売価 = 0は無視してよい情報と判断
                    $salesprice = $assumedcost = $originalprice = 0;
                    $shipper_id = 0;
                }
            }
            ////////////////////////////////////////
            // Product_idから在庫数取得
            ////////////////////////////////////////
            #productstocksをチェック、在庫数取得
            $p_stocks = MySQL倉庫別在庫管理テーブル
                    ->select('ＳＫＵコード',DB::raw('sum(在庫) as total'))
                    ->get();
            
            #加算在庫数取得
            $addstock = 0;//初期化
            $sts = 在庫タイプ::where(有効マーカ,1)->get();
            $additionals = array();
            foreach($sts as $st){
                $additionals[$st->id] = $st->加算在庫数;
            }
            #在庫加算数を確定
            If(!Empty($additionals[optional($saleslist->商品ＳＫＵテーブル)->在庫タイプ_id])){
                $addstock = $additionals[optional($saleslist->商品ＳＫＵテーブル)->在庫タイプ_id];
            }else{
                $addstock = 0;
            }
            
            #登録在庫数(最終)
            If(!empty($p_stocks)){
                #在庫数がある時、在庫数+加算在庫数を計上
                $stocks = ($p_stocks[0]->total) + $addstock;
            }else{
                #在庫数登録がない時、加算在庫数を計上
                $stocks = $addstock;
            }
            ////////////////////////////////////////
            // データベースに追加/上書き
            ////////////////////////////////////////
            #Producttemporaryから一致を探す
            $value = Producttemporary::where('product_id',$saleslist->product_id)->first();
            If(!empty($value)){
                #$valueが存在する時、在庫数を計算し格納
                If(($value->stock <> $stocks)or($value->originalprice <> $originalprice)or($value->assunedcost <> $assumedcost)or($value->salesprice <> $salesprice)){
                    If(($value->originalprice <> $originalprice)&&($originalprice <> 0)){$value->originalprice = (INT)$originalprice;}
                    If(($value->assunedcost <> $assumedcost)&&($assumedcost <> 0)){$value->assunedcost = (INT)$assumedcost;}
                    If(($value->salesprice <> $salesprice)&&($salesprice <> 0)){$value->salesprice = (INT)$salesprice;}
                    $value->shipper_id = $shipper_id;
                    $value->mathstocks = $stocks - ($value->stock);//更新用差分計算結果
                    $value->onoff = 1;
                    $value->save();
                }else{
                    #増減ない時、ゼロで更新 ※売価更新などでのエラー回避目的
                    $value->mathstocks = 0;//更新用差分計算結果
                    $value->onoff = 0;
                    $value->save();
                }
            }else{
                #テンポラリテーブルに存在しない時、新規追加
                $item = new Producttemporary;
                $item->product_id = $saleslist->product_id;
                $item->makercode = optional($saleslist->product)->makercode;
                $item->jan = optional($saleslist->product)->jan;
                $item->productname = optional($saleslist->product)->productname;
                $item->stock = NULL;
                $item->originalprice = $originalprice;
                $item->assunedcost = $assumedcost;
                $item->salesprice = $salesprice;
                $item->shipper_id = $shipper_id;
                $item->mathstocks = $stocks;//更新用差分計算結果
                $item->onoff = 1;
                $item->save();
            }
        }
    }
    
    /////////////// NextEngineアップロード //////////////////
    public static function ItemStockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)
    {
        ////////////////////////////////////////
        // 在庫数更新：商品マスタアップロード
        // ENDPOINT：https://api.next-engine.org/api_v1_master_goods/upload
        ////////////////////////////////////////
        #access_token取得
        $Endpoint = 'https://api.next-engine.org/api_v1_master_goods/upload/';
        
        ////////CSVデータ造作////////
        #$csv_header = ['syohin_code','sire_code','jan_code','kataban','syohin_name','genka_tnk','hyoji_tnk','baika_tnk','zaiko_su'];
        $csv_list = 'syohin_code,sire_code,jan_code,kataban,syohin_name,genka_tnk,hyoji_tnk,baika_tnk,zaiko_su';

        #商品名 = NULLのレコードはエラー回避のため除外
        $values = Producttemporary::where('onoff',1)
                ->whereNotNull('productname')
                ->get();
        
        $i = 0;
        foreach($values as $val){
            If(!empty($val->shipper_id)){
                #$shipper = optional($val->shipper)->pictfolder;
                $shipper = 9999;//テスト店舗用
            }else{
                $shipper = 9999;
            }
            $str = $val->product_id.','.$shipper.','.$val->jan.','.$val->makercode.',"'.$val->productname.'",'.$val->assunedcost.','.$val->originalprice.','.$val->salesprice.','.$val->mathstocks;
            $csv_list = $csv_list."\n".$str;
        }

        $header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");
        $params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&data_type=csv&data='.$csv_list;

        $response = self::postSSLAPI_Curl($Endpoint,$header,$params);

        $pattern = '/\{.+?\}/';
        preg_match_all($pattern, $response, $match);
        $list = (array)json_decode($match[0][0]);
        #sitelogincodesにend_Dateを登録
        //$access_token
        self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);
        //$refresh_toke
        self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);

        #テンポラリテーブルの全件削除
        #Producttemporary::truncate();
    }
        

    public static function saveTokenEndDate_NextEngine($code,$endDate,$name)
    {
        $necode_token = openssl_encrypt($code, 暗号Method, 暗号化Key);
        $value = MySQLからtokenコードで抽出;
        If(!empty($value)){
            If($value->有効期間 !== $endDate){
                $value->有効期間 = $endDate;
                $value->save();
            }
        }else{
            $value2 = MySQLからtoken名で抽出;
            If(!empty($value2)){
                $value2->token = $necode_token;
                $value2->有効期限 = $endDate;
                $value2->save();
            }
        }
        return;
    }
    
    /////////////// アップロードキューの結果取得 //////////////////
    public static function QueSearch_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)
    {
        #日付取得
        $now = Carbon::now();
        $yesterday = Carbon::yesterday();

        #NE商品マスタを取得
        $Endpoint = 'https://api.next-engine.org/api_v1_system_que/search';
        $header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");
        $fields = 'que_id,que_method_name,que_client_file_name,que_file_name,que_status_id,que_message,que_creation_date';
        $search = 'que_creation_date-gte='.$yesterday.&que_creation_date-lte='.$now;
        #que_creation_date　キュー作成日
        $params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&offset=1&fields='.$fields.'&'.$search;
            
        $response = self::postSSLAPI_Curl($Endpoint,$header,$params);
        $list = (array)json_decode($response);
        
        return;
    }

    /////////////// 基本的なAPI_POSTリクエスト/////////////// 
    public static function postSSLAPI_Curl($Endpoint,$header,$params)
    {
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $Endpoint);
        curl_setopt($curl, CURLOPT_POST, true);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, true);//SSL証明書
        curl_setopt($curl, CURLOPT_POSTFIELDS, $params);
        $response = curl_exec($curl);
        
        return $response;
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

340

341

342

343

344

345

346

347

348

349

350

351

352

353

354

355

356

357

358

359

360

361

362

363

364

365

366

367

368

369

370

371

372

373

374

375

376

377

378

379

380

381

382

383

384

385

386

387

388

389

390

391

392

393

394

395

396

397

398

399

400

401

402

403

404

405

406

class NEAPI {

public static function ConnectNE($selecterCode)

{

#token取得部（1～5）省略

//////////////////////////////////////////////////

// 動作の分岐 ※引数で動作を分けることでtoken発行までを共通化

//////////////////////////////////////////////////

Switch($selecterCode){

case 1:

#NE在庫数更新 ※ついでに出品中商品の登録

self::StockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);

break;

case 99:

#NEアップロードキュー検索 ※期間指定自動で昨日～本日

self::QueSearch_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);

break;

default:

break;

}

public static function StockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)

{

#タイムアウトしない & パース時間を設定しない

ini_set("max_execution_time",0);

ini_set("max_input_time",0);

#ネクストエンジンの商品マスタからテンポラリテーブルを作成

self::getItemData_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);

#ネクストエンジンの在庫マスタからテンポラリテーブルに在庫数を登録

self::getStockData_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);

#出品中のシステム内商品情報の抽出

$saleingItems = self::pickUpSaleItem_SystemData();

If(!empty($saleingItems)){

#システム内商品情報とテンポラリテーブルを比較して加減算

self::checkStockSystemData_Temp($saleingItems);

#テンポラリテーブルのマーカーで抽出ネクストエンジンアップロード

self::ItemStockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh);

}

return;

}

/////////////// NextEngin商品マスタ取得 //////////////////

public static function getItem_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)

{

$Endpoint = 'https://api.next-engine.org/api_v1_master_goods/count';

$header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");

$params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1';

#エンドポイントへアクセスして情報取得

$response = self::postSSLAPI_Curl($Endpoint,$header,$params);

#JSONの取り出し

$pattern = '/\{.+?\}/';

preg_match_all($pattern, $response, $match);

$list = (array)json_decode($match[0][0]);

#sitelogincodesにend_Dateを登録

//$access_token

self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);

//$refresh_toke

self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);

If(!empty($list['count'])){

$count = (ceil($list['count']/10000));

#NE商品マスタを取得

$Endpoint = 'https://api.next-engine.org/api_v1_master_goods/search';

$header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");

$fields = 'goods_id,goods_representation_id,goods_name,goods_supplier_id,goods_jan_code,goods_maker_model_number,goods_cost_price,goods_display_price,goods_selling_price';

for($i=0;$i < $count; $i++){

#forループで取り出し

$list = $ItemData = array();

$params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&offset='.$i.'&fields='.$fields;

$response = self::postSSLAPI_Curl($Endpoint,$header,$params);

$list = (array)json_decode($response);

#sitelogincodesにend_Dateを登録

//$access_token

self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);

//$refresh_toke

self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);

If(!empty($list['data'])){

foreach($list['data'] as $id){

#取得したデータを商品テンポラリテーブルに格納

$item = new Producttemporary;

$item->product_id = $id->goods_id;

If(!empty($id->goods_maker_model_number)){$item->makercode = $id->goods_maker_model_number;}else{$item->makercode = NULL;}

If(!empty($id->goods_jan_code)){$item->jan = $id->goods_jan_code;}else{$item->jan = NULL;}

$item->jan = $id->goods_jan_code;

$item->productname = $id->goods_name;

$item->stock = NULL;

$item->originalprice = $id->goods_display_price;

$item->assunedcost = $id->goods_cost_price;

$item->salesprice = $id->goods_selling_price;

$item->shipper_id = $id->goods_supplier_id;

$item->mathstocks = NULL;//更新用差分計算結果

$item->onoff = 0;//更新適用フラグ

$item->save();

}

}else{

#個数調査失敗※ログに残す

}

return;

}

/////////////// NextEngin在庫マスタ取得 //////////////////

public static function getStock_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)

{

$Endpoint = 'https://api.next-engine.org/api_v1_master_stock/count';

$header = array("cache-control: no-cache;charset=UTF-8");

$params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1';

#エンドポイントへアクセスして情報取得

$response = self::postSSLAPI_Curl($Endpoint,$header,$params);

#JSONの取り出し

$pattern = '/\{.+?\}/';

preg_match_all($pattern, $response, $match);

$list = (array)json_decode($match[0][0]);

#sitelogincodesにend_Dateを登録

//$access_token

self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);

//$refresh_toke

self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);

If(!empty($list['count'])){

$count = (ceil($list['count']/10000));

#NE商品マスタを取得

$Endpoint = 'https://api.next-engine.org/api_v1_master_stock/search';

$header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");

$fields = 'stock_goods_id,stock_quantity';

for($i=0;$i < $count; $i++){

#forループで取り出し

$list = $ItemData = array();

$params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&offset='.$i.'&fields='.$fields;

$response = self::postSSLAPI_Curl($Endpoint,$header,$params);

$list = (array)json_decode($response);

#sitelogincodesにend_Dateを登録

//$access_token

self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);

//$refresh_toke

self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);

If(!Empty($list['data'])){

foreach($list['data'] as $id){

#テンポラリに在庫数を登録

$item = Producttemporary::where('product_id',$id->stock_goods_id)->first();

$item->stock = $id->stock_quantity;

$item->save();

}

}else{

#個数調査失敗※ログに残す

}

return;

}

/////////////// 自社システム出品中抽出 //////////////////

public static function pickUpSaleItem_SystemData()

{

$array = MySQLから出品中商品を抽出;

return $array;

}

/////////////// レコード比較・差分計算 //////////////////

public static function checkStockSystemData_Temp($saleingItems)

{

#出品中商品から抽出した値を使ってループ

foreach($saleingItems as $saleslist){

////////////////////////////////////////

// Saleitemsに格納されている価格情報を取り出す

////////////////////////////////////////

#Select出品か否かを確認

If(!empty(optional($saleslist->saleitem)->selectsalesmark)){

#0はEmptyなのでここには選択肢商品のみが入る ※組み合わせ販売を振りから落せればOK

If($saleslist->product_id == $saleslist->selectitem_id){

#選択肢IDとproduct_idが同じ => パターン販売

//価格情報確定

$salesprice = optional($saleslist->saleitem)->salesprice;

$assumedcost =optional($saleslist->saleitem)->assumedcost;

$originalprice = optional($saleslist->saleitem)->originalprice;

$shipper_id = optional($saleslist->saleitem->shipper)->pictfolder;

}else{

#組み合わせ販売か設定ミス

//productconverterに複数のSaleitem_idが登録されていないかチェック

$subchecks = 選択肢販売のMySQL登録ルール

組合せ販売で発生するMySQL登録ルール

有効商品のルール->get();

If(!Empty($subchecks)){

#レコードが存在する

$salesprice = $assumedcost = $originalprice = $flag = 0;

foreach($subchecks as $subcheck){

#レコードの中にセレクトマーク0の値がないかチェック

$saleitemCheck = 商品情報のfind抽出;

If(($saleitemCheck->選択肢販売マーカー)&&($flag == 0)){

#価格情報を固定

$salesprice = $saleitemCheck->販売価格;

$assumedcost = $saleitemCheck->仕入原価;

$originalprice = $saleitemCheck->定価;

$shipper_id = optional($saleitemCheck->仕入企業テーブル)->区分名;

$flag = 1;//ループ終了マーカー

}

}else{

#レコードがない

$salesprice = $assumedcost = $originalprice = 0;

$shipper_id = '9999';

}

//組合せのみで出品している商品の諸々価格は0で登録される ※ただし上書き時には既存価格が入っているときスキップする

}

}else{

#NULLと0の境を作れないので0とみなして動作する

If(!empty(optional($saleslist->saleitem)->salesprice)){

#売価が入っていれば情報はnonObjectエラー回避できる

$salesprice = optional($saleslist->saleitem)->salesprice;

$assumedcost =optional($saleslist->saleitem)->assumedcost;

$originalprice = optional($saleslist->saleitem)->originalprice;

$shipper_id = optional($saleslist->saleitem)->shipper_id;

}else{

#売価 = 0は無視してよい情報と判断

$salesprice = $assumedcost = $originalprice = 0;

$shipper_id = 0;

}

////////////////////////////////////////

// Product_idから在庫数取得

////////////////////////////////////////

#productstocksをチェック、在庫数取得

$p_stocks = MySQL倉庫別在庫管理テーブル

->select('ＳＫＵコード',DB::raw('sum(在庫) as total'))

->get();

#加算在庫数取得

$addstock = 0;//初期化

$sts = 在庫タイプ::where(有効マーカ,1)->get();

$additionals = array();

foreach($sts as $st){

$additionals[$st->id] = $st->加算在庫数;

}

#在庫加算数を確定

If(!Empty($additionals[optional($saleslist->商品ＳＫＵテーブル)->在庫タイプ_id])){

$addstock = $additionals[optional($saleslist->商品ＳＫＵテーブル)->在庫タイプ_id];

}else{

$addstock = 0;

}

#登録在庫数(最終)

If(!empty($p_stocks)){

#在庫数がある時、在庫数+加算在庫数を計上

$stocks = ($p_stocks[0]->total) + $addstock;

}else{

#在庫数登録がない時、加算在庫数を計上

$stocks = $addstock;

}

////////////////////////////////////////

// データベースに追加/上書き

////////////////////////////////////////

#Producttemporaryから一致を探す

$value = Producttemporary::where('product_id',$saleslist->product_id)->first();

If(!empty($value)){

#$valueが存在する時、在庫数を計算し格納

If(($value->stock <> $stocks)or($value->originalprice <> $originalprice)or($value->assunedcost <> $assumedcost)or($value->salesprice <> $salesprice)){

If(($value->originalprice <> $originalprice)&&($originalprice <> 0)){$value->originalprice = (INT)$originalprice;}

If(($value->assunedcost <> $assumedcost)&&($assumedcost <> 0)){$value->assunedcost = (INT)$assumedcost;}

If(($value->salesprice <> $salesprice)&&($salesprice <> 0)){$value->salesprice = (INT)$salesprice;}

$value->shipper_id = $shipper_id;

$value->mathstocks = $stocks - ($value->stock);//更新用差分計算結果

$value->onoff = 1;

$value->save();

}else{

#増減ない時、ゼロで更新 ※売価更新などでのエラー回避目的

$value->mathstocks = 0;//更新用差分計算結果

$value->onoff = 0;

$value->save();

}

}else{

#テンポラリテーブルに存在しない時、新規追加

$item = new Producttemporary;

$item->product_id = $saleslist->product_id;

$item->makercode = optional($saleslist->product)->makercode;

$item->jan = optional($saleslist->product)->jan;

$item->productname = optional($saleslist->product)->productname;

$item->stock = NULL;

$item->originalprice = $originalprice;

$item->assunedcost = $assumedcost;

$item->salesprice = $salesprice;

$item->shipper_id = $shipper_id;

$item->mathstocks = $stocks;//更新用差分計算結果

$item->onoff = 1;

$item->save();

}

/////////////// NextEngineアップロード //////////////////

public static function ItemStockUplode_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)

{

////////////////////////////////////////

// 在庫数更新：商品マスタアップロード

// ENDPOINT：https://api.next-engine.org/api_v1_master_goods/upload

////////////////////////////////////////

#access_token取得

$Endpoint = 'https://api.next-engine.org/api_v1_master_goods/upload/';

////////CSVデータ造作////////

#$csv_header = ['syohin_code','sire_code','jan_code','kataban','syohin_name','genka_tnk','hyoji_tnk','baika_tnk','zaiko_su'];

$csv_list = 'syohin_code,sire_code,jan_code,kataban,syohin_name,genka_tnk,hyoji_tnk,baika_tnk,zaiko_su';

#商品名 = NULLのレコードはエラー回避のため除外

$values = Producttemporary::where('onoff',1)

->whereNotNull('productname')

->get();

$i = 0;

foreach($values as $val){

If(!empty($val->shipper_id)){

#$shipper = optional($val->shipper)->pictfolder;

$shipper = 9999;//テスト店舗用

}else{

$shipper = 9999;

}

$str = $val->product_id.','.$shipper.','.$val->jan.','.$val->makercode.',"'.$val->productname.'",'.$val->assunedcost.','.$val->originalprice.','.$val->salesprice.','.$val->mathstocks;

$csv_list = $csv_list."\n".$str;

}

$header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");

$params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&data_type=csv&data='.$csv_list;

$response = self::postSSLAPI_Curl($Endpoint,$header,$params);

$pattern = '/\{.+?\}/';

preg_match_all($pattern, $response, $match);

$list = (array)json_decode($match[0][0]);

#sitelogincodesにend_Dateを登録

//$access_token

self::saveTokenEndDate_NextEngine($list['access_token'],$list['access_token_end_date'],$encode_access);

//$refresh_toke

self::saveTokenEndDate_NextEngine($list['refresh_token'],$list['refresh_token_end_date'],$encode_refresh);

#テンポラリテーブルの全件削除

#Producttemporary::truncate();

}

public static function saveTokenEndDate_NextEngine($code,$endDate,$name)

{

$necode_token = openssl_encrypt($code, 暗号Method, 暗号化Key);

$value = MySQLからtokenコードで抽出;

If(!empty($value)){

If($value->有効期間 !== $endDate){

$value->有効期間 = $endDate;

$value->save();

}

}else{

$value2 = MySQLからtoken名で抽出;

If(!empty($value2)){

$value2->token = $necode_token;

$value2->有効期限 = $endDate;

$value2->save();

}

return;

}

/////////////// アップロードキューの結果取得 //////////////////

public static function QueSearch_NextEngine($access_token,$refresh_toke,$encode_access,$encode_refresh)

{

#日付取得

$now = Carbon::now();

$yesterday = Carbon::yesterday();

#NE商品マスタを取得

$Endpoint = 'https://api.next-engine.org/api_v1_system_que/search';

$header = array("Content-Type: application/x-www-form-urlencoded;charset=UTF-8");

$fields = 'que_id,que_method_name,que_client_file_name,que_file_name,que_status_id,que_message,que_creation_date';

$search = 'que_creation_date-gte='.$yesterday.&que_creation_date-lte='.$now;

#que_creation_date　キュー作成日

$params = 'access_token='.$access_token.'&refresh_token='.$refresh_toke.'&wait_flag=1&offset=1&fields='.$fields.'&'.$search;

$response = self::postSSLAPI_Curl($Endpoint,$header,$params);

$list = (array)json_decode($response);

return;

}

/////////////// 基本的なAPI_POSTリクエスト///////////////

public static function postSSLAPI_Curl($Endpoint,$header,$params)

{

$curl = curl_init();

curl_setopt($curl, CURLOPT_URL, $Endpoint);

curl_setopt($curl, CURLOPT_POST, true);

curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);

curl_setopt($curl, CURLOPT_HTTPHEADER, $header);

curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, true);//SSL証明書

curl_setopt($curl, CURLOPT_POSTFIELDS, $params);

$response = curl_exec($curl);

return $response;

}

お～長い！それも一般的に使うスクリプトと違うし。ほんと個人的なメモですね。
申し訳ない。

大まかな流れは『在庫変更の段取りを考える』でメモした通りです。

ちょっとしたスクリプト解説

393行目～405行目

まず最後のfunctionの部分、これはcurlのPOSTが多いので共通化しておいてあるものです。
このスクリプト内ではselfで呼び出してますが、実際には共通処理をまとめたLibrary に入れてあり『いろんな所』から呼び出して使ってます。

ネクストエンジンAPIではこの中の400行目【SSL証明書】が必須なので気をつけなきゃいけません。

9行目～20行目

selecterCodeという引数でその後のアクションを分けています。
理由はtoken取得までは同じ動きをするから。
スクリプトの例でいえば、引数＝1の場合は在庫更新を起動、引数=99の場合はキューの調査を動かします。

23行目～42行目

このfunctionは在庫更新の動作を5パートに分けて動かしています。

ネクストエンジンの商品マスタAPIを動かし、MySQLテンポラリテーブルに格納【30行目】
ネクストエンジンの在庫マスタAPIを動かし、登録したテンポラリテーブルのstockカラムに格納【32行目】
社内システムから有効な商品(ネクストエンジンに登録する商品)の在庫数をリストで抽出【34行目】
テンポラリテーブルのstockカラムと照らし合わせ更新用在庫数を登録、テンポラリにない場合は情報追加【37行目】
テンポラリテーブルを参照し、変更のあったレコードをアップロード【39行目】

それぞれのコードのJUMP先は下のようになっています。

44行目～108行目：30行目のコードの着地点。
110行目～163行目：32行目のコードの着地点。
165行目～299行目：34行目のコードの着地点。
302行目～348行目：37行目のコードの着地点。
351行目～369行目：39行目のコードの着地点。

371行目～390行目

selecterCode（引数）＝99で読み込みを行うアップロードキューの実行結果取得API。
期間指定を毎回行うのも面倒なので、昨日～本日の値を取ってくるように指示しています。

まとめ

これで在庫数更新自体は機能したのですが、問題も発生。

250レコード以上の登録ができない…。

ん～、なんでだろう。

ネクストエンジンさんにお聞きしたところ、一括登録の制限と言う事ではなさそう。
となると、作成したCSVレコードのどこかが悪いんだろうけど…現状原因不明です。

理由が判明したら別途記事書いて記録しておこう。

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

作成していて分かったNextEngineAPIの注意点

項目1について

項目2について

項目3について

在庫数更新のScript

ちょっとしたスクリプト解説

393行目～405行目

9行目～20行目

23行目～42行目

371行目～390行目

まとめ

関連

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その1】 2021.01.18

Laravel：NextEngineAPIで商品登録に失敗していた理由が判明 2021.01.21

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その2】

作成していて分かったNextEngineAPIの注意点

項目1について

項目2について

項目3について

在庫数更新のScript

ちょっとしたスクリプト解説

393行目～405行目

9行目～20行目

23行目～42行目

371行目～390行目

まとめ

共有:

関連

Laravel：NextEngineAPIで登録在庫の数を社内販売管理の個数に変更する【その1】 2021.01.18

Laravel：NextEngineAPIで商品登録に失敗していた理由が判明 2021.01.21