|
@@ -547,4 +547,117 @@ class OrderPay extends BaseController{
|
|
|
return error_show(1004,$e->getMessage());
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 显示创建资源表单页.
|
|
|
+ *
|
|
|
+ * @return \think\Response
|
|
|
+ */
|
|
|
+ public function importTrade()
|
|
|
+ {
|
|
|
+ $files = $this->request->file("excel");
|
|
|
+ $data = upload($files,$files->getOriginalExtension());
|
|
|
+ if($data['code']!=0){
|
|
|
+ return error_show(1004,$data['msg']);
|
|
|
+ }
|
|
|
+ $trade = $data['data'];
|
|
|
+ $list = [];
|
|
|
+ foreach ( $trade as $key => $value) {
|
|
|
+
|
|
|
+ if (!isset($value[0]) || $value[0] == '') {
|
|
|
+ //return ['code' => 1003, "msg" => '交易时间不能为空'];
|
|
|
+ return error_show( 1003, '交易时间不能为空!');
|
|
|
+ }
|
|
|
+ if ((!isset($value[1]) || $value[1] == '') && (!isset($value[2]) || $value[2] == '')) {
|
|
|
+ //return ['code' => 1003, "msg" => '收入/支出金额不能为空'];
|
|
|
+ return error_show( 1003, '收入/支出金额不能为空!');
|
|
|
+ }
|
|
|
+ if (!isset($value[4]) || $value[4] == '') {
|
|
|
+ // return ['code' => 1003, "msg" => '交易行名不能为空'];
|
|
|
+ return error_show( 1003, '交易行名不能为空!');
|
|
|
+ }
|
|
|
+ if (!isset($value[6]) || $value[6] == '') {
|
|
|
+ // return ['code' => 1003, "msg" => '对方账户不能为空'];
|
|
|
+ return error_show( 1003, '对方账户不能为空!');
|
|
|
+ }
|
|
|
+ if (!isset($value[7]) || $value[7] == '') {
|
|
|
+ // return ['code' => 1003, "msg" => '对方户名不能为空'];
|
|
|
+ return error_show( 1003, '对方户名不能为空!');
|
|
|
+ }
|
|
|
+ if ($key == 0) {
|
|
|
+ if ($value[0] != '交易时间') {
|
|
|
+ // return ['code' => 1003, "msg" => '模板第一列为必须为交易时间!'];
|
|
|
+ return error_show( 1003, '模板第一列为必须为交易时间!');
|
|
|
+ }
|
|
|
+ if ($value[1] != '收入金额') {
|
|
|
+ // return ['code' => 1003, "msg" => '模板第二列为必须为收入金额!'];
|
|
|
+ return error_show( 1003, '模板第二列为必须为收入金额!');
|
|
|
+ }
|
|
|
+ if ($value[2] != '支出金额') {
|
|
|
+ // return ['code' => 1003, "msg" => '模板第二列为必须为支出金额!'];
|
|
|
+ return error_show( 1003, '模板第二列为必须为支出金额!');
|
|
|
+ }
|
|
|
+ if ($value[4] != '交易行名') {
|
|
|
+ //return ['code' => 1003, "msg" => '模板第五列为必须为交易行名!'];
|
|
|
+ return error_show( 1003, '模板第五列为必须为交易行名!');
|
|
|
+ }
|
|
|
+ if ($value[6] != '对方账号') {
|
|
|
+ // return ['code' => 1003, "msg" => '模板第七列为必须为对方账号!'];
|
|
|
+ return error_show( 1003, '模板第七列为必须为对方账号!');
|
|
|
+ }
|
|
|
+ if ($value[7] != '对方户名') {
|
|
|
+ // return ['code' => 1003, "msg" => '模板第八列为必须为对方户名!'];
|
|
|
+ return error_show( 1003, '模板第八列为必须为对方户名!');
|
|
|
+ }
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $total_fee = $value[1]==0&&$value[2]!=0 ? $value[2]: $value[1];
|
|
|
+ $type = $value[1]==0&&$value[2]!=0 ? 1: 0;
|
|
|
+ $time = explode(" ", $value[0]);
|
|
|
+ $list[$key]["tradeTime"] = date("Y-m-d", strtotime($time[0])) . " " . (isset($time[1]) ? $time[1] : "00:00:00");
|
|
|
+ $list[$key]["trade_fee"] = str_replace(",","",$total_fee);
|
|
|
+ $list[$key]["trade_bank"] = $value[4];
|
|
|
+ $list[$key]["trade_account"] = $value[6];
|
|
|
+ $list[$key]["trade_out"] = $value[7];
|
|
|
+ $list[$key]["trade_in"] = '';
|
|
|
+ $list[$key]["trade_type"] = $type;
|
|
|
+ $list[$key]["trade_used"] = isset($value[8]) ? $value[8] : "";
|
|
|
+ $list[$key]["trade_remark"] = '';
|
|
|
+ }
|
|
|
+ if(empty($list)){
|
|
|
+ return error_show( 1003, '导入数据不能为空!');
|
|
|
+ }
|
|
|
+ Db::startTrans();
|
|
|
+ try{
|
|
|
+ $tra=[];
|
|
|
+ foreach ($list as $value) {
|
|
|
+ $temp = [];
|
|
|
+ $temp["tradNo"] = makeStr('S');
|
|
|
+ $temp['trade_time'] = $value['tradeTime'];
|
|
|
+ $temp['total_fee'] = $value['trade_fee'];
|
|
|
+ $temp['trade_bank'] = $value['trade_bank'];
|
|
|
+ $temp['trade_account'] = $value['trade_account'];
|
|
|
+ $temp['trade_type'] =$value['trade_type'];
|
|
|
+ $temp['trade_out'] = $value['trade_out'];
|
|
|
+ $temp['trade_in'] = $value['trade_in'];
|
|
|
+ $temp['trade_used'] = $value['trade_used'];
|
|
|
+ $temp['trade_remark'] = $value['trade_remark'];
|
|
|
+ $temp['balance'] =$value['trade_fee'];
|
|
|
+ $temp['addtime'] = date("Y-m-d H:i:s");
|
|
|
+ $temp['updatetime'] = date("Y-m-d H:i:s");
|
|
|
+ $tra[]=$temp;
|
|
|
+ }
|
|
|
+ $list = Db::name('trade')->insertAll($tra);
|
|
|
+ if($list==count($tra)){
|
|
|
+ Db::commit();
|
|
|
+ return app_show(0, "资金导入成功");
|
|
|
+ }else{
|
|
|
+ Db::rollback();
|
|
|
+ return app_show(1004, "资金导入失败");
|
|
|
+ }
|
|
|
+ }catch (\Exception $e){
|
|
|
+ Db::rollback();
|
|
|
+ return app_show(1004, $e->getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|