U8ThirdPartyService.php 79 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920
  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";
  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. public function purchaseIn1($data){
  85. if(empty($data['orderId'])) return [false, '采购到货单ID不能为空'];
  86. if(empty($data['orderNo'])) return [false, '采购到货单单号不能为空'];
  87. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  88. //获取采购到货单明细
  89. $service = new U8ThirtyPartyDatabaseServerService();
  90. $details_map = $service->getCGDHDetail1s($data['orderId']);
  91. if(empty($details_map)) return [false, '采购到货单明细不存在'];
  92. $existingLineNums = array_column($data['detail'], 'lineNum');
  93. $maxLineNum = empty($existingLineNums) ? 0 : max($existingLineNums);
  94. $body = [];
  95. $seenLineNums = []; // 用于记录已经处理过的原始行号
  96. foreach ($data['detail'] as $key => $value) {
  97. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  98. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  99. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  100. if(empty($value['productDate']) || ! $this->validateProductDate($value['productDate'])) return [false, '生产日期为空或格式错误'];
  101. if(empty($value['failureDate']) || ! $this->validateProductDate($value['failureDate'])) return [false, '失效日期为空或格式错误'];
  102. if(empty($value['lot'])) return [false, '批号不能为空'];
  103. if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  104. $currentLineNum = $value['lineNum'];
  105. // 2. 判断行号是否重复
  106. if (in_array($currentLineNum, $seenLineNums)) {
  107. $maxLineNum++;
  108. $currentLineNum = $maxLineNum;
  109. $editProp = 'A'; // 或者根据你的需求设为空或其他标志
  110. $o_tmp = $details_map[$value['materialCode']] ?? [];
  111. } else {
  112. $seenLineNums[] = $currentLineNum;
  113. $editProp = 'M';
  114. }
  115. // 3. 组织最终数据
  116. $body[] = [
  117. 'ivouchrowno' =>$currentLineNum,
  118. 'dPDate' => $value['productDate'],
  119. 'dVDate' => $value['failureDate'],
  120. 'cBatch' => $value['lot'],
  121. 'iQuantity' => $value['iQuantity'],
  122. 'editprop' => $editProp,
  123. ];
  124. }
  125. //调用所需
  126. $host = $data['u8_data']['host'];
  127. $token = $data['u8_data']['token'];
  128. //采购到货单弃审
  129. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  130. $url = $host . "/api/PuArrVouch/UnVerify";
  131. $json = [
  132. "VouchId" => $data['orderId'],
  133. ];
  134. $json = json_encode($json);
  135. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  136. if(! $status) return [false, $result];
  137. if(! isset($result['code'])) return [false, '采购到货单弃审失败'];
  138. if($result['code'] != 0) return [false, $result['msg']];
  139. //采购到货单编辑并审核
  140. $url = $host . "/api/PuArrVouch/Update";
  141. $json_final[] = [
  142. "Inum" => "PuArrVouch",
  143. "data" =>[
  144. "iHead" => [
  145. "cCode" => $data['orderNo'],
  146. "IsVerify" => true,
  147. "debug" => true,
  148. ],
  149. "iBody" => $body,
  150. ],
  151. ];
  152. $json = json_encode($json_final);
  153. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  154. if(! $status) return [false, $result];
  155. if(! isset($result['code'])) return [false, '采购到货单编辑并审核失败'];
  156. if($result['code'] != 0) return [false, $result['msg']];
  157. return [true, ''];
  158. }
  159. /**
  160. * 采购到货单拆行/更新处理
  161. */
  162. public function purchaseIn($data)
  163. {
  164. if (empty($data['orderId'])) return [false, '采购到货单ID不能为空'];
  165. if (empty($data['orderNo'])) return [false, '采购到货单单号不能为空'];
  166. if (empty($data['detail'])) return [false, '表体信息detail不能为空'];
  167. // 1. 获取到货单明细
  168. $service = new U8ThirtyPartyDatabaseServerService();
  169. $result = $service->getCGDHDetails($data['orderId']);
  170. if (empty($result)) return [false, '采购到货单明细不存在'];
  171. // 取出第一行作为模板,保留 ID, cCode 等主表关联信息
  172. $templateRow = reset($result);
  173. $mainId = $templateRow['ID'];
  174. // 2. 存货管控校验(批次/保质期)
  175. list($status, $msg) = $service->checkInventoryControl(array_column($data['detail'], 'materialCode'));
  176. if (!$status) return [false, $msg];
  177. $insertData = [];
  178. $rowNo = 1;
  179. foreach ($data['detail'] as $value) {
  180. if (!isset($result[$value['materialCode']])) continue;
  181. $map = $result[$value['materialCode']]; // 获取原始行信息(单价、税率等)
  182. // 计算单价
  183. $oldQty = (float)($map['iQuantity'] ?? 0);
  184. if ($oldQty <= 0) continue;
  185. $unitPrice = (float)$map['iOriSum'] / $oldQty;
  186. $unitMoney = (float)$map['iOriMoney'] / $oldQty;
  187. $unitLocalSum = (float)$map['iSum'] / $oldQty;
  188. $unitLocalMoney = (float)$map['iMoney'] / $oldQty;
  189. $newQty = (float)$value['iQuantity'];
  190. // 组织新行数据
  191. $newRow = $map;
  192. // 清理旧行主键和业务累积状态(关键!)
  193. unset($newRow['Autoid']);
  194. $newRow['fInspectQuantity'] = 0; // 已报检量清零
  195. $newRow['fValidQuantity'] = 0; // 合格量清零
  196. $newRow['iQuantity'] = $newQty;
  197. $newRow['ivouchrowno'] = $rowNo++; // 重新排序行号
  198. // 填充计算后的金额和批次日期
  199. $newRow['iOriMoney'] = round($unitMoney * $newQty, 2);
  200. $newRow['iOriSum'] = round($unitPrice * $newQty, 2);
  201. $newRow['iOriTaxPrice'] = round(($unitPrice - $unitMoney) * $newQty, 2);
  202. $newRow['iMoney'] = round($unitLocalMoney * $newQty, 2);
  203. $newRow['iSum'] = round($unitLocalSum * $newQty, 2);
  204. $newRow['iTaxPrice'] = round(($unitLocalSum - $unitLocalMoney) * $newQty, 2);
  205. $newRow['cBatch'] = $value['lot'];
  206. $newRow['dPDate'] = $this->formatAndValidateDate($value['productDate']);
  207. $newRow['dVDate'] = $this->formatAndValidateDate($value['failureDate']);
  208. $insertData[] = $newRow;
  209. }
  210. // 3. 执行数据库操作:先删后插
  211. list($status, $msg) = $service->rebuildDhDetails($mainId, $insertData);
  212. if (!$status) return [false, $msg];
  213. //查询采购到货单
  214. $order = $service->getCgOrder($data['orderId']);
  215. if(empty($order)) return [false, '采购到货单不存在'];
  216. //生成来料报检单
  217. $inspect = [
  218. "Inum" => "ArrInspect",
  219. "Data" => [
  220. "iHead" => [
  221. // 注意:这里使用的是主表的 ID
  222. "CSOURCEID" => $order['ID'],
  223. "CDEPCODE" => $order['cDepCode'],
  224. "DDATE" => date("Y-m-d"),
  225. "CCHECKTYPECODE" => 'ARR',
  226. ],
  227. "iBody" => []
  228. ]
  229. ];
  230. foreach ($order['details'] as $item) {
  231. $qty = (float)($item['iQuantity'] ?? 0);
  232. if ($qty <= 0) continue;
  233. $inspect["Data"]["iBody"][] = [
  234. "SOURCEAUTOID" => $item['Autoid'],
  235. "ITESTSTYLE" => 0,
  236. "CINVCODE" => $item['cInvCode'],
  237. "FCHANGRATE" => (float)($item['iInvExchRate'] ?? 0),
  238. "FQUANTITY" => $qty,
  239. "CBATCH" => $item['cBatch'],
  240. 'DPRODATE' => $item['dPDate'],
  241. 'DVDATE' => $item['dVDate'],
  242. ];
  243. }
  244. // 4. 封装成数组返回
  245. $final_data = [$inspect];
  246. //调用所需
  247. $host = $data['u8_data']['host'];
  248. $token = $data['u8_data']['token'];
  249. //报检单
  250. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  251. $url = $host . "/api/QmArr/ArrInspectAdd";
  252. $json = json_encode($final_data);
  253. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  254. if(! $status) return [false, $result];
  255. if(! isset($result['code'])) return [false, '报检单生成失败'];
  256. if($result['code'] != 0) return [false, $result['msg']];
  257. return [true, ''];
  258. }
  259. public function materialOut($data)
  260. {
  261. if (empty($data['orderId'])) return [false, '领料申请单ID不能为空'];
  262. if (empty($data['orderNo'])) return [false, '领料申请单单号不能为空'];
  263. if (empty($data['warehouseCode'])) return [false, '仓库不能为空'];
  264. if (empty($data['detail'])) return [false, '表体信息detail不能为空'];
  265. // 1. 获取领料申请单明细
  266. $service = new U8ThirtyPartyDatabaseServerService();
  267. $result = $service->getLlSQDetails($data['orderId']);
  268. if (empty($result)) return [false, '领料申请单明细不存在'];
  269. // 取出第一行作为模板,获取主表 ID
  270. $templateRow = reset($result);
  271. $mainId = $templateRow['ID'];
  272. // 2. 存货管控校验(批次/保质期)
  273. list($status, $msg) = $service->checkInventoryControl(array_column($data['detail'], 'materialCode'));
  274. if (!$status) return [false, $msg];
  275. $insertData = [];
  276. $rowNo = 1;
  277. foreach ($data['detail'] as $value) {
  278. if (!isset($result[$value['materialCode']])) continue;
  279. // 获取原始行(保留生产订单关联 morderdid、仓库 cwhcode 等信息)
  280. $map = $result[$value['materialCode']];
  281. $newQty = (float)$value['iQuantity'];
  282. // 组织新行数据
  283. $newRow = $map;
  284. // 清理主键
  285. unset($newRow['AutoID']);
  286. $newRow['iQuantity'] = $newQty; // 申请数量
  287. $newRow['irowno'] = $rowNo++; // 重新排序行号
  288. $newRow['cBatch'] = $value['lot']; // 批号
  289. // 生产日期与失效日期 (U8 领料申请单通常字段名为 dMadeDate 和 dVDate 或 dmadedate)
  290. $newRow['dMadeDate'] = !empty($value['productDate']) ? $this->formatAndValidateDate($value['productDate']) : null;
  291. $newRow['dVDate'] = !empty($value['failureDate']) ? $this->formatAndValidateDate($value['failureDate']) : null;
  292. $insertData[] = $newRow;
  293. }
  294. // 3. 执行数据库操作:先删后插
  295. list($status, $msg) = $service->rebuildLLDetails($mainId, $insertData);
  296. if (!$status) return [false, $msg];
  297. //查询领料申请单
  298. $order = $service->getLLOrder($data['orderId']);
  299. if(empty($order)) return [false, '领料单不存在'];
  300. //仓库区分出入库类别
  301. if($data['warehouseCode'] == "01"){
  302. $cRdCode = "0201";
  303. }else{
  304. $cRdCode = "0203";
  305. }
  306. $materialOut = [
  307. "Inum" => "MaterialOut",
  308. "Data" => [
  309. "iHead" => [
  310. "IsVerify" => true,
  311. "cWhCode" => $data['warehouseCode'], // 仓库
  312. "cVouchType" => "11",
  313. "cRdCode" => $cRdCode, // 出入库类别
  314. "cDepCode" => $order['cDepCode'], // 领用部门
  315. "cSource" => "领料申请单",
  316. "cBusCode" => $order['cCode'], // 领料申请单单号
  317. "cBusType" => "领料",
  318. "cMemo" => "接口生成",
  319. "dDate" => date("Y-m-d"),
  320. ],
  321. "iBody" => []
  322. ]
  323. ];
  324. foreach ($order['details'] as $index => $item) {
  325. // 这里的数量取值要对应你 getLLOrder 查出来的字段名,通常是 fQty
  326. $qty = $item['iQuantity'];
  327. if ($qty <= 0) continue;
  328. $materialOut["Data"]["iBody"][] = [
  329. "iRowNo" => $index + 1,
  330. "cInvCode" => $item['cInvCode'],
  331. "cBatch" => $item['cBatch'], // 批号
  332. "iQuantity" => $qty, // 实际出库数量
  333. "iNQuantity" => $qty, // 实收数量
  334. "iinvexchrate" => (float)($item['iinvexchrate'] ?? 1),
  335. "iMaIDs" => $item['AutoID'],
  336. "dMadeDate" => $item['dMadeDate'], // 生产日期
  337. "dVDate" => $item['dVDate'], // 失效日期
  338. ];
  339. }
  340. // 封装成数组返回
  341. $final_data = [$materialOut];
  342. //调用所需
  343. $host = $data['u8_data']['host'];
  344. $token = $data['u8_data']['token'];
  345. //材料出库单
  346. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  347. $url = $host . "/api/MaterialOut/Add";
  348. $json = json_encode($final_data);
  349. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  350. if(! $status) return [false, $result];
  351. if(! isset($result['code'])) return [false, '材料出库单生成失败'];
  352. if($result['code'] != 0) return [false, $result['msg']];
  353. return [true, ''];
  354. }
  355. //采购到货单弃审的版本
  356. public function materialOut1($data){
  357. if(empty($data['orderId'])) return [false, '领料申请单ID不能为空'];
  358. if(empty($data['orderNo'])) return [false, '领料申请单单号不能为空'];
  359. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  360. $body = [];
  361. foreach ($data['detail'] as $key => $value){
  362. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  363. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  364. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  365. if(empty($value['productDate']) || ! $this->validateProductDate($value['productDate'])) return [false, '生产日期为空或格式错误'];
  366. if(empty($value['failureDate']) || ! $this->validateProductDate($value['failureDate'])) return [false, '失效日期为空或格式错误'];
  367. if(empty($value['lot'])) return [false, '批号不能为空'];
  368. $body[] = [
  369. 'ivouchrowno' => $value['lineNum'],
  370. 'dPDate' => $value['productDate'],
  371. 'dVDate' => $value['failureDate'],
  372. 'cBatch' => $value['lot'],
  373. 'editprop' => 'M',
  374. ];
  375. }
  376. //调用所需
  377. $host = $data['u8_data']['host'];
  378. $token = $data['u8_data']['token'];
  379. //采购到货单弃审
  380. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  381. $url = $host . "/api/PuArrVouch/UnVerify";
  382. $json = [
  383. "VouchId" => $data['orderId'],
  384. ];
  385. $json = json_encode($json);
  386. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  387. if(! $status) return [false, $result];
  388. if(! isset($result['code'])) return [false, '采购到货单弃审失败'];
  389. if($result['code'] != 0) return [false, $result['msg']];
  390. //采购到货单编辑并审核
  391. $url = $host . "/api/PuArrVouch/Update";
  392. $json_final[] = [
  393. "Inum" => "PuArrVouch",
  394. "data" =>[
  395. "iHead" => [
  396. "cCode" => $data['orderNo'],
  397. "IsVerify" => true,
  398. "debug" => true,
  399. ],
  400. "iBody" => $body,
  401. ],
  402. ];
  403. $json = json_encode($json_final);
  404. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  405. if(! $status) return [false, $result];
  406. if(! isset($result['code'])) return [false, '采购到货单编辑并审核失败'];
  407. if($result['code'] != 0) return [false, $result['msg']];
  408. return [true, ''];
  409. }
  410. public function purchaseReturn($data){
  411. if(empty($data['orderId'])) return [false, '采购退货单ID不能为空'];
  412. // 1. 获取到货单(退货单)及明细
  413. $service = new U8ThirtyPartyDatabaseServerService();
  414. $order = $service->getArrivalVouchById($data['orderId']);
  415. if(empty($order)) return [false, '采购退货单数据不存在'];
  416. // 获取 Token 相关信息
  417. $host = $data['u8_data']['host'] ?? "";
  418. $token = $data['u8_data']['token'] ?? "";
  419. // 2. 组织单一仓库的红字采购入库单
  420. $iBody = [];
  421. foreach ($order['details'] as $index => $item) {
  422. // 强制转为负数,生成红字入库单
  423. $qty = abs((float)$item['iQuantity']) * -1;
  424. $iBody[] = [
  425. "iRowNo" => $index + 1,
  426. "cInvCode" => $item['cInvCode'],
  427. "cBatch" => $item['cBatch'] ?? '',
  428. "iinvexchrate" => (float)($item['iinvexchrate'] ?? 1),
  429. "iQuantity" => $qty, // 负数
  430. "iNQuantity" => $qty, // 负数
  431. "iArrsId" => $item['iArrsId'],
  432. "dMadeDate" => $item['dPDate'],
  433. "dVDate" => $item['dVDate'],
  434. "iTaxRate" => $item['iTaxRate'] ?? 0,
  435. "iTaxUnitPrice"=> $item['iOriTaxCost'] ?? 0,
  436. ];
  437. }
  438. if(empty($iBody)) return [false, '表体明细为空'];
  439. $final_data = [
  440. [
  441. "Inum" => "PurchaseIn",
  442. "Data" => [
  443. "iHead" => [
  444. "IsVerify" => true,
  445. "bIsRedVouch" => true, // 必须为红字
  446. "bCalPrice" => true, // 自动计算金额
  447. "cWhCode" => "01",
  448. "cRdCode" => $order['rd_code'],
  449. "cDepCode" => $order['depart_code'],
  450. "cARVCode" => $order['no'], // 关联来源单号
  451. "cSource" => "采购到货单", // 即使是退货单,参照来源也写这个
  452. "cBusType" => "普通采购",
  453. "cMemo" => "接口生成",
  454. "dDate" => date("Y-m-d"),
  455. "iExchRate"=> 1,
  456. ],
  457. "iBody" => $iBody
  458. ]
  459. ]
  460. ];
  461. // 3. 调用 API
  462. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  463. $url = $host . "/api/PurchaseIn/Add";
  464. $json = json_encode($final_data);
  465. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  466. if(! $status) return [false, $result];
  467. if(! isset($result['code'])) return [false, '红字采购入库单生成失败'];
  468. if($result['code'] != 0) return [false, $result['msg']];
  469. return [true, ''];
  470. }
  471. public function productIn($data){
  472. if(empty($data['orderId'])) return [false, '产品报检单ID不能为空'];
  473. if(empty($data['orderNo'])) return [false, '产品报检单单号不能为空'];
  474. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  475. // 1. 获取报检单明细 (建议 getBjOrder 返回以 cInvCode 为 key 的数组)
  476. $service = new U8ThirtyPartyDatabaseServerService();
  477. $result = $service->getBjOrder($data['orderId']);
  478. if (empty($result)) return [false, '报检单明细不存在'];
  479. // 取出第一行作为模板,获取主表 ID
  480. $templateRow = reset($result);
  481. $mainId = $templateRow['ID'];
  482. // 2. 存货管控校验(批次/保质期)
  483. list($status, $msg) = $service->checkInventoryControl(array_column($data['detail'], 'materialCode'));
  484. if (!$status) return [false, $msg];
  485. $insertData = [];
  486. $rowNo = 1;
  487. foreach ($data['detail'] as $value) {
  488. if (!isset($result[$value['materialCode']])) continue;
  489. // 获取原始行(保留来源单据关联,如采购到货单行 AutoID 等)
  490. $map = $result[$value['materialCode']];
  491. $newQty = (float)$value['iQuantity'];
  492. // 组织新行数据
  493. $newRow = $map;
  494. // 清理子表主键
  495. unset($newRow['AUTOID']);
  496. // --- 核心字段修正 (报检单子表字段通常为大写) ---
  497. $newRow['FQUANTITY'] = $newQty; // 报检数量
  498. $newRow['CBATCH'] = $value['lot']; // 批号
  499. // 报检单的日期字段通常是 DPRODATE (生产日期) 和 DVDATE (失效日期)
  500. $newRow['DPRODATE'] = !empty($value['productDate']) ? $this->formatAndValidateDate($value['productDate']) : null;
  501. $newRow['DVDATE'] = !empty($value['failureDate']) ? $this->formatAndValidateDate($value['failureDate']) : null;
  502. $insertData[] = $newRow;
  503. }
  504. // 3. 执行数据库操作:先删后插
  505. list($status, $msg) = $service->rebuildBjDetails($mainId, $insertData);
  506. if (!$status) return [false, $msg];
  507. // $service = new U8ThirtyPartyDatabaseServerService();
  508. // $result = $service->getBjOrder($data['orderId']);
  509. //
  510. // $tmp = $update = $insert = [];
  511. // foreach ($data['detail'] as $key => $value) {
  512. // if(empty($value['lineNum'])) return [false, '行号不能为空'];
  513. // if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  514. // if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  515. // if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  516. // $return = $this->formatAndValidateDate($value['productDate']);
  517. // if(! $return) return [false, '生产日期格式错误'];
  518. // $productDate = $return;
  519. // if(empty($value['failureDate'])) return [false, '失效日期不能为空'];
  520. // $return = $this->formatAndValidateDate($value['failureDate']);
  521. // if(! $return) return [false, '生产日期格式错误'];
  522. // $failureDate= $return;
  523. // if(empty($value['lot'])) return [false, '批号不能为空'];
  524. // if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  525. //
  526. // if(isset($result[$value['materialCode']])){
  527. // $map = $result[$value['materialCode']];
  528. // $update_detail = [
  529. // 'CBATCH' => $value['lot'],
  530. // 'FQUANTITY' => $value['iQuantity'],
  531. // 'DPRODATE' => $productDate,
  532. // 'DVDATE' => $failureDate,
  533. // ];
  534. // if(! isset($tmp[$value['materialCode']])){
  535. // $update[$map['AUTOID']] = $update_detail;
  536. // $tmp[$value['materialCode']] = $value['materialCode'];
  537. // }else{
  538. // $map['AUTOID'] = null;
  539. // $insert[] = array_merge($map, $update_detail);
  540. // }
  541. // }
  542. // }
  543. //
  544. // list($status,$msg) = $service->checkInventoryControl(array_values(array_column($data['detail'],'materialCode')));
  545. // if(! $status) return [false, $msg];
  546. //
  547. // list($status, $msg) = $service->updateBjOrder($update, $insert);
  548. // if(! $status) return [false, $msg];
  549. return [true, ''];
  550. }
  551. public function saleOut($data){
  552. if(empty($data['orderId'])) return [false, '销售订单ID不能为空'];
  553. if(empty($data['orderNo'])) return [false, '销售订单号不能为空'];
  554. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  555. //获取销售订单信息
  556. $service = new U8ThirtyPartyDatabaseServerService();
  557. $order = $service->getXsOrder($data['orderId']);
  558. if(empty($order)) return [false, '销售订单不存在'];
  559. $detail_map = [];
  560. foreach ($data['detail'] as $key => $value) {
  561. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  562. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  563. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  564. if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  565. $return = $this->formatAndValidateDate($value['productDate']);
  566. if(! $return) return [false, '生产日期格式错误'];
  567. $productDate = $return;
  568. if(empty($value['failureDate'])) return [false, '失效日期不能为空'];
  569. $return = $this->formatAndValidateDate($value['failureDate']);
  570. if(! $return) return [false, '生产日期格式错误'];
  571. $failureDate= $return;
  572. if(empty($value['lot'])) return [false, '批号不能为空'];
  573. if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  574. $detail_map[$value['materialCode']][] = [
  575. 'productDate' => $productDate,
  576. 'failureDate' => $failureDate,
  577. 'lot' => $value['lot'],
  578. 'iQuantity' => $value['iQuantity'],
  579. ];
  580. }
  581. // 2. 组织发货单 (DispatchList) 结构
  582. $tmp = [
  583. "Inum" => "DispatchList",
  584. "Data" => [
  585. "iHead" => [
  586. "cVouchType" => "05",
  587. "cSTCode" => (string)($order['cSTCode'] ?? "02"), // 示例中是02
  588. "cDepCode" => (string)($order['cDepCode'] ?? "01"),
  589. "IsVerify" => true,
  590. "cMemo" => "接口生成",
  591. "dDate" => date("Y-m-d"),
  592. "cSoCode" => (string)$order['cSOCode'],
  593. "ccuscode" => (string)$order['cCusCode'],
  594. "cexch_name" => (string)($order['cexch_name'] ?? "人民币"),
  595. "iexchrate" => (float)($order['iExchRate'] ?? 1.0), // 强制转浮点,去掉引号
  596. "iTaxRate" => (float)($order['iTaxRate'] ?? 13.0), // 强制转浮点
  597. ],
  598. "iBody" => []
  599. ]
  600. ];
  601. // 3. 遍历销售订单明细组织表体
  602. $key = 0;
  603. foreach ($order['details'] as $item) {
  604. $p_t = $detail_map[$item['cInvCode']] ?? [];
  605. if (empty($p_t)) continue;
  606. foreach ($p_t as $value) {
  607. $key++;
  608. $qty = (float)$value['iQuantity'];
  609. $taxRate = (float)($item['iTaxRate'] ?? 13.0);
  610. $taxUnitPrice = (float)$item['iTaxUnitPrice']; // 含税单价 (如 100)
  611. // 价税合计 (iSum)
  612. $iSum = round($qty * $taxUnitPrice, 2);
  613. // 无税金额 (imoney) = 价税合计 / (1 + 税率/100)
  614. $iMoney = round($iSum / (1 + ($taxRate / 100)), 2);
  615. // 税额 (itax)
  616. $iTax = round($iSum - $iMoney, 2);
  617. // 无税单价 (iunitprice)
  618. $iUnitPrice = round($taxUnitPrice / (1 + ($taxRate / 100)), 10);
  619. $tmp["Data"]["iBody"][] = [
  620. "iRowNo" => (int)$key, // 强制转整型
  621. "cInvCode" => (string)$item['cInvCode'],
  622. "iTaxRate" => (float)$taxRate,
  623. "cGroupCode" => (string)($item['cGroupCode'] ?? "01"),
  624. "iGroupType" => "0",
  625. "cUnitID" => (string)($item['cUnitID'] ?? "003"),
  626. "cWhCode" => "06",
  627. "iQuantity" => (float)$qty,
  628. "iNum" => 0, // 辅计量数量
  629. "iSum" => (float)$iSum,
  630. "iInvExchRate" => 1.0, // 换算率,必填
  631. "imoney" => (float)$iMoney,
  632. "itax" => (float)$iTax,
  633. "idiscount" => 0,
  634. "inatmoney" => (float)$iMoney,
  635. "inattax" => (float)$iTax,
  636. "inatdiscount" => 0,
  637. "inatsum" => (float)$iSum,
  638. "itaxunitprice" => (float)$taxUnitPrice,
  639. "iunitprice" => (float)$iUnitPrice,
  640. "inatunitprice" => (float)$iUnitPrice,
  641. "dvDate" => (string)$value['failureDate'], // 示例中只需失效日期
  642. "iSOsID" => (int)$item['iSOsID'], // 强制转整型,去掉引号
  643. "cBatch" => (string)$value['lot']
  644. ];
  645. }
  646. }
  647. $final_data = [$tmp];
  648. //调用所需
  649. $host = $data['u8_data']['host'];
  650. $token = $data['u8_data']['token'];
  651. //销售发货单
  652. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  653. $url = $host . "/api/Dispatch/Add";
  654. $json = json_encode($final_data);
  655. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  656. if(! $status) return [false, $result];
  657. if(! isset($result['code'])) return [false, '销售发货单生成失败'];
  658. if($result['code'] != 0) return [false, $result['msg']];
  659. $first = $result['data'][0];
  660. $id = $first['VouchId'];
  661. // $id = 1000000882;
  662. $fhOrder = $service->getFhOrder($id);
  663. if(empty($fhOrder)) return [false, '销售发货单获取失败'];
  664. // 2. 初始化销售出库单结构
  665. $saleOut = [
  666. "Inum" => "SaleOut",
  667. "Data" => [
  668. "iHead" => [
  669. "IsVerify" => true, // 自动审核
  670. "cWhCode" => "06", // 仓库编码
  671. "cRdCode" => "0299", // 出入库类别编码
  672. "cVouchType" => "32", // 单据类型编码
  673. "cMemo" => "接口生成",
  674. "cSource" => "发货单",
  675. "cSTCode" => $fhOrder['cSTCode'], // 销售类型
  676. "DLCode" => $fhOrder['cDLCode'], // 关联的发货单号
  677. "cDepCode" => $fhOrder['cDepCode'], // 部门
  678. "dDate" => date("Y-m-d"), // 出库日期
  679. ],
  680. "iBody" => []
  681. ]
  682. ];
  683. // 3. 遍历发货单明细组织表体
  684. foreach ($fhOrder['details'] as $index => $item) {
  685. // 计算待出库数量 (总发货数 - 已出库数)
  686. $qty = (float)($item['iQuantity'] ?? 0);
  687. $outQty = (float)($item['fOutQuantity'] ?? 0);
  688. $pendingQty = $qty - $outQty;
  689. // 如果该行已全部出库,则跳过(可选逻辑)
  690. if ($pendingQty <= 0) continue;
  691. $saleOut["Data"]["iBody"][] = [
  692. "iRowNo" => $index + 1,
  693. "cInvCode" => $item['cInvCode'] ?? "",
  694. "cPosition" => $item['cPosition'] ?? "", // 货位
  695. "cBatch" => $item['cBatch'] ?? "", // 批号
  696. "iinvexchrate" => (float)($item['iExchRate'] ?? 1), // 换算率
  697. "iQuantity" => $pendingQty, // 本次出库数量
  698. "iNQuantity" => $pendingQty, // 对应实收数量
  699. "iDLsID" => $item['iDLsID'], // 核心:发货单子表ID
  700. "dMadeDate" => $item['dMDate'], // 生产
  701. "dVDate" => $item['dvDate'], // 失效
  702. "iUnitCost" => (float)($item['iUnitPrice'] ?? 0), // 无税单价
  703. "iPrice" => round((float)($item['iUnitPrice'] ?? 0) * $pendingQty, 2), // 无税金额
  704. ];
  705. }
  706. // 4. 封装成数组
  707. $final_data = [$saleOut];
  708. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  709. $url = $host . "/api/SaleOut/Add";
  710. $json = json_encode($final_data);
  711. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  712. if(! $status) return [false, $result];
  713. if(! isset($result['code'])) return [false, '销售出库单生成失败'];
  714. if($result['code'] != 0) return [false, $result['msg']];
  715. return [true, ''];
  716. }
  717. public function saleOut1($data){
  718. if(empty($data['orderId'])) return [false, '销售订单ID不能为空'];
  719. if(empty($data['orderNo'])) return [false, '销售订单号不能为空'];
  720. if(empty($data['detail'])) return [false, '表体信息detail不能为空'];
  721. //获取销售订单信息
  722. $service = new U8ThirtyPartyDatabaseServerService();
  723. $order = $service->getXsOrder($data['orderId']);
  724. if(empty($order)) return [false, '销售订单不存在'];
  725. $orderItemMap = [];
  726. foreach ($order['details'] as $detail) {
  727. // 这里的 iTaxUnitPrice 是订单里的含税单价
  728. $orderItemMap[$detail['cInvCode']] = [
  729. 'iTaxUnitPrice' => $detail['iTaxUnitPrice'] ?? 0,
  730. 'iTaxRate' => $detail['iTaxRate'] ?? 13,
  731. 'iUnitPrice' => $detail['iUnitPrice'] ?? 0,
  732. ];
  733. }
  734. $detail_map = [];
  735. foreach ($data['detail'] as $key => $value) {
  736. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  737. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  738. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  739. if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  740. $return = $this->formatAndValidateDate($value['productDate']);
  741. if(! $return) return [false, '生产日期格式错误'];
  742. $productDate = $return;
  743. if(empty($value['failureDate'])) return [false, '失效日期不能为空'];
  744. $return = $this->formatAndValidateDate($value['failureDate']);
  745. if(! $return) return [false, '生产日期格式错误'];
  746. $failureDate= $return;
  747. if(empty($value['lot'])) return [false, '批号不能为空'];
  748. if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  749. $detail_map[$value['materialCode']][] = [
  750. 'productDate' => $productDate,
  751. 'failureDate' => $failureDate,
  752. 'lot' => $value['lot'],
  753. 'iQuantity' => $value['iQuantity'],
  754. ];
  755. }
  756. // 2. 组织发货单 (DispatchList) 结构
  757. $tmp = [
  758. "Inum" => "DispatchList",
  759. "Data" => [
  760. "iHead" => [
  761. "cVouchType" => "05",
  762. "cSTCode" => $order['cSTCode'] ?? "01",
  763. "cDepCode" => $order['cDepCode'] ?? "01",
  764. "IsVerify" => true,
  765. "cMemo" => "接口生成",
  766. "dDate" => date("Y-m-d"),
  767. "bCalPrice" => false,
  768. "PriceCalKey" => "iSum",
  769. "iExchRate" => $order['iExchRate'] ?? 1,
  770. "cexch_name" => $order['cexch_name'] ?? "人民币",
  771. "cCusCode" => $order['cCusCode'],
  772. "iTaxRate" => $order['iTaxRate'] ?? 13,
  773. "cinvoicecompany" => $order['cCusCode'],
  774. ],
  775. "iBody" => []
  776. ]
  777. ];
  778. // 3. 组织表体
  779. $rowKey = 0;
  780. foreach ($detail_map as $invCode => $items) {
  781. // 获取该存货在订单里的价格信息
  782. $priceInfo = $orderItemMap[$invCode];
  783. foreach ($items as $value) {
  784. $rowKey++;
  785. $quantity = $value['iQuantity'];
  786. $unitPrice = $priceInfo['iTaxUnitPrice']; // 直接使用订单里的含税单价
  787. // 计算价税合计:数量 * 含税单价
  788. $sum = round($quantity * $unitPrice, 2);
  789. $tmp["Data"]["iBody"][] = [
  790. "iRowNo" => $rowKey,
  791. "cInvCode" => $invCode,
  792. "iTaxRate" => $priceInfo['iTaxRate'],
  793. "cWhCode" => "06",
  794. "iQuantity" => $quantity,
  795. "iSum" => $sum, // 总金额
  796. "iMoney" => $sum,
  797. "cBatch" => $value['lot'],
  798. "dMDate" => $value['productDate'],
  799. "dvDate" => $value['failureDate'],
  800. "iTaxUnitPrice" => $unitPrice, // 含税单价
  801. "iUnitPrice" => $priceInfo['iUnitPrice'], // 原订单无税单价
  802. ];
  803. }
  804. }
  805. // 4. 封装成数组返回
  806. $final_data = [$tmp];
  807. //调用所需
  808. $host = $data['u8_data']['host'];
  809. $token = $data['u8_data']['token'];
  810. //销售发货单
  811. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  812. $url = $host . "/api/Dispatch/Add";
  813. $json = json_encode($final_data);
  814. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  815. if(! $status) return [false, $result];
  816. if(! isset($result['code'])) return [false, '销售发货单生成失败'];
  817. if($result['code'] != 0) return [false, $result['msg']];
  818. $first = $result['data'][0];
  819. $id = $first['VouchId'];
  820. // $id = 1000000882;
  821. $fhOrder = $service->getFhOrder($id);
  822. if(empty($fhOrder)) return [false, '销售发货单获取失败'];
  823. // 2. 初始化销售出库单结构
  824. $saleOut = [
  825. "Inum" => "SaleOut",
  826. "Data" => [
  827. "iHead" => [
  828. "IsVerify" => true, // 自动审核
  829. "cWhCode" => "06", // 仓库编码
  830. "cRdCode" => "0299", // 出入库类别编码
  831. "cVouchType" => "32", // 单据类型编码
  832. "cMemo" => "接口生成",
  833. "cSource" => "发货单",
  834. "cSTCode" => $fhOrder['cSTCode'], // 销售类型
  835. "DLCode" => $fhOrder['cDLCode'], // 关联的发货单号
  836. "cDepCode" => $fhOrder['cDepCode'], // 部门
  837. "dDate" => date("Y-m-d"), // 出库日期
  838. ],
  839. "iBody" => []
  840. ]
  841. ];
  842. // 3. 遍历发货单明细组织表体
  843. foreach ($fhOrder['details'] as $index => $item) {
  844. // 计算待出库数量 (总发货数 - 已出库数)
  845. $qty = (float)($item['iQuantity'] ?? 0);
  846. $outQty = (float)($item['fOutQuantity'] ?? 0);
  847. $pendingQty = $qty - $outQty;
  848. // 如果该行已全部出库,则跳过(可选逻辑)
  849. if ($pendingQty <= 0) continue;
  850. $saleOut["Data"]["iBody"][] = [
  851. "iRowNo" => $index + 1,
  852. "cInvCode" => $item['cInvCode'] ?? "",
  853. "cPosition" => $item['cPosition'] ?? "", // 货位
  854. "cBatch" => $item['cBatch'] ?? "", // 批号
  855. "iinvexchrate" => (float)($item['iExchRate'] ?? 1), // 换算率
  856. "iQuantity" => $pendingQty, // 本次出库数量
  857. "iNQuantity" => $pendingQty, // 对应实收数量
  858. "iDLsID" => $item['iDLsID'], // 核心:发货单子表ID
  859. "dMadeDate" => $item['dMDate'], // 生产
  860. "dVDate" => $item['dvDate'], // 失效
  861. "iUnitCost" => (float)($item['iUnitPrice'] ?? 0), // 无税单价
  862. "iPrice" => round((float)($item['iUnitPrice'] ?? 0) * $pendingQty, 2), // 无税金额
  863. ];
  864. }
  865. // 4. 封装成数组
  866. $final_data = [$saleOut];
  867. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  868. $url = $host . "/api/SaleOut/Add";
  869. $json = json_encode($final_data);
  870. list($status, $result) = $this->post_helper1($url,$json, $header, 30);
  871. if(! $status) return [false, $result];
  872. if(! isset($result['code'])) return [false, '销售出库单生成失败'];
  873. if($result['code'] != 0) return [false, $result['msg']];
  874. return [true, ''];
  875. }
  876. public function otherIn($data) {
  877. // 1. 基础校验
  878. if (empty($data['warehouseCode'])) return [false, '仓库编码不能为空'];
  879. if (empty($data['detail'])) return [false, '明细数据不能为空'];
  880. $iBody = [];
  881. foreach ($data['detail'] as $key => $value) {
  882. if(empty($value['lineNum'])) return [false, '行号不能为空'];
  883. if(! is_numeric($value['lineNum'])) return [false, '行号错误'];
  884. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  885. if(empty($value['productDate'])) return [false, '生产日期不能为空'];
  886. $return = $this->formatAndValidateDate($value['productDate']);
  887. if(! $return) return [false, '生产日期格式错误'];
  888. $productDate = $return;
  889. if(empty($value['failureDate'])) return [false, '失效日期不能为空'];
  890. $return = $this->formatAndValidateDate($value['failureDate']);
  891. if(! $return) return [false, '生产日期格式错误'];
  892. $failureDate= $return;
  893. if(empty($value['lot'])) return [false, '批号不能为空'];
  894. if(empty($value['iQuantity']) || ! is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  895. $iBody[] = [
  896. "iRowNo" => $key + 1,
  897. "cInvCode" => $value['materialCode'], // 存货编码
  898. "cBatch" => $value['lot'] ?? "", // 批号
  899. "iQuantity" => $value['iQuantity'],
  900. "iinvexchrate" => 0,
  901. "iNum" => 0,
  902. "dMadeDate" => $productDate, // 生产日期
  903. "dVDate" => $failureDate, // 失效日期
  904. ];
  905. }
  906. // 2. 组织表头 (iHead)
  907. $iHead = [
  908. "cWhCode" => $data['warehouseCode'], // 仓库编码
  909. "cRdCode" => "0109", // 收发类别 其他入
  910. "cDepCode" => "", // 部门
  911. "IsVerify" => ! isset($data['IsVerify']) ?? false, // 是否自动审核
  912. "cMemo" => "接口生成",
  913. "dDate" => $data['dDate'] ?? date("Y-m-d"), // 单据日期
  914. ];
  915. // 4. 封装成要求的数组结构
  916. $final_data = [
  917. [
  918. "Inum" => "OtherIn",
  919. "Data" => [
  920. "iHead" => $iHead,
  921. "iBody" => $iBody
  922. ]
  923. ]
  924. ];
  925. // 5. 准备发送请求
  926. $host = $data['u8_data']['host'] ?? "";
  927. $token = $data['u8_data']['token'] ?? "";
  928. $url = $host . "/api/OtherIn/Add";
  929. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  930. // 执行提交 (假设你已经定义了 post_helper1)
  931. $json = json_encode($final_data);
  932. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  933. if(! $status) return [false, $result];
  934. if(! isset($result['code'])) return [false, '其他入库单生成失败'];
  935. if($result['code'] != 0) return [false, $result['msg']];
  936. return [true, $result];
  937. }
  938. public function otherOut($data) {
  939. // 1. 基础校验
  940. if (empty($data['warehouseCode'])) return [false, '仓库编码不能为空'];
  941. if (empty($data['detail'])) return [false, '明细数据不能为空'];
  942. $iBody = [];
  943. foreach ($data['detail'] as $key => $value) {
  944. if(empty($value['materialCode'])) return [false, '存货编码不能为空'];
  945. // 格式化生产日期
  946. $productDate = null;
  947. if(!empty($value['productDate'])){
  948. $productDate = $this->formatAndValidateDate($value['productDate']);
  949. if(!$productDate) return [false, '生产日期格式错误'];
  950. }
  951. // 格式化失效日期
  952. $failureDate = null;
  953. if(!empty($value['failureDate'])){
  954. $failureDate = $this->formatAndValidateDate($value['failureDate']);
  955. if(!$failureDate) return [false, '失效日期格式错误'];
  956. }
  957. if(empty($value['iQuantity']) || !is_numeric($value['iQuantity'])) return [false, '存货数量错误'];
  958. $iBody[] = [
  959. "iRowNo" => $key + 1,
  960. "cInvCode" => $value['materialCode'], // 存货编码
  961. "cBatch" => $value['lot'] ?? "", // 批号
  962. "iQuantity" => $value['iQuantity'],
  963. "iinvexchrate" => 0,
  964. "dMadeDate" => $productDate, // 生产日期
  965. "dVDate" => $failureDate, // 失效日期
  966. ];
  967. }
  968. // 2. 组织表头 (iHead)
  969. $iHead = [
  970. "cWhCode" => $data['warehouseCode'], // 仓库编码
  971. "cRdCode" => "0209", // 收发类别:其他出库
  972. "cDepCode" => "", // 部门
  973. "IsVerify" => isset($data['IsVerify']) ?? false, // 是否自动审核
  974. "cMemo" => "接口生成",
  975. "dDate" => $data['dDate'] ?? date("Y-m-d"), // 单据日期
  976. ];
  977. // 4. 封装成要求的数组结构 - Inum 改为 OtherOut
  978. $final_data = [
  979. [
  980. "Inum" => "OtherOut",
  981. "Data" => [
  982. "iHead" => $iHead,
  983. "iBody" => $iBody
  984. ]
  985. ]
  986. ];
  987. // 5. 准备发送请求
  988. $host = $data['u8_data']['host'] ?? "";
  989. $token = $data['u8_data']['token'] ?? "";
  990. // 地址改为 OtherOut
  991. $url = $host . "/api/OtherOut/Add";
  992. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  993. // 执行提交
  994. $json = json_encode($final_data);
  995. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  996. if(! $status) return [false, "网络请求失败: " . $result];
  997. if(! isset($result['code'])) return [false, '其他出库单生成失败'];
  998. if($result['code'] != 0) return [false, "U8错误: " . $result['msg']];
  999. return [true, $result];
  1000. }
  1001. public function saleReturn1($data) {
  1002. if(empty($data['orderId'])) return [false, '销售退货单ID不能为空'];
  1003. // 1. 获取销售退货单/订单信息
  1004. $service = new U8ThirtyPartyDatabaseServerService();
  1005. $order = $service->getXsThOrder($data['orderId']);
  1006. if(empty($order)) return [false, '销售退货单信息不存在'];
  1007. $iBody = [];
  1008. foreach ($order['details'] as $key => $value) {
  1009. // 确保数量为负数(红字单据要求)
  1010. $qty = (float)($value['iQuantity'] ?? 0);
  1011. $redQty = $qty > 0 ? -$qty : $qty;
  1012. $iBody[] = [
  1013. "iRowNo" => $key + 1,
  1014. "cInvCode" => $value['cInvCode'], // 存货编码
  1015. "cPosition" => $value['cPosition'] ?? "", // 货位
  1016. "cBatch" => $value['cBatch'] ?? "", // 批号
  1017. "iinvexchrate" => (float)($value['iinvexchrate'] ?? 1),
  1018. "iQuantity" => $redQty, // 红字数量
  1019. "iNQuantity" => $redQty, // 实退数量
  1020. "iNum" => (float)($value['iNum'] ?? 0),
  1021. "iNNum" => (float)($value['iNum'] ?? 0),
  1022. // 核心关联:如果是参照发货单退货,需要 iDLsID (发货单子表Autoid)
  1023. "iDLsID" => $value['iDLsID'] ?? 0,
  1024. "dMadeDate" => $value['dMDate'], // 生产日期
  1025. "dVDate" => $value['dvDate'], // 失效日期
  1026. ];
  1027. }
  1028. // 2. 组织表头 (iHead)
  1029. $iHead = [
  1030. "IsVerify" => $data['IsVerify'] ?? false, // 是否自动审核
  1031. "bIsRedVouch" => true, // 核心:必须为 true (红字单据)
  1032. "cWhCode" => $order['cWhCode'], // 仓库
  1033. "cRdCode" => $order['cRdCode'], // 收发类别(如:销售出库/退货)
  1034. "cMemo" => "接口生成",
  1035. "cSource" => "发货单", // 来源类型
  1036. "cSTCode" => $order['cSTCode'], // 销售类型
  1037. "DLCode" => $order['cDLCode'], // 关联的发货单号
  1038. "dDate" => date("Y-m-d"), // 单据日期
  1039. ];
  1040. // 3. 封装成 SaleOut 结构
  1041. $final_data = [
  1042. [
  1043. "Inum" => "SaleOut",
  1044. "Data" => [
  1045. "iHead" => $iHead,
  1046. "iBody" => $iBody
  1047. ]
  1048. ]
  1049. ];
  1050. // 4. 发送请求
  1051. $host = $data['u8_data']['host'] ?? "";
  1052. $token = $data['u8_data']['token'] ?? "";
  1053. $url = $host . "/api/SaleOut/Add";
  1054. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1055. $json = json_encode($final_data);
  1056. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1057. if(! $status) return [false, $result];
  1058. if(! isset($result['code'])) return [false, '红字销售出库单生成失败'];
  1059. if($result['code'] != 0) return [false, $result['msg']];
  1060. return [true, $result];
  1061. }
  1062. public function saleReturn($data) {
  1063. if(empty($data['orderId'])) return [false, '销售退货单ID不能为空'];
  1064. // 1. 获取销售退货单信息 (DispatchList & DispatchLists)
  1065. $service = new U8ThirtyPartyDatabaseServerService();
  1066. $order = $service->getXsThOrder($data['orderId']);
  1067. if(empty($order)) return [false, '销售退货单信息不存在'];
  1068. // --- 核心修改:按仓库分组 ---
  1069. $groupDetails = [];
  1070. foreach ($order['details'] as $item) {
  1071. $whCode = $item['cWhCode'] ?? $order['cWhCode']; // 优先取明细里的仓库,没有则取主表的
  1072. $groupDetails[$whCode][] = $item;
  1073. }
  1074. $final_data = [];
  1075. // 2. 遍历每个仓库分组,生成各自的单据
  1076. foreach ($groupDetails as $whCode => $details) {
  1077. $iBody = [];
  1078. foreach ($details as $index => $value) {
  1079. $qty = (float)($value['iQuantity'] ?? 0);
  1080. $redQty = $qty > 0 ? -$qty : $qty; // 强制红字
  1081. $iBody[] = [
  1082. "iRowNo" => $index + 1,
  1083. "cInvCode" => $value['cInvCode'],
  1084. "cPosition" => $value['cPosition'] ?? "",
  1085. "cBatch" => $value['cBatch'] ?? "",
  1086. "iinvexchrate" => (float)($value['iinvexchrate'] ?? 1),
  1087. "iQuantity" => $redQty,
  1088. "iNQuantity" => $redQty,
  1089. "iNum" => (float)($value['iNum'] ?? 0),
  1090. "iNNum" => (float)($value['iNum'] ?? 0),
  1091. "iDLsID" => $value['iDLsID'] ?? 0, // 关键:关联发货单行ID
  1092. "dMadeDate" => $value['dMDate'] ?? null,
  1093. "dVDate" => $value['dvDate'] ?? null,
  1094. ];
  1095. }
  1096. // 组织该单据的表头
  1097. $iHead = [
  1098. "IsVerify" => true,
  1099. "bIsRedVouch" => true,
  1100. "cWhCode" => $whCode, // 当前分组的仓库
  1101. "cRdCode" => "0204",
  1102. "cMemo" => "接口生成",
  1103. "cSource" => "发货单",
  1104. "cSTCode" => $order['cSTCode'],
  1105. "DLCode" => $order['cDLCode'] ?? "",
  1106. "dDate" => date("Y-m-d"),
  1107. ];
  1108. // 放入大数组
  1109. $final_data[] = [
  1110. "Inum" => "SaleOut",
  1111. "Data" => [
  1112. "iHead" => $iHead,
  1113. "iBody" => $iBody
  1114. ]
  1115. ];
  1116. }
  1117. // 3. 发送请求
  1118. $host = $data['u8_data']['host'] ?? "";
  1119. $token = $data['u8_data']['token'] ?? "";
  1120. $url = $host . "/api/SaleOut/Add";
  1121. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1122. $json = json_encode($final_data);
  1123. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1124. if(!$status) return [false, $result];
  1125. if(!isset($result['code'])) return [false, '红字销售出库单生成失败'];
  1126. if($result['code'] != 0) return [false, $result['msg']];
  1127. return [true, $result];
  1128. }
  1129. //检验单生成产成品入库单
  1130. public function productInByZj($data){
  1131. $record = $data['record'];
  1132. $payload = $data['payload'];
  1133. $id = $record['u8_id'];
  1134. $type = $data['type'];
  1135. // 数量逻辑判断
  1136. $num = ($type == 1) ? (float)$payload['hg_quantity'] : (float)$payload['rb_quantity'];
  1137. // 获取单据 产品检验单
  1138. $service = new U8ThirtyPartyDatabaseServerService();
  1139. $order = $service->getJyOrder($id);
  1140. if(empty($order)) return [false, '产品检验单不存在'];
  1141. // 获取单据 生产订单子表 (用于获取生产订单累计数量 iNQuantity)
  1142. $product_detail = $service->getScDetails($order['SOURCEID']);
  1143. if(empty($product_detail)) return [false, '生产订单子表数据不存在'];
  1144. // u8 token 获取
  1145. list($status, $msg) = $this->getToken();
  1146. if(! $status) return [false, $msg];
  1147. // 组织 ProductIn 结构
  1148. $tmp = [
  1149. "Inum" => "ProductIn",
  1150. "Data" => [
  1151. "iHead" => [
  1152. "cWhCode" => (string)($order['cWhCode'] ?? "06"), // 产成品库
  1153. "cRdCode" => "0103", // 入库类别
  1154. "cDepCode" => $order['CINSPECTDEPCODE'],
  1155. "cMemo" => "接口生成",
  1156. "cSource" => "产品检验单",
  1157. "cBusType" => "成品入库",
  1158. "cMPoCode" => (string)$order['SOURCECODE'], // 生产订单号
  1159. "cChkCode" => (string)$order['CCHECKCODE'], // 检验单号
  1160. "dDate" => date("Y-m-d"),
  1161. "IsVerify" => true,
  1162. ],
  1163. "iBody" => []
  1164. ]
  1165. ];
  1166. // 组织表体
  1167. $tmp["Data"]["iBody"][] = [
  1168. "iRowNo" => 1,
  1169. "cInvCode" => (string)($order['CINVCODE'] ?? ''),
  1170. "iinvexchrate" => (float)($order['FCHANGRATE'] ?? 0), // 换算率转为数字
  1171. "iQuantity" => (float)$num, // 本次入库数量
  1172. "iNQuantity" => (float)($product_detail['Qty'] ?? 0), // 生产订单总数量
  1173. "iNum" => 0, // 辅计数量
  1174. "iNNum" => 0, // 生产订单辅计总数量
  1175. "iMPoIds" => (int)($order['SOURCEAUTOID'] ?? 0), // 生产订单子表ID,必须是整型
  1176. "cBatch" => (string)($order['CBATCH'] ?? ''),
  1177. "dMadeDate" => (string)($order['DPRODATE'] ?? ''),
  1178. "dVDate" => (string)($order['DVDATE'] ?? ''),
  1179. ];
  1180. $final_data = [$tmp];
  1181. // 调用参数
  1182. $host = $msg['host'] ?? "";
  1183. $token = $msg['token'] ?? "";
  1184. $url = $host . "/api/ProductIn/Add";
  1185. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1186. $json = json_encode($final_data);
  1187. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1188. if(! $status) return [false, $result];
  1189. if(! isset($result['code'])) return [false, '产成品入库单生成失败'];
  1190. if($result['code'] != 0) return [false, $result['msg']];
  1191. return [true, ''];
  1192. }
  1193. public function productInByZj2($data){
  1194. $record = $data['record'];
  1195. $payload = $data['payload'];
  1196. $id = $record['u8_id'];
  1197. $type = $data['type'];
  1198. if($type == 1){
  1199. $num = $payload['hg_quantity'];
  1200. }else{
  1201. $num = $payload['rb_quantity'];
  1202. }
  1203. //获取单据 产品检验单
  1204. $service = new U8ThirtyPartyDatabaseServerService();
  1205. $order = $service->getJyOrder($id);
  1206. if(empty($order)) return [false, '产品检验单不存在'];
  1207. //获取单据 生产订单子表
  1208. $product_detail = $service->getScDetails($order['SOURCEID']);
  1209. if(empty($product_detail)) return [false, '生产订单子表数据不存在'];
  1210. //u8 token
  1211. list($status, $msg) = $this->getToken();
  1212. if(! $status) return [false, $msg];
  1213. $tmp = [
  1214. "Inum" => "ProductIn",
  1215. "Data" => [
  1216. "iHead" => [
  1217. "IsVerify" => true,
  1218. "cWhCode" => "06", // 产成品库
  1219. "cRdCode" => '0103', // 入库类别 产成品入库
  1220. "cDepCode" => $order['CINSPECTDEPCODE'] ?? '', // 部门
  1221. "cMemo" => "接口生成",
  1222. "cSource" => "产品检验单",
  1223. "cBusType" => "成品入库",
  1224. "cMPoCode" => $order['SOURCECODE'], // 生产订单号
  1225. "cChkCode" => $order['CCHECKCODE'], // 检验单号
  1226. "dDate" => date("Y-m-d"),
  1227. "bIsRedVouch" => false, // 如果是红字入库请设为true
  1228. "bCalPrice" => true, // 是否由接口计算金额
  1229. ],
  1230. "iBody" => []
  1231. ]
  1232. ];
  1233. //一个检验单只有一行
  1234. $tmp["Data"]["iBody"][] = [
  1235. "iRowNo" => 1,
  1236. "cInvCode" => $order['cInvCode'] ?? '',
  1237. "cAssUnit" => $order['CUNITID'] ?? '',
  1238. "cPosition" => $order['cPosition'] ?? '',
  1239. "cBatch" => $order['cBatch'] ?? '',
  1240. "iinvexchrate" => $order['FCHANGRATE'] ?? 0,
  1241. "iQuantity" => $num, // 数量
  1242. "iNQuantity" => $product_detail['Qty'], // 生产订单产品数量
  1243. "iMPoIds" => $order['SOURCEAUTOID'] ?? 0, // 生产订单子表ID
  1244. "dMadeDate" => $order['DPRODATE'] ?? '', // 生产日期
  1245. "iMassDate" => $order['IMASSDATE'], // 保质期
  1246. "cMassUnit" => $order['CMASSUNIT'], // 保质期单位
  1247. "dVDate" => $order['DVDATE'] ?? '', // 失效日期
  1248. ];
  1249. $final_data = [$tmp];
  1250. //调用所需
  1251. $host = $msg['host'] ?? "";
  1252. $token = $msg['token'] ?? "";
  1253. //产成品入库单生成
  1254. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  1255. $url = $host . "/api/ProductIn/Add";
  1256. $json = json_encode($final_data);
  1257. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1258. if(! $status) return [false, $result];
  1259. if(! isset($result['code'])) return [false, '产成品入库单生成并审核失败'];
  1260. if($result['code'] != 0) return [false, $result['msg']];
  1261. return [true, ''];
  1262. }
  1263. public function productInByZj1($data){
  1264. $record = $data['record'];
  1265. $payload = $data['payload'];
  1266. $id = $record['u8_id'];
  1267. $type = $data['type'];
  1268. // 确定入库数量
  1269. $num = ($type == 1) ? $payload['hg_quantity'] : $payload['rb_quantity'];
  1270. // 1. 获取检验单数据(用于提取物料、批次、仓库等基本信息,即便不参照也需要这些数据)
  1271. $service = new U8ThirtyPartyDatabaseServerService();
  1272. $order = $service->getJyOrder($id);
  1273. if(empty($order)) return [false, '产品检验单不存在'];
  1274. // 2. 获取 U8 Token
  1275. list($status, $msg) = $this->getToken();
  1276. if(! $status) return [false, $msg];
  1277. // 3. 组织产成品入库单 (不参照模式)
  1278. $tmp = [
  1279. "Inum" => "ProductIn",
  1280. "Data" => [
  1281. "iHead" => [
  1282. "IsVerify" => true, // 自动审核
  1283. "cWhCode" => $order['CWHCODE'] ?? "06", // 产成品库
  1284. "cRdCode" => '0103', // 产成品入库类别编码 (根据U8实际修改,通常为12)
  1285. "cDepCode" => $order['CINSPECTDEPCODE'],
  1286. "cMemo" => "接口生成",
  1287. "cSource" => "库存", // 关键:设为库存即为手动入库
  1288. "cBusType" => "成品入库",
  1289. "dDate" => date("Y-m-d"),
  1290. "bIsRedVouch" => false,
  1291. "bCalPrice" => true,
  1292. ],
  1293. "iBody" => [
  1294. [
  1295. "iRowNo" => 1,
  1296. "cInvCode" => $order['CINVCODE'] ?? '',
  1297. "cBatch" => $order['CBATCH'] ?? '',
  1298. "iinvexchrate" => $order['FCHANGRATE'] ?? 0,
  1299. "iQuantity" => $num, // 入库数量
  1300. "iNQuantity" => $num, // 保持一致
  1301. "dMadeDate" => $order['DPRODATE'] ?? '', // 生产日期
  1302. "dVDate" => $order['DVDATE'] ?? '', // 失效日期
  1303. ]
  1304. ]
  1305. ]
  1306. ];
  1307. $final_data = [$tmp];
  1308. // 4. 调用接口
  1309. $host = $msg['host'] ?? "";
  1310. $token = $msg['token'] ?? "";
  1311. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1312. $url = $host . "/api/ProductIn/Add";
  1313. $json = json_encode($final_data);
  1314. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1315. if(! $status) return [false, $result];
  1316. if(! isset($result['code'])) return [false, '产成品入库单生成失败'];
  1317. if($result['code'] != 0) return [false, $result['msg']];
  1318. return [true, ''];
  1319. }
  1320. //检验单生成其他入库单
  1321. public function otherInByZj($data){
  1322. $record = $data['record'];
  1323. $payload = $data['payload'];
  1324. $id = $record['u8_id'];
  1325. $num = $payload['hg_not_quantity'];
  1326. //获取单据 检验单
  1327. $service = new U8ThirtyPartyDatabaseServerService();
  1328. $order = $service->getJyOrder($id);
  1329. if(empty($order)) return [false, '检验单不存在'];
  1330. //u8 token
  1331. list($status, $msg) = $this->getToken();
  1332. if(! $status) return [false, $msg];
  1333. $tmp = [
  1334. "Inum" => "OtherIn",
  1335. "Data" => [
  1336. "iHead" => [
  1337. "IsVerify" => true,
  1338. "cWhCode" => "53", // 成品不良品库
  1339. "cRdCode" => '0109', // 入库类别 其他入库
  1340. "cDepCode" => '', // 部门
  1341. "cMemo" => "接口生成",
  1342. "dDate" => date("Y-m-d"),
  1343. ],
  1344. "iBody" => []
  1345. ]
  1346. ];
  1347. //一个检验单只有一行
  1348. $tmp["Data"]["iBody"][] = [
  1349. "iRowNo" => 1,
  1350. "cInvCode" => $order['CINVCODE'] ?? '',
  1351. "cAssUnit" => $order['CUNITID'] ?? '',
  1352. "cPosition" => $order['cPosition'] ?? '',
  1353. "cBatch" => $order['CBATCH'] ?? '',
  1354. "iinvexchrate" => $order['FCHANGRATE'] ?? 0,
  1355. "iQuantity" => $num, // 数量
  1356. "dMadeDate" => $order['DPRODATE'] ?? '', // 生产日期
  1357. "dVDate" => $order['DVDATE'] ?? '',
  1358. ];
  1359. $final_data = [$tmp];
  1360. //调用所需
  1361. $host = $msg['host'] ?? "";
  1362. $token = $msg['token'] ?? "";
  1363. //产成品入库单生成
  1364. $header = ["Authorization: {$token}",'Content-Type:application/json'];
  1365. $url = $host . "/api/OtherIn/Add";
  1366. $json = json_encode($final_data);
  1367. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1368. if(! $status) return [false, $result];
  1369. if(! isset($result['code'])) return [false, '其他入库单生成并审核失败'];
  1370. if($result['code'] != 0) return [false, $result['msg']];
  1371. return [true, ''];
  1372. }
  1373. //检验单生产采购入库单
  1374. public function purchaseInByZj2($data)
  1375. {
  1376. $record = $data['record'];
  1377. $payload = $data['payload'];
  1378. $id = $record['u8_id']; // 这里的 ID 应该是检验单主表的 ID
  1379. $type = $data['type'];
  1380. if($type == 1){
  1381. $num = $payload['hg_quantity'];
  1382. }else{
  1383. $num = $payload['rb_quantity'];
  1384. }
  1385. // 1. 获取检验单明细 (需要包含来源到货单子表ID: SOURCEAUTOID)
  1386. $service = new U8ThirtyPartyDatabaseServerService();
  1387. $order = $service->getJyOrder2($id);
  1388. if(empty($order)) return [false, '检验单不存在'];
  1389. // 2. 获取 U8 Token
  1390. list($status, $msg) = $this->getToken();
  1391. if(! $status) return [false, $msg];
  1392. // 3. 组织采购入库单 (PurchaseIn) 结构
  1393. $tmp = [
  1394. "Inum" => "PurchaseIn",
  1395. "Data" => [
  1396. "iHead" => [
  1397. "IsVerify" => true, // 自动审核
  1398. "bCalPrice" => true, // 自动计算价格
  1399. "cWhCode" => $order['CWHCODE'], // 仓库编码
  1400. "cRdCode" => "0101", // 入库类别:原材料采购入库
  1401. "cSource" => "来料检验单", // 来源
  1402. "cBusType" => "普通采购",
  1403. "cChkCode" => $order['CCHECKCODE'] ?? '', // 关联检验单号
  1404. "cMemo" => "接口生成",
  1405. "dDate" => date("Y-m-d"),
  1406. ],
  1407. "iBody" => []
  1408. ]
  1409. ];
  1410. // 4. 组织表体
  1411. $tmp["Data"]["iBody"][] = [
  1412. "iRowNo" => 1,
  1413. "cInvCode" => $order['CINVCODE'] ?? '',
  1414. "cPosition" => $order['cPosition'] ?? '',
  1415. "cBatch" => $order['CBATCH'],
  1416. "iinvexchrate" => (float)($order['FCHANGRATE'] ?? 1),
  1417. "iQuantity" => $num, // 应收数量(入库数量)
  1418. "iNQuantity" => $num, // 实收数量
  1419. "iArrsId" => $order['SOURCEAUTOID'], // 子表id
  1420. "dMadeDate" => $order['DPRODATE'], // 生产日期
  1421. "dVDate" => $order['DVDATE'], // 失效日期
  1422. "iUnitCost" => $order['iCost'] ?? 0,
  1423. "iPrice" => round(($order['iCost'] ?? 0) * $num, 2),
  1424. "iTaxUnitPrice"=> $order['iOriTaxCost'] ?? 0,
  1425. "iSum" => round(($order['iOriTaxCost'] ?? 0) * $num, 2),
  1426. "iTaxRate" => $order['iTaxRate'] ?? 0,
  1427. ];
  1428. $final_data = [$tmp];
  1429. // 5. 调用 API
  1430. $host = $msg['host'] ?? "";
  1431. $token = $msg['token'] ?? "";
  1432. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1433. $url = $host . "/api/PurchaseIn/Add";
  1434. $json = json_encode($final_data);
  1435. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1436. if(! $status) return [false, $result];
  1437. if(! isset($result['code'])) return [false, '采购入库单生成失败'];
  1438. if($result['code'] != 0) return [false, $result['msg']];
  1439. return [true, ''];
  1440. }
  1441. public function purchaseInByZj1($data)
  1442. {
  1443. $record = $data['record'];
  1444. $payload = $data['payload'];
  1445. $type = $data['type'];
  1446. // 确定入库数量
  1447. $num = ($type == 1) ? $payload['hg_quantity'] : $payload['rb_quantity'];
  1448. // 1. 获取基础数据 (即使不参照,我们也需要从检验单拿到物料、仓库、供应商等基本信息)
  1449. $service = new U8ThirtyPartyDatabaseServerService();
  1450. $order = $service->getJyOrder2($record['u8_id']);
  1451. if(empty($order)) return [false, '检验单不存在'];
  1452. // 2. 获取 U8 Token
  1453. list($status, $msg) = $this->getToken();
  1454. if(! $status) return [false, $msg];
  1455. // 3. 组织采购入库单 (不参照模式)
  1456. $tmp = [
  1457. "Inum" => "PurchaseIn",
  1458. "Data" => [
  1459. "iHead" => [
  1460. "IsVerify" => true, // 自动审核
  1461. "bCalPrice" => true, // 自动计算价格
  1462. "PriceCalKey" => "iOriTaxCost", // 以含税单价为准计算
  1463. "cWhCode" => "01", // 仓库
  1464. "cVenCode" => $order['CVENCODE'], // 供应商(不参照时必填)
  1465. "cPTCode" => "01", // 采购类型:委外或普通
  1466. "cRdCode" => "0101", // 入库类别编码
  1467. "cDepCode" => $order['CDEPCODE'] ?? '', // 部门
  1468. "cBusType" => "普通采购",
  1469. "cSource" => "库存", // 设为库存即为不参照模式
  1470. "cMemo" => "接口生成",
  1471. "dDate" => date("Y-m-d"),
  1472. "cExch_Name" => "人民币",
  1473. "iExchRate" => 1,
  1474. ],
  1475. "iBody" => [
  1476. [
  1477. "iRowNo" => 1,
  1478. "cInvCode" => $order['CINVCODE'],
  1479. "cPosition" => $order['CPOSITION'] ?? '',
  1480. "cBatch" => $order['CBATCH'] ?? '',
  1481. "iQuantity" => $num, // 数量
  1482. "iNQuantity" => $num, // 实收数量
  1483. "iOriTaxCost" => $order['iOriTaxCost'], // 含税单价
  1484. "iTaxRate" => $order['iTaxRate'], // 税率
  1485. "dMadeDate" => $order['DPRODATE'], // 生产日期
  1486. "dVDate" => $order['DVDATE'], // 失效日期
  1487. // 注意:不参照时,不要传 iArrsId
  1488. ]
  1489. ]
  1490. ]
  1491. ];
  1492. $final_data = [$tmp];
  1493. // 4. 调用 API
  1494. $host = $msg['host'] ?? "";
  1495. $token = $msg['token'] ?? "";
  1496. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1497. $url = $host . "/api/PurchaseIn/Add";
  1498. $json = json_encode($final_data);
  1499. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1500. if(! $status) return [false, $result];
  1501. if(! isset($result['code'])) return [false, '采购入库单生成失败'];
  1502. if($result['code'] != 0) return [false, $result['msg']];
  1503. return [true, ''];
  1504. }
  1505. public function purchaseInByZj($data)
  1506. {
  1507. $record = $data['record'];
  1508. $payload = $data['payload'];
  1509. $type = $data['type'];
  1510. // 确定入库数量
  1511. $num = ($type == 1) ? (float)$payload['hg_quantity'] : (float)$payload['rb_quantity'];
  1512. // 1. 获取基础数据 (检验单信息)
  1513. $service = new U8ThirtyPartyDatabaseServerService();
  1514. $order = $service->getJyOrder2($record['u8_id']);
  1515. if(empty($order)) return [false, '检验单不存在'];
  1516. // 2. 获取 U8 Token
  1517. list($status, $msg) = $this->getToken();
  1518. if(! $status) return [false, $msg];
  1519. // 3. 组织采购入库单 (参照来料检验单模式)
  1520. $tmp = [
  1521. "Inum" => "PurchaseIn",
  1522. "Data" => [
  1523. "iHead" => [
  1524. "IsVerify" => true, // 示例中为 false
  1525. "cWhCode" => (string)($order['CWHCODE'] ?? "01"),
  1526. "cDepCode" => (string)($order['CDEPCODE']),
  1527. "cVenCode" => (string)$order['CVENCODE'],
  1528. "cRdCode" => "0101",
  1529. "iExchRate" => (float)($order['IEXCHRATE'] ?? 1.0),
  1530. "iTaxRate" => (float)($order['ITAXRATE'] ?? 13.0),
  1531. "cExch_Name" => "人民币",
  1532. "cSource" => "来料检验单", // 匹配示例中的来源
  1533. "cBusType" => "普通采购",
  1534. "cMemo" => "接口生成",
  1535. "dDate" => date("Y-m-d"),
  1536. "cChkCode" => (string)$order['CCHECKCODE'] // 检验单号
  1537. ],
  1538. "iBody" => [
  1539. [
  1540. "iRowNo" => 1,
  1541. "cInvCode" => (string)$order['CINVCODE'],
  1542. "iQuantity" => (float)$num, // 本次入库实收数量
  1543. "iNum" => 0,
  1544. "iNQuantity" => (float)($order['IQUANTITY'] ?? $num), // 检验单关联数量
  1545. "iNNum" => 0,
  1546. // "iCheckIdBaks" => (int)$order['ICHECKIDBAKS'],
  1547. "iArrsId" => $order['SOURCEAUTOID'], // 子表id
  1548. "cBatch" => (string)($order['CBATCH'] ?? ''),
  1549. "dMadeDate" => (string)($order['DPRODATE'] ?? ''),
  1550. "dVDate" => (string)($order['DVDATE'] ?? ''),
  1551. ]
  1552. ]
  1553. ]
  1554. ];
  1555. $final_data = [$tmp];
  1556. // 4. 调用 API
  1557. $host = $msg['host'] ?? "";
  1558. $token = $msg['token'] ?? "";
  1559. $header = ["Authorization: {$token}", 'Content-Type:application/json'];
  1560. $url = $host . "/api/PurchaseIn/Add";
  1561. $json = json_encode($final_data);
  1562. list($status, $result) = $this->post_helper1($url, $json, $header, 30);
  1563. if(! $status) return [false, $result];
  1564. if(! isset($result['code'])) return [false, '采购入库单生成失败'];
  1565. if($result['code'] != 0) return [false, $result['msg']];
  1566. return [true, ''];
  1567. }
  1568. public function post_helper1($url, $data, $header = [], $timeout = 20){
  1569. Log::channel('apiLog')->info('POST', ["api" => $url , "param" => json_decode($data,true) ,"header" => $header]);
  1570. $ch = curl_init();
  1571. curl_setopt($ch, CURLOPT_URL, $url);
  1572. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1573. curl_setopt($ch, CURLOPT_ENCODING, '');
  1574. curl_setopt($ch, CURLOPT_POST, 1);
  1575. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
  1576. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  1577. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  1578. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
  1579. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
  1580. curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10);
  1581. if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  1582. $r = curl_exec($ch);
  1583. if ($r === false) {
  1584. // 获取错误号
  1585. $errorNumber = curl_errno($ch);
  1586. // 获取错误信息
  1587. $errorMessage = curl_error($ch);
  1588. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  1589. Log::channel('apiLog')->info('POST结果', ["message" => $message ]);
  1590. return [false, $message];
  1591. }
  1592. curl_close($ch);
  1593. $return = json_decode($r, true);
  1594. unset($r);
  1595. Log::channel('apiLog')->info('POST结果', ["message" => $return ]);
  1596. return [true, $return];
  1597. }
  1598. function validateProductDate($dateStr) {
  1599. // SQL Server 常用的 datetime 格式包含 .v (毫秒)
  1600. // 注意:这里的格式必须严格对应 " 2025-12-13 00:00:00.000"
  1601. // 如果字符串开头有空格,格式字符串里也要留空格
  1602. $format = 'Y-m-d H:i:s.v';
  1603. $d = \DateTime::createFromFormat($format, $dateStr);
  1604. // 检查是否转换成功,并且转换后的格式与原字符串完全一致
  1605. return $d && $d->format($format) === $dateStr;
  1606. }
  1607. /**
  1608. * 校验并格式化日期
  1609. * 如果日期合法,返回格式化后的字符串;如果不合法,返回 false
  1610. */
  1611. public function formatAndValidateDate($dateStr) {
  1612. try {
  1613. // DateTime 构造函数会自动识别多种日期格式
  1614. // trim($dateStr) 用于去除可能存在的首尾空格
  1615. $d = new \DateTime(trim($dateStr));
  1616. // 统一转换为 SQL Server 喜欢的格式: 2026-03-11 00:00:00.000
  1617. return $d->format('Y-m-d H:i:s.v');
  1618. } catch (\Exception $e) {
  1619. // 如果传入的字符串无法解析为日期,会抛出异常
  1620. return false;
  1621. }
  1622. }
  1623. }