完善内部对接功能

fs-danaus

2021-06-17 5e6d268612d15a91dfe21bf4a38e0c15b4c36ad2

 src/com/yc/action/panval/PanelCommitAction.java

@@ -1,34 +1,31 @@
package com.yc.action.panval;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.URLDecoder;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.yc.action.BaseAction;
import com.yc.exception.CallBackMessage;
import com.yc.multiData.SpObserver;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import com.yc.factory.FactoryBean;
import com.yc.multiData.SpObserver;
import com.yc.open.mutual.entity.T120201Entity;
import com.yc.open.mutual.schedule.DeleteThread;
import com.yc.open.mutual.service.MutualServiceIfc;
import com.yc.service.BaseService;
import com.yc.service.impl.DBHelper;
import com.yc.service.panel.SqlDBHelperIfc;
import com.yc.service.panel.SystemSettingsDao;
import com.yc.utils.SessionKey;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.URLDecoder;
import java.sql.SQLException;
import java.util.*;

/**
 * 
@@ -42,6 +39,10 @@
    SystemSettingsDao sDao;
    @Autowired
    SqlDBHelperIfc sDbHelperIfc;
   @Autowired
   ThreadPoolTaskExecutor threadPoolExecutor;
   @Autowired
   MutualServiceIfc mutualServiceIfc;
    /**
     * 判断凭证状态
     * 
@@ -299,7 +300,10 @@
               //执行删除单据
               //sql = deletesql + sql;
               SpObserver.setDBtoInstance("_"+dbid);
               final T120201Entity entity = mutualServiceIfc.getT120201ByDistributor(doccode);
               sDbHelperIfc.doSql(listSql);
               //----增加内部对接推送处理,删除销售订单同时需要把推送到总部的销售订单也要删除  by danaus 2021/6/16 10:47
               threadPoolExecutor.execute(new DeleteThread(Integer.parseInt(formid), formType_int, entity, dbid));
               return callBackMessage.sendSuccessMessage("成功");
            } catch (DataAccessException e2) {
               return callBackMessage.sendErrorMessage(e2.getCause().getMessage());