hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增时候先查询，不存在则新增，存在则更新

This commit is contained in:
hecan 2024-08-13 17:38:53 +08:00
parent 1f5dcbd24d
commit 2058ea3d2c
7 changed files with 179 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
service/src/main/java/com/hzya/frame/grpU8/nxproof/glPzml/service/ISenderGlPzmlService.java
View File

@ -93,4 +93,13 @@ public interface ISenderGlPzmlService extends IBaseService<SenderGlPzmlEntity, S
* **/ * **/
JsonResultEntity deleteEntityHealthBureau(JSONObject jsonObject); JsonResultEntity deleteEntityHealthBureau(JSONObject jsonObject);
/**
*
* @content 保存凭证 商学院 确定指标被哪些凭证使用
* @Param
* @Return
* @Author hecan
* @Date 2024/8/13 17:00
* **/
Object saveGlPzmlSxy(JSONObject jsonObject);
} }

67
service/src/main/java/com/hzya/frame/grpU8/nxproof/glPzml/service/impl/SenderGlPzmlServiceImpl.java
View File

@ -3,6 +3,7 @@ package com.hzya.frame.grpU8.nxproof.glPzml.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
@ -35,7 +36,8 @@ import java.util.UUID;
@Service(value = "SenderGlPzmlServiceImpl") @Service(value = "SenderGlPzmlServiceImpl")
public class SenderGlPzmlServiceImpl extends BaseService<SenderGlPzmlEntity, String> implements ISenderGlPzmlService { public class SenderGlPzmlServiceImpl extends BaseService<SenderGlPzmlEntity, String> implements ISenderGlPzmlService {
private static String URLTest="http://39.106.158.149/";//测试环境
private static String URL="http://192.168.42.22/";//正式环境
private ISenderGlPzmlDao senderGlPzmlDao; private ISenderGlPzmlDao senderGlPzmlDao;
@ -664,5 +666,68 @@ public class SenderGlPzmlServiceImpl extends BaseService<SenderGlPzmlEntity, Str
} }
//保存凭证 商学院，指标被哪些凭证使用
@Override
public Object saveGlPzmlSxy(JSONObject jsonObject){
SenderGlPzmlEntity glPzmlEntity = jsonObject.toJavaObject(SenderGlPzmlEntity.class);
if(StrUtil.isEmpty(glPzmlEntity.getKjqj())){
glPzmlEntity.setKjqj(DateUtil.format(new Date(),"yyyyMM"));
}
//获取token
String token = getToken();
if(StrUtil.isEmpty(token)){
return BaseResult.getFailureMessageEntity("token为空，请先获取token");
}
//查询凭证数据
List<SenderGlPzmlEntity> pzmlEntities = senderGlPzmlDao.query(glPzmlEntity);
if(CollectionUtils.isEmpty(pzmlEntities)){
return BaseResult.getSuccessMessageEntity("没有需要同步得凭证",null);
}
for (SenderGlPzmlEntity pzmlEntity : pzmlEntities) {
String pzNum = pzmlEntity.getGsdm() + "_" + pzmlEntity.getZth() + "_" + pzmlEntity.getKjqj() + "_" + pzmlEntity.getPzh();
JSONObject jsonObjectParams=new JSONObject();
jsonObjectParams.put("code",pzmlEntity.getIdpzh());//pzid
jsonObjectParams.put("budgetYear",pzmlEntity.getKjqj().substring(0,4));//预算年度
jsonObjectParams.put("applyDate",DateUtil.format(new Date(),"yyyy-MM-dd"));//日期
jsonObjectParams.put("userCode","");//用户编码
jsonObjectParams.put("depCode","");//部门编码
jsonObjectParams.put("description",pzmlEntity.getPzzy());//说明
jsonObjectParams.put("amount",pzmlEntity.getPzje());//金额
jsonObjectParams.put("pzNum",pzNum);//凭证号 例如：公司代码+账套号+会计期间+凭证号：001_001_202408_付款_1
JSONArray jsonArray=new JSONArray();
jsonArray.add(jsonObjectParams);
JSONObject jsonObjectData=new JSONObject();
jsonObjectData.put("data",jsonArray);
}
return null;
}
//获取token
private String getToken(){
JSONObject jsonObject=new JSONObject();
jsonObject.put("appkey","9832-b00b-babf-4d6b-9e66-f6c1-3541-a0e6");
jsonObject.put("appsecret","fbab-16fc-348e-4151-4814-eb06-1526-5f22");
String params = jsonObject.toJSONString();
logger.info("=========获取凭证token请求参数:{}========",params);
String urlToken="nky/service/session/getAccessToken";
String result = HttpRequest.post(URLTest + urlToken).header("Content-Type", "soap/xml").timeout(30000).body(params).execute().body();
logger.info("=========获取凭证token返回结果:{}========",result);
JSONObject jsonObjectResult=JSONObject.parseObject(result);
String value=jsonObjectResult.getString("value");
if(StrUtil.isNotEmpty(value)){
JSONObject jsonObjectValue = JSONObject.parseObject(value);
String accessToken = jsonObjectValue.getString("accessToken");
logger.info("=========获取得凭证token值为:{}=======",accessToken);
return accessToken;
}
return null;
}
} }

