U8ThirdPartyService.php 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303
  1. <?php
  2. namespace App\Service;
  3. use Illuminate\Support\Facades\Cache;
  4. use Illuminate\Support\Facades\Log;
  5. class U8ThirdPartyService extends Service
  6. {
  7. const one = 1;
  8. const two = 2;
  9. const three = 3;
  10. const four = 4;
  11. const five = 5;
  12. const six = 6;
  13. const seven = 7;
  14. const eight = 8;
  15. const type_all = [
  16. self::one => '采购入库',
  17. self::two => '采购退货',
  18. self::three => '材料出库',
  19. self::four => '销售出库',
  20. self::five => '产成品入库',
  21. self::six => '销售退货',
  22. self::seven => '其他入',
  23. self::eight => '其他出',
  24. ];
  25. public function settleU8Data($data){
  26. if(empty($data['type'])) return [false, 'type类型不能为空'];
  27. if(! isset(self::type_all[$data['type']])) return [false, 'type类型错误'];
  28. $type = $data['type'];
  29. list($status, $msg) = $this->getToken();
  30. if(! $status) return [false, $msg];
  31. $data['u8_data'] = $msg;
  32. if($type == self::one){
  33. list($status, $msg) = $this->purchaseIn($data);
  34. }elseif ($type == self::two){
  35. list($status, $msg) = $this->purchaseReturn($data);
  36. }elseif ($type == self::three){
  37. list($status, $msg) = $this->materialOut($data);
  38. }elseif ($type == self::four){
  39. list($status, $msg) = $this->saleOut($data);
  40. }elseif ($type == self::five){
  41. list($status, $msg) = $this->productIn($data);
  42. }elseif ($type == self::six){
  43. list($status, $msg) = $this->saleReturn($data);
  44. }elseif ($type == self::seven){
  45. list($status, $msg) = $this->otherIn($data);
  46. }elseif ($type == self::eight){
  47. list($status, $msg) = $this->otherOut($data);
  48. }
  49. return [$status, $msg];
  50. }
  51. public function getToken(){
  52. $key = "drb_u8_api" . env('SQLSRV_DATABASE');
  53. $config = config('wms.drb');
  54. // 1. 自检网络通畅
  55. list($bool, $msg) = $this->checkNetworkStatus($config['api_host'], $config['api_port']);
  56. if (!$bool) return [false, "网络连接失败: " . $msg];
  57. $host = $config['api_host'] . ":" . $config['api_port'];
  58. // 2. 尝试从缓存获取
  59. $token = Cache::get($key);
  60. if (! $token) {
  61. // 3. 缓存失效,请求新 Token
  62. $url = $host . "/api/System/GetToken";
  63. $date = date("Y-m-d");
  64. $json = [
  65. "U8DbName" => $config['database'],
  66. "sUserId" => $config['user_id'],
  67. "sPassword" => $config['user_password'],
  68. "LoginDateTime" => $date,
  69. "bPersist" => true
  70. ];
  71. $header = ['Content-Type:application/json'];
  72. // 调用你的 POST 辅助函数
  73. list($status, $result) = $this->post_helper1($url, json_encode($json), $header);
  74. if (!$status) return [false, "用友token获取失败: " . $result];
  75. if (!isset($result['code'])) return [false, '获取用友登录信息失败: 响应格式异常'];
  76. if ($result['code'] != 0) return [false, "U8错误: " . ($result['msg'] ?? '未知错误')];
  77. $token = $result['data']['Token'] ?? "";
  78. if (empty($token)) return [false, "接口返回的 Token 为空"];
  79. // 30分钟 = 1800秒
  80. Cache::put($key, $token, now()->addMinutes(30));
  81. }
  82. return [true, ['host' => $host, 'token' => $token]];
  83. }
  84. /**
  85. * 采购到货单拆行/更新处理
  86. */
  87. public function purchaseIn($data)
  88. {
  89. if (empty($data['orderId'])) return [false, '采购到货单ID不能为空'];
  90. if (empty($data['orderNo'])) return [false, '采购到货单单号不能为空'];
  91. if (empty($data['detail'])) return [false, '表体信息detail不能为空'];
  92. // 1. 获取到货单明细
  93. $service = new U8ThirtyPartyDatabaseServerService();
  94. list($status, $result) = $service->getCGDHDetails($data['orderId']);
  95. if (! $status) return [false, $result];
  96. // 取出第一行作为模板,保留 ID, cCode 等主表关联信息
  97. $templateRow = reset($result);
  98. $mainId = $templateRow['ID'];
  99. // 2. 存货管控校验(批次/保质期)
  100. // list($status, $msg) = $service->checkInventoryControl(array_column($data['detail'], 'materialCode'));
  101. // if (!$status) return [false, $msg];
  102. $insertData = [];
  103. $rowNo = 1;
  104. foreach ($data['detail'] as $value) {
  105. if (!isset($result[$value['materialCode']])) continue;
  106. $map = $result[$value['materialCode']]; // 获取原始行信息(单价、税率等)
  107. // 计算单价
  108. $oldQty = (float)($map['iQuantity'] ?? 0);
  109. if ($oldQty <= 0) continue;
  110. $unitPrice = (float)$map['iOriSum'] / $oldQty;
  111. $unitMoney = (float)$map['iOriMoney'] / $oldQty;
  112. $unitLocalSum = (float)$map['iSum'] / $oldQty;
  113. $unitLocalMoney = (float)$map['iMoney'] / $oldQty;
  114. $newQty = (float)$value['iQuantity'];
  115. // 组织新行数据
  116. $newRow = $map;
  117. // 清理旧行主键和业务累积状态(关键!)
  118. unset($newRow['Autoid']);
  119. $newRow['fInspectQuantity'] = 0; // 已报检量清零
  120. $newRow['fValidQuantity'] = 0; // 合格量清零
  121. $newRow['iQuantity'] = $newQty;
  122. $newRow['ivouchrowno'] = $rowNo++; // 重新排序行号
  123. // 填充计算后的金额和批次日期
  124. $newRow['iOriMoney'] = round($unitMoney * $newQty, 2);
  125. $newRow['iOriSum'] = round($unitPrice * $newQty, 2);
  126. $newRow['iOriTaxPrice'] = round(($unitPrice - $unitMoney) * $newQty, 2);
  127. $newRow['iMoney'] = round($unitLocalMoney * $newQty, 2);
  128. $newRow['iSum'] = round($unitLocalSum * $newQty, 2);
  129. $newRow['iTaxPrice'] = round(($unitLocalSum - $unitLocalMoney) * $newQty, 2);
  130. $newRow['cBatch'] = $value['lot'] ?? null;
  131. $newRow['dPDate'] = !empty($value['productDate']) ? $this->formatAndValidateDate($value['productDate']) : null;
  132. $newRow['dVDate'] = !empty($value['failureDate']) ? $this->formatAndValidateDate($value['failureDate']) : null;
  133. $newRow['cFree1'] = $value['param_one'] ?? null; //锥入度
  134. $newRow['cFree2'] = $value['param_two'] ?? null; //包装规格
  135. $insertData[] = $newRow;
  136. }
  137. // 3. 执行数据库操作:先删后插
  138. list($status, $msg) = $service->rebuildDhDetails($mainId, $insertData);
  139. if (!$status) return [false, $msg];
  140. //查询采购到货单
  141. list($status, $order) = $service->getCgOrder($data['orderId']);
  142. if(! $status) return [false, $order];
  143. //生成来料报检单
  144. $inspect = [
  145. "Inum" => "ArrInspect",
  146. "Data" => [
  147. "iHead" => [
  148. // 注意:这里使用的是主表的 ID
  149. "CSOURCEID" => $order['ID'],
  150. "CDEPCODE" => $order['cDepCode'],
  151. "DDATE" => date("Y-m-d"),
  152. "CCHECKTYPECODE" => 'ARR',
  153. ],
  154. "iBody" => []
  155. ]
  156. ];
  157. foreach ($order['details'] as $item) {
  158. $qty = (float)($item['iQuantity'] ?? 0);
  159. if ($qty <= 0) continue;
  160. $inspect["Data"]["iBody"][] = [
  161. "SOURCEAUTOID" => $item['Autoid'],
  162. "ITESTSTYLE" => 0,
  163. "CINVCODE" => $item['cInvCode'],
  164. "FCHANGRATE" => (float)($item['iInvExchRate'] ?? 0),
  165. "FQUANTITY" => $qty,
  166. "CBATCH" => $item['cBatch'],
  167. 'DPRODATE' => $item['dPDate'],
  168. 'DVDATE' => $item['dVDate'],
  169. 'cFree1' => $item['cFree1'],
  170. 'cFree2' => $item['cFree2'],
  171. ];
  172. }
  173. // 4. 封装成数组返回
  174. $final_data = [$inspect];
  175. //调用所需
  176. $host = $data['u8_data']['host'];
  177. $token = $data['u8_data']['token'];
  178. //报检单
  179. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  180. $url = $host . "/api/QmArr/ArrInspectAdd";
  181. $json = json_encode($final_data);
  182. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  183. if(! $status) return [false, $result];
  184. if(! isset($result['code'])) return [false, '报检单生成失败'];
  185. if($result['code'] != 0) return [false, $result['msg']];
  186. return [true, ''];
  187. }
  188. public function materialOut($data)
  189. {
  190. if (empty($data['orderId'])) return [false, '领料申请单ID不能为空'];
  191. if (empty($data['orderNo'])) return [false, '领料申请单单号不能为空'];
  192. if (empty($data['warehouseCode'])) return [false, '仓库不能为空'];
  193. if (empty($data['detail'])) return [false, '表体信息detail不能为空'];
  194. // 1. 获取领料申请单明细
  195. $service = new U8ThirtyPartyDatabaseServerService();
  196. list($status, $result) = $service->getLlSQDetails($data['orderId']);
  197. if (! $status) return [false, $result];
  198. if(empty($result)) return [false, '领料申请单不存在'];
  199. // 取出第一行作为模板,获取主表 ID
  200. $templateRow = reset($result);
  201. $mainId = $templateRow['ID'];
  202. // 2. 存货管控校验(批次/保质期)
  203. // list($status, $msg) = $service->checkInventoryControl(array_column($data['detail'], 'materialCode'));
  204. // if (!$status) return [false, $msg];
  205. $insertData = [];
  206. $rowNo = 1;
  207. foreach ($data['detail'] as $value) {
  208. if (!isset($result[$value['materialCode']])) continue;
  209. // 获取原始行(保留生产订单关联 morderdid、仓库 cwhcode 等信息)
  210. $map = $result[$value['materialCode']];
  211. $newQty = (float)$value['iQuantity'];
  212. // 组织新行数据
  213. $newRow = $map;
  214. // 清理主键
  215. unset($newRow['AutoID']);
  216. $newRow['iQuantity'] = $newQty; // 申请数量
  217. $newRow['irowno'] = $rowNo++; // 重新排序行号
  218. $newRow['cBatch'] = $value['lot'] ?? null; // 批号
  219. // 生产日期与失效日期 (U8 领料申请单通常字段名为 dMadeDate 和 dVDate 或 dmadedate)
  220. $newRow['dMadeDate'] = !empty($value['productDate']) ? $this->formatAndValidateDate($value['productDate']) : null;
  221. $newRow['dVDate'] = !empty($value['failureDate']) ? $this->formatAndValidateDate($value['failureDate']) : null;
  222. $newRow['cFree1'] = $value['param_one'] ?? null; //锥入度
  223. $newRow['cFree2'] = $value['param_two'] ?? null; //包装规格
  224. $insertData[] = $newRow;
  225. }
  226. // 3. 执行数据库操作:先删后插
  227. list($status, $msg) = $service->rebuildLLDetails($mainId, $insertData);
  228. if (!$status) return [false, $msg];
  229. //查询领料申请单
  230. list($status, $order) = $service->getLLOrder($data['orderId']);
  231. if(!$status) return [false, '领料单不存在'];
  232. //仓库区分出入库类别
  233. if($data['warehouseCode'] == "01"){
  234. $cRdCode = "0201";
  235. }else{
  236. $cRdCode = "0203";
  237. }
  238. $materialOut = [
  239. "Inum" => "MaterialOut",
  240. "Data" => [
  241. "iHead" => [
  242. "IsVerify" => true,
  243. "cWhCode" => $data['warehouseCode'], // 仓库
  244. "cVouchType" => "11",
  245. "cRdCode" => $cRdCode, // 出入库类别
  246. "cDepCode" => $order['cDepCode'], // 领用部门
  247. "cSource" => "领料申请单",
  248. "cBusCode" => $order['cCode'], // 领料申请单单号
  249. "cBusType" => "领料",
  250. "cMemo" => "接口生成",
  251. "dDate" => date("Y-m-d"),
  252. ],
  253. "iBody" => []
  254. ]
  255. ];
  256. foreach ($order['details'] as $index => $item) {
  257. // 这里的数量取值要对应你 getLLOrder 查出来的字段名,通常是 fQty
  258. $qty = $item['iQuantity'];
  259. if ($qty <= 0) continue;
  260. $materialOut["Data"]["iBody"][] = [
  261. "iRowNo" => $index + 1,
  262. "cInvCode" => $item['cInvCode'],
  263. "cBatch" => $item['cBatch'] ?? null, // 批号
  264. "iQuantity" => $qty, // 实际出库数量
  265. "iNQuantity" => $qty, // 实收数量
  266. "iinvexchrate" => (float)($item['iinvexchrate'] ?? 1),
  267. "iMaIDs" => $item['AutoID'],
  268. "dMadeDate" => $item['dMadeDate'] ?? null, // 生产日期
  269. "dVDate" => $item['dVDate'] ?? null, // 失效日期
  270. 'cFree1' => $item['cFree1'],
  271. 'cFree2' => $item['cFree2'],
  272. ];
  273. }
  274. // 封装成数组返回
  275. $final_data = [$materialOut];
  276. //调用所需
  277. $host = $data['u8_data']['host'];
  278. $token = $data['u8_data']['token'];
  279. //材料出库单
  280. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  281. $url = $host . "/api/MaterialOut/Add";
  282. $json = json_encode($final_data);
  283. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  284. if(! $status) return [false, $result];
  285. if(! isset($result['code'])) return [false, '材料出库单生成失败'];
  286. if($result['code'] != 0) return [false, $result['msg']];
  287. return [true, ''];
  288. }
  289. public function purchaseReturn($data){
  290. if(empty($data['orderId'])) return [false, '采购退货单ID不能为空'];
  291. // 1. 获取到货单(退货单)及明细
  292. $service = new U8ThirtyPartyDatabaseServerService();
  293. list($status, $order) = $service->getArrivalVouchById($data['orderId']);
  294. if(! $status) return [false, $order];
  295. // 获取 Token 相关信息
  296. $host = $data['u8_data']['host'] ?? "";
  297. $token = $data['u8_data']['token'] ?? "";
  298. // 2. 组织单一仓库的红字采购入库单
  299. $iBody = [];
  300. foreach ($order['details'] as $index => $item) {
  301. // 强制转为负数,生成红字入库单
  302. $qty = abs((float)$item['iQuantity']) * -1;
  303. $iBody[] = [
  304. "iRowNo" => $index + 1,
  305. "cInvCode" => $item['cInvCode'],
  306. "cBatch" => $item['cBatch'] ?? '',
  307. "iinvexchrate" => (float)($item['iinvexchrate'] ?? 1),
  308. "iQuantity" => $qty, // 负数
  309. "iNQuantity" => $qty, // 负数
  310. "iArrsId" => $item['iArrsId'],
  311. "dMadeDate" => $item['dPDate'],
  312. "dVDate" => $item['dVDate'],
  313. "iTaxRate" => $item['iTaxRate'] ?? 0,
  314. "iTaxUnitPrice"=> $item['iOriTaxCost'] ?? 0,
  315. 'cFree1' => $item['cFree1'],
  316. 'cFree2' => $item['cFree2'],
  317. ];
  318. }
  319. if(empty($iBody)) return [false, '表体明细为空'];
  320. $final_data = [
  321. [
  322. "Inum" => "PurchaseIn",
  323. "Data" => [
  324. "iHead" => [
  325. "IsVerify" => true,
  326. "bIsRedVouch" => true, // 必须为红字
  327. "bCalPrice" => true, // 自动计算金额
  328. "cWhCode" => "01",
  329. "cRdCode" => $order['rd_code'],
  330. "cDepCode" => $order['depart_code'],
  331. "cARVCode" => $order['no'], // 关联来源单号
  332. "cSource" => "采购到货单", // 即使是退货单,参照来源也写这个
  333. "cBusType" => "普通采购",
  334. "cMemo" => "接口生成",
  335. "dDate" => date("Y-m-d"),
  336. "iExchRate"=> 1,
  337. ],
  338. "iBody" => $iBody
  339. ]
  340. ]
  341. ];
  342. // 3. 调用 API
  343. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  344. $url = $host . "/api/PurchaseIn/Add";
  345. $json = json_encode($final_data);
  346. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  347. if(! $status) return [false, $result];
  348. if(! isset($result['code'])) return [false, '红字采购入库单生成失败'];
  349. if($result['code'] != 0) return [false, $result['msg']];
  350. return [true, ''];
  351. }
  352. public function productIn($data){
  353. if(empty($data['orderId'])) return [false, '产品报检单ID不能为空'];
  354. if(empty($data['orderNo'])) return [false, '产品报检单单号不能为空'];
  355. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  356. // 1. 获取报检单明细 (建议 getBjOrder 返回以 cInvCode 为 key 的数组)
  357. $service = new U8ThirtyPartyDatabaseServerService();
  358. list($status,$result) = $service->getBjOrder($data['orderId']);
  359. if (! $status) return [false, $result];
  360. // 取出第一行作为模板,获取主表 ID
  361. $templateRow = reset($result);
  362. $mainId = $templateRow['ID'];
  363. // 2. 存货管控校验(批次/保质期)
  364. // list($status, $msg) = $service->checkInventoryControl(array_column($data['detail'], 'materialCode'));
  365. // if (!$status) return [false, $msg];
  366. $insertData = [];
  367. $rowNo = 1;
  368. foreach ($data['detail'] as $value) {
  369. if (!isset($result[$value['materialCode']])) continue;
  370. // 获取原始行(保留来源单据关联,如采购到货单行 AutoID 等)
  371. $map = $result[$value['materialCode']];
  372. $newQty = (float)$value['iQuantity'];
  373. // 组织新行数据
  374. $newRow = $map;
  375. // 清理子表主键
  376. unset($newRow['AUTOID']);
  377. // --- 核心字段修正 (报检单子表字段通常为大写) ---
  378. $newRow['FQUANTITY'] = $newQty; // 报检数量
  379. $newRow['CBATCH'] = $value['lot'] ?? null; // 批号
  380. // 报检单的日期字段通常是 DPRODATE (生产日期) 和 DVDATE (失效日期)
  381. $newRow['DPRODATE'] = !empty($value['productDate']) ? $this->formatAndValidateDate($value['productDate']) : null;
  382. $newRow['DVDATE'] = !empty($value['failureDate']) ? $this->formatAndValidateDate($value['failureDate']) : null;
  383. $insertData[] = $newRow;
  384. }
  385. // 3. 执行数据库操作:先删后插
  386. list($status, $msg) = $service->rebuildBjDetails($mainId, $insertData);
  387. if (!$status) return [false, $msg];
  388. // $service = new U8ThirtyPartyDatabaseServerService();
  389. // $result = $service->getBjOrder($data['orderId']);
  390. //
  391. // $tmp = $update = $insert = [];
  392. // foreach ($data['detail'] as $key => $value) {
  393. // if(empty($value['lineNum'])) return [false, '行号不能为空'];
  394. // if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  395. // if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  396. // if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  397. // $return = $this->formatAndValidateDate($value['productDate']);
  398. // if(! $return) return [false, '生产日期格式错误'];
  399. // $productDate = $return;
  400. // if(empty($value['failureDate'])) return [false, '失效日期不能为空'];
  401. // $return = $this->formatAndValidateDate($value['failureDate']);
  402. // if(! $return) return [false, '生产日期格式错误'];
  403. // $failureDate= $return;
  404. // if(empty($value['lot'])) return [false, '批号不能为空'];
  405. // if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  406. //
  407. // if(isset($result[$value['materialCode']])){
  408. // $map = $result[$value['materialCode']];
  409. // $update_detail = [
  410. // 'CBATCH' => $value['lot'],
  411. // 'FQUANTITY' => $value['iQuantity'],
  412. // 'DPRODATE' => $productDate,
  413. // 'DVDATE' => $failureDate,
  414. // ];
  415. // if(! isset($tmp[$value['materialCode']])){
  416. // $update[$map['AUTOID']] = $update_detail;
  417. // $tmp[$value['materialCode']] = $value['materialCode'];
  418. // }else{
  419. // $map['AUTOID'] = null;
  420. // $insert[] = array_merge($map, $update_detail);
  421. // }
  422. // }
  423. // }
  424. //
  425. // list($status,$msg) = $service->checkInventoryControl(array_values(array_column($data['detail'],'materialCode')));
  426. // if(! $status) return [false, $msg];
  427. //
  428. // list($status, $msg) = $service->updateBjOrder($update, $insert);
  429. // if(! $status) return [false, $msg];
  430. return [true, ''];
  431. }
  432. public function saleOut($data){
  433. if(empty($data['orderId'])) return [false, '销售订单ID不能为空'];
  434. if(empty($data['orderNo'])) return [false, '销售订单号不能为空'];
  435. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  436. //获取销售订单信息
  437. $service = new U8ThirtyPartyDatabaseServerService();
  438. list($status,$order) = $service->getXsOrder($data['orderId']);
  439. if(! $status) return [false, $order];
  440. $detail_map = [];
  441. foreach ($data['detail'] as $key => $value) {
  442. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  443. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  444. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  445. // if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  446. // $return = $this->formatAndValidateDate($value['productDate']);
  447. // if(! $return) return [false, '生产日期格式错误'];
  448. // $productDate = $return;
  449. if(! empty($value['failureDate'])) {
  450. $return = $this->formatAndValidateDate($value['failureDate']);
  451. if(! $return) return [false, '失效日期格式错误'];
  452. $failureDate= $return;
  453. }
  454. // if(empty($value['lot'])) return [false, '批号不能为空'];
  455. if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  456. $detail_map[$value['materialCode']][] = [
  457. // 'productDate' => $productDate,
  458. 'failureDate' => $failureDate ?? null,
  459. 'lot' => $value['lot'] ?? null,
  460. 'iQuantity' => $value['iQuantity'],
  461. ];
  462. }
  463. // 2. 组织发货单 (DispatchList) 结构
  464. $tmp = [
  465. "Inum" => "DispatchList",
  466. "Data" => [
  467. "iHead" => [
  468. "cVouchType" => "05",
  469. "cSTCode" => (string)($order['cSTCode'] ?? "02"), // 示例中是02
  470. "cDepCode" => (string)($order['cDepCode'] ?? "01"),
  471. "cBusType" => $order['cBusType'] ?? "分期收款",
  472. "IsVerify" => true,
  473. "cMemo" => "接口生成",
  474. "dDate" => date("Y-m-d"),
  475. "cSoCode" => (string)$order['cSOCode'],
  476. "ccuscode" => (string)$order['cCusCode'],
  477. "cexch_name" => (string)($order['cexch_name'] ?? "人民币"),
  478. "iexchrate" => (float)($order['iExchRate'] ?? 1.0), // 强制转浮点,去掉引号
  479. "iTaxRate" => (float)($order['iTaxRate'] ?? 13.0), // 强制转浮点
  480. ],
  481. "iBody" => []
  482. ]
  483. ];
  484. // 3. 遍历销售订单明细组织表体
  485. $key = 0;
  486. foreach ($order['details'] as $item) {
  487. $p_t = $detail_map[$item['cInvCode']] ?? [];
  488. if (empty($p_t)) continue;
  489. foreach ($p_t as $value) {
  490. $key++;
  491. $qty = (float)$value['iQuantity'];
  492. $taxRate = (float)($item['iTaxRate'] ?? 13.0);
  493. $taxUnitPrice = (float)$item['iTaxUnitPrice']; // 含税单价 (如 100)
  494. // 价税合计 (iSum)
  495. $iSum = round($qty * $taxUnitPrice, 2);
  496. // 无税金额 (imoney) = 价税合计 / (1 + 税率/100)
  497. $iMoney = round($iSum / (1 + ($taxRate / 100)), 2);
  498. // 税额 (itax)
  499. $iTax = round($iSum - $iMoney, 2);
  500. // 无税单价 (iunitprice)
  501. $iUnitPrice = round($taxUnitPrice / (1 + ($taxRate / 100)), 10);
  502. $tmp["Data"]["iBody"][] = [
  503. "iRowNo" => (int)$key, // 强制转整型
  504. "cInvCode" => (string)$item['cInvCode'],
  505. "iTaxRate" => (float)$taxRate,
  506. "cGroupCode" => (string)($item['cGroupCode'] ?? "01"),
  507. "iGroupType" => "0",
  508. "cUnitID" => (string)($item['cUnitID'] ?? "003"),
  509. "cWhCode" => "06",
  510. "iQuantity" => (float)$qty,
  511. "iNum" => 0, // 辅计量数量
  512. "iSum" => (float)$iSum,
  513. "iInvExchRate" => 1.0, // 换算率,必填
  514. "imoney" => (float)$iMoney,
  515. "itax" => (float)$iTax,
  516. "idiscount" => 0,
  517. "inatmoney" => (float)$iMoney,
  518. "inattax" => (float)$iTax,
  519. "inatdiscount" => 0,
  520. "inatsum" => (float)$iSum,
  521. "itaxunitprice" => (float)$taxUnitPrice,
  522. "iunitprice" => (float)$iUnitPrice,
  523. "inatunitprice" => (float)$iUnitPrice,
  524. "dvDate" => $value['failureDate'], // 示例中只需失效日期
  525. // "dMDate" => (string)$value['productDate'],
  526. "iSOsID" => (int)$item['iSOsID'], // 强制转整型,去掉引号
  527. "cBatch" => $value['lot'],
  528. 'cFree1' => $item['cFree1'],
  529. 'cFree2' => $item['cFree2'],
  530. ];
  531. }
  532. }
  533. $final_data = [$tmp];
  534. //调用所需
  535. $host = $data['u8_data']['host'];
  536. $token = $data['u8_data']['token'];
  537. //销售发货单
  538. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  539. $url = $host . "/api/Dispatch/Add";
  540. $json = json_encode($final_data);
  541. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  542. if(! $status) return [false, $result];
  543. if(! isset($result['code'])) return [false, '销售发货单生成失败'];
  544. if($result['code'] != 0) return [false, $result['msg']];
  545. $first = $result['data'][0];
  546. $id = $first['VouchId'];
  547. // $id = 1000000882;
  548. list($status, $fhOrder) = $service->getFhOrder($id);
  549. if(! $status) return [false, $fhOrder];
  550. // 2. 初始化销售出库单结构
  551. $saleOut = [
  552. "Inum" => "SaleOut",
  553. "Data" => [
  554. "iHead" => [
  555. "IsVerify" => true, // 自动审核
  556. "cWhCode" => "06", // 仓库编码
  557. "cRdCode" => "0299", // 出入库类别编码
  558. "cVouchType" => "32", // 单据类型编码
  559. "cBusType" => $fhOrder['cBusType'] ?? "分期收款",
  560. "cMemo" => "接口生成",
  561. "cSource" => "发货单",
  562. "cSTCode" => $fhOrder['cSTCode'], // 销售类型
  563. "DLCode" => $fhOrder['cDLCode'], // 关联的发货单号
  564. "cDepCode" => $fhOrder['cDepCode'], // 部门
  565. "dDate" => date("Y-m-d"), // 出库日期
  566. ],
  567. "iBody" => []
  568. ]
  569. ];
  570. // 3. 遍历发货单明细组织表体
  571. foreach ($fhOrder['details'] as $index => $item) {
  572. // 计算待出库数量 (总发货数 - 已出库数)
  573. $qty = (float)($item['iQuantity'] ?? 0);
  574. $outQty = (float)($item['fOutQuantity'] ?? 0);
  575. $pendingQty = $qty - $outQty;
  576. // 如果该行已全部出库,则跳过(可选逻辑)
  577. if ($pendingQty <= 0) continue;
  578. $saleOut["Data"]["iBody"][] = [
  579. "iRowNo" => $index + 1,
  580. "cInvCode" => $item['cInvCode'] ?? "",
  581. "cPosition" => $item['cPosition'] ?? "", // 货位
  582. "cBatch" => $item['cBatch'] ?? "", // 批号
  583. "iinvexchrate" => (float)($item['iExchRate'] ?? 1), // 换算率
  584. "iQuantity" => $pendingQty, // 本次出库数量
  585. "iNQuantity" => $pendingQty, // 对应实收数量
  586. "iDLsID" => $item['iDLsID'], // 核心:发货单子表ID
  587. "dMadeDate" => $item['dMDate'], // 生产
  588. "dVDate" => $item['dvDate'], // 失效
  589. 'cFree1' => $item['cFree1'],
  590. 'cFree2' => $item['cFree2'],
  591. // "iUnitCost" => (float)($item['iUnitPrice'] ?? 0), // 无税单价
  592. // "iPrice" => round((float)($item['iUnitPrice'] ?? 0) * $pendingQty, 2), // 无税金额
  593. ];
  594. }
  595. // 4. 封装成数组
  596. $final_data = [$saleOut];
  597. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  598. $url = $host . "/api/SaleOut/Add";
  599. $json = json_encode($final_data);
  600. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  601. if(! $status) return [false, $result];
  602. if(! isset($result['code'])) return [false, '销售出库单生成失败'];
  603. if($result['code'] != 0) return [false, $result['msg']];
  604. return [true, ''];
  605. }
  606. public function otherIn($data) {return [false, '其他入功能关闭'];
  607. // 1. 基础校验
  608. if (empty($data['warehouseCode'])) return [false, '仓库编码不能为空'];
  609. if (empty($data['detail'])) return [false, '明细数据不能为空'];
  610. $iBody = [];
  611. foreach ($data['detail'] as $key => $value) {
  612. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  613. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  614. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  615. if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  616. $return = $this->formatAndValidateDate($value['productDate']);
  617. if(! $return) return [false, '生产日期格式错误'];
  618. $productDate = $return;
  619. if(empty($value['failureDate'])) return [false, '失效日期不能为空'];
  620. $return = $this->formatAndValidateDate($value['failureDate']);
  621. if(! $return) return [false, '生产日期格式错误'];
  622. $failureDate= $return;
  623. if(empty($value['lot'])) return [false, '批号不能为空'];
  624. if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  625. $iBody[] = [
  626. "iRowNo" => $key + 1,
  627. "cInvCode" => $value['materialCode'], // 存货编码
  628. "cBatch" => $value['lot'] ?? "", // 批号
  629. "iQuantity" => $value['iQuantity'],
  630. "iinvexchrate" => 0,
  631. "iNum" => 0,
  632. "dMadeDate" => $productDate, // 生产日期
  633. "dVDate" => $failureDate, // 失效日期
  634. 'cFree1' => $value['param_one'] ?? null,
  635. 'cFree2' => $value['param_two'] ?? null,
  636. ];
  637. }
  638. // 2. 组织表头 (iHead)
  639. $iHead = [
  640. "cWhCode" => $data['warehouseCode'], // 仓库编码
  641. "cRdCode" => "0109", // 收发类别 其他入
  642. "cDepCode" => "", // 部门
  643. "IsVerify" => ! isset($data['IsVerify']) ?? false, // 是否自动审核
  644. "cMemo" => "接口生成",
  645. "dDate" => $data['dDate'] ?? date("Y-m-d"), // 单据日期
  646. ];
  647. // 4. 封装成要求的数组结构
  648. $final_data = [
  649. [
  650. "Inum" => "OtherIn",
  651. "Data" => [
  652. "iHead" => $iHead,
  653. "iBody" => $iBody
  654. ]
  655. ]
  656. ];
  657. // 5. 准备发送请求
  658. $host = $data['u8_data']['host'] ?? "";
  659. $token = $data['u8_data']['token'] ?? "";
  660. $url = $host . "/api/OtherIn/Add";
  661. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  662. // 执行提交 (假设你已经定义了 post_helper1)
  663. $json = json_encode($final_data);
  664. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  665. if(! $status) return [false, $result];
  666. if(! isset($result['code'])) return [false, '其他入库单生成失败'];
  667. if($result['code'] != 0) return [false, $result['msg']];
  668. return [true, $result];
  669. }
  670. public function otherOut($data) {return [false, '其他出功能关闭'];
  671. // 1. 基础校验
  672. if (empty($data['warehouseCode'])) return [false, '仓库编码不能为空'];
  673. if (empty($data['detail'])) return [false, '明细数据不能为空'];
  674. $iBody = [];
  675. foreach ($data['detail'] as $key => $value) {
  676. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  677. // 格式化生产日期
  678. $productDate = null;
  679. if(!empty($value['productDate'])){
  680. $productDate = $this->formatAndValidateDate($value['productDate']);
  681. if(!$productDate) return [false, '生产日期格式错误'];
  682. }
  683. // 格式化失效日期
  684. $failureDate = null;
  685. if(!empty($value['failureDate'])){
  686. $failureDate = $this->formatAndValidateDate($value['failureDate']);
  687. if(!$failureDate) return [false, '失效日期格式错误'];
  688. }
  689. if(empty($value['iQuantity']) || !is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  690. $iBody[] = [
  691. "iRowNo" => $key + 1,
  692. "cInvCode" => $value['materialCode'], // 存货编码
  693. "cBatch" => $value['lot'] ?? "", // 批号
  694. "iQuantity" => $value['iQuantity'],
  695. "iinvexchrate" => 0,
  696. "dMadeDate" => $productDate, // 生产日期
  697. "dVDate" => $failureDate, // 失效日期
  698. 'cFree1' => $value['param_one'] ?? null,
  699. 'cFree2' => $value['param_two'] ?? null,
  700. ];
  701. }
  702. // 2. 组织表头 (iHead)
  703. $iHead = [
  704. "cWhCode" => $data['warehouseCode'], // 仓库编码
  705. "cRdCode" => "0209", // 收发类别:其他出库
  706. "cDepCode" => "", // 部门
  707. "IsVerify" => isset($data['IsVerify']) ?? false, // 是否自动审核
  708. "cMemo" => "接口生成",
  709. "dDate" => $data['dDate'] ?? date("Y-m-d"), // 单据日期
  710. ];
  711. // 4. 封装成要求的数组结构 - Inum 改为 OtherOut
  712. $final_data = [
  713. [
  714. "Inum" => "OtherOut",
  715. "Data" => [
  716. "iHead" => $iHead,
  717. "iBody" => $iBody
  718. ]
  719. ]
  720. ];
  721. // 5. 准备发送请求
  722. $host = $data['u8_data']['host'] ?? "";
  723. $token = $data['u8_data']['token'] ?? "";
  724. // 地址改为 OtherOut
  725. $url = $host . "/api/OtherOut/Add";
  726. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  727. // 执行提交
  728. $json = json_encode($final_data);
  729. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  730. if(! $status) return [false, "网络请求失败: " . $result];
  731. if(! isset($result['code'])) return [false, '其他出库单生成失败'];
  732. if($result['code'] != 0) return [false, "U8错误: " . $result['msg']];
  733. return [true, $result];
  734. }
  735. public function saleReturn($data) {
  736. if(empty($data['orderId'])) return [false, '销售退货单ID不能为空'];
  737. // 1. 获取销售退货单信息 (DispatchList & DispatchLists)
  738. $service = new U8ThirtyPartyDatabaseServerService();
  739. list($status, $order) = $service->getXsThOrder($data['orderId']);
  740. if(! $status) return [false, $order];
  741. // --- 核心修改:按仓库分组 ---
  742. $groupDetails = [];
  743. foreach ($order['details'] as $item) {
  744. $whCode = $item['cWhCode'] ?? $order['cWhCode']; // 优先取明细里的仓库,没有则取主表的
  745. $groupDetails[$whCode][] = $item;
  746. }
  747. $final_data = [];
  748. // 2. 遍历每个仓库分组,生成各自的单据
  749. foreach ($groupDetails as $whCode => $details) {
  750. $iBody = [];
  751. foreach ($details as $index => $value) {
  752. $qty = (float)($value['iQuantity'] ?? 0);
  753. $redQty = $qty > 0 ? -$qty : $qty; // 强制红字
  754. $iBody[] = [
  755. "iRowNo" => $index + 1,
  756. "cInvCode" => $value['cInvCode'],
  757. "cPosition" => $value['cPosition'] ?? "",
  758. "cBatch" => $value['cBatch'] ?? "",
  759. "iinvexchrate" => (float)($value['iinvexchrate'] ?? 1),
  760. "iQuantity" => $redQty,
  761. "iNQuantity" => $redQty,
  762. "iNum" => (float)($value['iNum'] ?? 0),
  763. "iNNum" => (float)($value['iNum'] ?? 0),
  764. "iDLsID" => $value['iDLsID'] ?? 0, // 关键:关联发货单行ID
  765. "dMadeDate" => $value['dMDate'] ?? null,
  766. "dVDate" => $value['dvDate'] ?? null,
  767. 'cFree1' => $details['cFree1'] ?? null,
  768. 'cFree2' => $details['cFree2'] ?? null,
  769. ];
  770. }
  771. // 组织该单据的表头
  772. $iHead = [
  773. "IsVerify" => true,
  774. "bIsRedVouch" => true,
  775. "cWhCode" => $whCode, // 当前分组的仓库
  776. "cRdCode" => "0204",
  777. "cMemo" => "接口生成",
  778. "cSource" => "发货单",
  779. "cSTCode" => $order['cSTCode'],
  780. "DLCode" => $order['cDLCode'] ?? "",
  781. "dDate" => date("Y-m-d"),
  782. ];
  783. // 放入大数组
  784. $final_data[] = [
  785. "Inum" => "SaleOut",
  786. "Data" => [
  787. "iHead" => $iHead,
  788. "iBody" => $iBody
  789. ]
  790. ];
  791. }
  792. // 3. 发送请求
  793. $host = $data['u8_data']['host'] ?? "";
  794. $token = $data['u8_data']['token'] ?? "";
  795. $url = $host . "/api/SaleOut/Add";
  796. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  797. $json = json_encode($final_data);
  798. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  799. if(!$status) return [false, $result];
  800. if(!isset($result['code'])) return [false, '红字销售出库单生成失败'];
  801. if($result['code'] != 0) return [false, $result['msg']];
  802. return [true, $result];
  803. }
  804. //检验单生成产成品入库单
  805. public function productInByZj($data){
  806. $record = $data['record'];
  807. $payload = $data['payload'];
  808. $id = $record['u8_id'];
  809. $type = $data['type'];
  810. // 数量逻辑判断
  811. $num = ($type == 1) ? (float)$payload['hg_quantity'] : (float)$payload['rb_quantity'];
  812. // 获取单据 产品检验单
  813. $service = new U8ThirtyPartyDatabaseServerService();
  814. list($status, $order) = $service->getJyOrder($id);
  815. if(! $status) return [false, $order];
  816. // 获取单据 生产订单子表 (用于获取生产订单累计数量 iNQuantity)
  817. list($status, $product_detail) = $service->getScDetails($order['SOURCEID']);
  818. if(! $status) return [false, $product_detail];
  819. // u8 token 获取
  820. list($status, $msg) = $this->getToken();
  821. if(! $status) return [false, $msg];
  822. // 组织 ProductIn 结构
  823. $tmp = [
  824. "Inum" => "ProductIn",
  825. "Data" => [
  826. "iHead" => [
  827. "cWhCode" => (string)($order['cWhCode'] ?? "06"), // 产成品库
  828. "cRdCode" => "0103", // 入库类别
  829. "cDepCode" => $order['CINSPECTDEPCODE'],
  830. "cMemo" => "接口生成",
  831. "cSource" => "产品检验单",
  832. "cBusType" => "成品入库",
  833. "cMPoCode" => (string)$order['SOURCECODE'], // 生产订单号
  834. "cChkCode" => (string)$order['CCHECKCODE'], // 检验单号
  835. "dDate" => date("Y-m-d"),
  836. "IsVerify" => true,
  837. ],
  838. "iBody" => []
  839. ]
  840. ];
  841. // 组织表体
  842. $tmp["Data"]["iBody"][] = [
  843. "iRowNo" => 1,
  844. "cInvCode" => (string)($order['CINVCODE'] ?? ''),
  845. "iinvexchrate" => (float)($order['FCHANGRATE'] ?? 0), // 换算率转为数字
  846. "iQuantity" => (float)$num, // 本次入库数量
  847. "iNQuantity" => (float)($product_detail['Qty'] ?? 0), // 生产订单总数量
  848. "iNum" => 0, // 辅计数量
  849. "iNNum" => 0, // 生产订单辅计总数量
  850. "iMPoIds" => (int)($order['SOURCEAUTOID'] ?? 0), // 生产订单子表ID,必须是整型
  851. "cBatch" => (string)($order['CBATCH'] ?? ''),
  852. "dMadeDate" => (string)($order['DPRODATE'] ?? ''),
  853. "dVDate" => (string)($order['DVDATE'] ?? ''),
  854. 'cFree1' => $order['CFREE1'] ?? null,
  855. 'cFree2' => $order['CFREE2'] ?? null,
  856. ];
  857. $final_data = [$tmp];
  858. // 调用参数
  859. $host = $msg['host'] ?? "";
  860. $token = $msg['token'] ?? "";
  861. $url = $host . "/api/ProductIn/Add";
  862. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  863. $json = json_encode($final_data);
  864. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  865. if(! $status) return [false, $result];
  866. if(! isset($result['code'])) return [false, '产成品入库单生成失败'];
  867. if($result['code'] != 0) return [false, $result['msg']];
  868. return [true, ''];
  869. }
  870. //检验单生成其他入库单
  871. public function otherInByZj($data){
  872. $record = $data['record'];
  873. $payload = $data['payload'];
  874. $id = $record['u8_id'];
  875. $num = $payload['hg_not_quantity'];
  876. //获取单据 检验单
  877. $service = new U8ThirtyPartyDatabaseServerService();
  878. list($status, $order) = $service->getJyOrder($id);
  879. if(! $status) return [false, $order];
  880. //u8 token
  881. list($status, $msg) = $this->getToken();
  882. if(! $status) return [false, $msg];
  883. $tmp = [
  884. "Inum" => "OtherIn",
  885. "Data" => [
  886. "iHead" => [
  887. "IsVerify" => true,
  888. "cWhCode" => "53", // 成品不良品库
  889. "cRdCode" => '0109', // 入库类别 其他入库
  890. "cDepCode" => '', // 部门
  891. "cMemo" => "接口生成",
  892. "dDate" => date("Y-m-d"),
  893. ],
  894. "iBody" => []
  895. ]
  896. ];
  897. //一个检验单只有一行
  898. $tmp["Data"]["iBody"][] = [
  899. "iRowNo" => 1,
  900. "cInvCode" => $order['CINVCODE'] ?? '',
  901. "cAssUnit" => $order['CUNITID'] ?? '',
  902. "cPosition" => $order['cPosition'] ?? '',
  903. "cBatch" => $order['CBATCH'] ?? '',
  904. "iinvexchrate" => $order['FCHANGRATE'] ?? 0,
  905. "iQuantity" => $num, // 数量
  906. "dMadeDate" => $order['DPRODATE'] ?? '', // 生产日期
  907. "dVDate" => $order['DVDATE'] ?? '',
  908. 'cFree1' => $order['CFREE1'] ?? null,
  909. 'cFree2' => $order['CFREE2'] ?? null,
  910. ];
  911. $final_data = [$tmp];
  912. //调用所需
  913. $host = $msg['host'] ?? "";
  914. $token = $msg['token'] ?? "";
  915. //产成品入库单生成
  916. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  917. $url = $host . "/api/OtherIn/Add";
  918. $json = json_encode($final_data);
  919. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  920. if(! $status) return [false, $result];
  921. if(! isset($result['code'])) return [false, '其他入库单生成并审核失败'];
  922. if($result['code'] != 0) return [false, $result['msg']];
  923. return [true, ''];
  924. }
  925. public function purchaseInByZj($data)
  926. {
  927. $record = $data['record'];
  928. $payload = $data['payload'];
  929. $type = $data['type'];
  930. // 确定入库数量
  931. $num = ($type == 1) ? (float)$payload['hg_quantity'] : (float)$payload['rb_quantity'];
  932. // 1. 获取基础数据 (检验单信息)
  933. $service = new U8ThirtyPartyDatabaseServerService();
  934. list($status, $order) = $service->getJyOrder2($record['u8_id']);
  935. if(! $status || empty($order)) return [false, '检验单不存在'];
  936. // 2. 获取 U8 Token
  937. list($status, $msg) = $this->getToken();
  938. if(! $status) return [false, $msg];
  939. // --- 核心金额计算逻辑 ---
  940. $qty = (float)$num;
  941. $taxRate = (float)($order['iTaxRate'] ?? 13.0); // 税率
  942. $taxUnitPrice = (float)($order['iOriTaxCost'] ?? 0); // 原币含税单价
  943. // 1. 价税合计 (iSum)
  944. $iSum = round($qty * $taxUnitPrice, 2);
  945. // 2. 原币无税金额 (imoney) = 价税合计 / (1 + 税率/100)
  946. $iMoney = round($iSum / (1 + ($taxRate / 100)), 2);
  947. // 3. 税额 (itax)
  948. $iTax = round($iSum - $iMoney, 2);
  949. // 4. 原币无税单价 (iunitprice)
  950. $iUnitPrice = round($taxUnitPrice / (1 + ($taxRate / 100)), 6);
  951. // 3. 组织采购入库单
  952. $tmp = [
  953. "Inum" => "PurchaseIn",
  954. "Data" => [
  955. "iHead" => [
  956. "IsVerify" => true,
  957. "bCalPrice" => true, // 开启自动计算
  958. "PriceCalKey" => "iOriTaxCost", // 以含税单价为准
  959. "cWhCode" => (string)($order['CWHCODE'] ?? "01"),
  960. "cDepCode" => (string)($order['CDEPCODE']),
  961. "cVenCode" => (string)$order['CVENCODE'],
  962. "cRdCode" => "0101",
  963. "iExchRate" => (float)($order['IEXCHRATE'] ?? 1.0),
  964. "iTaxRate" => (float)$taxRate,
  965. "cExch_Name" => "人民币",
  966. "cSource" => "来料检验单",
  967. "cBusType" => "普通采购",
  968. "cMemo" => "接口生成",
  969. "dDate" => date("Y-m-d"),
  970. "cChkCode" => (string)$order['CCHECKCODE']
  971. ],
  972. "iBody" => [
  973. [
  974. "iRowNo" => 1,
  975. "cInvCode" => (string)$order['CINVCODE'],
  976. "iQuantity" => (float)$qty,
  977. "iNum" => 0,
  978. "iNQuantity" => (float)($order['IQUANTITY'] ?? $qty),
  979. "iNNum" => 0,
  980. "iArrsId" => (int)$order['SOURCEAUTOID'], // 强制转 int,关联到货单子表
  981. // --- 新增价格字段 ---
  982. "iOriTaxCost" => (float)$taxUnitPrice, // 原币含税单价
  983. "iOriCost" => (float)$iUnitPrice, // 原币无税单价
  984. "iOriMoney" => (float)$iMoney, // 原币无税金额
  985. "iOriTaxPrice" => (float)$iTax, // 原币税额
  986. "iOriSum" => (float)$iSum, // 原币价税合计
  987. "iTaxRate" => (float)$taxRate, // 税率
  988. // 本币字段 (inat...) 建议也加上,防止 U8 换算误差
  989. "fNatMoney" => (float)$iMoney, // 本币无税金额
  990. "fNatTax" => (float)$iTax, // 本币税额
  991. "fNatSum" => (float)$iSum, // 本币价税合计
  992. "cBatch" => (string)($order['CBATCH'] ?? ''),
  993. "dMadeDate" => (string)($order['DPRODATE'] ?? ''),
  994. "dVDate" => (string)($order['DVDATE'] ?? ''),
  995. 'cFree1' => $order['CFREE1'] ?? null,
  996. 'cFree2' => $order['CFREE2'] ?? null,
  997. ]
  998. ]
  999. ]
  1000. ];
  1001. // 3. 组织采购入库单 (参照来料检验单模式)
  1002. // $tmp = [
  1003. // "Inum" => "PurchaseIn",
  1004. // "Data" => [
  1005. // "iHead" => [
  1006. // "IsVerify" => true, // 示例中为 false
  1007. // "cWhCode" => (string)($order['CWHCODE'] ?? "01"),
  1008. // "cDepCode" => (string)($order['CDEPCODE']),
  1009. // "cVenCode" => (string)$order['CVENCODE'],
  1010. // "cRdCode" => "0101",
  1011. // "iExchRate" => (float)($order['IEXCHRATE'] ?? 1.0),
  1012. // "iTaxRate" => (float)($order['ITAXRATE'] ?? 13.0),
  1013. // "cExch_Name" => "人民币",
  1014. // "cSource" => "来料检验单", // 匹配示例中的来源
  1015. // "cBusType" => "普通采购",
  1016. // "cMemo" => "接口生成",
  1017. // "dDate" => date("Y-m-d"),
  1018. // "cChkCode" => (string)$order['CCHECKCODE'] // 检验单号
  1019. // ],
  1020. // "iBody" => [
  1021. // [
  1022. // "iRowNo" => 1,
  1023. // "cInvCode" => (string)$order['CINVCODE'],
  1024. // "iQuantity" => (float)$num, // 本次入库实收数量
  1025. // "iNum" => 0,
  1026. // "iNQuantity" => (float)($order['IQUANTITY'] ?? $num), // 检验单关联数量
  1027. // "iNNum" => 0,
  1028. //// "iCheckIdBaks" => (int)$order['ICHECKIDBAKS'],
  1029. // "iArrsId" => $order['SOURCEAUTOID'], // 子表id
  1030. // "cBatch" => (string)($order['CBATCH'] ?? ''),
  1031. // "dMadeDate" => (string)($order['DPRODATE'] ?? ''),
  1032. // "dVDate" => (string)($order['DVDATE'] ?? ''),
  1033. // ]
  1034. // ]
  1035. // ]
  1036. // ];
  1037. $final_data = [$tmp];
  1038. // 4. 调用 API
  1039. $host = $msg['host'] ?? "";
  1040. $token = $msg['token'] ?? "";
  1041. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1042. $url = $host . "/api/PurchaseIn/Add";
  1043. $json = json_encode($final_data);
  1044. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1045. if(! $status) return [false, $result];
  1046. if(! isset($result['code'])) return [false, '采购入库单生成失败'];
  1047. if($result['code'] != 0) return [false, $result['msg']];
  1048. return [true, ''];
  1049. }
  1050. public function post_helper1($url, $data, $header = [], $timeout = 20){
  1051. Log::channel('apiLog')->info('POST', ["api" => $url , "param" => json_decode($data,true) ,"header" => $header]);
  1052. $ch = curl_init();
  1053. curl_setopt($ch, CURLOPT_URL, $url);
  1054. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1055. curl_setopt($ch, CURLOPT_ENCODING, '');
  1056. curl_setopt($ch, CURLOPT_POST, 1);
  1057. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
  1058. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  1059. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  1060. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  1061. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
  1062. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
  1063. if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  1064. $r = curl_exec($ch);
  1065. if ($r === false) {
  1066. // 获取错误号
  1067. $errorNumber = curl_errno($ch);
  1068. // 获取错误信息
  1069. $errorMessage = curl_error($ch);
  1070. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  1071. Log::channel('apiLog')->info('POST结果', ["message" => $message ]);
  1072. return [false, $message];
  1073. }
  1074. curl_close($ch);
  1075. $return = json_decode($r, true);
  1076. unset($r);
  1077. Log::channel('apiLog')->info('POST结果', ["message" => $return ]);
  1078. return [true, $return];
  1079. }
  1080. function validateProductDate($dateStr) {
  1081. // SQL Server 常用的 datetime 格式包含 .v (毫秒)
  1082. // 注意:这里的格式必须严格对应 " 2025-12-13 00:00:00.000"
  1083. // 如果字符串开头有空格,格式字符串里也要留空格
  1084. $format = 'Y-m-d H:i:s.v';
  1085. $d = \DateTime::createFromFormat($format, $dateStr);
  1086. // 检查是否转换成功,并且转换后的格式与原字符串完全一致
  1087. return $d && $d->format($format) === $dateStr;
  1088. }
  1089. /**
  1090. * 校验并格式化日期
  1091. * 如果日期合法,返回格式化后的字符串;如果不合法,返回 false
  1092. */
  1093. public function formatAndValidateDate($dateStr) {
  1094. try {
  1095. // DateTime 构造函数会自动识别多种日期格式
  1096. // trim($dateStr) 用于去除可能存在的首尾空格
  1097. $d = new \DateTime(trim($dateStr));
  1098. // 统一转换为 SQL Server 喜欢的格式: 2026-03-11 00:00:00.000
  1099. return $d->format('Y-m-d H:i:s.v');
  1100. } catch (\Exception $e) {
  1101. // 如果传入的字符串无法解析为日期,会抛出异常
  1102. return false;
  1103. }
  1104. }
  1105. }