diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java index 1432ba2a..916c69a3 100644 --- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java +++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/incomeInvoiceData/service/impl/IncomeInvoiceServiceImpl.java @@ -30,11 +30,14 @@ import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.ssl.SSLContextBuilder; import org.apache.http.util.EntityUtils; +import org.checkerframework.checker.units.qual.A; import org.springframework.beans.factory.annotation.Autowired; import com.hzya.frame.basedao.service.impl.BaseService; import javax.net.ssl.SSLContext; import java.io.IOException; +import java.math.BigDecimal; +import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; @@ -59,6 +62,7 @@ public class IncomeInvoiceServiceImpl extends BaseService jnlist = incomeInvoiceDao.queryZtzz(jnentity); + if(jnlist != null && jnlist.size() == 1){ + dyAloneId = jnlist.get(0); + }else { + return BaseResult.getSuccessMessageEntity("未查询到当月的财报数据,不推送"); + } + //查询去年当帐套组织 + IncomeInvoiceEntity qnentity = new IncomeInvoiceEntity(); + qnentity.setDataSourceCode(""); + qnentity.setSysData(qncjzq); + qnentity.setOrgCode(ztbm); + List qnlist = incomeInvoiceDao.queryZtzz(qnentity); + if(qnlist != null && qnlist.size() == 1){ + qnAloneId = qnlist.get(0); + }else { + logger.info("未查询到去年当期的财报数据"); + } + + //查询当月的财报数据 + IncomeInvoiceEntity jnquerydata = new IncomeInvoiceEntity(); + jnquerydata.setDataSourceCode(""); + jnquerydata.setAloneId(dyAloneId.getAloneId()); + List dydataList = incomeInvoiceDao.queryByAloneId(jnquerydata); + if(dydataList != null && dydataList.size() == 1){ + dydata = dydataList.get(0); + }else { + return BaseResult.getSuccessMessageEntity("未查询到当月的财报数据,不推送"); + } + //查询去年当期的财报数据 + if(qnAloneId != null){ + //查找去年数据 + IncomeInvoiceEntity qnquerydata = new IncomeInvoiceEntity(); + qnquerydata.setDataSourceCode(""); + qnquerydata.setAloneId(qnAloneId.getAloneId()); + List qndataList = incomeInvoiceDao.queryByAloneId(qnquerydata); + if(qndataList != null && qndataList.size() == 1){ + qndata = qndataList.get(0); + } + } + //拼接数据 + JSONObject sendData = new JSONObject(); + sendData.put("accessKey",accessKey); + long timestamp = System.currentTimeMillis(); + sendData.put("timestamp",timestamp); + sendData.put("taskNo",rwbm); + sendData.put("period",cjzq); + + JSONArray reportList = new JSONArray(); + + JSONObject zcfzb = new JSONObject();//资产负债表 + zcfzb.put("period",cjzq); + zcfzb.put("reportType",1); + JSONArray reportSubjects1 = new JSONArray(); + setDataToArray("subjectName","12312",1,reportSubjects1); + zcfzb.put("reportSubjects",reportSubjects1); + + JSONObject llb = new JSONObject();//利润表 + llb.put("period",cjzq); + llb.put("reportType",2); + JSONArray reportSubjects2 = new JSONArray(); + llb.put("reportSubjects",reportSubjects2); + + JSONObject xjll = new JSONObject();//现金流量表 + xjll.put("period",cjzq); + xjll.put("reportType",3); + JSONArray reportSubjects3 = new JSONArray(); + xjll.put("reportSubjects",reportSubjects3); + reportList.add(zcfzb); + reportList.add(llb); + reportList.add(xjll); + sendData.put("reportList",reportList); + String a = YzfSignUtil.signRequest(sendData,accessSecret); + sendData.put("sign",a); - //JSONObject jsonObject = requestJson.getJSONObject("jsonStr"); - //String cdDate = null; - //String jnDate = null; - //String qnDate = null; - //String orgCode = "X0644"; - //IncomeInvoiceEntity dyAloneId = null; - //JSONObject dydata = null; - //JSONObject qndata = null; - //IncomeInvoiceEntity qnAloneId = null; - //if(requestJson.getString("orgCode") != null){ - // orgCode = requestJson.getString("orgCode"); - //} - //SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM"); - //if(requestJson.getString("year") != null && requestJson.getString("month") != null){ - // cdDate = requestJson.getString("year") + "-" + requestJson.getString("month"); - // if("13".equals(requestJson.getString("month"))){ - // cdDate = requestJson.getString("year") + "-12"; - // qnDate = (requestJson.getInteger("year")-1) + "-12"; - // }else { - // cdDate = requestJson.getString("year") + "-" + requestJson.getString("month"); - // qnDate = (requestJson.getInteger("year")-1) + "-" + requestJson.getString("month"); - // } - //}else { - // cdDate = sdf.format(new Date()); - // jnDate = sdf.format(new Date()); - // Calendar calendar = Calendar.getInstance(); - // calendar.setTime(new Date()); - // calendar.add(Calendar.YEAR, -1); - // Date qn = calendar.getTime(); - // qnDate = sdf.format(qn); - //} - // - ////查询帐套组织 - //IncomeInvoiceEntity jnentity = new IncomeInvoiceEntity(); - //jnentity.setDataSourceCode(""); - //jnentity.setSysData(jnDate); - //jnentity.setOrgCode(orgCode); - //List jnlist = incomeInvoiceDao.queryZtzz(jnentity); - //if(jnlist != null && jnlist.size() == 1){ - // dyAloneId = jnlist.get(0); - //}else { - // return BaseResult.getSuccessMessageEntity("未查询到当月的财报数据,不推送"); - //} - ////查询帐套组织 - //IncomeInvoiceEntity qnentity = new IncomeInvoiceEntity(); - //qnentity.setDataSourceCode(""); - //qnentity.setSysData(jnDate); - //qnentity.setOrgCode(orgCode); - //List qnlist = incomeInvoiceDao.queryZtzz(qnentity); - //if(qnlist != null && qnlist.size() == 1){ - // qnAloneId = qnlist.get(0); - //}else { - // logger.info("未查询到当月的财报数据"); - //} - // - ////查找今年数据 - //IncomeInvoiceEntity jnquerydata = new IncomeInvoiceEntity(); - //jnquerydata.setDataSourceCode(""); - //jnquerydata.setAloneId(dyAloneId.getAloneId()); - //List dydataList = incomeInvoiceDao.queryByAloneId(jnquerydata); - //if(dydataList != null && dydataList.size() == 1){ - // dydata = dydataList.get(0); - //}else { - // return BaseResult.getSuccessMessageEntity("未查询到当月的财报数据,不推送"); - //} - // - // //查找去年数据 - //IncomeInvoiceEntity qnquerydata = new IncomeInvoiceEntity(); - //qnquerydata.setDataSourceCode(""); - //qnquerydata.setAloneId(qnAloneId.getAloneId()); - //List qndataList = incomeInvoiceDao.queryByAloneId(qnquerydata); - //if(qndataList != null && qndataList.size() == 1){ - // qndata = qndataList.get(0); - //} - ////拼接数据 - // - // - // - // - //return BaseResult.getSuccessMessageEntity("执行成功"); + Map headers = new HashMap<>(); + headers.put("Content-Type", "application/json; charset=utf-8"); + String returndata = sendPost(url, headers, sendData.toJSONString()); + if (returndata != null && JSONObject.isValidObject(returndata)) { + JSONObject dataJson = JSONObject.parseObject(returndata); + if(dataJson != null && dataJson.getString("code") != null && "0".equals( dataJson.getString("code"))){ + JSONObject data = dataJson.getJSONObject("result"); + if(data != null ){ + if(data != null && data.getString("resultCode") != null && "0".equals( data.getString("resultCode"))){ + return BaseResult.getSuccessMessageEntity("执行成功"); + }else { + return BaseResult.getFailureMessageEntity("发送失败:"+returndata); + } + }else { + return BaseResult.getFailureMessageEntity("发送失败:"+returndata); + } + }else { + return BaseResult.getFailureMessageEntity("发送失败:"+returndata); + } + }else { + return BaseResult.getFailureMessageEntity("发送失败:"+returndata); + } + } - return null; + private void setDataToArray(String subjectName, String value, Integer valueType, JSONArray reportSubjects) { + if(value != null && !"".equals(value)){ + JSONObject jsonObject = new JSONObject(); + jsonObject.put("subjectName",subjectName); + jsonObject.put("value",new BigDecimal(value)); + jsonObject.put("valueType",valueType); + reportSubjects.add(jsonObject); + } } }