27
service/src/main/java/com/hzya/frame/grpU8/nxproof/glZtcs/service/impl/SenderGlZtcsServiceImpl.java
View File

@ -399,13 +399,26 @@ public class SenderGlZtcsServiceImpl extends BaseService<SenderGlZtcsEntity, Str
receiverGlZtcsEntity.setYkjhfs("0"); receiverGlZtcsEntity.setYkjhfs("0");
receiverGlZtcsEntity.setBkdxszhmc("0"); receiverGlZtcsEntity.setBkdxszhmc("0");
receiverGlZtcsEntity.setMaxzdycount(20); receiverGlZtcsEntity.setMaxzdycount(20);
receiverGlZtcsEntity.setId(receiverGlZtcsEntity.getKjnd()+'-'+receiverGlZtcsEntity.getZtbh()+'-'+receiverGlZtcsEntity.getHsdwdm()); SenderGlZtcsEntity senderGlZtcsEntity=new SenderGlZtcsEntity();
logger.info("==========开始根据账套号为:{}保存账套信息，id为:{}=========",receiverGlZtcsEntity.getZtbh(),receiverGlZtcsEntity.getId()); senderGlZtcsEntity.setKjnd(receiverGlZtcsEntity.getKjnd());
SenderGlZtcsEntity receiverGlZtcsEntity1 = senderGlZtcsDao.saveGlZtcsHealthBureau(receiverGlZtcsEntity); senderGlZtcsEntity.setZtbh(receiverGlZtcsEntity.getZtbh());
JSONObject jsonObject1=new JSONObject(); senderGlZtcsEntity.setHsdwdm(receiverGlZtcsEntity.getHsdwdm());
jsonObject1.put("status","200"); List<SenderGlZtcsEntity> senderGlZtcsEntities = queryEntityPageHealthBureau(senderGlZtcsEntity);
jsonObject1.put("ztcs",receiverGlZtcsEntity1); if(CollectionUtils.isEmpty(senderGlZtcsEntities)){
return jsonObject1; receiverGlZtcsEntity.setId(receiverGlZtcsEntity.getKjnd()+'-'+receiverGlZtcsEntity.getZtbh()+'-'+receiverGlZtcsEntity.getHsdwdm());
logger.info("==========开始根据账套号为:{}保存账套信息，id为:{}=========",receiverGlZtcsEntity.getZtbh(),receiverGlZtcsEntity.getId());
SenderGlZtcsEntity receiverGlZtcsEntity1 = senderGlZtcsDao.saveGlZtcsHealthBureau(receiverGlZtcsEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("ztcs",receiverGlZtcsEntity1);
return jsonObject1;
}else {
SenderGlZtcsEntity receiverGlZtcsEntity1 = senderGlZtcsDao.updateGlZtcsHealthBureau(receiverGlZtcsEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("ztcs",receiverGlZtcsEntity1);
return jsonObject1;
}
}catch (Exception e){ }catch (Exception e){
logger.info("根据账套编号:{}保存GROU8账套信息失败:{}",receiverGlZtcsEntity.getZtbh(),e.getMessage()); logger.info("根据账套编号:{}保存GROU8账套信息失败:{}",receiverGlZtcsEntity.getZtbh(),e.getMessage());
return BaseResult.getFailureMessageEntity("保存GROU8账套信息失败"); return BaseResult.getFailureMessageEntity("保存GROU8账套信息失败");

28
service/src/main/java/com/hzya/frame/grpU8/nxproof/glxmzl/service/impl/SenderGlXmzlServiceImpl.java
View File

@ -306,13 +306,27 @@ public class SenderGlXmzlServiceImpl extends BaseService<SenderGlXmzlEntity, Str
return BaseResult.getFailureMessageEntity("项目资料名称为空"); return BaseResult.getFailureMessageEntity("项目资料名称为空");
} }
try { try {
receiverGlXmzlEntity.setId(receiverGlXmzlEntity.getGsdm()+'-'+receiverGlXmzlEntity.getKjnd()+'-'+receiverGlXmzlEntity.getXmdm()); SenderGlXmzlEntity senderGlXmzlEntity=new SenderGlXmzlEntity();
logger.info("=======开始根据公司代码:{}保存项目资料，id为:{}",receiverGlXmzlEntity.getGsdm(),receiverGlXmzlEntity.getId()); senderGlXmzlEntity.setGsdm(receiverGlXmzlEntity.getGsdm());
SenderGlXmzlEntity receiverGlXmzlEntitySave = senderGlXmzlDao.saveGlXmzlHealthBureau(receiverGlXmzlEntity); senderGlXmzlEntity.setKjnd(receiverGlXmzlEntity.getKjnd());
JSONObject jsonObject1=new JSONObject(); senderGlXmzlEntity.setXmdm(receiverGlXmzlEntity.getXmdm());
jsonObject1.put("status","200"); List<SenderGlXmzlEntity> senderGlXmzlEntities = queryEntityPageHealthBureau(senderGlXmzlEntity);
jsonObject1.put("xmzl",receiverGlXmzlEntitySave); if(CollectionUtils.isEmpty(senderGlXmzlEntities)){
return jsonObject1; receiverGlXmzlEntity.setId(receiverGlXmzlEntity.getGsdm()+'-'+receiverGlXmzlEntity.getKjnd()+'-'+receiverGlXmzlEntity.getXmdm());
logger.info("=======开始根据公司代码:{}保存项目资料，id为:{}",receiverGlXmzlEntity.getGsdm(),receiverGlXmzlEntity.getId());
SenderGlXmzlEntity receiverGlXmzlEntitySave = senderGlXmzlDao.saveGlXmzlHealthBureau(receiverGlXmzlEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("xmzl",receiverGlXmzlEntitySave);
return jsonObject1;
}else{
logger.info("=======开始根据公司代码:{}更新项目资料，id为:{}",receiverGlXmzlEntity.getGsdm(),receiverGlXmzlEntity.getId());
SenderGlXmzlEntity receiverGlXmzlEntity1 = senderGlXmzlDao.updateGlXmzlHealthBureau(receiverGlXmzlEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("xmzl",receiverGlXmzlEntity1);
return jsonObject1;
}
}catch (Exception e){ }catch (Exception e){
logger.info("根据公司代码:{}保存GROU8项目资料失败:{}",receiverGlXmzlEntity.getGsdm(),e.getMessage()); logger.info("根据公司代码:{}保存GROU8项目资料失败:{}",receiverGlXmzlEntity.getGsdm(),e.getMessage());
return BaseResult.getFailureMessageEntity("保存GROU8项目资料失败"); return BaseResult.getFailureMessageEntity("保存GROU8项目资料失败");

28
service/src/main/java/com/hzya/frame/grpU8/nxproof/pubbmxx/service/impl/SenderPubbmxxServiceImpl.java
View File

@ -330,13 +330,27 @@ public class SenderPubbmxxServiceImpl extends BaseService<SenderPubbmxxEntity, S
return BaseResult.getFailureMessageEntity("建立日期为空"); return BaseResult.getFailureMessageEntity("建立日期为空");
} }
try { try {
receiverPubbmxxEntity.setId(receiverPubbmxxEntity.getGsdm()+'-'+receiverPubbmxxEntity.getKjnd()+'-'+receiverPubbmxxEntity.getBmdm()); SenderPubbmxxEntity senderPubbmxxEntity=new SenderPubbmxxEntity();
logger.info("==========开始保存公司编码为：{}得部门信息，id为:{}=========",receiverPubbmxxEntity.getGsdm(),receiverPubbmxxEntity.getId()); senderPubbmxxEntity.setKjnd(receiverPubbmxxEntity.getKjnd());
SenderPubbmxxEntity receiverPubbmxxEntity1 = senderPubbmxxDao.savePubbmxxHealthBureau(receiverPubbmxxEntity); senderPubbmxxEntity.setGsdm(receiverPubbmxxEntity.getGsdm());
JSONObject jsonObject1=new JSONObject(); senderPubbmxxEntity.setBmdm(receiverPubbmxxEntity.getBmdm());
jsonObject1.put("status","200"); List<SenderPubbmxxEntity> senderPubbmxxEntities = queryEntityPageHealthBureau(senderPubbmxxEntity);
jsonObject1.put("bmxx",receiverPubbmxxEntity1); if(CollectionUtils.isEmpty(senderPubbmxxEntities)){
return jsonObject1; receiverPubbmxxEntity.setId(receiverPubbmxxEntity.getGsdm()+'-'+receiverPubbmxxEntity.getKjnd()+'-'+receiverPubbmxxEntity.getBmdm());
logger.info("==========开始保存公司编码为：{}得部门信息，id为:{}=========",receiverPubbmxxEntity.getGsdm(),receiverPubbmxxEntity.getId());
SenderPubbmxxEntity receiverPubbmxxEntity1 = senderPubbmxxDao.savePubbmxxHealthBureau(receiverPubbmxxEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("bmxx",receiverPubbmxxEntity1);
return jsonObject1;
}else{
logger.info("==========开始更新公司编码为：{}得部门信息，代码为:{}=========",receiverPubbmxxEntity.getGsdm(),receiverPubbmxxEntity.getBmdm());
SenderPubbmxxEntity receiverPubbmxxEntity1 = senderPubbmxxDao.updatePubbmxxHealthBureau(receiverPubbmxxEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("bmxx",receiverPubbmxxEntity1);
return jsonObject1;
}
}catch (Exception e){ }catch (Exception e){
logger.info("保存公司编码为:{}得GROU8部门信息失败:{}",receiverPubbmxxEntity.getGsdm(),e.getMessage()); logger.info("保存公司编码为:{}得GROU8部门信息失败:{}",receiverPubbmxxEntity.getGsdm(),e.getMessage());
return BaseResult.getFailureMessageEntity("保存GROU8部门信息失败"); return BaseResult.getFailureMessageEntity("保存GROU8部门信息失败");

29
service/src/main/java/com/hzya/frame/grpU8/nxproof/pubkjqj/service/impl/SenderPubkjqjServiceImpl.java
View File

@ -332,13 +332,28 @@ public class SenderPubkjqjServiceImpl extends BaseService<SenderPubkjqjEntity, S
return BaseResult.getFailureMessageEntity("会计期间序号为空"); return BaseResult.getFailureMessageEntity("会计期间序号为空");
} }
try { try {
receiverPubkjqjEntity.setId(receiverPubkjqjEntity.getGsdm()+'-'+receiverPubkjqjEntity.getKjnd()+'-'+receiverPubkjqjEntity.getZth()+'-'+receiverPubkjqjEntity.getKjqjxh()); SenderPubkjqjEntity senderPubkjqjEntity=new SenderPubkjqjEntity();
logger.info("==========开始保存账套号为：{}得会计期间，id为:{}=========",receiverPubkjqjEntity.getZth(),receiverPubkjqjEntity.getId()); senderPubkjqjEntity.setZth(receiverPubkjqjEntity.getZth());
SenderPubkjqjEntity pubkjqjEntity = senderPubkjqjDao.savePubkjqjHealthBureau(receiverPubkjqjEntity); senderPubkjqjEntity.setGsdm(receiverPubkjqjEntity.getGsdm());
JSONObject jsonObject1=new JSONObject(); senderPubkjqjEntity.setKjnd(receiverPubkjqjEntity.getKjnd());
jsonObject1.put("status","200"); senderPubkjqjEntity.setKjqjxh(receiverPubkjqjEntity.getKjqjxh());
jsonObject1.put("kjqj",pubkjqjEntity); List<SenderPubkjqjEntity> senderPubkjqjEntities = queryEntityPageHealthBureau(senderPubkjqjEntity);
return jsonObject1; if(CollectionUtils.isEmpty(senderPubkjqjEntities)){
receiverPubkjqjEntity.setId(receiverPubkjqjEntity.getGsdm()+'-'+receiverPubkjqjEntity.getKjnd()+'-'+receiverPubkjqjEntity.getZth()+'-'+receiverPubkjqjEntity.getKjqjxh());
logger.info("==========开始保存账套号为：{}得会计期间，id为:{}=========",receiverPubkjqjEntity.getZth(),receiverPubkjqjEntity.getId());
SenderPubkjqjEntity pubkjqjEntity = senderPubkjqjDao.savePubkjqjHealthBureau(receiverPubkjqjEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("kjqj",pubkjqjEntity);
return jsonObject1;
}else{
logger.info("==========开始更新账套号为：{}得会计期间，id为:{}=========",receiverPubkjqjEntity.getZth(),receiverPubkjqjEntity.getId());
SenderPubkjqjEntity pubkjqjEntity = senderPubkjqjDao.updatePubkjqjHealthBureau(receiverPubkjqjEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("kjqj",pubkjqjEntity);
return jsonObject1;
}
}catch (Exception e){ }catch (Exception e){
logger.info("保存账套号为：{}得GROU8会计期间失败:{}",receiverPubkjqjEntity.getZth(),e.getMessage()); logger.info("保存账套号为：{}得GROU8会计期间失败:{}",receiverPubkjqjEntity.getZth(),e.getMessage());
return BaseResult.getFailureMessageEntity("保存GROU8会计期间失败"); return BaseResult.getFailureMessageEntity("保存GROU8会计期间失败");

27
service/src/main/java/com/hzya/frame/grpU8/nxproof/pubzyxx/service/impl/SenderPubzyxxServiceImpl.java
View File

@ -322,13 +322,26 @@ public class SenderPubzyxxServiceImpl extends BaseService<SenderPubzyxxEntity, S
return BaseResult.getFailureMessageEntity("人员姓名为空"); return BaseResult.getFailureMessageEntity("人员姓名为空");
} }
try { try {
receiverPubzyxxEntity.setId(receiverPubzyxxEntity.getGsdm()+'-'+receiverPubzyxxEntity.getKjnd()+'-'+receiverPubzyxxEntity.getZydm()); SenderPubzyxxEntity senderPubzyxxEntity=new SenderPubzyxxEntity();
logger.info("==========开始保存公司编码为：{}得人员信息，id为:{}=========",receiverPubzyxxEntity.getGsdm(),receiverPubzyxxEntity.getId()); senderPubzyxxEntity.setKjnd(receiverPubzyxxEntity.getKjnd());
SenderPubzyxxEntity receiverPubzyxxEntity1 = senderPubzyxxDao.savePubzyxxHealthBureau(receiverPubzyxxEntity); senderPubzyxxEntity.setGsdm(receiverPubzyxxEntity.getGsdm());
JSONObject jsonObject1=new JSONObject(); senderPubzyxxEntity.setZydm(receiverPubzyxxEntity.getZydm());
jsonObject1.put("status","200"); List<SenderPubzyxxEntity> senderPubzyxxEntities = queryEntityPageHealthBureau(senderPubzyxxEntity);
jsonObject1.put("zyxx",receiverPubzyxxEntity1); if(CollectionUtils.isEmpty(senderPubzyxxEntities)){
return jsonObject1; receiverPubzyxxEntity.setId(receiverPubzyxxEntity.getGsdm()+'-'+receiverPubzyxxEntity.getKjnd()+'-'+receiverPubzyxxEntity.getZydm());
logger.info("==========开始保存公司编码为：{}得人员信息，id为:{}=========",receiverPubzyxxEntity.getGsdm(),receiverPubzyxxEntity.getId());
SenderPubzyxxEntity receiverPubzyxxEntity1 = senderPubzyxxDao.savePubzyxxHealthBureau(receiverPubzyxxEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("zyxx",receiverPubzyxxEntity1);
return jsonObject1;
}else{
SenderPubzyxxEntity receiverPubzyxxEntity1 = senderPubzyxxDao.updatePubzyxxHealthBureau(receiverPubzyxxEntity);
JSONObject jsonObject1=new JSONObject();
jsonObject1.put("status","200");
jsonObject1.put("zyxx",receiverPubzyxxEntity1);
return jsonObject1;
}
}catch (Exception e){ }catch (Exception e){
logger.info("保存公司编码为：{}得GROU8人员信息失败:{}",receiverPubzyxxEntity.getGsdm(),e.getMessage()); logger.info("保存公司编码为：{}得GROU8人员信息失败:{}",receiverPubzyxxEntity.getGsdm(),e.getMessage());
return BaseResult.getFailureMessageEntity("保存GROU8人员信息失败"); return BaseResult.getFailureMessageEntity("保存GROU8人员信息失败");