CUCU2/src/custom/service/StockAutoDockDispatchService.java

package service;

import beans.accountbalance.Accountbalance;
import beans.accountbalance.CashbillEntity;
import beans.parameter.Parameter;
import beans.remind.Remind;
import beans.uploaderpdata.UploadDataToERP_HY;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import common.Controller;
import common.ServiceController;
import common.YosException;
import common.data.Row;
import common.data.Rows;
import common.data.RowsMap;
import common.data.SQLFactory;
import common.parameter.properties;
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import restcontroller.webmanage.executorService.Executor;
import utility.ERPDocking;
import utility.tools.WebRequest;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;

public class StockAutoDockDispatchService extends ServiceController {

    private static Logger logger = Logger.getLogger(DispatchAutoCloseService.class);
    String[] siteids = {"CCYOSG", "DLB"};

    @Override
    public void serviceRun() throws Exception {
        for (String siteid : siteids) {
            if (dbConnect.runSqlQuery("SELECT 1 from  sys_site WHERE siteid='" + siteid + "'").isEmpty()) {
                continue;
            }
            System.out.println("销售出库单自动同步任务");
            Properties yosProperties = properties.getYosProperties();
            if (yosProperties.getProperty("system.runmode.debug").equalsIgnoreCase("false")) {

                ArrayList<String> sqlList = new ArrayList<>();
                ERPDocking erpDocking = new ERPDocking(siteid);
                JSONArray ErpSainvoices = erpDocking.queryErpStockBill(500, 1, "销售出库");
                JSONArray flags = new JSONArray();
                if (!ErpSainvoices.isEmpty()) {
                    for (Object ErpSainvoice : ErpSainvoices) {
                        JSONObject erpSainvoice = (JSONObject) ErpSainvoice;
                        // 经销商编号
                        String fagentnum = erpSainvoice.getString("fagentnum");
                        long sys_enterpriseid = 0;
                        if (dbConnect.runSqlQuery("select sys_enterpriseid from sa_agents where siteid='" + siteid + "' and  agentnum='" + fagentnum + "'").isNotEmpty()) {
                            sys_enterpriseid = dbConnect.runSqlQuery("select sys_enterpriseid from sa_agents where siteid='" + siteid + "' and  agentnum='" + fagentnum + "'").get(0).getLong("sys_enterpriseid");
                        } else {
                            JSONObject flag = new JSONObject();
                            flag.put("syncyosid", erpSainvoice.getStringValue("syncyosid"));
                            flag.put("fupdateflag", "4");
                            flag.put("fupdatewarnlog", "yos中不存在【" + fagentnum + "】经销商");
                            flags.add(flag);
                            continue;
                        }
                        //单号
                        String fbillnum = erpSainvoice.getString("fbillnum");
                        // 单据日期
                        String fdate = erpSainvoice.getString("fdate");
                        // 会计期间
                        //  String fperiod = content.getString("fperiod");
                        // 红蓝字
                        String frb = erpSainvoice.getString("frb");
                        // 表头仓库
                        // String fstockno = content.getString("fstockno");
                        // 单据类型明细
                        //String ftypemx = content.getString("ftypemx");
                        // 单据状态
                        String fstatus = erpSainvoice.getString("fstatus");
                        // 制单人
                        String createby = erpSainvoice.getString("createby");
                        // 制单日期
                        String createdate = erpSainvoice.getString("createdate");
//                    // 审核人
//                    String checkby = erpSainvoice.getString("checkby");
//                    // 审核日期
//                    String checkdate = erpSainvoice.getString("checkdate");
                        // 备注
                        String fnotes = erpSainvoice.getString("fnote");
                        String fsourcebillno = erpSainvoice.getString("fsourcebillno");
                        String fsourcetype = erpSainvoice.getString("fsourcetype");
                        long sa_dispatchid = 0;
                        if(siteid.equalsIgnoreCase("CCYOSG")){
                            if (StringUtils.isNotBlank(fsourcebillno)) {
                                if (dbConnect.runSqlQuery("select sa_dispatchid from sa_dispatch where siteid='" + siteid + "' and  billno='" + fsourcebillno + "'").isNotEmpty()) {
                                    sa_dispatchid = dbConnect.runSqlQuery("select sa_dispatchid from sa_dispatch where siteid='" + siteid + "' and  billno='" + fsourcebillno + "'").get(0).getLong("sa_dispatchid");
                                } else {
                                    JSONObject flag = new JSONObject();
                                    flag.put("syncyosid", erpSainvoice.getStringValue("syncyosid"));
                                    flag.put("fupdateflag", "4");
                                    flag.put("fupdatewarnlog", "yos中不存在对应的发货单");
                                    flags.add(flag);
                                    continue;
                                }
                            } else {
                                JSONObject flag = new JSONObject();
                                flag.put("syncyosid", erpSainvoice.getStringValue("syncyosid"));
                                flag.put("fupdateflag", "4");
                                flag.put("fupdatewarnlog", "yos中不存在对应的发货单");
                                flags.add(flag);
                                continue;
                            }
                        }



                        Long sa_cashbillid = 0L;

                        Rows stockbillRows = dbConnect.runSqlQuery("select * from st_stockbill where siteid='" + siteid + "' and status='审核' and billno='" + fbillnum + "'");
                        Long st_stockbillid = 0L;
                        if (stockbillRows.isEmpty() && "审核".equals(fstatus)) {
                            /**
                             * DRP不存在销售出库单，且中间表状态为审核且不在删除状态时，DRP中需新增该销售出库单
                             */
                            SQLFactory sqlFactory = new SQLFactory(this, "销售出库单新增");
                            st_stockbillid = createTableID("st_stockbill");
                            sqlFactory.addParameter("siteid", siteid);
                            sqlFactory.addParameter("st_stockbillid", st_stockbillid);
                            sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
                            sqlFactory.addParameter("billno", fbillnum);
                            sqlFactory.addParameter("type", "销售出库");
                            sqlFactory.addParameter("rb", frb.equals("蓝") ? 1 : 0);
                            sqlFactory.addParameter("billdate", fdate);
                            sqlFactory.addParameter("createby", createby);
                            sqlFactory.addParameter("createdate", getDate(createdate));
                            sqlFactory.addParameter("changeby", createby);
                            sqlFactory.addParameter("changedate", getDate(createdate));
                            sqlFactory.addParameter("checkby", createby);
                            sqlFactory.addParameter("checkdate", getDate(createdate));
                            sqlFactory.addParameter("remarks", fnotes);
                            sqlList.add(sqlFactory.getSQL());

                            JSONArray detailarray = erpSainvoice.getJSONArray("details");
                            StringBuffer str = new StringBuffer();

                            for (Object object : detailarray) {
                                JSONObject jsonObject = (JSONObject) object;
                                if (str.toString().equals("")) {
                                    str.append("'" + jsonObject.getString("fitemno") + "'");
                                } else {
                                    str.append(",'" + jsonObject.getString("fitemno") + "'");
                                }
                            }
                            Rows rows;
                            if (!str.toString().equals("")) {
                                rows = dbConnect.runSqlQuery("select * from plm_item  where siteid='" + siteid + "' and itemno in " + "(" + str.toString() + ")");
                            } else {
                                rows = dbConnect.runSqlQuery("select * from plm_item  where siteid='" + siteid + "' and itemno in('')");
                            }
                            RowsMap itemRowsMap = rows.toRowsMap("itemno");
//                            Rows distiptchRows = dbConnect.runSqlQuery("select t2.price,t1.sa_dispatch_itemsid,t1.rowno,t1.sa_orderitemsid,t2.sa_orderid,t3.sys_enterpriseid,t4.sonum,t5.itemno,t5.itemname from sa_dispatch_items t1 inner join sa_orderitems t2 on t1.sa_orderitemsid=t2.sa_orderitemsid and t1.siteid=t2.siteid inner join sa_dispatch t3 on t1.sa_dispatchid=t3.sa_dispatchid and t1.siteid=t3.siteid left join sa_order t4 on t2.sa_orderid=t4.sa_orderid and t2.siteid=t4.siteid left join plm_item t5 on t1.itemid=t5.itemid and t1.siteid=t5.siteid where t3.status in('审核','复核','关闭') and  t1.siteid='" + siteid + "' and  t1.sa_dispatchid = " + sa_dispatchid);
//                            RowsMap distiptchRowsMap = distiptchRows.toRowsMap("rowno");

//                        Rows aftersalesmagRows = dbConnect.runSqlQuery("select t1.price,t1.sa_aftersalesmag_itemsid,t1.sa_orderitemsid,t2.sa_orderid from sa_aftersalesmag_items t1 inner join sa_orderitems t2 on t1.sa_orderitemsid=t2.sa_orderitemsid and t1.siteid=t2.siteid  where  t1.siteid='"+siteid+"' and  t1.sa_aftersalesmag_itemsid in " + sa_dispatch_itemsids.toString().replace("[", "(").replace("]", ")"));
//                        RowsMap aftersalesmagRowsMap = aftersalesmagRows.toRowsMap("rowno");
                            BigDecimal amountTotal = BigDecimal.ZERO;
                            for (Object object : detailarray) {
                                JSONObject jsonObject = (JSONObject) object;
                                String frownum = jsonObject.getString("finvorownum");
                                String finvonum = jsonObject.getString("finvonum");
                                String fitemno = jsonObject.getString("fitemno");
                                String fbatchno = jsonObject.getString("fbatchno");

                                System.err.println(frownum + ":" + fitemno);
                                BigDecimal fqty = new BigDecimal(jsonObject.getString("fqty"));
                                fqty = fqty.compareTo(BigDecimal.ZERO) < 0 ? fqty.negate() : fqty;
                                //String fdetailstockno = jsonObject.getString("fstockno");
                                //String fbatchno = jsonObject.getString("fbatchno");
                                String fdetailnotes = jsonObject.getString("fnote");
                                SQLFactory sqlFactorydetail = new SQLFactory(this, "销售出库单明细新增");
                                sqlFactorydetail.addParameter("siteid", siteid);
                                sqlFactorydetail.addParameter("st_stockbill_itemsid", createTableID("st_stockbill_items"));
                                sqlFactorydetail.addParameter("st_stockbillid", st_stockbillid);
                                sqlFactorydetail.addParameter("rowno", frownum);
                                sqlFactorydetail.addParameter("remarks", fnotes);
                                if (itemRowsMap.containsKey(fitemno) && itemRowsMap.get(fitemno).isNotEmpty()) {
                                    sqlFactorydetail.addParameter("itemid", itemRowsMap.get(fitemno).get(0).getLong("itemid"));
                                } else {
                                    sqlFactorydetail.addParameter("itemid", 0);
                                }
                                sqlFactorydetail.addParameter("remarks", fdetailnotes);
                                sqlFactorydetail.addParameter("qty", fqty);

                                if (frb.equals("蓝")) {
                                    Rows distiptchRows = dbConnect.runSqlQuery("select t2.price,t1.sa_dispatch_itemsid,t1.rowno,t1.sa_orderitemsid,t2.sa_orderid,t3.sys_enterpriseid,t4.sonum,t5.itemno,t5.itemname from sa_dispatch_items t1 inner join sa_orderitems t2 on t1.sa_orderitemsid=t2.sa_orderitemsid and t1.siteid=t2.siteid inner join sa_dispatch t3 on t1.sa_dispatchid=t3.sa_dispatchid and t1.siteid=t3.siteid left join sa_order t4 on t2.sa_orderid=t4.sa_orderid and t2.siteid=t4.siteid left join plm_item t5 on t1.itemid=t5.itemid and t1.siteid=t5.siteid where t3.status in('审核','复核','关闭') and t3.billno='"+finvonum+"' and  t1.siteid='" + siteid + "' and  t1.rowno = " + frownum);
                                    if (distiptchRows.isNotEmpty()) {
                                        sqlFactorydetail.addParameter("sa_dispatch_itemsid", distiptchRows.get(0).getLong("sa_dispatch_itemsid"));
                                        sqlFactorydetail.addParameter("price", distiptchRows.get(0).getBigDecimal("price"));
                                        amountTotal = amountTotal.add(fqty.multiply(distiptchRows.get(0).getBigDecimal("price")));
                                        sqlFactorydetail.addParameter("amount", fqty.multiply(distiptchRows.get(0).getBigDecimal("price")));
                                        sqlFactorydetail.addParameter("sa_orderitemsid", distiptchRows.get(0).getLong("sa_orderitemsid"));
                                        sqlFactorydetail.addParameter("sa_orderid", distiptchRows.get(0).getLong("sa_orderid"));
                                        System.out.println(amountTotal);
                                        //您的订单【XXX】商品【XXX】工厂已发货，出库单号【XXX】
                                        String message = "您的订单【" + distiptchRows.get(0).getString("sonum") + "】商品【" + distiptchRows.get(0).getString("itemname") + "】工厂已发货，出库单号【" + fbillnum + "】！";
                                        sendMsg(siteid,message, st_stockbillid,distiptchRows.get(0).getLong("sys_enterpriseid"));
                                    } else {
                                        sqlFactorydetail.addParameter("sa_dispatch_itemsid", 0);
                                        sqlFactorydetail.addParameter("price", 0);
                                        sqlFactorydetail.addParameter("amount", 0);
                                        sqlFactorydetail.addParameter("sa_orderitemsid", 0);
                                        sqlFactorydetail.addParameter("sa_orderid", 0);
                                    }
                                }
//                            else {
//                                if (aftersalesmagRowsMap.containsKey(String.valueOf(sainvoicedetailid)) && aftersalesmagRowsMap.get(sainvoicedetailid).isNotEmpty()) {
//                                    logger.info(aftersalesmagRowsMap.get(sainvoicedetailid).get(0).toJsonObject().toString());
//                                    sqlFactorydetail.addParameter("price", aftersalesmagRowsMap.get(sainvoicedetailid).get(0).getBigDecimal("price"));
//                                    sqlFactorydetail.addParameter("amount", fqty.multiply(aftersalesmagRowsMap.get(sainvoicedetailid).get(0).getBigDecimal("price")));
//                                    logger.info(aftersalesmagRowsMap.get(sainvoicedetailid).get(0).getBigDecimal("sa_orderitemsid"));
//                                    logger.info(aftersalesmagRowsMap.get(sainvoicedetailid).get(0).getBigDecimal("sa_orderid"));
//                                    sqlFactorydetail.addParameter("sa_orderitemsid", aftersalesmagRowsMap.get(sainvoicedetailid).get(0).getLong("sa_orderitemsid"));
//                                    sqlFactorydetail.addParameter("sa_orderid", aftersalesmagRowsMap.get(sainvoicedetailid).get(0).getLong("sa_orderid"));
//                                } else {
//                                    sqlFactorydetail.addParameter("price", 0);
//                                    sqlFactorydetail.addParameter("amount", 0);
//                                    sqlFactorydetail.addParameter("sa_orderitemsid", 0);
//                                    sqlFactorydetail.addParameter("sa_orderid", 0);
//                                }
//                            }

                                sqlList.add(sqlFactorydetail.getSQL());
                            }
                            sqlList.add("update st_stockbill set status='审核',checkby='" + createby + "',checkdate=CURRENT_TIMESTAMP where st_stockbillid = " + st_stockbillid + " and siteid='" + siteid + "'");
                            JSONObject flag = new JSONObject();
                            flag.put("syncyosid", erpSainvoice.getStringValue("syncyosid"));
                            flag.put("fupdateflag", "1");
                            flag.put("fupdatewarnlog", "");
                            flags.add(flag);

                        } else if (!stockbillRows.isEmpty() && "审核".equals(fstatus)) {
                            /**
                             * DRP存在销售出库单，且中间表状态为审核且不在删除状态时，DRP中需将当前销售出库单先反审核，修改内容后再进行审核
                             */
                            sqlList.add("update st_stockbill set status='新建',checkby='',checkdate=null where st_stockbillid = " + stockbillRows.get(0).getLong("st_stockbillid") + " and siteid='" + siteid + "'");
                            JSONObject flag = new JSONObject();
                            flag.put("syncyosid", erpSainvoice.getStringValue("syncyosid"));
                            flag.put("fupdateflag", "99");
                            flag.put("fupdatewarnlog", "");
                            flags.add(flag);
                            continue;
                        } else if (!stockbillRows.isEmpty() && "新建".equals(fstatus)) {
                            /**
                             * DRP存在收入凭证，且中间表状态为新建或在删除状态时，DRP中需将当前收入销售出库单先反审核
                             */
                            sqlList.add("update st_stockbill set status='新建',checkby='',checkdate=null where st_stockbillid = " + stockbillRows.get(0).getLong("st_stockbillid") + " and siteid='" + siteid + "'");
                            JSONObject flag = new JSONObject();
                            flag.put("syncyosid", erpSainvoice.getStringValue("syncyosid"));
                            flag.put("fupdateflag", "1");
                            flag.put("fupdatewarnlog", "");
                            flags.add(flag);
                        }
                    }
                }
                if (erpDocking.updateErpupdateFlag(flags).equals("true")) {
                    dbConnect.runSqlUpdate(sqlList);
                    /**
                     * 如单据为新建状态，则，先把单据强行删除掉
                     */
                    dbConnect.runSqlUpdate("delete from st_stockbill_items where st_stockbillid in(select st_stockbillid from st_stockbill where status='新建')");
                    dbConnect.runSqlUpdate("delete from st_stockbill where status='新建'");
                }


            }
        }
    }

    public String getDate(String date) {
        try {
            Date a = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").parse(date);
            return new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(a);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    public void sendMsg(String siteid,String content, Long st_stockbillid, Long sys_enterpriseid) throws YosException {

        ArrayList<Long> userList = getEnterpriseHrs(sys_enterpriseid, siteid).toArrayList("userid", new ArrayList<>());
        Remind remind = new Remind(new Controller(new JSONObject()));
        remind.setTitle("销售出库单消息");
        remind.setContent(content);
        remind.setType("应用");
        remind.setObjectid(st_stockbillid);
        remind.setObjectname("st_stockbill");
        remind.setTouserid(userList);
        remind.sendByDialogMsg().createSys_message();
    }
}