package com.finstone.gjj.dqd.service.imp;
import com.caucho.hessian.client.HessianProxyFactory;
import com.fins.html.Application;
import com.fins.jdbc.DataSourceRoute;
import com.fins.modules.dao.DataBaseHelper;
import com.fins.modules.web.mvc.support.ResponseEntity;
import com.finstone.app.common.service.LogService;
import com.finstone.app.common.util.SignatureUtils;
import com.finstone.app.common.util.XmlUtil;
import com.finstone.gjj.common.service.imp.ImportSupportService;
import com.finstone.gjj.dqd.client.WxsbAxisClient;
import com.finstone.gjj.dqd.protocol.wljk.util.AES;
import com.finstone.gjj.dqd.service.imp.TransService;
import com.finstone.gjj.dqd.support.Constants;
import com.finstone.gjj.dqd.support.DqdPropertyConstants;
import com.finstone.gjj.dqd.support.ResultStatus;
import com.finstone.gjj.dqd.support.ServiceException;
import com.finstone.gjj.dqd.support.util.ClassUtilsEx;
import com.finstone.gjj.dqd.support.util.ParamUtils;
import com.finstone.gjj.dqd.support.util.XmlUtils;
import com.finstone.gjj.dqd.support.util.ZipUtils;
import com.finstone.jwt.support.JwtConsts.JwtServiceError;
import com.tienon.util.FileFieldConv;
import java.lang.reflect.Method;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import java.util.Random;
import net.sf.ehcache.Cache;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
@Service
public class ResponseData {
private static String DEFAULT_CHARSET = "UTF-8";
@Autowired
private TransService transService;
@Autowired
private WxsbAxisClient wxsbAxisClient;
@Autowired
private ImportSupportService importSupportService;
@Autowired
private LogService logService;
private Cache retryInvokeCache;
protected Log logger = LogFactory.getLog(this.getClass());
private String GetXML_By_DB;
private static final String XML_HEAD = "";
public static String getDEFAULT_CHARSET() {
return DEFAULT_CHARSET;
}
public static void setDEFAULT_CHARSET(String default_charset) {
DEFAULT_CHARSET = default_charset;
}
public String getReturnCode(String transCode) {
String retransCode = transCode.substring(0, 2) + this.transService.getReturnTranscode(transCode.substring(2));
return retransCode;
}
public Map getReturnMap(Map m) {
String transcode = String.valueOf(m.get("transcode"));
String appid = String.valueOf(m.get("appid"));
String sGndm = "";
String tranXml = XmlUtils.converter(m);
if(transcode.length() == 9) {
sGndm = transcode.substring(0, 3);
transcode = transcode.substring(3);
}
ResultStatus resultStatus = null;
HashMap r = new HashMap();
Properties setings = Application.getApplicationSettings();
String sXmid = setings.getProperty("zhfw.xmid").toUpperCase();
m.put("xmid", sXmid);
long starttime = (new Date()).getTime();
try {
DataSourceRoute.putAppId("default");
this.transService.doLog(transcode, tranXml, "", "");
resultStatus = this.transService.tranProcMds(appid, transcode, "" + sXmid + "", sGndm, "1");
} catch (ServiceException var26) {
resultStatus.set(var26.getCode(), var26.getMessage());
this.logger.info("getMap业务查询异常>>>>>>>" + var26.getMessage(), var26);
r.put("code", "-1");
r.put("msg", "执行方法异常：" + var26.getMessage());
} catch (Exception var27) {
var27.printStackTrace();
this.logger.info("getMap业务查询异常>>>>>>>" + var27.getMessage(), var27);
r.put("code", "-1");
r.put("msg", "执行方法异常：" + var27.getMessage());
}
if(resultStatus.getCode().equals("0001")) {
String e = this.transService.getClassName(transcode, appid, sXmid);
String[] classArray = e.split("\\.");
try {
String e1 = this.transService.getSjy(transcode, appid, sXmid);
DataSourceRoute.putAppId(e1);
this.logger.info("getMap执行反射开始>>>>>>>");
r = (HashMap)ClassUtilsEx.invokeMethod(classArray[0], classArray[1], m);
if(r.get("code") != null && r.get("msg") != null) {
if(r.get("code").equals("0")) {
r.put("code", "0001");
r.put("msg", "成功返回结果!");
} else {
r.put("code", r.get("code"));
r.put("msg", r.get("msg"));
}
} else if(r.get("code") == null) {
r.put("code", "-1");
r.put("msg", "结果返回异常!");
} else {
boolean code = true;
try {
int code1 = Integer.parseInt(r.get("code").toString());
if(code1 > 0) {
r.put("code", r.get("code"));
r.put("msg", "成功返回结果!");
} else if(code1 == 0) {
r.put("code", "0001");
r.put("msg", "成功返回结果!");
} else if(code1 < 0) {
r.put("code", r.get("code"));
r.put("msg", "结果返回异常!");
}
} catch (Exception var25) {
r.put("code", "-1");
r.put("msg", "结果返回异常!");
}
}
} catch (Exception var28) {
this.logger.info("getMap执行反射异常>>>>>>>" + var28.getMessage(), var28);
var28.printStackTrace();
r.put("code", "-1");
r.put("msg", "反射执行方法异常：" + var28.getMessage());
} finally {
DataSourceRoute.putAppId("default");
}
} else {
this.logger.info("getMap内部异常：>>>>>>>" + resultStatus.getText());
r.put("code", "-1");
r.put("msg", "内部异常：" + resultStatus.getText());
}
r.put("transcode", transcode);
r.put("appid", appid);
r.put("inxml", tranXml);
r.put("blobid", m.get("blobid") == null?"":m.get("blobid").toString());
this.logger.info("写入getReturnMap日志>>>>>>>transcode：" + transcode + "|fwqd:" + appid);
try {
this.transService.savelogs(sGndm, appid, transcode, Integer.valueOf(r.get("code").toString()).intValue(), String.valueOf(r.get("msg")), m.toString(), starttime);
return r;
} catch (Exception var24) {
throw new ServiceException("9999", "记录操作日志错误，请联系管理员！");
}
}
public Map doJava(Map p) {
String testM = "com.finstone.zhfw.ywjk.service.ImpExpFileService.getTemplate";
String[] classArray = testM.split("\\.");
Object r = new HashMap();
try {
r = (Map)ClassUtilsEx.invokeMethod("ImpExpFileService", "getTemplate", p);
} catch (Exception var6) {
var6.printStackTrace();
((Map)r).put("code", "-1");
((Map)r).put("msg", "反射执行方法异常：" + var6.getMessage());
}
return (Map)r;
}
public String getOseqno() {
StringBuffer sb = new StringBuffer();
SimpleDateFormat tempDate = new SimpleDateFormat("yyyyMMddHHmmssSSS");
String datetime = tempDate.format(new Date());
sb.append(datetime);
Random ra = new Random();
for(int j = 0; j < 3; ++j) {
sb.append(ra.nextInt(10));
}
return sb.toString();
}
private String addZero(String str, int len) {
StringBuffer s = new StringBuffer();
s.append(str);
while(s.length() < len) {
s.insert(0, "0");
}
return s.toString();
}
public String doGenPage(String xml) {
boolean tmpStart = false;
String limit_start = StringUtils.substringBetween(xml, "", "");
String limit_length = StringUtils.substringBetween(xml, "", "");
if(StringUtils.isNotBlank(limit_start)) {
int len = Integer.valueOf(StringUtils.defaultIfEmpty(limit_length, "20")).intValue();
int tmpStart1;
if(Integer.valueOf(limit_start).intValue() > 1) {
tmpStart1 = (Integer.valueOf(limit_start).intValue() - 1) * len;
} else {
tmpStart1 = Integer.valueOf(limit_start).intValue() - 1;
}
xml = StringUtils.replace(xml, "" + limit_start + "", "" + (Integer.valueOf(tmpStart1).intValue() + 1) + "");
xml = StringUtils.replace(xml, "" + limit_length + "", "" + String.valueOf(tmpStart1 + len) + "");
}
return xml;
}
public Cache getRetryInvokeCache() {
return this.retryInvokeCache;
}
public void setRetryInvokeCache(Cache retryInvokeCache) {
this.retryInvokeCache = retryInvokeCache;
}
public void setGetXML_By_DB(String getXML_By_DB) {
this.GetXML_By_DB = getXML_By_DB;
}
public String invoke(String inXml) throws ServiceException, Exception {
Properties setings = Application.getApplicationSettings();
String isMutiDS = setings.getProperty("isMutiDS");
return isMutiDS.toUpperCase().equals("TRUE")?ParamUtils.encode(this.doResponseMD(inXml)):ParamUtils.encode(this.doResponse(inXml));
}
public Map invokeAndFile(String inXml, Map filemap) throws ServiceException, Exception {
return this.doResponseMDAndFile(inXml, filemap);
}
private String doResponse(String paramXml) throws ServiceException, Exception {
String inXml = "";
if(Constants.xmlZip.toUpperCase().equals("TRUE")) {
if(Constants.ziptype.toUpperCase().equals("GZIP")) {
inXml = ZipUtils.decompress(paramXml);
} else {
inXml = FileFieldConv.fieldBCDtoASC(paramXml, "GBK");
}
} else {
inXml = paramXml;
}
String iniseqno = "";
String bodyxml = inXml.substring(inXml.indexOf(""), inXml.indexOf("")) + " ";
String transCode = inXml.substring(inXml.indexOf("