Merge remote-tracking branch 'origin/main'

arap/META-INF/dev_arap.upm

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="gb2312"?>
+<module name="arap_EJB">
+	<public>
+		<component priority="0" singleton="true" remote="true" tx="CMT" supportAlias="true">
+			<interface>nc.itf.arap.dev.IDevArapBill2R6Service</interface>
+			<implementation>nc.impl.arap.dev.DevArapBill2R6Impl</implementation>
+		</component>
+	</public>
+</module>

arap/src/private/nc/bs/pub/action/N_F2_DELETE.java

@@ -0,0 +1,68 @@
+// Decompiled by DJ v2.9.9.60 Copyright 2000 Atanas Neshkov  Date: 2004-08-10 09:03:08
+// Home Page : http://members.fortunecity.com/neshkov/dj.html  - Check often for new version!
+// Decompiler options: packimports(3) ansi
+// Source File Name:   N_F2_DELETE.java
+
+package nc.bs.pub.action;
+
+import java.util.Hashtable;
+
+import nc.bs.arap.actions.N_BASE_ACTION;
+import nc.bs.framework.common.NCLocator;
+import nc.itf.arap.dev.IDevArapBill2R6Service;
+import nc.vo.arap.gathering.AggGatheringBillVO;
+import nc.vo.arap.gathering.GatheringBillVO;
+import nc.vo.arap.pub.ArapConstant;
+import nc.vo.fipub.exception.ExceptionHandler;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.compiler.PfParameterVO;
+import nccloud.pubitf.arap.arappub.IArapBillPubUtilService;
+
+public class N_F2_DELETE extends N_BASE_ACTION {
+
+    private Hashtable<String, Object> m_keyHas = null;
+
+    /*
+     * 备注：平台编写规则类 接口执行类
+     */
+    public Object runComClass(PfParameterVO paraVo) throws BusinessException {
+        try {
+
+            if (paraVo.m_preValueVos == null) {
+                return null;
+            }
+            Object obj = null;
+            super.m_tmpVo = paraVo;
+            // 权限校验
+            String actionCode = ArapConstant.DELETE;
+            NCLocator.getInstance().lookup(IArapBillPubUtilService.class).interceptorVaildator(paraVo.m_preValueVos, actionCode);
+            // 批量操作
+            setParameter("context", paraVo.m_preValueVos);
+            obj = runClass("nc.bs.arap.actions.GatheringbillDeleteBatchBSAction", "deleteVOs", "&context:nc.vo.pub.AggregatedValueObject[]", paraVo, m_keyHas);
+
+            afterCheck();
+            //调用删除更新合同销售订单更新
+            if(paraVo.m_preValueVo instanceof AggGatheringBillVO){
+                AggGatheringBillVO aggvo = (AggGatheringBillVO)paraVo.m_preValueVo;
+                NCLocator.getInstance().lookup(IDevArapBill2R6Service.class).updateR6Info(aggvo);
+            }
+            return obj;
+        } catch (Exception ex) {
+            throw ExceptionHandler.handleException(this.getClass(), ex);
+        }
+    }
+
+    public String getCodeRemark() {
+        return " arap action script not allowed to modify ,all rights reserved!";
+    }
+
+    protected void setParameter(String key, Object val) {
+        if (m_keyHas == null) {
+            m_keyHas = new Hashtable<String, Object>();
+        }
+        if (val != null) {
+            m_keyHas.put(key, val);
+        }
+    }
+
+}

arap/src/private/nc/impl/arap/dev/DevArapBill2R6Impl.java

