OA数据同步生产环境测试

webmain/model/flow/emfkModel.php

@@ -374,69 +374,7 @@ class flow_emfkClassModel extends flowModel
 
     //流程全部完成后调用
     protected function flowcheckfinsh($zt){
-        $this->sendMess(1,3);
-        $docnum=$this->rs['docnum'];
-        $withhold_cost = m('c_withhold_emfk')->getall("docnum='$docnum' and status =1", 'id,cost_id,amount');
-
-        foreach ($withhold_cost as $key => $vo) {
-            // 扣除账户余额 c_fund_account account_balance
-            $project=self::project($vo['cost_id']);
-            $cbzxid= self::dept($project['data'][0]['jz_cur_dept']);
-
-            $model = 'c_fund_account';
-            $sql = " cost_id ='$cbzxid' and status = 1 and  is_default=1";
-            $data = m($model)->getone($sql,'id,name,account_balance,freeze_amount');
-
-            $zfarr = array(
-                'account_balance'        =>$data['account_balance']-$vo['amount'],
-            );
-            $id=$data['id'];
-            m('c_fund_account')->update($zfarr,"`id`='$id'");
-
-            $freeze = array(
-                'freeze_amount' => $data['freeze_amount'] - $vo['amount'],
-            );
      
-            m('c_fund_account')->update($freeze, "`id`='$id'");
-
-            // 成本中心 amount 变更
-            $cbzx = substr($cbzxid,0,strrpos($cbzxid,"（"));
-            $cbzxsql = " code ='$cbzx' and status = 1";
-
-            $cbzxdata = m('c_cbzx')->getone($cbzxsql,'id,amount');
-            $cbarr = array(
-                'amount'        =>$cbzxdata['amount']+$vo['amount'],
-            );
-            m('c_cbzx')->update($cbarr,"`code`='$cbzx'");
-            //账户明细 c_account_detail
-            $account_detail=array(
-                'account' => $data['name'],
-                'opt_type' => 2,
-                'amount' =>$vo['amount'],
-                'trans_numb' => $this->rs['docnum'],
-                'account_balance' => $data['account_balance']-$vo['amount'],
-                'create_time'  =>date("Y-m-d H:i:s"),
-                'uid'  =>$this->rs['uid'],
-            );
-
-            m('c_account_detail')->insert($account_detail);
-
-            // 电费12
-
-
-            $fund_detail=array(
-                'trans_numb' =>$this->rs['docnum'],
-                'account' =>  $data['name'],
-                'toaccount' =>$this->rs['applicant'],
-                'trans_amount' =>$vo['amount'],
-                'business_type' =>12,
-                'opt_type' =>2,
-                'account_balance'=>$data['account_balance']-$vo['amount'],
-                'create_time'  =>date("Y-m-d H:i:s"),
-                'uid'  =>$this->rs['uid'],
-            );
-            m('c_fund_detail')->insert($fund_detail);
-        }
 
     }
     public function emfk_submit($cloudUrl,$cookie_jar,$id,$number){

webmain/task/openapi/openemAction.php

@@ -121,6 +121,68 @@ class openemClassAction extends openapiAction
                         'iszb'    =>0
                     );
                     m('flow_log')->insert($addarr);
+                    $docnum= $datalist['docnum'];
+                        $withhold_cost = m('c_withhold_emfk')->getall("docnum='$docnum' and status =1", 'id,cost_id,amount');
+
+                        foreach ($withhold_cost as $key => $vo) {
+                            // 扣除账户余额 c_fund_account account_balance
+                            $project=self::project($vo['cost_id']);
+                            $cbzxid= self::dept($project['data'][0]['jz_cur_dept']);
+
+                            $model = 'c_fund_account';
+                            $sql = " cost_id ='$cbzxid' and status = 1 and  is_default=1";
+                            $data = m($model)->getone($sql,'id,name,account_balance,freeze_amount');
+
+                            $zfarr = array(
+                                'account_balance'        =>$data['account_balance']-$vo['amount'],
+                            );
+                            $id=$data['id'];
+                            m('c_fund_account')->update($zfarr,"`id`='$id'");
+
+                            $freeze = array(
+                                'freeze_amount' => $data['freeze_amount'] - $vo['amount'],
+                            );
+
+                            m('c_fund_account')->update($freeze, "`id`='$id'");
+
+                            // 成本中心 amount 变更
+                            $cbzx = substr($cbzxid,0,strrpos($cbzxid,"（"));
+                            $cbzxsql = " code ='$cbzx' and status = 1";
+
+                            $cbzxdata = m('c_cbzx')->getone($cbzxsql,'id,amount');
+                            $cbarr = array(
+                                'amount'        =>$cbzxdata['amount']+$vo['amount'],
+                            );
+                            m('c_cbzx')->update($cbarr,"`code`='$cbzx'");
+                            //账户明细 c_account_detail
+                            $account_detail=array(
+                                'account' => $data['name'],
+                                'opt_type' => 2,
+                                'amount' =>$vo['amount'],
+                                'trans_numb' => $this->rs['docnum'],
+                                'account_balance' => $data['account_balance']-$vo['amount'],
+                                'create_time'  =>date("Y-m-d H:i:s"),
+                                'uid'  =>$this->rs['uid'],
+                            );
+
+                            m('c_account_detail')->insert($account_detail);
+
+                            // 电费12
+
+
+                            $fund_detail=array(
+                                'trans_numb' =>$this->rs['docnum'],
+                                'account' =>  $data['name'],
+                                'toaccount' =>$this->rs['applicant'],
+                                'trans_amount' =>$vo['amount'],
+                                'business_type' =>12,
+                                'opt_type' =>2,
+                                'account_balance'=>$data['account_balance']-$vo['amount'],
+                                'create_time'  =>date("Y-m-d H:i:s"),
+                                'uid'  =>$this->rs['uid'],
+                            );
+                            m('c_fund_detail')->insert($fund_detail);
+                        }
 
                 }
 
