src/Controller/PlanControoler.php line 43

Open in your IDE?
  1. <?php
  2. /**
  3.  * 生産計画管理用コントローラー
  4.  * 
  5.  */
  6. namespace App\Controller;
  8. use Symfony\Component\Routing\Annotation\Route;
  9. use Symfony\Component\HttpFoundation\Response;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\HttpFoundation\JsonResponse;
  12. use App\Controller\BaseController;
  13. use App\Service\KintoneService;
  14. use App\Service\CommonService;
  15. use DateTime;
  17. class PlanControoler extends BaseController
  18. {
  20.     protected $kintoneService;
  21.     protected $commonService;
  23.     /** @var Psr\Log\LoggerInterface logger */
  24.     protected $logger;
  26.     public function __construct(
  27.         KintoneService $kintoneService,
  28.         CommonService $commonService,
  29.         \Psr\Log\LoggerInterface $logger
  30.     )
  31.     {
  32.         parent::__construct();
  33.         $this->kintoneService = $kintoneService;
  34.         $this->commonService = $commonService;
  35.         $this->logger = $logger;
  36.     }
  38.     /**
  39.      * @param Request $request
  40.      * 
  41.      * @Route("/plan", name="plan")
  42.      */    
  43.     public function index(Request $request): Response
  44.     {
  46.         return $this->getPlanData($request, "html");
  47.     }
  49.     /**
  50.      * @param Request $request
  51.      * @param string $response_type (html/json)
  52.      */    
  53.     private function getPlanData($request, $response_type) {
  55.         $data["date"] = $request->get('search_date', date("Y-m-d"));
  56.         $data["machine"] = $request->get('search_machine', "1号機");
  57.         $search["machine"] = $data["machine"];
  59.         $increment_qty = [];    // 仕掛りで作る予定の数
  60.         $decrement_qty = [];    // 受注して在庫から減る予定の数
  61.         $arrangement_item = []; //手配商品
  63.         $this->getRemainingData($increment_qty, $arrangement_item, $data);
  65.         $data["arrangement"] = $arrangement_item;
  67.         $start = $data["date"];
  68.         $end = date("Y-m-d", strtotime($start . '+11 day'));
  70.         //指定した出荷予定日以降+５日の受注データ取得
  71.         $result = $this->kintoneService->requestGets('order', sprintf('出荷予定日_0 >= "%s" and 出荷予定日_0 < "%s" limit 500', $data["date"], $end));
  72.         $records = $result["records"];
  74.         // 出荷する商品数をセット
  75.         foreach($records as $record) {
  76.             $sub_table = $record["受注商品テーブル"]["value"];
  77.             $delivery_date = $record["出荷予定日_0"]["value"];
  79.             //分類で生産管理の判別をする
  80.             //項目 "通常の受注", "①外部倉庫・無償サンプル発送", "②仕入れ販売・外部倉庫出庫", "③当社へ引き取り", "④発送のみ", "⑤無償サンプル引き取り"
  81.             $bunrui = $record['分類']["value"];
  82.             $target_bunrui = ['通常の受注', '①外部倉庫・無償サンプル発送', '③当社へ引き取り', '⑤無償サンプル引き取り'];
  83.             if(in_array($bunrui, $target_bunrui)) {
  84.                 foreach($sub_table as $row){
  85.                     $item = $row["value"];
  86.                     $item_code = $item["商品コード"]["value"];
  87.     
  88.                     $qty = $item["箱数"]["value"] ? $item["箱数"]["value"] : 0;
  89.                     if(isset($decrement_qty[$item_code])) $decrement_qty[$item_code]+= $qty;
  90.                     else                                  $decrement_qty[$item_code] = $qty;
  91.                 }
  92.             }
  93.         }
  95.         //在庫マスタからデータ取得
  96.         $offset = 0;
  97.         $limit = 100;
  98.         $data["item"] = [];
  99.         $data["unarrangement"] = [];
  101.         while(1) {
  102.             $query = sprintf(' 手作業 not in ("レ")  order by レコード番号 limit %d offset %d', $limit, $offset);
  103.             $result = $this->kintoneService->requestGets('stock', $query);
  105.             foreach($result["records"] as $item) {
  106.                 $line = $item["製造号機"]["value"];
  107.                 $film = $item["フィルムの種類"]["value"];
  108.                 $film_addr = $item["フイルム住所・棚番"]["value"];
  109.                 $item_name = $item["商品名"]["value"];
  110.                 $item_code = $item["商品コード"]["value"];
  111.                 $stock_limit = $item["最低在庫数"]["value"];
  112.                 $stock = $item["在庫数"]["value"];
  114.                 //商品マスタ
  115.                 $data["item"][$item_code] = [
  116.                     "code" => $item_code,
  117.                     "name" => $item_name,
  118.                     "film" => $film,
  119.                     "film_addr" => $film_addr,
  120.                     "line" => $line,
  121.                     "limit" => $stock_limit,
  122.                     "stock" => $stock
  123.                 ];
  125.                 //生産可能リストを作成
  126.                 //$qty = is_numeric($stock) ? $stock : 0;
  127.                 $qty = $stock;
  128.                 // +5日分の受注数を減算する
  129.                 if( isset($decrement_qty[$item_code]) && is_numeric($decrement_qty[$item_code]) ) $qty-= $decrement_qty[$item_code];
  131.                 // 仕掛りで作られるであろう数を加算する 仕掛り分は減らさない
  132.                 if( isset($increment_qty[$item_code]) && is_numeric($increment_qty[$item_code])  ) $qty+= $increment_qty[$item_code];
  134.                 // 「仕掛りがある」もしくは「在庫数が目安より少なくなった」場合は　生産可能リストとして配列に持たす
  135.                 if($stock_limit > $qty || isset($increment_qty[$item_code]) ){
  136.                     //未手配の商品を製造機毎に配列で持たす
  137.                     foreach($line as $tmp_line){
  138.                        if(!is_numeric($qty) || !is_numeric($stock_limit)) {
  139.                           echo sprintf("商品コード：[%s]　在庫もしくは最低在庫数が数値ではありません。<br>kintone在庫アプリを確認してください。<br>※kintoneの修正後、反映に時間がかかる場合があります。", $item_code);
  140.                           exit;
  141.                        }else{
  142.                             $data["unarrangement"][$tmp_line][$item_code] = [
  143.                                 "num" => $stock_limit > $qty ? $stock_limit - $qty : 0,
  144.                             ];
  145.                        }
  146.                     }
  147.                 }
  148.             }
  149.             $offset += $limit;
  150.             if($result["totalCount"] < $offset) {
  151.                 break;
  152.             }
  153.             if($offset >= 10000 ) {
  154.                 echo '無限ループの可能性があります';
  155.                 break;
  156.             }
  158.         }
  160.         if($response_type == "html") {
  161.             return $this->render('plan.html.twig', [
  162.                 "data" => $data,
  163.                 "json_items" => json_encode($data["item"]),
  164.                 "json_unarrangement" => json_encode($data["unarrangement"]),
  165.                 "json_arrangement" => json_encode($data["arrangement"]),
  166.                 'machine_list' => $this->getOriginalConfig("param", "machines"),
  167.                 "search" => $search,
  168.             ]);
  169.         }else{
  170.             $params = [
  171.                 "json_items" => $data["item"],
  172.                 "json_unarrangement" => $data["unarrangement"],
  173.                 "json_arrangement" => $data["arrangement"],
  174.             ];
  176.             return new JsonResponse($params);
  177.         }
  179.     }
  182.     /**
  183.      * データの追加・修正
  184.      * @Route("/plan/set_plan", name="set_plan")
  185.      */
  186.     public function setPlan(Request $request){
  187.         $search_date = $request->get('search_date');
  188.         $line = $request->get('line');
  189.         $set_item = $request->get('set_item');
  190.         $mode = $request->get('mode');
  192.         if($mode == "regist") $disp_mode = "追加";
  193.         elseif($mode == "edit") $disp_mode = "修正";
  194.         elseif($mode == "sort") $disp_mode = "並び替え";
  196.         $this->logger->log("debug", sprintf("update Plan date:%s line:%s items:%s:", $search_date, $line, json_encode($set_item) ));
  198.         //現状を取得
  199.         $query = sprintf('手配日 = "%s" and 製造号機 in ("%s")', $search_date, $line);
  200.         $result = $this->kintoneService->requestGets('production_management', $query);
  202.         $no = $this->commonService->convertNo($set_item["no"]);
  203.         $update_date = $this->commonService->getDateTimeUTC();
  204.         $tmp = [
  205.             "No" => $no,
  206.             "急ぎ" => $set_item["quickly"] == "1" ? ["急ぎ"] : [],
  207.             "ケース" => $set_item["num"],
  208.             "商品コード" => $set_item["item_code"],
  209.             "key" => $set_item["key"],
  210.             "最終更新日時" => $update_date
  211.         ];
  212.         $fh = fopen(__DIR__ . "/log.txt", "w");
  213.         fputs($fh, print_r($tmp, true));
  214.         fclose($fh);
  216.         $new_items = [];
  217.         if(!empty($result['records'])) {
  218.             $records = $result['records'];
  219.             foreach($records as $record){
  220.                 $kintone_id = $record['$id']['value'];
  221.                 $table = $record['手配状況']['value'];
  222.                 $exist_flg = false;
  223.                 foreach($table as $item) {
  224.                     if( $item['value']['key']['value'] == $set_item["key"] ) {
  225.                         $exist_flg = true;
  226.                         $complete_num = $item['value']['完了数']['value'];
  227.                         if($tmp["ケース"] <= $complete_num) {
  228.                             $tmp["完了"] = ["完了"];
  229.                         }else{
  230.                             $tmp["完了"] = [];
  231.                         }
  232.                         $new_items[] = [ "id" => $item["id"], "value" => $this->kintoneService->setAttribute($tmp) ];
  233.                     }else{
  234.                         $new_items[] = [ "id" => $item["id"] ];
  235.                     }
  236.                 }
  237.                 if(!$exist_flg) {
  238.                     $new_items[] = [ "value" => $this->kintoneService->setAttribute($tmp) ];
  239.                 }
  241.                 $log = $this->create_log($record['更新履歴']['value'], $disp_mode, $update_date);
  242.                 $management["手配状況"] = $new_items;
  243.                 $management["更新履歴"] = $log;
  244.                 $management["全て完了"] = [];
  245.                 $management_data = $this->kintoneService->setAttribute($management);
  246.                 $this->kintoneService->requestPut("production_management", $kintone_id, $management_data);
  247.             }
  248.         }else{
  249.             $log = $this->create_log([], $disp_mode, $update_date);
  250.             $new_items[] = [ "value" => $this->kintoneService->setAttribute($tmp) ];
  251.             $management["製造号機"] = $line;
  252.             $management["手配日"] = $search_date;
  253.             $management["手配状況"] = $new_items;
  254.             $management["更新履歴"] = $log;
  255.             $management["手配状況"] = $new_items;
  256.             $management["全て完了"] = [];
  258.             $management_data = $this->kintoneService->setAttribute($management);
  259.             $this->kintoneService->requestPost("production_management", $management_data);
  260.         }
  262.         //return $this->getPlanData($request, "json");
  263.         return new JsonResponse(["result" => true]);
  264.     }
  266.     /**
  267.      * データの取り消し
  268.      * @Route("/plan/del_plan", name="del_plan")
  269.      */
  270.     public function delPplan(Request $request){
  271.         $search_date = $request->get('search_date');
  272.         $line = $request->get('line');
  273.         $key = $request->get('key');
  275.         /*
  276.         テストデータ
  277.         $search_date = "2024-10-16";
  278.         $line = "4号機";
  279.         $key = "1929e7de919d9";
  280.         */
  281.         $this->logger->log("debug", sprintf("delete Plan date:%s line:%s key:%s:", $search_date, $line, $key));
  283.         //現状を取得
  284.         $query = sprintf('手配日 = "%s" and 製造号機 in ("%s")', $search_date, $line);
  285.         $result = $this->kintoneService->requestGets('production_management', $query);
  286.         $update_date = $this->commonService->getDateTimeUTC();
  287.         foreach($result['records'] as $record) {
  288.             $kintone_id = $record['$id']['value'];
  289.             $table = $record['手配状況']['value'];
  290.             $new_items = [];
  291.             $all_complete = true;
  292.             foreach($table as $item) {
  293.                 if( $item['value']['key']['value'] != $key) {
  294.                     $new_items[] = ["id" => $item["id"]];
  295.                     if(!in_array("完了", $item["value"]["完了"]["value"])) {
  296.                         $all_complete = false;
  297.                     }
  298.                 }else{
  299.                     $tmp = [];
  300.                     $tmp["完了"] = $item["value"]["完了"]["value"];
  301.                     $tmp["完了"][] = "取消し";
  302.                     $tmp["最終更新日"] = $update_date;
  303.                     $new_items[] = [ "id" => $item["id"], "value" => $this->kintoneService->setAttribute($tmp) ];
  304.                 }
  305.             }
  307.             $management["手配状況"] = $new_items;
  308.             $management["更新履歴"] = $this->create_log($record['更新履歴']['value'], '取消し', $update_date);
  309.             if($all_complete) {
  310.                 $management["全て完了"] = ["完了"];
  311.             }
  312.             
  313.             $management_data = $this->kintoneService->setAttribute($management);
  314.         }
  316.         $result = $this->kintoneService->requestPut("production_management", $kintone_id, $management_data);
  317.     }
  319.     /**
  320.      * データの並び替え
  321.      * @Route("/plan/sort_plan", name="sort_plan")
  322.      */
  323.     public function sortPlan(Request $request){
  324.         $search_date = $request->get('search_date');
  325.         $line = $request->get('line');
  326.         $items = $request->get('items');
  328.         //現状を取得
  329.         $query = sprintf('手配日 = "%s" and 製造号機 in ("%s")', $search_date, $line);
  330.         $result = $this->kintoneService->requestGets('production_management', $query);
  332.         $update_date = $this->commonService->getDateTimeUTC();
  333.         foreach($result['records'] as $record) {
  334.             $kintone_id = $record['$id']['value'];
  335.             $table = $record['手配状況']['value'];
  336.             $new_items = [];
  337.             foreach($items as $item){
  338.                 foreach($table as $row) {
  339.                     if($row["value"]["key"]["value"] == $item["key"]) {
  340.                         $row["value"]["最終更新日"]["value"] = $update_date;
  341.                         $new_items[] = $row;
  342.                         break;
  343.                     }
  344.                 }
  345.             }
  346.             $management["手配状況"] = $new_items;
  347.             $management["更新履歴"] = $this->create_log($record['更新履歴']['value'], '並び替え', $update_date);
  348.             $management_data = $this->kintoneService->setAttribute($management);
  349.             $result = $this->kintoneService->requestPut("production_management", $kintone_id, $management_data);
  350.         }
  351.     }
  353.     /**
  354.      * 生産計画
  355.      * @Route("/manufacturing", name="manufacturing")
  356.      */
  357.     public function manufacturing(Request $request){
  359.         $today = $request->get('today', date('Y-m-d'));
  360.         $line = $request->get('line');
  361.         //$query = sprintf('手配日 = "%s" and 製造号機 in ("%s")', $today, $line);
  362.         $query = sprintf('製造号機 in ("%s") and (手配日 = "%s" or (手配日 < "%s" and 全て完了 not in ("完了"))) order by 手配日 asc', $line, $today, $today);
  364.         $result = $this->kintoneService->requestGets('production_management', $query);
  366.         $item_codes = [];
  367.         foreach($result['records'] as $record) {
  368.             $table = $record['手配状況']['value'];
  369.             $arrangement_date = $record['手配日']['value'];
  370.             foreach($table as $row) {
  371.                 if(count($row["value"]["完了"]["value"])) continue;
  372.                 if(empty($row["value"]["商品コード"]["value"])) continue;
  373.                 $item_code = $row["value"]["商品コード"]["value"];
  374.                 if(!isset($item_codes[$arrangement_date])) $item_codes[$arrangement_date] = [];
  375.                 $item_codes[$arrangement_date][] = $item_code;
  377.                 $qty = (int)$row["value"]["ケース"]["value"] - (int)$row["value"]["完了数"]["value"];
  378.                 if(!isset($order_qty[$arrangement_date])) $order_qty[$arrangement_date] = [];
  379.                 /*
  380.                 if(isset($order_qty[$arrangement_date][$item_code])) {
  381.                     $order_qty[$arrangement_date][$item_code]+= $qty;
  382.                     $order_no[$arrangement_date][$item_code][] = $this->commonService->convertDispNo($row["value"]["No"]["value"], $row["value"]["完了No"]["value"]);
  383.                 }else{
  384.                     $order_qty[$arrangement_date][$item_code] = $qty;
  385.                     $order_no[$arrangement_date][$item_code][] = $this->commonService->convertDispNo($row["value"]["No"]["value"], $row["value"]["完了No"]["value"]);
  386.                 }
  387.                 */
  388.                 $order[$arrangement_date][] = [
  389.                     "item_code" => $item_code,
  390.                     "no" => $this->commonService->convertDispNo($row["value"]["No"]["value"], $row["value"]["完了No"]["value"]),
  391.                     "qty" => $qty
  392.                 ];
  394.             }
  395.         }
  397.         $data["item"] = [];
  398.         //在庫マスタからデータ取得
  399.         foreach($item_codes as $date_val => $date_list) {
  401.             $query = sprintf('商品コード in (%s) order by レコード番号', '"' . join('","', $date_list) . '"');
  402.             $result = $this->kintoneService->requestGets('stock', $query);
  403.             foreach($result["records"] as $record) {
  404.                 $film = $record["フィルムの種類"]["value"];
  405.                 $film_addr = $record["フイルム住所・棚番"]["value"];
  406.                 $item_name = $record["商品名"]["value"];
  407.                 $item_code = $record["商品コード"]["value"];
  408.     
  409.                 $item[$item_code] = [
  410.                     "name" => $item_name,
  411.                     "film" => $film,
  412.                     "film_addr" => $film_addr,
  413.                 ];
  414.             }
  415.         }
  417.         //リストを作成
  418.         /*
  419.         foreach($item_codes as $date_val => $date_list) {
  420.             foreach($date_list as $item_code) {
  421.                 $diff = $order_qty[$date_val][$item_code];
  422.                 $no = $order_no[$date_val][$item_code];
  423.                 $data["item"][$date_val][] = [
  424.                     "code" => $item_code,
  425.                     "name" => $item[$item_code]["name"],
  426.                     "no" => $no,
  427.                     "film" => $item[$item_code]["film"],
  428.                     "film_addr" => $item[$item_code]["film_addr"],
  429.                     "diff" => $diff,
  430.                 ];
  431.             }
  432.         }
  433.         */
  435.         foreach($order as $date_val => $order_val){
  436.             foreach($order_val as $val){
  437.                 $item_code = $val["item_code"];
  438.                 $data["item"][$date_val][] = [
  439.                     "code" => $item_code,
  440.                     "name" => $item[$item_code]["name"],
  441.                     "no" => $val["no"],
  442.                     "film" => $item[$item_code]["film"],
  443.                     "film_addr" => $item[$item_code]["film_addr"],
  444.                     "diff" => $val["qty"],
  445.                 ];
  446.             }
  447.         }
  450.         $data["line"] = $line;
  451.         return $this->render('manufacturing.html.twig', [
  452.             "today" => $today,
  453.             "data" => $data,
  454.         ]);
  456.     }
  458.     /**
  459.      * 更新履歴用のデータ作成
  460.      *
  461.      * @param [type] $logs
  462.      * @param [type] $mode
  463.      * @return void
  464.      */
  465.     private function create_log($logs, $mode, $update_date){
  466.         $new_log = [];
  467.         foreach($logs as $item){
  468.             $new_log[] = ["id" => $item["id"]];
  469.         }
  470.         $new_log[] = [ "value" =>  $this->kintoneService->setAttribute([
  471.             "ページ" => "生産計画管理",
  472.             "処理内容" => $mode,
  473.             "処理日時" => $update_date,
  474.         ])];
  475.         return $new_log;
  476.     }
  478.     /**
  479.      * 仕掛りのデータ取得
  480.      * @param array $item_codes
  481.      * 
  482.      * @return array
  483.      */
  484.     private function getRemainingData(&$add_qty, &$arrangement_item, $data){
  486.         //完了していない手配済みリストを取得
  487.         $query = sprintf('手配日 = "%s" or (手配日 < "%s" and 完了 not in ("完了","取消し")) order by 手配日 asc', $data["date"], $data["date"]);
  488.         $result = $this->kintoneService->requestGets('production_management', $query);
  489.         $records = $result["records"];
  490.         foreach($records as $record){
  491.             $line = $record["製造号機"]["value"];
  492.             $arrangement_list = $record["手配状況"]["value"];
  493.             $complete = $record["全て完了"]["value"];
  494.             $arrangement_date = $record["手配日"]["value"];
  496.             foreach($arrangement_list as $tmp_item) {
  497.                 $item = $tmp_item["value"];
  498.                 $item_code = $item["商品コード"]["value"];
  499.                 if(empty($item_code)) continue;
  500.                 if(in_array("取消し", $item["完了"]["value"])) continue;
  501.                 $num = (int)$item["ケース"]["value"];
  503.                 if(!in_array("完了", $item["完了"]["value"])) {
  504.                     // 設定したNoと完了したNoの差分を出す
  505.                     $no = $this->commonService->convertDispNo($item["No"]["value"], $item["完了No"]["value"]);
  506.                     $default_no = $this->commonService->convertDispNo($item["No"]["value"], ""); //とりあえず設定した内容を表示
  508.                     $complete_num = (int)$item["完了数"]["value"];
  509.                     $key = $item["key"]["value"];
  510.                     $quickly = !empty($item["急ぎ"]["value"]) ? true : false;
  511.                     $diff = $num - $complete_num;
  512.                     if(empty($complete) && $item_code) {
  513.                         $arrangement_item[$line][$arrangement_date][] = [
  514.                             "item_code" => $item_code,
  515.                             "num" => $num,
  516.                             "no" => $no,
  517.                             "default_no" => $default_no,
  518.                             "complete_num" => $complete_num,
  519.                             "diff" => $diff,
  520.                             "key" => $key,
  521.                             "quickly" => $quickly,
  522.                         ];
  523.                     }
  525.                     // 仕掛りの残り生産数を計算する
  526.                     if(isset($total_arrangement[$item_code])) {
  527.                         $add_qty[$item_code]+= $diff;
  528.                     }else{
  529.                         $add_qty[$item_code] = $diff;
  530.                     }
  531.                 }
  533.             }
  534.         }
  536.     }
  538. }