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

丽知：1、客商档案分配过滤公司。

This commit is contained in:
zhengyf 2025-07-03 11:40:00 +08:00
parent 6ed7c74567
commit 1d0ec84e35
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/base/CustdocAutoAllotPluginInitializer.java
View File

@ -17,6 +17,7 @@ import com.hzya.frame.plugin.lets.queryvo.CustdocRequestVo;
import com.hzya.frame.plugin.lets.resultvo.CbdocResultVo;
import com.hzya.frame.plugin.lets.u8cdto.ReusltStrDto;
import com.hzya.frame.plugin.lets.util.PushDataByU8cUtil;
import com.hzya.frame.plugin.lets.util.QueryU8CEntityUtil;
import com.hzya.frame.plugin.lets.util.SaveOrUpdateBusinessLogUtil;
import com.hzya.frame.plugin.lets.util.pushData.Attribute;
import com.hzya.frame.plugin.lets.util.pushData.PushU8CByApiCode;
@ -86,6 +87,8 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
private PushU8CByApiCode pushU8CByApiCode;
@Autowired
private IBdCubasdocDao bdCubasdocDao;
@Autowired
private QueryU8CEntityUtil queryU8CEntityUtil;
@Override
public JsonResultEntity executeBusiness(JSONObject requestJson) throws Exception {
@ -282,7 +285,7 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
try {
ArrayList<CustDocAssginVo> assginvolist = new ArrayList<>();
List<BdCorpEntity> bdCorpEntities = null;
List<BdCorpEntity> corpAll = null;
//查询公司档案
try {
// String corpresponse = pushDataByU8cUtil.pushU8CByCode(OverallConstant.getOverAllValue("bdcorpQuery"), "{}");
@ -295,13 +298,26 @@ public class CustdocAutoAllotPluginInitializer extends PluginBaseEntity {
String data = attribute.getData();
Map map = JSONObject.parseObject(data, Map.class);
Object o = map.get("datas");
bdCorpEntities = JSONObject.parseArray(JSON.toJSONString(o), BdCorpEntity.class);
corpAll = JSONObject.parseArray(JSON.toJSONString(o), BdCorpEntity.class);
} catch (Exception e) {
throw new RuntimeException(e);
}
//过滤公司
List<BdCorpEntity> bdCorpEntities = new ArrayList<>();
//查询需要过滤的公司
String filterCompanyStr = queryU8CEntityUtil.queryBdDefDocByListPk();
String[] splitFilterCompany = filterCompanyStr.split(",");
List<String> asList = Arrays.asList(splitFilterCompany);
for (BdCorpEntity bdCorpEntity : corpAll) {
String unitCode = bdCorpEntity.getUnitcode();
if(!asList.contains(unitCode)){
bdCorpEntities.add(bdCorpEntity);
}
}
for (BdCorpEntity bdCorpEntity : bdCorpEntities) {
CustDocAssginVo custDocAssginVo = new CustDocAssginVo();
custDocAssginVo.setPk_cubasdoc(custcode);