@@ -0,0 +1,413 @@
+package nc.impl.arap.dev;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import nc.api.arap.resource.IgnoreSslUtil;
+import nc.bs.dao.BaseDAO;
+import nc.bs.dao.DAOException;
+import nc.bs.trade.business.HYSuperDMO;
+import nc.impl.pubapp.pattern.data.vo.VOUpdate;
+import nc.itf.arap.dev.IDevArapBill2R6Service;
+import nc.jdbc.framework.processor.MapProcessor;
+import nc.vo.arap.gathering.AggGatheringBillVO;
+import nc.vo.arap.gathering.GatheringBillItemVO;
+import nc.vo.bd.defdoc.DefdocVO;
+import nc.vo.cmp.util.StringUtils;
+import nc.vo.pub.BusinessException;
+import nc.vo.pub.lang.UFDouble;
+import nc.vo.pubapp.pattern.pub.MathTool;
+import nc.vo.so.m30.entity.SaleOrderHVO;
+
+import javax.crypto.Mac;
+import javax.crypto.spec.SecretKeySpec;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
+import java.security.InvalidKeyException;
+import java.security.NoSuchAlgorithmException;
+import java.util.*;
+import java.util.zip.GZIPInputStream;
+
+/**
+ * @Classname DevArapBill2R6Impl
+ * @Description TODO
+ * @Version 1.0.0
+ * @Date 2025/7/26 16:08
+ * @Created by ame
+ */
+public class DevArapBill2R6Impl implements IDevArapBill2R6Service {
+    HYSuperDMO dmo = null;
+
+    public HYSuperDMO getSuperDMO() {
+        if (dmo == null) {
+            dmo = new HYSuperDMO();
+        }
+        return dmo;
+    }
+    @Override
+    public void updateR6Info(AggGatheringBillVO aggvo) throws Exception {
+        GatheringBillItemVO[] billItemVOs = (GatheringBillItemVO[]) aggvo.getChildrenVO();
+        String pk_org = (String) aggvo.getParentVO().getAttributeValue("pk_org");
+        String pk_gatherbill = (String) aggvo.getParentVO().getAttributeValue("pk_gatherbill");
+        JSONObject jsonObject=new JSONObject();
+        JSONArray array=new JSONArray();
+        List<SaleOrderHVO> saleOrderHVOList = new ArrayList<>();
+        for (GatheringBillItemVO gatheringBillItemVO : billItemVOs) {
+            JSONObject js_apct = afterChangeMny(gatheringBillItemVO.getSrc_billid(), pk_org, gatheringBillItemVO.getDef6(),
+                    pk_gatherbill);
+            if(js_apct!=null){
+                SaleOrderHVO hvo = (SaleOrderHVO) js_apct.get("erphvo");
+                saleOrderHVOList.add(hvo);
+                js_apct.remove("erphvo");
+                array.add(js_apct);
+            }
+        }
+        if(saleOrderHVOList.isEmpty()){
+            return;
+        }
+        SaleOrderHVO[] update = (SaleOrderHVO[]) new VOUpdate().update(saleOrderHVOList.toArray(new SaleOrderHVO[0]),new String[]{"vdef11","vdef14"});
+        if(array!=null && array.size()>0){
+            jsonObject.put("HTXSDD",array);
+            pushBipCtOrderUpdate(jsonObject,saleOrderHVOList);
+        }
+    }
+    private JSONObject afterChangeMny(String csaleorderid, String pk_org, String ctid, String pk_gatherid) throws BusinessException {
+        try {
+            // 合同id
+            if (StringUtils.isEmpty(ctid)) {
+                return null;
+            }
+            if (StringUtils.isEmpty(csaleorderid)) {
+                return null;
+            }
+            // 获取销售订单表头
+            SaleOrderHVO hvo = (SaleOrderHVO) getSuperDMO().queryByPrimaryKey(SaleOrderHVO.class, csaleorderid);
+            if (hvo == null) {
+                return null;
+            }
+            String vdef9 = hvo.getVdef9();// BIP 合同销售订单id
+            if (StringUtils.isEmpty(vdef9)) {// 为空，不是从bip 生成的
+                return null;
+            }
+            // 合同金额vdef17
+            UFDouble ctmny = new UFDouble(hvo.getVdef17() == null ? "0" : hvo.getVdef17());
+            // 预收比例vdef15
+            UFDouble yfrate = new UFDouble(hvo.getVdef15() == null ? "0" : hvo.getVdef15());
+            UFDouble temp_yf_mny = ctmny.multiply(yfrate);
+            // 发货比例vdef16
+            UFDouble fhrate = new UFDouble(hvo.getVdef16() == null ? "0" : hvo.getVdef16());
+            UFDouble temp_fh_mny = ctmny.multiply(fhrate);
+            // vdef14 预付款标识
+            String vdef14 = "01";// 01无约定预付款
+            // vdef11 发货款标识
+            String vdef11 = "fhk03";// fhk03无约定发货款
+            UFDouble total_mny = UFDouble.ZERO_DBL;// 当前组织下本合同所有收款单金额累计
+            String sum_sql = "select sum(money_cr) as money_cr from ar_gatheritem where def6 not in ('~') and dr=0   and def6='"
+                    + ctid + "'";
+            Map map = (Map) new BaseDAO().executeQuery(sum_sql, new MapProcessor());
+            if (map != null) {
+                 total_mny = map.get("money_cr")==null ? UFDouble.ZERO_DBL:new UFDouble(String.valueOf(map.get("money_cr")));
+//                total_mny = new UFDouble(String.valueOf(map.get("money_cr")));
+            }
+            if ((MathTool.compareTo(yfrate, UFDouble.ZERO_DBL) == 0)) {
+
+            } else {
+                if (MathTool.compareTo(total_mny, temp_yf_mny) >= 0) {// 累计收款金额≥合同金额*预收比例
+                    vdef14 = "02"; // 02有约定已收到预付款
+                } else {
+                    vdef14 = "03";// 03 有约定未收到款
+                }
+            }
+            if ((MathTool.compareTo(fhrate, UFDouble.ZERO_DBL) == 0)) {
+
+            } else {
+                if (MathTool.compareTo(total_mny, temp_fh_mny) >= 0) {// 累计收款金额≥合同金额*发货比例
+                    vdef11 = "fhk01";// fhk01有约定已收到发货款
+                } else {
+                    vdef11 = "fhk02";// fhk02有约定未收到发货款
+                }
+            }
+            DefdocVO[] defdocVOs = (DefdocVO[]) getSuperDMO().queryByWhereClause(DefdocVO.class,
+                    " pk_defdoclist in (select pk_defdoclist from bd_defdoclist where code='xsdd' ) and code='" + vdef14
+                            + "' and dr=0 ");
+            if (defdocVOs != null && defdocVOs.length > 0) {
+                hvo.setVdef14(defdocVOs[0].getPrimaryKey());
+//                hvo.setVdef14(null);
+                hvo.setStatus(1);
+            }
+
+            defdocVOs = (DefdocVO[]) getSuperDMO().queryByWhereClause(DefdocVO.class,
+                    " pk_defdoclist in (select pk_defdoclist from bd_defdoclist where code='FHK' ) and code='" + vdef11
+                            + "' and dr=0 ");
+            if (defdocVOs != null && defdocVOs.length > 0) {
+                hvo.setVdef11(defdocVOs[0].getPrimaryKey());
+//                hvo.setVdef11(null);
+                hvo.setStatus(1);
+            }
+
+            JSONObject js_apct = new JSONObject();
+            js_apct.put("id", hvo.getVdef9());
+            js_apct.put("isShipRecdAmt", vdef11);
+            js_apct.put("isPreRecv", vdef14);
+            js_apct.put("actRecvAmt", hvo.getNreceivedmny().floatValue());
+            js_apct.put("actPreRecvAmt", hvo.getNpreceivemny().floatValue());
+            js_apct.put("erphvo",hvo);
+            return js_apct;
+        } catch (Exception e) {
+            throw new BusinessException(e.getMessage());
+        }
+    }
+    private void pushBipCtOrderUpdate(JSONObject array, List<SaleOrderHVO> saleOrderHVOList) throws BusinessException {
+        String baseUrl = "";
+        Map<String, String> bipParamMap = checkBipParam();
+        if (bipParamMap.isEmpty()) {
+            return ;
+        }
+        baseUrl = bipParamMap.get("baseUrl");
+        String contractSaleOrderUrl = bipParamMap.get("contractSaleOrder");// 开票申请单回传
+        if (StringUtils.isEmpty(contractSaleOrderUrl)) {
+            return ;
+        }
+        Gson gson = new Gson();
+        try {
+            String accessToken = getAccessToken(baseUrl, bipParamMap);
+            if (accessToken != "") {
+                Map<String, String> tokenParam = new HashMap<>();
+                tokenParam.put("access_token", accessToken);
+                Map<String, String> headers = new HashMap<String, String>();
+                headers.put("Content-Type", "application/json");
+                String custUpdateUrl = baseUrl + contractSaleOrderUrl;
+                String resultString = doSendHttp(custUpdateUrl, "POST", tokenParam, "", headers,
+                        array.toJSONString());
+                Map updateMap = gson.fromJson(resultString, Map.class);
+                if ("200".equals(updateMap.get("code"))) {// 保存更新成功后需要更新日志表
+//                    getSuperDMO().updateArray(saleOrderHVOList.toArray(new SaleOrderHVO[0]));
+                } else {
+                    throw new BusinessException("合同销售订单更新失败【"+updateMap.get("message")+"】");
+                }
+            }
+        } catch (Exception e) {
+            throw new BusinessException("合同销售订单更新失败【"+e.getMessage()+"】");
+        }
+    }
+    private Map<String, String> checkBipParam() {
+        Map<String, String> map = new HashMap<String, String>();
+        String strWhere = " pk_defdoclist in (select pk_defdoclist from bd_defdoclist where code='BIP-sq' and dr=0 )  and dr=0";
+        try {
+            DefdocVO[] defdocVOs = (DefdocVO[]) getSuperDMO().queryByWhereClause(DefdocVO.class, strWhere);
+            if (defdocVOs != null && defdocVOs.length > 0) {
+                for (DefdocVO defdocVO : defdocVOs) {
+                    map.put(defdocVO.getCode().trim(), defdocVO.getName());
+                }
+            }
+        } catch (DAOException e) {
+            e.printStackTrace();
+        }
+        return map;
+    }
+
+    private static String doGet(String path, Map<String, String> params) throws IOException {
+        HttpURLConnection conn = null;
+        InputStream is = null;
+        BufferedReader br = null;
+        StringBuilder result = new StringBuilder();
+        try {
+            if (params != null) {
+                String paramStr = "";
+                for (String key : params.keySet()) {
+                    if (!paramStr.isEmpty()) {
+                        paramStr += '&';
+                    }
+                    paramStr += key + '=' + params.get(key);
+                }
+
+                if (path.indexOf('?') > 0) {
+                    path += '&' + paramStr;
+                } else {
+                    path += '?' + paramStr;
+                }
+            }
+            // 创建远程url连接对象
+            URL url = new URL(path);
+            if ("https".equalsIgnoreCase(url.getProtocol())) {// 判定网址是否信任，不信任则调用忽略信任工具类SslUtil
+                IgnoreSslUtil.ignoreSsl();
+            }
+            // 通过远程url连接对象打开一个连接，强转成HTTPURLConnection类
+            conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("GET");
+            // 设置连接超时时间和读取超时时间
+            conn.setConnectTimeout(120000);
+            conn.setReadTimeout(120000);
+            conn.setRequestProperty("Accept", "application/json");
+            // 发送请求
+            conn.connect();
+            // 通过conn取得输入流，并使用Reader读取
+            if (200 == conn.getResponseCode()) {
+                is = conn.getInputStream();
+                br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
+                String line;
+                while ((line = br.readLine()) != null) {
+                    result.append(line);
+                    System.out.println(line);
+                }
+            } else {
+                System.out.println("ResponseCode is an error code:" + conn.getResponseCode());
+            }
+        } catch (MalformedURLException e) {
+            e.printStackTrace();
+        } catch (IOException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result.toString();
+    }
+
+    private String getAccessToken(String baseUrl, Map<String, String> bipParamMap)
+            throws NoSuchAlgorithmException, InvalidKeyException, IOException {
+        String tokenUrl = baseUrl + "/iuap-api-auth/open-auth/selfAppAuth/getAccessToken";
+//				String appKey = "f10c4bf17b1d4e1fb08eb82bf8540eab";
+        String appKey = bipParamMap.get("appKey");
+
+//				String appSecret = "71dc2a58ca378c1a1143231a62e73e75a60e9236";
+        String appSecret = bipParamMap.get("appSecret");
+        String accessToken = "";
+        Map<String, String> params = new HashMap<>();
+
+        params.put("appKey", appKey);
+        String timestamp = String.valueOf(System.currentTimeMillis());
+        params.put("timestamp", timestamp);
+        // 计算签名
+        Map<String, String> treeMap;
+        if (params instanceof TreeMap) {
+            treeMap = params;
+        } else {
+            treeMap = new TreeMap<>(params);
+        }
+        StringBuilder stringBuilder = new StringBuilder();
+        for (Map.Entry<String, String> entry : treeMap.entrySet()) {
+            stringBuilder.append(entry.getKey()).append(entry.getValue());
+        }
+        Mac mac = Mac.getInstance("HmacSHA256");
+
+        mac.init(new SecretKeySpec(appSecret.getBytes(StandardCharsets.UTF_8), "HmacSHA256"));
+        byte[] signData = mac.doFinal(stringBuilder.toString().getBytes(StandardCharsets.UTF_8));
+        String base64String = Base64.getEncoder().encodeToString(signData);
+        String signature = URLEncoder.encode(base64String, "UTF-8");
+        params.put("signature", signature);
+
+        String responseString = doGet(tokenUrl, params);
+
+        Gson gson = new Gson();
+        Map result = gson.fromJson(responseString, Map.class);
+        if ("00000".equals(result.get("code"))) {
+            Map<String, Object> tokenInfo = (Map<String, Object>) result.get("data");
+            accessToken = (String) tokenInfo.get("access_token");
+
+        }
+
+        return accessToken;
+    }
+
+    public static String doSendHttp(String baseUrl, String method, Map<String, String> paramMap, String mediaType,
+                                    Map<String, String> headers, String json) {
+        HttpURLConnection urlConnection = null;
+        InputStream in = null;
+        OutputStream out = null;
+        BufferedReader bufferedReader = null;
+        String result = null;
+        try {
+            StringBuffer sb = new StringBuffer();
+            sb.append(baseUrl);
+            if (paramMap != null) {
+                sb.append("?");
+                for (Map.Entry<String, String> entry : paramMap.entrySet()) {
+                    String key = entry.getKey();
+                    String value = entry.getValue();
+                    sb.append(key + "=" + value).append("&");
+                    baseUrl = sb.toString().substring(0, sb.toString().length() - 1);
+                }
+            }
+            URL urlobj = new URL(baseUrl);
+            if ("https".equalsIgnoreCase(urlobj.getProtocol())) {// 判定网址是否信任，不信任则调用忽略信任工具类SslUtil
+                IgnoreSslUtil.ignoreSsl();
+            }
+            urlConnection = (HttpURLConnection) urlobj.openConnection();
+            urlConnection.setConnectTimeout(50000);
+            urlConnection.setRequestMethod(method);
+            urlConnection.setDoInput(true);
+            urlConnection.setUseCaches(false);
+            // 如果设置了自定义头，则打印它们
+            if (headers != null && !headers.isEmpty()) {
+                for (Map.Entry<String, String> entry : headers.entrySet()) {
+                    urlConnection.addRequestProperty(entry.getKey(), entry.getValue());
+                }
+            }
+            if (json != null && json.length() > 0) {
+                urlConnection.setDoInput(true);
+                urlConnection.setDoOutput(true);
+                out = urlConnection.getOutputStream();
+                out.write(json.getBytes("utf-8"));
+                out.flush();
+            }
+            int resCode = urlConnection.getResponseCode();
+            String ecod = urlConnection.getContentEncoding();
+            if (resCode == HttpURLConnection.HTTP_OK || resCode == HttpURLConnection.HTTP_CREATED
+                    || resCode == HttpURLConnection.HTTP_ACCEPTED) {
+                if (!StringUtils.isEmpty(ecod) && ecod.equals("gzip")) {
+                    in = new GZIPInputStream(urlConnection.getInputStream());
+                } else {
+                    in = urlConnection.getInputStream();
+                }
+            } else {
+                in = urlConnection.getErrorStream();
+            }
+            bufferedReader = new BufferedReader(new InputStreamReader(in, "utf-8"));
+            StringBuffer temp = new StringBuffer();
+            String line = bufferedReader.readLine();
+            while (line != null) {
+                temp.append(line).append("\r\n");
+                line = bufferedReader.readLine();
+            }
+            if (ecod == null || ecod.equals("gzip")) {
+                ecod = Charset.forName("utf-8").name();
+            }
+            result = new String(temp.toString().getBytes("utf-8"), ecod);
+        } catch (Exception e) {
+            JSONObject js = new JSONObject();
+            js.put("", -1);
+            js.put("message", "调用外系统接口失败：" + e.getMessage());
+            result = js.toString();
+            e.printStackTrace();
+        } finally {
+            if (null != bufferedReader) {
+                try {
+                    bufferedReader.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (null != out) {
+                try {
+                    out.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            if (null != in) {
+                try {
+                    in.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+            urlConnection.disconnect();
+        }
+        return result;
+    }
+}

arap/src/public/nc/itf/arap/dev/IDevArapBill2R6Service.java

@@ -0,0 +1,14 @@
+package nc.itf.arap.dev;
+
+import nc.vo.arap.gathering.AggGatheringBillVO;
+
+/**
+ * @Classname IDevArapBill2R6Service
+ * @Description TODO
+ * @Version 1.0.0
+ * @Date 2025/7/26 16:07
+ * @Created by ame
+ */
+public interface IDevArapBill2R6Service {
+    void updateR6Info(AggGatheringBillVO aggvo) throws Exception;
+}