@@ -184,8 +246,69 @@ class openemClassAction extends openapiAction
                             'iszb'    =>0
                         );
                         m('flow_log')->insert($addarr);
+                        $docnum= $datalist['docnum'];
+                        $withhold_cost = m('c_withhold_emfk')->getall("docnum='$docnum' and status =1", 'id,cost_id,amount');
+
+                        foreach ($withhold_cost as $key => $vo) {
+                            // 扣除账户余额 c_fund_account account_balance
+                            $project=self::project($vo['cost_id']);
+                            $cbzxid= self::dept($project['data'][0]['jz_cur_dept']);
+
+                            $model = 'c_fund_account';
+                            $sql = " cost_id ='$cbzxid' and status = 1 and  is_default=1";
+                            $data = m($model)->getone($sql,'id,name,account_balance,freeze_amount');
+
+                            $zfarr = array(
+                                'account_balance'        =>$data['account_balance']-$vo['amount'],
+                            );
+                            $id=$data['id'];
+                            m('c_fund_account')->update($zfarr,"`id`='$id'");
+
+                            $freeze = array(
+                                'freeze_amount' => $data['freeze_amount'] - $vo['amount'],
+                            );
+
+                            m('c_fund_account')->update($freeze, "`id`='$id'");
+
+                            // 成本中心 amount 变更
+                            $cbzx = substr($cbzxid,0,strrpos($cbzxid,"（"));
+                            $cbzxsql = " code ='$cbzx' and status = 1";
+
+                            $cbzxdata = m('c_cbzx')->getone($cbzxsql,'id,amount');
+                            $cbarr = array(
+                                'amount'        =>$cbzxdata['amount']+$vo['amount'],
+                            );
+                            m('c_cbzx')->update($cbarr,"`code`='$cbzx'");
+                            //账户明细 c_account_detail
+                            $account_detail=array(
+                                'account' => $data['name'],
+                                'opt_type' => 2,
+                                'amount' =>$vo['amount'],
+                                'trans_numb' => $this->rs['docnum'],
+                                'account_balance' => $data['account_balance']-$vo['amount'],
+                                'create_time'  =>date("Y-m-d H:i:s"),
+                                'uid'  =>$this->rs['uid'],
+                            );
+
+                            m('c_account_detail')->insert($account_detail);
+
+                            // 电费12
 
 
+                            $fund_detail=array(
+                                'trans_numb' =>$this->rs['docnum'],
+                                'account' =>  $data['name'],
+                                'toaccount' =>$this->rs['applicant'],
+                                'trans_amount' =>$vo['amount'],
+                                'business_type' =>12,
+                                'opt_type' =>2,
+                                'account_balance'=>$data['account_balance']-$vo['amount'],
+                                'create_time'  =>date("Y-m-d H:i:s"),
+                                'uid'  =>$this->rs['uid'],
+                            );
+                            m('c_fund_detail')->insert($fund_detail);
+                        }   
+
                     }
                 }
             }
@@ -194,6 +317,24 @@ class openemClassAction extends openapiAction
 
 
 
+    }
+
+        public static function dept($data)
+    {
+        $sql="  id= '$data'";
+        $cbzxid = m('tmp_department')->getone($sql, 'id,cost');//查询账户表成本中心id
+        return $cbzxid['cost'];
+    }
+
+
+    public static function project($project_code){
+
+        $url = getconfig('base_url'). 'v2/project/list?key=';
+        $key = substr(md5(getconfig('openkey').date('Y-m-d')),0,12);
+        $url = $url.$key;
+        $url .= '&project_code='.$project_code;
+        $res = json_decode(curlGet($url),true);
+        return $res;
     }
 
     //登陆