| | |
|---|
| | | import com.doumee.dao.business.dao.CompanyMapper; |
|---|
| | | import com.doumee.dao.business.join.MemberJoinMapper; |
|---|
| | | import com.doumee.dao.business.model.*; |
|---|
| | | import com.doumee.dao.system.SystemUserMapper; |
|---|
| | | import com.doumee.dao.system.model.SystemUser; |
|---|
| | | import com.doumee.service.business.ext.ERPSyncService; |
|---|
| | | import com.doumee.service.business.impl.hksync.HkSyncBaseServiceImpl; |
|---|
| | | import com.doumee.service.business.impl.hksync.HkSyncEmpowerServiceImpl; |
|---|
| | |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.commons.collections.CollectionUtils; |
|---|
| | | import org.apache.commons.lang3.StringUtils; |
|---|
| | | import org.checkerframework.checker.units.qual.C; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Service; |
|---|
| | | import org.springframework.transaction.annotation.Transactional; |
|---|
| | |
|---|
| | | @Autowired |
|---|
| | | private ERPSyncService erpSyncService; |
|---|
| | | @Autowired |
|---|
| | | private SystemUserMapper systemUserMapper; |
|---|
| | | @Autowired |
|---|
| | | private SystemDictDataBiz systemDictDataBiz; |
|---|
| | | @Autowired |
|---|
| | | private DataSyncConfig dataSyncConfig; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 绑定海康用户openId |
|---|
| | | * { |
|---|
| | | * "openId" : "ovmre6R7w-vEQCHg52-UN2mV_abI", |
|---|
| | | * "userName" : "13856591439", |
|---|
| | | * "appKey" : "wx173e6caf5abc718a", |
|---|
| | | * "oaId" : "atwl", |
|---|
| | | * "platformName" : "安泰物流园区", |
|---|
| | | * |
|---|
| | | * } |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public String syncHkUserOpenid(Integer id){ |
|---|
| | | SystemUser user = systemUserMapper.selectById(id); |
|---|
| | | if(user == null ||StringUtils.isBlank(user.getOpenid()) ||Constants.equalsInteger(user.getOpenidHkStatus(),Constants.ONE)){ |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | UserOpenidSaveRequest request = new UserOpenidSaveRequest(); |
|---|
| | | request.setUserName(user.getUsername()); |
|---|
| | | request.setAppKey(systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_APPID).getCode()); |
|---|
| | | request.setOaId("atwl"); |
|---|
| | | request.setOpenId(user.getOpenid()); |
|---|
| | | request.setPlatformName(user.getRealname()); |
|---|
| | | BaseResponse<Integer> response = HKService.userOpenidSave(request); |
|---|
| | | if(response!=null &&response.getCode().equals(HKConstants.RESPONSE_SUCCEE) && Constants.equalsInteger(response.getData(),Constants.ONE)){ |
|---|
| | | user.setOpenidHkStatus(Constants.ONE); |
|---|
| | | user.setOpenidHkInfo("绑定成功"); |
|---|
| | | }else{ |
|---|
| | | user.setOpenidHkStatus(Constants.TWO); |
|---|
| | | user.setOpenidHkInfo(response!=null?StringUtils.defaultString(response.getMsg(),"【未知失败原因】"):"绑定失败"); |
|---|
| | | } |
|---|
| | | user.setOpenidHkDate(new Date()); |
|---|
| | | systemUserMapper.updateById(user); |
|---|
| | | return "成功"; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 同步海康组织信息,根据erp同步组织结果，定时检查需要下发到海康的组织信息 |
|---|
| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | Date date = new Date(); |
|---|
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() |
|---|
| | | String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() |
|---|
| | | +systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode(); |
|---|
| | | for(Member c : list){ |
|---|
| | | dealMemberInfoBiz(c,date,path) ; |
|---|
