产品基本资料同步

application/api/controller/Synchronization.php

@@ -34,8 +34,34 @@ class Synchronization extends Api
             $this->success('未获取新工单');
         }
         $data = [];
-        $i = $j = $m =0;
+        $i = $j = $m = $n =0;
         foreach ($workOrderList as $key=>$value){
+            $productData = \db('产品_基本资料')
+                ->where('产品编号',$value['成品编号'])
+                ->count();
+            if ($productData === 0){
+                $clientCode = substr($value['成品编号'],0,4);
+                $product = [
+                    '客户编号' => $clientCode,
+                    '客户名称' => $value['客户名称'],
+                    '产品编号' => $value['成品编号'],
+                    '产品名称' => $value['成品名称'],
+                    '计量单位' => '万张',
+                    '状态' => '',
+                    'Mod_rq' => date('Y-m-d H:i:s',time()),
+                    'UniqID' => \db('产品_基本资料')->order('UniqID desc')->value('UniqID')+1,
+                ];
+                if (strpos($value['成品名称'],'小盒') === false){
+                    $product['产品类别'] = '条盒';
+                }else{
+                    $product['产品类别'] = '小盒';
+                }
+                $productSql = \db('产品_基本资料')->fetchSql(true)->insert($product);
+                $productRes = \db()->query($productSql);
+                if ($productRes === false){
+                    $n++;
+                }
+            }
             $res = \db('工单_基本资料')
                 ->where('Uniqid',$value['UniqId'])
                 ->count();
@@ -124,7 +150,7 @@ class Synchronization extends Api
                 $m++;
             }
         }
-        if ($j !== 0 || $m !==0){
+        if ($j !== 0 || $m !==0 || $n !== 0){
             $this->error('工单资料同步失败');
         }else{
             $this->success('工单资料同步成功');